微信红包发放类封装【DEMO】

红包发放类封装【DEMO】"/>

微信红包发放类封装【DEMO】

发放相关配置<?php
/**
* 	配置账号信息
* 	配置要和证书在一起！！！！
*/class WxBonusConfig
{//=======【基本信息设置】=====================================///*** TODO: 修改这里配置为您自己申请的商户信息* 微信公众号信息配置* * APPID：绑定支付的APPID（必须配置，开户邮件中可查看）* * MCHID：商户号（必须配置，开户邮件中可查看）* * KEY：商户支付密钥，参考开户邮件设置（必须配置，登录商户平台自行设置）* 设置地址：.php/account/api_cert* */const APPID = '';const MCHID = '';const KEY = '';//=======【证书路径设置】=====================================/*** TODO：设置商户证书路径* 证书路径,注意应该填写绝对路径,发送红包和查询需要，可登录商户平台下载* API证书下载地址：.php/account/api_cert，下载之前需要安装商户操作证书）* @var path 跟这个文件同一目录下的cert文件夹放置证书！！！！*/const SSLCRET12 = 'cert/apiclient_cert.p12';const SSLCERT_PATH = 'cert/apiclient_cert.pem';const SSLKEY_PATH = 'cert/apiclient_key.pem';const SSLROOTCA = 'cert/rootca.pem';//=======【证书路径设置】=====================================/*** 获取文件的路径，证书需要完整路径* @return string*/public static function getRealPath(){return __DIR__.'/';}
}

