using JiShe.IoT.BusinessSystemAggregation.Dto;
using JiShe.IoT.DeviceAggregation.Dto;
using JiShe.ServicePro;
using JiShe.ServicePro.ApacheIoTDB.Provider.Options;
using JiShe.ServicePro.Core;
using JiShe.ServicePro.DataChannelManages;
using JiShe.ServicePro.DeviceManagement.DeviceInfos;
using JiShe.ServicePro.DeviceManagement.DeviceInfos.Dto;
using JiShe.ServicePro.DeviceManagement.Permissions;
using JiShe.ServicePro.DeviceManagement.ThingModels;
using JiShe.ServicePro.Dto;
using JiShe.ServicePro.Encrypt;
using JiShe.ServicePro.Enums;
using JiShe.ServicePro.FileManagement.Files;
using JiShe.ServicePro.FreeRedisProvider;
using JiShe.ServicePro.IoTDBManagement.DataChannels;
using JiShe.ServicePro.OneNET.Provider.OpenApiModels.Commands;
using JiShe.ServicePro.OneNETManagement.OneNETDevices;
using JiShe.ServicePro.OneNETManagement.OneNETProducts;
using Mapster;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Volo.Abp;
using Volo.Abp.Content;

namespace JiShe.IoT.DeviceAggregation
{
    /// <summary>
    /// 设备聚合服务
    /// </summary>
    /// <param name="logger"></param>
    /// <param name="deviceAppService">设备服务</param>
    /// <param name="oneNETDeviceService">OneNET设备服务</param>
    /// <param name="redisPubSubService">Redis发布订阅服务</param>
    /// <param name="ioTDBDataChannelManageService">数据通道</param>
    /// <param name="_ioTDBOptions">IoTDBOptions</param>
    /// <param name="oneNETProductService">OneNET产品服务</param>
    /// <param name="deviceThingModelService">设备端物模型服务</param>
    /// <param name="platformThingModelInfoAppService">平台端端物模型服务</param>
    /// <param name="deviceFirmwareInfoService">设备固件服务</param>
    /// <param name="deviceUpgradeRecordService">设备升级记录服务</param>
    /// <param name="fileAppService">文件管理服务</param>
    /// <param name="_serverOptions">应用服务配置</param>
    public class DeviceAggregationService(ILogger<DeviceAggregationService> logger, IDeviceAppService deviceAppService, IOneNETDeviceService oneNETDeviceService, IReliableRedisPubSubService redisPubSubService, IIoTDBDataChannelManageService ioTDBDataChannelManageService, IOptions<IoTDBOptions> _ioTDBOptions, IOptions<ServerApplicationOptions> _serverOptions, IOneNETProductService oneNETProductService, IDeviceThingModelManagementAppService deviceThingModelService, IIoTPlatformThingModelInfoAppService platformThingModelInfoAppService, IDeviceFirmwareInfoService deviceFirmwareInfoService, IDeviceUpgradeRecordService deviceUpgradeRecordService, IFileAppService fileAppService) : IoTAppService, IDeviceAggregationService
    {
        IoTDBOptions ioTDBOptions = _ioTDBOptions.Value;
        ServerApplicationOptions serverApplicationOptions = _serverOptions.Value;


