From 8740bad94c6b5725eb515fa2aeae1034790ff0b3 Mon Sep 17 00:00:00 2001 From: PandaX <18610165312@163.com> Date: Wed, 1 Nov 2023 17:11:48 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BC=98=E5=8C=96]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/device/util/device_rpc.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/device/util/device_rpc.go b/apps/device/util/device_rpc.go index 0a3ffcb..582317a 100644 --- a/apps/device/util/device_rpc.go +++ b/apps/device/util/device_rpc.go @@ -13,7 +13,7 @@ import ( "pandax/pkg/tool" ) -func BuildRunDeviceRpc(deviceId, mode string, metadata map[string]interface{}) error { +func BuildRunDeviceRpc(deviceId, mode string, msgData map[string]interface{}) error { device, err := services.DeviceModelDao.FindOne(deviceId) if err != nil { return err @@ -45,7 +45,7 @@ func BuildRunDeviceRpc(deviceId, mode string, metadata map[string]interface{}) e "orgId": device.OrgId, "owner": device.Owner, } - msg := message.NewMessage(device.Owner, message.RpcRequestToDevice, metadata, metadataVals) + msg := message.NewMessage(device.Owner, message.RpcRequestToDevice, msgData, metadataVals) err = instance.StartRuleChain(context.Background(), msg) if err != nil { global.Log.Error("规则链执行失败", errs)