host/JiShe.IoT.HttpApi.Host/configs/appsettings.Development.json

@@ -4,7 +4,7 @@
     "CorsOrigins": "https://*.IoT.com,http://localhost:4200,http://localhost:3100,http://localhost:80,http://10.10.90.3:4200"
   },
   "ConnectionStrings": {
-    "Default": "Data Source=192.168.111.174;Port=13306;Database=JiSheIoTProDB386;uid=root;pwd=JiShe!aqG#5kGgh&0;charset=utf8mb4;Allow User Variables=true;AllowLoadLocalInfile=true;TreatTinyAsBoolean=false;SslMode=None;Pooling=true;"
+    "Default": "Data Source=192.168.111.174;Port=13306;Database=JiSheIoTProDB;uid=root;pwd=JiShe!aqG#5kGgh&0;charset=utf8mb4;Allow User Variables=true;AllowLoadLocalInfile=true;TreatTinyAsBoolean=false;SslMode=None;Pooling=true;"
   },
   "Hangfire": {
     "Redis": {
@@ -80,8 +80,7 @@
     "AesSecurityKey": "RPTEIGCA1KvDEXS1",
     "IsAesEncrypted": false,
     "DistributedMessage": 2,
-    "SnowflakeWorkerId": 1,
+    "SnowflakeWorkerId": 1
-    "DownloadDeviceFirmwareBasicUrl": "http://121.42.175.177:32580/Aggregation/Device/DownloadFirmware?Id="
   },
   "Jwt": {
     "Audience": "JiShe.IoT",

host/JiShe.IoT.HttpApi.Host/configs/appsettings.json

@@ -2,8 +2,7 @@
   "Serilog": {
     "Using": [
       "Serilog.Sinks.Console",
-      "Serilog.Sinks.File",
+      "Serilog.Sinks.File"
-      "Serilog.Sinks.Grafana.Loki"
     ],
     "MinimumLevel": {
       "Default": "Warning",
@@ -22,27 +21,10 @@
         "Name": "Console"
       },
       {
-        "Name": "GrafanaLoki",
+        "Name": "File",
         "Args": {
-          "uri": "http://192.168.111.164:3100",
+          "path": "logs/logs-.txt",
-          "labels": [
+          "rollingInterval": "Hour"
-            {
-              "key": "app",
-              "value": "OneNETAdmin" // 应用名称
-            },
-            {
-              "key": "environment",
-              "value": "dev" // 环境（dev/staging/prod）
-            },
-            {
-              "key": "version",
-              "value": "1.2.3" // 应用版本（可选）
-            }
-          ],
-          "propertiesAsLabels": [
-            "Level",
-            "SourceContext"
-          ]
         }
       }
     ]

src/JiShe.IoT.Application.Contracts/BusinessSystemAggregation/Dto/BatchCreateDeviceBusinessSystemInput.cs

@@ -1,40 +0,0 @@
-using JiShe.ServicePro.Enums;
-using JiShe.ServicePro.OpenAPIModels;
-using System.ComponentModel.DataAnnotations;
-
-namespace JiShe.IoT.BusinessSystemAggregation.Dto
-{
-    /// <summary>
-    /// 业务系统批量创建设备信息
-    /// </summary>
-    public class BatchCreateDeviceBusinessSystemInput
-    {
-        /// <summary>
-        /// 设备信息集合
-        /// </summary>
-        [Required(ErrorMessage = "设备信息不能为空")]
-        public List<OpenApiDeviceInfoInput> DeviceInfos { get; set; }
-
-        /// <summary>
-        /// 物联网平台类型
-        /// </summary>
-        [Required(ErrorMessage = "物联网平台类型不能为空")]
-        public IoTPlatformTypeEnum IoTPlatform { get; set; }
-
-        /// <summary>
-        /// 集中器在物联网平台中对应的产品Id
-        /// </summary>
-        [Required(ErrorMessage = "产品Id不能为空")]
-        public string IoTPlatformProductId { get; set; }
-
-        /// <summary>
-        /// 设备类型,用来区分主设备是网关设备还是直连设备
-        /// </summary>
-        public DeviceTypeEnum? DeviceType { get; set; }
-
-        /// <summary>
-        /// 设备来源类型
-        /// </summary> 
-        public DeviceSourceTypeEnum? DeviceSourceType { get; set; }
-    }
-}

src/JiShe.IoT.Application.Contracts/BusinessSystemAggregation/Dto/BatchCreateDeviceInfoInput.cs

@@ -0,0 +1,36 @@
+using JiShe.ServicePro.Enums;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace JiShe.IoT.BusinessSystemAggregation.Dto
+{
+    /// <summary>
+    /// 批量创建设备信息输入
+    /// </summary>
+    public class BatchCreateDeviceInfoInput
+    {
+        /// <summary>
+        /// 设备来源类型，只接收 预付费业务系统推送、能耗业务系统推送
+        /// </summary>
+        public DeviceSourceTypeEnum DeviceSourceType { get; set; }
+         
+        /// <summary>
+        /// 物联网平台类型
+        /// </summary>
+        public IoTPlatformTypeEnum IoTPlatform { get; set; }
+
+        /// <summary>
+        /// 集中器在物联网平台中对应的产品Id
+        /// </summary>
+        public string IoTPlatformProductId { get; set; }
+
+        /// <summary>
+        /// 设备地址集合
+        /// </summary>
+        public List<string> DeviceAddresses { get; set; }
+    }
+}

src/JiShe.IoT.Application.Contracts/BusinessSystemAggregation/Dto/QueryDeviceDataInfoInput.cs

@@ -1,45 +0,0 @@
-using JiShe.ServicePro.Enums;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace JiShe.IoT.BusinessSystemAggregation.Dto
-{
-    /// <summary>
-    /// 单个查询设备信息输入
-    /// </summary>
-    public class QueryDeviceDataInfoInput
-    { 
-        /// <summary>
-        /// 设备类型
-        /// </summary>
-        public DeviceTypeEnum DeviceType { get; set; }
-
-        /// <summary>
-        /// 数据类型
-        /// </summary>
-        public string IoTDataType { get; set; }
-
-        /// <summary>
-        /// 开始时间，最终需要转换为纳秒级时间戳
-        /// </summary>
-        public DateTime BeginTime { get; set; }
-
-        /// <summary>
-        /// 结束时间，最终需要转换为纳秒级时间戳
-        /// </summary>
-        public DateTime EndTime { get; set; }
-
-        /// <summary>
-        /// 网关或者直连设备地址
-        /// </summary>
-        public string DeviceAddress { get; set; }
-
-        /// <summary>
-        /// 子设备地址
-        /// </summary>
-        public string SubDeviceAddress { get; set; }
-    }
-}

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

@@ -28,14 +28,7 @@ namespace JiShe.IoT.BusinessSystemAggregation
         Task<HttpDataResult<List<IoTDBDynamicObject>>> BatchQueryDeviceDataInfoAsync(OpenApiRequest input);
 
         /// <summary>
-        /// 业务系统查询单个设备数据，Msg 字段为 QueryDeviceDataInfoInput 实体
+        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceInfoInput 实体
-        /// </summary>
-        /// <param name="input"></param>
-        /// <returns></returns>
-        Task<HttpDataResult<List<IoTDBDynamicObject>>> QueryDeviceDataInfoAsync(OpenApiRequest input);
-
-        /// <summary>
-        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceBusinessSystemInput 实体
         /// </summary>
         /// <param name="input"></param>
         /// <returns></returns>

src/JiShe.IoT.Application.Contracts/DeviceAggregation/Dto/BatchCreateDeviceAggregationInput.cs

@@ -1,5 +1,4 @@
 using JiShe.ServicePro.Enums;
-using JiShe.ServicePro.OpenAPIModels;
 using System.ComponentModel.DataAnnotations;
 
 namespace JiShe.IoT.DeviceAggregation
@@ -10,16 +9,11 @@ namespace JiShe.IoT.DeviceAggregation
     public class BatchCreateDeviceAggregationInput
     {
         /// <summary>
-        /// 设备地址不能为空
+        /// 表通信地址集合
         /// </summary>
         [Required(ErrorMessage = "设备地址不能为空")]
         public List<string> AddressList { get; set; }
 
-        /// <summary>
-        /// 设备信息
-        /// </summary>
-        public List<OpenApiDeviceInfoInput> DeviceInfos { get; set; }
-
         /// <summary>
         /// 物联网平台类型
         /// </summary>
@@ -36,11 +30,6 @@ namespace JiShe.IoT.DeviceAggregation
         /// 设备来源类型
         /// </summary>
 
-        public DeviceSourceTypeEnum? DeviceSourceType { get; set; }
+        public DeviceSourceTypeEnum? DeviceSourceTypeEnum { get; set; }
-
-        /// <summary>
-        /// 设备类型
-        /// </summary>
-        public DeviceTypeEnum? DeviceType { get; set; }
     }
 }

src/JiShe.IoT.Application.Contracts/DeviceAggregation/Dto/CreateDeviceAggregationInput.cs

@@ -1,5 +1,4 @@
 using JiShe.ServicePro.Enums;
-using JiShe.ServicePro.OpenAPIModels;
 using System.ComponentModel.DataAnnotations;
 
 namespace JiShe.IoT.DeviceAggregation.Dto
@@ -15,11 +14,6 @@ namespace JiShe.IoT.DeviceAggregation.Dto
         [Required(ErrorMessage = "设备地址不能为空")]
         public string DeviceAddress { get; set; }
 
-        /// <summary>
-        /// 设备信息
-        /// </summary>
-        public OpenApiDeviceInfoInput DeviceInfos { get; set; }
-
         /// <summary>
         /// 物联网平台类型
         /// </summary>
@@ -36,13 +30,7 @@ namespace JiShe.IoT.DeviceAggregation.Dto
         /// 设备来源类型
         /// </summary>
 
-        public DeviceSourceTypeEnum? DeviceSourceType { get; set; }
+        public DeviceSourceTypeEnum? DeviceSourceTypeEnum { get; set; }
-
-
-        /// <summary>
-        /// 设备类型，与业务系统无关  
-        /// </summary>
-        public DeviceTypeEnum? DeviceType { get; set; }
 
     }
 }

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

