选配与暂存

Admin

2025-12-03 d41acebbd89f171b0eeb205fca4f68043ca85f95

 ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs

@@ -2,7 +2,10 @@
using MailKit.Search;
using Mapster;
using Masuit.Tools;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Database;
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using SqlSugar;
using System.Diagnostics;
using System.Reflection.Emit;
using System.Text.RegularExpressions;
@@ -44,6 +47,8 @@
    private readonly IDt_InZdp_mes_htyRepository _InZdp_Mes_HtyRepository; 
    private readonly IDt_ZdpStockRepository _ZdpStockRepository;
    private readonly IDt_ZdpStock_htyRepository _ZdpStock_HtyRepository;
    private readonly IDt_PreOutboundRepository _PreOutboundRepository;
    private readonly ILocationInfoRepository _locationInfoRepository;
    

    public Dt_TaskService(IDt_TaskRepository BaseDal,
@@ -68,7 +73,9 @@
                                IDt_InZdp_mes_htyRepository inZdp_Mes_HtyRepository,
                                IDt_ZdpStockRepository zdpStockRepository,
                                IDt_ZdpStock_htyRepository dt_ZdpStock_HtyRepository,
                                IDt_OutZdp_htyRepository dt_OutZdp_HtyRepository) : base(BaseDal)
                                IDt_OutZdp_htyRepository dt_OutZdp_HtyRepository,
                                IDt_PreOutboundRepository dt_PreOutboundRepository,
                                ILocationInfoRepository locationInfoRepository) : base(BaseDal)

    {
        _unitOfWorkManage = unitOfWorkManage;
@@ -90,6 +97,8 @@
        _ZdpStockRepository = zdpStockRepository;
        _ZdpStock_HtyRepository = dt_ZdpStock_HtyRepository;
        _Dt_OutZdp_htyRepository = dt_OutZdp_HtyRepository;
        _PreOutboundRepository = dt_PreOutboundRepository;
        _locationInfoRepository = locationInfoRepository;
    }

    #region å¤–部接口方法
@@ -339,6 +348,8 @@
                Wheels_mttype = stock.Wheels_mttype,
                //Wheels_SequenceNum = "",
                Wheels_ygljz = stock.Wheels_ygljz,
                Wheels_DateDet = stock.Wheels_DateDet,
                Wheels_Statue = stock.Wheels_Statue,
            };


@@ -424,6 +435,8 @@
                Zdp_GKJZ = stock.Zdp_GKJZ,
                Zdp_LSCSYMH = stock.Zdp_LSCSYMH,
                Zdp_rksj = stock.Zdp_rksj,
                Zdp_Statue= stock.Zdp_Statue,
                Zdp_DateDet = stock.Zdp_DateDet,
            };

            // äº‹åŠ¡å¤„理
@@ -708,7 +721,7 @@
                        SourceAddress = zdpInfo.Zdp_Location,
                        CurrentAddress =zdpInfo.Zdp_Location,
                        TaskState = (int)TaskOutStatusEnum.OutNew,
                        TaskType = outtype == "2" ? (int)TaskOutboundTypeEnum.OutBrake : (int)TaskOutboundTypeEnum.OutWheels,
                        TaskType = (int)TaskOutboundTypeEnum.OutBrake,
                        TaskNum = BaseDal.GetTaskNo().Result,
                        Creater = "System",
                        CreateDate = DateTime.Now,
