最新

Admin

2 天以前 fd7fa01f87026b9db4cc6d44c0f93987b9bc27f2

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

@@ -5,6 +5,7 @@
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;
@@ -47,6 +48,7 @@
    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,
@@ -72,7 +74,8 @@
                                IDt_ZdpStockRepository zdpStockRepository,
                                IDt_ZdpStock_htyRepository dt_ZdpStock_HtyRepository,
                                IDt_OutZdp_htyRepository dt_OutZdp_HtyRepository,
                                IDt_PreOutboundRepository dt_PreOutboundRepository) : base(BaseDal)
                                IDt_PreOutboundRepository dt_PreOutboundRepository,
                                ILocationInfoRepository locationInfoRepository) : base(BaseDal)

    {
        _unitOfWorkManage = unitOfWorkManage;
@@ -95,6 +98,7 @@
        _ZdpStock_HtyRepository = dt_ZdpStock_HtyRepository;
        _Dt_OutZdp_htyRepository = dt_OutZdp_HtyRepository;
        _PreOutboundRepository = dt_PreOutboundRepository;
        _locationInfoRepository = locationInfoRepository;
    }

    #region å¤–部接口方法
@@ -776,7 +780,7 @@
                        IsCheck = true,
                        Standards = stockInfo.Wheels_NewOrOld
                    };

                    

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


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



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


    #region åˆ é™¤ä»»åŠ¡å›žæ»š
    public override WebResponseContent DeleteData(object[] key)
    {
        WebResponseContent content = new WebResponseContent();
@@ -921,10 +929,84 @@
                return content.Error("未找到任务信息!");
            }

            if (task.TaskState != (int)TaskInStatusEnum.InNew && task.TaskState != (int)TaskOutStatusEnum.OutNew && task.TaskState != (int)TaskStatus.Created)
            if (task.TaskState != (int)TaskInStatusEnum.InNew && task.TaskState != (int)TaskOutStatusEnum.OutNew && task.TaskState != (int)TaskStatus.Created && task.TaskState != (int)TaskInStatusEnum.InAbnormalCompletion && task.TaskState != (int)TaskOutStatusEnum.OutAbnormalCompletion)
            {
                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();
            //判断任务类型
            // æ ¹æ®ä»»åŠ¡ç±»åž‹è°ƒç”¨ç›¸åº”的完成任务方法

            // éªŒè¯åº“存是否存在
            if(task.TaskState== (int)TaskInStatusEnum.InAbnormalCompletion || task.TaskState == (int)TaskOutStatusEnum.OutAbnormalCompletion)
            {
                var taskHtyNG2 = CreateHistoricalTask(task, true);

                //if (task.TaskState == (int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
                //{
                //    //if(task.TaskType ==  )
                //}

                // æ·»åŠ åŽ†å²ä»»åŠ¡
                var isTaskHtyAdd2 = _task_HtyRepository.AddData(taskHtyNG2) > 0;

                // åˆ é™¤ä»»åŠ¡æ•°æ®
                var isTaskDelete2 = BaseDal.Delete(task.TaskId);

                return content.OK("删除成功!");
            }
            else
            {
                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);

@@ -948,6 +1030,97 @@
    }

    /// <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获取任务
    /// </summary>
    /// <param name="id">任务ID</param>