发放工具类<?php/*** 微信红包发放底层类*/
class WxBonusApi
{// 现金红包请求地址const SENDREDPACK_URL = '';// 红包发放情况查询地址const GETHBINFO_URL = '';// 红包需要的配置 'wxappid','mch_id','key'private $_keys;// 红包需要的证书文件 'api_cert', 'api_key', 'rootca',请传入绝对路径！！！private $_cert;protected $log_file;public $error;// 相关配置必备参数protected $_parameters = array();// 最后一次生产的订单号protected $_lastMchBillno;// 记录最后一次发送请求的结果对象protected $_lastResult;// 最后一次随机数protected $_lastRandNum;/*** 初始化配置，设置关键字和证书* @param array $config* @throws Exception*/public function __construct($config){$keys = array('wxappid','mch_id','key');$files = array('api_cert','api_key','rootca');foreach ($keys as $key) {try {$this->_keys[$key] = $config[$key];} catch (Exception $e) {throw new Exception('参数缺失：' . $key);}}foreach ($files as $file) {try {$cret_file = $config[$file];if (is_file($cret_file)) {$this->_cert[$file] = $cret_file;}} catch (Exception $e) {throw new Exception('证书错误');}}}/*** 红包发放* @param array $parameters 发放所需参数* @return boolean*/public function sendredpack($parameters){// 官方硬性要求$stime = date('H:i');if ($stime < '08:00') {$this->error = '请北京时间0：00-8：00时间之外触发红包赠送';return false;}$bonus = array();$this->setParameter('mch_id', $this->_keys['mch_id']);$this->setParameter('wxappid', $this->_keys['wxappid']);$must = array('re_openid','nick_name','send_name','total_amount','wishing','act_name','remark','client_ip');foreach ($must as $key) {if (isset($parameters[$key]) && $parameters[$key]) {$this->setParameter($key, $parameters[$key]);} else if (! isset($this->_parameters[$key]) || ! $this->_parameters[$key]) {$this->error = '参数缺损:' . $key;return false;}}if (! isset($parameters['mch_billno'])) {$parameters['mch_billno'] = $this->getMchBillno();}$this->setParameter('mch_billno', $parameters['mch_billno']);$this->setParameter('total_num', 1);$this->setParameter('nonce_str', $this->getRand(30, 3));$postXml = $this->_createXml();if (! $postXml) {return false;}$this->log($postXml, 'SEND_XML');$result = $this->curl_post_ssl(self::SENDREDPACK_URL, $postXml);$this->log($result, 'RESULT_XML');if (! $result) {return false;}$resultObj = simplexml_load_string($result, 'SimpleXMLElement', LIBXML_NOCDATA);$this->_lastResult = $resultObj;if ($resultObj->return_code == 'SUCCESS') { // 成功标识if ($resultObj->result_code == 'SUCCESS') {return $resultObj->send_listid;}if ($resultObj->return_msg) {$this->error = (string) $resultObj->return_msg;return false;}$this->error = (string) $resultObj->err_code_des;return false;}if ($resultObj->return_code != 'FAIL') {$this->error = '返回信息格式异常';return false;}$this->error = (string) $resultObj->return_msg;return false;}/*** 查询红包的发放详情*   参数：*    mch_billno 发送红包时生产的唯一订单号*   返回：*    成功：object对象*    失败：false**/public function getInfo($mch_billno){$param = array('nonce_str' => $this->getRand(30, 3),'mch_billno'=> $mch_billno ,'mch_id'    => $this->_keys['mch_id'],'appid'     => $this->_keys['wxappid'],'bill_type' => 'MCHT',);ksort($param);$unSignParaString = $this->_formatQueryParaMap($param, false);$param['sign'] = $this->_sign($unSignParaString, $this->_keys['key']);$xml = $this->arrayToXml($param);$this->log($xml, 'GETINFO_XML');$result = $this->curl_post_ssl(WePay::GETHBINFO_URL, $xml);if(!$result){return false ;}$this->log($result, 'RESULT_XML');$resultObj = simplexml_load_string($result, 'SimpleXMLElement', LIBXML_NOCDATA);$this->_lastResult = $resultObj ;if($resultObj->return_code == 'SUCCESS'){//成功标识if($resultObj->result_code == 'SUCCESS'){return $resultObj ;}if($resultObj->return_msg){$this->error = $resultObj->return_msg ;return false ;}$this->error = $resultObj->err_code_des ;return false ;}if($resultObj->return_code != 'FAIL'){$this->error = '返回信息格式异常';return false ;}$this->error = $resultObj->return_msg ;return false ;}/*** 设置红包发放所需要的参数* @param  $parameter 键值数组/键* @param  $value 值* @return WxBonusApi*/public function setParameter($parameter, $value = null){if (! is_array($parameter)) {return $this->setParameter(array($parameter => $value));}foreach ($parameter as $key => $value) {$key = trim($key);$value = trim($value);$this->_parameters[$key] = $value;}return $this;}/*** 获取参数值* @param  $parameter 键名* @return multitype:*/public function getParameter($parameter){return $this->_parameters[$parameter];}/*** 获取随机数* @param number $len 随机数的位数* @param number $type 取值范围 1表示数字 2小写字母 4大写字母* @return string*/public function getRand($len = 30, $type = 0){$str = '';$max = - 1;if (! $type) {$type = 3;}if ($type & 1) {$str .= '1234567890';$max += 10;}if ($type & 2) {$str .= 'abcdefghijklmnopqrstuvwxyz';$max += 26;}if ($type & 4) {$str .= 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';$max += 26;}$rand = '';for ($i = 0; $i < $len; $i ++) {$rand .= $str[rand(0, $max)];}return $rand;}/*** 生成商户的订单号* @return string*/public function getMchBillno(){$this->_lastMchBillno = $this->_parameters['mch_id'] . date('YmdHis') . $this->getRand(4, 1); // $this->getRandNum();return $this->_lastMchBillno;}/*** 获取最后一次创建红包时生成的订单号* @return string*/public function getLastMchBillno(){return $this->_lastMchBillno;}/*** 创建XML的方法* @param number $retcode* @param string $reterrmsg* @return boolean|string*/private function _createXml(){try {$sign = $this->_getSign();if (! $sign) {return false;}$this->setParameter('sign', $sign);return $this->arrayToXml($this->_parameters);} catch (Exception $e) {$this->error = $e->getMessage();return false;}}/*** 参数转换成XML* @param array $arr 参数数组* @return string*/public function arrayToXml($arr){$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;}/*** 获得签名结果* @return boolean|Ambigous <string, boolean>*/protected function _getSign(){try {if ($this->_checkSign() == false) { // 检查生成签名参数$this->error = '生成签名参数缺失！';$this->log(json_encode($this->_parameters, JSON_UNESCAPED_UNICODE), 'ERROR_Sign_XML');return false;}ksort($this->_parameters);$unSignParaString = $this->_formatQueryParaMap($this->_parameters, false);return $this->_sign($unSignParaString, $this->_keys['key']);} catch (Exception $e) {$this->error = $e->getMessage();return false;}}/*** 检查签名所需参数是否齐全* @return boolean*/private function _checkSign(){// return true;if ($this->_parameters["nonce_str"] == null || $this->_parameters["mch_billno"] == null || $this->_parameters["mch_id"] == null || $this->_parameters["wxappid"] == null || $this->_parameters["nick_name"] == null || $this->_parameters["send_name"] == null || $this->_parameters["re_openid"] == null || $this->_parameters["total_amount"] == null || $this->_parameters["total_num"] == null || $this->_parameters["wishing"] == null || $this->_parameters["client_ip"] == null || $this->_parameters["act_name"] == null || $this->_parameters["remark"] == null) {return false;}return true;}/**** @param  $paraMap* @param  $urlencode* @return string*/private function _formatQueryParaMap($paraMap,$urlencode){$buff = "";ksort($paraMap);foreach ($paraMap as $k => $v) {if (null != $v && "null" != $v && "sign" != $k) {if ($urlencode) {$v = urlencode($v);}$buff .= $k . "=" . $v . "&";}}$reqPar;if (strlen($buff) > 0) {$reqPar = substr($buff, 0, strlen($buff) - 1);}return $reqPar;}/*** 签名* @param $content 签名的字符串* @param $key 密钥* @throws Exception* @return string|boolean*/private function _sign($content, $key){try {if (null == $key) {$this->error = '签名key不能为空！';return false;}if (null == $content) {$this->error = '签名内容不能为空';return false;}$signStr = $content . "&key=" . $key;return strtoupper(md5($signStr));} catch (Exception $e) {$this->error = $e->getMessage();return false;}}/*** cURL抓取** @param $url 链接地址* @param $vars 参数* @param*        	$second* @param*        	$aHeader* @return mixed|boolean*/function curl_post_ssl($url, $data, $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文件curl_setopt($ch, CURLOPT_SSLCERT, $this->_cert['api_cert']);curl_setopt($ch, CURLOPT_SSLKEY, $this->_cert['api_key']);curl_setopt($ch, CURLOPT_CAINFO, $this->_cert['rootca']);if (count($aHeader) >= 1) {curl_setopt($ch, CURLOPT_HTTPHEADER, $aHeader);}curl_setopt($ch, CURLOPT_POST, 1);curl_setopt($ch, CURLOPT_POSTFIELDS, $data);$data = curl_exec($ch);if ($data) {curl_close($ch);return $data;} else {$this->log(json_encode($this->_cert));$this->error = 'aa:'.curl_errno($ch);curl_close($ch);return false;}}/*** 获取服务器ip** @return string*/public function getServerIp(){$server_ip = '127.0.0.1';if (isset($_SERVER)) {if (isset($_SERVER['SERVER_ADDR']) && $_SERVER['SERVER_ADDR']) {$server_ip = $_SERVER['SERVER_ADDR'];} elseif (isset($_SERVER['LOCAL_ADDR']) && $_SERVER['LOCAL_ADDR']) {$server_ip = $_SERVER['LOCAL_ADDR'];}} else {$server_ip = getenv('SERVER_ADDR');}return $server_ip;}/*** 设置日志目录文件* * @param unknown $file        	*/public function setLogFile($file){$this->log_file = $file;}/*** 写日志* * @param $msg 写入的信息        	* @param $type 日志类型作为查询标示        	*/public function log($msg, $type){if ($this->log_file) {$log = str_replace(array("\r\n","\r","\n"), array("","",""), $msg);error_log($type . ' ' . date('Y-m-d H:i:s') . ' ' . $log . "\r\n", 3, $this->log_file);}}
}

