//using Newtonsoft.Json;
//using System;
//using System.Collections.Generic;
//using System.Linq;
//using System.Text;
//using System.Threading.Tasks;
//using WIDESEAWCS_Common.TaskEnum;
//using WIDESEAWCS_Common;
//using WIDESEAWCS_Core.Helper;
//using WIDESEAWCS_Core;
//using WIDESEAWCS_DTO.TaskInfo;
//using WIDESEAWCS_DTO.WMS;
//using WIDESEAWCS_Model.Models;
//using WIDESEAWCS_QuartzJob;
//using WIDESEAWCS_Tasks.ConveyorLineJob;
//using WIDESEAWCS_QuartzJob.DeviceBase;
//using WIDESEAWCS_QuartzJob.DTO;
//using AutoMapper;
//using WIDESEAWCS_IProcessRepository;
//using WIDESEAWCS_ISystemServices;
//using WIDESEAWCS_ITaskInfoRepository;
//using WIDESEAWCS_ITaskInfoService;
//using WIDESEAWCS_QuartzJob.Service;
//using HslCommunication;

//namespace WIDESEAWCS_Tasks.Public
//{
//    public class PublicCommonTask
//    {
//        public readonly ITaskService _taskService;
//        private readonly ITaskRepository _taskRepository;
//        private readonly ITaskExecuteDetailService _taskExecuteDetailService;
//        private readonly IRouterService _routerService;
//        private readonly IPlatFormRepository _platFormRepository;
//        private readonly ISys_ConfigService _sys_ConfigService;
//        private readonly IMapper _mapper;


//        public PublicCommonTask(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService)
//        {
//            _taskService = taskService;
//            _taskExecuteDetailService = taskExecuteDetailService;
//            _routerService = routerService;
//            _mapper = mapper;
//            _taskRepository = taskRepository;
//            _platFormRepository = platFormRepository;
//            _sys_ConfigService = sys_ConfigService;
//        }

//        /// <summary>
//        /// 处理出库任务
//        /// </summary>
//        public static void HandleTaskOut(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue, Dt_Task taskOut)
//        {
//            if (taskOut == null) return;

//            //var taskCommand = MapTaskCommand(taskOut, command);

//            bool isOutTray = taskOut.TaskType == (int)TaskOutboundTypeEnum.OutTray;
//            bool isOutboundAndOutFinish = taskOut.TaskType == (int)TaskOutboundTypeEnum.Outbound && taskOut.TaskState == (int)TaskOutStatusEnum.SC_OutFinish;
//            bool isOutboundAndLineOutExecuting = taskOut.TaskType == (int)TaskOutboundTypeEnum.Outbound && taskOut.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting;

//            if (isOutTray || isOutboundAndOutFinish || !isOutboundAndLineOutExecuting)
//            {
//                conveyorLine.SendCommand(taskCommand, childDeviceCode);
//                ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
//                _taskService.UpdateTaskStatusToNext(taskOut);
//            }
//            else if (taskOut.TaskType == (int)TaskOutboundTypeEnum.OutTray && taskOut.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting)
//            {
//                CompleteWmsTask(taskOut, command, conveyorLine, childDeviceCode, ProtocalDetailValue);
//            }
//        }

//        /// <summary>
//        /// 处理新任务
//        /// </summary>
//        private void HandleNewTask(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
//        {
//            if ((conveyorLine.DeviceCode == "1003" && childDeviceCode == "1016") || (conveyorLine.DeviceCode == "1005" && childDeviceCode == "1048"))
//            {
//                CreateAndSendEmptyTrayTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
//            }
//            else if ((conveyorLine.DeviceCode == "1001" && childDeviceCode == "1088") || (conveyorLine.DeviceCode == "1004" && childDeviceCode == "1339"))
//            {
//                RequestWmsTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
//            }
//            //else if ((conveyorLine.DeviceCode == "1001" && childDeviceCode == "1068"))
//            //{
//            //    ConveyorLineOutFinish(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
//            //}
//        }

//        /// <summary>
//        /// 完成WMS任务
//        /// </summary>
//        private void CompleteWmsTask(Dt_Task taskOut, ConveyorLineTaskCommand command, CommonConveyorLine conveyorLine, string childDeviceCode, int ProtocalDetailValue)
//        {
//            if (command.Barcode == "NoRead")
//            {
//                var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == taskOut.TargetAddress).Capacity;
//                taskOut.TargetAddress = NGAddress.ToString();
//            }

//            var keys = new Dictionary<string, object>()
//            {
//                {"taskNum", taskOut.TaskNum}
//            };
//            var config = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
//            var wmsBase = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.WMSIP_BASE)?.ConfigValue;
//            var completeTask = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.CompleteTask)?.ConfigValue;
//            if (wmsBase == null || completeTask == null)
//            {
//                throw new InvalidOperationException("WMS IP 未配置");
//            }
//            var wmsIpAddress = wmsBase + completeTask;

