IStackerStatusApp.cs 101 KB

Edit Raw Blame History Permalink

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Diagnostics;
using System.Xml;
using System.Linq;
using Infrastructure;
using WebRepository;
using ServiceReference1;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Information;

namespace WebApp
{
    /// <summary>
    /// 堆垛机运行节点接口App
    /// </summary>

    public partial class IStackerStatusApp : ApiApp
    {
        public IRepository<ReceiptHeader> _apprh;
        public IRepository<Container> _appc;
        public IRepository<ReceiptDetail> _apprd;
        public IRepository<Inventory> _appi;
        private object obj = new object();
        public IStackerStatusApp(IUnitWork unitWork, IRepository<Inventory> inventory, IRepository<Container> Container, IAuth auth, BaseDBContext context, IRepository<ReceiptDetail> receiptDetail, IRepository<ReceiptHeader> receiptHeader) : base(unitWork, auth, context)
        {
            _apprd = receiptDetail;
            _apprh = receiptHeader;
            _appi = inventory;
            _appc = Container;

            //系统字段赋值
            _apprd._loginInfo = _apprh._loginInfo = _loginInfo;
            _appi._loginInfo = _apprh._loginInfo = _loginInfo;
            _appc._loginInfo = _apprh._loginInfo = _loginInfo;
        }

