commit

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

@@ -40,9 +40,12 @@ func PrepareTimeWindowProducerQueue() {
 							faultLabel = f(data)
 							if faultLabel != "" {
 								if canCollect() {
+									c_log.GlobalLogger.Errorf("触发事件【%v】，开始采集。", faultLabel)
 									saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 									subscribersTimes[i] = time.Now()
 									break
+								} else {
+									c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
 								}
 							}
 						}
@@ -148,9 +151,8 @@ func canCollect() bool {
 		return false
 	}
 	if resp.Code != 200 { // 不是200 代表不允许采集
-		c_log.GlobalLogger.Info("采集数量已超过限额，当前周期内不再采集。", resp.Code)
+		c_log.GlobalLogger.Infof("当前周期内采集数量已超过限额。%+v", resp)
 		return false
 	}
-	c_log.GlobalLogger.Info("允许采集。")
 	return true
 }