diff --git a/src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs b/src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs index 23d6136..fd5d392 100644 --- a/src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs +++ b/src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs @@ -73,7 +73,8 @@ namespace JiShe.IoT.BusinessSystemAggregation return redis.call('HMGET', hashKey, unpack(fieldKeys))"; /// - /// 接收业务系统设置指令信息,Msg 字段为 ReceiveCommandInfoDto 实体,操作类型必须有对应的事件上报,进行业务系统回调触发,不能直接使用同步操作。 + /// 接收业务系统设置指令信息,Msg 字段为 ReceiveCommandInfoDto 实体 + /// 操作类型必须有对应的事件上报,进行业务系统回调触发,不能直接使用同步操作。 /// [AllowAnonymous] public async Task ReceiveSetCommandInfoAsync(OpenApiRequest input) @@ -81,6 +82,7 @@ namespace JiShe.IoT.BusinessSystemAggregation try { + logger.LogWarning($"{nameof(ReceiveSetCommandInfoAsync)} 业务系统设置指令信息入参为:{input.Serialize()}"); var handleResult = HandleOpenApiRequest(input, serverApplicationOptions); if (handleResult.Success == false) @@ -168,15 +170,15 @@ namespace JiShe.IoT.BusinessSystemAggregation //数据写入遥测任务数据存储通道 await ioTDBDataChannelManageService.DeviceTelemetryTaskWriterAsync(DataChannelManage.DeviceTelemetryTaskDataChannel.Writer, (DistributedMessageCenterConst.OneNETCommandIssuedEventName, packetTaskInfo)); - await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.OneNETCommandIssuedEventName, input); + await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.OneNETCommandIssuedEventName, packetTaskInfo); } else if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.CTWing) { - await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.CTWingAepCommandIssuedEventName, input); + return HttpDataResultExtensions.Failed("设置属性指令处理失败,CTWing平台类型没有实现", -105); } else { - return HttpDataResultExtensions.Failed("设置属性指令处理失败,当前设备平台类型异常", -105); + return HttpDataResultExtensions.Failed("设置属性指令处理失败,当前设备平台类型异常", -106); } return HttpDataResultExtensions.Success("指令下发成功"); @@ -188,7 +190,7 @@ namespace JiShe.IoT.BusinessSystemAggregation catch (Exception ex) { _logger.LogError(ex, "接收业务系统指令信息时发生异常"); - return HttpDataResultExtensions.Failed("指令处理失败,发送异常", -106); + return HttpDataResultExtensions.Failed("指令处理失败,发送异常", -107); } }