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


@@ -1,20 +1,11 @@





using AngleSharp.Io;


using log4net.Core;


using Mapster;


using Mapster;


using Masuit.Tools;


using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;


using SixLabors.Fonts.Tables.AdvancedTypographic;


using WIDESEA_Core.Const;


using WIDESEA_DTO.MOM;


using WIDESEA_DTO.WMS;


using WIDESEA_IServices;


using WIDESEA_IStoragIntegrationServices;


using WIDESEA_Model.Models;


using WIDESEA_Services;


using WIDESEA_StorageBasicRepository;


using WIDESEAWCS_BasicInfoRepository;


using WIDESEAWCS_Model.Models;




namespace WIDESEA_StorageTaskServices;




@@ -75,7 +66,6 @@


    #region 外部接口方法




    #region 出库任务完成






    public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task, DtStockInfo stock)


    {


@@ -184,7 +174,6 @@




    private void ValidateResponse(WebResponseContent content)


    {




    }




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


@@ -304,7 +293,6 @@


                // 执行数据库事务


                await _unitOfWorkManage.UseTranAsync(async () =>


                {




                    // 添加历史任务


                    var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHtyNG) > 0;




@@ -328,7 +316,6 @@




            // 根据是否有组盘信息创建库存实例模型


            DtStockInfo stock = boxing == null ? CreateEmptyPalletStock(task, locationInf) : CreateFullPalletStock(task, locationInf, boxing);






            // 执行数据库事务


            bool isResult = await ExecuteTransaction(stock, taskHty, locationInf, task.TaskId, boxing);


@@ -432,7 +419,6 @@


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


        }






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


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


        var stock = new DtStockInfo()


@@ -461,6 +447,10 @@




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


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


        if (respone.ProductionLine == null || respone.ParameterInfos == null || respone.SpecialParameterDuration.IsNullOrEmpty())


        {


            throw new Exception("MOM数据返回错误");


        }


        stock.LinedProcessFeedbackTime = respone.LinedProcessFeedbackTime;


        stock.SpecialParameterDuration = respone.SpecialParameterDuration;


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


@@ -524,6 +514,7 @@




            case (int)TaskRelocationTypeEnum.Relocation:


                return await CompleteTransferTaskAsync(task, stock);




            default:


                return content.Error("任务类型不存在");


        }


@@ -534,6 +525,7 @@


    #region 请求任务入库




    #region




    /// <summary>


    /// 请求任务巷道


    /// </summary>


@@ -568,7 +560,6 @@


                    return content.OK(data: taskDTO);


                }


            }






            var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == input.PalletCode && x.IsFull);


            if (stock != null)


@@ -721,18 +712,23 @@


                    case "CH01":


                        areaIn = "CH001";


                        break;




                    case "JZ01":


                        areaIn = "JZ001";


                        break;




                    case "GW01":


                        areaIn = "GWSC1";


                        break;




                    case "CW01":


                        areaIn = "CWSC1";


                        break;




                    case "CW02":


                        areaIn = "CWSC2";


                        break;




                    default:


                        break;


                }


@@ -764,7 +760,7 @@


        return content;


    }




    #endregion


    #endregion 请求任务入库




    public async Task<WebResponseContent> RequestTaskAsync(RequestTaskDto input)


    {


@@ -838,7 +834,6 @@


                return await HandleErrorCells(input, area, serialNosError);


            }






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


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




@@ -853,6 +848,7 @@




        return content;


    }




    /// <summary>


    /// 更新任务货位


    /// </summary>


@@ -868,11 +864,9 @@


                return content.Error($"暂未找到【{input.PalletCode}】的任务");




            return content = await UpdateExistingTask(input, task);




        }


        catch (Exception err)


        {




            throw;


        }


    }


@@ -887,7 +881,6 @@


        WebResponseContent content = new WebResponseContent();


        try


        {




            // 调用BaseDal.QueryFirstAsync方法，查询任务


            var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == input.PalletCode);


            if (task != null && task.TaskState == (int)TaskInStatusEnum.InNew)


@@ -908,7 +901,6 @@


                return content.OK(data: task);


            }






            var stationManagers = _stationManagerRepository.QueryData(x => x.stationType == 6 && x.stationChildCode == input.Position).FirstOrDefault();


            if (stationManagers == null)


            {


@@ -923,7 +915,6 @@


        }


        catch (Exception)


        {




            throw;


        }


    }


@@ -968,7 +959,7 @@


        };


    }




    #endregion 请求任务入库


    #endregion 外部接口方法




    #region 请求出库（实盘&空盘）




@@ -980,15 +971,15 @@


    /// <param name="areaCode">区域编码</param>


    /// <param name="roadways">巷道编码集合</param>


    /// <returns>返回结果集</returns>


    public async Task<WebResponseContent> RequestTrayOutTaskAsync(string position, int tag, string areaCode, List<string> roadways)


    public async Task<WebResponseContent> RequestTrayOutTaskAsync(string position, int tag, string areaCode, string productionLine)


    {


        WebResponseContent content = new WebResponseContent();


        try


        {


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


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


                ? QueryStockInfoForRealTrayAsync(areaCode, roadways).Result


                : QueryStockInfoForEmptyTrayAsync(areaCode, roadways).Result;


                ? QueryStockInfoForRealTrayAsync(areaCode, productionLine).Result


                : QueryStockInfoForEmptyTrayAsync(areaCode).Result;




            if (stockInfo == null)


            {


@@ -1035,7 +1026,7 @@


    /// <summary>


    /// 查询实盘库存信息


    /// </summary>


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


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


    {


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




@@ -1043,6 +1034,7 @@


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


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


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


            .WhereIF(!productionLine.IsNullOrEmpty(), x => x.ProductionLine == productionLine)


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


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


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


@@ -1056,7 +1048,7 @@


    /// <summary>


    /// 查询空盘库存信息


    /// </summary>


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


    private async Task<DtStockInfo> QueryStockInfoForEmptyTrayAsync(string areaCode)


    {


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




@@ -1119,7 +1111,7 @@


        };


    }




    #endregion 请求出库


    #endregion 请求出库（实盘&空盘）




    #region 任务状态更改




@@ -1169,7 +1161,7 @@


        return content;


    }




    #endregion


    #endregion 任务状态更改




    #region 出库解盘




@@ -1196,7 +1188,7 @@


        return content;


    }




    #endregion


    #endregion 出库解盘




    #region 指定任务出库




@@ -1262,6 +1254,7 @@




        return content;


    }




    private string GetWCSIpReceiveTask()


    {


        var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);


@@ -1274,7 +1267,7 @@


        return wmsBase + ipAddress;


    }




    #endregion


    #endregion 指定任务出库




    #endregion 外部接口方法




@@ -1495,7 +1488,6 @@


                                            .Include(x => x.BoxingInfoDetails)


                                            .ExecuteCommandAsync();


                }




            }




            var stocks = _stockInfoRepository.QueryData(x => x.AreaCode == stock.AreaCode && x.ProductionLine == stock.ProductionLine && x.SpecialParameterDuration != stock.SpecialParameterDuration);


@@ -1607,7 +1599,6 @@


                _unitOfWorkManage.CommitTran();


                return content.OK(data: task);


            }




        }


        catch (Exception ex)


        {