php实现微信公众号企业转账功能
程序员文章站
2022-05-29 19:39:29
企业付款提供由商户直接付钱至用户微信零钱的能力,支持平台操作及接口调用两种方式,资金到账速度快,使用及查询方便。主要用来解决合理的商户对用户付款需求,比如:保险理赔、彩票兑...
企业付款提供由商户直接付钱至用户微信零钱的能力,支持平台操作及接口调用两种方式,资金到账速度快,使用及查询方便。主要用来解决合理的商户对用户付款需求,比如:保险理赔、彩票兑换等等。
特点
- 发起方式灵活,可通过页面或接口发起
- 微信消息触达,用户及时获知入账详情
- 支持实名校验,判断收款人真实身份
- 通过openid即可实现付款,无需用户敏感隐私信息
- 到账速度快,在发起后,用户可在几分钟内收到付款
企业转账需要到微信商户平台=》产品中心=》企业付款到零钱,开启此功能
下面是程序截图:
第一步:设置配置参数
$url='https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers'; $pars = array(); $pars['mch_appid'] =$this->module['config']['appid']; $pars['mchid']=$this->module['config']['mchid']; $pars['nonce_str'] =random(32); $pars['partner_trade_no'] =time().random(3,1); $pars['openid'] =$openid; $pars['check_name'] ='no_check' ; //$pars['re_user_name'] ='' ; $monet_finall = $price * 100; $pars['amount'] =$monet_finall; //这里是折算成1%的所以要*100 $pars['desc'] ='您已成功提现 '.$price.' 现金'; $pars['spbill_create_ip'] =$this->module['config']['ip']; ksort($pars, sort_string); $string1 = ''; foreach ($pars as $k => $v) { $string1 .= "{$k}={$v}&"; } $string1 .= "key=".$this->module['config']['password']; $pars['sign'] = strtoupper(md5($string1)); $xml = array2xml($pars); $extras = array(); $extras['curlopt_cainfo'] = attachment_root . '/withdraw/cert/rootca.pem.' . $_w['uniacid']; $extras['curlopt_sslcert'] = attachment_root . '/withdraw/cert/apiclient_cert.pem.' . $_w['uniacid']; $extras['curlopt_sslkey'] = attachment_root . '/withdraw/cert/apiclient_key.pem.' . $_w['uniacid']; $procresult = null;
第二步:curl请求微信服务器
load()->func('communication'); $resp = ihttp_request($url, $xml, $extras);
其中ihttp_request函数内容是:
function ihttp_request($url, $post = '', $extra = array(), $timeout = 60) { $urlset = parse_url($url); if (empty($urlset['path'])) { $urlset['path'] = '/'; } if (!empty($urlset['query'])) { $urlset['query'] = "?{$urlset['query']}"; } if (empty($urlset['port'])) { } if (strexists($url, 'https://') && !extension_loaded('openssl')) { if (!extension_loaded("openssl")) { message('请开启您php环境的openssl'); } } if (function_exists('curl_init') && function_exists('curl_exec')) { $ch = curl_init(); if (!empty($extra['ip'])) { $extra['host'] = $urlset['host']; $urlset['host'] = $extra['ip']; unset($extra['ip']); } curl_setopt($ch, curlopt_url, $urlset['scheme'] . '://' . $urlset['host'] . ($urlset['port'] == '80' || empty($urlset['port']) ? '' : ':' . $urlset['port']) . $urlset['path'] . $urlset['query']); curl_setopt($ch, curlopt_returntransfer, 1); @curl_setopt($ch, curlopt_followlocation, 1); curl_setopt($ch, curlopt_header, 1); @curl_setopt($ch, curlopt_http_version, curl_http_version_1_0); if ($post) { if (is_array($post)) { $filepost = false; foreach ($post as $name => &$value) { if (version_compare(phpversion(), '5.6') >= 0 && substr($value, 0, 1) == '@') { $value = new curlfile(ltrim($value, '@')); } if ((is_string($value) && substr($value, 0, 1) == '@') || (class_exists('curlfile') && $value instanceof curlfile)) { $filepost = true; } } if (!$filepost) { $post = http_build_query($post); } } curl_setopt($ch, curlopt_post, 1); curl_setopt($ch, curlopt_postfields, $post); } if (!empty($globals['_w']['config']['setting']['proxy'])) { $urls = parse_url($globals['_w']['config']['setting']['proxy']['host']); if (!empty($urls['host'])) { curl_setopt($ch, curlopt_proxy, "{$urls['host']}:{$urls['port']}"); $proxytype = 'curlproxy_' . strtoupper($urls['scheme']); if (!empty($urls['scheme']) && defined($proxytype)) { curl_setopt($ch, curlopt_proxytype, constant($proxytype)); } else { curl_setopt($ch, curlopt_proxytype, curlproxy_http); curl_setopt($ch, curlopt_httpproxytunnel, 1); } if (!empty($globals['_w']['config']['setting']['proxy']['auth'])) { curl_setopt($ch, curlopt_proxyuserpwd, $globals['_w']['config']['setting']['proxy']['auth']); } } } curl_setopt($ch, curlopt_connecttimeout, $timeout); curl_setopt($ch, curlopt_timeout, $timeout); curl_setopt($ch, curlopt_ssl_verifypeer, false); curl_setopt($ch, curlopt_ssl_verifyhost, 0); curl_setopt($ch, curlopt_sslversion, 1); if (defined('curl_sslversion_tlsv1')) { curl_setopt($ch, curlopt_sslversion, curl_sslversion_tlsv1); } curl_setopt($ch, curlopt_useragent, 'mozilla/5.0 (windows nt 6.1; wow64; rv:9.0.1) gecko/20100101 firefox/9.0.1'); if (!empty($extra) && is_array($extra)) { $headers = array(); foreach ($extra as $opt => $value) { if (strexists($opt, 'curlopt_')) { curl_setopt($ch, constant($opt), $value); } elseif (is_numeric($opt)) { curl_setopt($ch, $opt, $value); } else { $headers[] = "{$opt}: {$value}"; } } if (!empty($headers)) { curl_setopt($ch, curlopt_httpheader, $headers); } } $data = curl_exec($ch); $status = curl_getinfo($ch); $errno = curl_errno($ch); $error = curl_error($ch); curl_close($ch); if ($errno || empty($data)) { return error(1, $error); } else { return ihttp_response_parse($data); } } $method = empty($post) ? 'get' : 'post'; $fdata = "{$method} {$urlset['path']}{$urlset['query']} http/1.1\r\n"; $fdata .= "host: {$urlset['host']}\r\n"; if (function_exists('gzdecode')) { $fdata .= "accept-encoding: gzip, deflate\r\n"; } $fdata .= "connection: close\r\n"; if (!empty($extra) && is_array($extra)) { foreach ($extra as $opt => $value) { if (!strexists($opt, 'curlopt_')) { $fdata .= "{$opt}: {$value}\r\n"; } } } $body = ''; if ($post) { if (is_array($post)) { $body = http_build_query($post); } else { $body = urlencode($post); } $fdata .= 'content-length: ' . strlen($body) . "\r\n\r\n{$body}"; } else { $fdata .= "\r\n"; } if ($urlset['scheme'] == 'https') { $fp = fsockopen('ssl://' . $urlset['host'], $urlset['port'], $errno, $error); } else { $fp = fsockopen($urlset['host'], $urlset['port'], $errno, $error); } stream_set_blocking($fp, true); stream_set_timeout($fp, $timeout); if (!$fp) { return error(1, $error); } else { fwrite($fp, $fdata); $content = ''; while (!feof($fp)) $content .= fgets($fp, 512); fclose($fp); return ihttp_response_parse($content, true); } }
第三步:解析分析微信服务器返回值并返回。
if (is_error($resp)) { $procresult = $resp; } else { $arr=json_decode(json_encode((array) simplexml_load_string($resp['content'])), true); $xml = '<?xml version="1.0" encoding="utf-8"?>' . $resp['content']; $dom = new \domdocument(); if ($dom->loadxml($xml)) { $xpath = new \domxpath($dom); $code = $xpath->evaluate('string(//xml/return_code)'); $ret = $xpath->evaluate('string(//xml/result_code)'); if (strtolower($code) == 'success' && strtolower($ret) == 'success') { $procresult = array('errno'=>0,'error'=>'success');; } else { $error = $xpath->evaluate('string(//xml/err_code_des)'); $procresult = array('errno'=>-2,'error'=>$error); } } else { $procresult = array('errno'=>-1,'error'=>'未知错误'); } } return $procresult;
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。