百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
肖洋
2024-11-22 5b2265e68c0a493c52ea336f77f8dbcd7655d34a 
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs


@@ -1,6 +1,7 @@


using log4net.Core;


using Mapster;


using Masuit.Tools;


using Masuit.Tools.Models;


using WIDESEA_DTO.MOM;


using WIDESEA_DTO.WMS;


using WIDESEA_IStorageBasicRepository;


@@ -12,7 +13,7 @@




namespace WIDESEA_StorageOutTaskServices;




public class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService


public partial class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService


{


    private readonly LogFactory LogFactory = new LogFactory();


    private readonly IUnitOfWorkManage _unitOfWorkManage;


@@ -34,6 +35,7 @@


    private readonly IProcessApplyService _processApplyService; //工艺路线


    private readonly IDt_AreaInfoRepository _areaInfoRepository; //区域


    private readonly IAgingInOrOutInputService _agingInOrOutInputService; //静置\陈化


    private readonly IProductionRepository _productionRepository; //生产




    public Dt_TaskService(IDt_TaskRepository BaseDal,


                                IUnitOfWorkManage unitOfWorkManage,


@@ -54,7 +56,8 @@


                                IProcessApplyService processApplyService,


                                IDt_AreaInfoRepository areaInfoRepository,


                                IAgingInOrOutInputService agingInOrOutInputService,


                                IStockInfoDetailRepository stockInfoDetailRepository) : base(BaseDal)


                                IStockInfoDetailRepository stockInfoDetailRepository,


                                IProductionRepository productionRepository) : base(BaseDal)


    {


        _unitOfWorkManage = unitOfWorkManage;


        _outOrderRepository = outOrderRepository;


@@ -75,6 +78,7 @@


        _areaInfoRepository = areaInfoRepository;


        _agingInOrOutInputService = agingInOrOutInputService;


        _stockInfoDetailRepository = stockInfoDetailRepository;


        _productionRepository = productionRepository;


    }




    #region 外部接口方法


@@ -89,11 +93,11 @@


        {


            if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound)


            {


                var process = await SqlSugarHelper.Db.Queryable<Dt_EquipmentProcess>()


                    .FirstAsync(x => x.EquipmentName == task.Roadway);


                var info = JsonConvert.DeserializeObject<ResponseEqptRunDto>(process.ProcessValue);


                //var process = await SqlSugarHelper.Db.Queryable<Dt_EquipmentProcess>()


                //    .FirstAsync(x => x.EquipmentName == task.Roadway);


                //var info = JsonConvert.DeserializeObject<ResponseEqptRunDto>(process.ProcessValue);




                var agingOutputDto = MapToAgingOutputDto(stock, info);


                var agingOutputDto = MapToAgingOutputDto(stock);


                content = await _agingInOrOutInputService.GetOCVOutputAsync(agingOutputDto);


                ValidateResponse(content);


            }


@@ -119,30 +123,37 @@


        }


    }




    private AgingOutputDto MapToAgingOutputDto(DtStockInfo stock, ResponseEqptRunDto info)


    private AgingOutputDto MapToAgingOutputDto(DtStockInfo stock, ResponseEqptRunDto info = null)


    {


        // TODO Value值根据MOM下发的静置时间到当前时间的分钟数


        var area = _areaInfoRepository.QueryFirst(x => x.AreaCode == stock.AreaCode);


        if (area == null)


        {


            throw new Exception("未找到对应的库区信息");


        }


        return new AgingOutputDto


        {


            OpFlag = 1,


            Software = "WMS",


            EquipmentCode = "ECH001-B",


            Software = area.Spare3,


            EquipmentCode = area.Spare2,


            TrayBarcode = stock.PalletCode,


            SerialNos = stock.StockInfoDetails.Select(x => new SerialNoOutDto


            {


                SlotNo = x.OrderNo.ToInt32(),


                SerialNo = x.SerialNumber,


                SerialNoResult = true,


                ParameterInfo = info.ParameterInfo.Select(x => new ParameterInfo()


                {


                    LowerLomit = x.LowerControlLimit,


                    UpperLimit = x.UpperControlLimit,


                    ParameterResult = x.EquipmentAvailabilityFlag,


                    ParameterCode = x.ParameterCode,


                    ParameterDesc = x.Description,


                    TargetValue = x.TargetValue,


                    Value = (DateTime.Now - stock.CreateDate).TotalMinutes.ToString(),


                    DefectCode = x.UOMCode


                }).ToList()


                ParameterInfo = new List<ParameterInfo> { new ParameterInfo() { Value = (DateTime.Now - stock.CreateDate).TotalMinutes.ToString() } }


                //ParameterInfo = info.ParameterInfo.Select(y => new ParameterInfo()


                //{


                //    LowerLomit = y.LowerControlLimit,


                //    UpperLimit = y.UpperControlLimit,


                //    ParameterResult = y.EquipmentAvailabilityFlag,


                //    ParameterCode = y.ParameterCode,


                //    ParameterDesc = y.Description,


                //    TargetValue = y.TargetValue,


                //    Value = (DateTime.Parse(stock.LinedProcessFeedbackTime, null, System.Globalization.DateTimeStyles.RoundtripKind).ToLocalTime() - stock.CreateDate).TotalMinutes.ToString(),


                //    DefectCode = y.UOMCode


                //}).ToList()


            }).ToList()


        };


    }