@@ -733,6 +746,14 @@
                {
                    Dt_WheelsStock stockInfo = _WheelsStockRepository.QueryFirst(x => x.Wheels_code == item);
                    if (stockInfo == null) return content.Error("未查询到对应的库存信息");

                    Dt_PreOutbound dt_Pre=_PreOutboundRepository.QueryFirst(x => x.PalletCode == stockInfo.Wheels_code);
                    if (dt_Pre != null)
                    {
                        return content.Error($"当前车轮号已在暂存出库中，不可直接出库！！！，车轮条码：{dt_Pre.PalletCode}");
                    }


                    stockInfo.Wheels_CurrentStatue = 4;
                    string Location = stockInfo.Wheels_Location;
                    var locationst = locationinfoData.Where(x => x.LocationCode== stockInfo.Wheels_Location).FirstOrDefault();
@@ -759,7 +780,7 @@
                        IsCheck = true,
                        Standards = stockInfo.Wheels_NewOrOld
                    };

                    

                    task = new Dt_Task
                    {
@@ -799,7 +820,7 @@
            }


            // èŽ·å–WMS IP地址用于发送任务请求
            //获取WMS IP地址用于发送任务请求
            var wmsIpAddress = GetWCSIpReceiveTask();
            if (wmsIpAddress == null)
            {
@@ -823,6 +844,8 @@
                    _WheelsStockRepository.UpdateData(WheelList);
                }
            }



        }
        catch (Exception ex)
