using HH.WCS.Hexafluo;
using HH.WCS.Hexafluo.device;
using HH.WCS.Hexafluo.dispatch;
using HH.WCS.Hexafluo.process;
using HH.WCS.Hexafluo.util;
using HH.WCS.Hexafluo.wms;
using HH.WCS.SJML.Comm;
using HH.WCS.SJML.dispatch;
using HH.WCS.SJML.Dto;
using HH.WCS.SJML.Entitys;
using HH.WCS.SJML.util;
using HH.WCS.ZCQTJ.dispatch;
using HH.WCS.ZCQTJ.Entitys;
using HH.WCS.ZCQTJ.Entitys.MES中间表;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;
using static HH.WCS.Hexafluo.device.OITcpHelper;

namespace HH.WCS.SJML.Bll
{
    public class StateTaskBLL
    {
        public virtual OperateResult ExecuteState(string taskNo, string taskState, LogPara logPara, WMSTask Task = null, string UserName = "")
        {
            var executeStatePara = ExecuteStateHandlePara(taskNo, taskState, logPara, Task, UserName);
            if (executeStatePara == null)
            {
                return OperateResult.Error("未查询到任务数据!任务号为:" + taskNo);
            }
            var result = new OperateResult();
            switch (taskState)
            {
                case "执行中":
                    result = StartTask(executeStatePara, logPara);
                    break;
                case "开始取货":
                    result = StartTaskQh(executeStatePara, logPara);
                    break;
                case "取货完成":
                    result = PickSucc(executeStatePara, logPara);
                    if (!executeStatePara.transportTask.S_TASK_NO.Contains("_") && executeStatePara.transportTask.S_TYPE == "出库" && executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.JbTray != null)
                    {
                        var chi = new SqlHelper<object>().GetInstance();
                        var newDb = chi.CopyNew();
                        var transportTask = newDb.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        var TaryJb = JsonConvert.DeserializeObject<List<TranyJb>>(transportTask.TypeJson);
                        var Kklock = newDb.Queryable<FunctionEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        if (TaryJb.FindAll(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ToList().Count > 0 && (Kklock != null && Kklock.TransportLock == "Y"))
                        {
                            try
                            {
                                newDb.BeginTran();
                                newDb.Deleteable<JbTrayNumberEntitys>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception ex)
                            {
                                LogHelper.TaskDetail(logPara, "取货完成释放接驳位的空托缓存数据 报错:" + ex.Message);
                            }
                        }
                    }
                    break;
                case "完成":
                    result = CompleteTask(executeStatePara, logPara);

                    if (!executeStatePara.transportTask.S_TASK_NO.Contains("_") && executeStatePara.transportTask.S_TYPE == "出库" && executeStatePara.transportTask.S_NOTE.Equals("立库任务"))
                    {
                        var chi = new SqlHelper<object>().GetInstance();
                        var newDb = chi.CopyNew();
                        var transportTask = newDb.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        var TaryJb = JsonConvert.DeserializeObject<List<TranyJb>>(transportTask.TypeJson);
                        var Kklock = newDb.Queryable<FunctionEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        if (TaryJb.FindAll(e => e.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ToList().Count > 0 && (Kklock != null && Kklock.TransportLock == "Y"))
                        {
                            JbTrayNumberEntitys jbTray = new JbTrayNumberEntitys();
                            jbTray.S_LOC_CODE = executeStatePara.transportTask.S_END_LOC;
                            jbTray.S_CNTR_CODE = executeStatePara.transportTask.S_CNTRS;
                            try
                            {
                                newDb.BeginTran();
                                newDb.Insertable(jbTray).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception ex)
                            {
                                LogHelper.TaskDetail(logPara, "任务完成释放接驳位的空托缓存数据 报错:" + ex.Message);
                            }
                        }
                    }
                    try
                    {
                        var chi = new SqlHelper<object>().GetInstance();
                        var newDb = chi.CopyNew();
                        var transJson = newDb.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "库区任务统计对照单")?.First();
                        var ListString = JsonConvert.DeserializeObject<List<AreaTaskNumber>>(transJson.TypeJson);
                        #region 巷道任务数量统计表
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "入库" && result.Success)
                        {
                            var taskview = newDb.Queryable<TaskViewEntitys>().Where(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA
                            && e.N_ROADWAY == executeStatePara.endIsCurrentTask.N_ROADWAY && e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"))?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    TaskViewEntitys taskView = new TaskViewEntitys();
                                    taskView.S_AREA_CODE = executeStatePara.transportTask.S_END_LAREA;
                                    taskView.N_ROADWAY = executeStatePara.endIsCurrentTask.N_ROADWAY;
                                    taskView.TASK_NUM = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成统计任务数量 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<TaskViewEntitys>().SetColumns(it => new TaskViewEntitys()
                                    {
                                        TASK_NUM = taskview.TASK_NUM + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成统计任务数量 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "出库" && result.Success)
                        {
                            var taskview = newDb.Queryable<TaskViewEntitys>().Where(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA
                             && e.N_ROADWAY == executeStatePara.startIsCurrentTask.N_ROADWAY && e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"))?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    TaskViewEntitys taskView = new TaskViewEntitys();
                                    taskView.S_AREA_CODE = executeStatePara.transportTask.S_START_LAREA;
                                    taskView.N_ROADWAY = executeStatePara.startIsCurrentTask.N_ROADWAY;
                                    taskView.TASK_NUM = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成统计任务数量 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<TaskViewEntitys>().SetColumns(it => new TaskViewEntitys()
                                    {
                                        TASK_NUM = taskview.TASK_NUM + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成统计任务数量 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        #endregion

                        #region 库区出入库总量统计表
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "入库" && result.Success)
                        {
                            var Texp = Expressionable.Create<AREANUMEntitys>();
                            AREANUMEntitys taskView = new AREANUMEntitys();
                            var ggd = ListString.Find(e => e.AreaCode == executeStatePara.transportTask.S_END_LAREA);
                            if (ggd != null)
                            {
                                taskView.S_CNTR_TYPE = ggd.TrayState;
                            }
                            if (executeStatePara.transportTask.S_END_LAREA == "LC11T")
                            {
                                Texp.And(e => e.S_CNTR_TYPE == executeStatePara.transportTask.S_TOOLS_TPYE);

                                taskView.S_CNTR_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                            }
                            Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA);
                            Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"));

                            var taskview = newDb.Queryable<AREANUMEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {

                                    taskView.S_AREA_CODE = executeStatePara.transportTask.S_END_LAREA;
                                    taskView.N_ENTER_NUM = 1;

                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AREANUMEntitys>().SetColumns(it => new AREANUMEntitys()
                                    {
                                        N_ENTER_NUM = taskview.N_ENTER_NUM + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "出库" && result.Success)
                        {

                            var Texp = Expressionable.Create<AREANUMEntitys>();
                            AREANUMEntitys taskView = new AREANUMEntitys();
                            var ggd = ListString.Find(e => e.AreaCode == executeStatePara.transportTask.S_START_LAREA);
                            if (ggd != null)
                            {
                                taskView.S_CNTR_TYPE = ggd.TrayState;
                            }
                            if (executeStatePara.transportTask.S_START_LAREA == "LC11T")
                            {
                                Texp.And(e => e.S_CNTR_TYPE == executeStatePara.transportTask.S_TOOLS_TPYE);

                                taskView.S_CNTR_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                            }
                            Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA);
                            Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"));
                            var taskview = newDb.Queryable<AREANUMEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    taskView.S_AREA_CODE = executeStatePara.transportTask.S_START_LAREA;
                                    taskView.N_OUT_NUM = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AREANUMEntitys>().SetColumns(it => new AREANUMEntitys()
                                    {
                                        N_OUT_NUM = taskview.N_OUT_NUM + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        #endregion
                        #region 库区出入库小时统计表
                        DateTime Da = DateTime.Now;
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "入库" && result.Success)
                        {
                            AreaTaskHourNumberEntitys taskView = new AreaTaskHourNumberEntitys();
                            var Texp = Expressionable.Create<AreaTaskHourNumberEntitys>();
                            var ggd = ListString.Find(e => e.AreaCode == executeStatePara.transportTask.S_END_LAREA);
                            if (ggd != null)
                            {
                                taskView.S_CNTR_TYPE = ggd.TrayState;
                            }
                            if (executeStatePara.transportTask.S_END_LAREA == "LC11T")
                            {
                                Texp.And(e => e.S_CNTR_TYPE == executeStatePara.transportTask.S_TOOLS_TPYE);

                                taskView.S_CNTR_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                            }
                            Texp.And(e => e.Area_Code == executeStatePara.transportTask.S_END_LAREA);
                            Texp.And(e => e.Date == Da.Date);
                            Texp.And(e => e.hour == Da.Hour);
                            var taskview = newDb.Queryable<AreaTaskHourNumberEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {

                                    taskView.Area_Code = executeStatePara.transportTask.S_END_LAREA;
                                    taskView.Num_RK = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AreaTaskHourNumberEntitys>().SetColumns(it => new AreaTaskHourNumberEntitys()
                                    {
                                        Num_RK = taskview.Num_RK + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.transportTask.S_TYPE == "出库" && result.Success)
                        {
                            AreaTaskHourNumberEntitys taskView = new AreaTaskHourNumberEntitys();
                            var Texp = Expressionable.Create<AreaTaskHourNumberEntitys>();
                            var ggd = ListString.Find(e => e.AreaCode == executeStatePara.transportTask.S_END_LAREA);
                            if (ggd != null)
                            {
                                taskView.S_CNTR_TYPE = ggd.TrayState;
                            }
                            if (executeStatePara.transportTask.S_START_LAREA == "LC11T")
                            {
                                Texp.And(e => e.S_CNTR_TYPE == executeStatePara.transportTask.S_TOOLS_TPYE);
                                taskView.S_CNTR_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                            }
                            Texp.And(e => e.Area_Code == executeStatePara.transportTask.S_START_LAREA);
                            Texp.And(e => e.Date == Da.Date);
                            Texp.And(e => e.hour == Da.Hour);
                            var taskview = newDb.Queryable<AreaTaskHourNumberEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    taskView.Area_Code = executeStatePara.transportTask.S_START_LAREA;
                                    taskView.Num_CK = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AreaTaskHourNumberEntitys>().SetColumns(it => new AreaTaskHourNumberEntitys()
                                    {
                                        Num_CK = taskview.Num_CK + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        #endregion
                        #region AGV每小时出入库统计
                        DateTime Daagv = DateTime.Now;
                        if (executeStatePara.transportTask.S_NOTE == "agv任务" && executeStatePara.transportTask.S_TYPE == "入库" && result.Success)
                        {
                            var taskview = newDb.Queryable<AgvAreaTaskHourNumberEntitys>().Where(e => e.AgvLicense == executeStatePara.transportTask.S_EQ_NO
                             && e.Date == Daagv.Date && e.hour == Daagv.Hour)?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    AgvAreaTaskHourNumberEntitys taskView = new AgvAreaTaskHourNumberEntitys();
                                    taskView.AgvLicense = executeStatePara.transportTask.S_EQ_NO;
                                    taskView.Num_RK = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AgvAreaTaskHourNumberEntitys>().SetColumns(it => new AgvAreaTaskHourNumberEntitys()
                                    {
                                        Num_RK = taskview.Num_RK + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        if (executeStatePara.transportTask.S_NOTE == "agv任务" && executeStatePara.transportTask.S_TYPE == "出库" && result.Success)
                        {
                            var taskview = newDb.Queryable<AgvAreaTaskHourNumberEntitys>().Where(e => e.AgvLicense == executeStatePara.transportTask.S_EQ_NO
                          && e.Date == Daagv.Date && e.hour == Daagv.Hour)?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    AgvAreaTaskHourNumberEntitys taskView = new AgvAreaTaskHourNumberEntitys();
                                    taskView.AgvLicense = executeStatePara.transportTask.S_EQ_NO;
                                    taskView.Num_CK = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<AgvAreaTaskHourNumberEntitys>().SetColumns(it => new AgvAreaTaskHourNumberEntitys()
                                    {
                                        Num_CK = taskview.Num_CK + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        #endregion

                        #region 库区出入库天统计表
                        if (!executeStatePara.transportTask.S_TASK_NO.Contains("_") && result.Success)
                        {
                            var Texp = Expressionable.Create<DayAreaTaskEntitys>();
                            DayAreaTaskEntitys taskView = new DayAreaTaskEntitys();
                            if (executeStatePara.transportTask.S_TYPE == "入库")
                            {
                                Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA);
                            }
                            else
                            {
                                //  Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA);
                                Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA);
                            }
                            Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"));
                            var taskview = newDb.Queryable<DayAreaTaskEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    taskView.S_AREA_CODE = executeStatePara.transportTask.S_END_LAREA;
                                    if (executeStatePara.transportTask.S_TYPE == "入库")
                                    {
                                        taskView.Num_RK = 1;
                                    }
                                    else
                                    {
                                        taskView.Num_CK = 1;
                                    }

                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {

                                    newDb.BeginTran();
                                    if (executeStatePara.transportTask.S_TYPE == "入库")
                                    {
                                        var I = newDb.Updateable<DayAreaTaskEntitys>().SetColumns(it => new DayAreaTaskEntitys()
                                        {
                                            Num_RK = taskview.Num_RK + 1
                                        }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                    }
                                    else
                                    {
                                        var I = newDb.Updateable<DayAreaTaskEntitys>().SetColumns(it => new DayAreaTaskEntitys()
                                        {
                                            Num_CK = taskview.Num_CK + 1
                                        }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                    }

                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        else
                        {
                            if (executeStatePara.transportTask.S_NOTE == "立库任务" && result.Success)
                            {
                                var Texp = Expressionable.Create<DayAreaTaskEntitys>();
                                DayAreaTaskEntitys taskView = new DayAreaTaskEntitys();
                                if (executeStatePara.transportTask.S_TYPE == "入库")
                                {
                                    Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA);
                                }
                                else
                                {
                                    Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA);
                                }

                                Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"));
                                var taskview = newDb.Queryable<DayAreaTaskEntitys>().Where(Texp.ToExpression())?.First();
                                if (taskview == null)//创建
                                {
                                    try
                                    {

                                        taskView.S_AREA_CODE = executeStatePara.transportTask.S_END_LAREA;
                                        if (executeStatePara.transportTask.S_TYPE == "入库")
                                        {
                                            taskView.Num_RK = 1;
                                        }
                                        else
                                        {
                                            taskView.Num_CK = 1;
                                        }

                                        newDb.BeginTran();
                                        var I = newDb.Insertable(taskView).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }
                                else//任务数+1
                                {
                                    try
                                    {
                                        newDb.BeginTran();
                                        if (executeStatePara.transportTask.S_TYPE == "入库")
                                        {
                                            var I = newDb.Updateable<DayAreaTaskEntitys>().SetColumns(it => new DayAreaTaskEntitys()
                                            {
                                                Num_RK = taskview.Num_RK + 1
                                            }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                            if (I == 0)
                                            {
                                                newDb.RollbackTran();
                                            }
                                        }
                                        else
                                        {
                                            var I = newDb.Updateable<DayAreaTaskEntitys>().SetColumns(it => new DayAreaTaskEntitys()
                                            {
                                                Num_CK = taskview.Num_CK + 1
                                            }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                            if (I == 0)
                                            {
                                                newDb.RollbackTran();
                                            }
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }
                            }
                        }
                        #endregion
                        #region 任务 年统计
                        if (!executeStatePara.transportTask.S_TASK_NO.Contains("_") && result.Success)
                        {
                            var Texp = Expressionable.Create<YearAreaTaskEntitys>();
                            YearAreaTaskEntitys taskView = new YearAreaTaskEntitys();
                            Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy"));
                            var taskview = newDb.Queryable<YearAreaTaskEntitys>().Where(Texp.ToExpression())?.First();
                            if (taskview == null)//创建
                            {
                                try
                                {
                                    taskView.TASK_NUM = 1;
                                    newDb.BeginTran();
                                    var I = newDb.Insertable(taskView).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                            else//任务数+1
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<YearAreaTaskEntitys>().SetColumns(it => new YearAreaTaskEntitys()
                                    {
                                        TASK_NUM = taskview.TASK_NUM + 1
                                    }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                    if (I == 0)
                                    {
                                        newDb.RollbackTran();
                                    }
                                    newDb.CommitTran();
                                }
                                catch (Exception ex)
                                {
                                    LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        else
                        {
                            if (executeStatePara.transportTask.S_NOTE == "立库任务" && result.Success)
                            {
                                var Texp = Expressionable.Create<YearAreaTaskEntitys>();
                                YearAreaTaskEntitys taskView = new YearAreaTaskEntitys();
                                Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy"));
                                var taskview = newDb.Queryable<YearAreaTaskEntitys>().Where(Texp.ToExpression())?.First();
                                if (taskview == null)//创建
                                {
                                    try
                                    {
                                        taskView.TASK_NUM = 1;
                                        newDb.BeginTran();
                                        var I = newDb.Insertable(taskView).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }
                                else//任务数+1
                                {
                                    try
                                    {
                                        newDb.BeginTran();
                                        var I = newDb.Updateable<YearAreaTaskEntitys>().SetColumns(it => new YearAreaTaskEntitys()
                                        {
                                            TASK_NUM = taskview.TASK_NUM + 1
                                        }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }
                            }
                        }
                        #endregion
                        #region 库区出库物料统计表
                        if (executeStatePara.transportTask.S_NOTE == "立库任务" && executeStatePara.trayItemMsts.Count > 0 && executeStatePara.transportTask.S_TYPE == "出库" && result.Success)
                        {
                            if (executeStatePara.trayItemMsts.Count > 0)
                            {
                                var Texp = Expressionable.Create<AreaIetmNumEntitys>();
                                AreaIetmNumEntitys taskView = new AreaIetmNumEntitys();
                                var ggd = ListString.Find(e => e.AreaCode == executeStatePara.transportTask.S_START_LAREA);
                                if (ggd != null)
                                {
                                    taskView.S_CNTR_TYPE = ggd.TrayState;
                                }
                                if (executeStatePara.transportTask.S_START_LAREA == "LC11T")
                                {
                                    Texp.And(e => e.S_CNTR_TYPE == executeStatePara.transportTask.S_TOOLS_TPYE);

                                    taskView.S_CNTR_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                                }
                                Texp.And(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA);
                                Texp.And(e => e.D_DATE == DateTime.Now.ToString("yyyy-MM-dd"));
                                var taskview = newDb.Queryable<AreaIetmNumEntitys>().Where(Texp.ToExpression())?.First();
                                if (taskview == null)//创建
                                {
                                    try
                                    {
                                        taskView.S_AREA_CODE = executeStatePara.transportTask.S_START_LAREA;
                                        taskView.N_OUT_NUM = 1;
                                        newDb.BeginTran();
                                        var I = newDb.Insertable(taskView).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }
                                else//任务数+1
                                {
                                    try
                                    {
                                        newDb.BeginTran();
                                        var I = newDb.Updateable<AreaIetmNumEntitys>().SetColumns(it => new AreaIetmNumEntitys()
                                        {
                                            N_OUT_NUM = taskview.N_OUT_NUM + 1
                                        }).Where(x => x.S_ID == taskview.S_ID).ExecuteCommand();
                                        if (I == 0)
                                        {
                                            newDb.RollbackTran();
                                        }
                                        newDb.CommitTran();
                                    }
                                    catch (Exception ex)
                                    {
                                        LogHelper.TaskDetail(logPara, "立库任务完成 出入库总量统计 报错:" + ex.Message);
                                        newDb.RollbackTran();
                                    }
                                }

                            }

                        }
                        #endregion

                    }
                    catch (Exception ex)
                    {
                        throw;
                    }
                    if (!executeStatePara.transportTask.S_TASK_NO.Contains("_") && executeStatePara.transportTask.S_TYPE == "出库" && executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.JbTray != null)
                    {
                        var chi = new SqlHelper<object>().GetInstance();
                        var newDb = chi.CopyNew();
                        var transportTask = newDb.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        var TaryJb = JsonConvert.DeserializeObject<List<TranyJb>>(transportTask.TypeJson);
                        var Kklock = newDb.Queryable<FunctionEntitys>().Where(e => e.Autoindex == "空托自动出库到接驳位")?.First();
                        if (TaryJb.FindAll(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ToList().Count > 0 && (Kklock != null && Kklock.TransportLock == "Y"))
                        {
                            try
                            {
                                newDb.BeginTran();
                                newDb.Deleteable<JbTrayNumberEntitys>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception ex)
                            {
                                LogHelper.TaskDetail(logPara, "任务完成释放接驳位的空托缓存数据 报错:" + ex.Message);
                            }
                        }
                    }

                    break;
                case "开始卸货":
                    result = StartTaskXh(executeStatePara, logPara);
                    break;
                case "卸货完成":
                    result = UnloadingSucc(executeStatePara, logPara);
                    break;
                case "取消":
                    result = CancelTask(executeStatePara, logPara, UserName);
                    break;
            }
            return result;

        }

        public ExecuteStateParaDto ExecuteStateHandlePara(string taskNo, string taskState, LogPara logPara, WMSTask Task = null, string UserName = "")
        {
            var executeStatePara = new ExecuteStateParaDto();
            executeStatePara.Name = UserName;
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            //查询任务
            if (Task != null)
            {
                executeStatePara.transportTask = Task;
            }
            else
            {
                LogHelper.TaskDetail(logPara, "开始查询：任务编号： " + taskNo);
                executeStatePara.transportTask = newDb.Queryable<WMSTask>().Where(e => e.S_TASK_NO == taskNo)?.First();
            }

            if (executeStatePara.transportTask == null)
            {
                return null;
            }

            executeStatePara.transportTaskSrc = newDb.Queryable<WMSTask>().Where(e => e.S_SRC_NO == executeStatePara.transportTask.S_SRC_NO).ToList();
            if (taskNo.IndexOf('_') > 0)
            {
                var tno = taskNo.Substring(0, taskNo.LastIndexOf("_"));
                executeStatePara.transportTaskZ = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
            }
            LogHelper.TaskDetail(logPara, "结束查询 任务结束：任务编号： " + taskNo);
            //起点库区
            var QbArea = newDb.Queryable<TN_AreaEntitys>().Where(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA.Trim() || e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA.Trim()).ToList();
            executeStatePara.startStockArea = QbArea.Find(e => e.S_AREA_CODE == executeStatePara.transportTask.S_START_LAREA.Trim());
            //结束库区
            executeStatePara.endStockArea = QbArea.Find(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA.Trim());
            // SqlSugarHelper.Db.Queryable<TN_AreaEntitys>().Where(e => e.S_AREA_CODE == executeStatePara.transportTask.S_END_LAREA.Trim())?.First();
            LogHelper.TaskDetail(logPara, "结束查询 起点/终点 库区结束：任务编号： " + taskNo);
            //起点货位是否绑定托盘
            //executeStatePara.startTrayLocation = SqlSugarHelper.Db.Queryable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS)?.First();
            var QbTrayCode = newDb.Queryable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC || e.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ToList();
            executeStatePara.startTrayLocation = QbTrayCode.Find(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC);
            //终点货位是否绑定托盘
            executeStatePara.endTrayLocation = QbTrayCode.Find(e => e.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC);
            LogHelper.TaskDetail(logPara, "结束查询 起点/终点 托盘货位结束：任务编号： " + taskNo);
            //起点货位拓展
            var QbLocation = newDb.Queryable<Location>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC || e.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ToList();
            executeStatePara.startIsCurrentTask = QbLocation.Find(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC);
            //终点货位拓展
            executeStatePara.endIsCurrentTask = QbLocation.Find(e => e.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC);
            LogHelper.TaskDetail(logPara, "结束查询 起点/终点 货位结束：任务编号： " + taskNo);
            //托盘物料主表
            executeStatePara.trayItemMsts = newDb.Queryable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ToList();
            LogHelper.TaskDetail(logPara, "结束查询 托盘物料结束：任务编号： " + taskNo);
            ////作业流程
            executeStatePara.WorkFlows = newDb.Queryable<TN_WorkFlowEntitys>().Where(e => e.S_FlowNo == executeStatePara.transportTask.S_FlowNo)?.First();

            executeStatePara.JbTray = newDb.Queryable<JbTrayNumberEntitys>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS && e.S_IS_USE == "N")?.First();

            //任务状态
            executeStatePara.taskState = taskState;
            return executeStatePara;
        }

        public virtual OperateResult StartTask(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            if (!executeStatePara.transportTask.S_B_STATE.Equals(Constants.TaskState_NoExecuted) && !executeStatePara.transportTask.S_B_STATE.Equals("已推送"))
                return OperateResult.Error("请启动未执行的任务！");

            if (executeStatePara.transportTask.S_NOTE.Equals("自管任务") && executeStatePara.transportTask.S_Subtask == "Y")
            {
                return OperateResult.Error("主任务禁止直接开始任务！");
            }
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            string UserName = "";
            WMSTask task = executeStatePara.transportTask;
            if (executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.Name == "")
            {
                UserName = "agv";
            }
            else if (!executeStatePara.transportTask.S_NOTE.Equals("自管任务") && executeStatePara.Name == "")
            {
                UserName = "立库";
            }
            else
            {
                UserName = executeStatePara.Name;
            }
            if (executeStatePara.transportTask.S_NOTE == "立库任务")
            {
                string no = executeStatePara.transportTask.S_TASK_NO;
                if (no.IndexOf('_') > 0)
                {
                    no = no.Substring(0, no.LastIndexOf("_"));
                    task = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == no);
                }
                // 获取主任务

                LogHelper.TaskDetail(logPara, "获取主任务：任务编号： " + no);
                var bit = "";
                if (task.S_TYPE == "出库")
                {
                    bit = task.S_END_LOC;
                }
            }
            if (executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.transportTask.S_TYPE == "入库")
            {
                var tac = newDb.Queryable<TN_TcpCont>().Where(a => a.LocationCode == executeStatePara.transportTask.S_START_LOC)?.First();
                if (tac != null)
                {
                    //查询通讯方式
                    if (tac.CtiaMode == "MODBUS")
                    {
                        if (string.IsNullOrEmpty(tac.host) || tac.port == 0)
                        {
                            LogHelper.Info("完工回报", $"报错:通讯模式配置表货中 货位{executeStatePara.transportTask.S_START_LOC} ip地址 写入目标设备的IP端口  有空值或者默认值");
                        }
                        else
                        {
                            RegisterWriteOutPutModel Register = new RegisterWriteOutPutModel();
                            Register.host = tac.host;
                            Register.port = tac.port;
                            Register.addr = tac.addr + 1;
                            Register.data = tac.dataNum;
                            LogHelper.Info("完工回报", $"MODBUS   发送参数{JsonConvert.SerializeObject(Register)}");
                            var ta = OITcpHelper.RegisterWriteOutPut(Register);
                            LogHelper.Info("完工回报", $"MODBUS   返回参数{JsonConvert.SerializeObject(ta)}");
                        }
                    }
                    if (tac.CtiaMode == "VMI")
                    {
                        var Alone = newDb.Queryable<SqlCountEntitys>().Where(e => e.ConfigId == tac.host)?.First();
                        if (Alone == null)
                        {
                            throw new Exception($"未查询到对应的VMI ConfigId为 {tac.host} 的数据库连接字符串");
                        }
                        var childA = new SqlHelper<object>().GetInstance(Alone.ConnectionString);
                        var GGF = childA.Updateable<DATA_TO_HMI>().SetColumns(it => new DATA_TO_HMI() { Value = "1", Handshake = "U" }).Where(e => e.TagName == "IMES_AGV_BDST_READY_FOR_OPERATION").ExecuteCommand();
                        if (GGF == 0)
                        {
                            throw new Exception("写安全信号交互表 IMES_AGV_BDST_READY_FOR_OPERATION字段为 1失败");
                        }
                        LogHelper.Info("完工回报", "写安全信号交互表 IMES_AGV_BDST_READY_FOR_OPERATION 字段为 1成功");
                    }
                }
            }
            else if (executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.transportTask.S_TYPE == "出库")
            {
                var tac = newDb.Queryable<TN_TcpCont>().Where(a => a.LocationCode == executeStatePara.transportTask.S_END_LOC)?.First();
                if (tac != null)
                {
                    //查询通讯方式
                    if (tac.CtiaMode == "MODBUS")
                    {
                        if (string.IsNullOrEmpty(tac.host) || tac.port == 0)
                        {
                            LogHelper.Info("完工回报", $"报错:通讯模式配置表货中 货位{executeStatePara.transportTask.S_END_LOC} ip地址 写入目标设备的IP端口  有空值或者默认值");
                        }
                        else
                        {
                            RegisterWriteOutPutModel Register = new RegisterWriteOutPutModel();
                            Register.host = tac.host;
                            Register.port = tac.port;
                            Register.addr = tac.addr;
                            Register.data = tac.dataNum;
                            var ta = OITcpHelper.RegisterWriteOutPut(Register);
                            LogHelper.Info("完工回报", $"MODBUS   发送参数{JsonConvert.SerializeObject(Register)}");
                            LogHelper.Info("完工回报", $"MODBUS   返回参数{JsonConvert.SerializeObject(ta)}");
                        }
                    }
                    if (tac.CtiaMode == "VMI")
                    {
                        var Alone = newDb.Queryable<SqlCountEntitys>().Where(e => e.ConfigId == tac.host)?.First();
                        if (Alone == null)
                        {
                            throw new Exception($"未查询到对应的VMI ConfigId为 {tac.host} 的数据库连接字符串");
                        }
                        var childA = new SqlHelper<object>().GetInstance(Alone.ConnectionString);
                        var GGF = childA.Updateable<DATA_TO_HMI>().SetColumns(it => new DATA_TO_HMI() { Value = "1", Handshake = "U" }).Where(e => e.TagName == "IMES_AGV_BDST_READY_FOR_OPERATION").ExecuteCommand();
                        if (GGF == 0)
                        {
                            throw new Exception("写安全信号交互表 IMES_AGV_BDST_READY_FOR_OPERATION字段为 1失败");
                        }
                        LogHelper.Info("完工回报", "写安全信号交互表 IMES_AGV_BDST_READY_FOR_OPERATION 字段为 1成功");
                    }
                }
            }
            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();

                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_START_TIME = DateTime.Now, S_B_STATE = Constants.TaskState_Executing }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                if (executeStatePara.transportTask.S_TYPE == "入库" && executeStatePara.transportTask.S_NOTE.Equals("agv任务"))
                {
                    var fff = executeStatePara.transportTaskSrc.Select(e => e.S_ID).ToList();
                    I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_START_TIME = DateTime.Now, T_MODIFY = DateTime.Now }).Where(e => fff.Contains(e.S_ID)).ExecuteCommand();
                }
                if (executeStatePara.transportTask.S_TYPE == "出库" && executeStatePara.transportTask.S_NOTE.Equals("立库任务"))
                {
                    var fff = executeStatePara.transportTaskSrc.Select(e => e.S_ID).ToList();
                    I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_START_TIME = DateTime.Now, T_MODIFY = DateTime.Now }).Where(e => fff.Contains(e.S_ID)).ExecuteCommand();
                }
                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                Task.Run(() =>
                {
                    if (executeStatePara.transportTask.S_SRC_SYS == "MES")
                    {
                        ZCReceivePriorityEntity mes = new ZCReceivePriorityEntity();
                        var tno = executeStatePara.transportTask.S_TASK_NO;
                        mes.taskNo = executeStatePara.transportTask.S_UpstreamNo;
                        var task2 = new WMSTask();
                        if (executeStatePara.transportTask.S_TYPE == "入库")
                        {
                            task2 = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == executeStatePara.transportTask.S_UpstreamNo);
                        }
                        else
                        {
                            if (tno.IndexOf('_') > 0)
                            {
                                tno = tno.Substring(0, tno.LastIndexOf("_"));
                            }
                            //task2 = SqlSugarHelper.Db.Queryable<WMSTask>().Where(e => e.S_TASK_NO == tno)?.First();
                            task2 = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
                        }
                        if (task2 != null)
                        {
                            if (executeStatePara.transportTask.S_TYPE == "入库")
                            {
                                mes.End_big = task2?.S_START_LOC ?? executeStatePara.transportTask.S_START_LOC;
                            }
                            if (executeStatePara.transportTask.S_TYPE == "出库")
                            {
                                mes.End_big = task2?.S_END_LOC ?? executeStatePara.transportTask.S_END_LOC;
                            }
                            mes.Data_status = 1;
                            //调mes接口
                            BLLCreator.CreateSingleton<MesTask>().MesTaskEntity(mes);
                        }
                    }
                });
                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }

        public virtual OperateResult StartTaskQh(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();

                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_START_TIME = DateTime.Now, T_MODIFY = DateTime.Now, S_B_STATE = Constants.TaskState_Executing }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }
        public virtual OperateResult StartTaskXh(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            List<string> TaskState = new List<string>() { "取消", "完成", "卸货完成" };
            if (TaskState.Contains(executeStatePara.transportTask.S_B_STATE))
            {
                return OperateResult.Error("只能执行没有 取消/完成/卸货完成的任务！");
            }
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();

            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();

                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = Constants.TaskState_Executing }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }

                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }

        /// <summary>
        /// 任务完成
        /// </summary>
        /// <param name="executeStatePara"></param>
        /// <param name="logPara"></param>
        /// <returns></returns>
        public virtual OperateResult CompleteTask(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            //对取消的任务类型进行筛选
            if (!executeStatePara.transportTask.S_B_STATE.Equals("未执行") && !executeStatePara.transportTask.S_B_STATE.Equals("已推送") && !executeStatePara.transportTask.S_B_STATE.Equals("执行中") && !executeStatePara.transportTask.S_B_STATE.Equals("完成一半") && !executeStatePara.transportTask.S_B_STATE.Equals("取货完成") && !executeStatePara.transportTask.S_B_STATE.Equals("卸货完成"))
            {
                return OperateResult.Error("只能完成未执行、执行中的任务！");
            }
            //需要写入货位表的参数合集
            #region 拼接上下架表数据
            GroundingOffshelfEntitys UoDown = new GroundingOffshelfEntitys();
            UoDown.S_CNTR_CODE = executeStatePara.transportTask.S_CNTRS;
            UoDown.S_TRAY_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
            UoDown.S_TASK_NO = executeStatePara.transportTask.S_TASK_NO;
            #endregion
            var productionDate = "";
            var takeEffectTime = "";
            var expireTime = "";
            var S_TRAY_TYPE = "";
            deadlockRollEntitys Deck = new deadlockRollEntitys();
            Deck.S_INTER_STATE = "2";
            Deck.S_VALUE_JSON = executeStatePara.transportTask.S_TASK_NO;

            if (executeStatePara.transportTask.S_CNTRS != null && executeStatePara.transportTask.S_CNTRS.Contains("KJZ"))
            {
                S_TRAY_TYPE = "KJZ";
                UoDown.S_TRAY_TYPE = "KJZ";
            }
            else
            {
                if (executeStatePara.trayItemMsts?.Count() > 0)
                {
                    S_TRAY_TYPE = "MT";
                }
                else
                {
                    S_TRAY_TYPE = "KT";
                }
            }
            if (executeStatePara.trayItemMsts?.Count() > 0)
            {
                var tex = executeStatePara.trayItemMsts.FirstOrDefault();
                productionDate = tex.productionDate.ToString();
                takeEffectTime = tex.takeEffectTime.ToString();
                expireTime = tex.expireTime.ToString();
                UoDown.S_ITEM_CODE = tex.S_ITEM_CODE;
                UoDown.S_ITEM_NAME = tex.S_ITEM_NAME;
                UoDown.F_QTY = tex.F_QTY;
                UoDown.F_AVG_QTY = tex.F_AVG_QTY;
                UoDown.F_SUM_QTY = tex.F_SUM_QTY;
                UoDown.expireTime = tex.expireTime;
                UoDown.itemFeature = tex.itemFeature;
                UoDown.itemModel = tex.itemModel;
                UoDown.Level = tex.Level;
                UoDown.productionDate = tex.productionDate;
                UoDown.takeEffectTime = tex.takeEffectTime;
                UoDown.TurnCardNum = tex.TurnCardNum;
                UoDown.S_ITEM_STATE = tex.S_ITEM_STATE;
                UoDown.S_BATCH_NO = tex.S_BATCH_NO;
                UoDown.applyProdSpecList = tex.applyProdSpecList;
            }

            //判断是否是自管任务 因为中策项目的流程是拆分子任务的流程 主任务直接完成了  但是子任务任在运行 当子任务上报完成了  主任务比子任务先完成  会出现逻辑错误
            if (executeStatePara.transportTask.S_NOTE.Equals("自管任务") && executeStatePara.transportTask.S_Subtask == "Y")
            {
                return OperateResult.Error("主任务禁止直接完成！");
            }
            string no = executeStatePara.transportTask.S_TASK_NO;
            if (no.IndexOf('_') < 1 && executeStatePara.transportTask.S_Subtask == "Y")
            {
                return OperateResult.Error("主任务不允许直接完成，请先完成子任务！！");
            }
            string UserName = "";
            if (executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.Name == "")
            {
                UserName = "agv";
            }
            else if (!executeStatePara.transportTask.S_NOTE.Equals("自管任务") && executeStatePara.Name == "" && executeStatePara.transportTask.S_Subtask == "Y")
            {
                UserName = "立库";
            }
            else
            {
                UserName = executeStatePara.Name;
            }
            string tno = executeStatePara.transportTask.S_TASK_NO;
            if (tno.IndexOf('_') > 0)
            {
                tno = tno.Substring(0, tno.LastIndexOf("_"));
            }
            var cno = "";
            // 获取主任务
            // var task = SqlSugarHelper.Db.Queryable<WMSTask>().Where(e => e.S_TASK_NO == tno)?.First();
            var task = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
            UoDown.S_TASK_NO = task?.S_TASK_NO;
            executeStatePara.ZtransportTask = task;
            string bit = null;


            if (task.S_TYPE == "出库")
            {
                bit = task.S_END_LOC;
                if (task.S_Subtask == "Y" && executeStatePara.transportTask.S_NOTE == "agv任务")
                {
                    var WcsTask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == executeStatePara.transportTask.S_SRC_NO + "_1");
                    if (WcsTask != null)
                    {
                        if (WcsTask.S_B_STATE != "完成")
                        {
                            return OperateResult.Error("立库任务还没完成,agv任务暂时不能完成！");
                        }
                    }
                }
            }
            //更新任务状态
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();
                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_END_TIME = DateTime.Now, S_B_STATE = Constants.TaskState_Complete }).Where(x => x.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                LogHelper.TaskDetail(logPara, "更新任务状态-任务号：" + executeStatePara.transportTask.S_TASK_NO + "状态为：" + executeStatePara.taskState);

                if (executeStatePara.transportTask.S_SRC_NO == executeStatePara.transportTask.S_TASK_NO)
                {
                    var Task_tk = tno + "_yk";
                    if (Task_tk != executeStatePara.transportTask.S_TASK_NO)
                    {
                        if (executeStatePara.transportTaskZ != null)
                        {
                            I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_END_TIME = DateTime.Now, S_B_STATE = Constants.TaskState_Complete }).Where(x => x.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新任务状态失败");
                            }
                        }

                    }
                }
                string taskNo = executeStatePara.transportTask.S_TASK_NO;
                //出库第二阶段任务 标记  用于完成时跳过起点货位状态变动
                string JbTaskNo = null;
                //立库任务   子任务完成时，需要同步处理主任务   
                if (taskNo.IndexOf('_') > 0)
                {
                    string topNo = taskNo.Substring(0, taskNo.IndexOf("_"));
                    string navNo = taskNo.Substring(taskNo.IndexOf("_") + 1);
                    cno = navNo;
                    if (navNo == "2")
                    {
                        JbTaskNo = navNo;
                    }
                    //A到B的AGV搬运任务
                    if (navNo == "1")
                    {
                        if (task.S_TYPE == "出库")
                        {
                            I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_START_TIME = DateTime.Now, S_B_STATE = Constants.TaskState_Executing }).Where(x => x.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新任务状态失败");
                            }
                            LogHelper.TaskDetail(logPara, "更新主任务状态-任务号：" + topNo + "状态为：" + Constants.TaskState_Executing);
                        }
                        else
                        {
                            //主任务状态更改为:完成一半
                            //I = SqlSugarHelper.Db.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = Constants.TaskState_CompleteHalf, S_READ_LOCK = "N" }).Where(x => x.S_TASK_NO == topNo).ExecuteCommand();
                            //if (I == 0)
                            //{
                            //    throw new Exception("更新任务状态失败");
                            //}
                            //LogHelper.TaskDetail(logPara, "更新主任务状态-任务号：" + topNo + "状态为：" + Constants.TaskState_CompleteHalf);
                        }
                    }
                    //B到C的立库搬运任务
                    if (navNo == "2")
                    {
                        //主任务状态更改为:完成
                        I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { T_END_TIME = DateTime.Now, S_B_STATE = Constants.TaskState_Complete }).Where(x => x.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新任务状态失败");
                        }
                        LogHelper.TaskDetail(logPara, "更新任务状态-任务号：" + topNo + "状态为：" + Constants.TaskState_Complete);
                    }
                }
                if (executeStatePara.transportTask.S_TYPE == null)
                    executeStatePara.transportTask.S_TYPE = "";
                #region 入库 + 转运
                if (executeStatePara.transportTask.S_TYPE.Equals("入库") || executeStatePara.transportTask.S_TYPE.Equals("转运"))
                {
                    var LocCnt = new LocCntrRel();
                    LocCnt.S_CNTR_CODE = executeStatePara.transportTask.S_CNTRS;
                    LocCnt.S_LOC_CODE = executeStatePara.transportTask.S_END_LOC;
                    LocCnt.S_TYPE = executeStatePara.transportTask.S_TOOLS_TPYE;
                    if (executeStatePara.transportTask.S_CNTRS != null && executeStatePara.transportTask.S_CNTRS.Contains("KJZ"))
                    {
                        LocCnt.S_TYPE = "KJZ";
                    }
                    if (executeStatePara.startTrayLocation != null)
                    {
                        //解绑托盘与货位的关系
                        I = newDb.Deleteable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                        if (I == 0)
                        {
                            LogHelper.TaskDetail(logPara, "删除起点托盘货位表失败");
                            //  throw new Exception("删除起点托盘货位表失败");
                        }
                        else
                        {
                            LogHelper.TaskDetail(logPara, "删除起点托盘货位表成功");
                        }
                        LogHelper.TaskDetail(logPara, "删除起点托盘货位表");
                        //起点
                        if (executeStatePara.startIsCurrentTask != null && executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y") && executeStatePara.transportTask.S_TYPE.Equals("转运"))
                        {
                            I = newDb.Updateable<Location>().SetColumns(it => new Location()
                            {
                                T_MODIFY = DateTime.Now,
                                N_CURRENT_NUM = 0,
                                T_EMPTY_TIME = DateTime.Now,
                                S_LOCK_STATE = "无",
                                S_TRAY_TYPE = "",
                                productionDate = "",
                                takeEffectTime = "",
                                expireTime = ""
                            }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新出库锁的货位状态为无数量为0失败");
                            }
                            LogHelper.TaskDetail(logPara, "更新出库锁的货位状态为无数量为0，起点货位号：" + executeStatePara.transportTask.S_START_LOC);
                        }
                    }
                    if (executeStatePara.endTrayLocation == null)
                    {
                        if ((
                            executeStatePara.endIsCurrentTask != null) &&
                            executeStatePara.endStockArea.S_CONTROL_QTY.Equals("Y"))
                        {
                            //添加托盘货位
                            I = newDb.Insertable(LocCnt).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("添加托盘货位表数据失败 " + executeStatePara.transportTask.S_CNTRS);
                            }
                            LogHelper.TaskDetail(logPara, "添加终点托盘货位表 " + executeStatePara.transportTask.S_CNTRS);
                            UoDown.Type = "+";
                            I = newDb.Insertable(UoDown).ExecuteCommand();
                            LogHelper.TaskDetail(logPara, "添加上架表");
                            I = newDb.Updateable<Location>().SetColumns(it => new Location()
                            {
                                T_MODIFY = DateTime.Now,
                                N_CURRENT_NUM = 1,
                                T_FULL_TIME = DateTime.Now,
                                S_LOCK_STATE = "无",
                                S_TRAY_TYPE = S_TRAY_TYPE,
                                productionDate = productionDate,
                                takeEffectTime = takeEffectTime,
                                expireTime = expireTime
                            }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新入库锁的货位状态为无数量为1失败");
                            }
                            LogHelper.TaskDetail(logPara, "更新入库锁的货位状态为无数量为1，终点货位号：" + executeStatePara.transportTask.S_END_LOC);
                        }
                    }
                }
                #endregion
                #region 出库
                if (executeStatePara.transportTask.S_TYPE.Equals("出库"))
                {
                    var LocCnt = new LocCntrRel();
                    LocCnt.S_CNTR_CODE = executeStatePara.transportTask.S_CNTRS;
                    LocCnt.S_LOC_CODE = executeStatePara.transportTask.S_END_LOC;
                    if (executeStatePara.startTrayLocation != null)
                    {
                        I = newDb.Deleteable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                        if (I == 0)
                        {
                            LogHelper.TaskDetail(logPara, "删除起点托盘货位表失败 " + executeStatePara.transportTask.S_CNTRS);
                            //  throw new Exception("删除起点托盘货位表失败");
                        }
                        else
                        {
                            LogHelper.TaskDetail(logPara, "删除起点托盘货位表成功  " + executeStatePara.transportTask.S_CNTRS);
                        }
                        //if (executeStatePara.trayItemMsts?.Count() > 0)
                        //{
                        //    I = SqlSugarHelper.Db.Deleteable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                        //    if (I == 0)
                        //    {
                        //        LogHelper.TaskDetail(logPara, "删除起点托盘货位表失败 " + executeStatePara.transportTask.S_CNTRS);
                        //        //  throw new Exception("删除起点托盘货位表失败");
                        //    }
                        //    else
                        //    {
                        //        LogHelper.TaskDetail(logPara, "删除起点托盘货位表成功  " + executeStatePara.transportTask.S_CNTRS);
                        //    }
                        //}
                        if (executeStatePara.trayItemMsts?.Count() > 0)
                        {
                            I = newDb.Deleteable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                            LogHelper.TaskDetail(logPara, "删除托盘物料表  " + executeStatePara.transportTask.S_CNTRS + $" 影响行数{I}");
                        }

                    }
                    if (executeStatePara.startIsCurrentTask.S_LOC_TYPE != "接驳位")
                    {
                        UoDown.Type = "-";
                        I = newDb.Insertable(UoDown).ExecuteCommand();
                        LogHelper.TaskDetail(logPara, "添加下架表");
                    }
                    //起点
                    if (executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y") && string.IsNullOrEmpty(JbTaskNo) && executeStatePara.startIsCurrentTask.N_CAPACITY < 2)
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location()
                        {
                            T_MODIFY = DateTime.Now,
                            N_CURRENT_NUM = 0,
                            T_EMPTY_TIME = DateTime.Now,
                            S_LOCK_STATE = "无",
                            S_TRAY_TYPE = "",
                            productionDate = "",
                            takeEffectTime = "",
                            expireTime = ""
                        }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新出库锁的货位状态为无数量为0失败");
                        }
                        LogHelper.TaskDetail(logPara, "更新出库锁的货位状态为无数量为0，起点货位号：" + executeStatePara.transportTask.S_START_LOC);
                    }
                    //终点
                    if (executeStatePara.endStockArea.S_CONTROL_QTY.Equals("Y") && executeStatePara.endIsCurrentTask.N_CAPACITY < 2)
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location()
                        {
                            T_MODIFY = DateTime.Now,
                            N_CURRENT_NUM = 1,
                            T_FULL_TIME = DateTime.Now,
                            S_LOCK_STATE = "无",
                            S_TRAY_TYPE = S_TRAY_TYPE,
                            productionDate = productionDate,
                            takeEffectTime = takeEffectTime,
                            expireTime = expireTime
                        }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新入库锁的货位状态为无数量为1失败");
                        }
                        LogHelper.TaskDetail(logPara, "更新入库锁的货位状态为无数量为1，终点货位号：" + executeStatePara.transportTask.S_END_LOC);
                        //添加托盘货位
                        if (executeStatePara.endTrayLocation == null)
                        {
                            I = newDb.Insertable(LocCnt).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("添加托盘货位表数据失败 " + executeStatePara.transportTask.S_CNTRS);
                            }
                            LogHelper.TaskDetail(logPara, "添加终点托盘货位表 " + executeStatePara.transportTask.S_CNTRS);
                        }
                    }
                    else
                    {
                        if (executeStatePara.trayItemMsts.Any())
                        {
                            I = newDb.Deleteable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                            if (I == 0)
                            {
                                LogHelper.TaskDetail(logPara, "删除托盘物料表失败");
                                //  throw new Exception("删除托盘物料表失败");
                            }
                            else
                            {
                                LogHelper.TaskDetail(logPara, "删除托盘物料表成功");
                            }
                        }
                        if (executeStatePara.endIsCurrentTask.S_LOC_TYPE == "堆叠")
                        {
                            I = newDb.Updateable<Location>().SetColumns(it => new Location()
                            {
                                T_MODIFY = DateTime.Now,
                                N_CURRENT_NUM = it.N_CURRENT_NUM + 1,
                                T_FULL_TIME = DateTime.Now,
                                S_LOCK_STATE = "无",
                                S_TRAY_TYPE = S_TRAY_TYPE
                            }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ExecuteCommand();
                            LogHelper.TaskDetail(logPara, "堆叠式更新货位容量，终点货位号：" + executeStatePara.transportTask.S_END_LOC + " 影响行数:" + I);
                        }
                    }
                }

                #endregion
                #region 移库

                if (executeStatePara.transportTask.S_TYPE.Equals("移库"))
                {

                    var LocCnt = new LocCntrRel();
                    LocCnt.S_CNTR_CODE = executeStatePara.transportTask.S_CNTRS;
                    LocCnt.S_LOC_CODE = executeStatePara.transportTask.S_END_LOC;

                    if (executeStatePara.startTrayLocation != null)
                    {
                        //解绑托盘与货位的关系

                        I = newDb.Deleteable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("删除起点托盘货位表失败");
                        }
                        LogHelper.TaskDetail(logPara, "删除起点托盘货位表");
                    }

                    if (executeStatePara.endTrayLocation == null)
                    {
                        //添加托盘货位
                        I = newDb.Insertable(LocCnt).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("添加托盘货位表数据失败");
                        }
                        LogHelper.TaskDetail(logPara, "添加终点托盘货位表");
                        //终点
                        if (executeStatePara.endIsCurrentTask != null && executeStatePara.endStockArea.S_CONTROL_QTY.Equals("Y"))
                        {
                            I = newDb.Updateable<Location>().SetColumns(it => new Location()
                            {
                                T_MODIFY = DateTime.Now,
                                N_CURRENT_NUM = 1,
                                T_FULL_TIME = DateTime.Now,
                                S_LOCK_STATE = "无",
                                S_TRAY_TYPE = S_TRAY_TYPE,
                                productionDate = productionDate,
                                takeEffectTime = takeEffectTime,
                                expireTime = expireTime
                            }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新入库锁的货位状态为无数量为1失败");
                            }
                            LogHelper.TaskDetail(logPara, "更新入库锁的货位状态为无数量为1失败，终点货位号：" + executeStatePara.transportTask.S_END_LOC);
                        }

                        //起点
                        if (executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y"))
                        {
                            I = newDb.Updateable<Location>().SetColumns(it => new Location()
                            {
                                T_MODIFY = DateTime.Now,
                                N_CURRENT_NUM = 0,
                                T_EMPTY_TIME = DateTime.Now,
                                S_LOCK_STATE = "无",
                                S_TRAY_TYPE = "",
                                productionDate = "",
                                takeEffectTime = "",
                                expireTime = ""
                            }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("更新出库锁的货位状态为无数量为0失败");
                            }
                            LogHelper.TaskDetail(logPara, "更新出库锁的货位状态为无数量为0，起点货位号：" + executeStatePara.transportTask.S_START_LOC);
                        }
                    }
                }
                #endregion
                #region 添加点对点接驳位释放表数据
                if (executeStatePara.transportTask.S_Subtask != "Y" && executeStatePara.transportTask.S_TASK_NO.IndexOf('_') < 0 && executeStatePara.transportTask.S_TYPE == "出库" && executeStatePara.transportTask.S_NOTE == "立库任务")
                {
                    if (executeStatePara.endStockArea.S_CONTROL_QTY.Equals("Y"))
                    {
                        AloneWcsTaskUnbingEntitys aloneWcsTask = new AloneWcsTaskUnbingEntitys()
                        {

                            S_TASK_NO = executeStatePara.transportTask.S_TASK_NO,
                            JbLocation = executeStatePara.transportTask.S_END_LOC,
                            IsRead = "N"
                        };
                        I = newDb.Insertable(aloneWcsTask).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("添加点对点接驳位释放表数据失败");
                        }
                        LogHelper.TaskDetail(logPara, "添加点对点接驳位释放表数据失败");
                    }
                }
                #endregion
                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                Task.Run(() =>
                {
                    if (executeStatePara.transportTask.S_SRC_SYS == "MES")
                    {
                        ZCReceivePriorityEntity mes = new ZCReceivePriorityEntity();

                        mes.taskNo = executeStatePara.transportTask.S_UpstreamNo;
                        var task2 = new WMSTask();
                        if (executeStatePara.transportTask.S_TYPE == "入库")
                        {
                            task2 = SqlSugarHelper.Db.Queryable<WMSTask>().Where(e => e.S_TASK_NO == executeStatePara.transportTask.S_UpstreamNo)?.First();
                        }
                        else
                        {
                            task2 = SqlSugarHelper.Db.Queryable<WMSTask>().Where(e => e.S_TASK_NO == tno)?.First();
                        }
                        if (task2 != null)
                        {
                            if (executeStatePara.transportTask.S_TYPE == "入库")
                            {
                                mes.End_big = "LCRKAGV";
                            }
                            if (executeStatePara.transportTask.S_TYPE == "出库")
                            {
                                mes.End_big = task2?.S_END_LOC ?? executeStatePara.transportTask.S_END_LOC;
                            }
                            mes.Data_status = 2;
                            //调mes接口
                            BLLCreator.CreateSingleton<MesTask>().MesTaskEntity(mes);
                        }
                    }
                });

                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();

                if (ex.Message.Contains("死锁"))
                {
                    newDb.BeginTran();

                    var I = newDb.Insertable(Deck).ExecuteCommand();
                    if (I == 0)
                    {
                        newDb.RollbackTran();
                    }
                    newDb.CommitTran();

                }
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }
        public virtual OperateResult CancelTask(ExecuteStateParaDto executeStatePara, LogPara logPara, string UserName = "")
        {
            List<string> TaskState = new List<string>() { "取消", "完成", "卸货完成" };
            if (TaskState.Contains(executeStatePara.transportTask.S_B_STATE))
            {
                return OperateResult.Error("只能取消非取消/完成/卸货完成的任务！");
            }
            deadlockRollEntitys Deck = new deadlockRollEntitys();
            Deck.S_INTER_STATE = "7";
            Deck.S_VALUE_JSON = executeStatePara.transportTask.S_TASK_NO;
            //中策项目对取消操作管控的最严 一不留神的操作可能造成整个任务和数据的错乱
            WMSTask task = executeStatePara.transportTask;
            WMSTask Wmtask = null;
            WMSTask Twotask = null;
            WMSTask Agvtask = null;
            string tno = executeStatePara.transportTask.S_TASK_NO;
            string navNo = "";
            if (tno.IndexOf('_') > 0)
            {
                navNo = tno.Substring(tno.IndexOf("_") + 1);
            }
            //主任务号
            string Tno = "";
            bool Desc = false;
            bool esc = false;
            bool Wcs = false;
            bool CkTask2 = false;
            bool RkTask = false;
            var WcsTask = new WMSTask();
            //这里 如果任务有分发子任务 说明是出库任务 并且该任务在进行的途中 这时候是不允许取消主任务的
            //立库任务取消要通知立库
            if (tno.IndexOf('_') < 0 && executeStatePara.transportTask.S_Subtask == "Y")
            {
                var tasklist = new List<string> { tno + "_1", tno + "_2" };
                Wmtask = executeStatePara.transportTaskSrc.Find(e => tasklist.Contains(e.S_TASK_NO));

                if (Wmtask != null)
                {
                    return OperateResult.Error("主任务不允许直接取消，请先取消子任务！！");
                }
            }
            //如果程序进入这里 ↓  说明是子任务取消操作 这时候获取主任务的信息
            if (tno.IndexOf('_') > 0)
            {
                tno = tno.Substring(0, tno.LastIndexOf("_"));
                task = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
                Tno = tno;
            }
            else if (executeStatePara.transportTask.S_TYPE.Equals("入库"))
            {
                //能进这里 说明是agv在入库 或者 RFID不符的时候 上报取消操作 这时候需要先删除库中的物料
                RkTask = true;
            }
            if (navNo == "2" && executeStatePara.transportTask.S_NOTE.Equals("agv任务"))//出库
            {
                //能进这里 说明是agv在出库  这时候要判断 立库是否执行完成  如果完成了 可以取消  没完成禁止取消
                Twotask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == Tno + "_1");
                if (Twotask.S_B_STATE.Trim().Equals("完成") || Twotask.S_B_STATE.Trim().Equals("取消"))
                {
                    Desc = true;
                }
                else
                {
                    return OperateResult.Error("立库任务一旦运行，无法取消！");
                }
            }
            if (navNo == "2" && executeStatePara.transportTask.S_NOTE.Equals("agv任务"))//出库
            {
                //能进这里说明立库任务已经处于完成状态 这时候 查询agv任务
                Twotask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == Tno + "_2");

                if (Twotask.S_B_STATE.Equals("取货完成"))
                {
                    CkTask2 = true;
                }
            }
            if (navNo == "2" && executeStatePara.transportTask.S_NOTE.Equals("立库任务"))//入库
            {
                //能进这里说明是入库的第二阶段 八成原因的RFID异常 要取消任务  这时候需要判断ams任务是否处于完成状态
                Twotask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == Tno + "_1");

                if (Twotask.S_B_STATE.Trim().Equals("完成") || Twotask.S_B_STATE.Trim().Equals("卸货完成"))
                {
                    esc = true;
                }
            }
            if (navNo == "1" && executeStatePara.transportTask.S_NOTE.Equals("立库任务"))//出库
            {
                //能进这里说明 是出库任务  并且报取消的是立库任务  这时候需要判断立库任务的实时状态
                Twotask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == Tno + "_1");
                Agvtask = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == Tno + "_2");
                if (Twotask.S_B_STATE.Trim().Equals("未执行") || Twotask.S_B_STATE.Trim().Equals("执行中") || Twotask.S_B_STATE.Trim().Equals("取货完成"))
                {
                    Wcs = true;
                }
                else
                {
                    return OperateResult.Error("立库任务一旦运行，无法取消！");
                }
            }
            if (navNo == "1" && executeStatePara.transportTask.S_NOTE.Equals("agv任务"))//入库
            {
                //能进这里说明 是入库任务  并且报取消的是立库任务  这时候需要判断立库任务的实时状态

                Task.Run(() =>
                {
                    NDCHelper.Cancel(executeStatePara.transportTask.S_TASK_NO);//取消agv任务
                    LogHelper.TaskDetail(logPara, "1通知agv取消任务" + executeStatePara.transportTask.S_TASK_NO);
                });

            }
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();
                var I = 0;
                if (CkTask2)
                {
                    I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                    if (I == 0)
                    {
                        throw new Exception("更新任务状态失败");
                    }
                    LogHelper.TaskDetail(logPara, "更新任务状态失败" + executeStatePara.transportTask.S_TASK_NO);

                    if (Tno != "")
                    {
                        //当子任务取消了 主任务跟着取消 
                        I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新任务状态失败");
                        }
                    }
                }
                if (RkTask)
                {
                    I = newDb.Deleteable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                    LogHelper.TaskDetail(logPara, "删除托盘物料表 托盘:" + executeStatePara.transportTask.S_CNTRS);
                }
                if (executeStatePara.transportTask.S_NOTE.Equals("agv任务") && UserName == "")
                {
                    UserName = "agv";
                }
                else if (!executeStatePara.transportTask.S_NOTE.Equals("自管任务") && UserName == "")
                {
                    UserName = "立库";
                }
                //更新任务状态

                I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                LogHelper.TaskDetail(logPara, "更新任务状态成功" + executeStatePara.transportTask.S_TASK_NO);
                if (Tno != "")
                {
                    I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                    if (I == 0)
                    {
                        throw new Exception("更新任务状态失败");
                    }
                    LogHelper.TaskDetail(logPara, "更新任务状态失败  " + "子任务取消 主任务跟着取消  主任务 任务号为" + Tno);
                }
                //终点
                if (executeStatePara.transportTask.S_TYPE.Equals("入库") || executeStatePara.transportTask.S_TYPE.Equals("转运")
                    || executeStatePara.transportTask.S_TYPE.Equals("移库"))
                {
                    if (executeStatePara.transportTask.S_TASK_NO.IndexOf('_') < 1 && executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.transportTask.S_Subtask != "Y")
                    {
                        NDCHelper.Cancel(executeStatePara.transportTask.S_TASK_NO);//取消agv任务
                        LogHelper.TaskDetail(logPara, "通知agv取消3任务" + executeStatePara.transportTask.S_TASK_NO);
                    }
                    else if (executeStatePara.transportTask.S_TASK_NO.IndexOf('_') < 1 && executeStatePara.transportTask.S_NOTE.Equals("立库任务") && executeStatePara.transportTask.S_Subtask != "Y")
                    {
                        var re = BLLCreator.CreateSingleton<WcsTask>().WcsCancellTask(executeStatePara.transportTask);
                        LogHelper.TaskDetail(logPara, $"立库任务取消通知{JsonConvert.SerializeObject(executeStatePara.transportTask)} 是否成功:{JsonConvert.SerializeObject(re)}");
                        if (!re.Success)
                        {
                            throw new Exception(re.Msg);
                        }
                    }
                    if (executeStatePara.endStockArea.S_CONTROL_QTY.Equals("Y"))
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location() { S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC && x.S_LOCK_STATE == "入库锁").ExecuteCommand();
                        LogHelper.TaskDetail(logPara, "更新终点货位" + executeStatePara.transportTask.S_END_LOC + "的状态为无！" + $"影响行数{I}");
                    }
                    if (task != null)
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location() { S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == task.S_END_LOC && x.S_LOCK_STATE == "入库锁").ExecuteCommand();

                        LogHelper.TaskDetail(logPara, "更新主任务终点货位" + task.S_END_LOC + "的状态为无！" + $"影响行数{I}");
                        if (task.S_TYPE.Equals("入库"))
                        {
                            I = newDb.Deleteable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                            LogHelper.TaskDetail(logPara, "删除托盘产品关联结果--托盘:" + executeStatePara.transportTask.S_CNTRS);
                        }
                    }
                }
                if (Desc)
                {
                    if (executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y"))
                    {
                        AloneWcsTaskUnbingEntitys aloneWcsTask = new AloneWcsTaskUnbingEntitys()
                        {
                            S_TASK_NO = executeStatePara.transportTask.S_TASK_NO,
                            JbLocation = Twotask.S_START_LOC,
                            IsRead = "N"
                        };
                        I = newDb.Insertable(aloneWcsTask).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("Agv取消释放接驳位");
                        }
                        LogHelper.TaskDetail(logPara, "Agv取消释放接驳位");
                    }
                    NDCHelper.Cancel(Twotask.S_TASK_NO);//取消agv任务
                    LogHelper.TaskDetail(logPara, "2通知agv取消任务" + Twotask.S_TASK_NO);
                }
                if (esc)
                {
                    var re = BLLCreator.CreateSingleton<WcsTask>().WcsCancellTask(executeStatePara.transportTask);
                    LogHelper.TaskDetail(logPara, $"立库任务取消通知{JsonConvert.SerializeObject(executeStatePara.transportTask)} 是否成功:{JsonConvert.SerializeObject(re)}");
                    if (!re.Success)
                    {
                        throw new Exception(re.Msg);
                    }
                    I = newDb.Updateable<Location>().SetColumns(it => new Location() { S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC && x.S_LOCK_STATE == "入库锁").ExecuteCommand();
                    LogHelper.TaskDetail(logPara, "更新主任务终点货位" + executeStatePara.transportTask.S_END_LOC + "的状态为无！");
                }
                //在立库任务没有执行的时候取消任务则释放 终点接驳位
                if (Wcs)
                {
                    var re = BLLCreator.CreateSingleton<WcsTask>().WcsCancellTask(Twotask);
                    LogHelper.TaskDetail(logPara, $"立库任务取消通知{JsonConvert.SerializeObject(Twotask)} 是否成功:{JsonConvert.SerializeObject(re)}");
                    if (!re.Success)
                    {
                        throw new Exception(re.Msg);
                    }
                    I = newDb.Updateable<Location>().SetColumns(it => new Location() { S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == Twotask.S_END_LOC && x.S_LOCK_STATE == "入库锁").ExecuteCommand();
                    LogHelper.TaskDetail(logPara, "更新立库任务终点货位" + Twotask.S_END_LOC + "的状态为无！" + $"影响行数{I}");
                    //更新agv子任务 任务状态
                    I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == Agvtask.S_ID).ExecuteCommand();
                    LogHelper.TaskDetail(logPara, "更新agv子任务的任务 " + Agvtask.S_TASK_NO + "的状态为取消！" + $"影响行数{I}");
                    NDCHelper.Cancel(Agvtask.S_TASK_NO);//取消agv任务
                    LogHelper.TaskDetail(logPara, "3通知agv取消任务" + Agvtask.S_TASK_NO);
                }
                //起点
                if (executeStatePara.transportTask.S_TYPE.Equals("出库") || executeStatePara.transportTask.S_TYPE.Equals("转运")
                    || executeStatePara.transportTask.S_TYPE.Equals("移库"))
                {
                    if (executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y"))
                    {
                        var Stalocarion = Twotask?.S_START_LOC ?? executeStatePara.transportTask.S_START_LOC;
                        I = newDb.Updateable<Location>().SetColumns(it => new Location() { S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == Stalocarion && x.S_LOCK_STATE == "出库锁").ExecuteCommand();
                        LogHelper.TaskDetail(logPara, "更新起点货位" + executeStatePara.transportTask.S_START_LOC + "的状态为无！" + $"影响行数{I}");
                    }
                    if (executeStatePara.transportTask.S_TASK_NO.IndexOf('_') < 1 && executeStatePara.transportTask.S_NOTE.Equals("agv任务") && executeStatePara.transportTask.S_Subtask != "Y")
                    {
                        NDCHelper.Cancel(executeStatePara.transportTask.S_TASK_NO);//取消agv任务
                        LogHelper.TaskDetail(logPara, "4通知agv取消任务" + executeStatePara.transportTask.S_TASK_NO);
                    }
                    if (executeStatePara.transportTask.S_TASK_NO.IndexOf('_') < 1 && executeStatePara.transportTask.S_NOTE.Equals("立库任务") && executeStatePara.transportTask.S_Subtask != "Y")
                    {
                        var re = BLLCreator.CreateSingleton<WcsTask>().WcsCancellTask(executeStatePara.transportTask);
                        LogHelper.TaskDetail(logPara, $"立库任务取消通知{JsonConvert.SerializeObject(executeStatePara.transportTask)} 是否成功:{JsonConvert.SerializeObject(re)}");
                        if (!re.Success)
                        {
                            throw new Exception(re.Msg);
                        }
                    }
                    if (executeStatePara.transportTask.S_Subtask == "Y" && executeStatePara.transportTask.S_NOTE.Equals("agv任务"))
                    {
                        if (executeStatePara.transportTask.S_B_STATE.Equals("未执行") || executeStatePara.transportTask.S_B_STATE.Equals("执行中") || executeStatePara.transportTask.S_B_STATE.Equals("已推送"))
                        {
                            AloneWcsTaskUnbingEntitys aloneWcsTask = new AloneWcsTaskUnbingEntitys()
                            {

                                S_TASK_NO = executeStatePara.transportTask.S_TASK_NO,
                                JbLocation = executeStatePara.transportTask.S_START_LOC,
                                IsRead = "N"
                            };
                            I = newDb.Insertable(aloneWcsTask).ExecuteCommand();
                            if (I == 0)
                            {
                                throw new Exception("添加点对点接驳位释放表数据失败");
                            }
                            LogHelper.TaskDetail(logPara, "添加点对点接驳位释放表数据");
                        }
                    }
                }
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.CommitTran();
                Task.Run(() =>
                {
                    if (executeStatePara.transportTask.S_SRC_SYS == "MES")
                    {
                        ZCReceivePriorityEntity mes = new ZCReceivePriorityEntity();
                        mes.taskNo = executeStatePara.transportTask.S_UpstreamNo;
                        var task2 = new WMSTask();
                        if (executeStatePara.transportTask.S_TYPE == "入库")
                        {
                            task2 = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == executeStatePara.transportTask.S_UpstreamNo);
                        }
                        else
                        {
                            task2 = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
                        }
                        if (task2 != null)
                        {
                            if (executeStatePara.transportTask.S_TYPE == "入库")
                            {
                                mes.End_big = task2?.S_START_LOC ?? executeStatePara.transportTask.S_START_LOC;
                            }
                            if (executeStatePara.transportTask.S_TYPE == "出库")
                            {
                                mes.End_big = task2?.S_END_LOC ?? executeStatePara.transportTask.S_END_LOC;
                            }
                            mes.Data_status = 3;
                            //调mes接口
                            BLLCreator.CreateSingleton<MesTask>().MesTaskEntity(mes);
                        }

                    }
                });

                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                if (ex.Message.Contains("死锁"))
                {
                    newDb.BeginTran();

                    var I = newDb.Insertable(Deck).ExecuteCommand();
                    if (I == 0)
                    {
                        newDb.RollbackTran();
                    }
                    newDb.CommitTran();

                }
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }
        public OperateResult PickSucc(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            if (!executeStatePara.transportTask.S_B_STATE.Equals("未执行") && !executeStatePara.transportTask.S_B_STATE.Equals("已推送") && !executeStatePara.transportTask.S_B_STATE.Equals("执行中") && !executeStatePara.transportTask.S_B_STATE.Equals("开始取货"))
            {
                return OperateResult.Error("只能执行已推送/未执行/执行中的任务！");
            }
            var locationExt = SqlSugarHelper.Db.Queryable<Location>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC)?.First();
            if (locationExt == null)
            {
                return OperateResult.Error("当前任务起点未找到货位扩展记录！");
            }


            string tno = executeStatePara.transportTask.S_TASK_NO;
            if (tno.IndexOf('_') > 0)
            {
                tno = tno.Substring(0, tno.LastIndexOf("_"));
            }
            // 获取主任务
            // var task = SqlSugarHelper.Db.Queryable<WMSTask>().Where(e => e.S_TASK_NO == tno)?.First();
            var task = executeStatePara.transportTaskSrc.Find(e => e.S_TASK_NO == tno);
            LogHelper.TaskDetail(logPara, "获取主任务：任务编号： " + tno);
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            Location location2 = null;
            List<ConfigValueList> ListValues = new List<ConfigValueList>();
            //if (executeStatePara.startIsCurrentTask.S_NOTE == "智能空桶满托")
            //{
            //    //查询配置表信息
            //    var transport = newDb.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "智能空桶缓存")?.First();
            //    if (transport != null)
            //    {
            //        ListValues = JsonConvert.DeserializeObject<List<ConfigValueList>>(transport.TypeJson);
            //        if (ListValues.Count() > 0)
            //        {
            //            //查询出对应的空托缓存位
            //            var ggf = ListValues.Find(e => e.LocationCode1 == executeStatePara.transportTask.S_START_LOC);
            //            if (ggf != null)
            //            {
            //                location2 = newDb.Queryable<Location>().Where(e => e.S_LOC_CODE == ggf.LocationCode2)?.First();
            //            }
            //        }
            //    }
            //}
            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();
                //更新任务状态
                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                LogHelper.TaskDetail(logPara, "更新任务状态" + executeStatePara.transportTask.S_TASK_NO);
                LogHelper.TaskDetail(logPara, "更新任务状态为：" + executeStatePara.taskState);
                //回报mes
                var bit = "";
                if (task.S_TYPE == "出库")
                {
                    bit = task.S_END_LOC;
                }
                if (executeStatePara.startTrayLocation != null)
                {
                    //解绑托盘与货位的关系
                    I = newDb.Deleteable<LocCntrRel>().Where(e => e.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                    //I = SqlSugarHelper.Db.Deleteable(executeStatePara.startTrayLocation).ExecuteCommand();
                    if (I == 0)
                    {
                        LogHelper.TaskDetail(logPara, "删除起点托盘货位表失败 " + executeStatePara.transportTask.S_CNTRS);
                        //  throw new Exception("删除起点托盘货位表失败");
                    }
                    else
                    {
                        LogHelper.TaskDetail(logPara, "删除起点托盘货位表成功 " + executeStatePara.transportTask.S_CNTRS);
                    }
                    //I = SqlSugarHelper.Db.Updateable<Location>().SetColumns(it => new Location() { N_CURRENT_NUM = 0, S_LOCK_STATE = "无" }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC && x.S_LOCK_STATE == "出库锁").ExecuteCommand();
                    //if (I == 0)
                    //{
                    //    throw new Exception("更新终点货位" + executeStatePara.transportTask.S_END_LOC + "的状态为无！");
                    //}
                    //LogHelper.TaskDetail(logPara, "更新任务终点货位" + executeStatePara.transportTask.S_START_LOC + "的状态锁为无！");
                }
                //if (executeStatePara.transportTask.S_TYPE.Equals("入库") && executeStatePara.startIsCurrentTask.S_NOTE == "智能空桶满托")
                //{
                //    if (location2 != null && (location2.N_CURRENT_NUM - 1 >= 0))
                //    {
                //        I = newDb.Updateable<Location>().SetColumns(it => new Location()
                //        {
                //            T_MODIFY = DateTime.Now,
                //            N_CURRENT_NUM = it.N_CURRENT_NUM - 1,
                //            T_EMPTY_TIME = DateTime.Now
                //        }).Where(x => x.S_LOC_CODE == location2.S_LOC_CODE).ExecuteCommand();
                //        if (I == 0)
                //        {
                //            throw new Exception("更新终点当前容量-1失败");
                //        }
                //    }
                //}
                if (executeStatePara.transportTask.S_TYPE.Equals("出库"))
                {
                    //删除托盘产品关联
                    if (executeStatePara.endStockArea.S_CONTROL_QTY != "Y")
                    {
                        I = newDb.Deleteable<CntrItemRel>().Where(e => e.S_CNTR_CODE == executeStatePara.transportTask.S_CNTRS).ExecuteCommand();
                        //if (I == 0)
                        //{
                        //    throw new Exception("删除托盘物料表失败");
                        //}
                        LogHelper.TaskDetail(logPara, "删除托盘产品关联结果--托盘:" + executeStatePara.transportTask.S_CNTRS);
                    }
                }
                //起点是否属于当前任务
                if (executeStatePara.startIsCurrentTask != null && executeStatePara.startStockArea.S_CONTROL_QTY.Equals("Y"))
                {
                    if (executeStatePara.startIsCurrentTask.N_CAPACITY < 2)
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location() { T_MODIFY = DateTime.Now, N_CURRENT_NUM = 0, S_LOCK_STATE = "无", S_TRAY_TYPE = "", productionDate = "", takeEffectTime = "", expireTime = "" }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_START_LOC).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新终点货位" + executeStatePara.transportTask.S_START_LOC + "的状态为无 更新失败！");
                        }
                        LogHelper.TaskDetail(logPara, "更新任务终点货位" + executeStatePara.transportTask.S_START_LOC + "的状态锁为无！");
                    }
                }
                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }

        /// <summary>
        /// 卸货完成
        /// </summary>
        /// <param name="executeStatePara"></param>
        /// <param name="logPara"></param>
        /// <returns></returns>
        public OperateResult UnloadingSucc(ExecuteStateParaDto executeStatePara, LogPara logPara)
        {
            List<string> TaskState = new List<string>() { "取消", "完成", "卸货完成" };
            if (TaskState.Contains(executeStatePara.transportTask.S_B_STATE))
            {
                return OperateResult.Error("只能执行没有 取消/完成/卸货完成的任务！");
            }
            if (executeStatePara.transportTask.S_NOTE.Equals("自管任务") && executeStatePara.transportTask.S_Subtask == "Y")
            {
                return OperateResult.Error("主任务禁止直接完成！");
            }
            var taskNo = executeStatePara.transportTask.S_TASK_NO;
            string topNo = "";
            if (taskNo.IndexOf("_") > 0)
            {
                topNo = taskNo.Substring(0, taskNo.IndexOf("_"));
            }
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();

            List<string> AreaLo = new List<string>() { "TCXB", "TTXB", "NCXB", "DSXB", "TMXB", "TQXB", "TQJT" };
            WMSTask PritTask = null;
            //查询是否是相关库区
            if (executeStatePara.transportTask.S_TYPE == "出库" && AreaLo.Contains(executeStatePara.transportTask.S_END_LAREA))
            {
                LogHelper.TaskDetail(logPara, $"更新任务优先级-任务号：{executeStatePara.transportTask.S_TASK_NO} 终点库区是否包含{JsonConvert.SerializeObject(AreaLo)} 本任务:" + executeStatePara.transportTask.S_END_LAREA);
                //查询配置文件
                var transportTask = STAttribute.GetValueTwo(executeStatePara.transportTask.S_END_LAREA + "-送满取空");
                if (transportTask != null)
                {
                    var ListString = JsonConvert.DeserializeObject<List<ConfigValueListTwo>>(transportTask);
                    if (ListString != null && ListString.Count > 0)
                    {
                        var Strin = ListString.Find(e => e.LocationCode1 == executeStatePara.transportTask.S_END_LOC);
                        LogHelper.TaskDetail(logPara, "更新任务优先级-任务号：" + executeStatePara.transportTask.S_TASK_NO + "是否匹配到了队友的货位信息" + JsonConvert.SerializeObject(Strin));
                        if (Strin != null)
                        {
                            //查询旁边的货位是否有已推送但是没执行的任务
                            //  List<string> TaskState2 = new List<string> { "未执行", "已推送", "执行中" };
                            var SfgLo = newDb.Queryable<WMSTask>().Where(e => Strin.LocationCode2.Contains(e.S_START_LOC) && e.S_NOTE.Equals("agv任务") && (e.S_B_STATE == "未执行" || e.S_B_STATE == "已推送" || e.S_B_STATE == "执行中")).ToList();
                            LogHelper.TaskDetail(logPara, "更新任务优先级-任务号：" + executeStatePara.transportTask.S_TASK_NO + "匹配到的货位 是否存在 是agv任务 并且任务状态为 未执行/已推送/执行中 的任务有:" + JsonConvert.SerializeObject(SfgLo));
                            if (SfgLo.Count() > 0)//有这个任务
                            {
                                //看这个任务是否是有处于配置空托第一位的货位
                                var OneLoc = Strin.LocationCode2.FirstOrDefault();
                                LogHelper.TaskDetail(logPara, "更新任务优先级  配置中第一个货位为：" + OneLoc);
                                var OneTask = SfgLo.Find(e => e.S_START_LOC == OneLoc);
                                if (OneTask != null)
                                {
                                    if (OneTask.S_B_STATE == "未执行")//推送任务
                                    {
                                        OneTask.N_PRIORITY = 60;
                                        TaskProcess.SendTask(OneTask);
                                    }
                                    else
                                    {
                                        var Agvstr = NDCHelper.ChangeParamPri(OneTask.S_TASK_NO, 60);
                                        LogHelper.TaskDetail(logPara, "更新任务优先级-任务号：" + OneTask.S_TASK_NO + "优先级为：" + 60 + "   是否成功 :" + Agvstr);
                                    }
                                    PritTask = OneTask;
                                }
                                else
                                {
                                    SfgLo = SfgLo.OrderBy(e => e.T_CREATE).ToList();
                                    var OneTaskR = SfgLo.FirstOrDefault();
                                    if (OneTaskR.S_B_STATE == "未执行")//推送任务
                                    {
                                        OneTaskR.N_PRIORITY = 60;
                                        TaskProcess.SendTask(OneTaskR);
                                    }
                                    else
                                    {
                                        var Agvstr = NDCHelper.ChangeParamPri(OneTaskR.S_TASK_NO, 60);
                                        LogHelper.TaskDetail(logPara, "更新任务优先级-任务号：" + OneTaskR.S_TASK_NO + "优先级为：" + 60 + "   是否成功 :" + Agvstr);
                                    }
                                    PritTask = OneTaskR;
                                }
                            }
                        }
                    }
                }
            }

            try
            {
                LogHelper.TaskDetail(logPara, "更新任务状态 事务开始:" + executeStatePara.transportTask.S_TASK_NO);
                newDb.BeginTran();
                //更新任务状态
                var I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = executeStatePara.taskState }).Where(e => e.S_ID == executeStatePara.transportTask.S_ID).ExecuteCommand();
                if (I == 0)
                {
                    throw new Exception("更新任务状态失败");
                }
                LogHelper.TaskDetail(logPara, "更新任务状态" + executeStatePara.transportTask.S_TASK_NO);
                LogHelper.TaskDetail(logPara, "更新任务状态为：" + executeStatePara.taskState);
                //主任务状态更改为:完成一半
                LogHelper.TaskDetail(logPara, $" 主任务号{topNo} 类型:{executeStatePara.transportTask.S_TYPE} mark:{executeStatePara.transportTask.mark}");
                if (!string.IsNullOrEmpty(topNo) && executeStatePara.transportTask.S_TYPE.Equals("入库") && executeStatePara.transportTask.mark != "Y")
                {
                    if (executeStatePara.endIsCurrentTask.S_LOC_TYPE != "接驳位")
                    {
                        I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = Constants.TaskState_Complete }).Where(e => e.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新任务状态失败");
                        }
                        LogHelper.TaskDetail(logPara, "更新主任务状态-任务号：" + topNo + "状态为：" + Constants.TaskState_Complete);
                    }
                    else
                    {
                        I = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { S_B_STATE = Constants.TaskState_CompleteHalf, S_READ_LOCK = "N" }).Where(e => e.S_ID == executeStatePara.transportTaskZ.S_ID).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新任务状态失败");
                        }
                        LogHelper.TaskDetail(logPara, "更新主任务状态-任务号：" + topNo + "状态为：" + Constants.TaskState_CompleteHalf);
                    }
                }
                if (executeStatePara.endIsCurrentTask.S_NOTE == "智能空桶缓存点")
                {
                    if (executeStatePara.endIsCurrentTask.N_CURRENT_NUM + 1 <= executeStatePara.endIsCurrentTask.N_CAPACITY)
                    {
                        I = newDb.Updateable<Location>().SetColumns(it => new Location()
                        {
                            T_MODIFY = DateTime.Now,
                            N_CURRENT_NUM = it.N_CURRENT_NUM + 1,
                            T_EMPTY_TIME = DateTime.Now
                        }).Where(x => x.S_LOC_CODE == executeStatePara.transportTask.S_END_LOC).ExecuteCommand();
                        if (I == 0)
                        {
                            throw new Exception("更新终点当前容量+1失败");
                        }
                    }
                }

                if (PritTask != null)
                {
                    // var ddd = executeStatePara.transportTaskSrc.Select(e => e.S_ID).ToList();
                    var ggj = newDb.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = 60 }).Where(e => e.S_ID == PritTask.S_ID).ExecuteCommand();
                    LogHelper.TaskDetail(logPara, "更新任务优先级-任务号：" + PritTask.S_TASK_NO + "优先级为：" + 60 + "   是否成功 改wms任务 影响行数:" + ggj);
                }
                newDb.CommitTran();
                LogHelper.TaskDetail(logPara, "更新任务状态 事务结束:" + executeStatePara.transportTask.S_TASK_NO);
                return OperateResult.Succeed();
            }
            catch (Exception ex)
            {
                LogHelper.TaskDetail(logPara, JsonConvert.SerializeObject(ex));
                newDb.RollbackTran();
                return OperateResult.Error(JsonConvert.SerializeObject(ex));
            }
        }

    }

}