JYHB-WCS/src/Khd.Core.Wcs/Wcs/FiveFloorAGV.cs

using Khd.Core.Domain.Dto.TaskType;
using Khd.Core.Domain.Dto.waring;
using Khd.Core.Domain.Dto.webapi;
using Khd.Core.Domain.Models;
using Khd.Core.EntityFramework;
using Khd.Core.Library;
using Khd.Core.Library.Mapper;
using Khd.Core.Plc.S7;
using Khd.Core.Wcs.Global;
using Masuit.Tools;
using Microsoft.AspNetCore.Razor.Language;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Newtonsoft.Json;
using Z.EntityFramework.Plus;

namespace Khd.Core.Wcs.Wcs
{
    /// <summary>
    /// 五楼AGV调度
    /// </summary>
    public class FiveFloorAGV
    {
        private readonly LoggerUtils _logger = new LoggerUtils();
        private readonly IHost _host;
        private readonly BasePlcpoint LineSignal;
        int FloorNo { get; set; }
        int agvID = 28;
        public FiveFloorAGV(IHost host, int floor)
        {
            this._host = host;
            FloorNo = floor;
            this.LineSignal = StaticData.BasePlcpointList.First(t => t.plcpointNo == "linesignal05");
        }
        /// <summary>
        /// 启动上件扫描监听
        /// </summary>
        public void StartPoint()
        {
            Thread FlowPointThread = new(MonitorInLocatorPoint);
            FlowPointThread.IsBackground = true;
            FlowPointThread.Name = "FiveFloorAGV";
            FlowPointThread.Start();
            Console.WriteLine(DateTime.Now + ":五楼AGV上件扫描监听启动成功");
            _logger.Info("五楼AGV上件扫描监听启动成功");
        }

