admin/JiShe.IOT.Admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化数据异步推送

Browse Source
This commit is contained in:
ChenYi 2026-03-13 17:04:28 +08:00
parent f83eccf1b9
commit 25383f7c0c
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs
View File

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