Wechat.php 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303
  1. <?php namespace Pay\Lib;
  2. use Dever;
  3. Dever::apply('sdk/wechat', 'pay');
  4. class Wechat extends Core
  5. {
  6. public function __construct($config)
  7. {
  8. $project = Dever::project('pay');
  9. $this->config = new \WxPayConfig();
  10. # 通知接口
  11. $config['notify'] = $this->url($config['type'], $config['id']);
  12. # 证书
  13. $config['ssl'] = array
  14. (
  15. 'cert' => $config['file_cert'],
  16. 'key' => $config['file_key'],
  17. );
  18. $config['ip'] = (isset($config['ip']) && $config['ip']) ? $config['ip'] : Dever::ip();
  19. $this->config->set($config['appid'], $config['appsecret'], $config['mchid'], $config['notify'], $config['key'], $config['ssl'], $config['type'], $config['timeout'], $config['ip']);
  20. }
  21. /**
  22. * 通知
  23. */
  24. public function notify()
  25. {
  26. $this->log('支付回调-初始化', file_get_contents("php://input"));
  27. $callback = new Callback();
  28. $result = $callback->Handle($this->config, false);
  29. }
  30. # 查询订单
  31. public function search($order_id)
  32. {
  33. $info = Dever::db('pay/order')->one(array('order_id' => $order_id));
  34. if ($info && $info['status'] == 2) {
  35. $this->updateOrder($info['order_id'], 1);
  36. return $info;
  37. }
  38. return 2;
  39. if (!$info) {
  40. $input = new \WxPayOrderQuery();
  41. $input->SetOut_trade_no($order_id);
  42. $result = \WxPayApi::orderQuery($this->config, $input);
  43. if (isset($result['transaction_id']) && isset($result['out_trade_no']) && isset($result['trade_state_desc'])) {
  44. $this->updateOrder($result['out_trade_no'], $result['cash_fee']);
  45. }
  46. return $result;
  47. } else {
  48. return $info;
  49. }
  50. }
  51. /**
  52. * 获取统一下单的基本信息
  53. */
  54. public function order($account_id, $project_id, $uid, $username, $product_id, $name, $cash, $openid = false, $type = 1, $order_id = false)
  55. {
  56. $trade_type = $this->getType($type);
  57. $order_id = $this->createOrder($uid, $username, $account_id, $project_id, $product_id, $name, $cash, $this->config->GetType(), $order_id);
  58. $tools = new \JsApiPay($this->config);
  59. $input = new \WxPayUnifiedOrder();
  60. $input->SetBody($name);
  61. $input->SetAttach($name);
  62. $input->SetOut_trade_no($order_id);
  63. $input->SetTotal_fee($cash * 100);
  64. $input->SetTime_start(date("YmdHis"));
  65. $input->SetTime_expire(date("YmdHis", time() + $this->config->GetTimeOut()));
  66. //$input->SetGoods_tag($name);
  67. $input->SetNotify_url($this->config->GetNotifyUrl());
  68. $input->SetTrade_type($trade_type);
  69. $input->SetProduct_id($product_id);
  70. if ($type != 4 && $openid != -1) {
  71. $openid = $openid ? $openid : $tools->GetOpenid();
  72. $input->SetOpenid($openid);
  73. }
  74. if ($type == 2) {
  75. # 下单信息
  76. $this->updateOrderParam($order_id, $input);
  77. return $input;
  78. } else {
  79. $order = \WxPayApi::unifiedOrder($this->config, $input);
  80. # 下单信息
  81. $order['time'] = '' . time() . '';
  82. $order['order_id'] = $order_id;
  83. $order['sign_type'] = $this->config->GetSignType();
  84. unset($order['mch_id']);
  85. $this->updateOrderParam($order_id, $order);
  86. return $order;
  87. }
  88. }
  89. /**
  90. * 获取二维码支付
  91. */
  92. public function qrcode($order, $refer)
  93. {
  94. $notify = new \NativePay();
  95. $result = $notify->GetPayUrl($order);
  96. $url = $result['code_url'];
  97. return $url;
  98. }
  99. /**
  100. * 获取小程序支付
  101. */
  102. public function applet($order)
  103. {
  104. if (isset($order['prepay_id'])) {
  105. $string = 'appId='.$this->config->GetAppId().'&nonceStr='.$order['nonce_str'].'&package=prepay_id='.$order['prepay_id'].'&signType='.$order['sign_type'].'&timeStamp='.$order['time'].'&key='.$this->config->GetKey();
  106. $this->log('支付签名-applet', $string);
  107. if($order['sign_type'] == "MD5"){
  108. $string = md5($string);
  109. } else {
  110. $string = hash_hmac("sha256", $string, $this->config->GetKey());
  111. }
  112. $order['sign'] = $string;
  113. }
  114. return $order;
  115. }
  116. /**
  117. * 获取app支付
  118. */
  119. public function app($order)
  120. {
  121. if (isset($order['prepay_id'])) {
  122. $order['partnerid'] = $this->config->GetMerchantId();
  123. $order['package_string'] = 'Sign=WXPay';
  124. $string = array();
  125. $string['appid'] = $this->config->GetAppId();
  126. $string['partnerid'] = $order['partnerid'];
  127. $string['prepayid'] = $order['prepay_id'];
  128. $string['package'] = $order['package_string'];
  129. $string['noncestr'] = $order['nonce_str'];
  130. $string['timestamp'] = $order['time'];
  131. ksort($string);
  132. $string = str_replace('%3D', '=', http_build_query($string));
  133. $string .= '&key=' . $this->config->GetKey();
  134. $this->log('支付签名-app', $string);
  135. if($order['sign_type'] == "MD5"){
  136. $string = md5($string);
  137. } else {
  138. $string = hash_hmac("sha256", $string, $this->config->GetKey());
  139. }
  140. $order['sign'] = $string;
  141. }
  142. return $order;
  143. }
  144. /**
  145. * 获取页面支付
  146. */
  147. public function page($order, $refer)
  148. {
  149. if (isset($order['mweb_url'])) {
  150. $url = $order['mweb_url'] . '&redirect_url=' . $refer;
  151. if (!$url) {
  152. $location = 'window.open("' . $url . '")';
  153. } else {
  154. $location = 'location.href="' . $url . '"';
  155. }
  156. return '<script type="text/javascript">'.$location.'</script>';
  157. }
  158. $refer = urldecode($refer);
  159. $tools = new \JsApiPay($this->config);
  160. $info = $tools->GetJsApiParameters($order);
  161. $html = '<script type="text/javascript">
  162. function jsApiCall()
  163. {
  164. WeixinJSBridge.invoke(
  165. "getBrandWCPayRequest",
  166. '.$info.',
  167. function(res){
  168. //WeixinJSBridge.log(res.err_msg);
  169. if(res.err_msg == "get_brand_wcpay_request:ok")
  170. {
  171. location.href = "'.$refer.'";
  172. } else {
  173. alert("支付失败");
  174. //alert(res.err_code+res.err_desc+res.err_msg);
  175. }
  176. }
  177. );
  178. }
  179. function callpay()
  180. {
  181. if (typeof WeixinJSBridge == "undefined"){
  182. if( document.addEventListener ){
  183. document.addEventListener("WeixinJSBridgeReady", jsApiCall, false);
  184. }else if (document.attachEvent){
  185. document.attachEvent("WeixinJSBridgeReady", jsApiCall);
  186. document.attachEvent("onWeixinJSBridgeReady", jsApiCall);
  187. }
  188. }else{
  189. jsApiCall();
  190. }
  191. }
  192. callpay();
  193. </script>';
  194. return $html;
  195. }
  196. private function getType($type)
  197. {
  198. switch ($type) {
  199. case 1:
  200. $type = 'JSAPI';
  201. break;
  202. case 2:
  203. $type = 'NATIVE';
  204. break;
  205. case 3:
  206. $type = 'APP';
  207. break;
  208. case 4:
  209. $type = 'MWEB';
  210. break;
  211. }
  212. return $type;
  213. }
  214. }
  215. class Callback extends \WxPayNotify
  216. {
  217. public function NotifyProcess($objData, $config, &$msg)
  218. {
  219. $data = $objData->GetValues();
  220. $obj = Dever::load('pay/lib/core');
  221. $obj->log('支付回调-获取数据', $data);
  222. $callback = function($msg = '') use ($obj, $data) {
  223. if ($msg) {
  224. $msg = $data['transaction_id'] . ':' . $msg;
  225. }
  226. $obj->updateOrder($data['out_trade_no'], $data['cash_fee'], $msg);
  227. };
  228. if(!array_key_exists("transaction_id", $data)){
  229. $msg = '输入参数不正确';
  230. $callback($msg);
  231. return false;
  232. }
  233. # 参数校验
  234. if(!array_key_exists("return_code", $data)
  235. ||(array_key_exists("return_code", $data) && $data['return_code'] != "SUCCESS")) {
  236. $msg = $data['return_code'] . '(异常)';
  237. $callback($msg);
  238. return false;
  239. }
  240. # 进行签名验证
  241. try {
  242. $checkResult = $objData->CheckSign($config);
  243. if($checkResult == false){
  244. $msg = '签名错误';
  245. $callback($msg);
  246. return false;
  247. }
  248. } catch(Exception $e) {
  249. $msg = '签名异常';
  250. $callback($msg);
  251. return false;
  252. }
  253. # 查询订单,判断订单真实性
  254. /*
  255. if(!$this->Queryorder($data["transaction_id"])){
  256. $msg = '订单查询失败';
  257. $callback($msg);
  258. return false;
  259. }
  260. */
  261. # 处理业务逻辑
  262. $callback();
  263. return true;
  264. }
  265. }