From 25383f7c0cc807b7d9886f461d1fc799623b6903 Mon Sep 17 00:00:00 2001
From: ChenYi <296215406@outlook.com>
Date: Fri, 13 Mar 2026 17:04:28 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE=E5=BC=82?=
 =?UTF-8?q?=E6=AD=A5=E6=8E=A8=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BusinessSystemAggregationService.cs              | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

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))";
 
         /// <summary>
-        /// 接收业务系统设置指令信息，Msg 字段为 ReceiveCommandInfoDto 实体，操作类型必须有对应的事件上报，进行业务系统回调触发，不能直接使用同步操作。
+        /// 接收业务系统设置指令信息，Msg 字段为 ReceiveCommandInfoDto 实体
+        /// 操作类型必须有对应的事件上报，进行业务系统回调触发，不能直接使用同步操作。
         /// </summary>
         [AllowAnonymous]
         public async Task<HttpDataResult> ReceiveSetCommandInfoAsync(OpenApiRequest input)
@@ -81,6 +82,7 @@ namespace JiShe.IoT.BusinessSystemAggregation
 
             try
             {
+                logger.LogWarning($"{nameof(ReceiveSetCommandInfoAsync)} 业务系统设置指令信息入参为:{input.Serialize()}");
 
                 var handleResult = HandleOpenApiRequest<ReceiveCommandInfoDto>(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);
             }
         }