devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

fastAdmin支付插件之异步回调问题，处理并发通知_fastadmin异步处理

作者：知新_RL | 2024-02-22 23:44:54

赞

踩

fastadmin异步处理

最近使用FastAdmin的支付插件来开发了一个PC端扫码充值余额的功能。在成功充值后，我遇到了微信服务器多次发送异步回调通知，我的数据多次修改的问题。我按照FastAdmin支付插件里的回调响应，

  1. //下面这句必须要执行,且在此之前不能有任何输出
  2. return $pay->success()->send();

但是我觉得这一行代码没有实际作用（不知道是否是bug，网上没找到相关解决的办法），因此没有向微信服务器发送成功的响应消息使微信不再推送。这导致微信服务器继续发送通知，最终导致我的数据被多次修改，以下内容主要是解决这个问题。

我查阅了微信支付官方文档，发现文档明确指出：“同样的通知可能会多次发送给商户系统。商户系统必须能够正确处理重复的通知。” 推荐的做法是，当商户系统收到通知后，首先检查相关业务数据的状态，判断通知是否已经被处理。如果尚未处理，则进行处理；如果已经处理，则直接返回处理成功的结果。在处理业务数据之前，必须使用数据锁来进行并发控制，以防止函数重入造成数据混乱。

并发控制确实是需要考虑的问题。下面是我打印的日志：

  1. 写入时间:	2023-09-15 10:07:21
  2. 支付时间:	2023-09-15T10:07:20+08:00
  3. 商户订单号:	R20230915100609000017
  4. 支付方式:	wechat
  5. 微信支付系统订单号:	4200001944202309159886018410
  6. 支付类型:	NATIVE
  7. 总金额:	0.01
  8. 用户支付金额:	0.01
  9. 付款银行:	OTHERS
  10. 支付手续费:	0
  11. 支付状态:	SUCCESS
  12. ============================================================================
  13.  
  14. 写入时间:	2023-09-15 10:07:23
  15. 支付时间:	2023-09-15T10:07:20+08:00
  16. 商户订单号:	R20230915100609000017
  17. 支付方式:	wechat
  18. 微信支付系统订单号:	4200001944202309159886018410
  19. 支付类型:	NATIVE
  20. 总金额:	0.01
  21. 用户支付金额:	0.01
  22. 付款银行:	OTHERS
  23. 支付手续费:	0
  24. 支付状态:	SUCCESS
  25. ============================================================================
  26.  
  27. 写入时间:	2023-09-15 10:07:37
  28. 支付时间:	2023-09-15T10:07:20+08:00
  29. 商户订单号:	R20230915100609000017
  30. 支付方式:	wechat
  31. 微信支付系统订单号:	4200001944202309159886018410
  32. 支付类型:	NATIVE
  33. 总金额:	0.01
  34. 用户支付金额:	0.01
  35. 付款银行:	OTHERS
  36. 支付手续费:	0
  37. 支付状态:	SUCCESS
  38. ============================================================================

显示微信服务器在短短5秒内发送了3次通知。由于我的余额修改业务代码位于异步通知中，因此我的余额连续修改了三次。这导致我的余额瞬间暴涨，我的血压也随之上升。这对用户来说是一个“好事”，对于我来说就是要命呐，多余的资金还得自己承担。