测试用发放demo<?php
include 'WxBonus.Config.php';
include 'WxBonus.Api.php';
class WxBonusDemo{public function indexAction(){//初始化配置$WxBonus=new WxBonusApi(array('wxappid'=>WxBonusConfig::APPID,'mch_id'=>WxBonusConfig::MCHID,'key'=>WxBonusConfig::KEY,'api_cert'=>WxBonusConfig::getRealPath(). WxBonusConfig::SSLCERT_PATH,//三个路径都是绝对路径'api_key'=>WxBonusConfig::getRealPath().WxBonusConfig::SSLKEY_PATH,'rootca'=>WxBonusConfig::getRealPath().WxBonusConfig::SSLROOTCA));$param=array('re_openid'=>'openid',//发送的openid'nick_name'=>'测试',//没有用，但是需要的参数'send_name'=>'test',//收到的红包名称'total_amount'=>'100',//金额 分'wishing'=>'祝福语',//红包祝福语，不超过32个字符'act_name'=>'活动名称',//活动名称，不会显示'remark'=>'备注',//备注，不会显示'client_ip'=>$WxBonus->getServerIp()//发送的服务器ip地址);$WxBonus->setLogFile('D:\\log1.txt');//设置日志文件$result=$WxBonus->sendredpack($param);//发送红包//结果就是true / false 如果是false 错误信息就在 error 中if($result){echo "ok";return true;}echo $WxBonus->error;return false;}}

最后附上代码下载地址：