微信支付成功后的异步通知处理

app/mobile/controller/Common.php

@@ -59,4 +59,10 @@ class Common extends BaseController
         return CommonLogic::getPrepayId($param);
     }
 
+    //微信支付成功后的异步通知及订单处理
+    public function Notify(){
+
+        return CommonLogic::Notify();
+    }
+
 }

app/mobile/logic/CommonLogic.php

@@ -228,4 +228,78 @@ class CommonLogic extends BaseLogic
 
     }
 
+    //微信支付成功后的异步通知及订单处理
+    public static function Notify()
+    {
+
+        Db::startTrans();
+        try {
+
+            $notifyInfo = WechatLogic::Notify();
+
+            $pay_info = PayInfoModel::field('id,type,status')
+                ->where('code', $notifyInfo['out_trade_no'])
+                ->findOrEmpty();
+
+            if ($pay_info->isEmpty()) throw new Exception('该支付信息不存在');
+
+            //待处理
+            if ($pay_info->status == CommonModel::$order_status_wait_pay) {
+
+                $updatetime = date('Y-m-d H:i:s');
+
+                PayInfoModel::where(['code' => $notifyInfo['out_trade_no'], 'status' => CommonModel::$order_status_wait_pay])
+                    ->save([
+                        'status' => CommonModel::$order_status_not_deliver,
+                        'updaterid' => '0',
+                        'updater' => '微信支付',
+                        'updatetime' => $updatetime,
+                        'transaction_id' => $notifyInfo['transaction_id'],
+                        'trade_type' => $notifyInfo['trade_type'],
+                        'notify_result' => json_encode($notifyInfo, JSON_UNESCAPED_UNICODE),
+                    ]);
+
+                if ($pay_info->type == GoodModel::$type_exchange) {
+                    //兑换商品订单
+                    Db::name('order')
+                        ->where(['is_del' => CommonModel::$del_normal, 'pay_info_id' => $pay_info->id, 'status' => CommonModel::$order_status_wait_pay])
+                        ->update([
+                            'updaterid' => '0',
+                            'updater' => '微信支付',
+                            'updatetime' => $updatetime,
+                            'status' => CommonModel::$order_status_not_deliver
+                        ]);
+
+
+                } else {
+                    //服务订单
+                    Db::name('order_service')
+                        ->where(['is_del' => CommonModel::$del_normal, 'pay_info_id' => $pay_info->id, 'status' => CommonModel::$order_status_wait_pay])
+                        ->update([
+                            'updaterid' => '0',
+                            'updater' => '微信支付',
+                            'updatetime' => $updatetime,
+                            'status' => CommonModel::$order_status_not_deliver
+                        ]);
+                }
+
+            }
+
+
+            Db::commit();
+            return xml(['return_code' => 'SUCCESS', 'return_msg' => 'DEAL WITH SUCCESS']);
+        } catch (Exception $exception) {
+            Db::rollback();
+            return xml(['return_code' => 'FAIL', 'return_msg' => $exception->getMessage()]);
+        }
+
+        // 返回XML状态，至于XML数据可以自己生成，成功状态是必须要返回的。
+        // <xml>
+        //    return_code><![CDATA[SUCCESS]]></return_code>
+        //    return_msg><![CDATA[OK]]></return_msg>
+        // </xml>
+
+
+    }
+
 }

app/mobile/logic/WechatLogic.php

@@ -4,6 +4,7 @@
 namespace app\mobile\logic;
 
 //关于微信相关操作的工具类
+use think\Exception;
 use think\exception\ValidateException;
 use think\facade\Config;
 use think\facade\Validate;
@@ -51,7 +52,7 @@ class WechatLogic
     public static function getPrepayId(string $openid = '', string $body = '', string $out_trade_no = '', float $total_fee = 0, string $notify_url = '', string $trade_type = "JSAPI")
     {
 
-        if($notify_url == '') $notify_url=env('notify_url');
+        if ($notify_url == '') $notify_url = env('notify_url');
 
         $pay = &load_wechat('Pay');
 
@@ -61,4 +62,21 @@ class WechatLogic
     }
 
 
+    //支付通知回调
+    public static function Notify()
+    {
+
+        //实例化支付接口
+        $pay = &load_wechat('Pay');
+
+        //获取支付通知
+        $notifyInfo = $pay->getNotify();
+
+        if ($notifyInfo === false) throw new Exception('获取微信支付通知数据失败,' . $pay->errMsg);
+        elseif ($notifyInfo['result_code'] == 'SUCCESS' && $notifyInfo['return_code'] == 'SUCCESS') return $notifyInfo;// 支付状态完全成功，可以更新订单的支付状态了
+        else throw new Exception('获取微信支付通知数据失败,' . json_encode($notifyInfo, JSON_UNESCAPED_UNICODE));
+
+    }
+
+
 }

app/mobile/middleware/mobileMiddleware.php

@@ -18,7 +18,7 @@ class mobileMiddleware
 {
 
     //白名单
-    private $white_list = ['login'];
+    private $white_list = ['login', 'notify'];
 
     //请求入口
     public function handle($request, \Closure $next)
@@ -28,7 +28,7 @@ class mobileMiddleware
         $request->request_id = date('YmdHis') . mt_rand(100000, 999999);
 
         //接收参数
-        $param = $request->post();
+        $param = $request->param();
 
         //记录日志
         AccountLogModel::add($request->request_id, $param);
@@ -44,7 +44,7 @@ class mobileMiddleware
 
                 //获取用户信息
                 $account = $this->verifyMobileToken($param['token']);
-                BaseLogic::setUserInfo($account['aid'], $account['aname'], $account['company_id'], $account['card_id'],$account['group_id']);
+                BaseLogic::setUserInfo($account['aid'], $account['aname'], $account['company_id'], $account['card_id'], $account['group_id']);
 
                 $request->aid = $account['aid'];
                 $request->aname = $account['aname'];

app/mobile/route/app.php

@@ -9,6 +9,8 @@ Route::rule('info', 'Account/info');//账户详情
 Route::rule('updatePassword', 'Account/updatePassword');//修改密码
 Route::rule('bindAccountByCode', 'Account/bindAccountByCode');//通过微信端code绑定账户
 Route::rule('getPrepayId', 'Common/getPrepayId');//微信支付预下单
+Route::rule('notify', 'Common/Notify');//微信支付成功后的异步通知及订单处理
+
 
 //【公共】
 Route::rule('video', 'Common/getVideoList');//视频列表