@@ -159,7 +170,7 @@


    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(DtStockInfo stock, Dt_Task task)


    {


        var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress);


        var details = _stockInfoDetailRepository.QueryData(x => x.StockId == stock.Id);


        //var details = _stockInfoDetailRepository.QueryData(x => x.StockId == stock.Id);




        location.LocationStatus = (int)LocationEnum.Free;


        task.TaskState = (int)TaskOutStatusEnum.OutFinish;


@@ -284,6 +295,7 @@


            // 记录异常信息到控制台和日志


            Console.WriteLine(err.Message.ToString());


            LogFactory.GetLog("任务完成").Error(true, err);


            content.Error(err.Message);


        }


        return content;


    }


@@ -293,6 +305,8 @@


    /// </summary>


    private DtStockInfo CreateEmptyPalletStock(Dt_Task task, DtLocationInfo locationInf)


    {


        var loation = _locationRepository.QueryFirst(x => x.RoadwayNo == task.Roadway && x.LocationCode == task.TargetAddress);


        var area = _areaInfoRepository.QueryFirst(x => x.AreaID == loation.AreaId);


        return new DtStockInfo()


        {


            PalletCode = task.PalletCode,


@@ -300,13 +314,15 @@


            CreateDate = DateTime.Now,


            Creater = "system",


            IsFull = false,


            AreaCode = task.Roadway,


            AreaCode = area.AreaCode,


            LocationId = loation.Id,


            StockInfoDetails = new List<DtStockInfoDetail>()


            {


                new DtStockInfoDetail()


                {


                    MaterielCode = "空托盘",


                    Id = 0,


                    Status = (int)StockStateEmun.已入库


                }


            }


        };


@@ -317,7 +333,14 @@


    /// </summary>


    private DtStockInfo CreateFullPalletStock(Dt_Task task, DtLocationInfo locationInf, DtBoxingInfo boxing)


    {


        var loation = _locationRepository.QueryFirst(x => x.RoadwayNo == task.Roadway && x.LocationCode == task.TargetAddress);


        if (loation == null)


            throw new Exception("未找到对应位置信息");


        var area = _areaInfoRepository.QueryFirst(x => x.AreaID == loation.AreaId);


        if (area == null)


            throw new Exception("未找到对应区域信息");


        var boxDetail = boxing.BoxingInfoDetails.Adapt<List<DtStockInfoDetail>>();


        boxDetail.ForEach(x => { x.Status = (int)StockStateEmun.已入库; });


        var stock = new DtStockInfo()


        {


            PalletCode = task.PalletCode,


@@ -325,7 +348,8 @@


            CreateDate = DateTime.Now,


            Creater = "system",


            IsFull = boxing.IsFull,


            AreaCode = task.Roadway,


            AreaCode = area.AreaCode,


            LocationId = loation.Id,


            StockInfoDetails = boxDetail,


        };




@@ -337,12 +361,16 @@


                .ToList(),


            TrayBarcode = task.PalletCode,


            OpFlag = 1,


            EquipmentCode = "ECH001-B",


            Software = "WMS"


            EquipmentCode = area.Spare2,


            Software = area.Spare3


        };


        var result = _agingInOrOutInputService.GetOCVInputAsync(agingInputDto).Result;


        var respone = JsonConvert.DeserializeObject<ResponeAgingInputDto>(result.Data.ToString());


        stock.Remark = respone.LinedProcessFeedbackTime;


        stock.LinedProcessFeedbackTime = respone.LinedProcessFeedbackTime;


        stock.SpecialParameterDuration = respone.SpecialParameterDuration;


        //2024年11月16日：新增字段计算应出库时间


        stock.OutboundTime = Convert.ToDateTime(respone.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(respone.SpecialParameterDuration));


        stock.ProductionLine = respone.ProductionLine;




        // 记录日志


        LogFactory.GetLog("任务完成").InfoFormat(true, "入库任务完成", $"货位地址：{task.TargetAddress},修改后货位数据：{locationInf}");


@@ -434,12 +462,18 @@


                    return content.OK(data: taskDTO);


                }


            }




            var area = await _areaInfoRepository.QueryFirstAsync(x => x.Spare1.Contains(input.Position));


            if (area == null)


                return content.Error("改点位不在区域列表中存在");




            // 创建一个TrayCellsStatusDto对象，并赋值


            TrayCellsStatusDto trayCells = new TrayCellsStatusDto()


            {


                Software = "WMS",


                Software = area.Spare3,


                TrayBarcode = input.PalletCode,


                EquipmentCode = "ECH001-B"


                //EquipmentCode = "EQ_CWJZ01"


                EquipmentCode = area.Spare2


            };




            // 调用GetTrayCellStatusAsync方法，获取整盘电芯


