wx 并发处理

Application/Callback/Controller/NotifyController.class.php

@@ -7,6 +7,7 @@ use Org\SwiftpassSDK\Swiftpass;
 use Think\Log;
 use Qiniu\json_decode;
 use Sdk\Controller\Ipa365Controller;
+use Base\Tool\Redis;
 
 
 /**
@@ -278,6 +279,15 @@ class NotifyController extends BaseController
 
     public function wxpay_callback()
     {
+        Log::write("timeout".time(), Log::DEBUG);
+        $key = "sdk:paycallback_wx";
+        $ret = Redis::get($key);
+        if ($ret) {
+            Log::write("sdk:paycallback_wx 请求太频繁", Log::DEBUG);
+            exit();
+        }
+        Redis::set($key, 1, 3);   // 3秒钟收一次请求
+        
         $values = array();
         Vendor("WxPayPubHelper.WxPayPubHelper");
         $weixin = A("WeiXin", "Event");