liuxiulin 4 days ago
parent
commit
a02d6936c8
1 changed files with 3 additions and 1 deletions
  1. 3 1
      pkg/ruleEngine/nodes/temp_alarm_node.go

+ 3 - 1
pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -18,6 +18,8 @@ import (
 	"time"
 )
 
+const mainCode = "0aa9eab3202fc0a0940923ae02174b2334da8b2a79b45a6f37b94404ee6dd96e33057e03cd7c7030c9a215f6a22d16ca"
+
 type TempAlarmNode struct {
 	pool    *grpool.Pool
 	config  *TempAlarmNodeConfig
@@ -133,7 +135,7 @@ func (t *TempAlarmNode) newAlarmMessage(message *protocol.Message) error {
 func (t *TempAlarmNode) evaluateConditions(message *protocol.Message) bool {
 	deviceId := message.MetaData["device_id"].(string)
 	// 判断设备类型
-	if message.MetaData["product_key"].(string) != t.config.ProductKey {
+	if message.MetaData["product_key"].(string) != t.config.ProductKey || message.MetaData["product_key"].(string) != mainCode {
 		return false
 	}