@@ -1,5 +1,4 @@
-using JiShe.IoT.BusinessSystemAggregation.Dto;
+using JiShe.IoT.DeviceAggregation.Dto;
-using JiShe.IoT.DeviceAggregation.Dto;
 using JiShe.ServicePro;
 using JiShe.ServicePro.Core;
 using JiShe.ServicePro.DeviceManagement.DeviceInfos;
@@ -104,6 +103,6 @@ namespace JiShe.IoT.DeviceAggregation
         /// </summary>
         /// <param name="input"></param>
         /// <returns></returns>
-        Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceBusinessSystemInput input); 
+        Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceAggregationInput input); 
     }
 }

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

@@ -213,94 +213,9 @@ namespace JiShe.IoT.BusinessSystemAggregation
             }
         }
 
-        /// <summary>
-        /// 业务系统查询单个设备数据，Msg 字段为 QueryDeviceDataInfoInput 实体
-        /// </summary>
-        /// <param name="input"></param>
-        /// <returns></returns>
-        [AllowAnonymous]
-        public async Task<HttpDataResult<List<IoTDBDynamicObject>>> QueryDeviceDataInfoAsync(OpenApiRequest input)
-        {
-            try
-            {
-                var handleResult = HandleOpenApiRequest<QueryDeviceDataInfoInput>(input, serverOptions);
-                if (handleResult.Success == false)
-                {
-                    return HttpDataResultExtensions.Failed<List<IoTDBDynamicObject>>(null, handleResult.Message, handleResult.LocationCode);
-                }
-                var messageBody = handleResult.Data;
-
-                if (string.IsNullOrWhiteSpace(messageBody.DeviceAddress))
-                {
-                    return HttpDataResultExtensions.Failed<List<IoTDBDynamicObject>>(null, "设备地址不能为空", -103);
-                }
-
-                // Lua脚本
-                string luaScript = @"
-                local hashKey = KEYS[1]
-                local fieldKeys = ARGV
-                return redis.call('HMGET', hashKey, unpack(fieldKeys))";
-
-                //执行脚本
-                var result = await FreeRedisProvider.Instance.EvalAsync
-                (
-                    luaScript,
-                    new[] { RedisConst.CacheAllDeviceInfoHashKey },
-                    new List<string>() { messageBody.DeviceAddress }.ToArray()
-                );
-
-                List<DeviceCacheInfos> deviceCacheInfos = new List<DeviceCacheInfos>();
-
-                // 处理返回结果
-                if (result is object[] values)
-                {
-                    foreach (var value in values)
-                    {
-                        var tempFocusInfo = ServiceProJsonSerializer.Deserialize<DeviceCacheInfos>(value as string);
-                        deviceCacheInfos.Add(tempFocusInfo);
-                    }
-                }
-
-                List<IoTDBDynamicObject> queryResult = new List<IoTDBDynamicObject>();
-                var deviceCacheInfo = deviceCacheInfos.FirstOrDefault(x => x.DeviceAddress == messageBody.DeviceAddress);
-
-                if (deviceCacheInfo == null)
-                {
-                    _logger.LogError($"{nameof(BatchQueryDeviceDataInfoAsync)} 业务系统单个查询设备数据，设备地址：{messageBody.DeviceAddress}未找到设备地址缓存信息，消息体为：{input.Serialize()}");
-                }
-
-                var pageResult = await treeModelService.OpenRequestDeviceDataInfoPageAsync(new DeviceTreeModelDataInfoInput()
-                {
-                    DeviceAddress = messageBody.DeviceAddress,
-                    DeviceType = messageBody.DeviceType,
-                    IoTDataType = messageBody.IoTDataType,
-                    IsNeedPaging = false,
-                    StartCreationTime = messageBody.BeginTime,
-                    EndCreationTime = messageBody.EndTime,
-                    SubDeviceAddress = messageBody.SubDeviceAddress,
-                });
-
-                //todo 根据业务系统时间间隔要求进行过滤
-                if (pageResult.Items != null && pageResult.Items.Count > 0)
-                {
-                    queryResult.AddRange(pageResult.Items);
-                }
-
-                return HttpDataResultExtensions.Success(queryResult, "查询成功");
-
-
-            }
-            catch (Exception ex)
-            {
-
-                return HttpDataResultExtensions.Failed<List<IoTDBDynamicObject>>(null, $"查询设备数据失败，发送异常：{ex.Message}", -106);
-
-            }
-        }
-
 
         /// <summary>