        public Response<TaskDetail> SetStackerStatus(STKStatusModel sTKStatusModel)
        {
            using (var tran = _unitWork.GetDbContext().Database.BeginTransaction())
            {
                Response<TaskDetail> Response = new Response<TaskDetail>();
                try
                {
                    TaskDetail td = null;
                    if (sTKStatusModel.Status == 30)
                    {
                        td = _unitWork.FindSingle<TaskDetail>(u => u.TaskNo == sTKStatusModel.TaskNo && u.Status >= TaskStatus.新建任务 && u.Status < TaskStatus.已经完成);
                    }
                    else if (sTKStatusModel.Status == 40)
                    {
                        td = _unitWork.FindSingle<TaskDetail>(u => u.TaskNo == sTKStatusModel.TaskNo && u.Status >= TaskStatus.新建任务 && u.Status < TaskStatus.已经完成);
                    }
                    //WCS回库 货物到Rgv上给一次反馈站台占用解除
                    else if (sTKStatusModel.Status == 10)
                    {
                        td = _unitWork.FindSingle<TaskDetail>(u => u.TaskNo == sTKStatusModel.TaskNo && u.Status >= TaskStatus.新建任务 && u.Status < TaskStatus.已经完成);
                        Station stationType = _unitWork.Find<Station>(n => n.Code == td.SourceLocation).FirstOrDefault();
                        if (td == null)
                        {
                            td.UpdateTime = DateTime.Now;
                            td.Error = "任务重发，任务号：" + sTKStatusModel.TaskNo;
                            _unitWork.Update(td);
                            Response.Message = "重发";
                            return Response;
                        }
                        if (stationType != null)
                        {
                            if (stationType.Type == StationType.PP片上胶站台)
                            {
                                Station stationEmpty = (from se in _unitWork.Find<Station>(n => n.IsEmpty == 1 && n.IsStop == 0 && n.Containercode != "")
                                                        join sts in _unitWork.Find<StationToStation>(a => a.EndStation == td.SourceLocation)
                                                        on se.Code equals sts.StartStation
                                                        select se).FirstOrDefault();
                                if (stationEmpty != null)
                                {
                                    stationEmpty.Containercode = "";
                                    stationEmpty.UpdateBy = "wms";
                                    stationEmpty.UpdateTime = DateTime.Now;
                                    _unitWork.Update(stationEmpty);
                                }
                            }
                        }
                        if (td.TaskType == TaskType.移库)
                        {
                            Location loc = _unitWork.Find<Location>(n => n.Code == td.SourceLocation && n.Status == LocationStatus.任务锁定中).FirstOrDefault();
                            if (loc == null)
                            {
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "移库初始仓位状态不正确！";
                                td.Error = "移库初始仓位状态不正确！";
                                _unitWork.Update(td);
                                return Response;
                            }
                            else
                            {
                                //修改初始仓位
                                _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                                {
                                    Status = LocationStatus.空仓位,
                                    ContainerCode = "",
                                    UpdateTime = DateTime.Now
                                });
                                td.UpdateTime = DateTime.Now;
                                td.Error = "堆垛机已接任务:"+ DateTime.Now;
                                _unitWork.Update(td);
                            }
                        }
                        else
                        {
                            Station station = _unitWork.Find<Station>(n => n.Code == td.SourceLocation && n.Containercode == td.ContainerCode && td.SourceLocation != "PP_SpecialPoint").FirstOrDefault();
                            if (station != null)
                            {
                                station.Containercode = "";
                                station.UpdateBy = "wms";
                                station.UpdateTime = DateTime.Now;
                            }
                            else if (_unitWork.IsExist<Station>(n => n.Containercode == td.SourceLocation))
                            {
                                station = _unitWork.Find<Station>(n => n.Code == td.SourceLocation).FirstOrDefault();
                                station.Containercode = "";
                                station.UpdateBy = "wms";
                                station.UpdateTime = DateTime.Now;
                            }
                            else
                            {
                                Response.Message = "重发";
                                return Response;
                            }
                            _unitWork.Update(station);

                        }

                        tran.Commit();
                        return Response;
                    }
                    //WCS回库仓位高度请求
                    else if (sTKStatusModel.Status == 20)
                    {
                        td = _unitWork.Find<TaskDetail>(u => u.TaskNo == sTKStatusModel.TaskNo && u.Status >= TaskStatus.新建任务 && u.Status < TaskStatus.已经完成 && (u.TaskType == TaskType.容器回库 || u.TaskType == TaskType.空容器入库)).FirstOrDefault();
                        StationRoadway stationRoadway = _unitWork.Find<StationRoadway>(n => n.StationCode == td.SourceLocation).FirstOrDefault();
                        Location loc = null;
                        if (stationRoadway == null)
                        {
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "未找到起始站台！";
                            return Response;
                        }
                        else if (td == null)
                        {
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "未找到回库任务！";
                            return Response;
                        }
                        else if (_unitWork.IsExist<Location>(n => n.ContainerCode == td.ContainerCode))
                        {
                            if (_unitWork.IsExist<Inventory>(n => n.ContainerCode == td.ContainerCode && n.TaskStatus == InventoryTaskType.有盘点任务))
                            {
                                loc = _unitWork.Find<Location>(n => n.ContainerCode == td.ContainerCode).FirstOrDefault();
                            }
                            else
                            {
                                Response.Result = td;
                                Response.Message = "已有仓位！";
                                return Response;
                            }
                        }
                        if (stationRoadway.StationCode == "EntranceStationD02(P1004)" && td.ContainerCode.Contains("N5PP"))
                        {
                            stationRoadway.RoadWay = 2;
                        }
                        Container container = _unitWork.Find<Container>(n => n.Code == td.ContainerCode).FirstOrDefault();
                        if (loc == null && container != null)
                        {
                            if (sTKStatusModel.Height == -1)
                            {
                                sTKStatusModel.Height = (int)container.Height;
                            }
                            string error = "";
                            while (true)
                            {
                                var tasks = _unitWork.Find<TaskDetail>(n => n.TaskNo != null).ToList();
                                if (_unitWork.GetCount<Location>(n => n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "") < 6)
                                {
                                    loc = null;
                                    error = "仓位不足6个！";
                                    break;
                                }
                                //RowIndex 1：里仓位，2：外仓位。查找到里仓位时外仓位要为空
                                if (stationRoadway.StationPlace == StationPlace.巷道北面)
                                {
                                    loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                           join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                               on loca.ContiguousCode equals cLoca.Code
                                           select loca)
                                    .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                }
                                else if (stationRoadway.StationPlace == StationPlace.巷道南面)
                                {
                                    loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                           join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                               on loca.ContiguousCode equals cLoca.Code
                                           select loca)
                                    .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenByDescending(y => y.Row).FirstOrDefault();
                                }

                                if (loc == null)
                                {
                                    if (stationRoadway.StationPlace == StationPlace.巷道北面)
                                    {
                                        loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                               join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                   on loca.ContiguousCode equals cLoca.Code
                                               select loca)
                                        .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                    }
                                    else if (stationRoadway.StationPlace == StationPlace.巷道南面)
                                    {
                                        loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                               join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                   on loca.ContiguousCode equals cLoca.Code
                                               select loca)
                                       .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenByDescending(y => y.Row).FirstOrDefault();
                                    }
                                }


                                //更新仓位对应的容器，如果回库分配的不是原仓位则更新仓位且锁定
                                if (loc == null)
                                {
                                    Response.Code = 300;
                                    Response.Status = false;
                                    Response.Message = "未找到仓位！";
                                    td.Error = "未找到仓位！" + error;
                                    _unitWork.Update(td);
                                    tran.Commit();
                                    return Response;
                                }
                                else
                                {
                                    if (_unitWork.IsExist<TaskDetail>(a => (a.DestinationLocation == loc.ContiguousCode || a.SourceLocation == loc.ContiguousCode) && a.Roadway == 1))
                                    {
                                        continue;
                                    }
                                    int i = _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                                    {
                                        Status = LocationStatus.任务锁定中,
                                        ContainerCode = td.ContainerCode,
                                        UpdateTime = DateTime.Now
                                    });
                                    if (i == 1)
                                    {
                                        break;
                                    }
                                }
                            }
                        }

                        List<Inventory> inventories = _unitWork.Find<Inventory>(n => n.ContainerCode == td.ContainerCode).ToList();
                        if (container == null)
                        {
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "未找到该容器！";
                            td.Error = "未找到该容器！";
                            _unitWork.Update(td);
                            return Response;
                        }
                        else
                        {
                            //更改容器
                            container.Height = sTKStatusModel.Height;
                            container.LocationCode = loc.Code;
                            container.LocationId = loc.Id;
                            _unitWork.Update(container);
                        }

                        //更新同个容器中其它物料对应新的回库仓位
                        if (inventories.Count > 0)
                        {
                            foreach (Inventory inv in inventories)
                            {
                                if (inv.LocationCode != loc.Code)
                                {
                                    inv.LocationCode = loc.Code;
                                    _appi.Update(inv);
                                }
                            }
                        }
                        //更改任务终点
                        td.DestinationLocation = loc.Code;
                        _unitWork.Update(td);
                        //如果入库起始站台为PP片排版房入库口，那么在请求仓位后就直接清除站台占用
                        Station stationOne = _unitWork.Find<Station>(n => n.Code == td.SourceLocation).FirstOrDefault();
                        if (stationOne.Containercode == td.ContainerCode && td.SourceLocation == "EntranceStationY01")
                        {
                            stationOne.Containercode = "";
                            stationOne.UpdateBy = "wms";
                            stationOne.UpdateTime = DateTime.Now;
                            _unitWork.Update(stationOne);
                        }
                        tran.Commit();
                        Response.Result = td;
                        return Response;
                    }
                    //2楼叠盘机补板完成，绑定物料与托盘
                    else if (sTKStatusModel.Status == 70)
                    {
                        var ConLength = sTKStatusModel.ContainerCode.Length;
                        if (sTKStatusModel.ContainerCode.StartsWith("N5PJ") && ConLength == 9)
                        {
                            StoreStation storeStation = _unitWork.Find<StoreStation>(n => n.StationCode == "InStationB06(P3316)" && n.Status == StoreStationStatus.到达站台).FirstOrDefault();
                            if (storeStation != null)
                            {
                                List<Inventory> inventories = _unitWork.Find<Inventory>(n => n.ContainerCode == storeStation.ContainerCode).ToList();
                                if (inventories.Count() > 0)
                                {
                                    foreach (var inventorie in inventories)
                                    {
                                        inventorie.ContainerCode = sTKStatusModel.ContainerCode;
                                        inventorie.UpdateTime = DateTime.Now;
                                        _unitWork.Update(inventorie);
                                    }
                                    _unitWork.Delete(storeStation);
                                    tran.Commit();
                                    Response.Code = 200;
                                    Response.Status = true;
                                    Response.Message = inventories.Count().ToString();
                                    return Response;
                                }
                                else
                                {
                                    tran.Rollback();
                                    Response.Code = 300;
                                    Response.Status = false;
                                    Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "绑定物料失败，未找到托盘号"+ storeStation.ContainerCode + "的物料数据";
                                    return Response;
                                }
                            }
                            else
                            {
                                tran.Rollback();
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "绑定物料失败，未找到已经到达叠盘机的木板数据！";
                                return Response;
                            }
                        }
                        else
                        {
                            tran.Rollback();
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "错误，不是PP卷的托盘号，不允许绑定物料！";
                            return Response;
                        }
                    }
                    //2楼空板暂存从库内呼叫空板
                    else if (sTKStatusModel.Status == 80)
                    {
                        TaskDetail tad = _unitWork.Find<TaskDetail>(n => n.DestinationLocation == "OutStationB05(P3310)" || n.DestinationLocation == "ExitStationB02(P3328)").FirstOrDefault();
                        if (tad != null)
                        {
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "2楼空板暂存区已有出库任务！";
                            return Response;
                        }
                        var type = "P_1";
                        var LocType = LocationStatus.空容器;
                        StationRoadway stationRoadway = null;
                        Station sta = _unitWork.Find<Station>(n => n.Code == "OutStationB05(P3310)").FirstOrDefault();
                        stationRoadway = _unitWork.Find<StationRoadway>(n => n.StationCode == "OutStationB05(P3310)").FirstOrDefault();
                        List<Container> containers;
                        //****************
                        if (stationRoadway.StationPlace == StationPlace.巷道北面)
                        {
                            containers = (from con in _unitWork.Find<Container>(n => n.Type == type && n.Status == ContainerStatus.空 && n.IsLock == 0)
                                          join loccon in _unitWork.Find<Location>(n => n.Roadway == stationRoadway.RoadWay && n.Status == LocType)
                                          on con.LocationCode equals loccon.Code
                                          orderby loccon.RowIndex == 2 ? 0 : loccon.RowIndex, loccon.Row
                                          select con).ToList();
                        }
                        else if (stationRoadway.StationPlace == StationPlace.巷道南面)
                        {
                            containers = (from con in _unitWork.Find<Container>(n => n.Type == type && n.Status == ContainerStatus.空 && n.IsLock == 0)
                                          join loccon in _unitWork.Find<Location>(n => n.Roadway == stationRoadway.RoadWay && n.Status == LocType)
                                          on con.LocationCode equals loccon.Code
                                          orderby loccon.RowIndex == 2 ? 0 : loccon.RowIndex, loccon.Row descending
                                          select con).ToList();
                        }
                        else
                        {
                            containers = (from con in _unitWork.Find<Container>(n => n.Type == type && n.Status == ContainerStatus.空 && n.IsLock == 0)
                                          join loccon in _unitWork.Find<Location>(n => n.Roadway == stationRoadway.RoadWay && n.Status == LocType)
                                          on con.LocationCode equals loccon.Code
                                          orderby loccon.RowIndex == 2 ? 0 : loccon.RowIndex
                                          select con).ToList();
                        }
                        Container container = null;
                        foreach (Container con in containers)
                        {
                            if (_unitWork.IsExist<TaskDetail>(n => n.ContainerCode == con.Code))
                            {
                                continue;
                            }
                            else
                            {
                                container = con;
                                break;
                            }
                        }

                        if (container == null)
                        {
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "库内无空托盘！";
                            return Response;
                        }
                        var pro = 501;
                        Task ptask = new Task();
                        TaskDetail ptaskDetail = new TaskDetail();
                        var taskNo = _unitWork.GetTaskNo(TaskNo.空板补充);
                        ptask.TaskNo = taskNo;
                        ptask.OrderCode = taskNo;
                        ptask.BusinessType = BusinessType.出库_其他出库单;
                        ptask.FirstStatus = TaskStatus.待下发任务;
                        ptask.LastStatus = TaskStatus.待下发任务;
                        ptask.CreateTime = DateTime.Now;
                        _unitWork.Add(ptask);

                        ptaskDetail.TaskNo = taskNo;
                        ptaskDetail.OrderCode = taskNo;
                        ptaskDetail.TaskType = TaskType.空容器出库;
                        ptaskDetail.ContainerCode = container.Code;
                        ptaskDetail.SourceLocation = container.LocationCode;
                        ptaskDetail.DestinationLocation = stationRoadway.StationCode;
                        ptaskDetail.OderQty = 0;
                        ptaskDetail.ContainerQty = 0;
                        ptaskDetail.HadQty = 0;
                        ptaskDetail.Roadway = stationRoadway.RoadWay;
                        ptaskDetail.Station = stationRoadway.StationCode;
                        ptaskDetail.Status = TaskStatus.待下发任务;
                        ptaskDetail.Priority = pro;
                        ptaskDetail.CreateTime = DateTime.Now;
                        _unitWork.Add(ptaskDetail);

                        container.IsLock = 1;
                        _unitWork.Update(container);

                        List<Location> loc = _unitWork.Find<Location>(n => n.ContainerCode == container.Code).ToList();
                        if (loc.Count() > 0)
                        {
                            foreach (Location la in loc)
                            {
                                _unitWork.Update<Location>(n => n.Id == la.Id && n.Version == la.Version, n => new Location
                                {
                                    Status = LocationStatus.任务锁定中
                                });
                            }
                        }
                    }
                    //2楼叠盘机货物入库
                    else if (sTKStatusModel.Status == 90)
                    {
                        var ConLength = sTKStatusModel.ContainerCode.Length;
                        if (sTKStatusModel.ContainerCode.StartsWith("N5PJ") && ConLength == 9)
                        {
                            if (_unitWork.IsExist<Location>(n => n.ContainerCode == sTKStatusModel.ContainerCode && n.ContainerCode != ""))
                            {
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "在库位表中已经存在，不允许创建任务！";
                                return Response;
                            }
                            TaskDetail Stacker_taskDetail = _unitWork.Find<TaskDetail>(n => n.ContainerCode == sTKStatusModel.ContainerCode).FirstOrDefault();
                            if (Stacker_taskDetail == null)
                            {
                                Container Stacker_container = _unitWork.Find<Container>(n => n.Code == sTKStatusModel.ContainerCode).FirstOrDefault();
                                if (Stacker_container == null)
                                {
                                    Stacker_container = new Container
                                    {
                                        Code = sTKStatusModel.ContainerCode,
                                        LocationCode = "OutStationB06(P3319)",
                                        IsLock = ContainerLock.任务锁,
                                        Status = ContainerStatus.有,
                                        Type = "p_1",
                                        PrintCount = 0,
                                        CreateTime = DateTime.Now,
                                        CreateBy = "IStackerStatusApp"
                                    };
                                    _unitWork.Add(Stacker_container);
                                }
                                StationRoadway stationRoadway = _unitWork.Find<StationRoadway>(n => n.StationCode == "OutStationB06(P3319)").FirstOrDefault();
                                List<Inventory> inventories1 = _unitWork.Find<Inventory>(n => n.ContainerCode == Stacker_container.Code).ToList();
                                //有物料创建货物入库
                                if (inventories1.Count() > 0)
                                {
                                    //创建2楼叠盘机入库任务
                                    Location location = null;
                                    var tasks = _unitWork.Find<TaskDetail>(n => n.TaskNo != null).ToList();

                                    if (location == null)
                                    {
                                        while (true)
                                        {
                                            if (stationRoadway.StationPlace == StationPlace.巷道北面)
                                            {
                                                location = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                                            join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                                on loca.ContiguousCode equals cLoca.Code
                                                            select loca)
                                                .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                            }
                                            else if (stationRoadway.StationPlace == StationPlace.巷道南面)
                                            {
                                                location = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                                            join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                                on loca.ContiguousCode equals cLoca.Code
                                                            select loca)
                                                .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenByDescending(y => y.Row).FirstOrDefault();
                                            }
                                            if (location == null)
                                            {
                                                if (stationRoadway.StationPlace == StationPlace.巷道北面)
                                                {
                                                    location = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                                                join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                                    on loca.ContiguousCode equals cLoca.Code
                                                                select loca)
                                                    .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                                }
                                                else if (stationRoadway.StationPlace == StationPlace.巷道南面)
                                                {
                                                    location = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                                                join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                                    on loca.ContiguousCode equals cLoca.Code
                                                                select loca)
                                                   .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenByDescending(y => y.Row).FirstOrDefault();
                                                }
                                            }
                                            if (location == null)
                                            {
                                                tran.Rollback();
                                                Response.Code = 300;
                                                Response.Status = false;
                                                Response.Message = "库内仓位已满！";
                                                return Response;
                                            }
                                            else
                                            {
                                                if (_unitWork.IsExist<TaskDetail>(a => (a.DestinationLocation == location.ContiguousCode || a.SourceLocation == location.ContiguousCode) && a.Roadway == 3))
                                                {
                                                    continue;
                                                }
                                                int i = _unitWork.Update<Location>(n => n.Id == location.Id && n.Version == location.Version, n => new Location
                                                {
                                                    Status = LocationStatus.任务锁定中,
                                                    ContainerCode = Stacker_container.Code,
                                                    UpdateTime = DateTime.Now
                                                });
                                                if (i == 1)
                                                {
                                                    break;
                                                }
                                            }
                                        }
                                    }
                                    var taskNo = "";
                                    Task task = new Task();
                                    TaskDetail taskDetail = new TaskDetail();
                                    taskNo = "OutStationB06(P3319)" + _unitWork.GetTaskNo(TaskNo.容器回库);
                                    task.TaskNo = taskNo;
                                    task.OrderCode = taskNo;
                                    task.BusinessType = BusinessType.入库_其他入库单;
                                    task.FirstStatus = TaskStatus.待下发任务;
                                    task.LastStatus = TaskStatus.待下发任务;
                                    task.CreateTime = DateTime.Now;
                                    _unitWork.Add(task);

                                    taskDetail.TaskNo = taskNo;
                                    taskDetail.OrderCode = taskNo;
                                    taskDetail.TaskType = TaskType.容器回库;
                                    taskDetail.ContainerCode = Stacker_container.Code;
                                    taskDetail.SourceLocation = "OutStationB06(P3319)";
                                    taskDetail.DestinationLocation = location.Code;
                                    taskDetail.OderQty = 0;
                                    taskDetail.ContainerQty = 0;
                                    taskDetail.HadQty = 0;
                                    taskDetail.Roadway = 3;
                                    taskDetail.Station = "OutStationB06(P3319)";
                                    taskDetail.Status = TaskStatus.待下发任务;
                                    taskDetail.Priority = 99;
                                    taskDetail.CreateTime = DateTime.Now;
                                    _unitWork.Add(taskDetail);

                                    Container UpConSta = _unitWork.Find<Container>(n => n.Code == Stacker_container.Code).FirstOrDefault();
                                    UpConSta.Status = LocationStatus.有货;
                                    UpConSta.LocationCode = location.Code;
                                    UpConSta.Type = "p_1";
                                    _unitWork.Update(UpConSta);

                                    List<Inventory> inventories = _unitWork.Find<Inventory>(n => n.ContainerCode == Stacker_container.Code).ToList();
                                    //更新同个容器中其它物料对应新的回库仓位
                                    if (inventories.Count > 0)
                                    {
                                        foreach (Inventory inv in inventories)
                                        {
                                            if (inv.LocationCode != location.Code)
                                            {
                                                inv.LocationCode = location.Code;
                                                _appi.Update(inv);
                                            }
                                        }
                                    }
                                    tran.Commit();
                                    Response.Code = 200;
                                    Response.Result = taskDetail;
                                    Response.Status = true;
                                    return Response;
                                }
                                else
                                {

                                    Location loc = null;
                                    while (true)
                                    {
                                        var tasks = _unitWork.Find<TaskDetail>(n => n.TaskNo != null).ToList();

                                        loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                               join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                               on loca.ContiguousCode equals cLoca.Code
                                               select loca)
                                              .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();

                                        if (loc == null)
                                        {
                                            loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay && n.ContainerCode == "")
                                                   join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == stationRoadway.RoadWay)
                                                   on loca.ContiguousCode equals cLoca.Code
                                                   select loca)
                                                  .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                        }
                                        //更新仓位对应的容器，如果回库分配的不是原仓位则更新仓位且锁定
                                        if (loc == null)
                                        {
                                            Response.Code = 300;
                                            Response.Status = false;
                                            Response.Message = "未找到仓位！";
                                            return Response;
                                        }
                                        else
                                        {
                                            if (_unitWork.IsExist<TaskDetail>(a => (a.DestinationLocation == loc.ContiguousCode || a.SourceLocation == loc.ContiguousCode) && (a.Roadway == 1 || a.Roadway == 3)))
                                            {
                                                continue;
                                            }
                                            int i = _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                                            {
                                                Status = LocationStatus.任务锁定中,
                                                ContainerCode = Stacker_container.Code,
                                                UpdateTime = DateTime.Now
                                            });

                                            if (i == 1)
                                            {
                                                break;
                                            }
                                        }
                                    }
                                    var pro = 99;
                                    TaskDetail taskDetail = new TaskDetail();
                                    Task task = new Task();
                                    var tno = stationRoadway.StationCode + _unitWork.GetTaskNo(TaskNo.空托盘入库);
                                    task.TaskNo = tno;
                                    task.OrderCode = tno;
                                    task.BusinessType = BusinessType.入库_其他入库单;
                                    task.FirstStatus = TaskStatus.待下发任务;
                                    task.LastStatus = TaskStatus.待下发任务;
                                    task.CreateTime = DateTime.Now;
                                    _unitWork.Add(task);

                                    taskDetail.TaskNo = tno;
                                    taskDetail.OrderCode = tno;
                                    taskDetail.TaskType = TaskType.空容器入库;
                                    taskDetail.ContainerCode = Stacker_container.Code;
                                    taskDetail.SourceLocation = stationRoadway.StationCode;
                                    taskDetail.DestinationLocation = loc.Code;
                                    taskDetail.OderQty = 0;
                                    taskDetail.ContainerQty = 0;
                                    taskDetail.HadQty = 0;

                                    taskDetail.Roadway = stationRoadway.RoadWay;
                                    taskDetail.Station = stationRoadway.StationCode;
                                    taskDetail.Status = TaskStatus.待下发任务;
                                    taskDetail.Priority = pro;
                                    taskDetail.CreateTime = DateTime.Now;
                                    _unitWork.Add(taskDetail);

                                    Stacker_container.Type = "p_1";
                                    Stacker_container.Status = ContainerStatus.空;
                                    _unitWork.Update(Stacker_container);

                                    tran.Commit();
                                    Response.Code = 200;
                                    Response.Result = taskDetail;
                                    Response.Status = true;
                                    return Response;
                                }
                            }
                            else
                            {
                                tran.Rollback();
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "已有任务，不允许重复创建任务！";
                            }
                        }
                        else
                        {
                            tran.Rollback();
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "错误，不是PP卷的托盘号，不允许创建任务！";
                        }
                        return Response;
                    }
                    //1楼叠盘机请求入库
                    else if (sTKStatusModel.Status == 100)
                    {
                        if (sTKStatusModel.ContainerCode.Contains("N5PJ"))
                        {
                            Inventory inv = _unitWork.Find<Inventory>(n => n.ContainerCode == sTKStatusModel.ContainerCode).FirstOrDefault();
                            if (inv != null)
                            {
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "有物料不能空托盘组入库！";
                                return Response;
                            }
                            if (_unitWork.IsExist<Location>(n => n.ContainerCode == sTKStatusModel.ContainerCode && n.ContainerCode != ""))
                            {
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "库内存在该托盘！";
                                return Response;
                            }
                            TaskDetail tad = _unitWork.Find<TaskDetail>(n => n.DestinationLocation == "ExitStationB01(P3100)").FirstOrDefault();
                            if (tad != null)
                            {
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "提升机已有出库任务，等待出库任务完成才允许入库！";
                                return Response;
                            }
                            TaskDetail Stacker_taskDetail = _unitWork.Find<TaskDetail>(n => n.ContainerCode == sTKStatusModel.ContainerCode).FirstOrDefault();
                            if (Stacker_taskDetail == null)
                            {
                                Container Stacker_container = _unitWork.Find<Container>(n => n.Code == sTKStatusModel.ContainerCode).FirstOrDefault();
                                if (Stacker_container == null)
                                {
                                    Stacker_container = new Container
                                    {
                                        Code = sTKStatusModel.ContainerCode,
                                        LocationCode = "EntranceStationB02(P3101)",
                                        IsLock = ContainerLock.任务锁,
                                        Status = ContainerStatus.空,
                                        Type = "p_2",
                                        PrintCount = 0,
                                        CreateTime = DateTime.Now,
                                        CreateBy = "IStackerStatusApp"
                                    };
                                    _unitWork.Add(Stacker_container);
                                }
                                //创建空托盘组回库任务
                                Location loc = null;
                                while (true)
                                {
                                    var tasks = _unitWork.Find<TaskDetail>(n => n.TaskNo != null).ToList();
                                    loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 1 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == 3 && n.ContainerCode == "")
                                           join cLoca in _unitWork.Find<Location>(n => n.ContainerCode == "" && n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == 3)
                                           on loca.ContiguousCode equals cLoca.Code
                                           select loca)
                                          .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();

                                    if (loc == null)
                                    {
                                        loc = (from loca in _unitWork.Find<Location>(n => n.RowIndex == 2 && !tasks.Select(a => a.DestinationLocation).Contains(n.ContiguousCode) && !tasks.Select(a => a.SourceLocation).Contains(n.ContiguousCode) && n.Status == LocationStatus.空仓位 && n.IsStop == false && n.Roadway == 3 && n.ContainerCode == "")
                                               join cLoca in _unitWork.Find<Location>(n => n.Status != LocationStatus.任务锁定中 && n.IsStop == false && n.Roadway == 3)
                                               on loca.ContiguousCode equals cLoca.Code
                                               select loca)
                                              .OrderBy(n => n.RowIndex == 1 ? 0 : n.RowIndex).ThenBy(b => b.MaxHeight).ThenBy(a => a.Layer).ThenBy(y => y.Row).FirstOrDefault();
                                    }
                                    //更新仓位对应的容器，如果回库分配的不是原仓位则更新仓位且锁定
                                    if (loc == null)
                                    {
                                        tran.Rollback();
                                        Response.Code = 300;
                                        Response.Status = false;
                                        Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "未找到仓位，不允许创建任务！";
                                        return Response;
                                    }
                                    else
                                    {
                                        if (_unitWork.IsExist<TaskDetail>(a => (a.DestinationLocation == loc.ContiguousCode || a.SourceLocation == loc.ContiguousCode) && a.Roadway == 3))
                                        {
                                            continue;
                                        }
                                        int i = _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                                        {
                                            Status = LocationStatus.任务锁定中,
                                            ContainerCode = Stacker_container.Code,
                                            UpdateTime = DateTime.Now
                                        });

                                        if (i == 1)
                                        {
                                            break;
                                        }
                                    }
                                }
                                var pro = 99;
                                TaskDetail taskDetail = new TaskDetail();
                                Task task = new Task();
                                var tno = "";

                                tno = "EntranceStationB02(P3101)" + _unitWork.GetTaskNo(TaskNo.空托盘组入库);

                                task.TaskNo = tno;
                                task.OrderCode = tno;
                                task.BusinessType = BusinessType.入库_其他入库单;
                                task.FirstStatus = TaskStatus.待下发任务;
                                task.LastStatus = TaskStatus.待下发任务;
                                task.CreateTime = DateTime.Now;
                                _unitWork.Add(task);

                                taskDetail.TaskNo = tno;
                                taskDetail.OrderCode = tno;
                                taskDetail.TaskType = TaskType.空容器入库;
                                taskDetail.ContainerCode = Stacker_container.Code;
                                taskDetail.SourceLocation = "EntranceStationB02(P3101)";
                                taskDetail.DestinationLocation = loc.Code;
                                taskDetail.OderQty = 0;
                                taskDetail.ContainerQty = 0;
                                taskDetail.HadQty = 0;

                                taskDetail.Roadway = 3;
                                taskDetail.Station = "EntranceStationB02(P3101)";
                                taskDetail.Status = TaskStatus.待下发任务;
                                taskDetail.Priority = pro;
                                taskDetail.CreateTime = DateTime.Now;
                                _unitWork.Add(taskDetail);
                                tran.Commit();
                                Response.Code = 200;
                                Response.Result = taskDetail;
                                Response.Status = true;
                                return Response;
                            }
                            else
                            {
                                tran.Rollback();
                                Response.Code = 300;
                                Response.Status = false;
                                Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "已有任务，不允许重复创建任务！";
                                return Response;
                            }
                        }
                        else
                        {
                            tran.Rollback();
                            Response.Code = 300;
                            Response.Status = false;
                            Response.Message = "托盘号" + sTKStatusModel.ContainerCode + "错误，不是PP卷的托盘号，不允许创建任务！";
                            return Response;
                        }
                    }
                    else
                    {
                        tran.Rollback();
                        Response.Code = 500;
                        Response.Status = false;
                        Response.Message = "不识别的任务状态！";
                        return Response;
                    }

                    if (td != null)
                    {
                        List<TaskDetail> taskDetailsShipments = _unitWork.Find<TaskDetail>(n => n.ContainerCode == td.ContainerCode && (n.TaskType == TaskType.整盘出库 || n.TaskType == TaskType.分拣出库) && n.Station == td.Station).ToList();
                        foreach (var taskDetailsShipment in taskDetailsShipments)
                        {
                            if (taskDetailsShipment.Status == TaskStatus.待下发任务)
                            {
                                taskDetailsShipment.Status = TaskStatus.下达任务;
                                _unitWork.Update(taskDetailsShipment);
                            }
                        }
                        List<TaskDetail> taskDetails = new List<TaskDetail>();
                        if (td.ContainerCode == "empty")
                        {
                            taskDetails = _unitWork.Find<TaskDetail>(u => u.TaskNo == td.TaskNo && u.Status > TaskStatus.待下发任务 && u.Status < TaskStatus.已经完成).ToList();
                        }
                        else
                        {
                            taskDetails = _unitWork.Find<TaskDetail>(u => u.ContainerCode == td.ContainerCode && u.Status >= TaskStatus.待下发任务 && u.Status < TaskStatus.已经完成).ToList();
                        }
                        if (sTKStatusModel.Status == 30)   //堆垛机出库完成容器到达站台
                        {
                            foreach (TaskDetail t in taskDetails)
                            {
                                if (t.TaskType == TaskType.容器出库 || t.TaskType == TaskType.空容器出库 || t.TaskType == TaskType.盘点)
                                {
                                    t.Status = TaskStatus.已经完成;   //更新托盘出库任务为已完成
                                    t.UpdateBy = "wms";
                                    t.UpdateTime = DateTime.Now;
                                    _unitWork.Update(t);
                                }
                                else if (t.TaskType == TaskType.站台到站台)
                                {
                                    t.Status = TaskStatus.已经完成;   //更新托盘出库任务为已完成
                                    t.UpdateBy = "wms";
                                    t.UpdateTime = DateTime.Now;
                                    _unitWork.Update(t);

                                    Station stationSource = _unitWork.Find<Station>(n => n.Code == t.SourceLocation).FirstOrDefault();
                                    if (stationSource != null)
                                    {
                                        if (stationSource.Containercode == td.ContainerCode)
                                        {
                                            stationSource.Containercode = "";
                                            _unitWork.Update(stationSource);
                                        }
                                    }
                                }
                                else if (t.TaskType == TaskType.直接出库)
                                {
                                    t.Status = TaskStatus.已经完成;   //更新托盘出库任务为已完成
                                    t.UpdateBy = "wms";
                                    t.UpdateTime = DateTime.Now;
                                    _unitWork.Update(t);
                                }
                                else
                                {
                                    if ((t.TaskType == TaskType.整盘出库 || t.TaskType == TaskType.分拣出库) && td.Station == t.Station)//出库任务类型
                                    {
                                        List<InventoryOut> inventoryOuts = _unitWork.Find<InventoryOut>(n => n.ContainerCode == t.ContainerCode && n.ShipmentState == 0).ToList();
                                        //判断出库任务是否为MES下发
                                        if (inventoryOuts.First().CreateBy == "Api")
                                        {
                                            ApiShipmentDetail ApiInvshipmentDetail = _unitWork.Find<ApiShipmentDetail>(u => u.ShipmentCode == inventoryOuts.First().ReceiptCode && u.Status == ShipmentHeaderStatus.分配完成).FirstOrDefault();
                                            if (ApiInvshipmentDetail != null)
                                            {
                                                ApiInterfaceLog ApiinterfaceLog = _unitWork.Find<ApiInterfaceLog>(n => n.TaskNo == ApiInvshipmentDetail.SourceCode).FirstOrDefault();
                                                if (ApiinterfaceLog != null)
                                                {
                                                    ApiinterfaceLog.ComNum = 1;
                                                    _unitWork.Update(ApiinterfaceLog);
                                                }
                                                ApiInvshipmentDetail.Status = ShipmentHeaderStatus.过账;
                                                ApiInvshipmentDetail.UpdateBy = "wms";
                                                ApiInvshipmentDetail.UpdateTime = DateTime.Now;
                                                _unitWork.Update(ApiInvshipmentDetail);
                                            }
                                            ApiShipmentHeader apiShipmentHeader = _unitWork.Find<ApiShipmentHeader>(n => n.SourceCode == t.SourceCode).FirstOrDefault();
                                            List<ApiShipmentDetail> apiShipmentDetail = _unitWork.Find<ApiShipmentDetail>(n => n.SourceCode == t.SourceCode).OrderBy(a => a.Status).ToList();
                                            apiShipmentHeader.FirstStatus = apiShipmentDetail.Last().Status;
                                            apiShipmentHeader.LastStatus = apiShipmentDetail.First().Status;
                                            _unitWork.Update(apiShipmentHeader);
                                            //更新库存出库记录表状态
                                            foreach (InventoryOut inventoryOut in inventoryOuts)
                                            {
                                                inventoryOut.ShipmentState = 1;
                                                _unitWork.Update(inventoryOut);
                                            }
                                        }
                                        else
                                        {
                                            foreach (InventoryOut inventoryOut in inventoryOuts)
                                            {
                                                inventoryOut.ShipmentState = 1;
                                                _unitWork.Update(inventoryOut);
                                                //更改出库明细状态
                                                //查找当前托盘的inventoryOut对应的出库单据明细，并将改明细状态修改
                                                ShipmentDetail InvshipmentDetail = _unitWork.Find<ShipmentDetail>(u => u.ShipmentCode == inventoryOut.ReceiptCode && u.Project == inventoryOut.QrCode && u.Status == ShipmentHeaderStatus.分配完成).FirstOrDefault();
                                                if (InvshipmentDetail != null)
                                                {
                                                    InterfaceLog interfaceLog = _unitWork.Find<InterfaceLog>(n => n.TaskNo == InvshipmentDetail.SourceCode).FirstOrDefault();
                                                    if (interfaceLog != null)
                                                    {
                                                        interfaceLog.ComNum += 1;
                                                        _unitWork.Update(interfaceLog);
                                                    }
                                                    InvshipmentDetail.Status = ShipmentHeaderStatus.过账;
                                                    InvshipmentDetail.UpdateBy = "wms";
                                                    InvshipmentDetail.UpdateTime = DateTime.Now;
                                                    _unitWork.Update(InvshipmentDetail);
                                                }
                                            }

                                            ShipmentHeader shipment = _unitWork
                                                .Find<ShipmentHeader>(n => n.SourceCode == t.SourceCode).FirstOrDefault();
                                            List<ShipmentDetail> shipmentDetails = _unitWork
                                                .Find<ShipmentDetail>(n => n.SourceCode == t.SourceCode).OrderBy(a => a.Status).ToList();
                                            shipment.FirstStatus = shipmentDetails.Last().Status;
                                            shipment.LastStatus = shipmentDetails.First().Status;
                                            _unitWork.Update(shipment);
                                        }

                                    }
                                }

                                t.Status = TaskStatus.已经完成;  //更新任务明细状态为已完成
                                t.UpdateBy = "wms";
                                t.UpdateTime = DateTime.Now;
                                _unitWork.Update(t);
                                //更新主任务头尾状态
                                Task task = _unitWork.Find<Task>(u => u.TaskNo == t.TaskNo).FirstOrDefault();
                                if (task == null)
                                {
                                    throw new Exception("任务主表:" + t.TaskNo + "不存在！");
                                }
                                // Task task = _unitWork.FindSingle<Task>(u => u.TaskNo == t.TaskNo);
                                TaskDetail tdel = _unitWork.Find<TaskDetail>(u => u.TaskNo == t.TaskNo).OrderBy(a => a.Status).FirstOrDefault();//同一个任务号下面最小的任务状态，包含其它容器的任务，用于更新主任务的尾状态
                                if (tdel == null)
                                {
                                    throw new Exception("任务子表:" + t.TaskNo + "不存在！");
                                }
                                if (task.FirstStatus < t.Status)
                                {
                                    task.FirstStatus = t.Status;
                                }
                                if (task.LastStatus < tdel.Status)
                                {
                                    task.LastStatus = tdel.Status;
                                }
                                task.UpdateBy = "wms";
                                task.UpdateTime = DateTime.Now;
                                _unitWork.Update(task);
                                //任务完成创建ERP单据过账数据
                                if (task.CreateBy == "HandTaskApi" && task.SourceCode != "")
                                {
                                    InterfaceLog inter = new InterfaceLog
                                    {
                                        Type = "ErpSourceCode",
                                        AllNum = 1,
                                        ComNum = 1,
                                        Request = "",
                                        Status = 0,
                                        TaskNo = task.SourceCode,
                                        CreateTime = DateTime.Now,
                                        CreateBy = "WMS"
                                    };
                                    _unitWork.Add(inter);
                                }
                                //已完成的单据任务迁移至历史任务表
                                if (task.LastStatus == TaskStatus.已经完成)
                                {
                                    TaskHistory taskhis = new TaskHistory();
                                    task.CopyTo(taskhis);
                                    taskhis.Id = null;
                                    _unitWork.Add(taskhis);

                                    List<TaskDetail> taskdtls = _unitWork.Find<TaskDetail>(u => u.TaskNo == task.TaskNo).ToList();
                                    foreach (TaskDetail tdl in taskdtls)
                                    {
                                        TaskDetailHistory taskdthis = new TaskDetailHistory();
                                        tdl.CopyTo(taskdthis);
                                        taskdthis.Id = null;
                                        _unitWork.Add(taskdthis);

                                        _unitWork.Delete(tdl);
                                    }
                                    _unitWork.Delete(task);
                                }
                            }

                            if (td.SourceLocation != "OutStationB07(P3300)" && (td.TaskType == TaskType.直接出库 || td.TaskType == TaskType.空容器出库 || td.TaskType == TaskType.容器出库 || td.TaskType == TaskType.站台到站台 || td.TaskType == TaskType.盘点))
                            {
                                //托盘出库完成，容器占用站台
                                Station st = _unitWork.Find<Station>(u => u.Code == td.Station).FirstOrDefault();
                                if (st == null)
                                {
                                    throw new Exception("站台:" + td.Station + "不存在！");
                                }
                                else if (st.IsOccupy == 0 && td.IsOccupy != 1 && td.ContainerCode == st.Containercode)
                                {
                                    st.Containercode = "";
                                }
                                else if (st.IsOccupy == 1 && td.IsOccupy != 0)
                                {
                                    st.Containercode = td.ContainerCode;
                                }
                                Container cont = _unitWork.Find<Container>(n => n.Code == td.ContainerCode && n.Code != "woodPallet").FirstOrDefault();
                                if (cont != null && td.TaskType != TaskType.盘点)
                                {
                                    if (td.TaskType != TaskType.站台到站台 && st.Type != StationType.暂存区站台)
                                    {
                                        cont.Status = "empty";
                                    }
                                    cont.Height = 0;
                                    cont.LocationCode = st.Code;
                                    _unitWork.Update(cont);
                                }
                                st.UpdateBy = "wms";
                                st.UpdateTime = DateTime.Now;
                                _unitWork.Update(st);
                                List<Inventory> inventories = new List<Inventory>();
                                if (td.ContainerCode == "empty")
                                {
                                    inventories = _unitWork.Find<Inventory>(n => n.Id == td.InventoryId).ToList();
                                }
                                else
                                {
                                    inventories = _unitWork.Find<Inventory>(n => n.ContainerCode == td.ContainerCode && n.ContainerCode != "woodPallet").ToList();
                                }
                                //暂存区出库完成更新库存状态并添加库存交易
                                if ((st.Type == StationType.暂存区站台) || td.TaskType == TaskType.盘点 || td.DestinationLocation == "ExitStationB02(P3328)")
                                {
                                    foreach (Inventory inv in inventories)
                                    {
                                        if (st.Type == StationType.暂存区站台)
                                        {
                                            inv.TaskStatus = InventoryTaskType.无任务;
                                        }
                                        inv.LocationCode = st.Code;
                                        _appi.UpdateByTracking(inv);
                                        InventoryTransaction inventoryTransaction = new InventoryTransaction
                                        {
                                            Type = TransactionType.出库,
                                            SourceCode = inv.SourceCode,
                                            UserDef1 = td.OrderCode,
                                            ContainerCode = inv.ContainerCode,
                                            Position = inv.Position,
                                            TaskSteps = inv.TaskSteps,
                                            MaterialCode = inv.MaterialCode,
                                            Batch = inv.Batch,
                                            Lot = inv.Lot,
                                            Qty = inv.Qty,
                                            QrCode = inv.QrCode,
                                            Supplier = inv.Supplier,
                                            ResidualWeight = inv.ResidualWeight,
                                            Retreat = inv.Retreat,
                                            Specification = inv.Specification,
                                            NameDescription = inv.NameDescription,
                                            Unit = inv.Unit,
                                            Size = inv.Size,
                                            NumberofSheets = inv.NumberofSheets,
                                            Groupnum = inv.Groupnum,
                                            OldBatch = inv.OldBatch,
                                            Combo = inv.Combo,
                                            Status = inv.Status,
                                            LocationCode = td.Station,
                                            StackingNumber = inv.StackingNumber,
                                            CreateTime = inv.CreateTime,
                                            UpdateBy = "IStackerStatusApp",
                                            UpdateTime = DateTime.Now
                                        };
                                        _unitWork.Add(inventoryTransaction);
                                    }
                                }
                                else
                                {
                                    //出库完成后删除库存并添加库存交易
                                    foreach (Inventory inv in inventories)
                                    {
                                        _unitWork.Delete(inv);
                                        InventoryTransaction inventoryTransaction = new InventoryTransaction
                                        {
                                            Type = TransactionType.出库,
                                            UserDef1 = td.OrderCode,
                                            SourceCode = inv.SourceCode,
                                            ContainerCode = inv.ContainerCode,
                                            Position = inv.Position,
                                            TaskSteps = inv.TaskSteps,
                                            MaterialCode = inv.MaterialCode,
                                            Batch = inv.Batch,
                                            Lot = inv.Lot,
                                            Qty = inv.Qty,
                                            QrCode = inv.QrCode,
                                            Supplier = inv.Supplier,
                                            ResidualWeight = inv.ResidualWeight,
                                            Retreat = inv.Retreat,
                                            Specification = inv.Specification,
                                            NameDescription = inv.NameDescription,
                                            Unit = inv.Unit,
                                            Size = inv.Size,
                                            NumberofSheets = inv.NumberofSheets,
                                            Groupnum = inv.Groupnum,
                                            OldBatch = inv.OldBatch,
                                            Combo = inv.Combo,
                                            Status = inv.Status,
                                            LocationCode = td.Station,
                                            StackingNumber = inv.StackingNumber,
                                            CreateTime = inv.CreateTime,
                                            UpdateTime = DateTime.Now,
                                            UpdateBy = "IStackerStatusApp"
                                        };
                                        _unitWork.Add(inventoryTransaction);
                                    }
                                }

                                if (td.TaskType != TaskType.盘点)
                                {
                                    //托盘出库完成，解锁并释放仓位
                                    Location loc = _unitWork.Find<Location>(u => u.Code == td.SourceLocation).FirstOrDefault();
                                    if (loc != null)
                                    {
                                        _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                                        {
                                            ContainerCode = "",
                                            Status = "empty",
                                            UpdateBy = "wms",
                                            UpdateTime = DateTime.Now
                                        });
                                    }
                                }
                            }

                            //   Response.Result = td;
                            //2楼木板到2楼叠盘机
                            else if (td.TaskType == TaskType.站台到站台 && td.SourceLocation == "OutStationB07(P3300)" && td.DestinationLocation == "InStationB06(P3316)")
                            {
                                StoreStation storeStation = _unitWork.Find<StoreStation>(n => n.ContainerCode == td.ContainerCode).FirstOrDefault();
                                if (storeStation != null)
                                {
                                    Container container = _unitWork.Find<Container>(n => n.Code == storeStation.ContainerCode).FirstOrDefault();
                                    if (container != null)
                                    {
                                        _unitWork.Delete(container);
                                    }
                                    storeStation.Status = StoreStationStatus.到达站台;
                                    storeStation.UpdateTime = DateTime.Now;
                                    _unitWork.Update(storeStation);
                                }
                            }

                            //空板补给
                            if (td.TaskType == TaskType.空容器出库)
                            {
                                StoreStation storeStation = _unitWork.Find<StoreStation>(n => n.ContainerCode == td.ContainerCode && n.Status == StoreStationStatus.任务中).FirstOrDefault();
                                if (storeStation != null)
                                {
                                    storeStation.Status = StoreStationStatus.到达站台;
                                    storeStation.UpdateTime = DateTime.Now;
                                    _unitWork.Update(storeStation);
                                }
                                TaskDetail tdPP = _unitWork.Find<TaskDetail>(n => n.TaskType == TaskType.站台到站台 && n.Status == TaskStatus.新建任务 && n.SourceLocation == td.Station && n.ContainerCode == td.ContainerCode).FirstOrDefault();
                                if (tdPP != null)
                                {
                                    tdPP.Status = TaskStatus.待下发任务;
                                    _unitWork.Update(tdPP);
                                    if (storeStation != null)
                                    {
                                        _unitWork.Delete(storeStation);
                                    }
                                }

                            }
                        }
                        else if (sTKStatusModel.Status == 40)  //堆垛机入库完成容器到达仓位
                        {
                            string locationStatus = ContainerStatus.有;
                            Container container = _unitWork.Find<Container>(u => u.Code == td.ContainerCode).FirstOrDefault();
                            foreach (TaskDetail t in taskDetails)
                            {
                                if (t.TaskType == TaskType.容器回库)
                                {
                                    t.Status = TaskStatus.已经完成;   //更新托盘入库任务为已完成
                                    t.UpdateBy = "wms";
                                    t.UpdateTime = DateTime.Now;
                                    _unitWork.Update(t);

                                    Task pintask = _unitWork.FindSingle<Task>(u => u.TaskNo == t.TaskNo);
                                    if (pintask == null)
                                    {
                                        throw new Exception("任务主表:" + t.TaskNo + "不存在！");
                                    }
                                    pintask.FirstStatus = TaskStatus.已经完成;
                                    pintask.LastStatus = TaskStatus.已经完成;
                                    pintask.UpdateBy = "wms";
                                    pintask.UpdateTime = DateTime.Now;
                                    _unitWork.Update(pintask);
                                    Station sta = _unitWork.Find<Station>(n => n.Code == t.SourceLocation).FirstOrDefault();

                                    //更新库存交易仓位
                                    List<InventoryTransaction> inventoryTransactions = _unitWork.Find<InventoryTransaction>(u => u.ContainerCode == t.ContainerCode && u.UserDef1 == t.TaskNo).ToList();
                                    if (inventoryTransactions.Count > 0)
                                    {
                                        foreach (InventoryTransaction i in inventoryTransactions)
                                        {
                                            i.LocationCode = t.DestinationLocation;
                                            i.UpdateTime = DateTime.Now;
                                            _unitWork.Update(i);
                                        }
                                    }


                                    //已完成的托盘入库任务迁移至历史任务表
                                    TaskHistory taskHistory = new TaskHistory();
                                    pintask.CopyTo(taskHistory);
                                    taskHistory.Id = null;
                                    _unitWork.Add(taskHistory);
                                    TaskDetailHistory taskDetailHistory = new TaskDetailHistory();
                                    t.CopyTo(taskDetailHistory);
                                    taskDetailHistory.Id = null;
                                    _unitWork.Add(taskDetailHistory);

                                    //删除已完成的托盘入库任务
                                    _unitWork.Delete(pintask);
                                    _unitWork.Delete(t);
                                }
                                else
                                {
                                    t.Status = TaskStatus.已经完成;  //更新任务明细状态为已完成
                                    t.UpdateBy = "wms";
                                    t.UpdateTime = DateTime.Now;
                                    _unitWork.Update(t);
                                    //更新主任务头尾状态
                                    Task task = _unitWork.Find<Task>(u => u.TaskNo == t.TaskNo).FirstOrDefault();
                                    if (task == null)
                                    {
                                        throw new Exception("任务主表:" + t.TaskNo + "不存在！");
                                    }
                                    // Task task = _unitWork.FindSingle<Task>(u => u.TaskNo == t.TaskNo);
                                    TaskDetail tdel = _unitWork.Find<TaskDetail>(u => u.TaskNo == t.TaskNo).OrderBy(a => a.Status).FirstOrDefault();//同一个任务号下面最小的任务状态，包含其它容器的任务，用于更新主任务的尾状态
                                    if (tdel == null)
                                    {
                                        throw new Exception("任务子表:" + t.TaskNo + "不存在！");
                                    }
                                    if (task.FirstStatus < t.Status)
                                    {
                                        task.FirstStatus = t.Status;
                                    }
                                    if (task.LastStatus < tdel.Status)
                                    {
                                        task.LastStatus = tdel.Status;
                                    }
                                    task.UpdateBy = "wms";
                                    task.UpdateTime = DateTime.Now;
                                    _unitWork.Update(task);

                                    //已完成的单据任务迁移至历史任务表
                                    if (task.LastStatus == TaskStatus.已经完成)
                                    {
                                        TaskHistory taskhis = new TaskHistory();
                                        task.CopyTo(taskhis);
                                        taskhis.Id = null;
                                        _unitWork.Add(taskhis);

                                        List<TaskDetail> taskdtls = _unitWork.Find<TaskDetail>(u => u.TaskNo == task.TaskNo).ToList();
                                        foreach (TaskDetail tdl in taskdtls)
                                        {
                                            TaskDetailHistory taskdthis = new TaskDetailHistory();
                                            tdl.CopyTo(taskdthis);
                                            taskdthis.Id = null;
                                            _unitWork.Add(taskdthis);

                                            _unitWork.Delete(tdl);
                                        }
                                        _unitWork.Delete(task);
                                    }

                                    if (t.TaskType == TaskType.整盘入库 || t.TaskType == TaskType.补充入库)//入库任务类型
                                    {
                                        //更新入库明细单据状态
                                        ReceiptDetail receiptDetail = _unitWork.Find<ReceiptDetail>(u => u.SourceCode == t.SourceCode && u.ReceiptCode == t.OrderCode && u.MaterialCode == t.MaterialCode && t.OderQty == t.HadQty).FirstOrDefault();
                                        if (receiptDetail != null)
                                        {
                                            receiptDetail.Status = ReceiptHeaderStatus.过账;
                                            receiptDetail.UpdateTime = DateTime.Now;
                                            _apprd.UpdateByTracking(receiptDetail);
                                            //更新入库主单据头尾状态
                                            // ReceiptHeader receiptHeader = _unitWork.Find<ReceiptHeader>(u => u.Code == t.OrderCode).FirstOrDefault();
                                            ReceiptHeader receiptHeader = _unitWork.Find<ReceiptHeader>(u => u.SourceCode == t.SourceCode).FirstOrDefault();
                                            ReceiptDetail recepdt = _unitWork.Find<ReceiptDetail>(u => u.SourceCode == t.SourceCode).OrderBy(a => a.Status).FirstOrDefault();
                                            if (receiptHeader.FirstStatus < receiptDetail.Status)
                                            {
                                                receiptHeader.FirstStatus = receiptDetail.Status;
                                            }
                                            if (receiptHeader.LastStatus < recepdt.Status)
                                            {
                                                receiptHeader.LastStatus = recepdt.Status;
                                            }
                                            receiptHeader.UpdateTime = DateTime.Now;
                                            _apprh.UpdateByTracking(receiptHeader);
                                        }
                                    }
                                    else if (t.TaskType == TaskType.空容器入库) //空容器入库任务类型
                                    {
                                        container.Status = ContainerStatus.空;
                                        if (container.Type == ContainerType.空托盘组)
                                        {
                                            locationStatus = LocationStatus.空容器组;
                                        }
                                        else
                                        {
                                            locationStatus = LocationStatus.空容器;
                                        }
                                    }
                                    else if (t.TaskType == TaskType.移库)
                                    {
                                        if (container.Status == ContainerStatus.空 && container.Type == ContainerType.普通栈板)
                                        {
                                            locationStatus = LocationStatus.空容器;
                                        }
                                        else if (container.Status == ContainerStatus.空 && container.Type == ContainerType.空托盘组)
                                        {
                                            locationStatus = LocationStatus.空容器组;
                                        }
                                    }
                                    else
                                    {
                                        throw new Exception("未知任务类型:" + t.TaskType);
                                    }
                                }
                            }

                            //清除该托盘占用的站台
                            Station s = _unitWork.Find<Station>(n => n.Code == td.SourceLocation && n.Containercode == td.ContainerCode && (td.TaskType == TaskType.容器回库 || td.TaskType == TaskType.空容器入库)).FirstOrDefault();
                            if (s != null)
                            {
                                s.Containercode = "";
                                _unitWork.Update(s);
                            }
                            //托盘入库完成，解锁并释放仓位
                            Location Fromloc = _unitWork.Find<Location>(u => u.Code == td.SourceLocation && u.ContainerCode == td.ContainerCode).FirstOrDefault();
                            Location loc = _unitWork.Find<Location>(u => u.Code == td.DestinationLocation).FirstOrDefault();
                            if (loc == null)
                            {
                                throw new Exception("目的仓位:" + td.DestinationLocation + "不存在！");
                            }
                            if(Fromloc != null && td.TaskType == TaskType.移库)
                            {
                                int fromiLoc = _unitWork.Update<Location>(n => n.Id == Fromloc.Id && n.Version == Fromloc.Version, n => new Location
                                {
                                    ContainerCode = "",
                                    Status = "empty",
                                    UpdateBy = "wcs",
                                    UpdateTime = DateTime.Now
                                });
                            }

                            int iLoc = _unitWork.Update<Location>(n => n.Id == loc.Id && n.Version == loc.Version, n => new Location
                            {
                                ContainerCode = td.ContainerCode,
                                Status = locationStatus,
                                UpdateBy = "wms",
                                UpdateTime = DateTime.Now
                            });

                            List<Inventory> inventories = _unitWork.Find<Inventory>(n => n.ContainerCode == td.ContainerCode && n.Status != "cyclecountLock").ToList();
                            //更新同个容器中其它物料对应新的回库仓位
                            if (inventories.Count > 0)
                            {
                                foreach (Inventory inv in inventories)
                                {
                                    if (loc.Roadway == 1)
                                    {
                                        inv.WarehouseType = "TB_WareCell";
                                    }
                                    else if (loc.Roadway == 2)
                                    {
                                        inv.WarehouseType = "PP_WareCell";
                                    }
                                    else if (loc.Roadway == 3)
                                    {
                                        inv.WarehouseType = "PJ_WareCell";
                                    }

                                    if (inv.LocationCode != loc.Code)
                                    {
                                        inv.LocationCode = loc.Code;
                                    }

                                    if (inv.TaskStatus == InventoryTaskType.任务锁定中)
                                    {
                                        inv.TaskStatus = InventoryTaskType.无任务;
                                    }
                                    _appi.UpdateByTracking(inv);
                                    //判断入库物料单据是从ERP来还是从MES来
                                    if (inv.SourceCode.Contains("&"))
                                    {
                                        InterfaceLog inter = _unitWork.Find<InterfaceLog>(n => n.TaskNo == inv.SourceCode && n.Status != 1).FirstOrDefault();
                                        if (inter != null)
                                        {
                                            inter.ComNum += 1;
                                            _unitWork.Update(inter);
                                        }
                                    }
                                    else
                                    {
                                        ApiInterfaceLog inter = _unitWork.Find<ApiInterfaceLog>(n => n.TaskNo == inv.SourceCode && n.Status != 1).FirstOrDefault();
                                        if (inter != null)
                                        {
                                            inter.ComNum += 1;
                                            _unitWork.Update(inter);
                                        }
                                    }
                                }

                            }
                            //托盘入库完成，解锁并释放容器
                            if (container == null)
                            {
                                throw new Exception("容器:" + td.ContainerCode + "不存在！");
                            }
                            container.LocationCode = td.DestinationLocation;
                            container.IsLock = ContainerLock.未锁;
                            container.UpdateBy = "wms";
                            container.UpdateTime = DateTime.Now;
                            _unitWork.Update(container);
                        }
                        else
                        {
                            Response.Code = 500;
                            Response.Status = false;
                            Response.Message = "不识别的任务状态！";
                        }
                    }
                    else
                    {
                        Response.Code = 500;
                        Response.Status = false;
                        Response.Message = "获取任务号错误，未找到此容器的任务！";
                    }
                    tran.Commit();
                }
                catch (Exception ex)
                {
                    tran.Rollback();
                    Response.Code = 500;
                    Response.Status = false;
                    Response.Message = ex.Message;
                }

                return Response;
            }
        }
    }
}