commit

aarch64/pjibot_delivery/master/package/config/trigger_init.go

@@ -147,7 +147,6 @@ func InitTriggerConfig() {
 			c_log.GlobalLogger.Error("未知的topic：", topic2)
 			continue
 		}
-
 	JudgeDone:
 		label, err := open.Lookup("Label")
 		if err != nil {

aarch64/pjibot_delivery/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)
 								}
 							}
 						}
@@ -54,7 +57,6 @@ func PrepareTimeWindowProducerQueue() {
 		}
 		if err != nil {
 			c_log.GlobalLogger.Info("创建订阅者", masterConfig.TopicOfObstacleDetection, "发生故障：", err)
-			//TODO 如何回传日志
 			continue
 		}
 	}
@@ -148,9 +150,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
 }