- 非生产环境不限制GetMsg的等待时间

business/msghub/msghub.go

@@ -125,12 +125,14 @@ func GetMsg(ctx *jxcontext.Context, storeID int, lastOrderTime time.Time, lastOr
 			pollingDuration := defPollingDuration
 			if waitingSecond != 0 {
 				pollingDuration = time.Duration(waitingSecond) * time.Second
+				if globals.IsProductEnv() {
 					if pollingDuration > maxPollingDuration {
 						pollingDuration = maxPollingDuration
 					} else if pollingDuration < minPollingDuration {
 						pollingDuration = minPollingDuration
 					}
 				}
+			}
 			timer := time.NewTimer(pollingDuration)
 			select {
 			case msg2, ok := <-chan2Listen:

globals/globals.go

@@ -77,3 +77,7 @@ func Init() {
 func IsCallbackAlwaysReturnSuccess() bool {
 	return beego.BConfig.RunMode == "beta"
 }
+
+func IsProductEnv() bool {
+	return beego.BConfig.RunMode == "prod" || beego.BConfig.RunMode == "jxgy"
+}