【fix】规则链测试数据导致上报失败

pkg/rule_engine/nodes/action_save_timeseries_node.go

@@ -2,7 +2,6 @@ package nodes
 
 import (
 	"github.com/sirupsen/logrus"
-	"log"
 	"pandax/pkg/global"
 	"pandax/pkg/rule_engine/message"
 )
@@ -36,10 +35,7 @@ func (n *saveTimeSeriesNode) Handle(msg *message.Message) error {
 	}
 	//deviceId := msg.GetMetadata().GetValues()["deviceId"].(string)
 	deviceName := msg.Metadata["deviceName"].(string)
-	log.Println(msg.Msg)
-	log.Println(msg.Metadata)
 	err := global.TdDb.InsertDevice(deviceName+"_telemetry", msg.Msg)
-	log.Println(err)
 	if err != nil {
 		if failureLabelNode != nil {
 			return failureLabelNode.Handle(msg)

pkg/rule_engine/nodes/filter_message_type_switch_node.go

@@ -34,7 +34,6 @@ func (f messageTypeSwitchNodeFactory) Create(id string, meta Metadata) (Node, er
 
 func (n *messageTypeSwitchNode) Handle(msg *message.Message) error {
 	logrus.Infof("%s handle message '%s'", n.Name(), msg.MsgType)
-	msg.Metadata = map[string]interface{}{"AA": "BB", "deviceName": "fff"}
 	nodes := n.GetLinkedNodes()
 	messageType := msg.MsgType
 	for label, node := range nodes {

shutdown.bat

@@ -1 +1 @@
-taskkill /pid 32872  -t  -f
+taskkill /pid 20548  -t  -f