From bde42bfc9a0e8c57840f4c32b36ef84e378fe647 Mon Sep 17 00:00:00 2001
From: XM-GO <93296511+XM-GO@users.noreply.github.com>
Date: Thu, 14 Sep 2023 09:01:29 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E8=A7=84=E5=88=99?=
 =?UTF-8?q?=E9=93=BE=E6=B5=8B=E8=AF=95=E6=95=B0=E6=8D=AE=E5=AF=BC=E8=87=B4?=
 =?UTF-8?q?=E4=B8=8A=E6=8A=A5=E5=A4=B1=E8=B4=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pkg/rule_engine/nodes/action_save_timeseries_node.go     | 4 ----
 pkg/rule_engine/nodes/filter_message_type_switch_node.go | 1 -
 shutdown.bat                                             | 2 +-
 3 files changed, 1 insertion(+), 6 deletions(-)

diff --git a/pkg/rule_engine/nodes/action_save_timeseries_node.go b/pkg/rule_engine/nodes/action_save_timeseries_node.go
index 10a387c..2b6fcd7 100644
--- a/pkg/rule_engine/nodes/action_save_timeseries_node.go
+++ b/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)
diff --git a/pkg/rule_engine/nodes/filter_message_type_switch_node.go b/pkg/rule_engine/nodes/filter_message_type_switch_node.go
index 0797117..032f592 100644
--- a/pkg/rule_engine/nodes/filter_message_type_switch_node.go
+++ b/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 {
diff --git a/shutdown.bat b/shutdown.bat
index ace1693..51543dd 100644
--- a/shutdown.bat
+++ b/shutdown.bat
@@ -1 +1 @@
-taskkill /pid 32872  -t  -f
\ No newline at end of file
+taskkill /pid 20548  -t  -f
\ No newline at end of file