//            var result = HttpHelper.GetAsync(wmsIpAddress, keys).Result;
//            WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);
//            if (content.Status)
//            {
//                ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
//                _taskService.UpdateTaskStatusToNext(taskOut);
//            }
//        }

//        /// <summary>
//        /// 创建并发送空托盘任务
//        /// </summary>
//        public void CreateAndSendEmptyTrayTask(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
//        {
//            if (command.Barcode != "NoRead")
//            {
//                var taskDTO = CreateEmptyTrayTaskDto(command.Barcode, childDeviceCode);

//                if (_taskRepository.QueryFirst(x => x.PalletCode == taskDTO.PalletCode) != null)
//                {
//                    //WriteInfo(conveyorLine.DeviceName, "当前托盘存在任务");
//                    return;
//                }

//                var content = CreateAndSendTask(taskDTO);
//                if (content.Status)
//                {
//                    var task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
//                    if (task != null)
//                    {
//                        var taskCommand = MapTaskCommand(task, command);
//                        conveyorLine.SendCommand(taskCommand, childDeviceCode);
//                        ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
//                        _taskService.UpdateTaskStatusToNext(task);
//                    }
//                }
//            }
//        }

//        /// <summary>
//        /// 创建空托盘任务DTO
//        /// </summary>
//        private WMSTaskDTO CreateEmptyTrayTaskDto(string barcode, string childDeviceCode)
//        {
//            var request = new RequestTaskDto()
//            {
//                Position = childDeviceCode,
//                PalletCode = barcode,
//            };

//            var config = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
//            var wmsBase = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.WMSIP_BASE)?.ConfigValue;
//            var requestTrayInTask = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.RequestTrayInTask)?.ConfigValue;
//            if (wmsBase == null || requestTrayInTask == null)
//            {
//                throw new InvalidOperationException("WMS IP 未配置");
//            }
//            var wmsIpAddrss = wmsBase + requestTrayInTask;
//            var result = HttpHelper.PostAsync(wmsIpAddrss, request.ToJsonString()).Result;
//            if (result == null)
//                return new WMSTaskDTO();

//            WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);
//            if (!content.Status)
//                return new WMSTaskDTO();

//            return JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());
//        }

//        /// <summary>
//        /// 请求WMS任务
//        /// </summary>
//        private async void RequestWmsTask(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
//        {
//            var content = await _taskService.RequestWMSTask(command.Barcode, childDeviceCode);
//            if (content.Status)
//            {
//                var task = _taskService.QueryBarCodeConveyorLineTask(command.Barcode, childDeviceCode);
//                if (task != null)
//                {
//                    var taskCommand = MapTaskCommand(task, command);
//                    conveyorLine.SendCommand(taskCommand, childDeviceCode);
//                    ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
//                    _taskService.UpdateTaskStatusToNext(task);
//                }
//            }
//        }


//        /// <summary>
//        /// 输送线交互完成
//        /// </summary>
//        /// <param name="conveyorLine">输送线实例对象</param>
//        /// <param name="childDeviceCode">子设备编号</param>
//        /// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param>
//        /// <param name="value">值</param>
//        public void ConveyorLineSendFinish(CommonConveyorLine conveyorLine, string childDeviceCode, int ProtocalDetailValue, bool value)
//        {
//            DeviceProDTO? devicePro = conveyorLine.DeviceProDTOs.Where(x => x.DeviceProParamType == nameof(DeviceCommand) && x.DeviceChildCode == childDeviceCode).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
//            string[] x = devicePro.DeviceProAddress.Split('.');
//            x[x.Length - 1] = (ProtocalDetailValue + 1).ToString();
//            string DeviceProAddress = string.Join(".", x);
//            conveyorLine.Communicator.Write(DeviceProAddress, value);
//        }


//        /// <summary>
//        /// 输送线入库完成
//        /// </summary>
//        /// <param name="conveyorLine">输送线实例对象</param>
//        /// <param name="command">读取的请求信息</param>
//        /// <param name="childDeviceCode">子设备编号</param>
//        /// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param>
//        public void ConveyorLineInFinish(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
//        {
//            var task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
//            if (task != null && task.TaskState != (int)TaskInStatusEnum.Line_InFinish)
//            {
//                ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);

//                WebResponseContent content = _taskService.UpdateTaskStatusToNext(task);

//                Console.Out.WriteLine(content.Serialize());
//            }
//        }

//        /// <summary>
//        /// 创建任务
//        /// </summary>
//        public WebResponseContent CreateAndSendTask(WMSTaskDTO taskDTO)
//        {
//            var content = _taskService.ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO });
//            if (content.Status)
//            {
//                Console.WriteLine($"{taskDTO.TaskType}呼叫成功");
//            }
//            return content;
//        }
//    }
//}