From 364aa0d6c656814ae2f3778af302b8b9fa66fd89 Mon Sep 17 00:00:00 2001
From: lixxxww <941403820@qq.com>
Date: Mon, 22 Jan 2024 10:01:44 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=B8=80=E4=BA=9B=E5=B0=8F?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: lixxxww <941403820@qq.com>
---
 iothub/hook_message_work/hook_message_work.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/iothub/hook_message_work/hook_message_work.go b/iothub/hook_message_work/hook_message_work.go
index 643c86d..8d7d2f9 100644
--- a/iothub/hook_message_work/hook_message_work.go
+++ b/iothub/hook_message_work/hook_message_work.go
@@ -69,6 +69,7 @@ func (s *HookService) handleOne(msg *netbase.DeviceEventInfo) {
 		case message.DisConnectMes, message.ConnectMes:
 			//检测设备影子并修改设备影子状态
 			if msg.Type == message.ConnectMes {
+				shadow.InitDeviceShadow(msg.DeviceAuth.Name, msg.DeviceAuth.ProductId)
 				shadow.DeviceShadowInstance.SetOnline(msg.DeviceAuth.Name)
 			} else {
 				shadow.DeviceShadowInstance.SetOffline(msg.DeviceAuth.Name)
@@ -116,10 +117,10 @@ func getRuleChainInstance(etoken *model.DeviceAuth) *rule_engine.RuleChainInstan
 		}
 		code, _ := json.Marshal(lfData.LfData.DataCode)
 		//新建规则链实体
-		instance, errs := rule_engine.NewRuleChainInstance(rule.Id, code)
-		if errs != nil {
-			global.Log.Error("规则链初始化失败", errs)
-			return nil, errs
+		instance, err := rule_engine.NewRuleChainInstance(rule.Id, code)
+		if err != nil {
+			global.Log.Error("规则链初始化失败", err)
+			return nil, err
 		}
 		return instance, nil
 	})
@@ -154,7 +155,7 @@ func SendZtWebsocket(deviceId, message string) {
 		"attrs":  msgVals,
 	}
 	data, _ := json.Marshal(twinData)
-	for stageid := range websocket.Wsp {
+		for stageid := range websocket.Wsp {
 		CJNR := fmt.Sprintf(`{"MESSAGETYPE":"01","MESSAGECONTENT": %s}`, string(data))
 		websocket.SendMessage(CJNR, stageid)
 	}