using AngleSharp.Io;
using System.Threading.Tasks;

namespace WIDESEA_StorageTaskServices;

public partial class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService
{
    private readonly LogFactory LogFactory = new LogFactory();
    private readonly IUnitOfWorkManage _unitOfWorkManage;
    private readonly IStockInfoRepository _stockInfoRepository;
    private readonly IStockInfoDetailRepository _stockInfoDetailRepository;
    private readonly IDt_Task_HtyRepository _task_HtyRepository;
    private readonly IMapper _mapper;
    private readonly ILocationInfoRepository _locationRepository;
    private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
    private readonly IBoxingInfoRepository _boxingInfoRepository; //组盘
    private readonly IDt_AreaInfoRepository _areaInfoRepository; //区域
    private readonly IDt_StationManagerRepository _stationManagerRepository;
    private readonly ISys_ConfigService _configService;
    private readonly IDt_WareAreaInfoRepository _wareAreaInfoRepository;

    public Dt_TaskService(IDt_TaskRepository BaseDal,
                                IUnitOfWorkManage unitOfWorkManage,
                                IStockInfoRepository stockInfoRepository,
                                IDt_Task_HtyRepository task_HtyRepository,
                                IMapper mapper,
                                ILocationInfoRepository locationRepository,
                                ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
                                IBoxingInfoRepository boxingInfoRepository,
                                IDt_AreaInfoRepository areaInfoRepository,
                                IStockInfoDetailRepository stockInfoDetailRepository,
                                IDt_StationManagerRepository stationManagerRepository,
                                ISys_ConfigService configService,
                                IDt_WareAreaInfoRepository wareAreaInfoRepository) : base(BaseDal)
    {
        _unitOfWorkManage = unitOfWorkManage;
        _stockInfoRepository = stockInfoRepository;
        _task_HtyRepository = task_HtyRepository;
        _mapper = mapper;
        _locationRepository = locationRepository;
        _locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
        _boxingInfoRepository = boxingInfoRepository;
        _areaInfoRepository = areaInfoRepository;
        _stockInfoDetailRepository = stockInfoDetailRepository;
        _stationManagerRepository = stationManagerRepository;
        _configService = configService;
        _wareAreaInfoRepository = wareAreaInfoRepository;
    }

    #region 外部接口方法

    #region 出库任务完成

