Notify.php 3.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. <?php
  2. namespace app\h5\controller;
  3. use EasyWeChat\Factory;
  4. use think\Controller;
  5. use think\Db;
  6. class Notify extends Controller
  7. {
  8. public function pay(){
  9. $config = config('app.wx_config');
  10. $app = Factory::payment($config);
  11. $response = $app->handlePaidNotify(function ($message, $fail) {
  12. if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') { // return_code 表示通信状态,不代表支付状态
  13. // 用户是否支付成功
  14. $tradeNo = $message['out_trade_no'];
  15. // 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
  16. $order = Db::name('order_convey_pay')->where('sn',$tradeNo)->find();
  17. if (!$order || $order['status'] != 0) { // 如果订单不存在 或者 订单已经支付过了
  18. return true; // 告诉微信,我已经处理完了,订单没找到,别再通知我了
  19. }
  20. $ret = Db::name('order_convey_pay')->where('id',$order['id'])->update([
  21. 'type' => 2,
  22. 'status' => 1,
  23. 'pay_time' => date('Y-m-d H:i:s')
  24. ]);
  25. if(!$ret){
  26. trace('订单修改失败');
  27. $fail('订单修改失败');
  28. }
  29. } else {
  30. return $fail('通信失败,请稍后再通知我');
  31. }
  32. return true; // 返回处理完成
  33. });
  34. $response->send();
  35. }
  36. public function payDinner(){
  37. $org_id = input('org_id',0);
  38. $config = get_pay_wechat($org_id);
  39. $app = \EasyWeChat\Factory::payment($config);
  40. $response = $app->handlePaidNotify(function ($message, $fail) {
  41. if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') { // return_code 表示通信状态,不代表支付状态
  42. // 用户是否支付成功
  43. $ret = false;
  44. $tradeNo = $message['out_trade_no'];
  45. $info = Db::name('dinner_order')
  46. ->where('sn',$tradeNo)
  47. ->find();
  48. if(!$info){
  49. $ret = true;
  50. }else{
  51. if($info['state'] != 0){
  52. $ret = true;
  53. }else{
  54. $data = array(
  55. 'state' => 1,
  56. 'pay_time' => date('Y-m-d H:i:s'),
  57. 'update_time'=>date('Y-m-d H:i:s'),
  58. );
  59. $ret = Db::name('dinner_order')
  60. ->where('sn',$tradeNo)
  61. ->update($data);
  62. }
  63. }
  64. if($ret){
  65. return true; // 告诉微信,我已经处理完了,订单没找到,别再通知我了
  66. }else{
  67. $fail('订单修改失败');
  68. }
  69. //这儿通知打印机打印
  70. // $this->print($ordernumber);
  71. } else {
  72. return $fail('通信失败,请稍后再通知我');
  73. }
  74. return true; // 返回处理完成
  75. });
  76. $response->send();
  77. }
  78. }