Demo.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
  1. <?php
  2. namespace app\admin\controller;
  3. use payment\wechat\WechatTransfers;
  4. use think\Response;
  5. use think\Config;
  6. /**
  7. * 示例接口
  8. */
  9. class Demo
  10. {
  11. //如果$noNeedLogin为空表示所有接口都需要登录才能请求
  12. //如果$noNeedRight为空表示所有接口都需要验证权限才能请求
  13. //如果接口已经设置无需登录,那也就无需鉴权了
  14. //
  15. // 无需登录的接口,*表示全部
  16. protected $noNeedLogin = ['*'];
  17. // 无需鉴权的接口,*表示全部
  18. protected $noNeedRight = ['*'];
  19. /**
  20. * 测试方法
  21. *
  22. */
  23. public function test()
  24. {
  25. $batch_name = '测试提现功能';//转账的名称
  26. $out_trade_no = 'lgd'.getUniId();//单号
  27. $money = 1;//金额
  28. $openid = 'o4a9g5ffjsMcXS9wCtTyONqMTdEc';//用户openid
  29. $detail = [];
  30. $transfers = new WechatTransfers();
  31. $detail[] = $transfers->getDetailList($out_trade_no,$money,$batch_name,$openid);
  32. $res = $transfers->transfers($batch_name,$detail);
  33. halt($res);
  34. // $this->tixian($batch_name,$out_trade_no,$money,$openid);
  35. }
  36. public function tixian($batch_name,$out_trade_no,$money,$openid){
  37. $url = 'https://api.mch.weixin.qq.com/v3/transfer/batches';
  38. $pars = [];
  39. $pars['appid'] = config('wxconfig.appId');//直连商户的appid
  40. $pars['out_batch_no'] = 'lg'.date('Ymd').mt_rand(1000, 9999);//商户系统内部的商家批次单号,要求此参数只能由数字、大小写字母组成,在商户系统内部唯一
  41. $pars['batch_name'] = $batch_name;//该笔批量转账的名称
  42. $pars['batch_remark'] = $batch_name;//转账说明,UTF8编码,最多允许32个字符
  43. $pars['total_amount'] = intval($money * 100);//转账总金额 单位为“分”
  44. $pars['total_num'] = 1;//转账总笔数
  45. $pars['transfer_detail_list'][0] = [
  46. 'out_detail_no'=>'lgd'.$out_trade_no,
  47. 'transfer_amount'=>$pars['total_amount'],
  48. 'transfer_remark'=>$batch_name,
  49. 'openid'=>$openid
  50. ];//转账明细列表
  51. $token = $this->getToken($pars);//获取token
  52. $res = $this->https_request($url,json_encode($pars),$token);//发送请求
  53. $resArr = json_decode($res,true);
  54. halt($resArr);
  55. //成功返回
  56. // array(3) {
  57. // ["batch_id"] => string(40) "1030001016101247194272022062900873000000"
  58. // ["create_time"] => string(25) "2022-06-29T10:21:30+08:00"
  59. // ["out_batch_no"] => string(16) "sjzz202206291647001"
  60. // }
  61. }
  62. function https_request($url,$data = null,$token){
  63. $curl = curl_init();
  64. curl_setopt($curl, CURLOPT_URL, (string)$url);
  65. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
  66. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
  67. if (!empty($data)){
  68. curl_setopt($curl, CURLOPT_POST, 1);
  69. curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  70. }
  71. curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
  72. //添加请求头
  73. $headers = [
  74. 'Authorization:WECHATPAY2-SHA256-RSA2048 '.$token,
  75. 'Accept: application/json',
  76. 'Content-Type: application/json; charset=utf-8',
  77. 'User-Agent:Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36',
  78. ];
  79. if(!empty($headers)){
  80. curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
  81. }
  82. $output = curl_exec($curl);
  83. curl_close($curl);
  84. return $output;
  85. }
  86. public function getToken($pars)
  87. {
  88. // $url = 'https://api.mch.weixin.qq.com/v3/certificates';
  89. $url = 'https://api.mch.weixin.qq.com/v3/transfer/batches';
  90. $http_method = 'POST';//请求方法(GET,POST,PUT)
  91. $timestamp = time();//请求时间戳
  92. $url_parts = parse_url($url);//获取请求的绝对URL
  93. $nonce = $timestamp.rand('10000','99999');//请求随机串
  94. $body = json_encode((object)$pars);//请求报文主体
  95. $stream_opts = [
  96. "ssl" => [
  97. "verify_peer"=>false,
  98. "verify_peer_name"=>false,
  99. ]
  100. ];
  101. $apiclient_cert_path = 'https://'.$_SERVER['HTTP_HOST'].'/uploads/apiclient/apiclient_cert.pem';
  102. $apiclient_key_path = 'https://'.$_SERVER['HTTP_HOST'].'/uploads/apiclient/apiclient_key.pem';
  103. $apiclient_cert_arr = openssl_x509_parse(file_get_contents($apiclient_cert_path,false, stream_context_create($stream_opts)));
  104. $serial_no = $apiclient_cert_arr['serialNumberHex'];//证书序列号
  105. $mch_private_key = file_get_contents($apiclient_key_path,false, stream_context_create($stream_opts));//密钥
  106. $merchant_id = config('wxconfig.payMchId');//商户id
  107. $canonical_url = ($url_parts['path'] . (!empty($url_parts['query']) ? "?${url_parts['query']}" : ""));
  108. $message = $http_method."\n".
  109. $canonical_url."\n".
  110. $timestamp."\n".
  111. $nonce."\n".
  112. $body."\n";
  113. openssl_sign($message, $raw_sign, $mch_private_key, 'sha256WithRSAEncryption');
  114. $sign = base64_encode($raw_sign);//签名
  115. $schema = 'WECHATPAY2-SHA256-RSA2048';
  116. $token = sprintf('mchid="%s",nonce_str="%s",timestamp="%d",serial_no="%s",signature="%s"',
  117. $merchant_id, $nonce, $timestamp, $serial_no, $sign);//微信返回token
  118. return $token;
  119. }
  120. }