微信红包发放类封装

程序员文章站 2022-05-02 18:21:40
...
发放相关配置

发放工具类

_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 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 _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 = "";
		foreach ($arr as $key => $val) {
			if (is_numeric($val)) {
				$xml .= "" . $val . "" . $key . ">";
			} else {
				$xml .= "" . $key . ">";
			}
		}
		$xml .= "";
		return $xml;
	}

	/**
	 * 获得签名结果
	 * @return boolean|Ambigous 
	 */
	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

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;
	}
	
	
}

最后附上代码下载地址：
链接：http://pan.baidu.com/s/1o7p6GXG 密码：shjz

                
                
                
                    以上就介绍了微信红包发放类封装，包括了方面的内容，希望对PHP教程有兴趣的朋友有所帮助。
微信红包发放类封装

Android中微信抢红包助手的实现详解

IOS 实现微信自动抢红包（非越狱IPhone）

分享Android微信红包插件

iOS支付宝、微信、银联支付集成封装调用（上）

iOS支付宝、微信、银联支付集成封装调用（下）

微信双十一活动11.11岂止于购赢红包iphone6

PHP 生成微信红包代码简单

分享Android微信红包插件

微信小程序数据封装，参数传值等经验分享

iOS支付宝、微信、银联支付集成封装调用（下）

微信红包发放类封装

Android中微信抢红包助手的实现详解

IOS 实现微信自动抢红包（非越狱IPhone）

分享Android微信红包插件

iOS支付宝、微信、银联支付集成封装调用（上）

iOS支付宝、微信、银联支付集成封装调用（下）

微信双十一活动11.11岂止于购赢红包iphone6

PHP 生成微信红包代码简单

分享Android微信红包插件

微信小程序 数据封装，参数传值等经验分享

iOS支付宝、微信、银联支付集成封装调用（下）

微信小程序数据封装，参数传值等经验分享
