测试

src/JiShe.IoT.Application.Contracts/BusinessSystemAggregation/IBusinessSystemAggregationService.cs

@@ -33,5 +33,7 @@ namespace JiShe.IoT.BusinessSystemAggregation
         /// <param name="input"></param>
         /// <returns></returns>
         Task<HttpDataResult> BatchCreateDeviceInfoAsync(OpenApiRequest input);
+
+        Task<string> BatchCreateDeviceInfoAsync2(OpenApiRequest input);
     }
 }

src/JiShe.IoT.Application.Contracts/DeviceAggregation/IDeviceAggregationService.cs

@@ -1,4 +1,5 @@
 using JiShe.IoT.DeviceAggregation.Dto;
+using JiShe.ServicePro;
 using JiShe.ServicePro.Core;
 using JiShe.ServicePro.DeviceManagement.DeviceInfos;
 using Volo.Abp;
@@ -75,5 +76,9 @@ namespace JiShe.IoT.DeviceAggregation
         /// <param name="input"></param>
         /// <returns></returns>
         Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceAggregationInput input);
+
+
+        Task<HttpDataResult> BatchCreateDeviceInfoAsync();
+        Task<string> BatchCreateDeviceInfoAsync2();
     }
 }

src/JiShe.IoT.Application/BusinessSystemAggregation/BusinessSystemAggregationService.cs

@@ -220,6 +220,24 @@ namespace JiShe.IoT.BusinessSystemAggregation
             {
                 return HttpDataResultExtensions.Failed($"查询设备数据失败，发送异常：{ex.Message}", -106);
             }
-        } 
+        }
+
+
+        /// <summary>
+        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceInfoInput 实体
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<string> BatchCreateDeviceInfoAsync2(OpenApiRequest input)
+        {
+            try
+            {
+                return "新增设备成功";
+            }
+            catch (Exception ex)
+            {
+                return ex.Message;
+            }
+        }
     }
 }

src/JiShe.IoT.Application/DeviceAggregation/DeviceAggregationService.cs

@@ -439,6 +439,40 @@ namespace JiShe.IoT.DeviceAggregation
             }
         }
 
+        /// <summary>
+        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceInfoInput 实体
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<HttpDataResult> BatchCreateDeviceInfoAsync()
+        {
+            try
+            { 
+                return HttpDataResultExtensions.Success("新增设备成功");
+            }
+            catch (Exception ex)
+            {
+                return HttpDataResultExtensions.Failed($"查询设备数据失败，发送异常：{ex.Message}", -106);
+            }
+        }
+
+        /// <summary>
+        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceInfoInput 实体
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<string> BatchCreateDeviceInfoAsync2()
+        {
+            try
+            {
+                return "新增设备成功";
+            }
+            catch (Exception ex)
+            {
+                return ex.Message;
+            }
+        }
+
         /// <summary>
         /// OneNET设备批量创建
         /// </summary>

src/JiShe.IoT.HttpApi/Controllers/BusinessSystemAggregationController.cs

@@ -45,5 +45,15 @@ namespace JiShe.IoT.Controllers
         {
             return await _businessSystemAggregationService.BatchCreateDeviceInfoAsync(input);
         }
+
+        /// <summary>
+        /// 业务系统批量新增设备数据
+        /// </summary>
+        [HttpPost(nameof(BatchCreateDeviceInfoAsync2))]
+        [SwaggerOperation(summary: "业务系统批量新增设备数据", Tags = new[] { "AggregationBusiness" })]
+        public async Task<string> BatchCreateDeviceInfoAsync2(OpenApiRequest input)
+        {
+            return await _businessSystemAggregationService.BatchCreateDeviceInfoAsync2(input);
+        }
     }
 }

src/JiShe.IoT.HttpApi/Controllers/DeviceAggregationController.cs

@@ -1,5 +1,6 @@
 using JiShe.IoT.DeviceAggregation;
 using JiShe.IoT.DeviceAggregation.Dto;
+using JiShe.ServicePro;
 using JiShe.ServicePro.Core;
 using JiShe.ServicePro.DeviceManagement.DeviceInfos;
 
@@ -85,6 +86,31 @@ namespace JiShe.IoT.Controllers
         {
             return _deviceAggregationService.DeviceCommandForApiAsync(input);
         }
-        
+
+
+        /// <summary>
+        /// 发送设备指令信息
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost(nameof(DeviceCommandForApiAsync))]
+        [SwaggerOperation(summary: "发送设备指令信息", Tags = new[] { "AggregationDevice" })]
+        public Task<HttpDataResult> BatchCreateDeviceInfoAsync()
+        {
+            return _deviceAggregationService.BatchCreateDeviceInfoAsync();
+        }
+
+        /// <summary>
+        /// 发送设备指令信息
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost(nameof(BatchCreateDeviceInfoAsync2))]
+        [SwaggerOperation(summary: "发送设备指令信息", Tags = new[] { "AggregationDevice" })]
+        public Task<string> BatchCreateDeviceInfoAsync2()
+        {
+            return _deviceAggregationService.BatchCreateDeviceInfoAsync2();
+        }
+
     }
 }