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)