百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
肖洋
2024-12-17 dcacc1fbcb885a958d6a9715c360ebb4aeac0894 
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs


@@ -1,31 +1,14 @@





using log4net.Core;


using Mapster;


using Masuit.Tools;


using Masuit.Tools.Models;


using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;


using SixLabors.Fonts.Tables.AdvancedTypographic;


using System.Diagnostics;


using WIDESEA_Common;


using Masuit.Tools;


using WIDESEA_Core.Const;


using WIDESEA_DTO;


using WIDESEA_DTO.MOM;


using WIDESEA_DTO.WMS;


using WIDESEA_IStorageBasicRepository;


using WIDESEA_IStoragIntegrationServices;


using WIDESEA_Model.Models;


using WIDESEA_StorageBasicRepository;


using WIDESEA_StorageTaskRepository;


using WIDESEA_StoragIntegrationServices;


using WIDESEAWCS_Model.Models;




namespace WIDESEA_StorageTaskServices;




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


{




    #region 出库任务完成






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


    //{


@@ -357,6 +340,7 @@


    #endregion 任务完成




    #region 请求任务入库




    /// <summary>


    /// 请求入库


    /// </summary>


@@ -390,7 +374,6 @@


                    return content.OK(data: taskDTO);


                }


            }




            


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


            content = await CreateNewTask(input);


@@ -450,8 +433,6 @@


                TaskType = task.TaskType,


            };


            content.OK(data: taskDTO);




           


        }


        else


            content.Error("添加任务失败");


@@ -487,10 +468,10 @@


    }




    #region 直接出库任务




    private async Task<Dt_Task> CreateInToOutTaskAsync(RequestTaskDto input, Dt_StationManager stationManager)


    {


        //if (stationManager.stationType != 5) throw new Exception("错误的调取");






        input.EquiCodeMOM = "24MEJQ11-1006-1";




@@ -590,10 +571,11 @@




        return task;


    }


    #endregion




    #endregion 直接出库任务




    #region 入库任务




    private async Task<Dt_Task> CreateInTaskAsync(RequestTaskDto input, Dt_StationManager stationManager)


    {


        if (stationManager.stationType != 1 && stationManager.stationType != 6) throw new Exception("错误的调取");


@@ -704,9 +686,11 @@




        return task;


    }


    #endregion




    #endregion 入库任务




    #region 库位分配




    /// <summary>


    /// 


    /// </summary>


@@ -715,6 +699,7 @@


    private async Task<DtLocationInfo> RequestLocation(RequestTaskDto requestTask, bool isCheckRequest = false)


    {


        #region 获取货位




        try


        {


            List<DtLocationInfo> locations;


@@ -739,9 +724,11 @@


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


            return null;


        }




        #endregion 获取货位


    }


    #endregion




    #endregion 库位分配




    // 获取工艺申请


    private async Task<ProcessApplyDto> GetProcessApplyAsync(RequestTaskDto input, ResultTrayCellsStatus content)


@@ -759,7 +746,7 @@


        };


    }




    #endregion 请求空框出库


    #endregion 请求任务入库




    public async Task<Dt_Task> CreateEmptyOutTaskAsync(RequestTaskDto input, Dt_StationManager stationManager)


    {


@@ -798,12 +785,12 @@


        }


        catch (Exception ex)


        {




            throw new Exception(ex.Message);


        }


    }




    #region 直接出库任务完成




    public async Task<WebResponseContent> CompleteInToOutTaskAsync(Dt_Task task)


    {


        WebResponseContent content = new WebResponseContent();


@@ -822,10 +809,11 @@


            return content.Error(ex.Message);


        }


    }


    #endregion




    #endregion 直接出库任务完成




    #region MyRegion




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


    {


        _unitOfWorkManage.BeginTran();


@@ -864,13 +852,13 @@


            throw new Exception(err.Message); // 抛出异常以便外部捕获


        }


    }


    #endregion




    #endregion MyRegion




    #region 检测高温库是否有可出库库存




    public WebResponseContent StockCheckingAsync()


    {




        WebResponseContent webResponseContent = new WebResponseContent();


        try


        {


@@ -894,7 +882,6 @@


                        if (stockInfo.Count <= 0) continue;


                        foreach (var item in stockInfo)


                        {




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


                            if (hasTask != null)


                            {


@@ -912,7 +899,6 @@


                            task.NextAddress = "002-000-002";


                            // 创建任务DTO


                            WMSTaskDTO taskDTO = CreateTaskDTO(task);






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


                            var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;


@@ -949,7 +935,7 @@


        }


    }




    #endregion


    #endregion 检测高温库是否有可出库库存




    #region 常温补空托盘至分容




@@ -1000,6 +986,5 @@


        return content;


    }




    #endregion




    #endregion 常温补空托盘至分容


}