    public async Task<WebResponseContent> CompleteOutboundTaskAsync(Dt_Task task, DtStockInfo stock)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            (var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
            // 事务处理
            _unitOfWorkManage.BeginTran();
            checked
            {
                await UpdateLocationAsync(loc);
                BaseDal.DeleteAndMoveIntoHty(tas, App.User.UserName != null ? OperateTypeEnum.人工完成 : OperateTypeEnum.自动完成);
                _stockInfoRepository.DeleteAndMoveIntoHty(stock, App.User.UserName != null ? OperateTypeEnum.人工完成 : OperateTypeEnum.自动完成);
            }
            _unitOfWorkManage.CommitTran();

            return content.OK("任务完成成功");
        }
        catch (Exception ex)
        {
            _unitOfWorkManage.RollbackTran();
            task.ErrorMessage = ex.Message;
            await BaseDal.UpdateDataAsync(task);
            return content.Error(ex.Message);
        }
    }

    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(DtStockInfo stock, Dt_Task task)
    {
        var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
        int lastStatus = location.LocationStatus;
        location.LocationStatus = (int)LocationEnum.Free;
        task.TaskState = (int)TaskOutStatusEnum.OutFinish;

        _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticOutbound, task.TaskNum);

        LogFactory.GetLog("任务完成").Info(true, "更新库存状态与任务状态");
        return (location, task);
    }

    #endregion 出库任务完成 

    #region 入库任务完成

    /// <summary>
    /// 完成入库任务
    /// </summary>
    /// <param name="task">任务数据合集</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteInboundTaskAsync(Dt_Task task)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var boxinfo = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);

            if (boxinfo == null)
            {
                return content.Error("未找到组盘数据");
            }

            var stock = CreateStock(boxinfo, task);

            var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
            int lastStatus = location.LocationStatus;
            
            location.LocationStatus = (int)LocationEnum.InStock;

            _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticInbound, task.TaskNum);

            task.TaskState = (int)TaskInStatusEnum.InFinish;

            _unitOfWorkManage.BeginTran();

            checked
            {
                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserName != null ? OperateTypeEnum.人工完成 : OperateTypeEnum.自动完成);
                await _stockInfoRepository.AddDataNavAsync(stock);
                await _locationRepository.UpdateDataAsync(location); 
            }

            _unitOfWorkManage.CommitTran();
            content.OK("入库完成");
        }
        catch (Exception ex)
        {
            _unitOfWorkManage.RollbackTran();
            task.ErrorMessage = ex.Message;
            await BaseDal.UpdateDataAsync(task);
            return content.Error(ex.Message);
        }
        return content;
    }

    public DtStockInfo CreateStock(DtBoxingInfo boxingInfo,Dt_Task task)
    {
        return new DtStockInfo()
        {
            PalletCode = task.PalletCode,
            LocationCode = task.TargetAddress,
            CreateDate = DateTime.Now,
            MaterielName = boxingInfo.MaterielName,
            OutboundTime = Convert.ToDateTime(DateTime.Now).AddHours(Convert.ToDouble(12)),
            LinedProcessFeedbackTime = DateTime.Now.ToString(),
            SpecialParameterDuration = 12.ToString(),
            Creater = "System",
            IsFull = boxingInfo.IsFull,
            StockStatus = (int)StockStateEmun.已入库
        };
    }
    #endregion 入库任务完成

    #region 任务完成

    /// <summary>
    /// 完成任务
    /// </summary>
    /// <param name="taskNum">任务编号</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteAsync(int taskNum)
    {
        // 初始化响应内容
        WebResponseContent content = new WebResponseContent();

        // 提取任务数据
        LogFactory.GetLog("任务完成").InfoFormat(true, "提取任务数据", $"任务号：{taskNum}");

        // 验证任务是否存在0
        var task = await GetByTaskNum(taskNum);
        if (task == null)
        {
            return content.Error("任务不存在");
        }
        LogFactory.GetLog("任务完成").InfoFormat(true, "验证任务是否存在", JsonConvert.SerializeObject(task));


        // 验证库存是否存在
        var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);

        if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
        {
            return await CompleteOutboundTaskAsync(task, stock);
        }
        else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
        {
            return await CompleteInboundTaskAsync(task);
        }
        else
        {
            return content.Error("未找到任务类型");
        }
    }
    #endregion 任务完成

    #region 取消任务
    public WebResponseContent TaskCancel(int taskNum)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            
            return content = WebResponseContent.Instance.Error("未找到任务类型对应业务处理逻辑");
        }
        catch (Exception ex)
        {
            _unitOfWorkManage.RollbackTran();
            return content = WebResponseContent.Instance.Error(ex.Message);
        }
    }

    #endregion

    #region 请求任务入库
    public async Task<WebResponseContent> RequestInboundTaskAsync(RequestTaskDto taskDto)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == taskDto.PalletCode);
            if (task != null)
            {
                return content.Error($"托盘【{taskDto.PalletCode}】存在任务");
            }

            var boxInfo = await _boxingInfoRepository.QueryFirstAsync(x => x.PalletCode == taskDto.PalletCode);
            if (boxInfo == null && taskDto.IsFull)
            {
                return content.Error("未找到托盘组盘信息");
            }
            var location = await GetEmptyLocation(taskDto.AreaId);

            if (location == null)
            {
                return content.Error("未找到空闲货位");
            }

            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = taskDto.PalletCode,
                SourceAddress = taskDto.Position,
                TargetAddress = location.LocationCode,
                CurrentAddress = taskDto.Position,
                NextAddress = location.LocationCode,
                TaskType = taskDto.IsFull ? (int)TaskInboundTypeEnum.Inbound : (int)TaskInboundTypeEnum.InTray,
                TaskState = (int)TaskInStatusEnum.InNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = location.RoadwayNo,
            };
            int lastStatus = location.LocationStatus;
            location.LocationStatus = (int)LocationEnum.Lock;
            _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticInbound, taskNew.TaskNum);
            BaseDal.AddData(taskNew);
            _locationRepository.UpdateData(location);
            var taskDTO = CreateTaskDTO(taskNew);
            return content.OK(data: taskDTO);
        }
        catch (Exception err)
        {
            return content.Error(err.Message);
        }
    }
    /// <summary>
    /// 直接请求入库任务（直接进入GW或CW流程，不进入缓存库流程）
    /// </summary>
    /// <param name="taskDto"></param>
    /// <returns></returns>
    public async Task<WebResponseContent> RequsetInToGWOrCW(RequestTaskDto request)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var stationManager = await _stationManagerRepository.QueryFirstAsync(x => x.stationChildCode == request.Position);
            if (stationManager == null)
            {
                return content.Error("未找到站台配置");
            }

            var nextStation = _stationManagerRepository.QueryFirst(x => x.stationChildCode == request.TargetStationManager);

            var task = await BaseDal.QueryFirstAsync(x => x.SourceAddress == request.Position || x.TargetAddress == request.TargetAddress);
            if (task != null)
            {
                return content.Error($"终点地址【{request.TargetAddress}】或起点地址【{request.Position}】存在任务");
            }
            var location = await _locationRepository.QueryFirstAsync(x => x.RoadwayNo == nextStation.stationChildCode && x.Remark == request.TargetAddress);
            if (location == null)
            {
                return content.Error($"未找到目标地址【{request.TargetStationManager}-{request.TargetAddress}】的货位信息");
            }
            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = "",
                SourceAddress = request.Position,
                TargetAddress = request.TargetStationManager,
                CurrentAddress = stationManager.stationLocation,
                NextAddress = location.LocationCode,
                TaskType = (int)TaskInboundTypeEnum.Inbound,
                TaskState = (int)TaskInStatusEnum.InNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = stationManager.Roadway,
                Creater = App.User.UserName != null ? App.User.UserName : "System",
                CreateDate = DateTime.Now,
            };

            BaseDal.AddData(taskNew);
            var taskDTO = CreateTaskDTO(taskNew);
            return content.OK(data: taskDTO);
        }
        catch (Exception ex)
        {
            return content.Error(ex.Message);
        }
    }

    public async Task<WebResponseContent> PDARequestInboundTaskAsync(RequestTaskDto taskDto)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == taskDto.PalletCode);
            if (task != null)
            {
                return content.Error($"托盘【{taskDto.PalletCode}】存在任务");
            }

            var boxInfo = await _boxingInfoRepository.QueryFirstAsync(x => x.PalletCode == taskDto.PalletCode);
            if (boxInfo == null && taskDto.IsFull)
            {
                return content.Error("未找到托盘组盘信息");
            }
            var location = await GetEmptyLocation(taskDto.AreaId);

            if (location == null)
            {
                return content.Error("未找到空闲货位");
            }

            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = taskDto.PalletCode,
                SourceAddress = taskDto.Position,
                TargetAddress = location.LocationCode,
                CurrentAddress = taskDto.Position,
                NextAddress = location.LocationCode,
                TaskType = taskDto.IsFull ? (int)TaskInboundTypeEnum.Inbound : (int)TaskInboundTypeEnum.InTray,
                TaskState = (int)TaskInStatusEnum.InNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = location.RoadwayNo,
            };
            int lastStatus = location.LocationStatus;
            location.LocationStatus = (int)LocationEnum.Lock;
            _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticInbound, taskNew.TaskNum);
            BaseDal.AddData(taskNew);
            _locationRepository.UpdateData(location);
            var taskDTO = CreateTaskDTO(taskNew);
            content = await SendWCSTask(taskDTO);
            return content;
        }
        catch (Exception err)
        {
            return content.Error(err.Message);
        }
    }

    #endregion 请求任务入库

    #region 更新任务状态


    /// <summary>
    /// 更新任务货位
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<WebResponseContent> UpdateTaskStatus(int taskNum, int taskState)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var task = await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);
            if (task == null)
                return content.Error("未找到任务");

            task.TaskState = taskState;
            var asb = await BaseDal.UpdateDataAsync(task);
            if (asb)
                content.OK();
            else
                content.Error();
        }
        catch (Exception ex)
        {
            content.Error(ex.Message);
        }
        return content;
    }

    #endregion

    #region 请求出库（实盘&空盘）
    /// <summary>
    /// 请求出库（实盘&空盘）
    /// </summary>
    /// <param name="palletCode"></param>
    /// <returns></returns>
    public async Task<WebResponseContent> RequestOutboundTaskAsync(RequestTaskDto taskDto)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var stationManager = await _stationManagerRepository.QueryFirstAsync(x => x.stationChildCode == taskDto.Position);
            if (stationManager == null)
            {
                return content.Error("未找到站台配置");
            }

            var task = await BaseDal.QueryFirstAsync(x => x.TargetAddress == taskDto.Position);
            if (task != null)
            {
                return content.Error($"终点地址【{taskDto.Position}】存在任务");
            }

            var stock = await _stockInfoRepository.QueryFirstAsync(x => x.MaterielName == stationManager.stationMaterialCode);

            if (stock == null)
            {
                return content.Error($"设备【{taskDto.Position}】物料编码【{stationManager.stationMaterialCode}】未找到库存数据");
            }

            var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == stock.LocationCode);
            if (location == null)
            {
                return content.Error($"设备【{taskDto.Position}】物料编码【{stationManager.stationMaterialCode}】未找到货位信息");
            }

            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = stock.PalletCode,
                SourceAddress = location.LocationCode,
                TargetAddress = taskDto.Position,
                CurrentAddress = location.LocationCode,
                NextAddress = stationManager.stationLocation,
                TaskType = taskDto.IsFull ? (int)TaskOutboundTypeEnum.Outbound : (int)TaskOutboundTypeEnum.OutTray,
                TaskState = (int)TaskOutStatusEnum.OutNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = location.RoadwayNo,
                Creater = App.User.UserName != null ? App.User.UserName : "System",
                CreateDate = DateTime.Now,
            };
            int lastStatus = location.LocationStatus;
            location.LocationStatus = (int)LocationEnum.InStockDisable;
            _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticInbound, taskNew.TaskNum);
            BaseDal.AddData(taskNew);
            _locationRepository.UpdateData(location);
            var taskDTO = CreateTaskDTO(taskNew);
            return content.OK(data: taskDTO);
        }
        catch (Exception ex)
        {
            return content.Error(ex.Message);
        }
    }


    public async Task<WebResponseContent> RequestInToOutTaskAsync(RequestTaskDto taskDto)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var stationManager = await _stationManagerRepository.QueryFirstAsync(x => x.stationChildCode == taskDto.Position);
            if (stationManager == null)
            {
                return content.Error("未找到站台配置");
            }

            var nextStation = _stationManagerRepository.QueryFirst(x => x.stationProcessCode == taskDto.TargetAddress);

            var task = await BaseDal.QueryFirstAsync(x => x.SourceAddress == taskDto.Position || x.TargetAddress == taskDto.TargetAddress);
            if (task != null)
            {
                return content.Error($"终点地址【{taskDto.TargetAddress}】或起点地址【{taskDto.Position}】存在任务");
            }

            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = "",
                SourceAddress = taskDto.Position,
                TargetAddress = taskDto.TargetAddress,
                CurrentAddress = stationManager.stationLocation,
                NextAddress = nextStation.stationLocation,
                TaskType = (int)TaskOutboundTypeEnum.InToOut,
                TaskState = (int)TaskOutStatusEnum.OutNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = stationManager.Roadway,
                Creater = App.User.UserName != null ? App.User.UserName : "System",
                CreateDate = DateTime.Now,
            };
            
            BaseDal.AddData(taskNew);
            var taskDTO = CreateTaskDTO(taskNew);
            return content.OK(data: taskDTO);
        }
        catch (Exception ex)
        {
            return content.Error(ex.Message);
        }
    }

    public async Task<WebResponseContent> PDARequestOutboundTaskAsync(RequestTaskDto taskDto)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var stock = await _stockInfoRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
            if (stock == null)
            {
                return content.Error("未找到库存信息");
            }

            var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == stock.PalletCode);
            if (task != null)
            {
                return content.Error($"托盘【{stock.PalletCode}】存在任务");
            }

            var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
            if (location == null)
            {
                return content.Error("未找到货位信息");
            }

            var taskNew = new Dt_Task
            {
                TaskNum = BaseDal.GetTaskNo().Result,
                PalletCode = stock.PalletCode,
                SourceAddress = taskDto.Position,
                TargetAddress = taskDto.TargetAddress,
                CurrentAddress = taskDto.Position,
                NextAddress = taskDto.TargetAddress,
                TaskType = taskDto.IsFull ? (int)TaskOutboundTypeEnum.Outbound : (int)TaskOutboundTypeEnum.OutTray,
                TaskState = (int)TaskOutStatusEnum.OutNew,
                Grade = 1,
                Dispatchertime = DateTime.Now,
                Roadway = location.RoadwayNo,
                Creater = App.User.UserName != null ? App.User.UserName : "System",
                CreateDate = DateTime.Now,
            };
            int lastStatus = location.LocationStatus;
            location.LocationStatus = (int)LocationEnum.InStockDisable;
            _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticInbound, taskNew.TaskNum);
            BaseDal.AddData(taskNew);
            _locationRepository.UpdateData(location);
            var taskDTO = CreateTaskDTO(taskNew);
            content = await SendWCSTask(taskDTO);
            return content;
        }
        catch (Exception ex)
        {
            return content.Error(ex.Message);
        }
    }
    #endregion 请求出库（实盘&空盘）

    #region 获取AGV任务号

    private static readonly Random _random = new Random();

    public static string GenerateUniqueId()
    {
        // 获取当前毫秒级时间戳
        long timestamp = DateTimeOffset.Now.ToUnixTimeMilliseconds();

        // 生成4位随机数（0000-9999）
        int randomNumber = _random.Next(0, 10000);
        string randomPart = randomNumber.ToString("D4"); // 补零到4位

        return $"{timestamp}{randomPart}";
    }
    #endregion

    #region 获取任务信息
    public WebResponseContent GetTaskInfo()
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            Expression<Func<Dt_Task, bool>> expression = x => true;
            if (!App.User.IsSuperAdmin)
            {
                expression = x => x.Creater == App.User.UserName;
            }
            var task = BaseDal.Db.Queryable<Dt_Task>().OrderByDescending(x => x.CreateDate).Take(100).Select(x => new Dt_Task { TaskNum = x.TaskNum, PalletCode = x.PalletCode, TaskType = x.TaskType, SourceAddress = x.SourceAddress, TargetAddress = x.TargetAddress }).ToList();
            content = WebResponseContent.Instance.OK(data: task);
        }
        catch (Exception ex)
        {
            content = WebResponseContent.Instance.Error(ex.Message);
        }
        return content;
    }
    #endregion

    #endregion 外部接口方法

    #region 调用WCS接口
    private string GetWCSIPAddress(string baseIp, string name)
    {
        var configz = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
        var wcsBasez = configz.Where(x => x.ConfigKey == baseIp).FirstOrDefault()?.ConfigValue;
        var address = configz.Where(x => x.ConfigKey == name).FirstOrDefault()?.ConfigValue;
        if (wcsBasez == null || address == null)
        {
            throw new InvalidOperationException("WMS IP 未配置");
        }
        return wcsBasez + address;
    }

    public async Task<WebResponseContent> SendWCSTask(WMSTaskDTO taskDTO)
    {
        WebResponseContent content = new WebResponseContent();
        var SendTask = GetWCSIPAddress(SysConfigConst.WCSIPAddress, SysConfigConst.ReceiveTask);
        // 发送请求并等待响应
        var result = await HttpHelper.PostAsync(SendTask, taskDTO.ToJsonString());

        content = JsonConvert.DeserializeObject<WebResponseContent>(result.ToString());

        return content;
    }
    #endregion

    #region 内部调用方法

    private WMSTaskDTO CreateTaskDTO(Dt_Task task)
    {
        return new WMSTaskDTO
        {
            TaskNum = task.TaskNum.Value,
            Grade = task.Grade.Value,
            PalletCode = task.PalletCode,
            RoadWay = task.Roadway,
            SourceAddress = task.SourceAddress,
            TargetAddress = task.TargetAddress,
            CurrentAddress = task.CurrentAddress,
            NextAddress = task.NextAddress,
            TaskState = task.TaskState,
            Id = 0,
            TaskType = task.TaskType,
        };
    }
    private List<WMSTaskDTO> CreateTaskDTO(List<Dt_Task> task)
    {
        List<WMSTaskDTO> taskNews = new List<WMSTaskDTO>();
        foreach (var item in task)
        {
            taskNews.Add(new WMSTaskDTO
            {
                TaskNum = item.TaskNum.Value,
                Grade = item.Grade.Value,
                PalletCode = item.PalletCode,
                RoadWay = item.Roadway,
                SourceAddress = item.SourceAddress,
                CurrentAddress = item.CurrentAddress,
                NextAddress = item.NextAddress, 
                TaskState = item.TaskState,
                Id = 0,
                TaskType = item.TaskType,
            });
        }

        return taskNews;
    }

    private async Task UpdateLocationAsync(DtLocationInfo info)
    {
        var isStockUpdated = await _locationRepository.UpdateDataAsync(info);
        if (!isStockUpdated)
        {
            throw new Exception("库位信息更新失败");
        }
    }

    public override WebResponseContent DeleteData(object[] key)
    {
        WebResponseContent content = new WebResponseContent();
        // 创建历史任务实例模型
        try
        {
            foreach (var item in key)
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == Convert.ToInt32(key));
                if (task == null)
                {
                    return content.Error("未找到任务信息!");
                }
                task.TaskState = task.TaskType > 199 ? (int)TaskInStatusEnum.InFinish : (int)TaskOutStatusEnum.OutFinish;

                BaseDal.DeleteAndMoveIntoHty(task, OperateTypeEnum.人工删除);
            }
            return content.OK("删除成功!");
        }
        catch (Exception ex)
        {
            return content.Error("删除任务异常：" + ex.Message);
        }
    }
    /// <summary>
    /// 根据任务号获取任务
    /// </summary>
    /// <param name="taskNum"></param>
    /// <returns></returns>
    public async Task<Dt_Task> GetByTaskNum(int taskNum)
    {
        return await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);
    }
    #endregion 内部调用方法

    #region private 内部方法

    #region 任务请求方法

    private static readonly SemaphoreSlim _semaphoreUpdate = new SemaphoreSlim(1, 1);
    /// <summary>
    /// 获取货位号
    /// </summary>
    /// <returns></returns>
    public async Task<DtLocationInfo> GetEmptyLocation(int area)
    {
        List<DtLocationInfo> locations = await _locationRepository.QueryDataAsync(x => x.AreaId == area && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1);
        if (locations.Count == 0)
        {
            return null;
        }
        return locations.OrderBy(x => x.Row).OrderBy(x => x.Column).ThenBy(x => x.Layer).FirstOrDefault();
    }


    #endregion 任务请求方法

    #endregion private 内部方法
}