@@ -452,7 +486,16 @@


            var result = JsonConvert.DeserializeObject<ResultTrayCellsStatus>(content.Data.ToString());


            if (result.SerialNos.Count <= 0)


                return content.Error(result.MOMMessage);




            // TODO 获取本地料框属性与整盘电芯属性获取的值进行对比，如果一致则继续，否则返回错误信息


            //var productions = await _productionRepository.QueryDataAsync(x => result.TrayBarcodePropertys.Select(x => x.TrayBarcodeProperty).ToList().Contains(x.TrayBarcodeProperty));


            //if (productions.Count <= 0)


            //    return content.Error("料框属性不存在");




            // 调用CreateBoxingInfo方法，创建组盘信息




            var boxing = await CreateBoxingInfo(result, input.PalletCode);


            if (boxing == null) return content.Error("组盘失败");




            // 调用GetProcessApplyAsync方法，获取工艺路线


            ProcessApplyDto process = await GetProcessApplyAsync(result);


@@ -460,11 +503,24 @@


            // 如果process为null，则返回content


            if (process == null) return content;




            // 调用GetProcessResponseAsync方法，获取工艺响应


            var processResponse = await GetProcessResponseAsync(process, input.Position);


            // 并赋值上位软件名称和设备编码


            process.Software = area.Spare3;


            process.EquipmentCode = area.Spare2;




            // 调用GetProcessApplyAsync方法，获取工艺申请




            // 调用_processApplyService.GetProcessApplyAsync方法，获取工艺申请


            content = await _processApplyService.GetProcessApplyAsync(process);




            // 如果状态为false，则返回null


            if (!content.Status) return content.Error("工艺申请失败");




            //// 调用GetProcessResponseAsync方法，获取工艺响应


            //var processResponse = await GetProcessResponseAsync(process, input.Position);




            List<string> strings = input.Position == "1088" ? new List<string>() { "CHSC01" } : new List<string>() { "JZSC01" };


            // 调用CreateNewTask方法，创建新任务


            content =  await CreateNewTask(input, processResponse);


            content = await CreateNewTask(input, strings);


            if (content.Status)


            {


                var isBox = await _boxingInfoRepository.AddDataNavAsync(boxing);


@@ -536,7 +592,11 @@


                return content.OK(data: task);


            }




            return await CreateNewTask(input, null, 1);


            // 获取目标地址


            List<string> strings = input.Position == "1016" ? new List<string>() { "CHSC01" } : new List<string>() { "JZSC01" };




            return await CreateNewTask(input, strings, 1);


            //return await CreateNewTask(input, null, 1);


        }


        catch (Exception)


        {


@@ -564,7 +624,7 @@


                SerialNumber = serialNoObj.SerialNo,


                OrderNo = serialNoObj.PositionNo.ToString(),


                Status = serialNoObj.SerialNoStatus,


                MaterielCode = serialNoObj.BindCode,


                MaterielCode = result.BindCode,


                Remark = result.TrayBarcodePropertys.ToJsonString(),


            }).ToList()


        };