        public void MonitorInLocatorPoint()
        {
            using var scope = _host.Services.CreateScope();
            using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
            BaseEquip baseEquip = StaticData.BaseEquip.First(t => t.objid == agvID);
            while (true)
            {
                try
                {
                    dbContext.ChangeTracker.Clear();
                    var taskList = dbContext.WcsTask
                        .Where(t => t.useFlag == 1)
                        .Where(t => t.IsDelete == 0 || t.IsDelete == null)
                        .Where(t => t.nextPointId == agvID).OrderBy(t => t.createTime).ToList();
                    foreach (var item in taskList)
                    {
                        if (taskList.Where(t => t.taskStatus > 0).Where(t => t.objid != item.objid).Any())
                        {
                            _logger.Info($"5楼AGV线程：有其他任务正在执行，跳过当前任务{item.objid}");
                            continue;
                        }
                        item.updateTime = DateTime.Now;
                        if (item.taskStatus == 0)//下发任务
                        {
                            BaseDictionary baseDictionary = StaticData.BaseDictionary.First(t => t.objid == item.taskType);
                            if (item.taskType == StaticTaskType.FiveProductOut)//出库任务
                            {
                                BaseEquip lineEquip = dbContext.BaseEquip.First(t => t.objid == 5);
                                if (lineEquip.equipStatus == 0)
                                {
                                    bool canSend = dbContext.WcsTask.Where(t => t.nextPointId == lineEquip.objid && t.taskStatus > 0).Any();
                                    if (lineEquip.equipStatus == 1)
                                    {
                                        _logger.Info("五楼AGV:接驳位有任务，无法下发出库任务");
                                        continue;
                                    }
                                    if (Convert.ToInt32(StaticData.PlcDic[0].Read(LineSignal.plcpointAddress)) == 1 && !canSend)
                                    {
                                        Console.WriteLine($"{DateTime.Now}:5楼接驳位上有货，无法下发Agv出库任务");
                                        continue;
                                    }
                                    BaseEquip nextEquip = StaticData.BaseEquip.First(t => t.floorNo == 5 && t.equipType == 1);
                                    RequestAGVTaskDto agvTask = new()
                                    {
                                        reqCode = StaticData.SnowId.NextId().ToString(),
                                        positionCodePath = new List<Position>
                                        {
                                            new ()
                                            {
                                                positionCode=item.currPointNo,
                                                type="00"
                                            },
                                            new ()
                                            {
                                                positionCode=nextEquip.agvPositionCode,
                                                type="00"
                                            }
                                        },
                                        taskTyp = baseDictionary.dicValue,
                                        ctnrTyp = "2"
                                    };

                                    string message = JsonConvert.SerializeObject(agvTask);
                                    string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                    var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                    if (reponseMessage != null && reponseMessage.message == "成功")
                                    {
                                        _logger.Info("五楼Agv下发任务成功：" + message);
                                        Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + item.currPointNo + "," + nextEquip.agvPositionCode);
                                        item.taskCode = reponseMessage.data;
                                        item.taskStatus = 1;
                                        lineEquip.equipStatus = 1;
                                        dbContext.Update(lineEquip);
                                        dbContext.Update(item);
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 1 });
                                        dbContext.SaveChanges();
                                    }
                                    else
                                    {
                                        _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                    }

                                }
                                else
                                {
                                    continue;
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveStockReturnTask)//退库任务
                            {
                                BaseEquip lineEquip = dbContext.BaseEquip.First(t => t.objid == 5);
                                if (lineEquip.equipStatus == 0)
                                {
                                    bool canSend = dbContext.WcsTask.Where(t => t.nextPointId == lineEquip.objid && t.taskStatus > 0).Any();
                                    if (lineEquip.equipStatus == 1)
                                    {
                                        _logger.Info("五楼AGV:接驳位有任务，无法下发出库任务");
                                        continue;
                                    }
                                    if (Convert.ToInt32(StaticData.PlcDic[0].Read(LineSignal.plcpointAddress)) == 1 && !canSend)
                                    {
                                        Console.WriteLine($"{DateTime.Now}:5楼接驳位上有货，无法下发Agv出库任务");
                                        continue;
                                    }
                                    BaseEquip nextEquip = StaticData.BaseEquip.First(t => t.floorNo == 5 && t.equipType == 1);
                                    RequestAGVTaskDto agvTask = new()
                                    {
                                        reqCode = StaticData.SnowId.NextId().ToString(),
                                        positionCodePath = new List<Position>
                                        {
                                            new ()
                                            {
                                                positionCode=item.currPointNo,
                                                type="00"
                                            },
                                            new ()
                                            {
                                                positionCode=nextEquip.agvPositionCode,
                                                type="00"
                                            }
                                        },
                                        taskTyp = baseDictionary.dicValue,
                                        ctnrTyp = "2"
                                    };

                                    string message = JsonConvert.SerializeObject(agvTask);
                                    string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                    var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                    if (reponseMessage != null && reponseMessage.message == "成功")
                                    {
                                        _logger.Info("五楼Agv下发任务成功：" + message);
                                        Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + item.currPointNo + "," + nextEquip.agvPositionCode);
                                        item.taskCode = reponseMessage.data;
                                        item.taskStatus = 1;
                                        lineEquip.equipStatus = 1;
                                        dbContext.Update(lineEquip);
                                        dbContext.Update(item);
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 1 });
                                        dbContext.SaveChanges();
                                    }
                                    else
                                    {
                                        _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                    }

                                }
                                else
                                {
                                    continue;
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveRawToBack)//原材料到背板安装
                            {
                                BaseEquip endEquip = StaticData.BaseEquip.First(t => t.objid == 30);
                                RequestAGVTaskDto agvTask = new()
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new ()
                                        {
                                            positionCode=item.currPointNo,
                                            type="00"
                                        },
                                        new ()
                                        {
                                            positionCode= endEquip.agvPositionCode,
                                            type="00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2"
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + item.currPointNo + "," + endEquip.agvPositionCode);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveHalfIn)//背板安装到半成品
                            {
                                BaseEquip currentEquip = StaticData.BaseEquip.First(t => t.objid == 30);
                                var agvTask = new RequestAGVTaskDto
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new ()
                                        {
                                            positionCode=currentEquip.agvPositionCode,
                                            type="00"
                                        },
                                        new ()
                                        {
                                            positionCode=item.endPointNo,
                                            type="00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2",
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + currentEquip.agvPositionCode + "," + item.endPointNo);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog() { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveRawToSplit)//原材料到拆分区
                            {
                                BaseEquip currentEquip = StaticData.BaseEquip.First(t => t.objid == 29);
                                RequestAGVTaskDto agvTask = new()
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new ()
                                        {
                                            positionCode=item.currPointNo,
                                            type="00"
                                        },
                                        new ()
                                        {
                                            positionCode=currentEquip.agvPositionCode,
                                            type="00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2"
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + item.currPointNo + "," + currentEquip.agvPositionCode);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveRawSplitReturn)//拆分区返库
                            {
                                BaseEquip currentEquip = StaticData.BaseEquip.First(t => t.objid == 29);
                                RequestAGVTaskDto agvTask = new()
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new()
                                        {
                                            positionCode = currentEquip.agvPositionCode,
                                            type = "00"
                                        },
                                        new()
                                        {
                                            positionCode = item.endPointNo,
                                            type = "00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2"

                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + currentEquip.agvPositionCode + "," + item.endPointNo);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveRawIn)//原材料入库
                            {
                                BaseEquip startEquip = StaticData.BaseEquip.First(t => t.objid == 5);
                                var agvTask = new RequestAGVTaskDto
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new ()
                                        {
                                            positionCode= startEquip.agvPositionCode,
                                            type="00"
                                        },
                                        new ()
                                        {
                                            positionCode=item.endPointNo,
                                            type="00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2",
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + startEquip.agvPositionCode + "," + item.endPointNo);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog() { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                            else if (item.taskType == StaticTaskType.FiveRemove)//移库
                            {
                                var agvTask = new RequestAGVTaskDto
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    positionCodePath = new List<Position>
                                    {
                                        new ()
                                        {
                                            positionCode=item.currPointNo,
                                            type="00"
                                        },
                                        new ()
                                        {
                                            positionCode=item.endPointNo,
                                            type="00"
                                        }
                                    },
                                    taskTyp = baseDictionary.dicValue,
                                    ctnrTyp = "2",
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/genAgvSchedulingTask", message);
                                var reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv下发任务成功：" + item.currPointNo + "," + item.endPointNo);
                                    item.taskCode = reponseMessage.data;
                                    item.taskStatus = 1;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog() { taskStatus = 1 });
                                    dbContext.SaveChanges();
                                }
                                else
                                {
                                    _logger.Info("五楼Agv下发任务失败" + item.taskType + result);
                                }
                            }
                        }
                        else
                        {
                            if (item.taskStatus == 3)
                            {
                                if (item.currPointId == 5)
                                {
                                    var lineSignalValue = StaticData.PlcDic[0].Read(LineSignal.plcpointAddress);
                                    if (lineSignalValue == null || Convert.ToInt32(lineSignalValue) == 0)
                                    {
                                        Console.WriteLine(DateTime.Now + ":五楼Agv：接驳位为空，无法取货");
                                        _logger.Info("五楼Agv：接驳位为空，无法取货");
                                        continue;
                                    }
                                }
                                else if (item.endPointId == 5)
                                {
                                    var lineSignalValue = StaticData.PlcDic[0].Read(LineSignal.plcpointAddress);
                                    var wcsrun = StaticData.PlcDic[0].Read(StaticData.BasePlcpointList.First(t => t.plcpointNo == "wcsrun03").plcpointAddress);
                                    if (lineSignalValue == null || Convert.ToInt32(lineSignalValue) == 1 || wcsrun == null || wcsrun.ToString() != "0")
                                    {
                                        Console.WriteLine(DateTime.Now + ":五楼Agv：接驳位有货，无法送货");
                                        _logger.Info("五楼Agv：接驳位有货，无法送货");
                                        continue;
                                    }
                                }
                                var agvTask = new RequestAGVTaskDto
                                {
                                    reqCode = StaticData.SnowId.NextId().ToString(),
                                    taskCode = item.taskCode
                                };
                                string message = JsonConvert.SerializeObject(agvTask);
                                string result = HttpHelper.SendPostMessage(baseEquip.serverIp, baseEquip.serverPort.Value, "rcms/services/rest/hikRpcService/continueTask", message);
                                ReponseMessage? reponseMessage = JsonConvert.DeserializeObject<ReponseMessage>(result);
                                if (reponseMessage != null && reponseMessage.message == "成功")
                                {
                                    _logger.Info("五楼Agv下发继续任务成功：" + message);
                                    Console.WriteLine(DateTime.Now + ":五楼Agv继续任务：" + item.currPointNo + "," + item.endPointNo);
                                    item.taskStatus = 4;
                                    dbContext.Update(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog() { taskStatus = 4 });
                                    dbContext.SaveChanges();
                                }
                            }
                            else if (item.taskStatus == 5)
                            {
                                if (item.taskType == StaticTaskType.FiveRemove)//移库
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    WmsProductStock? wmsProductStock = null;
                                    var wmsRawStock = dbContext.WmsRawStock.Where(t => t.locationCode == item.currPointNo).FirstOrDefault();
                                    if (wmsRawStock != null)
                                    {
                                        wmsRawStock.locationCode = item.endPointNo;
                                        dbContext.Update(wmsRawStock);
                                    }
                                    else if (wmsRawStock == null)
                                    {
                                        wmsProductStock = dbContext.WmsProductStock.FirstOrDefault(t => t.locationCode == item.currPointNo);
                                        if (wmsProductStock != null)
                                        {
                                            wmsProductStock.locationCode = item.endPointNo;
                                            dbContext.Update(wmsProductStock);
                                        }
                                        else
                                        {
                                            continue;
                                        }
                                    }
                                    else
                                    {
                                        continue;
                                    }
                                    WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.Where(t => t.locationId == item.currPointId).First();
                                    WmsBaseLocation toLocation = dbContext.WmsBaseLocation.Where(t => t.locationId == item.endPointId).First();
                                    SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                    SystemData.UnLockOutLocation(toLocation, dbContext);
                                    dbContext.WmsBaseLocation.Where(t => t.locationId == wmsBaseLocation.locationId)
                                        .Update(t => new WmsBaseLocation() { containerCode = null, updateTime = DateTime.Now, locationStatus = "1", returnFlag = "0" });
                                    dbContext.WmsBaseLocation.Where(t => t.locationId == toLocation.locationId)
                                        .Update(t => new WmsBaseLocation { containerCode = item.containerNo, updateTime = DateTime.Now, locationStatus = "1", returnFlag = wmsBaseLocation.returnFlag });

                                    //dbContext.WmsBaseLocation.Where(t => t.locationId == item.currPointId).Update(t => new WmsBaseLocation
                                    //{
                                    //    returnFlag = "0",
                                    //    locationStatus = "1",
                                    //    containerCode = null,
                                    //    updateTime = DateTime.Now
                                    //});
                                    //dbContext.WmsBaseLocation.Where(t => t.locationId == item.endPointId).Update(t => new WmsBaseLocation
                                    //{
                                    //    locationStatus = "1",
                                    //    returnFlag = wmsBaseLocation.returnFlag,
                                    //    containerCode = item.containerNo,
                                    //    updateTime = DateTime.Now
                                    //});

                                    dbContext.Remove(item);
                                    dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog() { taskStatus = 6 });
                                    #region 插入移库记录
                                    var wmsMove = dbContext.WmsMove.Where(t => t.MoveId == item.orderId).FirstOrDefault();
                                    if (wmsMove == null)
                                    {
                                        wmsMove = new WmsMove();
                                        wmsMove.MoveId = StaticData.SnowId.NextId();
                                        wmsMove.TaskCode = StaticData.SnowId.NextId().ToString();
                                        wmsMove.WarehouseId = wmsBaseLocation.warehouseId;
                                        wmsMove.OriLocationCode = wmsBaseLocation.locationCode;
                                        wmsMove.TargetLocationCode = toLocation.locationCode;
                                        wmsMove.InstockBatch = wmsRawStock == null ? wmsProductStock.productBatch : wmsRawStock.instockBatch;
                                        wmsMove.MaterialId = wmsRawStock == null ? wmsProductStock.productId : wmsRawStock.materialId;
                                        wmsMove.PlanAmount = 1;
                                        wmsMove.RealOutstockAmount = 1;
                                        wmsMove.RealInstockAmount = 1;
                                        wmsMove.OperationType = "3";
                                        wmsMove.MoveWay = "2";
                                        wmsMove.MoveType = "1";
                                        wmsMove.AuditStatus = "1";
                                        wmsMove.ExecuteStatus = "2";
                                        wmsMove.UpdateBy = "WCS";
                                        wmsMove.UpdateDate = DateTime.Now;
                                        wmsMove.BeginTime = DateTime.Now;
                                        wmsMove.EndTime = DateTime.Now;
                                        dbContext.WmsMove.Add(wmsMove);
                                    }
                                    else
                                    {
                                        wmsMove.RealOutstockAmount += 1;
                                        wmsMove.EndTime = DateTime.Now;
                                        wmsMove.UpdateDate = DateTime.Now;
                                        wmsMove.UpdateBy = "WCS";
                                        wmsMove.ExecuteStatus = "2";
                                        dbContext.Update(wmsMove);
                                    }
                                    WmsMoveDetail wmsMoveDetail = new WmsMoveDetail();
                                    wmsMoveDetail.MoveId = wmsMove.MoveId;
                                    wmsMoveDetail.MaterialBarcode = wmsMove.InstockBatch;
                                    wmsMoveDetail.InstockBatch = wmsMove.InstockBatch;
                                    wmsMoveDetail.MaterialId = wmsRawStock == null ? (long)wmsProductStock.productId : (long)wmsRawStock.materialId;
                                    wmsMoveDetail.LocationCode = toLocation.locationCode;
                                    wmsMoveDetail.PlanAmount = 1;
                                    wmsMoveDetail.RealInstockAmount = 1;
                                    wmsMoveDetail.RealAmount = 1;
                                    wmsMoveDetail.ExecuteStatus = "2";
                                    wmsMoveDetail.ExecuteTime = DateTime.Now;
                                    wmsMoveDetail.ExecuteEndTime = DateTime.Now;
                                    wmsMoveDetail.ExecutePerson = "WCS";
                                    wmsMoveDetail.UpdateBy = "WCS";
                                    wmsMoveDetail.UpdateDate = DateTime.Now;

                                    dbContext.WmsMoveDetail.Add(wmsMoveDetail);
                                    #endregion
                                    dbContext.SaveChanges();
                                    SystemData.SendPlcLocation(wmsBaseLocation);
                                    SystemData.SendPlcLocation(toLocation);

                                }
                                else if (item.taskType == StaticTaskType.FiveProductOut)//出库
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());

