WxPay.Api.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809
  1. <?php
  2. require_once "WxPay.Exception.php";
  3. require_once "WxPay.Config.php";
  4. require_once "WxPay.Data.php";
  5. /**
  6. *
  7. * 接口访问类,包含所有微信支付API列表的封装,类中方法为static方法,
  8. * 每个接口有默认超时时间(除提交被扫支付为10s,上报超时时间为1s外,其他均为6s)
  9. * @author widyhu
  10. *
  11. */
  12. class WxPayApi
  13. {
  14. /**
  15. *
  16. * 统一下单,WxPayUnifiedOrder中out_trade_no、body、total_fee、trade_type必填
  17. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  18. * @param WxPayUnifiedOrder $inputObj
  19. * @param int $timeOut
  20. * @throws WxPayException
  21. * @return 成功时返回,其他抛异常
  22. */
  23. public static function unifiedOrder($inputObj, $timeOut = 6)
  24. {
  25. $url = "https://api.mch.weixin.qq.com/pay/unifiedorder";
  26. //检测必填参数
  27. if(!$inputObj->IsOut_trade_noSet()) {
  28. throw new WxPayException("缺少统一支付接口必填参数out_trade_no!");
  29. }else if(!$inputObj->IsBodySet()){
  30. throw new WxPayException("缺少统一支付接口必填参数body!");
  31. }else if(!$inputObj->IsTotal_feeSet()) {
  32. throw new WxPayException("缺少统一支付接口必填参数total_fee!");
  33. }else if(!$inputObj->IsTrade_typeSet()) {
  34. throw new WxPayException("缺少统一支付接口必填参数trade_type!");
  35. }
  36. //关联参数
  37. if($inputObj->GetTrade_type() == "JSAPI" && !$inputObj->IsOpenidSet()){
  38. throw new WxPayException("统一支付接口中,缺少必填参数openid!trade_type为JSAPI时,openid为必填参数!");
  39. }
  40. if($inputObj->GetTrade_type() == "NATIVE" && !$inputObj->IsProduct_idSet()){
  41. throw new WxPayException("统一支付接口中,缺少必填参数product_id!trade_type为JSAPI时,product_id为必填参数!");
  42. }
  43. //异步通知url未设置,则使用配置文件中的url
  44. if(!$inputObj->IsNotify_urlSet()){
  45. $inputObj->SetNotify_url(WxPayConfig::NOTIFY_URL);//异步通知url
  46. }
  47. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  48. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  49. $inputObj->SetSpbill_create_ip($_SERVER['REMOTE_ADDR']);//终端ip
  50. //$inputObj->SetSpbill_create_ip("1.1.1.1");
  51. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  52. //签名
  53. $inputObj->SetSign();
  54. $xml = $inputObj->ToXml();
  55. $startTimeStamp = self::getMillisecond();//请求开始时间
  56. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  57. $result = WxPayResults::Init($response);
  58. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  59. return $result;
  60. }
  61. /**
  62. *
  63. * 查询订单,WxPayOrderQuery中out_trade_no、transaction_id至少填一个
  64. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  65. * @param WxPayOrderQuery $inputObj
  66. * @param int $timeOut
  67. * @throws WxPayException
  68. * @return 成功时返回,其他抛异常
  69. */
  70. public static function orderQuery($inputObj, $timeOut = 6)
  71. {
  72. $wepro_appid = D('Home/Front')->get_config_by_name('wepro_appid');
  73. $wepro_partnerid = D('Home/Front')->get_config_by_name('wepro_partnerid');
  74. $url = "https://api.mch.weixin.qq.com/pay/orderquery";
  75. //检测必填参数
  76. if(!$inputObj->IsOut_trade_noSet() && !$inputObj->IsTransaction_idSet()) {
  77. throw new WxPayException("订单查询接口中,out_trade_no、transaction_id至少填一个!");
  78. }
  79. $inputObj->SetAppid($wepro_appid);//公众账号ID
  80. $inputObj->SetMch_id($wepro_partnerid);//商户号
  81. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  82. $inputObj->SetSign();//签名
  83. $xml = $inputObj->ToXml();
  84. $startTimeStamp = self::getMillisecond();//请求开始时间
  85. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  86. $result = WxPayResults::Init($response);
  87. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  88. return $result;
  89. }
  90. /**
  91. *
  92. * 关闭订单,WxPayCloseOrder中out_trade_no必填
  93. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  94. * @param WxPayCloseOrder $inputObj
  95. * @param int $timeOut
  96. * @throws WxPayException
  97. * @return 成功时返回,其他抛异常
  98. */
  99. public static function closeOrder($inputObj, $timeOut = 6)
  100. {
  101. $url = "https://api.mch.weixin.qq.com/pay/closeorder";
  102. //检测必填参数
  103. if(!$inputObj->IsOut_trade_noSet()) {
  104. throw new WxPayException("订单查询接口中,out_trade_no必填!");
  105. }
  106. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  107. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  108. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  109. $inputObj->SetSign();//签名
  110. $xml = $inputObj->ToXml();
  111. $startTimeStamp = self::getMillisecond();//请求开始时间
  112. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  113. $result = WxPayResults::Init($response);
  114. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  115. return $result;
  116. }
  117. /**
  118. 发送红包接口
  119. **/
  120. public static function bonuspay($inputObj, $timeOut = 6)
  121. {
  122. $url = "https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack";
  123. $param = array();
  124. $param['mch_billno'] = $inputObj['mch_billno'];
  125. $param['mch_id'] = WxPayConfig::MCHID;
  126. $param['wxappid'] = WxPayConfig::APPID;
  127. $param['nick_name'] = $inputObj['nick_name'];// urlencode($inputObj['nick_name']);//$inputObj['nick_name'];
  128. $param['send_name'] = $inputObj['nick_name'];//urlencode($inputObj['nick_name']);//$inputObj['send_name'];
  129. $param['re_openid'] = $inputObj['openid'];
  130. $param['total_amount'] = $inputObj['total_amount'];
  131. $param['min_value'] = $inputObj['total_amount'];
  132. $param['max_value'] = $inputObj['total_amount'];
  133. $param['total_num'] = 1;
  134. $param['wishing'] = '恭喜发财';//urlencode('恭喜发财');//'恭喜发财';
  135. $param['client_ip'] = $_SERVER['REMOTE_ADDR'];
  136. $param['act_name'] = '组团成功';//urlencode('组团成功');//'组团成功';
  137. //$param['act_id'] = '';
  138. $param['remark'] = '团长红包';//urlencode('团长红包');//'团长红包';
  139. $param['nonce_str'] = self::getNonceStr();
  140. $param['sign'] = self::MakeSignfh($param);
  141. $xml = self::arrdatetoxml($param);
  142. //$xml = iconv("UTF-8", "ISO8859-1", $xml);
  143. $startTimeStamp = self::getMillisecond();//请求开始时间
  144. //var_dump($startTimeStamp);die(); ISO8859-1
  145. $response = self::postXmlCurl($xml, $url, true, $timeOut);
  146. libxml_disable_entity_loader(true);
  147. $result = json_decode(json_encode(simplexml_load_string($response, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
  148. $res_data = array();
  149. if($result['return_code']=='SUCCESS')
  150. {
  151. $res_data['ret'] = 1;
  152. $res_data['mes'] = $result['return_msg'];
  153. } else {
  154. $res_data['ret'] = 0;
  155. $res_data['mes'] = $result['return_msg'];
  156. }
  157. return $res_data;
  158. }
  159. public static function arrdatetoxml($values)
  160. {
  161. $xml = "<xml>";
  162. foreach ($values as $key=>$val)
  163. {
  164. if (is_numeric($val)){
  165. $xml.="<".$key.">".$val."</".$key.">";
  166. }else{
  167. $xml.="<".$key."><![CDATA[".$val."]]></".$key.">";
  168. }
  169. }
  170. $xml.="</xml>";
  171. return $xml;
  172. }
  173. /**
  174. * 生成签名
  175. * @return 签名,本函数不覆盖sign成员变量,如要设置签名需要调用SetSign方法赋值
  176. */
  177. public static function MakeSignfh($values)
  178. {
  179. $pay_key = D('Home/Front')->get_config_by_name('wepro_key');
  180. //签名步骤一:按字典序排序参数
  181. ksort($values);
  182. $string = self::ToUrlParamsfh($values);
  183. //var_dump($string);die();
  184. //签名步骤二:在string后加入KEY
  185. $string = $string . "&key=".$pay_key;
  186. //签名步骤三:MD5加密
  187. $string = md5($string);
  188. //签名步骤四:所有字符转为大写
  189. $result = strtoupper($string);
  190. return $result;
  191. }
  192. /**
  193. * 格式化参数格式化成url参数
  194. */
  195. public static function ToUrlParamsfh($values)
  196. {
  197. $buff = "";
  198. foreach ($values as $k => $v)
  199. {
  200. if($k != "sign" && $v != "" && !is_array($v)){
  201. $buff .= $k . "=" . $v . "&";
  202. }
  203. }
  204. $buff = trim($buff, "&");
  205. return $buff;
  206. }
  207. public static function payToUser($openid,$amount,$username,$desc,$partner_trade_no,$uniacid=0)
  208. {
  209. $wepro_appid = D('Home/Front')->get_config_by_name('wepro_appid');
  210. $mchid = D('Home/Front')->get_config_by_name('wepro_partnerid');
  211. $wepro_key = D('Home/Front')->get_config_by_name('wepro_key');
  212. $url = 'https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers';
  213. $params = array();
  214. $params['amount'] = $amount;
  215. $params['desc'] = $desc;
  216. $params['mch_appid'] = $wepro_appid;
  217. $params['mchid'] = $mchid;
  218. $params['nonce_str'] = self::getNonceStr();
  219. $params['partner_trade_no'] = $partner_trade_no;
  220. $params['openid'] = $openid;
  221. $params['check_name'] = 'FORCE_CHECK';
  222. $params['re_user_name'] = $username;
  223. $params['spbill_create_ip'] = $_SERVER['REMOTE_ADDR'];
  224. $strs = "";
  225. if(!empty($params)){
  226. $p = ksort($params);
  227. if($p){
  228. $str = '';
  229. foreach ($params as $k=>$val){
  230. $str .= $k .'=' . $val . '&';
  231. }
  232. $strs = rtrim($str, '&');
  233. }
  234. }
  235. //$str = 'amount='.$params["amount"].'&check_name='.$params["check_name"].'&desc='.$params["desc"].'&mch_appid='.$params["mch_appid"].'&mchid='.$params["mchid"].'&nonce_str='.$params["nonce_str"].'&openid='.$params["openid"].'&partner_trade_no='.$params["partner_trade_no"].'&spbill_create_ip='.$params['spbill_create_ip'].'&key='.$wepro_key;
  236. $str = $strs.'&key='.$wepro_key;
  237. $sign = strtoupper(md5($str));
  238. $params['sign'] = $sign;
  239. $xml = self::arrdatetoxml($params);
  240. $response = self::postXmlCurl($xml, $url, true ,6 );
  241. libxml_disable_entity_loader(true);
  242. $result = json_decode(json_encode(simplexml_load_string($response, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
  243. return $result;
  244. }
  245. /**
  246. *
  247. * 申请退款,WxPayRefund中out_trade_no、transaction_id至少填一个且
  248. * out_refund_no、total_fee、refund_fee、op_user_id为必填参数
  249. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  250. * @param WxPayRefund $inputObj
  251. * @param int $timeOut
  252. * @throws WxPayException
  253. * @return 成功时返回,其他抛异常
  254. */
  255. public static function refund($inputObj, $timeOut = 6,$from_type='weixin',$uniacid = 0)
  256. {
  257. $url = "https://api.mch.weixin.qq.com/secapi/pay/refund";
  258. //https://api.mch.weixin.qq.com/secapi/pay/refund
  259. //检测必填参数
  260. if(!$inputObj->IsOut_trade_noSet() && !$inputObj->IsTransaction_idSet()) {
  261. die("退款申请接口中,out_trade_no、transaction_id至少填一个!");
  262. throw new WxPayException("退款申请接口中,out_trade_no、transaction_id至少填一个!");
  263. }else if(!$inputObj->IsOut_refund_noSet()){
  264. die("退款申请接口中,缺少必填参数out_refund_no!");
  265. throw new WxPayException("退款申请接口中,缺少必填参数out_refund_no!");
  266. }else if(!$inputObj->IsTotal_feeSet()){
  267. die("退款申请接口中,缺少必填参数total_fee!");
  268. throw new WxPayException("退款申请接口中,缺少必填参数total_fee!");
  269. }else if(!$inputObj->IsRefund_feeSet()){
  270. die("退款申请接口中,缺少必填参数refund_fee!");
  271. throw new WxPayException("退款申请接口中,缺少必填参数refund_fee!");
  272. }else if(!$inputObj->IsOp_user_idSet()){
  273. die("退款申请接口中,缺少必填参数op_user_id!");
  274. throw new WxPayException("退款申请接口中,缺少必填参数op_user_id!");
  275. }
  276. //$inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  277. if($from_type =='wepro')
  278. {
  279. $wepro_appid = D('Home/Front')->get_config_by_name('wepro_appid');
  280. $inputObj->SetAppid($wepro_appid);//公众账号ID
  281. }else{
  282. $wepro_appid = D('Home/Front')->get_config_by_name('wepro_appid');
  283. $inputObj->SetAppid($wepro_appid);//公众账号ID
  284. }
  285. $mchid = D('Home/Front')->get_config_by_name('wepro_partnerid', $uniacid);
  286. $inputObj->SetMch_id($mchid);//商户号
  287. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  288. $inputObj->SetSign();//签名
  289. $xml = $inputObj->ToXml();
  290. $startTimeStamp = self::getMillisecond();//请求开始时间
  291. //var_dump($startTimeStamp);die();
  292. $response = self::postXmlCurl($xml, $url, true, $timeOut);
  293. //var_dump($response);die();
  294. $result = WxPayResults::Init($response);
  295. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  296. return $result;
  297. }
  298. /**
  299. *
  300. * 查询退款
  301. * 提交退款申请后,通过调用该接口查询退款状态。退款有一定延时,
  302. * 用零钱支付的退款20分钟内到账,银行卡支付的退款3个工作日后重新查询退款状态。
  303. * WxPayRefundQuery中out_refund_no、out_trade_no、transaction_id、refund_id四个参数必填一个
  304. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  305. * @param WxPayRefundQuery $inputObj
  306. * @param int $timeOut
  307. * @throws WxPayException
  308. * @return 成功时返回,其他抛异常
  309. */
  310. public static function refundQuery($inputObj, $timeOut = 6)
  311. {
  312. $url = "https://api.mch.weixin.qq.com/pay/refundquery";
  313. //检测必填参数
  314. if(!$inputObj->IsOut_refund_noSet() &&
  315. !$inputObj->IsOut_trade_noSet() &&
  316. !$inputObj->IsTransaction_idSet() &&
  317. !$inputObj->IsRefund_idSet()) {
  318. throw new WxPayException("退款查询接口中,out_refund_no、out_trade_no、transaction_id、refund_id四个参数必填一个!");
  319. }
  320. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  321. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  322. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  323. $inputObj->SetSign();//签名
  324. $xml = $inputObj->ToXml();
  325. $startTimeStamp = self::getMillisecond();//请求开始时间
  326. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  327. $result = WxPayResults::Init($response);
  328. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  329. return $result;
  330. }
  331. /**
  332. * 下载对账单,WxPayDownloadBill中bill_date为必填参数
  333. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  334. * @param WxPayDownloadBill $inputObj
  335. * @param int $timeOut
  336. * @throws WxPayException
  337. * @return 成功时返回,其他抛异常
  338. */
  339. public static function downloadBill($inputObj, $timeOut = 6)
  340. {
  341. $url = "https://api.mch.weixin.qq.com/pay/downloadbill";
  342. //检测必填参数
  343. if(!$inputObj->IsBill_dateSet()) {
  344. throw new WxPayException("对账单接口中,缺少必填参数bill_date!");
  345. }
  346. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  347. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  348. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  349. $inputObj->SetSign();//签名
  350. $xml = $inputObj->ToXml();
  351. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  352. if(substr($response, 0 , 5) == "<xml>"){
  353. return "";
  354. }
  355. return $response;
  356. }
  357. /**
  358. * 提交被扫支付API
  359. * 收银员使用扫码设备读取微信用户刷卡授权码以后,二维码或条码信息传送至商户收银台,
  360. * 由商户收银台或者商户后台调用该接口发起支付。
  361. * WxPayWxPayMicroPay中body、out_trade_no、total_fee、auth_code参数必填
  362. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  363. * @param WxPayWxPayMicroPay $inputObj
  364. * @param int $timeOut
  365. */
  366. public static function micropay($inputObj, $timeOut = 10)
  367. {
  368. $url = "https://api.mch.weixin.qq.com/pay/micropay";
  369. //检测必填参数
  370. if(!$inputObj->IsBodySet()) {
  371. throw new WxPayException("提交被扫支付API接口中,缺少必填参数body!");
  372. } else if(!$inputObj->IsOut_trade_noSet()) {
  373. throw new WxPayException("提交被扫支付API接口中,缺少必填参数out_trade_no!");
  374. } else if(!$inputObj->IsTotal_feeSet()) {
  375. throw new WxPayException("提交被扫支付API接口中,缺少必填参数total_fee!");
  376. } else if(!$inputObj->IsAuth_codeSet()) {
  377. throw new WxPayException("提交被扫支付API接口中,缺少必填参数auth_code!");
  378. }
  379. $inputObj->SetSpbill_create_ip($_SERVER['REMOTE_ADDR']);//终端ip
  380. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  381. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  382. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  383. $inputObj->SetSign();//签名
  384. $xml = $inputObj->ToXml();
  385. $startTimeStamp = self::getMillisecond();//请求开始时间
  386. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  387. $result = WxPayResults::Init($response);
  388. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  389. return $result;
  390. }
  391. /**
  392. *
  393. * 撤销订单API接口,WxPayReverse中参数out_trade_no和transaction_id必须填写一个
  394. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  395. * @param WxPayReverse $inputObj
  396. * @param int $timeOut
  397. * @throws WxPayException
  398. */
  399. public static function reverse($inputObj, $timeOut = 6)
  400. {
  401. $url = "https://api.mch.weixin.qq.com/secapi/pay/reverse";
  402. //检测必填参数
  403. if(!$inputObj->IsOut_trade_noSet() && !$inputObj->IsTransaction_idSet()) {
  404. throw new WxPayException("撤销订单API接口中,参数out_trade_no和transaction_id必须填写一个!");
  405. }
  406. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  407. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  408. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  409. $inputObj->SetSign();//签名
  410. $xml = $inputObj->ToXml();
  411. $startTimeStamp = self::getMillisecond();//请求开始时间
  412. $response = self::postXmlCurl($xml, $url, true, $timeOut);
  413. $result = WxPayResults::Init($response);
  414. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  415. return $result;
  416. }
  417. /**
  418. *
  419. * 测速上报,该方法内部封装在report中,使用时请注意异常流程
  420. * WxPayReport中interface_url、return_code、result_code、user_ip、execute_time_必填
  421. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  422. * @param WxPayReport $inputObj
  423. * @param int $timeOut
  424. * @throws WxPayException
  425. * @return 成功时返回,其他抛异常
  426. */
  427. public static function report($inputObj, $timeOut = 1)
  428. {
  429. $url = "https://api.mch.weixin.qq.com/payitil/report";
  430. //检测必填参数
  431. if(!$inputObj->IsInterface_urlSet()) {
  432. throw new WxPayException("接口URL,缺少必填参数interface_url!");
  433. } if(!$inputObj->IsReturn_codeSet()) {
  434. throw new WxPayException("返回状态码,缺少必填参数return_code!");
  435. } if(!$inputObj->IsResult_codeSet()) {
  436. throw new WxPayException("业务结果,缺少必填参数result_code!");
  437. } if(!$inputObj->IsUser_ipSet()) {
  438. throw new WxPayException("访问接口IP,缺少必填参数user_ip!");
  439. } if(!$inputObj->IsExecute_time_Set()) {
  440. throw new WxPayException("接口耗时,缺少必填参数execute_time_!");
  441. }
  442. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  443. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  444. $inputObj->SetUser_ip($_SERVER['REMOTE_ADDR']);//终端ip
  445. $inputObj->SetTime(date("YmdHis"));//商户上报时间
  446. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  447. $inputObj->SetSign();//签名
  448. $xml = $inputObj->ToXml();
  449. $startTimeStamp = self::getMillisecond();//请求开始时间
  450. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  451. return $response;
  452. }
  453. /**
  454. *
  455. * 生成二维码规则,模式一生成支付二维码
  456. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  457. * @param WxPayBizPayUrl $inputObj
  458. * @param int $timeOut
  459. * @throws WxPayException
  460. * @return 成功时返回,其他抛异常
  461. */
  462. public static function bizpayurl($inputObj, $timeOut = 6)
  463. {
  464. if(!$inputObj->IsProduct_idSet()){
  465. throw new WxPayException("生成二维码,缺少必填参数product_id!");
  466. }
  467. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  468. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  469. $inputObj->SetTime_stamp(time());//时间戳
  470. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  471. $inputObj->SetSign();//签名
  472. return $inputObj->GetValues();
  473. }
  474. /**
  475. *
  476. * 转换短链接
  477. * 该接口主要用于扫码原生支付模式一中的二维码链接转成短链接(weixin://wxpay/s/XXXXXX),
  478. * 减小二维码数据量,提升扫描速度和精确度。
  479. * appid、mchid、spbill_create_ip、nonce_str不需要填入
  480. * @param WxPayShortUrl $inputObj
  481. * @param int $timeOut
  482. * @throws WxPayException
  483. * @return 成功时返回,其他抛异常
  484. */
  485. public static function shorturl($inputObj, $timeOut = 6)
  486. {
  487. $url = "https://api.mch.weixin.qq.com/tools/shorturl";
  488. //检测必填参数
  489. if(!$inputObj->IsLong_urlSet()) {
  490. throw new WxPayException("需要转换的URL,签名用原串,传输需URL encode!");
  491. }
  492. $inputObj->SetAppid(WxPayConfig::APPID);//公众账号ID
  493. $inputObj->SetMch_id(WxPayConfig::MCHID);//商户号
  494. $inputObj->SetNonce_str(self::getNonceStr());//随机字符串
  495. $inputObj->SetSign();//签名
  496. $xml = $inputObj->ToXml();
  497. $startTimeStamp = self::getMillisecond();//请求开始时间
  498. $response = self::postXmlCurl($xml, $url, false, $timeOut);
  499. $result = WxPayResults::Init($response);
  500. self::reportCostTime($url, $startTimeStamp, $result);//上报请求花费时间
  501. return $result;
  502. }
  503. /**
  504. *
  505. * 支付结果通用通知
  506. * @param function $callback
  507. * 直接回调函数使用方法: notify(you_function);
  508. * 回调类成员函数方法:notify(array($this, you_function));
  509. * $callback 原型为:function function_name($data){}
  510. */
  511. public static function notify($callback, &$msg)
  512. {
  513. //获取通知的数据
  514. if( !isset($GLOBALS['HTTP_RAW_POST_DATA']) )
  515. {
  516. $xml = file_get_contents('php://input');
  517. }else{
  518. $xml = $GLOBALS['HTTP_RAW_POST_DATA'];
  519. }
  520. //如果返回成功则验证签名
  521. try {
  522. $result = WxPayResults::Init($xml);
  523. } catch (WxPayException $e){
  524. $msg = $e->errorMessage();
  525. return false;
  526. }
  527. return call_user_func($callback, $result);
  528. }
  529. /**
  530. *
  531. * 产生随机字符串,不长于32位
  532. * @param int $length
  533. * @return 产生的随机字符串
  534. */
  535. public static function getNonceStr($length = 32)
  536. {
  537. $chars = "abcdefghijklmnopqrstuvwxyz0123456789";
  538. $str ="";
  539. for ( $i = 0; $i < $length; $i++ ) {
  540. $str .= substr($chars, mt_rand(0, strlen($chars)-1), 1);
  541. }
  542. return $str;
  543. }
  544. /**
  545. * 直接输出xml
  546. * @param string $xml
  547. */
  548. public static function replyNotify($xml)
  549. {
  550. echo $xml;
  551. }
  552. /**
  553. *
  554. * 上报数据, 上报的时候将屏蔽所有异常流程
  555. * @param string $usrl
  556. * @param int $startTimeStamp
  557. * @param array $data
  558. */
  559. private static function reportCostTime($url, $startTimeStamp, $data)
  560. {
  561. //如果不需要上报数据
  562. if(WxPayConfig::REPORT_LEVENL == 0){
  563. return;
  564. }
  565. //如果仅失败上报
  566. if(WxPayConfig::REPORT_LEVENL == 1 &&
  567. array_key_exists("return_code", $data) &&
  568. $data["return_code"] == "SUCCESS" &&
  569. array_key_exists("result_code", $data) &&
  570. $data["result_code"] == "SUCCESS")
  571. {
  572. return;
  573. }
  574. //上报逻辑
  575. $endTimeStamp = self::getMillisecond();
  576. $objInput = new WxPayReport();
  577. $objInput->SetInterface_url($url);
  578. $objInput->SetExecute_time_($endTimeStamp - $startTimeStamp);
  579. //返回状态码
  580. if(array_key_exists("return_code", $data)){
  581. $objInput->SetReturn_code($data["return_code"]);
  582. }
  583. //返回信息
  584. if(array_key_exists("return_msg", $data)){
  585. $objInput->SetReturn_msg($data["return_msg"]);
  586. }
  587. //业务结果
  588. if(array_key_exists("result_code", $data)){
  589. $objInput->SetResult_code($data["result_code"]);
  590. }
  591. //错误代码
  592. if(array_key_exists("err_code", $data)){
  593. $objInput->SetErr_code($data["err_code"]);
  594. }
  595. //错误代码描述
  596. if(array_key_exists("err_code_des", $data)){
  597. $objInput->SetErr_code_des($data["err_code_des"]);
  598. }
  599. //商户订单号
  600. if(array_key_exists("out_trade_no", $data)){
  601. $objInput->SetOut_trade_no($data["out_trade_no"]);
  602. }
  603. //设备号
  604. if(array_key_exists("device_info", $data)){
  605. $objInput->SetDevice_info($data["device_info"]);
  606. }
  607. try{
  608. self::report($objInput);
  609. } catch (WxPayException $e){
  610. //不做任何处理
  611. }
  612. }
  613. /**
  614. * 以post方式提交xml到对应的接口url
  615. *
  616. * @param string $xml 需要post的xml数据
  617. * @param string $url url
  618. * @param bool $useCert 是否需要证书,默认不需要
  619. * @param int $second url执行超时时间,默认30s
  620. * @throws WxPayException
  621. */
  622. private static function postXmlCurl($xml, $url, $useCert = false, $second = 30, $uniacid=0)
  623. {
  624. $ch = curl_init();
  625. //设置超时
  626. curl_setopt($ch, CURLOPT_TIMEOUT, $second);
  627. //如果有配置代理这里就设置代理
  628. /**
  629. if(WxPayConfig::CURL_PROXY_HOST != "0.0.0.0"
  630. && WxPayConfig::CURL_PROXY_PORT != 0){
  631. curl_setopt($ch,CURLOPT_PROXY, WxPayConfig::CURL_PROXY_HOST);
  632. curl_setopt($ch,CURLOPT_PROXYPORT, WxPayConfig::CURL_PROXY_PORT);
  633. }
  634. **/
  635. curl_setopt($ch,CURLOPT_URL, $url);
  636. curl_setopt($ch,CURLOPT_SSL_VERIFYPEER,false);
  637. curl_setopt($ch,CURLOPT_SSL_VERIFYHOST,false);//严格校验
  638. //设置header
  639. curl_setopt($ch, CURLOPT_HEADER, FALSE);
  640. //要求结果为字符串且输出到屏幕上
  641. curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
  642. if($useCert == true){
  643. $path = ROOT_PATH.'/Data/wxpaylogs/';
  644. $wechat_apiclient_cert_pem = D('Home/Front')->get_config_by_name('wechat_apiclient_cert_pem');
  645. $wechat_apiclient_key_pem = D('Home/Front')->get_config_by_name('wechat_apiclient_key_pem');
  646. $file_cert_name = mt_rand(1,99).'_cert.pem';
  647. $file_key_name = mt_rand(100,999).'_key.pem';
  648. file_put_contents($path.$file_cert_name,$wechat_apiclient_cert_pem);
  649. file_put_contents($path.$file_key_name,$wechat_apiclient_key_pem);
  650. //设置证书
  651. //使用证书:cert 与 key 分别属于两个.pem文件
  652. curl_setopt($ch,CURLOPT_SSLCERTTYPE,'PEM');
  653. curl_setopt($ch,CURLOPT_SSLCERT, $path.$file_cert_name );
  654. curl_setopt($ch,CURLOPT_SSLKEYTYPE,'PEM');
  655. curl_setopt($ch,CURLOPT_SSLKEY, $path.$file_key_name );
  656. }
  657. //post提交方式
  658. curl_setopt($ch, CURLOPT_POST, TRUE);
  659. curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
  660. //运行curl
  661. $data = curl_exec($ch);
  662. //var_dump( $data);die();
  663. //返回结果
  664. if($data){
  665. if($useCert == true)
  666. {
  667. unlink($path.$file_cert_name);
  668. unlink($path.$file_key_name);
  669. }
  670. curl_close($ch);
  671. return $data;
  672. } else {
  673. $error = curl_errno($ch);
  674. curl_close($ch);
  675. throw new WxPayException("curl出错,错误码:$error");
  676. }
  677. }
  678. /**
  679. * 获取毫秒级别的时间戳
  680. */
  681. private static function getMillisecond()
  682. {
  683. //获取毫秒的时间戳
  684. $time = explode ( " ", microtime () );
  685. $time = $time[1] . ($time[0] * 1000);
  686. $time2 = explode( ".", $time );
  687. $time = $time2[0];
  688. return $time;
  689. }
  690. }