@@ -892,6 +915,8 @@
        return await BaseDal.Delete(ids);
    }


    #region åˆ é™¤ä»»åŠ¡å›žæ»š
    public override WebResponseContent DeleteData(object[] key)
    {
        WebResponseContent content = new WebResponseContent();
@@ -907,6 +932,59 @@
            if (task.TaskState != (int)TaskInStatusEnum.InNew && task.TaskState != (int)TaskOutStatusEnum.OutNew && task.TaskState != (int)TaskStatus.Created)
            {
                return content.Error("任务不处于新建状态,禁止删除!");
            }

            ////入库枚举
            //List<int> TaskInboundTypeEnums = Enum.GetValues(typeof(TaskInboundTypeEnum)).Cast<int>().ToList();
            ////出库枚举
            //List<int> TaskOutboundTypeEnums = Enum.GetValues(typeof(TaskOutboundTypeEnum)).Cast<int>().ToList();
            ////移库枚举
            //List<int> TaskMoveTypeEnums = Enum.GetValues(typeof(TaskRelocationTypeEnum)).Cast<int>().ToList();
            //判断任务类型
            // æ ¹æ®ä»»åŠ¡ç±»åž‹è°ƒç”¨ç›¸åº”的完成任务方法

            // éªŒè¯åº“存是否存在
            var stock = _WheelsStockRepository.QueryFirstNavAsync(x => x.Wheels_Num.Contains(task.PalletCode) && x.Wheels_Location == task.SourceAddress);
            var ZdpStock = _ZdpStockRepository.QueryFirstNavAsync(x => x.Zdp_code == task.PalletCode && x.Zdp_Location == task.SourceAddress);
            bool res = false;
            switch (task.TaskType)
            {
                case (int)TaskInboundTypeEnum.Inbound:
                case (int)TaskInboundTypeEnum.InWheels:
                case (int)TaskInboundTypeEnum.InBrake:
                    LogFactory.GetLog("任务完成").InfoFormat(true, "入库任务", "");
                        res = SellectLocationInfo(task,1);
                    break;

                case (int)TaskOutboundTypeEnum.Outbound:
                case (int)TaskOutboundTypeEnum.OutWheels:
                    LogFactory.GetLog("任务完成").InfoFormat(true, "出库任务", "");
                        res = SellectLocationInfo(task,2);
                    break;

                case (int)TaskOutboundTypeEnum.OutBrake:
                    LogFactory.GetLog("任务完成").InfoFormat(true, "制动盘出库任务", "");
                        res = SellectLocationInfo(task,3);
                    break;

                case (int)TaskRelocationTypeEnum.Relocation:
                    if (stock != null)
                    {
                        res = SellectLocationInfo(task,4);
                    }
                    else 
                    {
                        res = SellectLocationInfo(task,5);
                    }
                    break;

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

            if (!res)
            {
                return content.Error("在执行任务分类的时候出现错误！");
            }

            var taskHtyNG = CreateHistoricalTask(task, true);
@@ -929,6 +1007,97 @@
            return content.Error("删除任务异常：" + ex.Message);
        }
    }

    /// <summary>
    /// èŽ·å–库位信息
    /// </summary>
    /// <param name="targetAddress"></param>
    /// <returns></returns>
    /// <exception cref="NotImplementedException"></exception>
    private bool SellectLocationInfo(Dt_Task task,int taskType)
    {
        // èŽ·å–库位信息
        DtLocationInfo locationInfoT = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress);
        DtLocationInfo locationInfoS = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.SourceAddress);


        Dt_WheelsStock stock = _WheelsStockRepository.QueryFirst(x => x.Wheels_Num.Contains(task.PalletCode) && x.Wheels_Location == task.SourceAddress);
        Dt_ZdpStock ZdpStock = _ZdpStockRepository.QueryFirst(x => x.Zdp_code == task.PalletCode && x.Zdp_Location == task.SourceAddress);

        //if (locationInfoT == null) return false;

        //if (locationInfoS == null) return false;
        //1-入库   2-出库   3-制动盘出库   4-移库
        var db = _locationInfoRepository.Db as SqlSugarClient;
        try
        {
            db.Ado.BeginTran();
            if (taskType == 1)
            {
                locationInfoT.LocationStatus = (int)LocationEnum.Free;
                bool res = _locationInfoRepository.UpdateData(locationInfoT);
                if (res)
                {
                    db.Ado.CommitTran();
                    return true;
                }
            }
            else if (taskType == 2)
            {
                locationInfoS.LocationStatus = (int)LocationEnum.InStock;
                bool res = _locationInfoRepository.UpdateData(locationInfoS);
                stock.Wheels_CurrentStatue = 1;
                bool ress = _WheelsStockRepository.UpdateData(stock);
                if (res && ress)
                {
                    db.Ado.CommitTran();
                    return true;
                }
            }
            else if (taskType == 3)
            {
                locationInfoS.LocationStatus = (int)LocationEnum.InStock;
                bool res = _locationInfoRepository.UpdateData(locationInfoS);
                ZdpStock.Zdp_CurrentStatue = 1;
                bool ress = _ZdpStockRepository.UpdateData(ZdpStock);
                if (res && ress)
                {
                    db.Ado.CommitTran();
                    return true;
                }
            }
            //移库
            else
            {
                locationInfoT.LocationStatus = (int)LocationEnum.Free;
                locationInfoS.LocationStatus = (int)LocationEnum.InStock;
                bool res = _locationInfoRepository.UpdateData(locationInfoT);
                bool res1 = _locationInfoRepository.UpdateData(locationInfoS);
                if(taskType == 4)
                {
                    stock.Wheels_CurrentStatue = 1;
                }
                else
                {
                    ZdpStock.Zdp_CurrentStatue = 1;
                }
                bool ress = taskType == 4 ? _WheelsStockRepository.UpdateData(stock) : _ZdpStockRepository.UpdateData(ZdpStock);
                if (res && res1 && ress)
                {
                    db.Ado.CommitTran();
                    return true;
                }
            }
            return false;
        }
        catch (Exception ex)
        {
            db.Ado.RollbackTran();
            return false;
        }
    }

    #endregion

    /// <summary>
    /// é€šè¿‡ID获取任务
@@ -1128,6 +1297,7 @@

                var wheels_Mes_Hty = inWheels_Mes.Adapt<Dt_InWheels_mes_hty>();

                wheels_Mes_Hty.Wheels_Type = "è½®";
                wheels_Mes_Hty.Wheels_CurrentStatue = "2";
                wheels_Mes_Hty.FinishDate = DateTime.Now;
                wheels_Mes_Hty.OperateType = (int)OperateTypeEnum.自动完成;
@@ -1417,4 +1587,21 @@
    #endregion ä»»åŠ¡è¯·æ±‚方法

    #endregion private å†…部方法



    public WebResponseContent GetStockStatue()
    {
        WebResponseContent content=new WebResponseContent();
        int Wherecount = _WheelsStockRepository.QueryData(x => x.Wheels_Statue == 1).Count();

        int Zdpcount = _ZdpStockRepository.QueryData(x => x.Zdp_Statue == 1).Count();

        content.Data = new
        {
            WheelsCount = Wherecount,
            ZdpCount = Zdpcount
        };
        return content;
    }
}