为了解决并发请求异步回调的问题，我采取了下面的方法：

  1. /**
  2.      *  商户订单号作为标识同一个请求
  3.      *  查询数据库支付订单状态是否修改为已经支付，是则退出
  4.      *  根据订单号首字母区别是客户下单支付还是充值余额
  5.      *  O：客户下单  R: 客户充值
  6.      *  支付成功异步通知
  7.      */
  8.     public function notifyx()
  9.     {
  10.         $paytype = $this->request->param('paytype');
  11.         $pay = Service::checkNotify($paytype);
  12.         if (!$pay) {
  13.             echo '签名错误';
  14.             return;
  15.         }
  16.         $data = Service::isVersionV3() ? $pay->callback() : $pay->verify();
  17.  
  18.         try {
  19.             $payamount = $paytype == 'alipay' ? $data['total_amount'] : $data['total_fee'] / 100;
  20.             'wechat' == $paytype ? $pay_method = 0 : $pay_method = 1;
  21.             // 微信支付
  22.             if($pay_method == 0){
  23.                 $out_trade_no = $data['resource']['ciphertext']['out_trade_no'];
  24.                 // 获取 Redis 实例并选择数据库
  25.                 $redis = Cache::store('redis')->handler();
  26.                 // 选择数据库
  27.                 $redis->select(8);
  28.                 // 是否添加锁表
  29.                 $addLock = false;
  30.                 // 使用 Lua 脚本确保分布式锁的原子性
  31.                 //redis.call('SET', key, 1, 'EX', 60 * 60 * 24 * 7) -- 设置为7天的过期时间
  32.                 $script = <<<LUA
  33.         local key = KEYS[1]
  34.         local exists = redis.call('EXISTS', key)
  35.         if exists == 0 then
  36.         redis.call('SET', key, 1, 'EX', 60 * 2) 
  37.         end
  38.         return exists
  39. LUA;
  40.                 $result = $redis->eval($script, [$out_trade_no], 1);
  41.  
  42.                 if ($result == 1) {
  43.                     //订单号已经存在则锁住;
  44.                     $addLock = true;
  45.                 }
  46.                 if ($addLock) {
  47.                     return;
  48.                 }
  49.                 // 同一请求已经处理则退出
  50.                 if($this->isThameRequest($out_trade_no)){
  51.                     return json(['code' => 'SUCCESS', 'message' => '成功']);
  52.                 }
  53.                 $transaction_id = $data['resource']['ciphertext']['transaction_id'];
  54.                 $trade_type = $data['resource']['ciphertext']['trade_type'];
  55.                 $success_time = $data['resource']['ciphertext']['success_time'];
  56.                 $total = $data['resource']['ciphertext']['amount']['total'] * 0.01;
  57.                 $payer_total = $data['resource']['ciphertext']['amount']['payer_total'] * 0.01;
  58.                 $openid = $data['resource']['ciphertext']['payer']['openid'];
  59.                 $bank_type = $data['resource']['ciphertext']['bank_type'];
  60.                 $status = $data['resource']['ciphertext']['trade_state'];
  61.                 // 记录日志
  62.                 $logMessage = "写入时间:\t".date('Y-m-d H:i:s')."\n";
  63.                 $logMessage .= "支付时间:\t" . $success_time . "\n";
  64.                 $logMessage .= "商户订单号:\t" . $out_trade_no . "\n";
  65.                 $logMessage .= "支付方式:\t" . $paytype. "\n";
  66.                 $logMessage .= "微信支付系统订单号:\t" . $transaction_id . "\n";
  67.                 $logMessage .= "支付类型:\t" . $trade_type. "\n";
  68.                 $logMessage .= "总金额:\t" . $total. "\n";
  69.                 $logMessage .= "用户支付金额:\t" . $payer_total. "\n";
  70.                 $logMessage .= "用户标识:\t" . $openid. "\n";
  71.                 $logMessage .= "付款银行:\t" . $bank_type. "\n";
  72.                 $logMessage .= "支付手续费:\t" . $payamount. "\n";
  73.                 $logMessage .= "支付状态:\t" . $status. "\n";
  74.                 $logMessage .= "============================================================================"."\n\n";
  75.                 try{
  76.                     // 写入日志文件
  77.                     $this->recodeLog(self::PAYLOG,'wechat.txt',$logMessage);
  78.                 }catch (\think\Exception $e){
  79.                     $errlogMessage = "时间:\t" . date('Y-m-d H:i:s') . "\n";
  80.                     $errlogMessage .= "日志内容:\t" . $e . "\n";
  81.                     $this->recodeLog(self::PAYLOG,'wechat_error.txt',$errlogMessage);
  82.                 }
  83.                 //你可以在此编写订单逻辑
  84.                 if($data['resource']['ciphertext']['trade_state'] == 'SUCCESS'){
  85.                     $saveData = [
  86.                         //'id'                =>      $out_trade_no,
  87.                         'pay_method_type'   =>      $pay_method,
  88.                         'transaction_id'    =>      $transaction_id,
  89.                         'trade_type'        =>      $trade_type,
  90.                         'success_time'      =>      $success_time,
  91.                         'total'             =>      $total,
  92.                         'payer_total'       =>      $payer_total,
  93.                         'openid'            =>      $openid,
  94.                         'bank_type'         =>      $bank_type,
  95.  
  96.                         //'admin_id'          =>      $this->auth->id, // 下单客户
  97.                         'ispay'             =>      1,
  98.                         'status'            =>      2, // 目前订单都默认审核通过
  99.                     ];
  100.                     $rechargeData = [
  101.                         //'admin_id'                           =>      $this->auth->id,
  102.                         //'recharge_order_number'              =>      $out_trade_no,
  103.                         'transaction_serial_number'          =>      $transaction_id,
  104.                         'recharge_amount'                    =>      $total,
  105.                         'recharge_time'                      =>      $success_time,
  106.                         'recharge_channel'                   =>      0, //支付渠道 0：微信，1支付宝
  107.                         'recharge_type'                      =>      0,   //支付渠道 0：微信，1支付宝
  108.                         'ispay'                              =>      1,
  109.                     ];
  110.                     Db::startTrans();
  111.                     try{
  112.                         if($this->getFirstLetter($out_trade_no) == 'O'){
  113.                             // 客户下单支付
  114.                             $isExistOrder = (new \app\admin\model\Orders())->where('id',$out_trade_no)->find();
  115.                             if(!empty($isExistOrder)){
  116.                                 (new \app\admin\model\Orders())->where('id',$out_trade_no)->update($saveData);
  117.                             }
  118.                         }else if($this->getFirstLetter($out_trade_no) == 'R'){
  119.                             // 客户充值余额
  120.                             // 查找recharge对应的admin_id 和 recharge_order_number
  121.                             $isExistRecharge = Db::table('fa_recharge')->field('admin_id,recharge_order_number')->where('recharge_order_number', $out_trade_no)->find();
  122.                             if (!empty($isExistRecharge)) {
  123.                                 Db::table('fa_recharge')->where('recharge_order_number', $out_trade_no)->update($rechargeData);
  124.                                 // 修改余额
  125.                                 $account_balance = (new Customer())
  126.                                     ->field('account_balance')
  127.                                     ->where('admin_id',$isExistRecharge['admin_id'])->find();
  128.                                 $balance = $account_balance['account_balance'] + $total;
  129.                                 (new Customer())
  130.                                     ->where('admin_id',$isExistRecharge['admin_id'])
  131.                                     ->update(['account_balance'=>$balance]);
  132.                             }
  133.                         }
  134.                         Db::commit();
  135.                     }catch (\Exception $exception){
  136.                         $errlogMessage = "时间:\t" . date('Y-m-d H:i:s') . "\n";
  137.                         $errlogMessage .= "数据库事务日志内容:\t" . $exception . "\n";
  138.                         $this->recodeLog(self::PAYLOG,'wechat_error.txt',$errlogMessage);
  139.                         Db::rollback();
  140.                     }
  141.                     return json(['code' => 'SUCCESS', 'message' => '成功']);
  142.                 }
  143.             }else {  // 支付宝
  144.                 $out_trade_no = $data['out_trade_no'];
  145.                 // 获取 Redis 实例并选择数据库
  146.                 $redis = Cache::store('redis')->handler();
  147.                 // 选择数据库
  148.                 $redis->select(8);
  149.                 // 是否添加锁表
  150.                 $addLock = false;
  151.                 // 使用 Lua 脚本确保分布式锁的原子性
  152.                 //redis.call('SET', key, 1, 'EX', 60 * 60 * 24 * 7) -- 设置为7天的过期时间
  153.                 $script = <<<LUA
  154.         local key = KEYS[1]
  155.         local exists = redis.call('EXISTS', key)
  156.         if exists == 0 then
  157.         redis.call('SET', key, 1, 'EX', 60 * 2) 
  158.         end
  159.         return exists
  160. LUA;
  161.                 $result = $redis->eval($script, [$out_trade_no], 1);
  162.  
  163.                 if ($result == 1) {
  164.                     // 订单号已经存在则锁住;
  165.                     $addLock = true;
  166.                 }
  167.                 if ($addLock) {
  168.                     return;
  169.                 }
  170.                 // 同一请求已经处理则退出
  171.                 if($this->isThameRequest($out_trade_no)){
  172.                     return json('success',200);
  173.                 }
  174.                 $trade_no = $data['trade_no'];
  175.                 $seller_id = $data['seller_id'];
  176.                 $success_time = $data['gmt_payment'];
  177.                 $total = $data['total_amount'];
  178.                 $status = $data['trade_status'];
  179.                 // 记录日志
  180.                 $logMessage = "写入时间:\t".date('Y-m-d H:i:s')."\n";
  181.                 $logMessage .= "支付时间:\t" . $success_time . "\n";
  182.                 $logMessage .= "商户订单号:\t" . $out_trade_no . "\n";
  183.                 $logMessage .= "支付方式:\t" . $paytype . "\n";
  184.                 $logMessage .= "交易金额:\t" . $total . "\n";
  185.                 $logMessage .= "支付状态:\t" . $status . "\n";
  186.                 $logMessage .= "============================================================================" . "\n\n";
  187.                 try {
  188.                     // 写入日志文件
  189.                     $this->recodeLog(self::PAYLOG,'ali.txt',$logMessage);
  190.                 } catch (\think\Exception $e) {
  191.                     $errlogMessage = "时间:\t" . date('Y-m-d H:i:s') . "\n";
  192.                     $errlogMessage .= "日志内容:\t" . $e . "\n";
  193.                     $this->recodeLog(self::PAYLOG,'ali.txt',$logMessage);
  194.                 }
  195.                 //你可以在此编写订单逻辑
  196.                 if ($data['trade_status'] == 'TRADE_SUCCESS') {
  197.                     $saveData = [
  198.                         //'id' => $out_trade_no,
  199.                         'pay_method_type' => $pay_method,  // 支付宝支付
  200.                         'trade_no' => $trade_no,
  201.                         'seller_id' => $seller_id,
  202.                         'success_time' => $success_time,
  203.                         'total' => $total,
  204.  
  205.                         //'admin_id' => $this->auth->id, // 下单客户
  206.                         'ispay' => 1,
  207.                         'status' => 2, // 目前订单都默认审核通过
  208.                     ];
  209.                     $rechargeData = [
  210.                         //'admin_id' => $this->auth->id,
  211.                         //'recharge_order_number' => $out_trade_no,
  212.                         'transaction_serial_number' => $trade_no,
  213.                         'recharge_amount' => $total,
  214.                         'recharge_time' => $success_time,
  215.                         'recharge_channel' => 1, //支付渠道 0：微信，1支付宝
  216.                         'recharge_type' => 1,   //支付渠道 0：微信，1支付宝
  217.                         'ispay'         => 1,
  218.                     ];
  219.                     Db::startTrans();
  220.                     try {
  221.                         if ($this->getFirstLetter($out_trade_no) == 'O') {
  222.                             // 客户下单支付
  223.                             $isExistOrder = (new \app\admin\model\Orders())->where('id', $out_trade_no)->find();
  224.                             if (!empty($isExistOrder)) {
  225.                                 (new \app\admin\model\Orders())->where('id',$out_trade_no)->update($saveData);
  226.                             }
  227.                         } else if ($this->getFirstLetter($out_trade_no) == 'R') {
  228.                             // 客户充值
  229.                             // 查找recharge对应的admin_id 和 recharge_order_number
  230.                             $isExistRecharge = Db::table('fa_recharge')->field('admin_id,recharge_order_number')->where('recharge_order_number', $out_trade_no)->find();
  231.                             if (!empty($isExistRecharge)) {
  232.                                 Db::table('fa_recharge')->where('recharge_order_number', $isExistRecharge['recharge_order_number'])->update($rechargeData);
  233.                                 // 修改余额
  234.                                 $account_balance = (new Customer())
  235.                                     ->field('account_balance')
  236.                                     ->where('admin_id',$isExistRecharge['admin_id'])->find();
  237.                                 $balance = $account_balance['account_balance'] + $total;
  238.                                 (new Customer())
  239.                                     ->where('admin_id',$isExistRecharge['admin_id'])
  240.                                     ->update(['account_balance'=>$balance]);
  241.                             }
  242.                         }
  243.                         Db::commit();
  244.                     } catch (\Exception $exception) {
  245.                         $errlogMessage = "时间:\t" . date('Y-m-d H:i:s') . "\n";
  246.                         $errlogMessage .= "日志内容:\t" . $exception . "\n";
  247.                         //file_put_contents($errorLogFile, $errlogMessage, FILE_APPEND);
  248.                         $this->recodeLog(self::PAYLOG,'ali_error.txt',$errlogMessage);
  249.                         Db::rollback();
  250.                     }
  251.                     return json('success',200);
  252.                 }
  253.             }
  254.         } catch (Exception $e) {
  255.  
  256.         }
  257.         return $pay->success()->send();
  258.     }
  259.  
  260.  
  261. /**
  262.      * 根据订单号标识是否是同一请求，同一请求已经处理则返回
  263.      * @param $out_trade_no
  264.      * @return true|void
  265.      */
  266.     public function isThameRequest($out_trade_no){
  267.         if($this->getFirstLetter($out_trade_no) == 'O'){
  268.             // 客户下单支付
  269.             $isExistOrder = (new \app\admin\model\Orders())->field('ispay')->where('id',$out_trade_no)->find();
  270.             if(!empty($isExistOrder) && $isExistOrder['ispay'] == 1){
  271.                 return true;
  272.             }
  273.         }else if($this->getFirstLetter($out_trade_no) == 'R'){
  274.             // 客户充值余额
  275.             $isExistRecharge = Db::table('fa_recharge')->field('ispay')->where('recharge_order_number', $out_trade_no)->find();
  276.             if (!empty($isExistRecharge) && $isExistRecharge['ispay'] == 1) {
  277.                 return true;
  278.             }
  279.         }
  280.     }

尽管这种方法解决了问题，但我仍然觉得它有点缺陷，我都不知道微信服务器是否接收到我的响应，总之我的数据保持了一致性，那先告一段落吧。在FastAdmin支付插件中的代码是直接返回了响应，但是我没解决这个问题，不知道是不是有bug。如果您有更好的解决方法，欢迎留言分享，让我们一起探讨！

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/132074
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号