public/PandaX
1
0
Fork 0
mirror of https://gitee.com/XM-GO/PandaX.git synced 2026-04-23 02:48:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

[优化]

Browse Source
This commit is contained in:
PandaX
2023-11-01 17:11:48 +08:00
parent f8322ef3b8
commit 8740bad94c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/device/util/device_rpc.go
View File

@@ -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)