                                    var wmsProductOutstock = dbContext.WmsProductOutstock.FirstOrDefault(t => t.productOutstockId == item.orderId);

                                    if (wmsProductOutstock != null)
                                    {
                                        var wmsBaseLocation = dbContext.WmsBaseLocation.Where(t => t.locationId == item.currPointId).First();
                                        WmsProductStock wmsProductStock = dbContext.WmsProductStock.First(t => t.locationCode == wmsBaseLocation.locationCode);


                                        wmsProductOutstock.outstockQty += 1;
                                        if (wmsProductOutstock.applyQty <= wmsProductOutstock.outstockQty)
                                        {
                                            wmsProductOutstock.endTime = DateTime.Now;
                                            wmsProductOutstock.executeStatus = "2";
                                        }
                                       
                                        WmsProductOutstockDetail? wmsProductOutstockDetail = dbContext.WmsProductOutstockDetail.FirstOrDefault(x => x.productOutstockId == wmsProductOutstock.productOutstockId && x.locationCode == item.currPointId.ToString());
                                        if (wmsProductOutstockDetail != null)
                                        {  //人工出库，mes会自动插入，wcs只需要更新即可
                                            wmsProductOutstockDetail.outstockAmount = 1;
                                            wmsProductOutstockDetail.executeStatus = "2";
                                            wmsProductOutstockDetail.updateDate = DateTime.Now;
                                            wmsProductOutstockDetail.endTime = DateTime.Now;
                                            dbContext.Update(wmsProductOutstockDetail);
                                        }
                                        else
                                        {
                                            wmsProductOutstockDetail = new WmsProductOutstockDetail();
                                            wmsProductOutstockDetail.productOutstockId = wmsProductOutstock.productOutstockId;
                                            wmsProductOutstockDetail.warehouseId = wmsProductOutstock.warehouseId;
                                            wmsProductOutstockDetail.locationCode = wmsBaseLocation.locationCode;
                                            wmsProductOutstockDetail.productBarcode = wmsProductStock.productBatch;
                                            wmsProductOutstockDetail.productId = wmsProductStock.productId;
                                            wmsProductOutstockDetail.planAmount = wmsProductOutstock.applyQty;
                                            wmsProductOutstockDetail.outstockAmount = wmsProductOutstock.outstockQty;
                                            wmsProductOutstockDetail.executeStatus = "2";
                                            wmsProductOutstockDetail.updateBy = "WCS";
                                            wmsProductOutstockDetail.updateDate = DateTime.Now;
                                            wmsProductOutstockDetail.beginTime = DateTime.Now;
                                            wmsProductOutstockDetail.endTime = DateTime.Now;
                                            dbContext.Add(wmsProductOutstockDetail);
                                        }
                                        wmsBaseLocation.locationStatus = "1";
                                        wmsBaseLocation.containerCode = null;
                                        wmsBaseLocation.updateTime = DateTime.Now;
                                        wmsBaseLocation.updateBy = "WCS";

                                        SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                        dbContext.Update(wmsBaseLocation);
                                        dbContext.WmsProductStock.Where(t => t.locationCode == wmsBaseLocation.locationCode).Delete();
                                        BaseEquip floorLineEquip = StaticData.BaseEquip.First(t => t.equipType == 1 && t.floorNo == 5);
                                        WcsTask newTask = CoreMapper.Map<WcsTask>(item);
                                        newTask.createTime = DateTime.Now;
                                        newTask.nextPointId = floorLineEquip.objid;
                                        newTask.nextPointNo = floorLineEquip.equipNo;
                                        newTask.fromFloorNo = 5;
                                        newTask.floorNo = 1;
                                        newTask.taskStatus = 6;
                                        newTask.objid = StaticData.SnowId.NextId();     
                                        dbContext.Remove(item);
                                        dbContext.Add(newTask);
                                        WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(newTask);
                                        dbContext.Add(wcsTaskLog);
                                        dbContext.SaveChanges();
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                        SystemData.SendPlcLocation(wmsBaseLocation);
                                    }
                                }
                                else if (item.taskType == StaticTaskType.FiveRawToBack)//原材料到背板安装
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    WmsRawOutstock? wmsRawOutstock = dbContext.WmsRawOutstock.Where(t => t.rawOutstockId == item.orderId).FirstOrDefault();
                                  
