实现OneNET数据上报主从设备区分逻辑
This commit is contained in:
parent
6461c2ae98
commit
123eb6cdcb
@ -294,14 +294,14 @@ namespace JiShe.IoT.DeviceAggregation
|
|||||||
{
|
{
|
||||||
throw new UserFriendlyException($"设备不存在");
|
throw new UserFriendlyException($"设备不存在");
|
||||||
}
|
}
|
||||||
//将指令存储Kafka的OneNET主题中
|
//将指令存储
|
||||||
var commandRequest = new OpenApiRequest()
|
var commandRequest = new OpenApiRequest()
|
||||||
{
|
{
|
||||||
Message = new ReceiveCommandInfoDto()
|
Message = new ReceiveCommandInfoDto()
|
||||||
{
|
{
|
||||||
DeviceAddress = deviceInfo.DeviceAddress,
|
DeviceAddress = deviceInfo.DeviceAddress,
|
||||||
Commands = input.CommandContent.Deserialize<Dictionary<string,object>>(),
|
Commands = input.CommandContent.Deserialize<Dictionary<string,object>>(),
|
||||||
DeviceType = input.DeviceType ?? DeviceTypeEnum.Focus,//todo 设备类型 需要跟设备统一什么情况下知道具体设备类型
|
DeviceType = input.DeviceType ?? DeviceTypeEnum.GATEWAY,//todo 设备类型 需要跟设备统一什么情况下知道具体设备类型
|
||||||
SourceType = DeviceTelemetrySourceTypeEnum.AdminSystem,
|
SourceType = DeviceTelemetrySourceTypeEnum.AdminSystem,
|
||||||
TelemetryType = input.TelemetryType ?? DeviceTelemetryCommandTypeEnum.抄读,
|
TelemetryType = input.TelemetryType ?? DeviceTelemetryCommandTypeEnum.抄读,
|
||||||
IoTPlatform = deviceInfo.IoTPlatform,
|
IoTPlatform = deviceInfo.IoTPlatform,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user