-        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceBusinessSystemInput 实体
+        /// 业务系统批量新增设备数据，Msg 字段为 BatchCreateDeviceInfoInput 实体
         /// </summary>
         /// <param name="input"></param>
         /// <returns></returns>
@@ -309,20 +224,25 @@ namespace JiShe.IoT.BusinessSystemAggregation
         {
             try
             {
-                var handleResult = HandleOpenApiRequest<BatchCreateDeviceBusinessSystemInput>(input, serverOptions);
+                var handleResult = HandleOpenApiRequest<BatchCreateDeviceInfoInput>(input, serverOptions);
                 if (handleResult.Success == false)
                 {
                     return HttpDataResultExtensions.Failed(handleResult.Message, handleResult.LocationCode);
                 }
                 var messageBody = handleResult.Data;
 
-                if (messageBody.DeviceInfos == null || messageBody.DeviceInfos.Count <= 0)
+                if (messageBody.DeviceAddresses == null || messageBody.DeviceAddresses.Count <= 0)
                 {
                     return HttpDataResultExtensions.Failed("设备地址不能为空", -101);
                 }
 
-                // 批量新增设备
+                var createResult = await deviceAggregationService.BatchCreateDeviceBusinessSystemAsync(new BatchCreateDeviceAggregationInput()
-                var createResult = await deviceAggregationService.BatchCreateDeviceBusinessSystemAsync(messageBody);
+                {
+                    DeviceSourceTypeEnum = messageBody.DeviceSourceType,
+                    IoTPlatform = messageBody.IoTPlatform,
+                    IoTPlatformProductId = messageBody.IoTPlatformProductId,
+                    AddressList = messageBody.DeviceAddresses
+                });
 
                 if (createResult == false)
                 {

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

@@ -1,5 +1,4 @@
-using JiShe.IoT.BusinessSystemAggregation.Dto;
+using JiShe.IoT.DeviceAggregation.Dto;
-using JiShe.IoT.DeviceAggregation.Dto;
 using JiShe.ServicePro;
 using JiShe.ServicePro.ApacheIoTDB.Provider.Options;
 using JiShe.ServicePro.Core;
@@ -59,7 +58,7 @@ namespace JiShe.IoT.DeviceAggregation
         {
             try
             {
-                input.DeviceSourceType = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;
+                input.DeviceSourceTypeEnum = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;
                 if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                 {
                     return await CTWingDeviceCreateAsync(input);
@@ -100,7 +99,7 @@ namespace JiShe.IoT.DeviceAggregation
                     throw new UserFriendlyException($"批量创建设备失败，设备信息不能超过100个。");
                 }
 
-                input.DeviceSourceType = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;
+                input.DeviceSourceTypeEnum = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;
 
                 if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                 {
@@ -129,7 +128,7 @@ namespace JiShe.IoT.DeviceAggregation
         {
             try
             {
-                input.DeviceSourceType = DeviceSourceTypeEnum.Workshop;
+                input.DeviceSourceTypeEnum = DeviceSourceTypeEnum.Workshop;
 
                 if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                 {
@@ -169,7 +168,7 @@ namespace JiShe.IoT.DeviceAggregation
                     throw new UserFriendlyException($"批量创建设备失败，设备信息不能超过100个。");
                 }
 
-                input.DeviceSourceType = DeviceSourceTypeEnum.Workshop;
+                input.DeviceSourceTypeEnum = DeviceSourceTypeEnum.Workshop;
 
                 if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                 {
@@ -652,38 +651,32 @@ namespace JiShe.IoT.DeviceAggregation
         /// </summary>
         /// <param name="input"></param>
         /// <returns></returns>
-        public async Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceBusinessSystemInput input)
+        public async Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceAggregationInput input)
         {
             try
             {
-                if (input.DeviceInfos == null || input.DeviceInfos.Count <= 0)
+                if (input.AddressList == null || input.AddressList.Count <= 0)
                 {
                     throw new UserFriendlyException($"业务系统批量创建设备信息，设备信息不能为空。");
                 }
 
-                if (input.DeviceInfos.Count > 100)
+                if (input.AddressList.Count > 100)
                 {
                     throw new UserFriendlyException($"业务系统批量创建设备信息，设备信息不能超过100个。");
                 }
 
-                if (input.DeviceSourceType != DeviceSourceTypeEnum.Prepay && input.DeviceSourceType != DeviceSourceTypeEnum.Energy)
+                if (input.DeviceSourceTypeEnum != DeviceSourceTypeEnum.Prepay && input.DeviceSourceTypeEnum != DeviceSourceTypeEnum.Energy)
                 {
                     throw new UserFriendlyException($"业务系统批量创建设备信息，设备来源异常。");
                 }
 
                 if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
-                {                      
+                {
-                    var batchCreateDeviceInput = input.Adapt<BatchCreateDeviceAggregationInput>();
+                    return await CTWingDeviceBatchCreateAsync(input);
-                    batchCreateDeviceInput.AddressList = input.DeviceInfos.Select(f => f.DeviceAddress.Trim()).ToList();
-
-                    return await CTWingDeviceBatchCreateAsync(batchCreateDeviceInput);
                 }
                 else if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                 {
-                    var batchCreateDeviceInput = input.Adapt<BatchCreateDeviceAggregationInput>();
+                    return await OneNETDeviceBatchCreateAsync(input);
-                    batchCreateDeviceInput.AddressList = input.DeviceInfos.Select(f => f.DeviceAddress.Trim()).ToList();
-
-                    return await OneNETDeviceBatchCreateAsync(batchCreateDeviceInput);
                 }
 
                 throw new UserFriendlyException($"不支持的物联网平台");
@@ -715,7 +708,7 @@ namespace JiShe.IoT.DeviceAggregation
                     throw new UserFriendlyException($"OneNET创建设备失败，未找到对应的产品配置信息。");
                 }
 
-                if (input.DeviceSourceType == DeviceSourceTypeEnum.Workshop && !productInfo.IsEnabled)   //车间生产推送，必须是已经启用的产品才可以
+                if (input.DeviceSourceTypeEnum == DeviceSourceTypeEnum.Workshop && !productInfo.IsEnabled)   //车间生产推送，必须是已经启用的产品才可以
                 {
                     throw new UserFriendlyException($"车间生产推送OneNET创建设备失败，产品未启用。");
                 }
@@ -726,10 +719,6 @@ namespace JiShe.IoT.DeviceAggregation
                 createDeviceInput.PlatformPassword = productInfo.ProductAccesskey;
                 createDeviceInput.IoTPlatformProductName = productInfo.ProductName;
                 createDeviceInput.AccountPhoneNumber = productInfo.AccountPhoneNumber;
-                if (input.DeviceType.HasValue)
-                {
-                    createDeviceInput.DeviceType = input.DeviceType.Value;
-                }
 
                 var insertResult = await deviceAppService.CreateAsync(createDeviceInput);
                 if (insertResult == null)
@@ -753,7 +742,6 @@ namespace JiShe.IoT.DeviceAggregation
                     return false;
                 }
 
-                //更新OneNET平台推送结果
                 await DeviceUpdateHandler(insertResult, pushResult, pushResult.Data.SecurityKey);
 
                 return true;
@@ -776,7 +764,7 @@ namespace JiShe.IoT.DeviceAggregation
             {
                 var productInfo = await FreeSqlDbContext.Instance.Select<OneNETProductInfos>()
                   .Where(e => e.IoTPlatformProductId == input.IoTPlatformProductId)//此处不需要过滤产品状态，方便测试产品配置信息是否准确，避免跟车间生产搞混
-                  .WhereIf(input.DeviceSourceType == DeviceSourceTypeEnum.Workshop, e => e.IsEnabled == true)
+                  .WhereIf(input.DeviceSourceTypeEnum == DeviceSourceTypeEnum.Workshop, e => e.IsEnabled == true)
                  .FirstAsync();
 
                 if (productInfo == null)
@@ -790,27 +778,8 @@ namespace JiShe.IoT.DeviceAggregation
                     AddressList = input.AddressList,
                     DeviceInputs = new List<CreateDeviceInput>()
                 };
-
-                //检查网关或者直连设备信息是否已经存在
-                var checkDevicesInfos = await deviceAppService.FindByDeviceAddressAsync(new FindByDeviceAddressInput()
-                {
-                    AddressList = input.AddressList,
-                    IoTPlatform = input.IoTPlatform,
-                    IoTPlatformProductId = input.IoTPlatformProductId,
-                });
-
                 foreach (var item in input.AddressList)
                 {
-                    if (checkDevicesInfos != null)
-                    {
-                        if (checkDevicesInfos.Any(e => e.DeviceAddress == item))
-                        {
-                            logger.LogError($"{nameof(OneNETDeviceBatchCreateAsync)} 平台{input.IoTPlatform} 产品 {input.IoTPlatformProductId} 下设备信息已存在：{item}");
-                            continue;
-                        }
-                    }
-
-
                     CreateDeviceInput createDeviceInput = input.Adapt<CreateDeviceInput>();
                     createDeviceInput.DeviceName = item;
                     createDeviceInput.DeviceAddress = item;
@@ -819,18 +788,7 @@ namespace JiShe.IoT.DeviceAggregation
                     createDeviceInput.PlatformPassword = productInfo.ProductAccesskey;
                     createDeviceInput.IoTPlatformProductName = productInfo.ProductName;
                     createDeviceInput.AccountPhoneNumber = productInfo.AccountPhoneNumber;
-                    createDeviceInput.DeviceSourceType = input.DeviceSourceType.Value;
+                    createDeviceInput.DeviceSourceTypeEnum = input.DeviceSourceTypeEnum.Value;
-                    createDeviceInput.DeviceType = input.DeviceType.Value;
-
-                    if (input.DeviceSourceType.HasValue)
-                    {
-                        createDeviceInput.DeviceSourceType = input.DeviceSourceType.Value;
-                    }
-
-                    if (input.DeviceType.HasValue)
-                    {
-                        createDeviceInput.DeviceType = input.DeviceType.Value;
-                    }
 
                     batchCreateDeviceInput.DeviceInputs.Add(createDeviceInput);
                 }
@@ -861,7 +819,6 @@ namespace JiShe.IoT.DeviceAggregation
                     return false;
                 }
 
-                //更新OneNET平台推送结果
                 foreach (var item in insertResult)
                 {
                     var successEntity = pushResult.Data.Successlist.Where(d => d.DeviceName == item.IoTPlatformDeviceOpenInfo).FirstOrDefault();

src/JiShe.IoT.DbMigrator/appsettings.json

@@ -1,6 +1,6 @@
 {
   "ConnectionStrings": {
-    "Default": "Data Source=192.168.111.174;Port=13306;Database=JiSheIoTProDB386;uid=root;pwd=JiShe!aqG#5kGgh&0;charset=utf8mb4;Allow User Variables=true;AllowLoadLocalInfile=true;TreatTinyAsBoolean=false;SslMode=None;Pooling=true;"
+    "Default": "Data Source=192.168.111.174;Port=13306;Database=JiSheIoTProDB;uid=root;pwd=JiShe!aqG#5kGgh&0;charset=utf8mb4;Allow User Variables=true;AllowLoadLocalInfile=true;TreatTinyAsBoolean=false;SslMode=None;Pooling=true;"
   },
   "IoTDBOptions": {
     "UserName": "root",

src/JiShe.IoT.EntityFrameworkCore/EntityFrameworkCore/IoTDbContext.cs

@@ -69,7 +69,6 @@ namespace JiShe.IoT.EntityFrameworkCore
 
         // 设备管理
         public DbSet<DeviceManagementInfo> DeviceManagementInfo { get; set; }
-        public DbSet<SubDeviceManagementInfo> SubDeviceManagementInfo { get; set; }
         public DbSet<DeviceThingModelManagement> DeviceThingModelManagement { get; set; }
         public DbSet<DeviceThingModelPropertyInfo> DeviceThingModelDetailInfo { get; set; }
         public DbSet<DeviceThingModelCommandInfo> DeviceThingModelCommandInfo { get; set; }