@@ -576,8 +636,6 @@


        // 创建一个ProcessApplyDto对象，并赋值


        return new ProcessApplyDto()


        {


            EquipmentCode = "ECH001-B",


            Software = "WMS",


            //WipOrderNo = result.BindCode,


            SerialNos = content.SerialNos.Select(item => new SerialNos


            {


@@ -637,12 +695,20 @@


        {


            // 根据托盘类型查询库存信息


            DtStockInfo stockInfo = tag == (int)TaskOutboundTypeEnum.Outbound


                ? QueryStockInfoForRealTray(areaCode, roadways)


                : QueryStockInfoForEmptyTray(areaCode, roadways);


                ? QueryStockInfoForRealTrayAsync(areaCode, roadways).Result


                : QueryStockInfoForEmptyTrayAsync(areaCode, roadways).Result;




            if (stockInfo == null)


            {


                return content.Error("库存信息不存在");


            }




            // 新增重复任务校验


            var hasTask = BaseDal.QueryFirst(x => x.PalletCode == stockInfo.PalletCode);


            if (hasTask != null)


            {


                WMSTaskDTO taskDTO1 = CreateTaskDTO(hasTask);


                return content.OK("已存在空盘出库任务", data: taskDTO1);


            }




            // 创建新任务实例


@@ -677,25 +743,43 @@


    /// <summary>


    /// 查询实盘库存信息


    /// </summary>


    private DtStockInfo QueryStockInfoForRealTray(string areaCode, List<string> roadways)


    private async Task<DtStockInfo> QueryStockInfoForRealTrayAsync(string areaCode, List<string> roadways)


    {


        return _stockInfoRepository.Db.Queryable<DtStockInfo>().Where(x => x.AreaCode == areaCode && Convert.ToDateTime(x.Remark) < DateTime.Now && x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && roadways.Contains(x.LocationInfo.RoadwayNo))


                                   .Includes(x => x.LocationInfo)


                                   .Includes(x => x.StockInfoDetails)


                                   .OrderBy(x => x.CreateDate)


                                   .First();


        var area = await _areaInfoRepository.QueryFirstAsync(x => x.AreaCode == areaCode);




        var result = await _stockInfoRepository.Db.Queryable<DtStockInfo>()


            .Includes(x => x.LocationInfo) // 预加载LocationInfo


            .Includes(x => x.StockInfoDetails) // 预加载StockInfoDetails


            .Where(x => x.AreaCode == areaCode && x.OutboundTime < DateTime.Now && x.IsFull == true) // 过滤条件


            .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID) // 过滤条件


            .OrderBy(x => x.OutboundTime) // 排序


            .FirstAsync(); // 获取第一个元素




        //var firstOrDefault = result.FirstOrDefault(x => roadways.Contains(x.LocationInfo.RoadwayNo)); // 查找第一个匹配的元素


        //var firstOrDefault = result[0]; // 查找第一个匹配的元素


        //return firstOrDefault;


        return result;


    }




    /// <summary>


    /// 查询空盘库存信息


    /// </summary>


    private DtStockInfo QueryStockInfoForEmptyTray(string areaCode, List<string> roadways)


    private async Task<DtStockInfo> QueryStockInfoForEmptyTrayAsync(string areaCode, List<string> roadways)


    {


        return _stockInfoRepository.Db.Queryable<DtStockInfo>().Where(x => x.AreaCode == areaCode && x.StockInfoDetails.Any(z => z.MaterielCode == "空托盘") && roadways.Contains(x.LocationInfo.RoadwayNo))


                                   .Includes(x => x.LocationInfo)


                                   .Includes(x => x.StockInfoDetails)


                                   .OrderBy(x => x.CreateDate)


                                   .First();


        var area = await _areaInfoRepository.QueryFirstAsync(x => x.AreaCode == areaCode);




        var result = await _stockInfoRepository.Db.Queryable<DtStockInfo>()


            .Includes(x => x.LocationInfo) // 预加载LocationInfo


            .Includes(x => x.StockInfoDetails) // 预加载StockInfoDetails


            .Where(x => x.AreaCode == areaCode && x.IsFull == false)


            .Where(x => x.StockInfoDetails.Any(y => y.MaterielCode == "空托盘"))


            .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID) // 过滤条件


            .OrderBy(x => x.CreateDate) // 排序


            .FirstAsync(); // 转换为列表




        //var firstOrDefault = result[0]; // 查找第一个匹配的元素


        //return firstOrDefault;


        return result;


    }




    /// <summary>


@@ -760,7 +844,7 @@


            if (task == null)


                return content.Error("未找到任务");




            if (taskState == (int)TaskOutStatusEnum.Line_OutFinish)


            if (taskState == (int)TaskOutStatusEnum.Line_OutFinish || taskState == (int)TaskInStatusEnum.SC_InFinish)


            {


                var taskHty = CreateHistoricalTask(task);


                await _unitOfWorkManage.UseTranAsync(async () =>


@@ -921,7 +1005,7 @@


    /// <returns>是否更新成功</returns>


    public async Task<bool> Update(Dt_Task model)


    {


        return await BaseDal.Update(model);


        return await BaseDal.UpdateDataAsync(model);


    }




    /// <summary>


@@ -931,7 +1015,7 @@


    /// <returns>是否更新成功</returns>


    public async Task<bool> Update(List<Dt_Task> models)


    {


        return await BaseDal.Update(models);


        return await BaseDal.UpdateDataAsync(models);


    }




    /// <summary>


@@ -951,7 +1035,7 @@


    /// <returns></returns>


    public async Task<Dt_Task> GetByLocation(string locationID)


    {


        return await Db.Queryable<Dt_Task>().Where(x => x.SourceAddress == locationID).FirstAsync();


        return await BaseDal.QueryFirstAsync(x => x.SourceAddress == locationID);


    }




    /// <summary>


@@ -961,7 +1045,7 @@


    /// <returns></returns>


    public async Task<Dt_Task> GetByTaskNum(int taskNum)


    {


        return await Db.Queryable<Dt_Task>().Where(x => x.TaskNum == taskNum).FirstAsync();


        return await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);


    }




    #endregion 内部调用方法


@@ -1051,12 +1135,13 @@


    /// <param name="taskHty">历史任务对象</param>


    /// <param name="taskId">任务ID</param>


    /// <returns></returns>


    private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId)


    private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId, DtBoxingInfo boxingInfo = null)


    {


        _unitOfWorkManage.BeginTran();


        try


        {


            var isUpdateStock = true;


            var isDeleteBoxing = true;


            if (taskHty.TaskType == (int)TaskTypeEnum.Outbound)


            {


                // 更新库存


@@ -1066,6 +1151,9 @@


            {


                // 添加库存


                isUpdateStock = await _stockInfoRepository.AddDataNavAsync(stock);


                isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxingInfo.Id)


                   .Include(x => x.BoxingInfoDetails)


                   .ExecuteCommandAsync();


            }






@@ -1080,7 +1168,7 @@


            var isTaskDelete = await Delete(taskId);




            // 提交或回滚事务


            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc)


            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteBoxing)


            {


                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改移库前货位状态：{isUpdateLoc}");


                _unitOfWorkManage.CommitTran();


@@ -1095,7 +1183,7 @@


        }


        catch (Exception err)


        {


            LogFactory.GetLog("任务完成").InfoFormat(true, $"移库任务完成,系统异常，异常信息：{err.Message}", "无参数");


            LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");


            _unitOfWorkManage.RollbackTran();


            throw; // 抛出异常以便外部捕获


        }


@@ -1111,46 +1199,140 @@


    /// <param name="task">任务实例</param>


    /// <param name="content">响应内容</param>


    /// <returns></returns>


    //private async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input, Dt_Task task)


    //{


    //    // 创建WebResponseContent对象


    //    WebResponseContent content = new WebResponseContent();


    //    // 定义变量


    //    string toAddress;


    //    int taskState;


    //    string original = task.CurrentAddress;


    //    DtLocationInfo location = new DtLocationInfo();


    //    int beforeStatus = 0;




    //    // 处理入库任务


    //    location = await GetLocationDistributeAsync(task.Roadway);


    //    toAddress = location.LocationCode;


    //    taskState = (int)TaskInStatusEnum.Line_InFinish;


    //    beforeStatus = location.LocationStatus;




    //    // 更新货位信息


    //    location.LocationStatus = (int)LocationEnum.Lock;




    //    // 更新任务信息


    //    task.CurrentAddress = input.Position;


    //    task.TargetAddress = toAddress;


    //    task.NextAddress = toAddress;


    //    task.TaskState = taskState;




    //    // 开始事务


    //    _unitOfWorkManage.BeginTran();


    //    // 定义变量


    //    bool isUpdateLo = true;


    //    bool isUpdateChange = true;




    //    // 尝试更新任务


    //    bool isResult = await BaseDal.UpdateDataAsync(task);


    //    bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, original, input.Position, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));




    //    // 创建LocationChangeRecordDto对象


    //    LocationChangeRecordDto changeRecordDto = new LocationChangeRecordDto()


    //    {


    //        // 设置变量


    //        AfterStatus = location.LocationStatus,


    //        BeforeStatus = beforeStatus,


    //        TaskNum = task.TaskNum.Value,


    //        LocationId = location.Id,


    //        LocationCode = location.LocationCode,


    //        ChangeType = (int)StatusChangeTypeEnum.AutomaticStorage,


    //    };


    //    // 更新位置状态


    //    isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);


    //    isUpdateLo = await _locationRepository.UpdateDataAsync(location);




    //    if (isResult && isUpdateLo && isTaskDetail)


    //    {


    //        // 提交事务


    //        _unitOfWorkManage.CommitTran();


    //        content.OK(data: task);


    //    }


    //    else


    //    {


    //        // 回滚事务


    //        _unitOfWorkManage.RollbackTran();


    //        content.Error("更新任务失败");


    //    }


    //    return content;


    //}




    // 更新任务货位




    private async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input, Dt_Task task)


    {


        // 创建WebResponseContent对象


        WebResponseContent content = new WebResponseContent();


        // 定义变量


        string toAddress;


        int taskState;


        string original = task.CurrentAddress;


        DtLocationInfo location = new DtLocationInfo();


        int beforeStatus = 0;


        if (task == null)


        {


            return new WebResponseContent().Error("任务对象为空");


        }




        // 处理入库任务


        location = await GetLocationDistributeAsync(task.Roadway);


        toAddress = location.LocationCode;


        taskState = (int)TaskInStatusEnum.Line_InFinish;


        beforeStatus = location.LocationStatus;


        try


        {


            // 创建WebResponseContent对象


            var content = new WebResponseContent();




        // 更新货位信息


        location.LocationStatus = (int)LocationEnum.Lock;


            // 获取目标地址和更新任务状态


            var location = await GetLocationDistributeAsync(task.Roadway);


            if (location == null)


            {


                return content.Error("无法获取货位信息");


            }




        // 更新任务信息


            string toAddress = location.LocationCode;


            int taskState = (int)TaskInStatusEnum.Line_InFinish;


            int beforeStatus = location.LocationStatus;




            // 更新货位信息


            location.LocationStatus = (int)LocationEnum.Lock;




            // 更新任务信息


            MapTaskProperties(task, input, toAddress, taskState);




            // 开始事务


            var isResult = await UpdateTaskAsync(task, location, beforeStatus);


            if (!isResult)


            {


                _unitOfWorkManage.RollbackTran();


                return content.Error("更新任务失败");


            }




            // 提交事务


            _unitOfWorkManage.CommitTran();


            return content.OK(data: task);


        }


        catch (Exception ex)


        {


            // 回滚事务


            _unitOfWorkManage.RollbackTran();


            // 这里可以添加日志记录


            return new WebResponseContent().Error($"更新任务时发生错误: {ex.Message}");


        }


    }




    private void MapTaskProperties(Dt_Task task, RequestTaskDto input, string toAddress, int taskState)


    {


        task.CurrentAddress = input.Position;


        task.TargetAddress = toAddress;


        task.NextAddress = toAddress;


        task.TaskState = taskState;


    }




        // 开始事务


        _unitOfWorkManage.BeginTran();


        // 定义变量


        bool isUpdateLo = true;


        bool isUpdateChange = true;




        // 尝试更新任务


    // 修改任务


    private async Task<bool> UpdateTaskAsync(Dt_Task task, DtLocationInfo location, int beforeStatus)


    {


        bool isResult = await BaseDal.UpdateDataAsync(task);


        bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, original, input.Position, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));


        bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, task.CurrentAddress, task.TargetAddress, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));




        // 创建LocationChangeRecordDto对象


        LocationChangeRecordDto changeRecordDto = new LocationChangeRecordDto()


        {


            // 设置变量


            AfterStatus = location.LocationStatus,


            BeforeStatus = beforeStatus,


            TaskNum = task.TaskNum.Value,


@@ -1158,23 +1340,11 @@


            LocationCode = location.LocationCode,


            ChangeType = (int)StatusChangeTypeEnum.AutomaticStorage,


        };


        // 更新位置状态


        isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);


        isUpdateLo = await _locationRepository.UpdateDataAsync(location);




        if (isResult && isUpdateLo && isTaskDetail)


        {


            // 提交事务


            _unitOfWorkManage.CommitTran();


            content.OK(data: task);


        }


        else


        {


            // 回滚事务


            _unitOfWorkManage.RollbackTran();


            content.Error("更新任务失败");


        }


        return content;


        bool isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);


        bool isUpdateLo = await _locationRepository.UpdateDataAsync(location);




        return isResult && isUpdateLo && isTaskDetail;


    }




    /// <summary>


