commit

aarch64/pjisuv/master/package/service/produce_window.go

@@ -119,10 +119,7 @@ func PrepareTimeWindowProducerQueue() {
 			entity.Subscriber2TimeMutex.Lock()
 			// 判断是否是连续故障码
 			gap := time.Since(entity.Subscriber2Time).Seconds()
-			if gap < 1 {
-				entity.Subscriber2TimeMutex.Unlock()
-				return
-			} else {
+			if gap > 1 {
 				// 2 不是连续故障码
 				subscriber2Mutex.Lock()
 				faultHappenTime := util.GetNowTimeCustom()   // 获取当前故障发生时间
@@ -134,13 +131,12 @@ func PrepareTimeWindowProducerQueue() {
 					if faultLabel != "" {
 						saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 						entity.Subscriber2Time = time.Now()
-						entity.Subscriber2TimeMutex.Unlock()
 						break
 					}
 				}
 				subscriber2Mutex.Unlock()
 			}
-
+			entity.Subscriber2TimeMutex.Unlock()
 		}})
 	if err != nil {
 		c_log.GlobalLogger.Info("创建订阅者2发生故障：", err)