                                    if (wmsRawOutstock != null)
                                    {

                                        wmsRawOutstock.realOutstockAmount += 1;
                                        wmsRawOutstock.executeStatus = "2";
                                        wmsRawOutstock.endTime = DateTime.Now;

                                        WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.First(t => t.locationId == item.currPointId);
                                        wmsBaseLocation.returnFlag = "0";
                                        wmsBaseLocation.locationStatus = "1";
                                        wmsBaseLocation.containerCode = null;
                                        wmsBaseLocation.updateTime = DateTime.Now;
                                        wmsBaseLocation.updateBy = "WCS";

                                        WmsRawStock wmsRawStock =   dbContext.WmsRawStock.FirstOrDefault(t => t.locationCode == wmsBaseLocation.locationCode);


                                        WmsRawOutstockDetail newWmsRawOutstockDetail = new WmsRawOutstockDetail();
                                        newWmsRawOutstockDetail.rawOutstockId = wmsRawOutstock.rawOutstockId;
                                        newWmsRawOutstockDetail.taskCode = wmsRawOutstock.taskCode;
                                        newWmsRawOutstockDetail.warehouseId = wmsRawOutstock.warehouseId;
                                        newWmsRawOutstockDetail.locationCode = wmsRawOutstock.locationCode;
                                        newWmsRawOutstockDetail.materialBarcode = wmsRawOutstock.materialBatch;
                                        newWmsRawOutstockDetail.materialId = wmsRawOutstock.materialId;

                                        if (wmsRawStock != null)
                                        {
                                            MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == wmsRawStock.instockBatch).FirstOrDefault();
                                            if (mesBaseBarcodeInfo != null)
                                            {
                                                newWmsRawOutstockDetail.instockBatch = mesBaseBarcodeInfo.batchCode;
                                                newWmsRawOutstockDetail.materialProductionDate = mesBaseBarcodeInfo.productionDate;
                                            }
                                        }