@@ -1184,20 +1354,13 @@


    /// <param name="areaId">区域ID</param>


    /// <param name="content">响应内容</param>


    /// <returns></returns>


    private async Task<WebResponseContent> CreateNewTask(RequestTaskDto input, List<Dt_EquipmentProcess> process = null, int flag = 0)


    private async Task<WebResponseContent> CreateNewTask(RequestTaskDto input, List<string> process = null, int flag = 0)


    {


        WebResponseContent content = new WebResponseContent();


        List<string> strings = new List<string>();


        if (process != null)


        {


            strings = process.Select(x => x.EquipmentName).ToList();


        }


        else


        {


            strings = input.Position.Split(',').ToList();


        }




        // 获取目标地址


        string ToAddress = await GetRoadWayAsync(strings);


        //string ToAddress = await GetRoadWayAsync(process);


        string ToAddress = await GetRoadWayAsync(input, process);




        // 创建新任务实例


        var task = new Dt_Task


@@ -1253,16 +1416,25 @@


    /// <summary>


    /// 查找货位


    /// </summary>


    /// <param name="areaId">区域主键</param>


    /// <param name="IsFull">区域主键</param>


    /// <param name="roadWay">巷道</param>


    /// <returns></returns>


    public async Task<DtLocationInfo> GetLocationDistributeAsync(string roadWay)


    public async Task<DtLocationInfo> GetLocationDistributeAsync(string roadWay, bool IsFull = true)


    {


        #region 获取货位




        try


        {


            var locations = await _locationRepository.QueryDataAsync(x => x.LocationStatus == (int)LocationEnum.Free && x.RoadwayNo == roadWay);


            List<DtLocationInfo> locations;


            if (IsFull)


            {


                locations = await _locationRepository.QueryDataAsync(x => x.LocationStatus == (int)LocationEnum.Free && x.RoadwayNo == roadWay);


            }


            else


            {


                locations = await _locationRepository.QueryDataAsync(x => x.LocationStatus == (int)LocationEnum.Free && x.RoadwayNo == roadWay /*&& x.LocationType ==*/);


            }




            if (locations == null)


            {


                return null;


@@ -1287,10 +1459,10 @@


    /// <param name="Direction">方向</param>


    /// <param name="area">关系区域</param>


    /// <returns></returns>


    public async Task<string> GetRoadWayAsync(List<string> process)


    public async Task<string> GetRoadWayAsync(RequestTaskDto input, List<string> process)


    {


        var minGroup = _locationRepository.QueryData(x => process.Contains(x.RoadwayNo) && x.LocationStatus == (int)LocationEnum.Free)


            .GroupBy(x => x.RoadwayNo)


             .GroupBy(x => x.RoadwayNo)


             .OrderByDescending(g => g.Count()) // 根据每个组的元素数量排序


             .First(); // 取出数量最多的组