PHP微信红包生成代码分享
程序员文章站
2024-04-02 13:25:40
本文实例为大家分享了php微信公众号自动发送红包api代码,分享给大家供大家参考。具体如下:
贴出核心接口代码至于数据自己填写,接口测试ok
wechat_packet...
本文实例为大家分享了php微信公众号自动发送红包api代码,分享给大家供大家参考。具体如下:
贴出核心接口代码至于数据自己填写,接口测试ok
wechat_packet.php
<!--?php /** * 发送红包接口 * created by phpstorm. * user: adki * date: 2016/4/25 0025 * time: 15:25 */ class wechat_packet{ private $url = 'https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack';//请求url private $mch_id;//商户号 private $weixin_appid;//公众账号appid private $send_name;//商户名称 private $total_num = 1;//发送红包总人数 private $wishing;//红包祝福语 private $client_ip;//调用接口的机器ip地址 private $act_name;//活动名称 private $remark;//备注信息 private $nonce_str;//随机字符串,不长于32位 private $api_password; private $arraytoxml;//数组转xml /** * 公钥 */ private $public_key = "/api/wechat/cert/apiclient_cert.pem"; /** * 私钥 */ private $private_key = '/api/wechat/cert/apiclient_key.pem'; /** * ca证书 */ private $rootca = 'api/wechat/cert/rootca.pem'; public function __construct() { //初始化红包设置信息 $this--->weixin_appid = c('wap_weixin_appid'); $this->mch_id = c('wechat_mch_id'); $this->send_name = c('wechat_send_name'); $this->wishing = c('wechat_wishing'); $this->act_name = c('wechat_act_name'); $this->client_ip = $_server['server_addr']; $this->remark = c('wechat_remark'); $this->nonce_str = $this->create_nonce_str(32); $this->api_password = c('wechat_api_password'); $inc_file = base_path.ds.'api'.ds.'wechat'.ds.'arraytoxml.php'; if(is_file($inc_file)) { require($inc_file); } $this->arraytoxml = new arraytoxml(); } public function send_post($mch_billno,$re_openid,$total_amount){ $sign = $this->create_sign($mch_billno,$re_openid,$total_amount); $send_array = array( 'nonce_str' => $this->nonce_str, 'mch_billno' => $mch_billno, 'mch_id' => $this->mch_id, 'wxappid' => $this->weixin_appid, 'send_name' => $this->send_name, 're_openid' => $re_openid, 'total_amount' => $total_amount, 'total_num' => $this->total_num, 'wishing' => $this->wishing, 'client_ip' => $this->client_ip, 'act_name' => $this->act_name, 'remark' => $this->remark, 'sign' => $sign, ); $send_xml = $this->arraytoxml->toxml($send_array,''); $data = $this->curl_post_ssl($this->url, $send_xml); $data = $this->xmltoarray($data); file_put_contents('adki',var_export($data,true),file_append); } /* 请确保您的libcurl版本是否支持双向认证,版本高于7.20.1 */ private function curl_post_ssl($url, $vars, $second=30,$aheader=array()){ $ch = curl_init(); //超时时间 curl_setopt($ch,curlopt_timeout,$second); curl_setopt($ch,curlopt_returntransfer, 1); //这里设置代理,如果有的话 //curl_setopt($ch,curlopt_proxy, '10.206.30.98'); //curl_setopt($ch,curlopt_proxyport, 8080); curl_setopt($ch,curlopt_url,$url); curl_setopt($ch,curlopt_ssl_verifypeer,false); curl_setopt($ch,curlopt_ssl_verifyhost,false); //以下两种方式需选择一种 //第一种方法,cert 与 key 分别属于两个.pem文件 //默认格式为pem,可以注释 curl_setopt($ch,curlopt_sslcerttype,'pem'); curl_setopt($ch,curlopt_sslcert,getcwd().$this->public_key); //默认格式为pem,可以注释 curl_setopt($ch,curlopt_sslkeytype,'pem'); curl_setopt($ch,curlopt_sslkey,getcwd().$this->private_key); //ca证书 curl_setopt($ch,curlopt_cainfo,$this->rootca); //第二种方式,两个文件合成一个.pem文件 //curl_setopt($ch,curlopt_sslcert,getcwd().'/all.pem'); if( count($aheader) >= 1 ){ curl_setopt($ch, curlopt_httpheader, $aheader); } curl_setopt($ch,curlopt_post, 1); curl_setopt($ch,curlopt_postfields,$vars); $data = curl_exec($ch); if($data){ curl_close($ch); return $data; } else { $error = curl_errno($ch); echo "call faild, errorcode:$error\n\n\n\n"; curl_close($ch); return false; } } //生成签名 private function create_sign($mch_billno,$re_openid,$total_amount){ $string_array = array( 'act_name' => $this->act_name, 'client_ip' => $this->client_ip, 'mch_billno' => $mch_billno, 'mch_id' => $this->mch_id, 'nonce_str' => $this->nonce_str, 're_openid' => $re_openid, 'remark' => $this->remark, 'send_name' => $this->send_name, 'total_amount' => $total_amount, 'total_num' => $this->total_num, 'wishing' => $this->wishing, 'wxappid' => $this->weixin_appid, ); foreach ($string_array as $key => $value){ if(!empty($value)){ $stringa .= "$key=$value"; if($key != 'wxappid'){ $stringa .= '&'; } } } //转成utf-8 $stringa = $this->gbktoutf8($stringa); $stringsigntemp="$stringa&key=$this->api_password"; $sign = md5($stringsigntemp); $sign = strtoupper($sign); return $sign; } //生成随机字符串 private function create_nonce_str($length){ $str = null; $strpol = "abcdefghijklmnopqrstuvwxyz0123456789abcdefghijklmnopqrstuvwxyz"; $max = strlen($strpol)-1; for($i=0;$i<$length;$i++){ $str.=$strpol[rand(0,$max)];//rand($min,$max)生成介于min和max两个数之间的一个随机整数 } return $str; } /** *自动判断把gbk或gb2312编码的字符串转为utf8 *能自动判断输入字符串的编码类,如果本身是utf-8就不用转换,否则就转换为utf-8的字符串 *支持的字符编码类型是:utf-8,gbk,gb2312 *@$str:string 字符串 */ private function gbktoutf8($str){ $charset = mb_detect_encoding($str,array('ascii','utf-8','gbk','gb2312')); $charset = strtolower($charset); if("utf-8" != $charset){ $str = iconv('utf-8',$charset,$str); } return $str; } private function xmltoarray($poststr){ $msg = array(); $msg = (array)simplexml_load_string($poststr, 'simplexmlelement', libxml_nocdata); return $msg; } }
数组转xml:arraytoxml.php
<!--?php /** * created by phpstorm. * user: adki * date: 2016/4/26 0026 * time: 12:19 */ class arraytoxml { public function toxml($data){ $xml = '<xml-->'; foreach ($data as $key => $value){ if (is_numeric($value)){ $xml .= "<".$key.">".$value."<!--".$key."-->"; }else{ $xml .= "<".$key."><!--[cdata[".$value."]]--><!--".$key."-->"; } } $xml .= ''; return $xml; } }
重写了一下php下面的微信api接口,
微信红包支持,jsapi的动态参数接口支持
微信api类 - 增加红包支持
<?php /******************************************************** * @author kyler you <qq:2444756311> * @link http://mp.weixin.qq.com/wiki/home/index.html * @version 2.0.1 * @uses $wxapi = new wxapi(); * @package 微信api接口 陆续会继续进行更新 ********************************************************/ class wxapi { const appid = ""; const appsecret = ""; const mchid = ""; //商户号 const privatekey = ""; //私钥 public $parameters = array(); public function __construct(){ } /**************************************************** * 微信提交api方法,返回微信指定json ****************************************************/ public function wxhttpsrequest($url,$data = null){ $curl = curl_init(); curl_setopt($curl, curlopt_url, $url); curl_setopt($curl, curlopt_ssl_verifypeer, false); curl_setopt($curl, curlopt_ssl_verifyhost, false); if (!empty($data)){ curl_setopt($curl, curlopt_post, 1); curl_setopt($curl, curlopt_postfields, $data); } curl_setopt($curl, curlopt_returntransfer, 1); $output = curl_exec($curl); curl_close($curl); return $output; } /**************************************************** * 微信带证书提交数据 - 微信红包使用 ****************************************************/ public function wxhttpsrequestpem($url, $vars, $second=30,$aheader=array()){ $ch = curl_init(); //超时时间 curl_setopt($ch,curlopt_timeout,$second); curl_setopt($ch,curlopt_returntransfer, 1); //这里设置代理,如果有的话 //curl_setopt($ch,curlopt_proxy, '10.206.30.98'); //curl_setopt($ch,curlopt_proxyport, 8080); curl_setopt($ch,curlopt_url,$url); curl_setopt($ch,curlopt_ssl_verifypeer,false); curl_setopt($ch,curlopt_ssl_verifyhost,false); //以下两种方式需选择一种 //第一种方法,cert 与 key 分别属于两个.pem文件 //默认格式为pem,可以注释 curl_setopt($ch,curlopt_sslcerttype,'pem'); curl_setopt($ch,curlopt_sslcert,getcwd().'/apiclient_cert.pem'); //默认格式为pem,可以注释 curl_setopt($ch,curlopt_sslkeytype,'pem'); curl_setopt($ch,curlopt_sslkey,getcwd().'/apiclient_key.pem'); curl_setopt($ch,curlopt_cainfo,'pem'); curl_setopt($ch,curlopt_cainfo,getcwd().'/rootca.pem'); //第二种方式,两个文件合成一个.pem文件 //curl_setopt($ch,curlopt_sslcert,getcwd().'/all.pem'); if( count($aheader) >= 1 ){ curl_setopt($ch, curlopt_httpheader, $aheader); } curl_setopt($ch,curlopt_post, 1); curl_setopt($ch,curlopt_postfields,$vars); $data = curl_exec($ch); if($data){ curl_close($ch); return $data; } else { $error = curl_errno($ch); echo "call faild, errorcode:$error\n"; curl_close($ch); return false; } } /**************************************************** * 微信获取accesstoken 返回指定微信公众号的at信息 ****************************************************/ public function wxaccesstoken($appid = null , $appsecret = null){ $appid = is_null($appid) ? self::appid : $appid; $appsecret = is_null($appsecret) ? self::appsecret : $appsecret; //echo $appid,$appsecret; $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$appid."&secret=".$appsecret; $result = $this->wxhttpsrequest($url); //print_r($result); $jsoninfo = json_decode($result, true); $access_token = $jsoninfo["access_token"]; return $access_token; } /**************************************************** * 微信通过openid获取用户信息,返回数组 ****************************************************/ public function wxgetuser($openid){ $wxaccesstoken = $this->wxaccesstoken(); $url = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=".$wxaccesstoken."&openid=".$openid."&lang=zh_cn"; $result = $this->wxhttpsrequest($url); $jsoninfo = json_decode($result, true); return $jsoninfo; } /**************************************************** * 微信通过指定模板信息发送给指定用户,发送完成后返回指定json数据 ****************************************************/ public function wxsendtemplate($jsondata){ $wxaccesstoken = $this->wxaccesstoken(); $url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=".$wxaccesstoken; $result = $this->wxhttpsrequest($url,$jsondata); return $result; } /**************************************************** * 发送自定义的模板消息 ****************************************************/ public function wxsetsend($touser, $template_id, $url, $data, $topcolor = '#7b68ee'){ $template = array( 'touser' => $touser, 'template_id' => $template_id, 'url' => $url, 'topcolor' => $topcolor, 'data' => $data ); $jsondata = json_encode($template); $result = $this->wxsendtemplate($jsondata); return $result; } /**************************************************** * 微信设置oauth跳转url,返回字符串信息 - scope = snsapi_base //验证时不返回确认页面,只能获取openid ****************************************************/ public function wxoauthbase($redirecturl,$state = "",$appid = null){ $appid = is_null($appid) ? self::appid : $appid; $url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=".$appid."&redirect_uri=".$redirecturl."&response_type=code&scope=snsapi_base&state=".$state."#wechat_redirect"; return $url; } /**************************************************** * 微信设置oauth跳转url,返回字符串信息 - scope = snsapi_userinfo //获取用户完整信息 ****************************************************/ public function wxoauthuserinfo($redirecturl,$state = "",$appid = null){ $appid = is_null($appid) ? self::appid : $appid; $url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=".$appid."&redirect_uri=".$redirecturl."&response_type=code&scope=snsapi_userinfo&state=".$state."#wechat_redirect"; return $url; } /**************************************************** * 微信oauth跳转指定url ****************************************************/ public function wxheader($url){ header("location:".$url); } /**************************************************** * 微信通过oauth返回页面中获取at信息 ****************************************************/ public function wxoauthaccesstoken($code,$appid = null , $appsecret = null){ $appid = is_null($appid) ? self::appid : $appid; $appsecret = is_null($appsecret) ? self::appsecret : $appsecret; $url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=".$appid."&secret=".$appsecret."&code=".$code."&grant_type=authorization_code"; $result = $this->wxhttpsrequest($url); //print_r($result); $jsoninfo = json_decode($result, true); //$access_token = $jsoninfo["access_token"]; return $jsoninfo; } /**************************************************** * 微信通过oauth的access_token的信息获取当前用户信息 // 只执行在snsapi_userinfo模式运行 ****************************************************/ public function wxoauthuser($oauthat,$openid){ $url = "https://api.weixin.qq.com/sns/userinfo?access_token=".$oauthat."&openid=".$openid."&lang=zh_cn"; $result = $this->wxhttpsrequest($url); $jsoninfo = json_decode($result, true); return $jsoninfo; } /***************************************************** * 生成随机字符串 - 最长为32位字符串 *****************************************************/ public function wxnoncestr($length = 16, $type = false) { $chars = "abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz0123456789"; $str = ""; for ($i = 0; $i < $length; $i++) { $str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1); } if($type == true){ return strtoupper(md5(time() . $str)); } else { return $str; } } /******************************************************* * 微信商户订单号 - 最长28位字符串 *******************************************************/ public function wxmchbillno($mchid = null) { if(is_null($mchid)){ if(self::mchid == "" || is_null(self::mchid)){ $mchid = time(); } else{ $mchid = self::mchid; } } else{ $mchid = substr(addslashes($mchid),0,10); } return date("ymd",time()).time().$mchid; } /******************************************************* * 微信格式化数组变成参数格式 - 支持url加密 *******************************************************/ public function wxsetparam($parameters){ if(is_array($parameters) && !empty($parameters)){ $this->parameters = $parameters; return $this->parameters; } else{ return array(); } } /******************************************************* * 微信格式化数组变成参数格式 - 支持url加密 *******************************************************/ public function wxformatarray($parameters = null, $urlencode = false){ if(is_null($parameters)){ $parameters = $this->parameters; } $restr = "";//初始化空 ksort($parameters);//排序参数 foreach ($parameters as $k => $v){//循环定制参数 if (null != $v && "null" != $v && "sign" != $k) { if($urlencode){//如果参数需要增加url加密就增加,不需要则不需要 $v = urlencode($v); } $restr .= $k . "=" . $v . "&";//返回完整字符串 } } if (strlen($restr) > 0) {//如果存在数据则将最后“&”删除 $restr = substr($restr, 0, strlen($restr)-1); } return $restr;//返回字符串 } /******************************************************* * 微信md5签名生成器 - 需要将参数数组转化成为字符串[wxformatarray方法] *******************************************************/ public function wxmd5sign($content, $privatekey){ try { if (is_null($key)) { throw new exception("财付通签名key不能为空!"); } if (is_null($content)) { throw new exception("财付通签名内容不能为空"); } $signstr = $content . "&key=" . $key; return strtoupper(md5($signstr)); } catch (exception $e) { die($e->getmessage()); } } /******************************************************* * 微信sha1签名生成器 - 需要将参数数组转化成为字符串[wxformatarray方法] *******************************************************/ public function wxsha1sign($content, $privatekey){ try { if (is_null($key)) { throw new exception("财付通签名key不能为空!"); } if (is_null($content)) { throw new exception("财付通签名内容不能为空"); } $signstr = $content . "&key=" . $key; return strtoupper(sha1($signstr)); } catch (exception $e) { die($e->getmessage()); } } /******************************************************* * 将数组解析xml - 微信红包接口 *******************************************************/ public function wxarraytoxml($parameters = null){ if(is_null($parameters)){ $parameters = $this->parameters; } if(!is_array($parameters) || empty($parameters)){ die("参数不为数组无法解析"); } $xml = "<xml>"; foreach ($arr as $key=>$val) { if (is_numeric($val)) { $xml.="<".$key.">".$val."</".$key.">"; } else $xml.="<".$key."><![cdata[".$val."]]></".$key.">"; } $xml.="</xml>"; return $xml; } }
后期还是会增加在一起的把这个class做起来,网上资源很多,但是都是有一定基础的人去看看改改可以,对于没有接触刚刚接触的新手还是需要给予支持的。帮助用户屡屡思路。
再来一份:
首先给大家看一看这个表格:
根据微信高级红包接口,开发php版本的api接口,现在进行主要代码分析。
红包接口调用请求代码,所有请求参数为必填参数与文档对应:
class wxapi { private $app_id = 'wxxxxxxxxxxxxx'; //公众账号appid,首先申请与之配套的公众账号 private $app_secret = 'xxxxxxxxxxxxxxxxxxxxxxxx';//公众号secret,用户获取用户授权token private $app_mchid = 'xxxxxxxx';//商户号id function __construct(){ //do sth here.... } /** * 微信支付 * @param string $openid 用户openid */ public function pay($re_openid) { include_once('wxhongbaohelper.php'); $commonutil = new commonutil(); $wxhongbaohelper = new wxhongbaohelper(); $wxhongbaohelper->setparameter("nonce_str", $this->great_rand());//随机字符串,丌长于 32 位 $wxhongbaohelper->setparameter("mch_billno", $this->app_mchid.date('ymdhis').rand(1000, 9999));//订单号 $wxhongbaohelper->setparameter("mch_id", $this->app_mchid);//商户号 $wxhongbaohelper->setparameter("wxappid", $this->app_id); $wxhongbaohelper->setparameter("nick_name", '红包');//提供方名称 $wxhongbaohelper->setparameter("send_name", '红包');//红包发送者名称 $wxhongbaohelper->setparameter("re_openid", $re_openid);//相对于医脉互通的openid $wxhongbaohelper->setparameter("total_amount", 100);//付款金额,单位分 $wxhongbaohelper->setparameter("min_value", 100);//最小红包金额,单位分 $wxhongbaohelper->setparameter("max_value", 100);//最大红包金额,单位分 $wxhongbaohelper->setparameter("total_num", 1);//红包収放总人数 $wxhongbaohelper->setparameter("wishing", '感谢您参与红包派发活动,祝您新年快乐!');//红包祝福诧 $wxhongbaohelper->setparameter("client_ip", '127.0.0.1');//调用接口的机器 ip 地址 $wxhongbaohelper->setparameter("act_name", '红包活动');//活劢名称 $wxhongbaohelper->setparameter("remark", '快来抢!');//备注信息 $postxml = $wxhongbaohelper->create_hongbao_xml(); $url = 'https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack'; $responsexml = $wxhongbaohelper->curl_post_ssl($url, $postxml); //用作结果调试输出 //echo htmlentities($responsexml,ent_compat,'utf-8'); $responseobj = simplexml_load_string($responsexml, 'simplexmlelement', libxml_nocdata); return $responseobj->return_code; }
获取随机字符串方法:
/** * 生成随机数 */ public function great_rand(){ $str = '1234567890abcdefghijklmnopqrstuvwxyz'; for($i=0;$i<30;$i++){ $j=rand(0,35); $t1 .= $str[$j]; } return $t1; }
签名算法:
/** 例如: appid: wxd111665abv58f4f mch_id: 10000100 device_info: 1000 body: test nonce_str: ibuaivckdprxkhja 第一步:对参数按照 key=value 的格式,并按照参数名 ascii 字典序排序如下: stringa="appid=wxd930ea5d5a258f4f&body=test&device_info=1000&mch_i d=10000100&nonce_str=ibuaivckdprxkhja"; 第二步:拼接支付密钥: stringsigntemp="stringa&key=192006250b4c09247ec02edce69f6a2d" sign=md5(stringsigntemp).touppercase()="9a0a8659f005d6984697e2ca0a 9cf3b7" */ protected function get_sign(){ define('partnerkey',"qsrxxxxxxxxxxxxxxxxxxxxx"); try { if (null == partnerkey || "" == partnerkey ) { throw new sdkruntimeexception("密钥不能为空!" . "<br>"); } if($this->check_sign_parameters() == false) { //检查生成签名参数 throw new sdkruntimeexception("生成签名参数缺失!" . "<br>"); } $commonutil = new commonutil(); ksort($this->parameters); $unsignparastring = $commonutil->formatqueryparamap($this->parameters, false); $md5signutil = new md5signutil(); return $md5signutil->sign($unsignparastring,$commonutil->trimstring(partnerkey)); }catch (sdkruntimeexception $e) { die($e->errormessage()); } }
curl请求以及发送证书:
function curl_post_ssl($url, $vars, $second=30,$aheader=array()) { $ch = curl_init(); //超时时间 curl_setopt($ch,curlopt_timeout,$second); curl_setopt($ch,curlopt_returntransfer, 1); //这里设置代理,如果有的话 curl_setopt($ch,curlopt_url,$url); curl_setopt($ch,curlopt_ssl_verifypeer,false); curl_setopt($ch,curlopt_ssl_verifyhost,false); //cert 与 key 分别属于两个.pem文件 //请确保您的libcurl版本是否支持双向认证,版本高于7.20.1 curl_setopt($ch,curlopt_sslcert,dirname(__file__).directory_separator.'zhengshu'.directory_separator.'apiclient_cert.pem'); curl_setopt($ch,curlopt_sslkey,dirname(__file__).directory_separator.'zhengshu'.directory_separator.'apiclient_key.pem'); curl_setopt($ch,curlopt_cainfo,dirname(__file__).directory_separator.'zhengshu'.directory_separator.'rootca.pem'); if( count($aheader) >= 1 ){ curl_setopt($ch, curlopt_httpheader, $aheader); } curl_setopt($ch,curlopt_post, 1); curl_setopt($ch,curlopt_postfields,$vars); $data = curl_exec($ch); if($data){ curl_close($ch); return $data; } else { $error = curl_errno($ch); //echo "call faild, errorcode:$error\n"; curl_close($ch); return false; } }
入口文件:
@require "pay.php"; //获取用户信息 $get = $_get['param']; $code = $_get['code']; //判断code是否存在 if($get=='access_token' && !empty($code)){ $param['param'] = 'access_token'; $param['code'] = $code; $packet = new packet(); //获取用户openid信息 $userinfo = $packet->_route('userinfo',$param); if(empty($userinfo['openid'])){ exit("noauth"); } //调取支付方法 $packet->_route('wxpacket',array('openid'=>$userinfo['openid'])); }else{ $packet->_route('userinfo'); }
以上就是本文的全部内容,希望对大家学习php程序设计有所帮助,也希望大家多多支持。
上一篇: php快速排序原理与实现方法分析
下一篇: 提交表单后 PHP获取提交内容的实现方法