        /// <summary>
        /// 管理后台创建设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [Authorize(DeviceManagementPermissions.DeviceInfoManagement.Create)]
        public async Task<bool> CreateDeviceForApiAsync(CreateDeviceAggregationInput input)
        {
            try
            {
                input.DeviceSourceType = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;
                if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    return await CTWingDeviceCreateAsync(input);
                }
                else if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                {
                    return await OneNETDeviceCreateAsync(input);
                }

                throw new UserFriendlyException($"不支持的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }

        }

        /// <summary>
        /// 管理后台批量创建设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [Authorize(DeviceManagementPermissions.DeviceInfoManagement.Create)]
        public async Task<bool> BatchCreateDeviceForApiAsync(BatchCreateDeviceAggregationInput input)
        {
            try
            {

                if (input.AddressList == null || input.AddressList.Count <= 0)
                {
                    throw new UserFriendlyException($"批量创建设备失败，设备信息不能为空。");
                }

                if (input.AddressList.Count > 100)
                {
                    throw new UserFriendlyException($"批量创建设备失败，设备信息不能超过100个。");
                }

                input.DeviceSourceType = ServicePro.Enums.DeviceSourceTypeEnum.AdminSystem;

                if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    return await CTWingDeviceBatchCreateAsync(input);
                }
                else if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                {
                    return await OneNETDeviceBatchCreateAsync(input);
                }

                throw new UserFriendlyException($"不支持的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 车间创建设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> CreateDeviceWorkshopAsync(CreateDeviceAggregationInput input)
        {
            try
            {
                input.DeviceSourceType = DeviceSourceTypeEnum.Workshop;

                if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    return await CTWingDeviceCreateAsync(input);
                }
                else if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                {
                    return await OneNETDeviceCreateAsync(input);
                }

                throw new UserFriendlyException($"不支持的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }

        }

        /// <summary>
        /// 车间批量创建设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> BatchCreateDeviceWorkshopAsync(BatchCreateDeviceAggregationInput input)
        {
            try
            {
                if (input.AddressList == null || input.AddressList.Count <= 0)
                {
                    throw new UserFriendlyException($"批量创建设备失败，设备信息不能为空。");
                }

                if (input.AddressList.Count > 100)
                {
                    throw new UserFriendlyException($"批量创建设备失败，设备信息不能超过100个。");
                }

                input.DeviceSourceType = DeviceSourceTypeEnum.Workshop;

                if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    return await CTWingDeviceBatchCreateAsync(input);
                }
                else if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                {
                    return await OneNETDeviceBatchCreateAsync(input);
                }

                throw new UserFriendlyException($"不支持的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 删除设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        [Authorize(DeviceManagementPermissions.DeviceInfoManagement.Delete)]
        public async Task<bool> DeleteAsync(IdInput input)
        {
            //检查设备信息是不是已经存在
            var existsDeviceInfo = await deviceAppService.FindByIdAsync(input);
            if (existsDeviceInfo == null)
            {
                throw new UserFriendlyException($"删除设备失败，未找到对应设备信息。");
            }

            //根据设备平台调用删除接口
            if (existsDeviceInfo.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
            {
                return await DeleteDeviceInfoToOneNET(existsDeviceInfo);
            }
            else if (existsDeviceInfo.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
            {
                return await DeleteDeviceInfoToCTWing(existsDeviceInfo);
            }

            throw new UserFriendlyException($"不支持的物联网平台");
        }

        /// <summary>
        /// 根据设备ID查询设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<DeviceManagementInfoDto> FindByIdAsync(IdInput input)
        {
            return await deviceAppService.FindByIdAsync(input);
        }

        /// <summary>
        /// 重新推送设备信息到物联网平台
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<DeviceManagementInfoDto> RepushDeviceInfoToIoTPlatform(IdInput input)
        {
            try
            {
                var entityDevice = await FreeSqlDbContext.Instance.Select<DeviceManagementInfo>().Where(f => f.Id == input.Id).FirstAsync<DeviceManagementInfoDto>();
                if (entityDevice == null)
                {
                    throw new UserFriendlyException($"推送失败，未找到设备数据");
                }

                if (entityDevice.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    return await RepushDeviceInfoToCTWing(entityDevice);
                }
                else if (entityDevice.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                {
                    return await RepushDeviceInfoToOneNET(entityDevice);
                }

                throw new UserFriendlyException($"推送失败，异常的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 更新设备信息并处理缓存
        /// </summary>
        /// <param name="input"></param>
        /// <param name="pushResult">推送结果原始信息</param>
        /// <param name="platformPassword">设备接入鉴权key</param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        private async Task<DeviceManagementInfoDto> DeviceUpdateHandler(DeviceManagementInfoDto input, HttpDataResult pushResult, string platformPassword = null)
        {
            UpdateDeviceInput updateDeviceInput = input.Adapt<UpdateDeviceInput>();
            updateDeviceInput.IoTPlatformResponse = pushResult.Serialize();
            updateDeviceInput.IsPlatformPushSuccess = true;
            if (!string.IsNullOrWhiteSpace(updateDeviceInput.PlatformPassword))
            {
                updateDeviceInput.PlatformPassword = platformPassword;
            }

            var updateResult = await deviceAppService.UpdateAsync(updateDeviceInput);
            if (updateResult == null)
            {
                logger.LogError($"{nameof(CreateDeviceForApiAsync)} 更新设备信息失败：{input.Serialize()}");
                throw new UserFriendlyException($"推送结果更新失败。");
            }

            //设备数据缓存到Redis
            DeviceCacheInfos deviceCacheInfos = input.Adapt<DeviceCacheInfos>();
            deviceCacheInfos.PlatformPassword = null;

            FreeRedisProvider.Instance.HSet<DeviceCacheInfos>(RedisConst.CacheAllDeviceInfoHashKey, input.DeviceAddress, deviceCacheInfos);



            return input.Adapt<DeviceManagementInfoDto>();
        }

        /// <summary>
        /// 发送设备指令信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> DeviceCommandForApiAsync(DeviceCommandForApiInput input)
        {
            try
            {
                if (input.CommandContent == null || input.CommandContent.Keys.Count <= 0)
                {
                    throw new UserFriendlyException($"指令参数异常");
                }

                var deviceInfo = await deviceAppService.FindByIdAsync(input);
                if (deviceInfo == null)
                {
                    throw new UserFriendlyException($"设备不存在");
                }
                //将指令存储
                var receiveCommandInfoDto = new ReceiveCommandInfoDto()
                {
                    DeviceAddress = deviceInfo.DeviceAddress,
                    Commands = input.CommandContent,
                    DeviceType = deviceInfo.DeviceType,
                    SourceType = DeviceTelemetrySourceTypeEnum.AdminSystem,
                    IoTPlatform = deviceInfo.IoTPlatform,
                };

                //数据写入遥测任务数据存储通道 
                if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.OneNET)
                {
                    return await DeviceCommandInfoToOneNET(deviceInfo, receiveCommandInfoDto);
                }
                else if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.CTWing)
                {
                    //await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.CTWingAepCommandIssuedEventName,commandRequest);
                    //return true;
                    throw new UserFriendlyException($"发送设备指令信息失败，CTWing暂未实现。");
                }
                else
                {
                    throw new UserFriendlyException($"发送设备指令信息失败，未找到对应的产品配置信息。");
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 验证并获取固件信息和文件信息
        /// </summary>
        /// <param name="firmwareVersionDataId">固件版本数据Id</param>
        /// <param name="iotPlatformProductId">物联网平台产品Id</param>
        /// <param name="firmwareNotFoundErrorCode">固件信息不存在的错误代码（可选，用于批量操作时的错误代码）</param>
        /// <param name="fileNotFoundErrorCode">文件信息不存在的错误代码（可选，用于批量操作时的错误代码）</param>
        /// <returns>返回固件信息和文件信息的元组</returns>
        private async Task<(DeviceFirmwareInfoDto FirmwareInfo, FileObjectDto FileInfo)> ValidateAndGetFirmwareInfoAsync(Guid firmwareVersionDataId, string iotPlatformProductId, string firmwareNotFoundErrorCode = null, string fileNotFoundErrorCode = null)
        {
            var deviceFirmwareVersionInfo = await deviceFirmwareInfoService.FindByIdAsync(new IdInput() { Id = firmwareVersionDataId });

            if (deviceFirmwareVersionInfo == null)
            {
                var errorMsg = $"产品Id{iotPlatformProductId}的新固件信息{firmwareVersionDataId}不存在";
                throw new UserFriendlyException(errorMsg, firmwareNotFoundErrorCode ?? string.Empty);
            }

            var fileInfo = await fileAppService.GetFileAsync(new IdInput() { Id = deviceFirmwareVersionInfo.FirmwareFileId });

            if (fileInfo == null)
            {
                var errorMsg = $"产品Id{iotPlatformProductId}的新固件信息{deviceFirmwareVersionInfo.FirmwareFileName}固件文件不存在";
                throw new UserFriendlyException(errorMsg, fileNotFoundErrorCode ?? string.Empty);
            }

            return (deviceFirmwareVersionInfo, fileInfo);
        }

        /// <summary>
        /// 创建接收指令信息Dto
        /// </summary>
        /// <param name="deviceInfo">设备信息</param>
        /// <returns>接收指令信息Dto</returns>
        private ReceiveCommandInfoDto CreateReceiveCommandInfoDto(DeviceManagementInfoDto deviceInfo)
        {
            return new ReceiveCommandInfoDto()
            {
                DeviceAddress = deviceInfo.DeviceAddress,
                DeviceType = deviceInfo.DeviceType,
                SourceType = DeviceTelemetrySourceTypeEnum.AdminSystem,
                IoTPlatform = deviceInfo.IoTPlatform,
            };
        }

        /// <summary>
        /// 获取OneNET产品信息和平台端物模型信息
        /// </summary>
        /// <param name="iotPlatformProductId">物联网平台产品Id</param>
        /// <param name="deviceAddress">设备地址（用于错误信息）</param>
        /// <returns>返回产品信息和平台端物模型信息的元组</returns>
        private async Task<(dynamic ProductInfo, dynamic PlatformThingModelInfo)> GetOneNETProductAndThingModelInfoAsync(string iotPlatformProductId, string deviceAddress)
        {
            //获取设备对应的产品信息
            var productInfo = await oneNETProductService.GetProductInfoAsync(new IdInput<string>() { Id = iotPlatformProductId });

            if (productInfo == null)
            {
                throw new UserFriendlyException($"{nameof(DeviceUpgradeCommandToOneNET)} OneNET设备升级属性设置失败，产品Id{iotPlatformProductId}未找到对应的产品信息。");
            }

            //获取设备对应的平台端物模型信息，校验前端传入的属性标识集合是否存在不合法的属性标识符  
            var platformThingModelInfo = await platformThingModelInfoAppService.FindByPlatformProductIdAsync(new IdInput<string>() { Id = iotPlatformProductId });

            if (platformThingModelInfo == null)
            {
                throw new UserFriendlyException($"设备{deviceAddress}的平台端物模型信息不存在。");
            }

            return (productInfo, platformThingModelInfo);
        }

        /// <summary>
        /// 根据平台处理设备升级指令
        /// </summary>
        /// <param name="deviceInfo">设备信息</param>
        /// <param name="receiveCommandInfoDto">接收指令信息Dto</param>
        /// <param name="deviceFirmwareVersionInfo">固件版本信息</param>
        /// <param name="fileInfo">文件信息</param>
        /// <param name="input">升级输入参数</param>
        /// <param name="oneNETProductInfo">OneNET产品信息（可选，如果已获取则传入以避免重复调用）</param>
        /// <param name="oneNETPlatformThingModelInfo">OneNET平台端物模型信息（可选，如果已获取则传入以避免重复调用）</param>
        /// <returns>处理结果</returns>
        private async Task<bool> ProcessDeviceUpgradeByPlatformAsync(DeviceManagementInfoDto deviceInfo, ReceiveCommandInfoDto receiveCommandInfoDto, DeviceFirmwareInfoDto deviceFirmwareVersionInfo, FileObjectDto fileInfo, DeviceUpgradeForApiInput input, dynamic oneNETProductInfo = null, dynamic oneNETPlatformThingModelInfo = null)
        {
            if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.OneNET)
            {
                //如果未传入产品信息和物模型信息，则获取
                if (oneNETProductInfo == null || oneNETPlatformThingModelInfo == null)
                {
                    var (productInfo, platformThingModelInfo) = await GetOneNETProductAndThingModelInfoAsync(deviceInfo.IoTPlatformProductId, deviceInfo.DeviceAddress);
                    oneNETProductInfo = productInfo;
                    oneNETPlatformThingModelInfo = platformThingModelInfo;
                }

                return await DeviceUpgradeCommandToOneNET(deviceInfo, receiveCommandInfoDto, deviceFirmwareVersionInfo, fileInfo, input, oneNETProductInfo, oneNETPlatformThingModelInfo);
            }
            else if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.CTWing)
            {
                //await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.CTWingAepCommandIssuedEventName,commandRequest);
                //return true;
                throw new UserFriendlyException($"发送设备升级指令信息失败，CTWing暂未实现。");
            }
            else
            {
                throw new UserFriendlyException($"发送设备升级指令信息失败，未找到对应的产品配置信息。");
            }
        }

        /// <summary>
        /// 发送设备升级指令信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> DeviceUpgradeForApiAsync(DeviceUpgradeForApiInput input)
        {
            try
            {
                var deviceInfo = await deviceAppService.FindByIdAsync(input);
                if (deviceInfo == null)
                {
                    throw new UserFriendlyException($"设备{input.Id}不存在");
                }

                var receiveCommandInfoDto = CreateReceiveCommandInfoDto(deviceInfo);

                var (deviceFirmwareVersionInfo, fileInfo) = await ValidateAndGetFirmwareInfoAsync(input.NowFirmwareVersionDataId, input.IoTPlatformProductId);

                return await ProcessDeviceUpgradeByPlatformAsync(deviceInfo, receiveCommandInfoDto, deviceFirmwareVersionInfo, fileInfo, input);
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 批量发送设备升级指令信息，只对同一个平台下，同一个产品下的设备进行固件升级信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<List<string>> DeviceBatchUpgradeForApiAsync(DeviceBatchUpgradeForApiInput input)
        {
            try
            {
                if (input.AddressList == null || input.AddressList.Count <= 0)
                {
                    throw new UserFriendlyException($"{nameof(DeviceBatchUpgradeForApiAsync)} 设备批量升级时地址列表不能为空", "-101");
                }

                if (input.AddressList.Count > 200)
                {
                    throw new UserFriendlyException($"{nameof(DeviceBatchUpgradeForApiAsync)} 设备批量升级时地址列表数量不能超过200", "-102");
                }

                var (deviceFirmwareVersionInfo, fileInfo) = await ValidateAndGetFirmwareInfoAsync(input.NowFirmwareVersionDataId, input.IoTPlatformProductId, "-103", "-104");

                var deviceInfoList = await deviceAppService.FindByDeviceAddressAsync(new FindByDeviceAddressInput() { AddressList = input.AddressList, IoTPlatform = input.IoTPlatform, IoTPlatformProductId = input.IoTPlatformProductId });

                //如果是OneNET平台，提前获取产品信息和物模型信息，避免在循环中重复调用
                dynamic oneNETProductInfo = null;
                dynamic oneNETPlatformThingModelInfo = null;
                if (input.IoTPlatform == IoTPlatformTypeEnum.OneNET && deviceInfoList != null && deviceInfoList.Count > 0)
                {
                    var firstDevice = deviceInfoList.FirstOrDefault();
                    if (firstDevice != null)
                    {
                        var (productInfo, platformThingModelInfo) = await GetOneNETProductAndThingModelInfoAsync(firstDevice.IoTPlatformProductId, firstDevice.DeviceAddress);
                        oneNETProductInfo = productInfo;
                        oneNETPlatformThingModelInfo = platformThingModelInfo;
                    }
                }

                List<string> deviceAddress = new List<string>();//异常的设备地址集合

                foreach (var item in input.AddressList)
                {
                    var deviceInfo = deviceInfoList.Where(d => d.DeviceAddress == item).FirstOrDefault();
                    if (deviceInfo == null)
                    {
                        deviceAddress.Add(item);
                        continue;
                    }

                    var receiveCommandInfoDto = CreateReceiveCommandInfoDto(deviceInfo);

                    var deviceUpgradeRecordInput = input.Adapt<DeviceUpgradeForApiInput>();
                    deviceUpgradeRecordInput.Id = deviceInfo.Id;

                    try
                    {
                        var oneNETHandleResult = await ProcessDeviceUpgradeByPlatformAsync(deviceInfo, receiveCommandInfoDto, deviceFirmwareVersionInfo, fileInfo, deviceUpgradeRecordInput, oneNETProductInfo, oneNETPlatformThingModelInfo);

                        if (!oneNETHandleResult)
                        {
                            deviceAddress.Add(item);
                        }
                    }
                    catch (Exception)
                    {
                        deviceAddress.Add(item);
                    }
                }

                return deviceAddress;
            }
            catch (Exception)
            {
                throw;
            }
        }


        /// <summary>
        /// 下载设备固件文件
        /// </summary>
        [AllowAnonymous]
        public async Task<RemoteStreamContent> DownloadFirmwareInfoAsync(IdInput input)
        {
            try
            {
                // Lua 脚本：获取并删除键（原子操作）升级记录Id与文件ID关系缓存
                string cacheKey = string.Format($"{RedisConst.CacheDeviceUpgradeRecordDataKey}", input.Id);
                var redisResult = await FreeRedisProvider.Instance.GetAsync(cacheKey);
                if (string.IsNullOrWhiteSpace(redisResult))
                {
                    throw new UserFriendlyException($"{nameof(DownloadFirmwareInfoAsync)} 设备升级记录信息 {input.Id} 不存在");
                }

                //将缓存中的文件ID转换成GUID
                Guid fileId = new Guid(redisResult);

                var downLoadResult = await fileAppService.AllowDownloadAsync(new IdInput()
                {
                    Id = fileId,
                });
                if (downLoadResult.ContentLength.HasValue && downLoadResult.ContentLength.Value > 0)
                {
                    //更新状态为文件下载中
                    await deviceUpgradeRecordService.UpdateStatusAsync(new UpdateStatusInput()
                    {
                        Id = input.Id,
                        UpgradeStatus = DeviceUpgradeStatusTypeEnum.Downloading,
                    });
                }

                return downLoadResult;
            }
            catch (Exception ex)
            {
                logger.LogError($"{nameof(DownloadFirmwareInfoAsync)}{input.Id}下载设备固件文件发生异常，{ex.Message}");
                throw;
            }
        }


        /// <summary>
        /// 获取设备属性最新值
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<Dictionary<string, object>> GetDevicePropertyValueForApiAsync(DevicePropertyValueForApiInput input)
        {
            try
            {
                if (input.PropertyList == null || input.PropertyList.Count <= 0)
                {
                    throw new UserFriendlyException($"属性标识符参数异常");
                }

                var deviceInfo = await deviceAppService.FindByIdAsync(input);
                if (deviceInfo == null)
                {
                    throw new UserFriendlyException($"设备不存在");
                }


                //数据写入遥测任务数据存储通道 
                if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.OneNET)
                {
                    return await DevicePropertyValueToOneNET(deviceInfo, input);
                }
                else if (deviceInfo.IoTPlatform == IoTPlatformTypeEnum.CTWing)
                {
                    //await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.CTWingAepCommandIssuedEventName,commandRequest);
                    //return true;
                    throw new UserFriendlyException($"发送设备指令信息失败，CTWing暂未实现。");
                }
                else
                {
                    throw new UserFriendlyException($"发送设备指令信息失败，未找到对应的产品配置信息。");
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 业务系统批量创建设备信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> BatchCreateDeviceBusinessSystemAsync(BatchCreateDeviceBusinessSystemInput input)
        {
            try
            {
                if (input.DeviceInfos == null || input.DeviceInfos.Count <= 0)
                {
                    throw new UserFriendlyException($"业务系统批量创建设备信息，设备信息不能为空。");
                }

                if (input.DeviceInfos.Count > 100)
                {
                    throw new UserFriendlyException($"业务系统批量创建设备信息，设备信息不能超过100个。");
                }

                if (input.DeviceSourceType != DeviceSourceTypeEnum.Prepay && input.DeviceSourceType != DeviceSourceTypeEnum.Energy)
                {
                    throw new UserFriendlyException($"业务系统批量创建设备信息，设备来源异常。");
                }

                if (input.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                {
                    var batchCreateDeviceInput = input.Adapt<BatchCreateDeviceAggregationInput>();
                    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>();
                    batchCreateDeviceInput.AddressList = input.DeviceInfos.Select(f => f.DeviceAddress.Trim()).ToList();

                    return await OneNETDeviceBatchCreateAsync(batchCreateDeviceInput);
                }

                throw new UserFriendlyException($"不支持的物联网平台");
            }
            catch (Exception)
            {

                throw;
            }
        }


        /// <summary>
        /// 绑定设备端物模型
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> BindingDeviceThingModel(BindingDeviceThingModelInput input)
        {
            try
            {
                List<DeviceManagementInfoDto> bindingDeviceList = await deviceAppService.BindingDeviceThingModel(input);

                if (bindingDeviceList == null)
                {
                    throw new UserFriendlyException($"绑定设备端物模型失败", "-101");
                }
                foreach (var item in bindingDeviceList)
                {
                    if (item.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.CTWing)
                    {
                        logger.LogInformation($"{nameof(BindingDeviceThingModel)} CTWing设备{item.DeviceAddress}绑定设备物模型未实现");
                        continue;
                    }
                    else if (item.IoTPlatform == ServicePro.Enums.IoTPlatformTypeEnum.OneNET)
                    {
                        var platformThingModelInfos = await platformThingModelInfoAppService.FindByPlatformProductIdAsync(new IdInput<string>() { Id = item.IoTPlatformProductId });


                        return await DeviceCommandInfoToOneNET(item, new ReceiveCommandInfoDto()
                        {
                            DeviceType = item.DeviceType,
                            SourceType = DeviceTelemetrySourceTypeEnum.AdminSystem,
                            DeviceAddress = item.DeviceAddress,
                            IoTPlatform = item.IoTPlatform,
                            Commands = new Dictionary<string, object>() { 
                                {ThingModelFixedTypeConst.SpecialCommand,
                                ""} 
                            },
                        }, platformThingModelInfos);
                    }
                }

                return true;

            }
            catch (Exception)
            {

                throw;
            }
        }


        #region OneNET 设备操作
        /// <summary>
        /// OneNET设备创建
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        protected async Task<bool> OneNETDeviceCreateAsync(CreateDeviceAggregationInput input)
        {
            try
            {
                CreateDeviceInput createDeviceInput = input.Adapt<CreateDeviceInput>();

                var productInfo = await oneNETProductService.GetProductInfoAsync(new IdInput<string>() { Id = input.IoTPlatformProductId });

                if (productInfo == null)
                {
                    throw new UserFriendlyException($"OneNET创建设备失败，未找到对应的产品配置信息。");
                }

                if (input.DeviceSourceType == DeviceSourceTypeEnum.Workshop && !productInfo.IsEnabled)   //车间生产推送，必须是已经启用的产品才可以
                {
                    throw new UserFriendlyException($"车间生产推送OneNET创建设备失败，产品未启用。");
                }

                createDeviceInput.DeviceName = input.DeviceAddress;
                createDeviceInput.IoTPlatformAccountId = productInfo.OneNETAccountId;
                createDeviceInput.IoTPlatformDeviceOpenInfo = $"{input.IoTPlatformProductId}{input.DeviceAddress}";
                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)
                {
                    logger.LogError($"{nameof(CreateDeviceForApiAsync)} 添加设备信息失败：{input.Serialize()}");
                    return false;
                }

                //推送至OneNET平台
                var pushResult = await oneNETDeviceService.CreateDeviceInfoAsync(new CreateDeviceInfoInput()
                {
                    DeviceName = createDeviceInput.IoTPlatformDeviceOpenInfo,
                    ProductId = productInfo.IoTPlatformProductId,
                    OneNETAccountId = productInfo.OneNETAccountId,
                    Description = input.DeviceAddress,
                });

                if (pushResult == null || pushResult.Code != ServicePro.Enums.ResponeResultEnum.Success || pushResult.Data == null)
                {
                    logger.LogError($"{nameof(CreateDeviceForApiAsync)} 推送设备信息失败：{pushResult.Serialize()}");
                    return false;
                }

                //更新OneNET平台推送结果
                await DeviceUpdateHandler(insertResult, pushResult, pushResult.Data.SecurityKey);

                return true;
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// OneNET设备批量创建
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        protected async Task<bool> OneNETDeviceBatchCreateAsync(BatchCreateDeviceAggregationInput input)
        {
            try
            {
                var productInfo = await FreeSqlDbContext.Instance.Select<OneNETProductInfos>()
                  .Where(e => e.IoTPlatformProductId == input.IoTPlatformProductId)//此处不需要过滤产品状态，方便测试产品配置信息是否准确，避免跟车间生产搞混
                  .WhereIf(input.DeviceSourceType == DeviceSourceTypeEnum.Workshop, e => e.IsEnabled == true)
                 .FirstAsync();

                if (productInfo == null)
                {
                    throw new UserFriendlyException($"批量创建设备失败，未找到对应的产品配置信息。");
                }

                BatchCreateDeviceInput batchCreateDeviceInput = new BatchCreateDeviceInput()
                {
                    IoTPlatform = input.IoTPlatform,
                    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.DeviceInfos)
                {
                    if (checkDevicesInfos != null)
                    {

                        var checkDevices = checkDevicesInfos.Where(e => e.DeviceAddress == item.DeviceAddress).FirstOrDefault();

                        if (checkDevices != null && checkDevices.IsPlatformPushSuccess)
                        {
                            logger.LogError($"{nameof(OneNETDeviceBatchCreateAsync)} 平台{input.IoTPlatform} 产品 {input.IoTPlatformProductId} 下设备信息已存在：{item.DeviceAddress}");
                            continue;
                        }
                    }


                    CreateDeviceInput createDeviceInput = input.Adapt<CreateDeviceInput>();
                    createDeviceInput.DeviceName = item.DeviceAddress;
                    createDeviceInput.DeviceAddress = item.DeviceAddress;
                    createDeviceInput.IoTPlatformAccountId = productInfo.OneNETAccountId;
                    createDeviceInput.IoTPlatformDeviceOpenInfo = $"{input.IoTPlatformProductId}{item.DeviceAddress}";
                    createDeviceInput.PlatformPassword = productInfo.ProductAccesskey;
                    createDeviceInput.IoTPlatformProductName = productInfo.ProductName;
                    createDeviceInput.AccountPhoneNumber = productInfo.AccountPhoneNumber;

                    if (input.DeviceSourceType.HasValue)
                    {
                        createDeviceInput.DeviceSourceType = input.DeviceSourceType.Value;
                    }

                    if (input.DeviceType.HasValue)
                    {
                        createDeviceInput.DeviceType = input.DeviceType.Value;
                    }

                    if (item.BusinessSystemDeviceDataId.HasValue)
                    {
                        createDeviceInput.BusinessSystemDeviceDataId = item.BusinessSystemDeviceDataId.Value;
                    }

                    batchCreateDeviceInput.DeviceInputs.Add(createDeviceInput);
                }


                if (batchCreateDeviceInput.DeviceInputs != null || batchCreateDeviceInput.DeviceInputs.Count > 0)
                {


                    var insertResult = await deviceAppService.BatchCreateAsync(batchCreateDeviceInput);
                    if (insertResult == null)
                    {
                        logger.LogError($"{nameof(OneNETDeviceBatchCreateAsync)} OneNET设备批量创建添加设备信息失败：{input.Serialize()}");
                        return false;
                    }
                    //网关或者直连设备 推送至OneNET平台
                    var oneNETBatchCreateDeviceInfoInput = new BatchCreateDeviceInfoInput()
                    {
                        ProductId = productInfo.IoTPlatformProductId,
                        OneNETAccountId = productInfo.OneNETAccountId,
                        DeviceList = new List<string>()
                    };

                    oneNETBatchCreateDeviceInfoInput.DeviceList = batchCreateDeviceInput.DeviceInputs.Select(d => d.IoTPlatformDeviceOpenInfo).ToList();

                    var pushResult = await oneNETDeviceService.BatchCreateDeviceInfoAsync(oneNETBatchCreateDeviceInfoInput);

                    if (pushResult == null || pushResult.Code != ServicePro.Enums.ResponeResultEnum.Success)
                    {
                        logger.LogError($"{nameof(CreateDeviceForApiAsync)} 推送设备信息失败：{pushResult.Serialize()}");
                        return false;
                    }

                    //更新OneNET平台推送结果
                    foreach (var item in insertResult)
                    {
                        var successEntity = pushResult.Data.Successlist.Where(d => d.DeviceName == item.IoTPlatformDeviceOpenInfo).FirstOrDefault();
                        if (successEntity != null)
                        {
                            await DeviceUpdateHandler(item, HttpDataResultExtensions.Success(successEntity), successEntity.SecurityKey);
                        }
                    }
                }

                //暂不考虑子设备地址信息，由网关设备主动上报

                return true;
            }
            catch (Exception)
            {

                throw;
            }
        }


        /// <summary>
        /// 重新推送设备信息到OneNET物联网平台
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<DeviceManagementInfoDto> RepushDeviceInfoToOneNET(DeviceManagementInfoDto input)
        {
            try
            {
                //检查OneNET平台设备是否已经存在
                var oneNETDeviceInfoResult = await oneNETDeviceService.DeviceInfoDetailAsync(new DeviceInfoDetailInput()
                {
                    DeviceName = input.IoTPlatformDeviceOpenInfo,
                    ProductId = input.IoTPlatformProductId,
                    OneNETAccountId = input.IoTPlatformAccountId,
                });

                if (oneNETDeviceInfoResult != null && oneNETDeviceInfoResult.Code == ServicePro.Enums.ResponeResultEnum.Success)
                {
                    throw new UserFriendlyException($"OneNET推送失败，账号产品下{input.IoTPlatformProductId}已经存在该设备{input.DeviceAddress}。");
                }

                //推送至OneNET平台
                var pushResult = await oneNETDeviceService.CreateDeviceInfoAsync(new CreateDeviceInfoInput()
                {
                    DeviceName = input.IoTPlatformDeviceOpenInfo,
                    ProductId = input.IoTPlatformProductId,
                    OneNETAccountId = input.IoTPlatformAccountId,
                    Description = input.DeviceAddress,
                });

                if (pushResult == null || pushResult.Code != ServicePro.Enums.ResponeResultEnum.Success || pushResult.Data == null)
                {
                    logger.LogError($"{nameof(CreateDeviceForApiAsync)} 推送设备信息失败：{pushResult.Serialize()}");
                    throw new UserFriendlyException($"平台请求失败。");

                }

                return await DeviceUpdateHandler(input, pushResult, pushResult.Data.SecurityKey);
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 删除OneNET平台设备
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<bool> DeleteDeviceInfoToOneNET(DeviceManagementInfoDto input)
        {
            try
            {
                //删除OneNET平台设备信息
                var deleteResult = await oneNETDeviceService.DeleteDeviceInfoAsync(new DeleteDeviceInfoInput()
                {
                    DeviceName = input.IoTPlatformDeviceOpenInfo,
                    ProductId = input.IoTPlatformProductId,
                    OneNETAccountId = input.IoTPlatformAccountId,
                });

                if (deleteResult == null || deleteResult.Code != ServicePro.Enums.ResponeResultEnum.Success)
                {
                    logger.LogError($"{nameof(CreateDeviceForApiAsync)} 删除设备信息失败：{deleteResult.Serialize()}");
                    throw new UserFriendlyException($"删除设备平台请求失败。");

                }

                var localDeleteReult = await deviceAppService.DeleteAsync(new IdInput() { Id = input.Id });
                if (localDeleteReult == false)
                {
                    throw new UserFriendlyException($"平台设备信息删除成功，系统删除设备失败。");
                }

                return localDeleteReult;
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 发送OneNET平台设备指令
        /// </summary>
        /// <param name="deviceInfo">设备信息</param>
        /// <param name="input">指令信息</param>
        /// <param name="platformThingModelInfos">平台端物模型信息</param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        protected async Task<bool> DeviceCommandInfoToOneNET(DeviceManagementInfoDto deviceInfo, ReceiveCommandInfoDto input, List<IoTPlatformThingModelInfoDto> platformThingModelInfos = null)
        {
            try
            {

                //获取设备对应的平台端物模型信息，校验前端传入的属性标识集合是否存在不合法的属性标识符
                if (platformThingModelInfos == null || platformThingModelInfos.Count <= 0)
                {
                    platformThingModelInfos = await platformThingModelInfoAppService.FindByPlatformProductIdAsync(new IdInput<string>() { Id = deviceInfo.IoTPlatformProductId });
                }

                if (platformThingModelInfos == null || platformThingModelInfos.Count <= 0)
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}的平台端物模型信息不存在。");
                }

                foreach (var item in input.Commands)
                {
                    var tempPlatformThingModelInfo = platformThingModelInfos.Where(d => d.IoTPlatformRawFieldName == item.Key).FirstOrDefault();
                    if (tempPlatformThingModelInfo == null)
                    {
                        throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}平台端物模型信息不存在属性标识符{item.Key}。");
                    }

                    //排除升级指令
                    if (tempPlatformThingModelInfo.StandardFieldName.ToLowerInvariant() == ThingModelFixedTypeConst.FIRMWARE_UPGRADE.ToLowerInvariant())
                    {
                        throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}平台端物模型属性标识符{item.Key}是升级指令，此处不允许下发。");
                    }
                }

                //检查设备是否有配置设备端物模型信息
                //如果有配置，就检查指令字典中是否有SpecialCommand标识符
                //如果有就需要构建 SpecialCommand 的特别指令 
                if (deviceInfo.IsNeedConfigDevicMdoel && deviceInfo.DeviceThingModelDataId.HasValue && input.Commands.ContainsKey(ThingModelFixedTypeConst.SpecialCommand))
                {
                    var propertyInfo = await oneNETProductService.GetProductThingModelSpecialCommandDataTypeListAsync(new IdInput<string>() { Id = deviceInfo.IoTPlatformProductId });

                    if (propertyInfo == null)
                    {
                        throw new UserFriendlyException($"{nameof(DeviceCommandInfoToOneNET)} OneNET设备属性设置失败，产品Id{deviceInfo.IoTPlatformProductId}未找到对应的属性信息。");
                    }

                    Dictionary<string, string> tempSpecialCommand = await deviceThingModelService.BuildThingModelSpecialCommandAsync(propertyInfo, deviceInfo.DeviceThingModelDataId.Value);

                    input.Commands[ThingModelFixedTypeConst.SpecialCommand] = tempSpecialCommand;
                }
                else if (input.Commands.ContainsKey(ThingModelFixedTypeConst.SpecialCommand))
                {
                    //非绑定物模型情况下，SpecialCommand还原默认值，设备也会恢复默认采集方式
                    input.Commands[ThingModelFixedTypeConst.SpecialCommand] = CommonConst.SpecialCommandDefaultValue;
                    logger.LogWarning($"{nameof(DeviceCommandInfoToOneNET)} OneNET平台设备{deviceInfo.DeviceAddress}特殊抄读指令还原为{CommonConst.SpecialCommandDefaultValue}");
                }

                var commandRequest = new OpenApiRequest()
                {
                    Message = input.Serialize(),
                };
                var packetTaskInfo = GetDeviceTelemetryPacketTaskInfo(ioTDBOptions, commandRequest, deviceInfo.Adapt<DeviceCacheInfos>(), input.Commands.Serialize());

                await ioTDBDataChannelManageService.DeviceTelemetryTaskWriterAsync(DataChannelManage.DeviceTelemetryTaskDataChannel.Writer, (DistributedMessageCenterConst.OneNETCommandIssuedEventName, packetTaskInfo));  

                await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.OneNETCommandIssuedEventName, packetTaskInfo);
                return true;
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 发送OneNET平台设备升级指令
        /// </summary>
        /// <param name="deviceInfo"></param>
        /// <param name="taskInput">设置属性请求内容相关</param>
        /// <param name="deviceFirmwareInfo">固件数据Id</param>
        /// <param name="fileObject">固件文件信息</param>
        /// <param name="input">入参</param>
        /// <param name="productInfo">产品信息（如果已获取则传入以避免重复调用）</param>
        /// <param name="platformThingModelInfo">平台端物模型信息（如果已获取则传入以避免重复调用）</param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        protected async Task<bool> DeviceUpgradeCommandToOneNET(DeviceManagementInfoDto deviceInfo, ReceiveCommandInfoDto taskInput, DeviceFirmwareInfoDto deviceFirmwareInfo, FileObjectDto fileObject, DeviceUpgradeForApiInput input, dynamic productInfo = null, dynamic platformThingModelInfo = null)
        {
            try
            {
                if (deviceInfo == null || deviceFirmwareInfo == null || fileObject == null)
                {
                    throw new UserFriendlyException($"{nameof(DeviceUpgradeCommandToOneNET)}设备或固件信息不能为空");
                }

                if ((deviceInfo.IoTPlatformProductId != deviceFirmwareInfo.IoTPlatformProductId) || (deviceInfo.IoTPlatform != deviceFirmwareInfo.IoTPlatform))
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}平台产品信息固件中不一致");
                }

                //如果未传入产品信息和物模型信息，则获取
                if (productInfo == null || platformThingModelInfo == null)
                {
                    var (productInfoResult, platformThingModelInfoResult) = await GetOneNETProductAndThingModelInfoAsync(deviceInfo.IoTPlatformProductId, deviceInfo.DeviceAddress);
                    productInfo = productInfoResult;
                    platformThingModelInfo = platformThingModelInfoResult;
                }

                var upgradeProperty = ((List<IoTPlatformThingModelInfoDto>)platformThingModelInfo).Where(d => d.StandardFieldName == ThingModelFixedTypeConst.FIRMWARE_UPGRADE).FirstOrDefault();
                if (upgradeProperty == null)
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}平台端物模型信息不存在升级属性标识符{ThingModelFixedTypeConst.FIRMWARE_UPGRADE}。");
                }

                //构建升级指令，《文件MD5值+OneNET产品KEY+升级标识符+文件大小》=>MD5计算获得签名值

                var upgradeRecordInput = new CreateDeviceUpgradeRecordInput()
                {
                    DeviceName = deviceInfo.DeviceName,
                    DeviceAddress = deviceInfo.DeviceAddress,
                    OldFirmwareVersion = deviceInfo.FirmwareVersion,
                    NowFirmwareVersion = deviceFirmwareInfo.FirmwareVersion,
                    UpgradeSource = DeviceUpgradeSourceTypeEnum.AdminSystem,
                    UpgradeIdentifier = Yitter.IdGenerator.YitIdHelper.NextId(),
                    UpgradeDescription = input.UpgradeDescription,
                    UpgradeStatus = DeviceUpgradeStatusTypeEnum.NotUpgrade,
                    Id = GuidGenerator.Create()
                };

                var md5HashRaw = $"{fileObject.Md5Hash}{productInfo.ProductAccesskey}{upgradeRecordInput.UpgradeIdentifier}{fileObject.FileSize}";

                var upgradeRequest = new DeviceUpgradeCommandRequest()
                {
                    Length = fileObject.FileSize,
                    UpgradeIdentifier = upgradeRecordInput.UpgradeIdentifier,
                    SignatureValue = md5HashRaw.Md5Fun(),
                    FirmwareUrl = $"{serverApplicationOptions.DownloadDeviceFirmwareBasicUrl}{upgradeRecordInput.Id}",
                    TimeOut = serverApplicationOptions.DownloadDeviceFirmwareTimeOut,
                };

                upgradeRecordInput.UpgradeMessage = upgradeRequest.Serialize();
                upgradeRecordInput.FirmwareSignature = upgradeRequest.SignatureValue;

                string upgradeMessageHexString = upgradeRecordInput.UpgradeMessage.ToHexString();

                //检查长度是否超过了OneNET平台升级属性标识符的长度限制
                var thingModelInfoStr = ((OneNETProductInfos)productInfo).ThingModelInfos;
                if (string.IsNullOrWhiteSpace(thingModelInfoStr))
                {
                    logger.LogError($"{nameof(DeviceUpgradeCommandToOneNET)} 通过OneNET产品ID和属性标识符获取属性配置信息失败，属性信息为空");
                    return false;
                }
                var thingModelInfo = thingModelInfoStr.Deserialize<OneNETAllThingModel>();
                if (thingModelInfo.Properties == null)
                {
                    logger.LogError($"{nameof(DeviceUpgradeCommandToOneNET)} 通过OneNET产品ID和属性标识符获取属性配置信息失败，属性信息为空");
                    return false;
                }

                var property = thingModelInfo.Properties.Where(d => d.Identifier == upgradeProperty.IoTPlatformRawFieldName).FirstOrDefault(); //精准匹配

                if (property == null)
                {
                    logger.LogError($"{nameof(DeviceUpgradeCommandToOneNET)} 通过OneNET产品ID和属性标识符获取属性配置信息失败，没有找到属性标识升级对应的属性平台信息");
                    return false;
                }

                var length = ((OneNETModelStringSpecs)property.DataType.Specs).Length;
                if (upgradeMessageHexString.Length > length)
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}平台端物模型信息属性标识符{upgradeProperty.IoTPlatformRawFieldName}长度超过OneNET平台限制，请检查物模型属性标识符长度是否超过了{length}");
                }

                var insertResult = await deviceUpgradeRecordService.CreateAsync(upgradeRecordInput);

                if (insertResult == null)
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceAddress}升级记录失败");
                }

                //发送OneNET平台设备升级指令，HEX格式字符串
                taskInput.Commands = new Dictionary<string, object>()
                {
                    { upgradeProperty.IoTPlatformRawFieldName, upgradeMessageHexString }
                };

                var commandRequest = new OpenApiRequest()
                {
                    Message = taskInput.Serialize(),
                };
                var packetTaskInfo = GetDeviceTelemetryPacketTaskInfo(ioTDBOptions, commandRequest, deviceInfo.Adapt<DeviceCacheInfos>(), taskInput.Commands.Serialize());

                await ioTDBDataChannelManageService.DeviceTelemetryTaskWriterAsync(DataChannelManage.DeviceTelemetryTaskDataChannel.Writer, (DistributedMessageCenterConst.OneNETUpgradeCommandIssuedEventName, packetTaskInfo));

                //将升级记录数据Id作为key，文件数据ID作为值，存入Redis缓存中。
                string cacheKey = string.Format($"{RedisConst.CacheDeviceUpgradeRecordDataKey}", upgradeRecordInput.Id);

                await FreeRedisProvider.Instance.SetAsync(cacheKey, fileObject.Id);

                await redisPubSubService.PublishReliableAsync(DistributedMessageCenterConst.OneNETCommandIssuedEventName, packetTaskInfo);

                //更新状态为升级中
                await deviceUpgradeRecordService.UpdateStatusAsync(new UpdateStatusInput()
                {
                    Id = upgradeRecordInput.Id.Value,
                    UpgradeStatus = DeviceUpgradeStatusTypeEnum.Upgrading,
                });
                return true;
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 抄读OneNET平台设备属性数据
        /// </summary>
        /// <param name="deviceInfo"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        protected async Task<Dictionary<string, object>> DevicePropertyValueToOneNET(DeviceManagementInfoDto deviceInfo, DevicePropertyValueForApiInput input)
        {
            try
            {
                //检查下设备是否在线
                var deviceOnlineStatus = await oneNETDeviceService.DeviceInfoDetailAsync(new DeviceInfoDetailInput()
                {
                    DeviceName = deviceInfo.IoTPlatformDeviceOpenInfo,
                    OneNETAccountId = deviceInfo.IoTPlatformAccountId,
                    ProductId = deviceInfo.IoTPlatformProductId,
                });

                if (deviceOnlineStatus == null || deviceOnlineStatus.Code != ResponeResultEnum.Success)
                {
                    throw new UserFriendlyException("获取平台设备信息失败");
                }

                if (deviceOnlineStatus.Data.Status != 1)
                {
                    throw new UserFriendlyException("设备不在线");
                }

                var deviceDataResult = await oneNETDeviceService.QueryDevicePropertyDetail(new QueryDevicePropertyDetailInput()
                {
                    DeviceName = deviceInfo.IoTPlatformDeviceOpenInfo,
                    OneNETAccountId = deviceInfo.IoTPlatformAccountId,
                    ProductId = deviceInfo.IoTPlatformProductId,
                    PropertyInfos = input.PropertyList
                });
                if (deviceDataResult == null || deviceDataResult.Success == false || deviceDataResult.Data == null)
                {
                    throw new UserFriendlyException($"设备{deviceInfo.DeviceName}获取数据失败");
                }

                return deviceDataResult.Data;
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion

        #region CTWing 设备操作 
        /// <summary>
        /// CTWing 设备创建
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        protected async Task<bool> CTWingDeviceCreateAsync(CreateDeviceAggregationInput input)
        {
            throw new UserFriendlyException($"CTWing 设备创建失败，功能未实现。");
        }

        /// <summary>
        /// CTWing 批量设备创建
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        protected async Task<bool> CTWingDeviceBatchCreateAsync(BatchCreateDeviceAggregationInput input)
        {
            try
            {
                throw new UserFriendlyException($"CTWing 批量设备创建失败，CTWing暂未实现。");
            }
            catch (Exception)
            {

                throw;
            }
        }



        /// <summary>
        /// 重新推送设备信息到CTWing物联网平台
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<DeviceManagementInfoDto> RepushDeviceInfoToCTWing(DeviceManagementInfoDto input)
        {
            try
            {
                throw new UserFriendlyException($"推送失败，CTWing暂未实现。");
            }
            catch (Exception)
            {

                throw;
            }
        }
        /// <summary>
        /// 删除CTWing平台设备
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="UserFriendlyException"></exception>
        public async Task<bool> DeleteDeviceInfoToCTWing(DeviceManagementInfoDto input)
        {
            try
            {
                throw new UserFriendlyException($"删除失败，CTWing暂未实现。");
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion
    }
}