防止汇付并发回调导致重复发放奖励

app/controller/api/Notify.php

@@ -10,6 +10,7 @@ use app\common\repositories\system\merchant\MerchantRepository;
 use app\common\repositories\user\UserRepository;
 use app\controller\api\merchant\sxy\Access;
 use app\controller\api\store\service\Huafei;
+use think\facade\Cache;
 use think\facade\Db;
 use think\facade\Log;
 use think\facade\Request;
@@ -26,6 +27,30 @@ class Notify
         $post_data_str = isset($post['data']) ? $post['data']: '';
         $post_sign_str = isset($post['sign']) ? $post['sign']: '';
 
+        if (!empty($post['id'])) {
+            $requestId = $post['id'];
+            $redisKey = 'api-notify-request-id:' . $requestId;
+            $ttl = 60;
+            $redisHandler = Cache::store('redis')->handler();
+            $isSet = $redisHandler->set($redisKey, 1, ['nx', 'ex' => $ttl]);
+            if ($isSet) {
+                Db::name("log")->insert([
+                    'data' => '汇付回调处理成功 (ID: ' . $requestId . ')'
+                ]);
+            } else {
+                // 重复回调
+                Db::name("log")->insert([
+                    'data' => '汇付回调错误：重复回调 (ID: ' . $requestId . ')'
+                ]);
+                return app('json')->success(['result' => 'ERROR']);
+            }
+        } else {
+            Db::name("log")->insert([
+                'data' => '汇付回调错误：缺少必要参数（id）'
+            ]);
+            return app('json')->success(['result' => 'ERROR']);
+        }
+
         # 先校验签名和返回的数据的签名的数据是否一致
         $adapay_tools=new AdapayTools();
         if ($post['app_id'] == 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0'){