                                        newWmsRawOutstockDetail.planAmount = wmsRawOutstock.outstockAmount;
                                        newWmsRawOutstockDetail.outstockAmount = wmsRawOutstock.realOutstockAmount;
                                        newWmsRawOutstockDetail.executeStatus = "2";
                                        newWmsRawOutstockDetail.outstockPerson = wmsRawOutstock.applyBy;
                                        newWmsRawOutstockDetail.outstockTime = DateTime.Now;
                                        newWmsRawOutstockDetail.outstockWay = "2";
                                        newWmsRawOutstockDetail.createBy = "WCS";
                                        newWmsRawOutstockDetail.createDate = DateTime.Now;
                                        newWmsRawOutstockDetail.stackAmount = 1;


                                        SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                        dbContext.Add(newWmsRawOutstockDetail);
                                        dbContext.Update(wmsRawOutstock);
                                        dbContext.Update(wmsBaseLocation);
                                        dbContext.WmsRawStock.Where(t => t.locationCode == wmsBaseLocation.locationCode).Delete();
                                        dbContext.Remove(item);
                                        if (wmsRawStock != null)
                                        {
                                            dbContext.Remove(wmsRawStock);
                                        }
                                        dbContext.SaveChanges();
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                        SystemData.SendPlcLocation(wmsBaseLocation);
                                    }
                                }
                                else if (item.taskType == StaticTaskType.FiveHalfIn)//半成品入库
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.First(t => t.locationId == item.endPointId);
                                    wmsBaseLocation.locationStatus = "1";
                                    wmsBaseLocation.containerCode = item.containerNo;
                                    wmsBaseLocation.updateTime = DateTime.Now;
                                    wmsBaseLocation.updateBy = "WCS";
                                    var mesBasePalletInfo = dbContext.MesBasePalletInfo.Where(t => t.palletInfoCode == item.containerNo).FirstOrDefault();
                                    var wmsProductInstock = dbContext.WmsProductInstock
                                        .Where(t => t.executeStatus == "1" && t.productType == "2" && t.warehouseId == 521).OrderByDescending(x=>x.applyDate)
                                        .FirstOrDefault();
                                    if (mesBasePalletInfo != null && wmsProductInstock != null)
                                    {
                                        //WmsProductInstockDetail? wmsProductInstockDetail = dbContext.WmsProductInstockDetail.Where(t => t.productInstockId == wmsProductInstock.productInstockId).FirstOrDefault();
                                        //if (wmsProductInstockDetail != null)
                                        //{
                                        wmsProductInstock.executeStatus = "2";
                                        wmsProductInstock.endTime = DateTime.Now;
                                        dbContext.Update(wmsProductInstock);
                                        WmsProductStock wmsProductStock = new WmsProductStock()
                                        {
                                            productId = wmsProductInstock.productId,
                                            activeFlag = "1",
                                            updateBy = "WCS",
                                            updateDate = DateTime.Now,
                                            saleorderCode = wmsProductInstock.saleorderCode,
                                            saleOrderId = wmsProductInstock.SaleOrderId == null ? 0 : wmsProductInstock.SaleOrderId,
                                            stockType = "2",
                                            productStockId = wmsProductInstock.productInstockId,
                                            qualityStatus = "0",
                                            createBy = "WCS",
                                            createDate = DateTime.Now,
                                            locationCode = wmsBaseLocation.locationCode,
                                            warehouseFloor = 5,
                                            totalAmount = 1,
                                            instockDate = DateTime.Now,
                                            productBatch = mesBasePalletInfo.materialBarcode,
                                            palletInfoCode = mesBasePalletInfo.palletInfoCode,
                                            frozenAmount = 0,
                                            occupyAmount = 0,
                                            planCode = wmsProductInstock.planCode,
                                            planDetailCode = wmsProductInstock.planDetailCode,
                                            warehouseId = 521
                                        };
                                        BaseEquip startEquip = StaticData.BaseEquip.First(t => t.objid == item.currPointId);
                                        //wmsProductInstockDetail.executeStatus = "2";
                                        //wmsProductInstockDetail.instockDate = DateTime.Now;
                                        startEquip.emptyCount = 0;
                                        //dbContext.Update(wmsProductInstockDetail);
                                        dbContext.Update(startEquip);
                                        dbContext.Add(wmsProductStock);
                                        dbContext.Update(wmsBaseLocation);
                                        dbContext.Remove(item);
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                        dbContext.SaveChanges();
                                        //}
                                        SystemData.SendPlcLocation(wmsBaseLocation);
                                    }
                                }
                                else if (item.taskType == StaticTaskType.FiveRawToSplit)//原材料到柜体拆分
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    var wmsRawOutStock = dbContext.WmsRawOutstock.Where(t => t.rawOutstockId == item.orderId).FirstOrDefault();

                                    WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.First(t => t.locationId == item.currPointId);
                                    WmsRawStock? wmsRawStock = dbContext.WmsRawStock.Where(t => t.locationCode == wmsBaseLocation.locationCode).FirstOrDefault();

                                    if (wmsRawOutStock != null && wmsRawStock != null)
                                    {


                                        wmsRawOutStock.realOutstockAmount += 1;
                                        wmsRawOutStock.executeStatus = "2";
                                        wmsRawOutStock.endTime = DateTime.Now;



                                        WmsRawOutstockDetail newWmsRawOutstockDetail = new WmsRawOutstockDetail();
                                        newWmsRawOutstockDetail.rawOutstockId = wmsRawOutStock.rawOutstockId;
                                        newWmsRawOutstockDetail.taskCode = wmsRawOutStock.taskCode;
                                        newWmsRawOutstockDetail.warehouseId = wmsRawOutStock.warehouseId;
                                        newWmsRawOutstockDetail.locationCode = wmsRawStock.locationCode;
                                        newWmsRawOutstockDetail.materialBarcode = wmsRawStock.instockBatch;
                                        newWmsRawOutstockDetail.materialId = wmsRawStock.materialId;
                                        MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == wmsRawStock.instockBatch).FirstOrDefault();
                                        if (mesBaseBarcodeInfo != null)
                                        {
                                            newWmsRawOutstockDetail.instockBatch = mesBaseBarcodeInfo.batchCode;
                                            newWmsRawOutstockDetail.materialProductionDate = mesBaseBarcodeInfo.productionDate;
                                        }
                                        newWmsRawOutstockDetail.planAmount = wmsRawOutStock.outstockAmount;
                                        newWmsRawOutstockDetail.outstockAmount = wmsRawOutStock.realOutstockAmount;
                                        newWmsRawOutstockDetail.executeStatus = "2";
                                        newWmsRawOutstockDetail.outstockPerson = wmsRawOutStock.applyBy;
                                        newWmsRawOutstockDetail.outstockTime = DateTime.Now;
                                        newWmsRawOutstockDetail.outstockWay = "2";
                                        newWmsRawOutstockDetail.createBy = "WCS";
                                        newWmsRawOutstockDetail.createDate = DateTime.Now;
                                        newWmsRawOutstockDetail.stackAmount = 1;



                                        wmsBaseLocation.locationStatus = "1";
                                        wmsBaseLocation.containerCode = null;
                                        wmsBaseLocation.updateTime = DateTime.Now;
                                        wmsBaseLocation.updateBy = "WCS";
                                        SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                        dbContext.Update(wmsBaseLocation);
                                        dbContext.Update(wmsRawOutStock);
                                        dbContext.Add(newWmsRawOutstockDetail);
                                        dbContext.Remove(wmsRawStock);
                                        dbContext.Remove(item);
                                        dbContext.SaveChanges();
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                        SystemData.SendPlcLocation(wmsBaseLocation);
                                    }
                                }
                                else if (item.taskType == StaticTaskType.FiveRawSplitReturn)//柜体拆分到原材料
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.First(t => t.locationId == item.endPointId);
                                    wmsBaseLocation.locationStatus = "1";
                                    wmsBaseLocation.returnFlag = "1";
                                    wmsBaseLocation.containerCode = item.containerNo;
                                    wmsBaseLocation.updateTime = DateTime.Now;
                                    wmsBaseLocation.updateBy = "WCS";
                                    MesBasePalletInfo? mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == item.containerNo);
                                    if (mesBasePalletInfo != null)
                                    {
                                        MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.FirstOrDefault(t => t.barcodeInfo == mesBasePalletInfo.materialBarcode);
                                        if (mesBaseBarcodeInfo != null)
                                        {
                                            WmsRawStock wmsRawStock = new()
                                            {
                                                palletInfoCode = mesBasePalletInfo.palletInfoCode,
                                                activeFlag = "1",
                                                createBy = "WCS",
                                                createDate = DateTime.Now,
                                                frozenAmount = 0,
                                                instockDate = DateTime.Now,
                                                locationCode = wmsBaseLocation.locationCode,
                                                occupyAmount = 0,
                                                warehouseFloor = 5,
                                                stockType = "1",
                                                totalAmount = 1,
                                                saleOrderId = mesBaseBarcodeInfo.saleOrderId == null ? 0 : mesBaseBarcodeInfo.saleOrderId,
                                                safeFlag = mesBaseBarcodeInfo.safeFlag,
                                                supplierId = mesBaseBarcodeInfo.manufacturerId,
                                                materialId = mesBasePalletInfo.materialId,
                                                qualityStatus = "0",
                                                rawStockId = StaticData.SnowId.NextId(),
                                                completeFlag = "0",
                                                instockBatch = mesBaseBarcodeInfo.barcodeInfo,
                                                updateBy = "WCS",
                                                updateDate = DateTime.Now,
                                                warehouseId = 511,
                                            };
                                            var WmsRawInstock = dbContext.WmsRawInstock.FirstOrDefault(t => t.materialBarCode == mesBasePalletInfo.materialBarcode && (t.instockType == "2" || t.instockType == "4"));
                                            if (WmsRawInstock != null)
                                            {
                                                WmsRawInstock.returnFlag = null;
                                                WmsRawInstock.executeStatus = "2";
                                                WmsRawInstock.updateDate = DateTime.Now;

                                                SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                                dbContext.Update(wmsBaseLocation);
                                                dbContext.Update(WmsRawInstock);
                                                dbContext.Add(wmsRawStock);
                                                BaseEquip startEquip = StaticData.BaseEquip.First(t => t.objid == item.currPointId);
                                                startEquip.emptyCount = 0;
                                                dbContext.Update(startEquip);
                                                dbContext.Remove(item);
                                                dbContext.SaveChanges();
                                                dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                                SystemData.SendPlcLocation(wmsBaseLocation);
                                            }
                                        }
                                    }

                                }
                                else if (item.taskType == StaticTaskType.FiveRawIn)//原材料入库
                                {
                                    Console.WriteLine(DateTime.Now + ":五楼AGV线程完成任务" + item.currPointNo + "," + item.endPointNo);
                                    _logger.Info("五楼Agv完成任务成功：" + item.ToJsonString());
                                    WmsBaseLocation wmsBaseLocation = dbContext.WmsBaseLocation.First(t => t.locationId == item.endPointId);
                                    wmsBaseLocation.locationStatus = "1";
                                    wmsBaseLocation.containerCode = item.containerNo;
                                    var mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == item.containerNo);
                                    if (mesBasePalletInfo != null)
                                    {
                                        var mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.FirstOrDefault(t => t.barcodeInfo == mesBasePalletInfo.materialBarcode);
                                        if (mesBaseBarcodeInfo != null)
                                        {
                                            //if (mesBaseBarcodeInfo.PurchaseOrderId == -1)
                                            //{   // 虚拟托盘号,合并的物料分别插入WmsRawInstock
                                            //    List<MesSaleOrderRelate> mesSaleOrderRelates = dbContext.MesSaleOrderRelate.Where(x => x.SaleOrderId == mesBaseBarcodeInfo.saleOrderId).ToList();
                                            //    List<WmsRawInstock>? wmsRawInstocks = new List<WmsRawInstock>();
                                            //    foreach (var mesSaleOrderRelate in mesSaleOrderRelates)
                                            //    {
                                            //        WmsRawInstock wmsRawInstock = new WmsRawInstock()
                                            //        {
                                            //            taskCode = StaticData.SnowId.NextId().ToString(),
                                            //            materialBarCode = null,
                                            //            materialBatchCode = null,
                                            //            applyBy = "wcs",
                                            //            applyDate = System.DateTime.Now,
                                            //            purchaseOrderId = mesSaleOrderRelate.PurchaseOrderId,
                                            //            beginTime = DateTime.Now,
                                            //            endTime = DateTime.Now,
                                            //            locationCode = wmsBaseLocation.locationCode,
                                            //            executeStatus = "2",
                                            //            instockAmount = mesSaleOrderRelate.RelateSaleOrderAmount,
                                            //            instockType = "1",

                                            //            materialId = mesSaleOrderRelate.MaterialId,
                                            //            operationType = "3",
                                            //            palletInfoCode = mesBaseBarcodeInfo.palletInfoCode,
                                            //            poNo = mesBaseBarcodeInfo.poNo,
                                            //            warehouseId = 511
                                            //        };
                                            //        wmsRawInstocks.Add(wmsRawInstock);
                                            //    }
                                            //    if (wmsRawInstocks.Count > 0)
                                            //    {
                                            //        dbContext.AddRange(wmsRawInstocks);
                                            //    }
                                            //}
                                            //else
                                            {
                                                WmsRawInstock wmsRawInstock = new WmsRawInstock()
                                                {
                                                    taskCode = StaticData.SnowId.NextId().ToString(),
                                                    materialBarCode = mesBaseBarcodeInfo.barcodeInfo,
                                                    materialBatchCode = mesBaseBarcodeInfo.batchCode,
                                                    applyBy = "wcs",
                                                    applyDate = System.DateTime.Now,
                                                    purchaseOrderId = mesBaseBarcodeInfo.PurchaseOrderId,
                                                    beginTime = DateTime.Now,
                                                    endTime = DateTime.Now,
                                                    locationCode = wmsBaseLocation.locationCode,
                                                    executeStatus = "2",
                                                    instockAmount = 1,
                                                    instockType = "4",
                                                    materialId = mesBaseBarcodeInfo.materialId,
                                                    operationType = "3",
                                                    palletInfoCode = mesBaseBarcodeInfo.palletInfoCode,
                                                    poNo = mesBaseBarcodeInfo.poNo,
                                                    warehouseId = 511
                                                };
                                                dbContext.Add(wmsRawInstock);

                                            }

                                            WmsRawStock wmsRawStock = new()
                                            {
                                                palletInfoCode = mesBasePalletInfo.palletInfoCode,
                                                activeFlag = "1",
                                                createBy = "WCS",
                                                createDate = DateTime.Now,
                                                frozenAmount = 0,
                                                instockDate = DateTime.Now,
                                                locationCode = wmsBaseLocation.locationCode,
                                                occupyAmount = 0,
                                                warehouseFloor = 5,
                                                stockType = "1",
                                                totalAmount = 1,
                                                saleOrderId = mesBaseBarcodeInfo.saleOrderId == null ? 0 : mesBaseBarcodeInfo.saleOrderId,
                                                safeFlag = mesBaseBarcodeInfo.safeFlag,
                                                supplierId = mesBaseBarcodeInfo.manufacturerId,
                                                materialId = mesBasePalletInfo.materialId,
                                                qualityStatus = "0",
                                                rawStockId = StaticData.SnowId.NextId(),
                                                completeFlag = mesBaseBarcodeInfo.completeFlag,
                                                instockBatch = mesBaseBarcodeInfo.barcodeInfo,
                                                updateBy = "WCS",
                                                updateDate = DateTime.Now,
                                                warehouseId = 511,
                                            };

                                            wmsBaseLocation.returnFlag = "0";
                                            SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                            dbContext.Update(wmsBaseLocation);
                                            BaseEquip lineEquip = dbContext.BaseEquip.First(t => t.objid == 5);
                                            lineEquip.equipStatus = 0;
                                            dbContext.Update(lineEquip);
                                            dbContext.Add(wmsRawStock);
                                            dbContext.Remove(item);
                                            dbContext.SaveChanges();
                                            dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6 });
                                            SystemData.SendPlcLocation(wmsBaseLocation);
                                        }
                                    }
                                }
                                else if (item.taskType == StaticTaskType.FiveStockReturnTask)
                                {
                                    BaseEquip floorLineEquip = StaticData.BaseEquip.First(t => t.objid == 5);
                                    var wmsRawOutstock = dbContext.WmsRawOutstock.Where(t => t.rawOutstockId == item.orderId).FirstOrDefault();
                                    var wmsRawStock = dbContext.WmsRawStock.Where(t => t.locationCode == item.currPointNo).FirstOrDefault();
                                    var wmsBaseLocation = dbContext.WmsBaseLocation.Where(t => t.locationCode == item.currPointNo).FirstOrDefault();
                                    if (wmsRawOutstock != null && wmsRawStock != null && wmsBaseLocation != null)
                                    {
                                        wmsRawOutstock.realOutstockAmount += 1;
                                        wmsRawOutstock.executeStatus = "2";
                                        wmsRawOutstock.endTime = DateTime.Now;
                                        dbContext.Remove(wmsRawStock);
                                        wmsBaseLocation.locationStatus = "1";
                                        wmsBaseLocation.containerCode = null;
                                        wmsBaseLocation.updateTime = DateTime.Now;
                                        wmsBaseLocation.updateBy = "WCS";

                                        WmsRawOutstockDetail newWmsRawOutstockDetail = new WmsRawOutstockDetail();
                                        newWmsRawOutstockDetail.rawOutstockId = wmsRawOutstock.rawOutstockId;
                                        newWmsRawOutstockDetail.taskCode = wmsRawOutstock.taskCode;
                                        newWmsRawOutstockDetail.warehouseId = wmsRawOutstock.warehouseId;
                                        newWmsRawOutstockDetail.locationCode = wmsRawOutstock.locationCode;
                                        newWmsRawOutstockDetail.materialBarcode = wmsRawOutstock.materialBatch;
                                        newWmsRawOutstockDetail.materialId = wmsRawOutstock.materialId;
                                        MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == wmsRawStock.instockBatch).FirstOrDefault();
                                        if (mesBaseBarcodeInfo != null)
                                        {
                                            newWmsRawOutstockDetail.instockBatch = mesBaseBarcodeInfo.batchCode;
                                            newWmsRawOutstockDetail.materialProductionDate = mesBaseBarcodeInfo.productionDate;
                                        }
                                        newWmsRawOutstockDetail.planAmount = wmsRawOutstock.outstockAmount;
                                        newWmsRawOutstockDetail.outstockAmount = wmsRawOutstock.realOutstockAmount;
                                        newWmsRawOutstockDetail.executeStatus = "2";
                                        newWmsRawOutstockDetail.outstockPerson = wmsRawOutstock.applyBy;
                                        newWmsRawOutstockDetail.outstockTime = DateTime.Now;
                                        newWmsRawOutstockDetail.outstockWay = "2";
                                        newWmsRawOutstockDetail.createBy = "WCS";
                                        newWmsRawOutstockDetail.createDate = DateTime.Now;
                                        newWmsRawOutstockDetail.stackAmount = 1;


                                        SystemData.UnLockOutLocation(wmsBaseLocation, dbContext);
                                        dbContext.Add(newWmsRawOutstockDetail);
                                        dbContext.Update(wmsBaseLocation);
                                        dbContext.Update(wmsRawOutstock);
                                        item.createTime = DateTime.Now;
                                        item.nextPointId = floorLineEquip.objid;
                                        item.nextPointNo = floorLineEquip.equipNo;
                                        item.fromFloorNo = 5;
                                        item.floorNo = 1;
                                        item.taskStatus = 6;
                                        dbContext.Update(item);
                                        dbContext.WcsTaskLog.Where(t => t.objid == item.objid).Update(t => new WcsTaskLog { taskStatus = 6, updateTime = DateTime.Now });
                                        dbContext.SaveChanges();
                                    }
                                }
                            }
                        }
                        break;
                    }
                }
                catch (Exception ex)
                {
                    if (ex is PlcException)
                    {

                    }
                    else
                    {
                        _logger.Error(ex.Message + "\n" + ex.StackTrace);
                    }
                }
                finally
                {
                    Thread.Sleep(1000);
                }
            }
        }

    }
}