using HH.WCS.Mobox3.WeiLi.device;
using HH.WCS.Mobox3.WeiLi.dispatch;
using HH.WCS.Mobox3.WeiLi.models;
using HH.WCS.Mobox3.WeiLi.process;
using HH.WCS.Mobox3.WeiLi.util;
using HH.WCS.Mobox3.WeiLi.wms;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Threading;
using static HH.WCS.Mobox3.WeiLi.api.ApiModel;
using static HH.WCS.Mobox3.WeiLi.api.OtherModel;
using static HH.WCS.Mobox3.WeiLi.wms.WMSHelper;

namespace HH.WCS.Mobox3.WeiLi.api
{
    /// <summary>
    /// api接口辅助类
    /// </summary>
    public class ApiHelper
    {
        static ApiHelper()
        {

        }


        internal static SimpleResult Putaway_Order_In(Putaway_Order_In model)
        {
            var result = new SimpleResult();
            //创建入库单主子表
            var po = WMSHelper.GetPutawayOrder(model.Data.arrival_no);
            if (po == null)
            {
                po = new PutawayOrder { S_NO = model.Data.arrival_no, S_BS_TYPE = model.Data.op_type };
                po.Details = new List<PutawayDetail>();
                if (model.Data.items.Count > 0)
                {
                    model.Data.items.ForEach(a =>
                    {
                        po.Details.Add(new PutawayDetail
                        {
                            S_PUTAWAY_NO = model.Data.arrival_no,
                            N_ROW_NO = po.Details.Count + 1,
                            S_ITEM_CODE = a.item_code,
                            F_QTY = a.qty,
                            S_BATCH_NO = a.batch_no,
                        });
                    });
                    WMSHelper.CreatePutawayOrder(po);
                }

            }
            return result;
        }

        internal static WeiLiResult ItemInfoSync(List<ItemInfoSyncModel> model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            if (model.Count > 0)
            {
                model.ForEach(a =>
                {
                    var info = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                    if (info != null)
                    {
                        info.S_ITEM_NAME = a.itemName;
                        info.S_IS_MANAGE = a.isManage;
                        info.S_IS_MANAGEDATE = a.isManageDate;
                        db.Updateable<TN_Material>(info).UpdateColumns(it => new { it.S_ITEM_NAME, it.S_IS_MANAGE, it.S_IS_MANAGEDATE }).ExecuteCommand();
                    }
                    else
                    {
                        db.Insertable(new TN_Material { S_ITEM_CODE = a.itemCode, S_ITEM_NAME = a.itemName, S_IS_MANAGE = a.isManage, S_IS_MANAGEDATE = a.isManageDate }).ExecuteCommand();
                    }
                    //db.Updateable<TN_Material>().SetColumns(it => new TN_Material() { S_ITEM_NAME = a.itemName }).Where(it => it.S_ITEM_CODE == a.itemCode).ExecuteCommand();
                    //db.Updateable<WHInventory>().SetColumns(it => new WHInventory() { S_ITEM_NAME = a.itemName }).Where(it => it.S_ITEM_CODE == a.itemCode).ExecuteCommand();
                });
            }
            return result;
        }

        internal static WeiLiResult FiveCodeSync(List<FiveCodeSyncResult> model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            if (model.Count > 0)
            {
                model.ForEach(a =>
                {
                    var info = db.Queryable<FiveCode>().Where(it => it.S_FIVE_CODE == a.fiveCode).First();
                    if (info != null)
                    {
                        info.S_IS_MANAGE = a.isManage;
                        info.S_IS_MANAGEDATE = a.isManageDate;
                        db.Updateable<FiveCode>(info).UpdateColumns(it => new { it.S_IS_MANAGE, it.S_IS_MANAGEDATE }).ExecuteCommand();
                    }
                    else
                    {
                        db.Insertable(new FiveCode { S_FIVE_CODE = a.fiveCode, S_IS_MANAGE = a.isManage, S_IS_MANAGEDATE = a.isManageDate }).ExecuteCommand();
                    }
                });
            }
            return result;
        }

        internal static WeiLiResult AddTask(AddTaskModel model)
        {
            var result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            var cntrweight = model.cntrWeight == 1 ? 2 : model.cntrWeight == 2 ? 3 : model.cntrWeight == 3 ? 11 : model.cntrWeight == 4 ? 30 : model.cntrWeight == 5 ? 150 : 0;
            if (!string.IsNullOrEmpty(model.startBit) && !string.IsNullOrEmpty(model.endBit))
            {
                if (!string.IsNullOrEmpty(model.TaskNo))
                {
                    var taskinfo = db.Queryable<WMSTask>().Where(a => a.S_CODE == model.TaskNo).First();
                    if (taskinfo == null)
                    {
                        var startinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.startBit).First();
                        var endinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.endBit).First();
                        if (startinfo != null && endinfo != null)
                        {
                            if (startinfo.N_LOCK_STATE != 0 || endinfo.N_LOCK_STATE != 0)
                            {
                                result.code = 500;
                                result.msg = "起点或终点货位锁定状态异常 不予创建任务";
                                return result;
                            }

                            var startloccntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startinfo.S_CODE).First();
                            LogHelper.Info("查询起点是否绑定托盘");
                            if (startloccntr == null)
                            {
                                LogHelper.Info("起点未绑定托盘 准备绑定托盘");
                                //绑定起点托盘
                                LocationHelper.BindingLoc(model.startBit, new List<string>() { model.cntrNo });
                            }
                            else if (startloccntr.S_CNTR_CODE != model.cntrNo)
                            {
                                result.code = 500;
                                result.msg = $"起点已绑定托盘{startloccntr.S_CNTR_CODE} 与任务托盘{model.cntrNo} 不符";
                                return result;
                            }

                            LogHelper.Info("转运任务 创建作业");

                            //创建作业
                            var optask = new WMSTask
                            {
                                S_CODE = model.TaskNo,
                                S_START_LOC = startinfo.S_CODE,
                                S_END_LOC = endinfo.S_CODE,
                                S_END_AREA = endinfo.S_AREA_CODE,
                                S_START_AREA = startinfo.S_AREA_CODE,
                                S_START_WH = startinfo.S_WH_CODE,
                                S_END_WH = endinfo.S_WH_CODE,
                                S_TYPE = "转运",
                                N_TYPE = 3,
                                N_B_STATE = 0,
                                S_CNTR_CODE = model.cntrNo,
                                S_OP_DEF_NAME = "转运",
                                S_BS_NO = model.workNo,
                                N_PRIORITY = model.priority,
                                N_TRAY_WEIGHT = cntrweight
                            };

                            var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                            if (note != null)
                            {
                                optask.S_NOTE = note.TaskType;
                            }



                            db.Insertable(optask).ExecuteCommand();
                            LocationHelper.LockLoc(startinfo.S_CODE, 2);
                            LocationHelper.LockLoc(endinfo.S_CODE, 1);
                        }
                        else
                        {
                            result.code = 500;
                            result.msg = "起点或终点信息有误 查询不到站点信息";
                        }
                    }
                    else
                    {
                        result.code = 500;
                        result.msg = "任务号重复 请勿重复下发任务";
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "任务号不能为空";
                }
            }
            else
            {
                result.code = 500;
                result.msg = "起点或终点不能为空";
            }

            return result;
        }

        internal static SimpleResult ErrorOperation(MoboxOperationBase model)
        {
            var result = new SimpleResult();
            var db = new SqlHelper<object>().GetInstance();
            var wmsTask = db.Queryable<WMSTask>().Where(a => a.S_CODE == model.OperationNo).First();
            if (wmsTask != null) 
            {
                LogHelper.Info($"清除错误作业 解绑托盘 托盘{wmsTask.S_CNTR_CODE}");
                db.Deleteable<LocCntrRel>().Where(a => a.S_CNTR_CODE == wmsTask.S_CNTR_CODE).ExecuteCommand();
                db.Deleteable<CntrItemRel>().Where(a => a.S_CNTR_CODE == wmsTask.S_CNTR_CODE).ExecuteCommand();
                var locInfo = db.Queryable<Location>().Where(a => a.S_CODE == wmsTask.S_START_LOC).First();
                if (locInfo != null) 
                {
                    LogHelper.Info($"清除错误作业 重置货位状态 货位{locInfo.S_CODE}");
                    locInfo.N_CURRENT_NUM = 0;
                    locInfo.N_LOCK_STATE = 0;
                    locInfo.S_LOCK_STATE = "无";
                    db.Updateable(locInfo).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
                }
            }

            return result;
        }

        internal static TaskStateresutl GetTaskState(GetTaskStateModel model)
        {
            var db = new SqlHelper<object>().GetInstance();
            TaskStateresutl result = new TaskStateresutl { success = false, code = 0 };
            if (!string.IsNullOrEmpty(model.taskNo))
            {
                var info = db.Queryable<WCSTask>().Where(a => a.S_OP_CODE == model.taskNo).First();
                if (info != null)
                {
                    var TaskStates = db.Queryable<TaskAction>().Where(a => a.S_TASK_CODE == info.S_CODE).ToList();
                    TaskStates = TaskStates.OrderBy(a => a.T_CREATE).ToList();
                    for (int i = 0; i < TaskStates.Count; i++)
                    {
                        TaskState task = new TaskState
                        {
                            state = TaskStates[i].N_ACTION_CODE.ToString(),
                            errMsg = "",
                            taskNo = model.taskNo,
                            transferTime = TaskStates[i].T_CREATE.ToString()
                        };
                        if (!string.IsNullOrEmpty(TaskStates[i].S_EQ_CODE))
                        {
                            task.agvNo = int.Parse(TaskStates[i].S_EQ_CODE);
                        }
                        result.data.Add(task);
                    }
                    result.success = true;
                }
                else
                {
                    result.code = 1;
                    result.msg = "该任务号没有状态记录!";
                }
            }
            else
            {
                result.code = 1;
                result.msg = "请求任务号不能为空!";
            }
            return result;
        }

        internal static SimpleResult WeiLiDisbutionIn(WeiLiDisbutionInMolde model)
        {
            int Ntype = 0; string Stype = ""; string S_OP_DEF_NAME = "";
            var result = new SimpleResult { resultCode = 0 };
            Location end = null;
            var db = new SqlHelper<object>().GetInstance();
            if (model.isTask == "Y")
            {
                if (string.IsNullOrEmpty(model.endArea) && string.IsNullOrEmpty(model.endLoc))
                {
                    Ntype = 1;
                    Stype = "入库";
                    S_OP_DEF_NAME = "分拣回";
                }
                else
                {
                    Ntype = 2;
                    Stype = "出库";
                    S_OP_DEF_NAME = "分拣出";
                }

                var TrayPrefix = model.cntrNo.Substring(0, 2);
                var endinfo = Settings.LKCodes.Where(a => a.TrayPrefix == TrayPrefix).FirstOrDefault();
                if (endinfo != null)
                {
                    if (string.IsNullOrEmpty(model.endArea))
                    {
                        model.endArea = endinfo.LiKuCode;
                    }
                }
                else
                {
                    result.resultCode = -1;
                    result.resultMsg = "终点库区为空 默认回库 找不到托盘前缀对应的回库库区";
                    return result;
                }

                if (!string.IsNullOrEmpty(model.endLoc))
                {
                    end = db.Queryable<Location>().Where(a => a.S_CODE == model.endLoc).First();
                    if (end != null)
                    {
                        if (end.N_LOCK_STATE != 0 || end.N_CURRENT_NUM != 0)
                        {
                            result.resultCode = 1;
                            result.resultMsg = "终点货位状态不满足生成任务";
                            return result;
                        }
                    }
                    else
                    {
                        result.resultCode = 1;
                        result.resultMsg = "终点货位信息不存在";
                        return result;
                    }
                }

                var cntrinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrNo).First();
                if (cntrinfo != null)
                {
                    var start = db.Queryable<Location>().Where(a => a.S_CODE == cntrinfo.S_LOC_CODE).First();
                    if (start != null)
                    {
                        if (start.N_LOCK_STATE == 0)
                        {
                            var conntinfo = Settings.ConnetAreas.Where(a => a.FullList.Contains(start.S_CODE) || a.EmptyList.Contains(start.S_CODE)).FirstOrDefault();
                            if (conntinfo != null)
                            {
                                var id = DateTime.Now.Ticks.ToString();
                                var reqinfo = db.Queryable<TN_PRICE>().Where(a => a.S_CNTR_CODE == model.cntrNo && a.S_NO == model.workNo).First();
                                if (reqinfo != null)
                                {
                                    id = reqinfo.S_REPEAT;
                                }
                                else
                                {
                                    reqinfo = new TN_PRICE { S_NO = model.workNo, S_CNTR_CODE = model.cntrNo, S_REPEAT = id };
                                    db.Insertable(reqinfo).ExecuteCommand();
                                }
                                if (!string.IsNullOrEmpty(model.endLoc))
                                {
                                    //创建作业
                                    var optask = new WMSTask
                                    {
                                        S_CODE = WMSHelper.GenerateTaskNo(),
                                        S_START_WH = start.S_WH_CODE,
                                        S_START_LOC = start.S_CODE,
                                        S_START_AREA = start.S_AREA_CODE,
                                        S_END_LOC = end.S_CODE,
                                        S_END_AREA = end.S_AREA_CODE,
                                        S_END_WH = end.S_WH_CODE,
                                        S_STATION_LOC = conntinfo.Station,
                                        N_TYPE = Ntype,
                                        S_TYPE = Stype,
                                        N_B_STATE = 0,
                                        S_CNTR_CODE = model.cntrNo,
                                        S_OP_DEF_NAME = S_OP_DEF_NAME,
                                        S_BS_NO = model.workNo
                                    };
                                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                                    if (note != null)
                                    {
                                        optask.S_NOTE = note.TaskType;
                                    }
                                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                                    LocationHelper.LockLoc(start.S_CODE, 2);
                                    LocationHelper.LockLoc(end.S_CODE, 1);
                                }
                                else
                                {
                                    //创建作业
                                    var optask = new WMSTask
                                    {
                                        S_CODE = WMSHelper.GenerateTaskNo(),
                                        S_START_WH = start.S_WH_CODE,
                                        S_START_LOC = start.S_CODE,
                                        S_START_AREA = start.S_AREA_CODE,
                                        S_END_LOC = "",
                                        S_END_AREA = model.endArea,
                                        S_END_WH = start.S_WH_CODE,
                                        S_STATION_LOC = conntinfo.Station,
                                        N_TYPE = Ntype,
                                        S_TYPE = Stype,
                                        N_B_STATE = 0,
                                        S_CNTR_CODE = model.cntrNo,
                                        S_OP_DEF_NAME = S_OP_DEF_NAME,
                                        S_BS_NO = model.workNo
                                    };
                                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                                    if (note != null)
                                    {
                                        optask.S_NOTE = note.TaskType;
                                    }
                                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                                    LocationHelper.LockLoc(start.S_CODE, 2);
                                }
                            }
                            else
                            {
                                result.resultCode = -2;
                                result.resultMsg = $"货位{start.S_CODE} 在接驳库区配置中找不到对应的拣货位信息";
                            }
                        }
                        else
                        {
                            result.resultCode = -3;
                            result.resultMsg = $"货位{start.S_CODE} 当前状态为{start.S_LOCK_STATE} 不予生成任务";
                        }
                    }
                    else
                    {
                        result.resultCode = -1;
                        result.resultMsg = $"查询不到托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE}的货位信息";
                    }
                }
                else
                {
                    result.resultCode = -1;
                    result.resultMsg = $"查询不到托盘{model.cntrNo} 的绑定货位";
                }
            }
            else
            {
                //人工库出库 解绑起点货位
                var url = Settings.ZTSeverUrl2 + "/business/BU_HX02";

                var id = DateTime.Now.Ticks.ToString();
                var reqinfo = db.Queryable<TN_PRICE>().Where(a => a.S_CNTR_CODE == model.cntrNo && a.S_NO == model.workNo).First();
                if (reqinfo != null)
                {
                    id = reqinfo.S_REPEAT;
                }
                else
                {
                    reqinfo = new TN_PRICE { S_NO = model.workNo, S_CNTR_CODE = model.cntrNo, S_REPEAT = id };
                    db.Insertable(reqinfo).ExecuteCommand();
                }

                var req = new { shippingNoteNo = model.workNo, cntrNo = "", destLocation = "", repeat = id, data = new List<object>() };
                model.data.ForEach(it =>
                {
                    req.data.Add(new
                    {
                        itemCode = it.itemCode,
                        factoryCode = string.IsNullOrEmpty(it.factoryCode) ? "" : it.factoryCode,
                        stockCode = string.IsNullOrEmpty(it.stockLocation) ? "" : it.stockLocation,
                        qty = Convert.ToInt32(it.qty),
                        vendorCode = string.IsNullOrEmpty(it.vendorCode) ? "" : it.vendorCode,
                        batchNo = string.IsNullOrEmpty(it.batchNo) ? "" : it.batchNo,
                        serialNo = string.IsNullOrEmpty(it.serialNo) ? "" : it.serialNo
                    });
                });
                LogHelper.Info($"出库完成任务回报 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
                var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
                if (!string.IsNullOrEmpty(feedback))
                {
                    var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
                    if (weilires.code == 200)
                    {
                        LogHelper.Info($"接口反馈成功");
                    }
                    else
                    {
                        LogHelper.Info($"出库完成任务回报 反馈失败 失败原因={weilires.msg}");
                        result.resultCode = -2;
                        result.resultMsg = $"回报中台出库单完成错误 错误信息{weilires.msg}";
                        return result;
                    }
                }
                else
                {
                    LogHelper.Info($"出库完成任务回报 反馈超时");
                    result.resultCode = -2;
                    result.resultMsg = $"出库完成任务回报 反馈超时";
                    return result;
                }

                //解绑起点
                var cntrinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrNo).First();
                if (cntrinfo != null)
                {
                    var start = db.Queryable<Location>().Where(a => a.S_CODE == cntrinfo.S_LOC_CODE).First();
                    if (start != null)
                    {
                        var deletechange = true;
                        //降量
                        url = Settings.MoboxSeverUrl + "inventory/AddChange";
                        //仓库量表升量
                        var req1 = new AddChangeModel { op_type = 4 };
                        //库区量表升量
                        var req2 = new AddChangeModel { op_type = 7 };
                        model.data.ForEach(a =>
                        {
                            LogHelper.Info($"填充数据");
                            LogHelper.Info($"减仓库量表数据 仓库{start.S_WH_CODE} 物料编码{a.itemCode} 物料名称{a.itemName} 数量{a.qty}");
                            req1.item_info.Add(new AddChangeModel.itemModel
                            {
                                wh_code = start.S_WH_CODE,
                                item_code = a.itemCode,
                                item_name = a.itemName,
                                qty = a.qty
                            });
                            LogHelper.Info($"减库区量表数据 库区{start.S_AREA_CODE} 物料编码{a.itemCode} 物料名称{a.itemName} 数量{a.qty}");
                            req2.item_info.Add(new AddChangeModel.itemModel
                            {
                                area_code = start.S_AREA_CODE,
                                wh_code = start.S_WH_CODE,
                                item_code = a.itemCode,
                                item_name = a.itemName,
                                qty = a.qty
                            });
                        });
                        var reqData = JsonConvert.SerializeObject(req);
                        var AppKey = Settings.AppKey;
                        var AppSecret = Settings.AppSecret;
                        var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
                        //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
                        LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}");
                        var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime);
                        LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}");
                        var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify);
                        if (!string.IsNullOrEmpty(res))
                        {
                            LogHelper.Info($"mobox 仓库降量接口返回 {res}");
                            var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
                            if (moboxres.err_code != 0)
                            {
                                deletechange = false;
                                result.resultCode = -1;
                                result.resultMsg = $"mobox仓库降量失败 失败原因{moboxres.err_msg}";
                            }
                        }
                        else
                        {
                            LogHelper.Info($"mobox 仓库降量接口返回为空");
                            deletechange = false;
                            result.resultCode = -1;
                            result.resultMsg = "mobox 仓库降量接口返回为空";
                        }
                        var reqData2 = JsonConvert.SerializeObject(req2);
                        var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
                        //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
                        LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}");
                        var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2);
                        LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}");
                        var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2);
                        if (!string.IsNullOrEmpty(res2))
                        {
                            LogHelper.Info($"mobox 库区降量接口返回 {res2}");
                            var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
                            if (moboxres.err_code != 0)
                            {
                                deletechange = false;
                                result.resultCode = -1;
                                result.resultMsg = $"mobox库区降量失败 失败原因{moboxres.err_msg}";
                            }
                        }
                        else
                        {
                            LogHelper.Info($"mobox 库区降量接口返回为空");
                            deletechange = false;
                            result.resultCode = -1;
                            result.resultMsg = "mobox库区降量接口返回为空";
                        }
                        if (deletechange)
                        {

                            foreach (var item in model.data)
                            {
                                var info = new TN_OnOff_Shelves
                                {
                                    S_NO = model.workNo,
                                    N_ACTION = 2,
                                    S_ACTION = "下架",
                                    S_ITEM_CODE = item.itemCode,
                                    S_ITEM_NAME = item.itemName,
                                    S_LOC_CODE = start.S_CODE,
                                    S_AREA_CODE = start.S_AREA_CODE,
                                    S_CNTR_CODE = model.cntrNo,
                                    S_BATCH_NO = item.batchNo,
                                    S_SERIAL_NO = item.serialNo,
                                    D_PRD_DATE = "",
                                    F_QTY = item.qty
                                };
                                db.Insertable(info).ExecuteCommand();
                            }



                            //修改起点容量
                            start.N_CURRENT_NUM = 0;
                            db.Updateable(start).UpdateColumns(it => new { it.N_CURRENT_NUM }).ExecuteCommand();
                            db.Deleteable(cntrinfo).ExecuteCommand();
                        }
                    }
                    else
                    {
                        result.resultCode = -1;
                        result.resultMsg = $"查询不到托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE}的货位信息";
                    }
                }
                else
                {
                    result.resultCode = -1;
                    result.resultMsg = $"查询不到托盘{model.cntrNo} 的绑定货位";
                }
            }

            return result;
        }

        internal static WeiLiResult CancelOutWork(CancelOutWorkModel model)
        {
            var result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            var OutWork = db.Queryable<TN_Outbound_Order>().Where(a => a.S_BS_NO == model.OutWorkOrder).First();
            if (OutWork != null)
            {
                if (OutWork.N_B_STATE == 0)
                {
                    //OutWork.N_B_STATE = 99;
                    //db.Updateable(OutWork).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
                    db.Deleteable(OutWork).ExecuteCommand();
                    db.Deleteable<TN_Outbound_Detail>().Where(it => it.S_DO_NO == OutWork.S_NO).ExecuteCommand();
                }
                else
                {
                    result.code = 500;
                    result.msg = $"出库单{model.OutWorkOrder} 已执行不允许取消";
                }
            }
            else
            {
                result.code = 500;
                result.msg = $"单号{model.OutWorkOrder} 找不到对应的出库单";
            }
            return result;
        }

        internal static SimpleResult WeiLiInstockVerify(WeiLiInstockVerify model)
        {
            var result = new SimpleResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                if (!string.IsNullOrEmpty(model.cntrNo) && !string.IsNullOrEmpty(model.isVerify))
                {
                    if (model.isVerify == "Y")
                    {
                        var task = db.Queryable<WMSTask>().Where(it => it.S_CNTR_CODE == model.cntrNo && it.N_B_STATE == 5).First();
                        if (task != null)
                        {
                            task.N_B_STATE = 0;
                            WMSHelper.UpdateTaskState(task);
                            result.resultMsg = "入库确认 托盘入立体库";
                        }
                        else
                        {
                            result.resultCode = 2;
                            result.resultMsg = $"确认失败 找不到该托盘对应的作业";
                        }
                    }
                    else
                    {
                        result.resultMsg = "入库确认 托盘不入立体库";
                    }
                }
                else
                {
                    result.resultCode = -1;
                    result.resultMsg = "必填数据不能为空";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"PDA码盘入库确认异常 异常信息={ex.Message}", ex);
                result.resultCode = 1;
                result.resultMsg = $"接口异常 异常信息={ex.Message}";
            }
            return result;
        }

        internal static List<AreaQueryResult> AreaQuery()
        {
            var result = new List<AreaQueryResult>();
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Area>().ToList();
            if (list.Count > 0)
            {
                list.ForEach(a =>
                {
                    result.Add(new AreaQueryResult { areaCode = a.S_CODE, areaName = a.S_NAME, workRegion = a.S_NOTE, workShop = a.S_WORK_SHOP });
                });
            }
            return result;
        }

        internal static PlcSendTaskres PlcCallbackState(PlcState model)
        {
            var db = new SqlHelper<object>().GetInstance();
            var result = new PlcSendTaskres { requestPk = model.requestPk, code = "0" };
            string message = "";
            if (model.noticeType == "0" || model.noticeType == "ERROR")
            {
                //称重
                if (model.noticeType == "0")
                {
                    //外形检测成功 修改任务参数
                    var wcsTask = db.Queryable<WCSTask>().Where(it => it.S_CNTR_CODE == model.contNo && it.N_B_STATE == 2 && it.S_SCHEDULE_TYPE == "NDC").First();
                    if (wcsTask != null)
                    {
                        wcsTask.N_ERR = 200;
                        db.Updateable(wcsTask).UpdateColumns(it => new { it.N_ERR }).ExecuteCommand();
                    }
                }
                else
                {
                    //外形检测失败 修改任务参数
                    var wcsTask = db.Queryable<WCSTask>().Where(it => it.S_CNTR_CODE == model.contNo && it.N_B_STATE == 2 && it.S_SCHEDULE_TYPE == "NDC").First();
                    if (wcsTask != null)
                    {
                        Location endLoc = null;
                        var Setting = Settings.ConnetAreas.Where(a => a.InLocList.Contains(wcsTask.S_END_LOC)).FirstOrDefault();
                        if (Setting != null)
                        {
                            if (Settings.DBAreas.Contains(wcsTask.S_START_AREA))
                            {
                                endLoc = db.Queryable<Location>().Where(a => a.S_CODE == wcsTask.S_START_LOC).First();
                            }
                            else
                            {
                                var endArea = Setting.ErrorArea;
                                endLoc = db.Queryable<Location>().Where(a => a.S_AREA_CODE == endArea && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0).First();
                            }

                            if (endLoc != null)
                            {
                                var wmsTask = db.Queryable<WMSTask>().Where(a => a.S_CODE == wcsTask.S_OP_CODE).First();
                                if (wmsTask != null)
                                {
                                    var PlcTask = db.Queryable<WCSTask>().Where(it => it.S_CNTR_CODE == model.contNo && (it.N_B_STATE == 2 || it.N_B_STATE == 1) && it.S_SCHEDULE_TYPE == "WCS").First();
                                    if (PlcTask != null)
                                    {
                                        TaskProcess.Cancel(PlcTask);
                                        //取消plc任务
                                        TaskProcess.OperateStatus(PlcTask, 7);
                                        WCSHelper.Fail(PlcTask);
                                    }
                                    LocationHelper.UnLockLoc(wmsTask.S_END_LOC);
                                    LocationHelper.LockLoc(endLoc.S_CODE, 1);
                                    LocationHelper.LockLoc(wcsTask.S_END_LOC, 2);
                                    wcsTask.S_ERR_LOC = endLoc.S_CODE;
                                    wcsTask.N_ERR = 500;
                                    db.Updateable(wcsTask).UpdateColumns(it => new { it.N_ERR, it.S_ERR_LOC }).ExecuteCommand();
                                }
                            }
                            else
                            {
                                LogHelper.Info($"外形检测失败 未找到退货终点");
                            }


                        }
                    }
                }
            }
            else
            {
                var task = WCSHelper.GetTask(model.requestPk);
                if (task != null)
                {
                    //if (!WCSHelper.CheckActionRecordExist(task.S_CODE, int.Parse(model.noticeType)))
                    //{
                    switch (model.noticeType)
                    {
                        case "1":
                            //执行状态
                            WCSHelper.Begin(task);
                            if (task.S_TYPE == "分拣出")
                            {
                                WCSHelper.UpdateStorStatus(task.S_CNTR_CODE, 3);
                            }
                            break;
                        case "5":
                            //取货无货(释放货位)
                            TaskProcess.OperateStatus(task, 4);
                            break;
                        case "2":
                            if (!WCSHelper.CheckActionRecordExist(task.S_CODE, 5))
                            {
                                TaskProcess.OperateStatus(task, 4);
                            }
                            //完成状态 (出库任务生成第二段agv任务) 解绑起点终点
                            //if (task.S_B_STATE != "取消" && task.S_B_STATE != "完成" && task.S_B_STATE != "关闭" && task.S_B_STATE != "强制完成")
                            //{
                            TaskProcess.OperateStatus(task, 6);
                            if (task.S_OP_NAME =="入库")
                            {
                                WMSHelper.AddChange(task);
                            }
                            if (task.S_OP_NAME == "出库")
                            {
                                WMSHelper.DeleteChange(task);
                            }
                            if (task.S_TYPE == "分拣回")
                            {
                                WMSHelper.PreparationState(task);
                            }
                            //TaskProcess.PlcSencondTask(task);
                            WCSHelper.End(task);
                            WMSHelper.End(task);
                            //}
                            break;
                        case "8":
                            //取货无货(释放货位)
                            quhuowuhuo(db, task);
                            break;
                        case "9":
                            //放货有货 (重分货位)
                            fanghuoyouhuo(db, result, task);
                            break;
                    }
                    WCSHelper.AddActionRecord(task.S_CODE, int.Parse(model.noticeType), "", "");
                    //}
                }
                else
                {
                    result.code = "1";
                    result.msg = "该任务编号不存在";
                }
            }
            return result;
        }

        private static void fanghuoyouhuo(SqlSugarClient db, PlcSendTaskres result, WCSTask task)
        {
            string msg = "";
            var wmstask = db.Queryable<WMSTask>().Where(a => a.S_CODE == task.S_OP_CODE).First();
            var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == task.S_END_LOC).First();
            locinfo.N_CURRENT_NUM = 1;
            locinfo.S_LOCK_STATE = "锁定";
            locinfo.N_LOCK_STATE = 4;
            db.Updateable(locinfo).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();

            //分配改道货位
            LogHelper.Info($"查找改道货位 优先查找{locinfo.N_ROADWAY}巷道货位");
            Location endbit = WMSHelper.GetLiKuLocationIn(locinfo.S_AREA_CODE, locinfo.N_ROADWAY, locinfo.S_TYPE);
            if (endbit != null)
            {
                LogHelper.Info($"查找到改道货位为{endbit.S_CODE}");
                //修改任务数据 终点 备注:改位
                LocationHelper.LockLoc(endbit.S_CODE, 1);
                wmstask.S_END_LOC = endbit.S_CODE;
                db.Updateable(wmstask).UpdateColumns(it => new { it.S_END_LOC }).ExecuteCommand();
                task.S_END_LOC = endbit.S_CODE;
                task.S_NOTE = "改位";
                db.Updateable(task).UpdateColumns(it => new { it.S_END_LOC, it.S_NOTE }).ExecuteCommand();
                var agvBit = db.Queryable<PeiZhi>().Where(it => it.BitCode == endbit.S_CODE).First();
                if (agvBit != null)
                {
                    result.new_locate_no = agvBit.PlcLocation;
                }

            }
            //else
            //{
            //    LogHelper.Info($"{locinfo.N_ROADWAY} 巷道找不到可入货位 随机分配货位");
            //    endbit = WMSHelper.GetLiKuLocationIn(locinfo.S_AREA_CODE, 0, locinfo.S_TYPE);
            //    if (endbit != null)
            //    {
            //        LogHelper.Info($"查找到改道货位为{endbit.S_CODE}");
            //        //修改任务数据 终点 备注:改位
            //        LocationHelper.LockLoc(endbit.S_CODE, 1);
            //        wmstask.S_END_LOC = endbit.S_CODE;
            //        db.Updateable(wmstask).UpdateColumns(it => new { it.S_END_LOC }).ExecuteCommand();
            //        task.S_END_LOC = endbit.S_CODE;
            //        task.S_NOTE = "改位";
            //        db.Updateable(task).UpdateColumns(it => new { it.S_END_LOC, it.S_NOTE }).ExecuteCommand();
            //
            //        var agvBit = db.Queryable<PeiZhi>().Where(it => it.BitCode == endbit.S_CODE).First();
            //        if (agvBit != null)
            //        {
            //            result.new_locate_no = agvBit.PlcLocation;
            //        }
            //    }
            //}
        }
        internal static SimpleResult OutboundOrderExecute(OutboundOrderCheck model)
        {
            var result = new SimpleResult();
            var db = new SqlHelper<object>().GetInstance();
            var nolist = model.out_no.Split(',').ToList();
            nolist.ForEach(a =>
            {
                var OutboundOrder = db.Queryable<TN_Outbound_Order>().Where(it => it.S_NO == a && it.N_B_STATE == 0).Includes(it => it.Details).First();
                if (OutboundOrder != null)
                {
                    var res = false;
                    for (int i = 0; i < OutboundOrder.Details.Count; i++)
                    {
                        var detail = OutboundOrder.Details[i];
                        var whi = db.Queryable<WHInventory>().Where(w => w.S_ITEM_CODE == detail.S_ITEM_CODE).First();
                        if (whi != null && whi.F_QTY - whi.F_ALLOC_QTY > 0)
                        {
                            res = true;
                            Expression<Func<CntrItemRel, bool>> expression = x => x.S_ITEM_CODE == detail.S_ITEM_CODE;
                            expression.AndAlso(x => x.Cntr.C_ENABLE == "Y");
                            expression.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) > (detail.F_QTY - detail.F_ACC_D_QTY));
                            expression.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) / 2 < (detail.F_QTY - detail.F_ACC_D_QTY));
                            if (!string.IsNullOrEmpty(detail.S_BATCH_NO)) expression.AndAlso(x => x.S_BATCH_NO == detail.S_BATCH_NO);
                            if (!string.IsNullOrEmpty(detail.S_OWNER)) expression.AndAlso(x => x.S_OWNER == detail.S_OWNER);
                            if (!string.IsNullOrEmpty(detail.S_ERP_WH_CODE)) expression.AndAlso(x => x.S_ERP_WH_CODE == detail.S_ERP_WH_CODE);
                            var bol = false;
                            var fjlist = db.Queryable<CntrItemRel>().Includes(c => c.Cntr)
                            .Where(expression)
                            .OrderBy(c => c.T_CREATE)
                            .ToList();
                            for (int j = 0; j < fjlist.Count; j++)
                            {
                                //检测这个托盘物料是否单一
                                var cir = fjlist[j];
                                //var isfj = db.Queryable<TN_Distribution_CNTR>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.C_REVERSE == "Y" && c.N_B_STATE < 2).First();
                                //if (isfj == null)
                                //{
                                //    var itemlist = db.Queryable<CntrItemRel>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.F_QTY > 0).ToList();
                                //    if (itemlist.Count == 1)
                                //    {
                                //        var dc_no = WMSHelper.GenerateDistrbutionCntrNo();
                                //        bol = true;
                                //        var dc = new TN_Distribution_CNTR
                                //        {
                                //            S_DC_NO = dc_no,
                                //            S_BS_NO = detail.S_DO_NO,
                                //            S_BS_TYPE = OutboundOrder.S_BS_TYPE,
                                //            S_CNTR_CODE = cir.S_CNTR_CODE,
                                //            S_EXIT_AREA_CODE = OutboundOrder.S_AREA_CODE,
                                //            S_OP_TYPE = OutboundOrder.S_BS_TYPE,
                                //            C_REVERSE = "Y"
                                //        };
                                //        db.Insertable(dc).ExecuteCommand();
                                //
                                //        var dc_detail = new TN_Distribution_CNTR_Detail
                                //        {
                                //            S_ITEM_CODE = detail.S_ITEM_CODE,
                                //            S_ITEM_NAME = detail.S_ITEM_NAME,
                                //            S_BATCH_NO = detail.S_BATCH_NO,
                                //            S_ERP_WH_CODE = detail.S_ERP_WH_CODE,
                                //            S_SUPPLIER_NO = detail.S_SUPPLIER_NO,
                                //            S_OWNER = detail.S_OWNER,
                                //            N_BS_ROW_NO = detail.N_ROW_NO,
                                //            S_BS_TYPE = OutboundOrder.S_BS_TYPE,
                                //            S_DC_NO = dc_no,
                                //            S_BS_NO = OutboundOrder.S_NO,
                                //            F_QTY = (itemlist[0].F_QTY - itemlist[0].F_ALLOC_QTY) - (detail.F_QTY - detail.F_ACC_D_QTY),
                                //        };
                                //        db.Insertable(dc_detail).ExecuteCommand();
                                //        //更新容器货品表分配量
                                //        cir.F_ALLOC_QTY += (float)dc_detail.F_QTY;
                                //        cir.T_MODIFY = DateTime.Now;
                                //        db.Updateable(cir).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                //        //更新分拣单子表的量
                                //        detail.F_ACC_D_QTY += detail.F_QTY - detail.F_ACC_D_QTY;
                                //        detail.T_MODIFY = DateTime.Now;
                                //        db.Updateable(detail).UpdateColumns(it => new { it.F_ACC_D_QTY, it.T_MODIFY }).ExecuteCommand();
                                //        whi.F_ALLOC_QTY += (float)(detail.F_QTY - detail.F_ACC_D_QTY);
                                //        whi.T_MODIFY = DateTime.Now;
                                //        db.Updateable(whi).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                //        break;
                                //    }
                                //}
                            }


                            Expression<Func<CntrItemRel, bool>> expression1 = x => x.S_ITEM_CODE == detail.S_ITEM_CODE;
                            expression1.AndAlso(x => x.Cntr.C_ENABLE == "Y");
                            expression1.AndAlso(x => (x.F_QTY - x.F_ALLOC_QTY) > 0);
                            if (!string.IsNullOrEmpty(detail.S_BATCH_NO)) expression1.AndAlso(x => x.S_BATCH_NO == detail.S_BATCH_NO);
                            if (!string.IsNullOrEmpty(detail.S_OWNER)) expression1.AndAlso(x => x.S_OWNER == detail.S_OWNER);
                            if (!string.IsNullOrEmpty(detail.S_ERP_WH_CODE)) expression1.AndAlso(x => x.S_ERP_WH_CODE == detail.S_ERP_WH_CODE);

                            if (!bol)
                            {
                                //按分拣单子表去配货，查找可用托盘(先查所有符合的，后面再优化)
                                var cirList = db.Queryable<CntrItemRel>().Includes(c => c.Cntr)
                                .Where(expression1)
                                .OrderBy(c => c.T_CREATE)
                                .ToList();
                                for (int j = 0; j < cirList.Count; j++)
                                {
                                    var cir = cirList[j];
                                    //var isfj = db.Queryable<TN_Distribution_CNTR>().Where(c => c.S_CNTR_CODE == cir.S_CNTR_CODE && c.C_REVERSE == "Y" && c.N_B_STATE < 2).First();
                                    //if (isfj == null)
                                    //{
                                    //    var dc_no = WMSHelper.GenerateDistrbutionCntrNo();
                                    //    bol = true;
                                    //    var dc = new TN_Distribution_CNTR
                                    //    {
                                    //        S_DC_NO = dc_no,
                                    //        S_BS_NO = detail.S_DO_NO,
                                    //        S_BS_TYPE = OutboundOrder.S_BS_TYPE,
                                    //        S_CNTR_CODE = cir.S_CNTR_CODE,
                                    //        S_EXIT_AREA_CODE = OutboundOrder.S_AREA_CODE,
                                    //        S_OP_TYPE = OutboundOrder.S_BS_TYPE
                                    //    };
                                    //    db.Insertable(dc).ExecuteCommand();
                                    //    var dc_detail = new TN_Distribution_CNTR_Detail
                                    //    {
                                    //        S_ITEM_CODE = detail.S_ITEM_CODE,
                                    //        S_ITEM_NAME = detail.S_ITEM_NAME,
                                    //        S_BATCH_NO = detail.S_BATCH_NO,
                                    //        S_ERP_WH_CODE = detail.S_ERP_WH_CODE,
                                    //        S_SUPPLIER_NO = detail.S_SUPPLIER_NO,
                                    //        S_OWNER = detail.S_OWNER,
                                    //        N_BS_ROW_NO = detail.N_ROW_NO,
                                    //        S_BS_TYPE = OutboundOrder.S_BS_TYPE,
                                    //        S_DC_NO = dc_no,
                                    //        S_BS_NO = OutboundOrder.S_NO,
                                    //    };
                                    //    bool needBreak = false;
                                    //    if (cir.F_QTY - cir.F_ALLOC_QTY >= (detail.F_QTY - detail.F_ACC_D_QTY))
                                    //    {
                                    //        dc_detail.F_QTY = detail.F_QTY - detail.F_ACC_D_QTY;
                                    //        needBreak = true;
                                    //    }
                                    //    else
                                    //    {
                                    //        //生成分拣明细，继续创建
                                    //        dc_detail.F_QTY = cir.F_QTY - cir.F_ALLOC_QTY;
                                    //    }
                                    //    db.Insertable(dc_detail).ExecuteCommand();
                                    //    //更新容器货品表分配量
                                    //    cir.F_ALLOC_QTY += (float)dc_detail.F_QTY;
                                    //    cir.T_MODIFY = DateTime.Now;
                                    //    db.Updateable(cir).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                    //    //更新分拣单子表的量
                                    //    detail.F_ACC_D_QTY += dc_detail.F_QTY;
                                    //    detail.T_MODIFY = DateTime.Now;
                                    //    db.Updateable(detail).UpdateColumns(it => new { it.F_ACC_D_QTY, it.T_MODIFY }).ExecuteCommand();
                                    //    whi.F_ALLOC_QTY += (float)dc_detail.F_QTY;
                                    //    whi.T_MODIFY = DateTime.Now;
                                    //    db.Updateable(whi).UpdateColumns(it => new { it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                    //    if (needBreak)
                                    //    {
                                    //        break;
                                    //    }
                                    //}
                                }
                            }
                        }
                        else
                        {
                            //修改出库单明细状态为缺件
                        }
                    }
                }

                //修改出库单状态为执行 
            });

            return result;
        }

        private static void quhuowuhuo(SqlSugarClient db, WCSTask task)
        {
            TaskProcess.OperateStatus(task, 7);
            task.S_NOTE = "异常";
            db.Updateable(task).UpdateColumns(it => new { it.S_NOTE }).ExecuteCommand();
        }


        internal static WeiLiResult InStockApply(InStockApplyModel model)
        {
            var result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();

            try
            {
                if (model.data.Count > 0)
                {
                    //通过料框初始化数据 料框号进行匹配终点库区
                    //创建作业
                    var endarea = "";
                    var tp = model.cntrNo.Substring(0, 2);
                    if (!string.IsNullOrEmpty(model.startLoction))
                    {
                        var cntrInfo = db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntrNo && it.S_LOC_CODE != model.startLoction).First();
                        if (cntrInfo != null)
                        {
                            result.code = 500;
                            result.msg = $"托盘{model.cntrNo} 绑定货位{cntrInfo.S_LOC_CODE} 无法从货位{model.startLoction}生成任务";
                            return result;
                        }
                        var locinfo = db.Queryable<Location>().Where(it => it.S_CODE == model.startLoction).First();
                        if (locinfo != null)
                        {
                            var djinfo = Settings.DJCodes.Where(it => it.DJAreaCode == locinfo.S_AREA_CODE).FirstOrDefault();
                            if (djinfo != null)
                            {
                                if (Settings.DJCodes.Where(it => it.DJAreaCode == locinfo.S_AREA_CODE && it.TrayPrefix == tp).FirstOrDefault() == null)
                                {
                                    result.code = 500;
                                    result.msg = $"起点与托盘类型不符";
                                    return result;
                                }
                            }
                            else
                            {
                                //起点不为检验区
                            }
                        }
                        else
                        {
                            result.code = 500;
                            result.msg = $"起点{model.startLoction} 无对应货位信息";
                            return result;
                        }
                    }

                    foreach (var item in model.data)
                    {
                        var OldCntr = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.itemCode && a.F_QTY > 0).First();
                        if (OldCntr != null)
                        {
                            var oldArea = Settings.LKCodes.Where(a => a.TrayPrefix == OldCntr.S_CNTR_CODE.Substring(0, 2)).FirstOrDefault();
                            var Area = Settings.LKCodes.Where(a => a.TrayPrefix == model.cntrNo.Substring(0, 2)).FirstOrDefault();
                            if (oldArea != null && Area != null && oldArea.LiKuCode != Area.LiKuCode)
                            {
                                var oldTp = OldCntr.S_CNTR_CODE.Substring(0, 2);
                                //var oldTPinfo = Settings.LKCodes.Where(a => a.TrayPrefix == oldTp).FirstOrDefault();
                                LogHelper.Info($"物料{item.itemCode}已绑定在托盘{OldCntr.S_CNTR_CODE} 与托盘{model.cntrNo}隶属不同库区 请更换托盘");
                                result.code = 500;
                                result.msg = $"物料{item.itemCode}已绑定在托盘{OldCntr.S_CNTR_CODE} 与托盘{model.cntrNo}隶属不同库区 请更换托盘";
                                return result;
                            }
                        }
                    }



                    var endinfo = Settings.LKCodes.Where(a => a.TrayPrefix == tp).FirstOrDefault();
                    if (endinfo != null)
                    {
                        endarea = endinfo.LiKuCode;
                    }
                    else
                    {
                        result.code = 500;
                        result.msg = "无法查询到容器所属终点库区 检查配置";
                        return result;
                    }



                    foreach (var a in model.data)
                    {
                        var itemName = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                        if (itemName == null)
                        {
                            result.code = 500;
                            result.msg = $"物料表中查询不到物料{a.itemCode} 对应的物料名称";
                            return result;
                        }
                    }



                    model.data.ForEach(a =>
                    {
                        LogHelper.Info($"qty={a.qty}");
                        var itemName = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                        CntrItemRel item = new CntrItemRel
                        {
                            S_CNTR_CODE = model.cntrNo,
                            S_ITEM_NAME = itemName.S_ITEM_NAME,
                            S_ITEM_CODE = a.itemCode,
                            S_BATCH_NO = a.batchNo,
                            S_OWNER = a.factoryCode,
                            S_ERP_WH_CODE = a.stockLoc,
                            F_QTY = a.qty,
                            S_SUPPLIER_NO = a.vendorCode,
                            S_SERIAL_NO = a.serialNo,
                            D_PRD_DATE = a.productDate,
                            N_ITEM_STATE = model.qualityState,
                            S_EXT_ATTR2 = a.blockState,
                            S_ITEM_STATE = model.qualityState == 0 ? "未质检" : model.qualityState == 1 ? "质检合格" : model.qualityState == 2 ? "质检不合格" : "",
                            T_MODIFY = DateTime.Now,
                            S_EXT_ATTR3 = model.temporarily
                        };
                        LogHelper.Info($"F_QTY={item.F_QTY}");
                        db.Insertable(item).ExecuteCommand();
                    });


                    var startinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.startLoction).First();
                    //终点库区判断 是否为待检区 如果不是根据物料区分去哪个立库
                    //var EndArea = model.needConfirm == "Y" ? Settings.DJCode : Settings.LKCodes[0].LiKuCode;
                    //创建作业
                    var optask = new WMSTask
                    {
                        S_START_AREA = startinfo.S_AREA_CODE,
                        S_START_WH = startinfo.S_WH_CODE,
                        S_END_WH = startinfo.S_WH_CODE,
                        S_CODE = model.orderNo,
                        S_START_LOC = model.startLoction,
                        S_END_LOC = "",
                        S_END_AREA = endarea,
                        S_STATION_LOC = model.station.ToString(),
                        S_TYPE = "入库",
                        N_TYPE = 1,
                        N_B_STATE = 0,
                        S_CNTR_CODE = model.cntrNo,
                        S_OP_DEF_NAME = "入库",
                        S_STORE = model.needConfirm
                    };
                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                    if (note != null)
                    {
                        optask.S_NOTE = note.TaskType;
                    }
                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                    if (res)
                    {
                        //LocationHelper.BindingLoc(model.startLoction, new List<string>() { model.cntrNo });
                        var cntrInfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.startLoction && a.S_CNTR_CODE == model.cntrNo).First();
                        if (cntrInfo == null)
                        {
                            db.Insertable(new LocCntrRel { S_LOC_CODE = model.startLoction, S_CNTR_CODE = model.cntrNo }).ExecuteCommand();
                        }
                        LocationHelper.LockLoc(model.startLoction, 2);
                        var cn = db.Queryable<Container>().Where(it => it.S_CODE == model.cntrNo).First();
                        if (cn == null)
                        {
                            var cntr = new Container { S_CODE = model.cntrNo, N_DETAIL_COUNT = model.data.Count };
                            db.Insertable(cntr).ExecuteCommand();
                        }
                        else
                        {
                            cn.N_DETAIL_COUNT += model.data.Count;
                            db.Updateable(cn).UpdateColumns(it => new { it.N_DETAIL_COUNT }).ExecuteCommand();
                        }
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "集合数据不能为空";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"入库请求异常 异常信息{ex.Message}", ex);
                result.code = 500;
                result.msg = $"入库请求异常 异常信息{ex.Message}";
            }

            return result;
        }

        internal static StockQueryRes StockQuery(StockQueryModel model)
        {
            StockQueryRes result = new StockQueryRes();
            LogHelper.Info($"库区查询 物料编码={model.itemCode} 库区={JsonConvert.SerializeObject(model.areaCode)} 料框号={model.cntrNo} 批次号={model.batchNo} 供应商编码={model.vendorCode}");
            var db = new SqlHelper<object>().GetInstance();
            var exp = Expressionable.Create<CntrItemRel>();
            exp.AndIF(!string.IsNullOrEmpty(model.itemCode), a => a.S_ITEM_CODE == model.itemCode);
            exp.AndIF(!string.IsNullOrEmpty(model.cntrNo), a => a.S_CNTR_CODE == model.cntrNo);
            exp.AndIF(!string.IsNullOrEmpty(model.batchNo), a => a.S_BATCH_NO == model.batchNo);
            exp.AndIF(!string.IsNullOrEmpty(model.vendorCode), a => a.S_SUPPLIER_NO == model.vendorCode);
            exp.AndIF(!string.IsNullOrEmpty(model.stockLoc), a => a.S_ERP_WH_CODE == model.stockLoc);
            exp.AndIF(!string.IsNullOrEmpty(model.blockState), a => a.S_EXT_ATTR2 == model.blockState);
            exp.AndIF(model.qualityState != 0, a => a.N_ITEM_STATE == model.qualityState);


            try
            {
                var itemlist = db.Queryable<CntrItemRel>().Where(exp.ToExpression()).PartitionBy(a => a.S_CNTR_CODE).Take(1).ToList();
                if (itemlist.Count > 0)
                {
                    for (int i = 0; i < itemlist.Count; i++)
                    {
                        var cntr = itemlist[i].S_CNTR_CODE;

                        var info = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == cntr).First();
                        if (info != null)
                        {
                            var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == info.S_LOC_CODE).First();
                            if (locinfo != null)
                            {
                                if (model.areaCode.Count > 0 && model.areaCode.Contains(locinfo.S_AREA_CODE))
                                {
                                    var newexp = Expressionable.Create<CntrItemRel>();
                                    newexp.AndIF(!string.IsNullOrEmpty(model.itemCode), a => a.S_ITEM_CODE == model.itemCode);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.cntrNo), a => a.S_CNTR_CODE == model.cntrNo);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.batchNo), a => a.S_BATCH_NO == model.batchNo);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.vendorCode), a => a.S_SUPPLIER_NO == model.vendorCode);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.stockLoc), a => a.S_ERP_WH_CODE == model.stockLoc);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.blockState), a => a.S_EXT_ATTR2 == model.blockState);
                                    newexp.AndIF(model.qualityState != 0, a => a.N_ITEM_STATE == model.qualityState);
                                    newexp.And(a => a.S_CNTR_CODE == cntr);

                                    //添加
                                    var data = new StockQueryResult
                                    {
                                        areaCode = locinfo.S_AREA_CODE,
                                        location = locinfo.S_CODE,
                                        cntrCode = cntr
                                    };
                                    var item = db.Queryable<CntrItemRel>().Where(newexp.ToExpression()).ToList();
                                    if (item.Count > 0)
                                    {
                                        item.ForEach(a =>
                                        {
                                            data.data.Add(new StockQueryResult.StockQueryData
                                            {
                                                batchNo = a.S_BATCH_NO,
                                                itemCode = a.S_ITEM_CODE,
                                                serialNo = a.S_SERIAL_NO,
                                                stockLocation = a.S_ERP_WH_CODE,
                                                factoryCode = a.S_OWNER,
                                                qty = a.F_QTY,
                                                productDate = a.D_PRD_DATE,
                                                vendorCode = a.S_SUPPLIER_NO,
                                                qualityState = a.N_ITEM_STATE,
                                                blockState = a.S_EXT_ATTR2
                                            });
                                        });
                                    }
                                    result.data.Add(data);
                                }
                                else if (model.areaCode.Count == 0)
                                {
                                    var newexp = Expressionable.Create<CntrItemRel>();
                                    newexp.AndIF(!string.IsNullOrEmpty(model.itemCode), a => a.S_ITEM_CODE == model.itemCode);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.cntrNo), a => a.S_CNTR_CODE == model.cntrNo);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.batchNo), a => a.S_BATCH_NO == model.batchNo);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.vendorCode), a => a.S_SUPPLIER_NO == model.vendorCode);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.stockLoc), a => a.S_ERP_WH_CODE == model.stockLoc);
                                    newexp.AndIF(!string.IsNullOrEmpty(model.blockState), a => a.S_EXT_ATTR2 == model.blockState);
                                    newexp.AndIF(model.qualityState != 0, a => a.N_ITEM_STATE == model.qualityState);
                                    newexp.And(a => a.S_CNTR_CODE == cntr);

                                    //添加
                                    var data = new StockQueryResult
                                    {
                                        areaCode = locinfo.S_AREA_CODE,
                                        location = locinfo.S_CODE,
                                        cntrCode = cntr
                                    };
                                    var item = db.Queryable<CntrItemRel>().Where(newexp.ToExpression()).ToList();
                                    if (item.Count > 0)
                                    {
                                        item.ForEach(a =>
                                        {
                                            data.data.Add(new StockQueryResult.StockQueryData
                                            {
                                                batchNo = a.S_BATCH_NO,
                                                itemCode = a.S_ITEM_CODE,
                                                serialNo = a.S_SERIAL_NO,
                                                stockLocation = a.S_ERP_WH_CODE,
                                                factoryCode = a.S_OWNER,
                                                qty = a.F_QTY,
                                                productDate = a.D_PRD_DATE,
                                                vendorCode = a.S_SUPPLIER_NO,
                                                qualityState = a.N_ITEM_STATE,
                                                blockState = a.S_EXT_ATTR2
                                            });
                                        });
                                    }
                                    //else LogHelper.Info($"查询不到托盘{cntr}的库存信息 查询条件{JsonConvert.SerializeObject(newexp.ToExpression())}");
                                    result.data.Add(data);
                                }
                            }
                        }
                    }
                }
                //else 
                //{
                //    result.code = 1;
                //}
            }
            catch (Exception ex)
            {
                LogHelper.Error($"库存查询接口异常 异常信息={ex.Message}", ex);
                result.code = 2;
            }

            return result;
        }

        internal static ReserveStockQueryRes ReserveStockQuery(ReserveStockQueryModel model)
        {
            ReserveStockQueryRes result = new ReserveStockQueryRes();
            var db = new SqlHelper<object>().GetInstance();
            var cntrlist = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == model.outStockOrderNo && a.S_EXT_ATTR1 == "Y").PartitionBy(a => a.S_CNTR_CODE).Take(1).ToList();
            //var cntrlist = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == outStockOrderNo).ToList();
            if (cntrlist.Count > 0)
            {
                LogHelper.Info($"查询到出库单号{model.outStockOrderNo} 对应的托盘数据{cntrlist.Count}条");
                cntrlist.ForEach(it =>
                {
                    var cntrCode = it.S_CNTR_CODE;
                    var locinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == cntrCode).First();
                    if (locinfo != null)
                    {
                        ReserveStockQueryResult info = new ReserveStockQueryResult
                        {
                            outStockOrderNo = model.outStockOrderNo,
                            cntrCode = cntrCode,
                            location = locinfo.S_LOC_CODE,
                            state = 1
                        };
                        var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntrCode).ToList();
                        if (itemlist.Count > 0)
                        {
                            itemlist.ForEach(item =>
                            {
                                info.data.Add(new ReserveStockQueryResult.ReserveStockQueryData
                                {
                                    serialNo = string.IsNullOrEmpty(item.S_SERIAL_NO) ? "" : item.S_SERIAL_NO,
                                    stockLocation = string.IsNullOrEmpty(item.S_ERP_WH_CODE) ? "" : item.S_ERP_WH_CODE,
                                    batchNo = string.IsNullOrEmpty(item.S_BATCH_NO) ? "" : item.S_BATCH_NO,
                                    factoryCode = string.IsNullOrEmpty(item.S_OWNER) ? "" : item.S_OWNER,
                                    itemCode = item.S_ITEM_CODE,
                                    vendorCode = string.IsNullOrEmpty(item.S_SUPPLIER_NO) ? "" : item.S_SUPPLIER_NO,
                                    qty = item.F_QTY,
                                    rowNo = item.N_BS_ROW_NO
                                });
                            });
                        }
                        result.data.Add(info);
                    }
                    else
                    {
                        LogHelper.Info($"未查询到托盘{it.S_CNTR_CODE} 对应的绑定货位");
                        result.code = 500;
                    }
                });
            }
            else
            {
                LogHelper.Info($"未查询到出库单号{model.outStockOrderNo} 对应的托盘数据");
                result.code = 500;
            }


            return result;
        }

        internal static WeiLiResult EmptyOutStockApply(EmptyOutStockApplyModel model)
        {
            var db = new SqlHelper<object>().GetInstance();
            WeiLiResult result = new WeiLiResult();
            string endarea = "";
            string startloc = ""; string startarea = ""; string cntrNo = ""; string startWh = "";
            try
            {
                var cntrSpecification = model.cntrSpecification == 1 ? "高货位" : model.cntrSpecification == 2 ? "低货位" : "";
                var cntrType = model.cntrType == 1 ? "2T" : model.cntrType == 2 ? "3T" : model.cntrType == 3 ? "11T" : "";
                var startareainfo = Settings.LKCodes.Where(a => a.AreaType == cntrType).FirstOrDefault();
                if (startareainfo != null)
                {
                    startarea = startareainfo.LiKuCode;
                    if (!string.IsNullOrEmpty(model.cntrNo))
                    {
                        var locinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrNo).First();
                        if (locinfo != null)
                        {
                            var startLoc = db.Queryable<Location>().Where(a => a.S_CODE == locinfo.S_LOC_CODE).First();
                            if (startLoc != null)
                            {
                                var DuiDuoPeiz = db.Queryable<DuiDuoPeiz>().Where(it => it.S_AREA_CODE == startLoc.S_AREA_CODE && it.N_LANE == startLoc.N_ROADWAY && it.N_STATE == 1).First();
                                if (DuiDuoPeiz != null)
                                {
                                    //获取起点信息
                                    var lociteminfo = db.Queryable<CntrItemRel>().Where(it => it.S_CNTR_CODE == locinfo.S_CNTR_CODE).First();
                                    if (lociteminfo == null)
                                    {
                                        startloc = locinfo.S_LOC_CODE;
                                        cntrNo = locinfo.S_CNTR_CODE;
                                    }
                                    else
                                    {
                                        result.code = 500;
                                        result.msg = "该托盘不是空框";
                                        return result;
                                    }
                                }
                                else
                                {
                                    result.code = 500;
                                    result.msg = $"货位{locinfo.S_LOC_CODE} 当前巷道堆垛机异常";
                                    return result;
                                }

                            }
                            else
                            {
                                result.code = 500;
                                result.msg = $"系统不存在绑定托盘货位{locinfo.S_LOC_CODE}";
                                return result;
                            }
                        }
                        else
                        {
                            result.code = 500;
                            result.msg = "系统中找不到该托盘绑定记录";
                            return result;
                        }
                    }
                    else
                    {
                        //算取起点货位
                        var startloclist = db.Queryable<Location>()
                           .Where(a => a.S_AREA_CODE == startarea && a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0)
                           .ToList();
                        if (startloclist.Count > 0)
                        {
                            foreach (var item in startloclist)
                            {
                                var locinfo = db.Queryable<LocCntrRel>().Where(it => it.S_LOC_CODE == item.S_CODE).First();
                                if (locinfo != null)
                                {
                                    var lociteminfo = db.Queryable<CntrItemRel>().Where(it => it.S_CNTR_CODE == locinfo.S_CNTR_CODE).First();
                                    if (lociteminfo == null)
                                    {
                                        var DuiDuoPeiz = db.Queryable<DuiDuoPeiz>().Where(it => it.S_AREA_CODE == item.S_AREA_CODE && it.N_LANE == item.N_ROADWAY && it.N_STATE == 1).First();
                                        if (DuiDuoPeiz != null)
                                        {
                                            if (!string.IsNullOrEmpty(cntrSpecification))
                                            {
                                                if (cntrSpecification == item.S_TYPE)
                                                {
                                                    startloc = locinfo.S_LOC_CODE;
                                                    startWh = item.S_WH_CODE;
                                                    cntrNo = locinfo.S_CNTR_CODE;
                                                    break;
                                                }
                                            }
                                            else
                                            {
                                                startloc = locinfo.S_LOC_CODE;
                                                startWh = item.S_WH_CODE;
                                                cntrNo = locinfo.S_CNTR_CODE;
                                                break;
                                            }
                                        }
                                        else
                                        {
                                            LogHelper.Info($"空框出库 库区{item.S_AREA_CODE} 巷道{item.N_ROADWAY} 堆垛机状态异常");
                                        }
                                    }
                                }
                            }
                        }
                    }


                    if (string.IsNullOrEmpty(startloc))
                    {
                        result.code = 500;
                        result.msg = $"库区中找不到可用空托";
                        return result;
                    }
                    else
                    {
                        var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == startloc).First();
                        if (locinfo.S_AREA_CODE != startarea)
                        {
                            result.code = 500;
                            result.msg = "托盘起点与库区不符";
                            return result;
                        }
                    }

                    if (!string.IsNullOrEmpty(model.destLocation))
                    {
                        //判断终点库区是否为空
                        var end = db.Queryable<Location>().Where(a => a.S_CODE == model.destLocation).First();
                        if (end != null && end.N_LOCK_STATE != 0)
                        {
                            result.code = 500;
                            result.msg = "指定终点货位锁状态异常";
                            return result;
                        }
                        else if (end == null)
                        {
                            result.code = 500;
                            result.msg = $"终点{model.destLocation} 找不到对应的货位信息";
                            return result;
                        }
                        if (string.IsNullOrEmpty(model.destArea))
                        {
                            endarea = end.S_AREA_CODE;
                        }
                        else endarea = model.destArea;
                    }

                    if (string.IsNullOrEmpty(endarea)) endarea = model.destArea;

                    //创建作业
                    var optask = new WMSTask
                    {
                        S_CODE = model.orderNo,
                        S_START_WH = startWh,
                        S_START_AREA = startarea,
                        S_START_LOC = startloc,
                        S_END_LOC = model.destLocation,
                        S_END_AREA = endarea,
                        S_END_WH = startWh,
                        S_STATION_LOC = model.station.ToString(),
                        S_TYPE = "出库",
                        N_TYPE = 2,
                        N_B_STATE = 0,
                        S_CNTR_CODE = cntrNo,
                        S_OP_DEF_NAME = "空框出库"
                    };
                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                    if (note != null)
                    {
                        optask.S_NOTE = note.TaskType;
                    }
                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                    LocationHelper.LockLoc(startloc, 2);
                    if (!string.IsNullOrEmpty(model.destLocation)) LocationHelper.LockLoc(model.destLocation, 1);
                }
                else
                {
                    result.code = 500;
                    result.msg = $"找不到库区类型{model.cntrType} 对应的起点库区";
                }

            }
            catch (Exception ex)
            {
                LogHelper.Error($"空框出库接口异常 异常信息={ex.Message}", ex);
                result.code = 500;
                result.msg = $"空框出库接口异常 异常信息={ex.Message}";
            }

            return result;
        }

        internal static WeiLiResult CancelOrder(CancelOrderModel1 model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            //var tasks = db.Queryable<WCSTask>().Where(a => a.S_OP_CODE == model.orderNo).ToList();
            //if (tasks.Count >= 1)
            //{
            //    //流程任务数量执行超过一条 任务不允许取消
            //    result.code = 500;
            //    result.msg = "流程任务执行中途不允许取消";
            //    return result;
            //}
            //var task = db.Queryable<WCSTask>().Where(a => a.S_OP_CODE == model.orderNo).OrderByDescending(a => a.T_CREATE).First();
            //if (task != null)
            //{
            //    if (WCSHelper.CheckActionRecordExist(task.S_CODE, 4))
            //    {
            //        result.code = 500;
            //        result.msg = "任务已取货完成 不允许取消";
            //        return result;
            //    }
            //    if (task.N_B_STATE == 0)
            //    {
            //        //等待直接修改状态为取消
            //        WCSHelper.UpdateStatus(model.orderNo, 5);
            //        //result.msg = "任务等待，直接取消";
            //    }
            //    else if (task.N_B_STATE != 3 && task.N_B_STATE != 4)
            //    {
            //        if (task.S_TYPE == "杭奥")
            //        {
            //            //通知立库取消任务
            //        }
            //        else
            //        {
            //            //已推送但是没有完成或者取消，通知hosttoagv
            //            NDCHelper.Cancel(task.S_CODE.Trim());
            //            //result.msg = "任务取消已经发送给小车";
            //        }
            //    }
            //    else
            //    {
            //        result.code = 500;
            //        result.msg = "任务已结束";
            //    }
            //}
            //else
            //{
            //    result.code = 500;
            //    result.msg = "任务不存在";
            //}

            var task = db.Queryable<WCSTask>().Where(a => a.S_OP_CODE == model.orderNo).OrderByDescending(a => a.T_CREATE).First();
            if (task != null)
            {
                var wmsTask = WMSHelper.GetWmsTask(task.S_OP_CODE);
                if (wmsTask != null)
                {
                    if (task.N_B_STATE == 0)
                    {
                        //等待直接修改状态为取消
                        WCSHelper.UpdateStatus(task.S_CODE, 4);
                        wmsTask.N_B_STATE = 6;
                        WMSHelper.UpdateTaskState(wmsTask);
                        LocationHelper.UnLockLoc(task.S_START_LOC);
                        LocationHelper.UnLockLoc(task.S_END_LOC);
                        LocationHelper.UnLockLoc(wmsTask.S_END_LOC);

                        result.msg = "任务等待，直接取消";
                    }
                    else if (task.N_B_STATE != 3 && task.N_B_STATE != 4)
                    {
                        if (task.S_SCHEDULE_TYPE == "NDC")
                        {
                            //已推送但是没有完成或者取消，通知hosttoagv
                            NDCApi.CancelOrder(task.S_CODE.Trim());
                        }
                        else
                        {
                            TaskProcess.Cancel(task);
                            TaskProcess.OperateStatus(task, 7);
                            WCSHelper.Fail(task);
                            WMSHelper.Fail(task);
                        }

                        result.msg = "任务取消已经发送给小车";
                    }
                    else
                    {
                        result.msg = "任务已结束";
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "任务所处的作业不存在";
                }
            }
            else
            {
                result.code = 500;
                result.msg = "任务不存在";
            }

            return result;
        }

        internal static WeiLiResult OutStcokApply(OutStcokApplyModel model)
        {
            WeiLiResult result = new WeiLiResult();
            string endarea = "";
            var db = new SqlHelper<object>().GetInstance();
            var cntrinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrCode).First();
            if (cntrinfo != null)
            {
                var startinfo = db.Queryable<Location>().Where(a => a.S_CODE == cntrinfo.S_LOC_CODE).First();
                if (startinfo != null && startinfo.N_LOCK_STATE == 0)
                {
                    var IsLiKu = Settings.LKCodes.Where(a => a.LiKuCode == startinfo.S_AREA_CODE).FirstOrDefault() != null;
                    if (IsLiKu)
                    {
                        var DuiDuoPeiz = db.Queryable<DuiDuoPeiz>().Where(a => a.S_AREA_CODE == startinfo.S_AREA_CODE && a.N_LANE == startinfo.N_ROADWAY && a.N_STATE == 1).First();
                        if (DuiDuoPeiz != null)
                        {
                            if (!string.IsNullOrEmpty(model.destLocation))
                            {
                                //判断终点库区是否为空
                                var end = db.Queryable<Location>().Where(a => a.S_CODE == model.destLocation).First();
                                if (end != null && end.N_LOCK_STATE != 0)
                                {
                                    result.code = 500;
                                    result.msg = "指定终点货位锁状态异常";
                                    return result;
                                }
                                else if (end == null)
                                {
                                    result.code = 500;
                                    result.msg = $"终点{model.destLocation} 找不到对应的货位信息";
                                    return result;
                                }


                                if (string.IsNullOrEmpty(model.destLocation))
                                {
                                    endarea = end.S_AREA_CODE;
                                }
                                else endarea = model.destArea;
                            }
                            if (string.IsNullOrEmpty(endarea)) endarea = model.destArea;

                            //创建作业
                            var optask = new WMSTask
                            {
                                S_CODE = model.orderNo,
                                S_START_LOC = startinfo.S_CODE,
                                S_START_AREA = startinfo.S_AREA_CODE,
                                S_START_WH = startinfo.S_WH_CODE,
                                S_END_LOC = model.destLocation,
                                S_END_AREA = endarea,
                                S_END_WH = startinfo.S_WH_CODE,
                                S_STATION_LOC = model.station.ToString(),
                                N_TYPE = 2,
                                S_TYPE = "出库",
                                N_B_STATE = 0,
                                S_CNTR_CODE = model.cntrCode,
                                S_OP_DEF_NAME = "出库",
                                S_BS_NO = model.orderNo
                            };
                            var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                            if (note != null)
                            {
                                optask.S_NOTE = note.TaskType;
                            }
                            var res = db.Insertable(optask).ExecuteCommand() > 0;
                            LocationHelper.LockLoc(startinfo.S_CODE, 2);
                        }
                        else
                        {
                            result.code = 500;
                            result.msg = $"库区{startinfo.S_AREA_CODE} 巷道{startinfo.N_ROADWAY} 所属堆垛机异常 无法出库";
                        }
                    }
                    else
                    {
                        LogHelper.Info($"出库 托盘{model.cntrCode} 绑定货位{cntrinfo.S_LOC_CODE} 不在立库区中 无法出库");
                        result.code = 500;
                        result.msg = $"出库 托盘{model.cntrCode} 绑定货位{cntrinfo.S_LOC_CODE} 不在立库区中 无法出库";
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "起点货位状态异常";
                    LogHelper.Info($"起点货位锁定状态异常");
                }
            }
            else
            {
                result.code = 500;
                result.msg = $"托盘{model.cntrCode} 找不到绑定关系";
            }



            return result;
        }

        internal static WeiLiResult ChangeOrderPrioryty(ChangeOrderPriorytyModel model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            var task = db.Queryable<WCSTask>().Where(a => a.S_OP_CODE == model.orderNo).OrderByDescending(a => a.T_CREATE).First();
            if (task != null)
            {
                if (task.N_B_STATE == 0)
                {
                    //等待直接修改状态为取消
                    WCSHelper.UpdatePrioryty(task, model.priority);
                    result.msg = "修改优先级成功";
                }
                else if (task.N_B_STATE != 3 && task.N_B_STATE != 4)
                {
                    if (task.S_TYPE == "杭奥")
                    {
                        //通知立库修改任务优先级
                        result.msg = "修改优先级成功";
                    }
                    else
                    {
                        //通知杭叉修改优先级
                        NDCHelper.Cancel(task.S_CODE.Trim());
                        result.msg = "修改优先级成功";
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "任务已结束";
                }
            }
            else
            {
                result.code = 500;
                result.msg = "任务不存在";
            }
            return result;
        }

        internal static WeiLiResult itemQualityStateUpdate(itemQualityStateUpdateModel model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            var itemstate = model.qualityState == 0 ? "未质检" : model.qualityState == 1 ? "质检合格" : model.qualityState == 2 ? "质检不合格" : "";

            try
            {
                var exp = Expressionable.Create<CntrItemRel>();
                exp.And(a => a.S_ITEM_CODE == model.itemCode);
                exp.AndIF(!string.IsNullOrEmpty(model.cntrNo), a => a.S_CNTR_CODE == model.cntrNo);
                exp.AndIF(!string.IsNullOrEmpty(model.batchNo), a => a.S_BATCH_NO == model.batchNo);
                exp.AndIF(!string.IsNullOrEmpty(model.vendorCode), a => a.S_SUPPLIER_NO == model.vendorCode);
                //exp.AndIF(!string.IsNullOrEmpty(model.stockLocation), a => a.S_ERP_WH_CODE == model.stockLocation);
                exp.AndIF(!string.IsNullOrEmpty(model.factoryCode), a => a.S_OWNER == model.factoryCode);
                exp.AndIF(!string.IsNullOrEmpty(model.serialNo), a => a.S_SERIAL_NO == model.serialNo);

                var itemlist = db.Queryable<CntrItemRel>().Where(exp.ToExpression()).ToList();
                if (itemlist.Count > 0)
                {
                    if (!string.IsNullOrEmpty(itemstate))
                    {
                        itemlist.ForEach(a =>
                        {
                            a.N_ITEM_STATE = model.qualityState;
                            a.S_ITEM_STATE = itemstate;
                            db.Updateable(a).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
                        });
                    }

                    string baockstate = model.blockState == 1 ? "Y" : model.blockState == 0 ? "N" : "";
                    if (!string.IsNullOrEmpty(baockstate))
                    {
                        itemlist.ForEach(a =>
                        {
                            a.S_EXT_ATTR2 = baockstate;
                            db.Updateable(a).UpdateColumns(it => new { it.S_EXT_ATTR2 }).ExecuteCommand();
                        });
                    }

                    if (!string.IsNullOrEmpty(model.stockLocation))
                    {
                        itemlist.ForEach(a =>
                        {
                            a.S_ERP_WH_CODE = model.stockLocation;
                            db.Updateable(a).UpdateColumns(it => new { it.S_ERP_WH_CODE }).ExecuteCommand();
                        });
                    }

                }
                else
                {
                    result.code = 500;
                    result.msg = "当前容器货品明细中 未找到符合条件的明细 无法更新";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"质量更新接口异常 异常信息={ex.Message}", ex);
                result.code = 500;
                result.msg = $"接口异常 异常信息{ex.Message}";
            }

            return result;
        }

        internal static WeiLiResult EmptyInstockApply(EmptyInstockApplyModel model)
        {
            var db = new SqlHelper<object>().GetInstance();
            string endarea = "";
            WeiLiResult result = new WeiLiResult();
            try
            {
                if (!string.IsNullOrEmpty(model.orderNo) && !string.IsNullOrEmpty(model.startLocation) && !string.IsNullOrEmpty(model.cntrCode))
                {
                    var cntrinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrCode).First();
                    var locinfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.startLocation).First();
                    if (locinfo != null && locinfo.S_CNTR_CODE != model.cntrCode)
                    {
                        result.code = 500;
                        result.msg = $"起点{model.startLocation} 已绑定托盘{locinfo.S_CNTR_CODE} 无法绑定托盘{model.cntrCode}";
                        return result;
                    }
                    if (cntrinfo != null && cntrinfo.S_LOC_CODE != model.startLocation)
                    {
                        result.code = 500;
                        result.msg = $"托盘{model.cntrCode} 已绑定货位{cntrinfo.S_LOC_CODE} 无法绑定起点{model.startLocation}";
                        return result;
                    }


                    var tp = model.cntrCode.Substring(0, 2);
                    var endinfo = Settings.LKCodes.Where(a => a.TrayPrefix == tp).FirstOrDefault();
                    if (endinfo != null)
                    {
                        endarea = endinfo.LiKuCode;
                    }
                    else
                    {
                        result.code = 500;
                        result.msg = "无法查询到容器所属终点库区 检查配置";
                        return result;
                    }



                    if (!string.IsNullOrEmpty(model.destLocation))
                    {
                        //判断终点库区是否为空
                        var end = db.Queryable<Location>().Where(a => a.S_CODE == model.destLocation).First();
                        if (end != null && end.N_LOCK_STATE != 0)
                        {
                            result.code = 500;
                            result.msg = "指定终点货位锁状态异常";
                            return result;
                        }
                        else if (end != null && end.S_AREA_CODE == endarea)
                        {
                            result.code = 500;
                            result.msg = "终点与托盘冲突";
                            return result;
                        }
                        else if (end == null)
                        {
                            result.code = 500;
                            result.msg = $"终点{model.destLocation} 找不到对应的货位信息";
                            return result;
                        }
                    }
                    if (!string.IsNullOrEmpty(model.destArea) && model.destArea != endarea)
                    {
                        result.code = 500;
                        result.msg = "终点库区与托盘冲突";
                        return result;
                    }

                    var startinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.startLocation).First();
                    if (startinfo != null && startinfo.N_LOCK_STATE != 0)
                    {
                        result.code = 500;
                        result.msg = $"起点{model.startLocation} 货位状态不为空闲 不允许创建任务";
                        return result;
                    }

                    //创建作业
                    var optask = new WMSTask
                    {
                        S_CODE = model.orderNo,
                        S_START_AREA = startinfo.S_AREA_CODE,
                        S_START_WH = startinfo.S_WH_CODE,
                        S_START_LOC = model.startLocation,
                        S_END_LOC = model.destLocation,
                        S_END_AREA = endarea,
                        S_END_WH = startinfo.S_WH_CODE,
                        S_STATION_LOC = model.station.ToString(),
                        N_TYPE = 1,
                        S_TYPE = "入库",
                        N_B_STATE = 0,
                        S_CNTR_CODE = model.cntrCode,
                        S_OP_DEF_NAME = "空框入库"
                    };
                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                    if (note != null)
                    {
                        optask.S_NOTE = note.TaskType;
                    }
                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                    if (res)
                    {
                        var cn = db.Queryable<Container>().Where(it => it.S_CODE == model.cntrCode).First();
                        if (cn == null)
                        {
                            var cntr = new Container { S_CODE = model.cntrCode, N_DETAIL_COUNT = 0 };
                            db.Insertable(cntr).ExecuteCommand();
                        }
                        else
                        {
                            cn.N_DETAIL_COUNT = 0;
                            db.Updateable(cn).UpdateColumns(it => new { it.N_DETAIL_COUNT }).ExecuteCommand();
                        }
                        var cntrInfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.startLocation && a.S_CNTR_CODE == model.cntrCode).First();
                        if (cntrInfo == null)
                        {
                            db.Insertable(new LocCntrRel { S_LOC_CODE = model.startLocation, S_CNTR_CODE = model.cntrCode }).ExecuteCommand();
                        }
                    } //LocationHelper.BindingLoc(model.startLocation, new List<string>() { model.cntrCode });
                    LocationHelper.LockLoc(model.startLocation, 2);
                }
                else
                {
                    result.code = 500;
                    result.msg = $"数据校验不能为空字符串";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"空框入库接口异常 异常信息={ex.Message}", ex);
                result.code = 500;
                result.msg = $"空框入库接口异常 异常信息={ex.Message}";
            }
            return result;
        }

        internal static WeiLiResult ReceivingNote(ReceivingNoteModel model)
        {
            var result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                //创建发货单，人工点确认后生成分拣单，没有缺货的自动更新为失败，有货的更新为执行中
                //创建入库单主子表
                var po = WMSHelper.GetASNOrder(model.receivingNoteNo);
                if (po == null)
                {
                    po = new TN_ASN_Order
                    {
                        S_NO = model.receivingNoteNo,
                        S_SUPPLIER_NO = model.vendorCode,
                        S_SUPPLIER_NAME = model.vendorName,
                        S_ASN_ID = model.receivingNoteID
                    };
                    po.Details = new List<TN_ASN_Detail>();
                    if (model.data.Count > 0)
                    {
                        foreach (var a in model.data)
                        {
                            var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                            if (item == null)
                            {
                                result.code = 500;
                                result.msg = $"行ID{a.rowID} 物料{a.itemCode}物料主数据不存在该物料";
                                return result;
                            }
                            po.Details.Add(new TN_ASN_Detail
                            {
                                S_ASN_NO = model.receivingNoteNo,
                                S_ITEM_CODE = a.itemCode,
                                F_QTY = a.qty,
                                F_ACC_R_QTY = a.qty,
                                S_BS_ROW_NO = a.rowID,
                                S_FAC_CODE = a.factoryCode,
                                S_ITEM_LOC = a.stockLocation,
                                S_BATCH_NO = a.batchNo,
                                N_IS_FLAG = a.qualityInspectionFlag
                            });
                        };
                        WMSHelper.CreateASNOrder(po);
                    }
                }
                else if (po != null && po.N_B_STATE == 0)
                {
                    var Details = new List<TN_ASN_Detail>();
                    if (model.data.Count > 0)
                    {
                        foreach (var a in model.data)
                        {
                            var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                            if (item == null)
                            {
                                result.code = 500;
                                result.msg = $"行ID{a.rowID} 物料{a.itemCode}物料主数据不存在该物料";
                                return result;
                            }
                            Details.Add(new TN_ASN_Detail
                            {
                                S_ASN_NO = model.receivingNoteNo,
                                S_ITEM_CODE = a.itemCode,
                                F_QTY = a.qty,
                                F_ACC_R_QTY = a.qty,
                                S_BS_ROW_NO = a.rowID,
                                S_FAC_CODE = a.factoryCode,
                                S_ITEM_LOC = a.stockLocation,
                                S_BATCH_NO = a.batchNo,
                                N_IS_FLAG = a.qualityInspectionFlag
                            });
                        };
                    }
                    po.S_SUPPLIER_NO = model.vendorCode;
                    po.S_SUPPLIER_NAME = model.vendorName;
                    po.S_ASN_ID = model.receivingNoteID;
                    db.Updateable(po).UpdateColumns(it => new { it.S_SUPPLIER_NO, it.S_SUPPLIER_NAME, it.S_ASN_ID }).ExecuteCommand();
                    if (Details.Count > 0)
                    {
                        db.Deleteable<TN_ASN_Detail>().Where(it => it.S_ASN_NO == model.receivingNoteNo).ExecuteCommand();
                        db.Insertable<TN_ASN_Detail>(Details).ExecuteCommand();
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "内向交货单状态异常 无法修改数据";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"内向交货单接收异常 异常信息={ex.Message}", ex);
                result.code = 500;
                result.msg = "接口异常";
            }

            return result;
        }

        internal static WeiLiResult ManualStockIn(ManualStockInModel model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            var po = WMSHelper.GetASNOrder(model.taskNo);
            if (po == null)
            {
                po = new TN_ASN_Order { S_NO = model.taskNo, S_BS_TYPE = "人工库入库" };
                po.Details = new List<TN_ASN_Detail>();
                if (model.data.Count > 0)
                {
                    foreach (var a in model.data)
                    {
                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                        if (item == null)
                        {
                            result.code = 500;
                            result.msg = $"物料{a.itemCode}物料主数据不存在该物料";
                            return result;
                        }
                        po.Details.Add(new TN_ASN_Detail
                        {
                            S_ASN_NO = model.taskNo,
                            S_ITEM_CODE = a.itemCode,
                            S_ITEM_NAME = item.S_ITEM_NAME,
                            F_QTY = a.qty,
                            S_BATCH_NO = a.batchNo,
                            S_FAC_CODE = a.factoryCode,
                            S_SUPPLIER_NO = a.vendorCode,
                            S_ITEM_LOC = a.stockCode,
                            N_ITEM_STATE = a.qualityState,
                            S_SERIAL_NO = a.serialNo
                        });
                    }
                    //WMSHelper.CreateShippingOrder(po);
                    WMSHelper.CreateASNOrder(po);
                }
            }
            else
            {
                result.code = 500;
                result.msg = "已有相同发货单号的发货单存在";
                return result;
            }
            return result;
        }

        internal static WeiLiResult ReceivingNoteBatchUpdate(ReceivingNoteBatchUpdateModel model)
        {
            WeiLiResult result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                if (!string.IsNullOrEmpty(model.receivingNoteNo))
                {
                    if (model.data.Count > 0)
                    {
                        model.data.ForEach(a =>
                        {
                            db.Updateable<TN_ASN_Detail>()
                            .SetColumns(it => new TN_ASN_Detail() { S_BATCH_NO = a.sapBatchNo })
                            .Where(it => it.S_ASN_NO == model.receivingNoteNo && it.S_BS_ROW_NO == a.receivingNoteRowNo)
                            .ExecuteCommand();
                        });
                    }
                }
                else
                {
                    result.code = 500;
                    result.msg = "交货单单号不能为空";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"更新交货单批次信息异常 异常信息={ex.Message}", ex);
            }
            return result;
        }

        internal static WeiLiResult ShippingNote(ShippingNoteModel model)
        {
            var result = new WeiLiResult();
            var db = new SqlHelper<object>().GetInstance();
            //创建发货单，人工点确认后生成分拣单，没有缺货的自动更新为失败，有货的更新为执行中
            //创建入库单主子表
            //var po = WMSHelper.GetShippingOrder(model.shippingNoteNo);
            try
            {
                db.BeginTran();
                var po = WMSHelper.GetOutboundOrder(model.shippingNoteNo);
                if (po == null)
                {
                    Dictionary<string, List<ShippingNoteModel.Shippingcomp>> OutGroupList = new Dictionary<string, List<ShippingNoteModel.Shippingcomp>>();
                    foreach (var a in model.data)
                    {
                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                        if (item == null)
                        {
                            result.code = 500;
                            result.msg = $"物料{a.itemCode}物料主数据不存在该物料";
                            return result;
                        }
                        else
                        {
                            if (model.bussType == 6)
                            {
                                //人工库出库 默认库区
                                if (OutGroupList.Keys.Contains("RGK"))
                                {
                                    OutGroupList["RGK"].Add(a);
                                }
                                else
                                {
                                    OutGroupList.Add("RGK", new List<ShippingNoteModel.Shippingcomp> { a });
                                }
                            }
                            else
                            {
                                if (!string.IsNullOrEmpty(item.S_AREA_CODE))
                                {
                                    if (OutGroupList.Keys.Contains(item.S_AREA_CODE))
                                    {
                                        OutGroupList[item.S_AREA_CODE].Add(a);
                                    }
                                    else
                                    {
                                        OutGroupList.Add(item.S_AREA_CODE, new List<ShippingNoteModel.Shippingcomp> { a });
                                    }
                                }
                                else
                                {
                                    result.code = 500;
                                    result.msg = $"物料{a.itemCode} 在物料主数据中未找到所属库区";
                                    return result;
                                }
                            }
                        }
                    }


                    foreach (var item in OutGroupList)
                    {
                        po = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(), S_OUT_TYPE = Gettype(model.bussType), S_END_AREA = model.destArea, S_BS_NO = model.shippingNoteNo, S_OUT_TO = model.station.ToString(), S_END_LOC = model.destLocation, S_STOCK_UP = model.Ispreparation, S_AREA_CODE = item.Key };
                        po.Details = new List<TN_Outbound_Detail>();
                        item.Value.ForEach(a =>
                        {
                            var itemInfo = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                            po.Details.Add(new TN_Outbound_Detail
                            {
                                S_DO_NO = po.S_NO,
                                S_AREA_CODE = model.destArea,
                                N_ROW_NO = a.rowNo,
                                S_ITEM_CODE = a.itemCode,
                                S_ITEM_NAME = itemInfo.S_ITEM_NAME,
                                F_QTY = a.qty,
                                S_BATCH_NO = a.batchNo,
                                S_OWNER = a.factoryCode,
                                S_SUPPLIER_NO = a.vendorCode,
                                S_ERP_WH_CODE = a.stockLocation,
                                //N_ITEM_STATE = a.qualityState,
                                S_SERIAL_NO = a.serialNo
                            });
                        });
                        WMSHelper.CreateOutboundOrder(po);
                    }


                    //po = new TN_Outbound_Order { S_NO = model.shippingNoteNo, S_OUT_TYPE = Gettype(model.bussType), S_AREA_CODE = model.destArea, S_BS_NO = model.shippingNoteNo, S_OUT_TO = model.station.ToString(), S_END_LOC = model.destLocation };
                    //po.Details = new List<TN_Outbound_Detail>();
                    //if (model.data.Count > 0)
                    //{
                    //    foreach (var a in model.data)
                    //    {
                    //        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                    //        if (item == null)
                    //        {
                    //            result.code = 500;
                    //            result.msg = $"物料{a.itemCode}物料主数据不存在该物料";
                    //            return result;
                    //        }
                    //        po.Details.Add(new TN_Outbound_Detail
                    //        {
                    //            S_DO_NO = model.shippingNoteNo,
                    //            S_AREA_CODE = model.destArea,
                    //            N_ROW_NO = a.rowNo,
                    //            S_ITEM_CODE = a.itemCode,
                    //            S_ITEM_NAME = item.S_ITEM_NAME,
                    //            F_QTY = a.qty,
                    //            S_BATCH_NO = a.batchNo,
                    //            S_OWNER = a.factoryCode,
                    //            S_SUPPLIER_NO = a.vendorCode,
                    //            S_ERP_WH_CODE = a.stockLocation,
                    //            //N_ITEM_STATE = a.qualityState,
                    //            S_SERIAL_NO = a.serialNo
                    //        });
                    //    }
                    //    //WMSHelper.CreateShippingOrder(po);
                    //    WMSHelper.CreateOutboundOrder(po);
                    //}
                }
                else
                {
                    result.code = 500;
                    result.msg = "已有相同发货单号的发货单存在";
                    return result;
                }
                db.Ado.CommitTran();
            }
            catch (Exception ex)
            {
                LogHelper.Error($"发货单接口异常 异常信息={ex.Message}", ex);
                result.code = 500;
                result.msg = $"发货单接口异常 异常信息={ex.Message}";
                db.Ado.RollbackTran();
            }
            return result;
        }

        private static string Gettype(int bussType)
        {
            var result = "";
            switch (bussType)
            {
                case 1:
                    result = "质检出库";
                    break;
                case 2:
                    result = "普通出库";
                    break;
                case 3:
                    result = "备料出库";
                    break;
                case 4:
                    result = "不合格品出库";
                    break;
                case 5:
                    result = "冻结出库";
                    break;
                case 6:
                    result = "人工库出库";
                    break;
            }

            return result;
        }

        internal static SimpleResult PalletSorting(PalletSorting model)
        {
            var result = new SimpleResult();
            //校验入库单数量，不可以超，成功后插入托盘物料表，更新入库单累计数量
            //也可以直接lua查询入库单数量，做校验
            var info = WMSHelper.GetPutawayOrderDetail(model.arrival_no, model.item_code);
            if (info != null)
            {
                if (info.F_QTY - info.F_ACC_B_QTY >= model.qty)
                {
                    // 插入到托盘明细表
                    var cntr = ContainerHelper.GetCntr(model.cntr_code, true);
                    if (cntr != null)
                    {
                        ContainerHelper.BindCntrItem(cntr, model.item_code, info.S_BATCH_NO, model.qty, model.arrival_no);
                        //更新入库单累计绑定数量
                        info.F_ACC_B_QTY += model.qty;
                        WMSHelper.UpdatePutawayOrderDetailQty(info);
                    }
                    else
                    {
                        result.resultCode = 2;
                        result.resultMsg = "获取托盘信息失败";
                    }
                }
                else
                {
                    result.resultCode = 1;
                    result.resultMsg = "累计码盘数量超出入库单数量";
                }
            }
            else
            {
                result.resultCode = 3;
                result.resultMsg = $"未找到入库单{model.arrival_no}";
            }

            return result;
        }

        internal static SimpleResult WeiLiOutstock(WeiLiOutstockInfo model)
        {
            var result = new SimpleResult();
            string workNo = "";
            string endarea = "";
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                if (!string.IsNullOrEmpty(model.cntrNo))
                {
                    var iteminfo = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == model.cntrNo).First();
                    if (iteminfo != null) workNo = iteminfo.S_BS_NO;
                    var cntrinfo = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntrNo).First();
                    if (cntrinfo != null)
                    {
                        var startinfo = db.Queryable<Location>().Where(a => a.S_CODE == cntrinfo.S_LOC_CODE).First();
                        if (startinfo != null)
                        {
                            var IsLiKu = Settings.LKCodes.Where(a => a.LiKuCode == startinfo.S_AREA_CODE).FirstOrDefault() != null;
                            if (IsLiKu)
                            {
                                var DuiDuoPeiz = db.Queryable<DuiDuoPeiz>().Where(a => a.S_AREA_CODE == startinfo.S_AREA_CODE && a.N_LANE == startinfo.N_ROADWAY && a.N_STATE == 1).First();
                                if (DuiDuoPeiz != null)
                                {
                                    if (!string.IsNullOrEmpty(model.endBit))
                                    {
                                        //判断终点库区是否为空
                                        var end = db.Queryable<Location>().Where(a => a.S_CODE == model.endBit).First();
                                        if (end != null && end.N_LOCK_STATE != 0)
                                        {
                                            result.resultCode = 3;
                                            result.resultMsg = "指定终点货位锁状态异常";
                                            return result;
                                        }
                                        else if (end == null)
                                        {
                                            result.resultCode = -1;
                                            result.resultMsg = $"终点{model.endBit} 找不到对应的货位信息";
                                            return result;
                                        }


                                        if (string.IsNullOrEmpty(model.endBit))
                                        {
                                            endarea = end.S_AREA_CODE;
                                        }
                                        else endarea = model.endArea;
                                    }
                                    if (string.IsNullOrEmpty(endarea)) endarea = model.endArea;

                                    //创建作业
                                    var optask = new WMSTask
                                    {
                                        S_CODE = WMSHelper.GenerateTaskNo(),
                                        S_START_WH = startinfo.S_WH_CODE,
                                        S_START_LOC = startinfo.S_CODE,
                                        S_START_AREA = startinfo.S_AREA_CODE,
                                        S_END_LOC = model.endBit,
                                        S_END_AREA = endarea,
                                        S_END_WH = startinfo.S_WH_CODE,
                                        S_STATION_LOC = model.station.ToString(),
                                        N_TYPE = 2,
                                        S_TYPE = "出库",
                                        N_B_STATE = 0,
                                        S_CNTR_CODE = model.cntrNo,
                                        S_OP_DEF_NAME = "指引出库",
                                        S_BS_NO = workNo
                                    };
                                    var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                                    if (note != null)
                                    {
                                        optask.S_NOTE = note.TaskType;
                                    }
                                    var res = db.Insertable(optask).ExecuteCommand() > 0;
                                    LocationHelper.LockLoc(startinfo.S_CODE, 2);
                                }
                                else
                                {
                                    LogHelper.Info($"指引出库 托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE} 巷道{startinfo.N_ROADWAY} 堆垛机状态异常");
                                    result.resultCode = -3;
                                    result.resultMsg = $"指引出库 托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE} 巷道{startinfo.N_ROADWAY} 堆垛机状态异常";
                                }
                            }
                            else
                            {
                                LogHelper.Info($"指引出库 托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE} 不在立库区中 无法出库");
                                result.resultCode = -3;
                                result.resultMsg = $"指引出库 托盘{model.cntrNo} 绑定货位{cntrinfo.S_LOC_CODE} 不在立库区中 无法出库";
                            }
                        }
                        else
                        {
                            LogHelper.Info($"指引出库 查询不到托盘{model.cntrNo}绑定货位{cntrinfo.S_LOC_CODE}的货位信息");
                            result.resultCode = -2;
                            result.resultMsg = $"指引出库 查询不到托盘{model.cntrNo}绑定货位{cntrinfo.S_LOC_CODE}的货位信息";
                        }
                    }
                    else
                    {
                        LogHelper.Info($"指引出库 找不到托盘{model.cntrNo}的绑定信息");
                        result.resultCode = -1;
                        result.resultMsg = $"指引出库 找不到托盘{model.cntrNo}的绑定信息";
                    }
                }
                else
                {
                    LogHelper.Info($"指引出库 输入托盘号不能为空");
                    result.resultCode = 2;
                    result.resultMsg = $"指引出库 输入托盘号不能为空";
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error($"指引出库接口异常 异常信息{ex.Message}", ex);
                result.resultCode = 1;
                result.resultMsg = $"指引出库接口异常 异常信息{ex.Message}";
            }
            return result;
        }

        internal static SimpleResult WeiLiInstock(WeiLiInstockInfo model)
        {
            var result = new SimpleResult();
            var db = new SqlHelper<object>().GetInstance();
            var req = new ReceivingNoteSerialNo();
            try
            {
                if (model.isTask == "Y")
                {
                    if (!string.IsNullOrEmpty(model.cntrNo) && !string.IsNullOrEmpty(model.startLoction))
                    {
                        var start = db.Queryable<Location>().Where(it => it.S_CODE == model.startLoction).First();
                        if (start != null && start.N_LOCK_STATE == 0)
                        {
                            var cntrinfo = db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntrNo && it.S_LOC_CODE != model.startLoction).First();
                            if (cntrinfo != null)
                            {
                                result.resultCode = 1;
                                result.resultMsg = $"托盘{model.cntrNo} 已绑定货位{cntrinfo.S_LOC_CODE} 无法从{model.startLoction}生成任务";
                                return result;
                            }


                            if (model.data.Count > 0)
                            {
                                db.BeginTran();
                                var inworklist = new List<string>();
                                //通过料框初始化数据 料框号进行匹配终点库区
                                //创建作业
                                var bol = false;
                                foreach (var item in model.data)
                                {
                                    if (!string.IsNullOrEmpty(item.itemCode) && item.itemCode.Length >= 5)
                                    {
                                        var fivecode = item.itemCode.Substring(0, 5);
                                        var fiveinfo = db.Queryable<FiveCode>().Where(a => a.S_FIVE_CODE == fivecode).First();
                                        if (fiveinfo != null)
                                        {
                                            if (fiveinfo.S_IS_MANAGE == "Y" && string.IsNullOrEmpty(item.serialNo))
                                            {
                                                bol = true;
                                                result.resultCode = 1;
                                                result.resultMsg = result.resultMsg + $"物料{item.itemCode} 已开启五位码管理 唯一码不能为空";
                                            }
                                            if (fiveinfo.S_IS_MANAGEDATE == "Y" && string.IsNullOrEmpty(item.productDate))
                                            {
                                                bol = true;
                                                result.resultCode = 1;
                                                result.resultMsg = result.resultMsg + $"物料{item.itemCode} 已开启生产日期管理 生产日期不能为空";
                                            }
                                        }
                                        var iteminfo = db.Queryable<TN_Material>().Where(a => a.S_ITEM_CODE == item.itemCode).First();
                                        if (iteminfo != null)
                                        {
                                            if (iteminfo.S_IS_MANAGE == "Y" && string.IsNullOrEmpty(item.serialNo))
                                            {
                                                bol = true;
                                                result.resultCode = 1;
                                                result.resultMsg = result.resultMsg + $"物料{item.itemCode} 已开启唯一码管理 唯一码不能为空";
                                            }
                                            if (iteminfo.S_IS_MANAGEDATE == "Y" && string.IsNullOrEmpty(item.productDate))
                                            {
                                                bol = true;
                                                result.resultCode = 1;
                                                result.resultMsg = result.resultMsg + $"物料{item.itemCode} 已开启生产日期管理 生产日期不能为空";
                                            }
                                        }
                                    }
                                    else
                                    {
                                        result.resultCode = -1;
                                        result.resultMsg = "物料编码不能为空 并且长度必须大于5位";
                                        return result;
                                    }
                                }
                                if (bol) return result;

                                //判断托盘物料 同一种物料只能入一种库区
                                foreach (var item in model.data)
                                {
                                    var OldCntr = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.itemCode && a.F_QTY > 0).First();
                                    if (OldCntr != null)
                                    {
                                        var oldArea = Settings.LKCodes.Where(a => a.TrayPrefix == OldCntr.S_CNTR_CODE.Substring(0, 2)).FirstOrDefault();
                                        var Area = Settings.LKCodes.Where(a => a.TrayPrefix == model.cntrNo.Substring(0, 2)).FirstOrDefault();
                                        if (oldArea != null && Area != null && oldArea.LiKuCode != Area.LiKuCode)
                                        {
                                            LogHelper.Info($"托盘前缀{oldArea.TrayPrefix} 隶属库区{oldArea.LiKuCode} 托盘前缀{Area.TrayPrefix} 隶属库区{Area.LiKuCode}");
                                            var oldTp = OldCntr.S_CNTR_CODE.Substring(0, 2);
                                            var oldTPinfo = Settings.LKCodes.Where(a => a.TrayPrefix == oldTp).FirstOrDefault();
                                            LogHelper.Info($"物料{item.itemCode}已绑定在托盘{OldCntr.S_CNTR_CODE} 存放在{oldTPinfo.AreaType}库区 与托盘{model.cntrNo}隶属不同库区 请更换托盘");
                                            result.resultCode = -1;
                                            result.resultMsg = $"物料{item.itemCode}已绑定在托盘{OldCntr.S_CNTR_CODE} 存放在{oldTPinfo.AreaType}库区 与托盘{model.cntrNo}隶属不同库区 请更换托盘";
                                            return result;
                                        }
                                    }
                                }



                                List<WeiLiInstockInfo.WeiLiInstockcomple> newList = model.data.Select(item => new WeiLiInstockInfo.WeiLiInstockcomple
                                {
                                    serialNo = item.serialNo,
                                    stockLocation = item.stockLocation,
                                    batchNo = item.batchNo,
                                    factoryCode = item.factoryCode,
                                    inWorkNo = item.inWorkNo,
                                    itemCode = item.itemCode,
                                    productDate = item.productDate,
                                    qty = item.qty,
                                    qualityInspectionFlag = item.qualityInspectionFlag,
                                    rowID = item.rowID,
                                    vendorCode = item.vendorCode
                                }).ToList();
                                var itemlist = new List<WeiLiInstockInfo.WeiLiInstockcomple>();
                                foreach (var item in newList)
                                {
                                    var rowID = item.rowID;
                                    var qty = item.qty;
                                    var iteminfo = itemlist.Where(a => a.rowID == rowID).FirstOrDefault();
                                    if (iteminfo == null)
                                    {
                                        //添加数据
                                        itemlist.Add(item);
                                    }
                                    else
                                    {
                                        //修改数量
                                        iteminfo.qty = iteminfo.qty + qty;
                                    }
                                    LogHelper.Info($"拆分数据{JsonConvert.SerializeObject(itemlist)} 原数据{JsonConvert.SerializeObject(model.data)}");
                                }

                                foreach (var item in itemlist)
                                {
                                    var exp = Expressionable.Create<TN_Inbound_Detail>();
                                    exp.And(it => it.S_IO_NO == item.inWorkNo);
                                    exp.And(it => it.N_BS_ROW_NO == item.rowID);
                                    exp.And(it => it.S_ITEM_CODE == item.itemCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.batchNo), it => it.S_BATCH_NO == item.batchNo);
                                    exp.AndIF(!string.IsNullOrEmpty(item.stockLocation), it => it.S_ERP_WH_CODE == item.stockLocation);
                                    exp.AndIF(!string.IsNullOrEmpty(item.factoryCode), it => it.S_OWNER == item.factoryCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.vendorCode), it => it.S_SUPPLIER_NO == item.vendorCode);
                                    LogHelper.Info($"S_IO_NO={item.inWorkNo} and N_BS_ROW_NO={item.rowID} and S_ITEM_CODE={item.itemCode} and S_BATCH_NO={item.batchNo} and S_ERP_WH_CODE={item.stockLocation} and S_OWNER={item.factoryCode} and S_SUPPLIER_NO={item.vendorCode} qty={item.qty}");
                                    var InWorkOrder = db.Queryable<TN_Inbound_Detail>().Where(exp.ToExpression()).First();
                                    if (InWorkOrder != null)
                                    {
                                        if (InWorkOrder.F_QTY - InWorkOrder.F_ACC_B_QTY < item.qty)
                                        {
                                            result.resultCode = 4;
                                            result.resultMsg = $"入库单明细 余量为{InWorkOrder.F_QTY - InWorkOrder.F_ACC_B_QTY} 码盘数量为{item.qty} 不得超出入库单余量";
                                            return result;
                                        }
                                    }
                                    else
                                    {
                                        LogHelper.Info($"未找到{JsonConvert.SerializeObject(item)} 对应的入库单明细");
                                        result.resultCode = 3;
                                        result.resultMsg = $"未找到{JsonConvert.SerializeObject(item)} 对应的入库单明细";
                                        return result;
                                    }
                                }

                                var endarea = "";
                                var tp = model.cntrNo.Substring(0, 2);

                                if (!string.IsNullOrEmpty(model.needInspect))
                                {
                                    if (model.needInspect == "Y")
                                    {
                                        var endinfo = Settings.DJCodes.Where(a => a.TrayPrefix == tp).FirstOrDefault();
                                        if (endinfo != null)
                                        {
                                            endarea = endinfo.DJAreaCode;
                                        }
                                        else
                                        {
                                            result.resultCode = 2;
                                            result.resultMsg = "无法查询到容器所属终点库区 检查配置";
                                            return result;
                                        }
                                    }
                                    else
                                    {
                                        var endinfo = Settings.LKCodes.Where(a => a.TrayPrefix == tp).FirstOrDefault();
                                        if (endinfo != null)
                                        {
                                            endarea = endinfo.LiKuCode;
                                        }
                                        else
                                        {
                                            result.resultCode = 2;
                                            result.resultMsg = "无法查询到容器所属终点库区 检查配置";
                                            return result;
                                        }
                                    }
                                }
                                else
                                {
                                    result.resultCode = 2;
                                    result.resultMsg = "无法确定托盘去向 是否去检验区";
                                    return result;
                                }
                                var loccntr = db.Queryable<LocCntrRel>().Where(it => it.S_LOC_CODE == model.startLoction).First();
                                if (loccntr == null)
                                {
                                    foreach (var item in model.data)
                                    {
                                        if (!string.IsNullOrEmpty(item.serialNo))
                                        {
                                            db.Insertable(new TN_WeiLi_SerialNo { InWork = item.inWorkNo, SerialNo = item.serialNo, RowId = item.rowID }).ExecuteCommand();
                                        }
                                        //升量
                                        var exp = Expressionable.Create<TN_Inbound_Detail>();
                                        exp.And(it => it.S_IO_NO == item.inWorkNo);
                                        exp.And(it => it.N_BS_ROW_NO == item.rowID);
                                        exp.And(it => it.S_ITEM_CODE == item.itemCode);
                                        exp.AndIF(!string.IsNullOrEmpty(item.batchNo), it => it.S_BATCH_NO == item.batchNo);
                                        exp.AndIF(!string.IsNullOrEmpty(item.stockLocation), it => it.S_ERP_WH_CODE == item.stockLocation);
                                        exp.AndIF(!string.IsNullOrEmpty(item.factoryCode), it => it.S_OWNER == item.factoryCode);
                                        exp.AndIF(!string.IsNullOrEmpty(item.vendorCode), it => it.S_SUPPLIER_NO == item.vendorCode);
                                        var InWorkOrder = db.Queryable<TN_Inbound_Detail>().Where(exp.ToExpression()).First();
                                        InWorkOrder.F_ACC_B_QTY += item.qty;
                                        db.Updateable(InWorkOrder).UpdateColumns(it => new { it.F_ACC_B_QTY }).ExecuteCommand();
                                        var inwork = db.Queryable<TN_Inbound_Detail>().Where(it => it.S_IO_NO == item.inWorkNo && it.F_QTY > it.F_ACC_B_QTY).First();
                                        if (inwork == null)
                                        {
                                            if (!inworklist.Contains(item.inWorkNo))
                                            {
                                                inworklist.Add(item.inWorkNo);
                                            }
                                        }
                                    }

                                    //if (Settings.ZTenable == 1)
                                    //{
                                    //    LogHelper.Info("2222222222222");
                                    //    if (inworklist.Count > 0)
                                    //    {
                                    //        LogHelper.Info("2222222222222");
                                    //
                                    //        foreach (var item in inworklist)
                                    //        {
                                    //            LogHelper.Info("2222222222222");
                                    //
                                    //            var seriallist = db.Queryable<TN_WeiLi_SerialNo>().Where(it => it.InWork == item).ToList();
                                    //            if (seriallist.Count > 0)
                                    //            {
                                    //                LogHelper.Info("44444444444444");
                                    //                seriallist.ForEach(a =>
                                    //                {
                                    //                    var serinfo = req.data.Where(it => it.rowID == a.RowId).FirstOrDefault();
                                    //                    if (serinfo == null)
                                    //                    {
                                    //                        LogHelper.Info("55555555555555");
                                    //                        var se = new ReceivingNoteSerialNo.serial();
                                    //                        se.rowID = a.RowId;
                                    //                        se.serialNo.Add(a.SerialNo);
                                    //                        req.data.Add(se);
                                    //                    }
                                    //                    else
                                    //                    {
                                    //                        req.data[req.data.FindIndex(x => x.Equals(serinfo))].serialNo.Add(a.SerialNo);
                                    //                    }
                                    //                });
                                    //            }
                                    //            if (req.data.Count > 0)
                                    //            {
                                    //                LogHelper.Info("3333333333333333");
                                    //                //回传唯一码列表
                                    //                var url = Settings.ZTSeverUrl + "ReceivingNoteSerialNo";
                                    //                LogHelper.Info($"唯一码回传接口 地址{url} 接口参数{JsonConvert.SerializeObject(req)}");
                                    //                var feedback = new HttpHelper().WebPost(url, JsonConvert.SerializeObject(req));
                                    //                LogHelper.Info($"唯一码回传接口 地址{url} 接口参数{JsonConvert.SerializeObject(req)} 返回参数{feedback}");
                                    //                if (!string.IsNullOrEmpty(feedback))
                                    //                {
                                    //                    var weilires = JsonConvert.DeserializeObject<WeiLiResult>(feedback);
                                    //                    if (weilires.code == 200)
                                    //                    {
                                    //                        LogHelper.Info($"接口反馈成功");
                                    //                        db.Deleteable<TN_WeiLi_SerialNo>().Where(it => it.InWork == item).ExecuteCommand();
                                    //                    }
                                    //                    else
                                    //                    {
                                    //                        db.Ado.RollbackTran();
                                    //                        result.resultCode = 5;
                                    //                        result.resultMsg = $"唯一码回传接口反馈失败 失败原因{weilires.msg}";
                                    //                        return result;
                                    //                    }
                                    //                }
                                    //                else
                                    //                {
                                    //                    db.Ado.RollbackTran();
                                    //                    result.resultCode = 5;
                                    //                    result.resultMsg = "唯一码回传接口超时";
                                    //                    return result;
                                    //                }
                                    //            }
                                    //        }
                                    //    }
                                    //}
                                    model.data.ForEach(a =>
                                    {
                                        LogHelper.Info($"添加容器货品明细 行ID{a.rowID}");
                                        var itemName = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                                        CntrItemRel item = new CntrItemRel
                                        {
                                            S_CNTR_CODE = model.cntrNo,
                                            S_WU = a.rowID,
                                            S_ITEM_NAME = itemName.S_ITEM_NAME,
                                            S_ITEM_CODE = a.itemCode,
                                            S_BATCH_NO = a.batchNo,
                                            S_OWNER = a.factoryCode,
                                            S_ERP_WH_CODE = a.stockLocation,
                                            F_QTY = a.qty,
                                            S_SUPPLIER_NO = a.vendorCode,
                                            S_SERIAL_NO = a.serialNo,
                                            D_PRD_DATE = a.productDate,
                                            N_ITEM_STATE = a.qualityInspectionFlag,
                                            S_ITEM_STATE = a.qualityInspectionFlag == 0 ? "未质检" : a.qualityInspectionFlag == 1 ? "质检合格" : a.qualityInspectionFlag == 2 ? "质检不合格" : "",
                                            T_MODIFY = DateTime.Now
                                        };
                                        db.Insertable(item).ExecuteCommand();
                                        LogHelper.Info($"添加容器货品明细 数据={JsonConvert.SerializeObject(item)}");
                                    });
                                }
                                else if (loccntr.S_CNTR_CODE != model.cntrNo)
                                {
                                    result.resultCode = 3;
                                    result.resultMsg = $"货位{model.startLoction} 已绑定{loccntr.S_CNTR_CODE} 不能绑定{model.cntrNo}";
                                    return result;
                                }



                                //终点库区判断 是否为待检区 如果不是根据物料区分去哪个立库
                                //var EndArea = model.needConfirm == "Y" ? Settings.DJCode : Settings.LKCodes[0].LiKuCode;
                                //创建作业
                                var optask = new WMSTask
                                {
                                    S_CODE = WMSHelper.GenerateTaskNo(),
                                    S_START_WH = start.S_WH_CODE,
                                    S_START_AREA = start.S_AREA_CODE,
                                    S_START_LOC = model.startLoction,
                                    S_END_LOC = "",
                                    S_END_AREA = endarea,
                                    S_END_WH = start.S_WH_CODE,
                                    S_STATION_LOC = model.station.ToString(),
                                    S_TYPE = "入库",
                                    N_TYPE = 1,
                                    N_B_STATE = 0,
                                    S_CNTR_CODE = model.cntrNo,
                                    S_OP_DEF_NAME = "码盘入库"
                                };
                                var note = Settings.Tasktypes.Where(a => a.StartArea == optask.S_START_AREA && a.EndArea == optask.S_END_AREA).FirstOrDefault();
                                if (note != null)
                                {
                                    optask.S_NOTE = note.TaskType;
                                }
                                var res = db.Insertable(optask).ExecuteCommand() > 0;
                                if (res)
                                {
                                    //LocationHelper.BindingLoc(model.startLoction, new List<string>() { model.cntrNo });
                                    var cntrInfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.startLoction && a.S_CNTR_CODE == model.cntrNo).First();
                                    if (cntrInfo == null)
                                    {
                                        db.Insertable(new LocCntrRel { S_LOC_CODE = model.startLoction, S_CNTR_CODE = model.cntrNo }).ExecuteCommand();
                                    }
                                    LocationHelper.LockLoc(model.startLoction, 2);
                                    var cn = db.Queryable<Container>().Where(it => it.S_CODE == model.cntrNo).First();
                                    if (cn == null)
                                    {
                                        var cntr = new Container { S_CODE = model.cntrNo, N_DETAIL_COUNT = model.data.Count };
                                        db.Insertable(cntr).ExecuteCommand();
                                    }
                                    else
                                    {
                                        cn.N_DETAIL_COUNT += model.data.Count;
                                        db.Updateable(cn).UpdateColumns(it => new { it.N_DETAIL_COUNT }).ExecuteCommand();
                                    }
                                }
                            }
                            else
                            {
                                result.resultCode = -1;
                                result.resultMsg = "集合数据不能为空";
                            }
                        }
                        else
                        {
                            result.resultCode = -2;
                            result.resultMsg = "起点货位信息有误 或起点货位状态不为空闲";
                        }
                    }
                    else
                    {
                        result.resultCode = -1;
                        result.resultMsg = "入库料框号和起点货位不能为空";
                    }
                }
                else
                {
                    var addchangeres = true;
                    //人工库入库
                    if (!string.IsNullOrEmpty(model.endLocation) && !string.IsNullOrEmpty(model.cntrNo))
                    {
                        var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.endLocation).First();
                        if (locinfo != null)
                        {
                            if (model.needInspect == "Y")
                            {
                                //检验区人工入库 绑定托盘 无需绑定物料
                                var cntrInfo = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.endLocation && a.S_CNTR_CODE == model.cntrNo).First();
                                if (cntrInfo == null)
                                {
                                    db.Insertable(new LocCntrRel { S_LOC_CODE = model.endLocation, S_CNTR_CODE = model.cntrNo }).ExecuteCommand();
                                }
                                //LocCntrRel loc = new LocCntrRel { S_LOC_CODE = model.endLocation, S_CNTR_CODE = model.cntrNo };
                                //var locbol=db.Insertable(loc).ExecuteCommand()>0;
                                LogHelper.Info($"绑定货位容器 货位{model.endLocation} 容器{model.cntrNo}");
                                List<WeiLiInstockInfo.WeiLiInstockcomple> newList = model.data.Select(item => new WeiLiInstockInfo.WeiLiInstockcomple
                                {
                                    serialNo = item.serialNo,
                                    stockLocation = item.stockLocation,
                                    batchNo = item.batchNo,
                                    factoryCode = item.factoryCode,
                                    inWorkNo = item.inWorkNo,
                                    itemCode = item.itemCode,
                                    productDate = item.productDate,
                                    qty = item.qty,
                                    qualityInspectionFlag = item.qualityInspectionFlag,
                                    rowID = item.rowID,
                                    vendorCode = item.vendorCode
                                }).ToList();
                                var itemlist = new List<WeiLiInstockInfo.WeiLiInstockcomple>();
                                foreach (var item in newList)
                                {
                                    var rowID = item.rowID;
                                    var qty = item.qty;
                                    var iteminfo = itemlist.Where(a => a.rowID == rowID).FirstOrDefault();
                                    if (iteminfo == null)
                                    {
                                        //添加数据
                                        itemlist.Add(item);
                                    }
                                    else
                                    {
                                        //修改数量
                                        iteminfo.qty = iteminfo.qty + qty;
                                    }
                                    LogHelper.Info($"拆分数据{JsonConvert.SerializeObject(itemlist)} 原数据{JsonConvert.SerializeObject(model.data)}");
                                }

                                foreach (var item in itemlist)
                                {
                                    var exp = Expressionable.Create<TN_Inbound_Detail>();
                                    exp.And(it => it.S_IO_NO == item.inWorkNo);
                                    exp.And(it => it.N_BS_ROW_NO == item.rowID);
                                    exp.And(it => it.S_ITEM_CODE == item.itemCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.batchNo), it => it.S_BATCH_NO == item.batchNo);
                                    exp.AndIF(!string.IsNullOrEmpty(item.stockLocation), it => it.S_ERP_WH_CODE == item.stockLocation);
                                    exp.AndIF(!string.IsNullOrEmpty(item.factoryCode), it => it.S_OWNER == item.factoryCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.vendorCode), it => it.S_SUPPLIER_NO == item.vendorCode);
                                    LogHelper.Info($"S_IO_NO={item.inWorkNo} and N_BS_ROW_NO={item.rowID} and S_ITEM_CODE={item.itemCode} and S_BATCH_NO={item.batchNo} and S_ERP_WH_CODE={item.stockLocation} and S_OWNER={item.factoryCode} and S_SUPPLIER_NO={item.vendorCode} qty={item.qty}");
                                    var InWorkOrder = db.Queryable<TN_Inbound_Detail>().Where(exp.ToExpression()).First();
                                    if (InWorkOrder != null)
                                    {
                                        if (InWorkOrder.F_QTY - InWorkOrder.F_ACC_B_QTY < item.qty)
                                        {
                                            result.resultCode = 4;
                                            result.resultMsg = $"入库单明细 余量为{InWorkOrder.F_QTY - InWorkOrder.F_ACC_B_QTY} 码盘数量为{item.qty} 不得超出入库单余量";
                                            return result;
                                        }
                                    }
                                    else
                                    {
                                        LogHelper.Info($"未找到{JsonConvert.SerializeObject(item)} 对应的入库单明细");
                                        result.resultCode = 3;
                                        result.resultMsg = $"未找到{JsonConvert.SerializeObject(item)} 对应的入库单明细";
                                        return result;
                                    }
                                }

                                foreach (var item in model.data)
                                {
                                    //升量
                                    var exp = Expressionable.Create<TN_Inbound_Detail>();
                                    exp.And(it => it.S_IO_NO == item.inWorkNo);
                                    exp.And(it => it.N_BS_ROW_NO == item.rowID);
                                    exp.And(it => it.S_ITEM_CODE == item.itemCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.batchNo), it => it.S_BATCH_NO == item.batchNo);
                                    exp.AndIF(!string.IsNullOrEmpty(item.stockLocation), it => it.S_ERP_WH_CODE == item.stockLocation);
                                    exp.AndIF(!string.IsNullOrEmpty(item.factoryCode), it => it.S_OWNER == item.factoryCode);
                                    exp.AndIF(!string.IsNullOrEmpty(item.vendorCode), it => it.S_SUPPLIER_NO == item.vendorCode);
                                    var InWorkOrder = db.Queryable<TN_Inbound_Detail>().Where(exp.ToExpression()).First();
                                    if (InWorkOrder != null)
                                    {
                                        InWorkOrder.F_ACC_B_QTY += item.qty;
                                        db.Updateable(InWorkOrder).UpdateColumns(it => new { it.F_ACC_B_QTY }).ExecuteCommand();
                                    }
                                    else
                                    {
                                        LogHelper.Info($"找不到对应的入库单明细 行ID{item.rowID}");
                                    }

                                }

                                model.data.ForEach(a =>
                                {
                                    LogHelper.Info($"添加容器货品明细 行ID{a.rowID}");
                                    var itemName = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                                    CntrItemRel item = new CntrItemRel
                                    {
                                        S_CNTR_CODE = model.cntrNo,
                                        S_WU = a.rowID,
                                        S_ITEM_NAME = itemName.S_ITEM_NAME,
                                        S_ITEM_CODE = a.itemCode,
                                        S_BATCH_NO = a.batchNo,
                                        S_OWNER = a.factoryCode,
                                        S_ERP_WH_CODE = a.stockLocation,
                                        F_QTY = a.qty,
                                        S_SUPPLIER_NO = a.vendorCode,
                                        S_SERIAL_NO = a.serialNo,
                                        D_PRD_DATE = a.productDate,
                                        N_ITEM_STATE = a.qualityInspectionFlag,
                                        S_ITEM_STATE = a.qualityInspectionFlag == 0 ? "未质检" : a.qualityInspectionFlag == 1 ? "质检合格" : a.qualityInspectionFlag == 2 ? "质检不合格" : "",
                                        T_MODIFY = DateTime.Now
                                    };
                                    db.Insertable(item).ExecuteCommand();
                                });
                                WMSHelper.receiveUnloadConfirm(model.cntrNo, model.endLocation);
                                TaskProcess.InspectionAreaStockUpdate(model.cntrNo, model.endLocation);
                                locinfo.N_CURRENT_NUM = 1;
                                db.Updateable(locinfo).UpdateColumns(it => new { it.N_CURRENT_NUM }).ExecuteCommand();
                                var cn = db.Queryable<Container>().Where(it => it.S_CODE == model.cntrNo).First();
                                if (cn == null)
                                {
                                    var newcntr = new Container { S_CODE = model.cntrNo, N_DETAIL_COUNT = model.data.Count };
                                    db.Insertable(newcntr).ExecuteCommand();
                                }
                                else
                                {
                                    cn.N_DETAIL_COUNT += model.data.Count;
                                    db.Updateable(cn).UpdateColumns(it => new { it.N_DETAIL_COUNT }).ExecuteCommand();
                                }
                                db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == model.cntrNo).ExecuteCommand();
                            }
                            else
                            {
                                var url = Settings.MoboxSeverUrl + "inventory/AddChange";
                                //仓库量表升量
                                var req1 = new AddChangeModel { op_type = 5 };
                                //库区量表升量
                                var req2 = new AddChangeModel { op_type = 6 };
                                foreach (var a in model.data)
                                {
                                    var iteminfo = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                                    if (iteminfo != null)
                                    {
                                        LogHelper.Info($"填充数据");
                                        LogHelper.Info($"添加仓库量表数据 仓库{locinfo.S_WH_CODE} 物料编码{a.itemCode} 物料名称{iteminfo.S_ITEM_NAME} 数量{a.qty}");
                                        req1.item_info.Add(new AddChangeModel.itemModel
                                        {
                                            wh_code = locinfo.S_WH_CODE,
                                            item_code = a.itemCode,
                                            item_name = iteminfo.S_ITEM_NAME,
                                            qty = a.qty
                                        });
                                        LogHelper.Info($"添加库区量表数据 库区{locinfo.S_AREA_CODE} 物料编码{a.itemCode} 物料名称{iteminfo.S_ITEM_NAME} 数量{a.qty}");
                                        req2.item_info.Add(new AddChangeModel.itemModel
                                        {
                                            wh_code = locinfo.S_WH_CODE,
                                            area_code = locinfo.S_AREA_CODE,
                                            item_code = a.itemCode,
                                            item_name = iteminfo.S_ITEM_NAME,
                                            qty = a.qty
                                        });
                                    }
                                    else
                                    {
                                        LogHelper.Info($"物料表中不包含物料编码{a.itemCode} 无法升量");
                                        result.resultCode = 2;
                                        result.resultMsg = $"物料表中不包含物料编码{a.itemCode} 无法升量";
                                        return result;
                                    }
                                };
                                var reqData = JsonConvert.SerializeObject(req1);
                                var AppKey = Settings.AppKey;
                                var AppSecret = Settings.AppSecret;
                                var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
                                //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
                                LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}");
                                var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime);
                                LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}");
                                var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify);
                                if (!string.IsNullOrEmpty(res))
                                {
                                    LogHelper.Info($"mobox 仓库升量接口返回 {res}");
                                    var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
                                    if (moboxres.err_code != 0)
                                    {
                                        addchangeres = false;
                                    }
                                }
                                else
                                {
                                    LogHelper.Info($"mobox 仓库升量接口返回为空");
                                    addchangeres = false;
                                }
                                var reqData2 = JsonConvert.SerializeObject(req2);
                                var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
                                //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
                                LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}");
                                var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2);
                                LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}");
                                var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2);
                                if (!string.IsNullOrEmpty(res2))
                                {
                                    LogHelper.Info($"mobox 库区升量接口返回 {res2}");
                                    var moboxres = JsonConvert.DeserializeObject<moboxres>(res);
                                    if (moboxres.err_code != 0)
                                    {
                                        addchangeres = false;
                                    }
                                }
                                else
                                {
                                    LogHelper.Info($"mobox 库区升量接口返回为空");
                                    addchangeres = false;
                                }
                                var workNo = "";
                                if (addchangeres)
                                {
                                    //添加上下架记录
                                    foreach (var item in model.data)
                                    {

                                    }

                                    var cntr = "";
                                    var loc = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == model.endLocation).First();
                                    if (loc != null)
                                    {
                                        cntr = loc.S_CNTR_CODE;
                                    }
                                    else
                                    {
                                        cntr = model.cntrNo;
                                    }
                                    //绑定托盘
                                    if (cntr == model.cntrNo)
                                    {
                                        //添加物料明细
                                        model.data.ForEach(a =>
                                        {
                                            workNo = a.inWorkNo;
                                            var itemName = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.itemCode).First();
                                            CntrItemRel item = new CntrItemRel
                                            {
                                                S_CNTR_CODE = cntr,
                                                S_ITEM_NAME = itemName.S_ITEM_NAME,
                                                S_ITEM_CODE = a.itemCode,
                                                S_BATCH_NO = a.batchNo,
                                                S_OWNER = a.factoryCode,
                                                S_ERP_WH_CODE = a.stockLocation,
                                                F_QTY = a.qty,
                                                S_SUPPLIER_NO = a.vendorCode,
                                                S_SERIAL_NO = a.serialNo,
                                                D_PRD_DATE = a.productDate,
                                                N_ITEM_STATE = a.qualityInspectionFlag,
                                                S_ITEM_STATE = a.qualityInspectionFlag == 0 ? "未质检" : a.qualityInspectionFlag == 1 ? "质检合格" : a.qualityInspectionFlag == 2 ? "质检不合格" : "",
                                                T_MODIFY = DateTime.Now
                                            };

                                            var info = new TN_OnOff_Shelves
                                            {
                                                S_NO = a.inWorkNo,
                                                N_ACTION = 1,
                                                S_ACTION = "上架",
                                                S_ITEM_CODE = a.itemCode,
                                                S_ITEM_NAME = itemName.S_ITEM_NAME,
                                                S_LOC_CODE = model.endLocation,
                                                S_AREA_CODE = locinfo.S_AREA_CODE,
                                                S_CNTR_CODE = model.cntrNo,
                                                S_BATCH_NO = a.batchNo,
                                                S_SERIAL_NO = a.serialNo,
                                                D_PRD_DATE = a.productDate,
                                                F_QTY = a.qty
                                            };
                                            db.Insertable(info).ExecuteCommand();

                                            db.Insertable(item).ExecuteCommand();
                                        });
                                    }
                                    else
                                    {
                                        //合并物料
                                        model.data.ForEach(it =>
                                        {
                                            var exp = Expressionable.Create<CntrItemRel>();
                                            exp.And(a => a.S_ITEM_CODE == it.itemCode);
                                            exp.And(a => a.S_CNTR_CODE == cntr);
                                            exp.And(a => a.N_ITEM_STATE == it.qualityInspectionFlag);
                                            exp.AndIF(!string.IsNullOrEmpty(it.batchNo), a => a.S_BATCH_NO == it.batchNo);
                                            exp.AndIF(!string.IsNullOrEmpty(it.vendorCode), a => a.S_SUPPLIER_NO == it.vendorCode);
                                            exp.AndIF(!string.IsNullOrEmpty(it.stockLocation), a => a.S_ERP_WH_CODE == it.stockLocation);
                                            exp.AndIF(!string.IsNullOrEmpty(it.factoryCode), a => a.S_OWNER == it.factoryCode);
                                            exp.AndIF(!string.IsNullOrEmpty(it.serialNo), a => a.S_SERIAL_NO == it.serialNo);

                                            var item = db.Queryable<CntrItemRel>().Where(exp.ToExpression()).First();
                                            if (item != null)
                                            {
                                                workNo = it.inWorkNo;
                                                //修改数量
                                                item.F_QTY = item.F_QTY + it.qty;
                                                db.Updateable(item).UpdateColumns(k => new { k.F_QTY }).ExecuteCommand();
                                            }
                                            else
                                            {
                                                workNo = it.inWorkNo;
                                                var itemName = db.Queryable<TN_Material>().Where(k => k.S_ITEM_CODE == it.itemCode).First();
                                                item = new CntrItemRel
                                                {
                                                    S_CNTR_CODE = cntr,
                                                    S_ITEM_NAME = itemName.S_ITEM_NAME,
                                                    S_ITEM_CODE = it.itemCode,
                                                    S_BATCH_NO = it.batchNo,
                                                    S_OWNER = it.factoryCode,
                                                    S_ERP_WH_CODE = it.stockLocation,
                                                    F_QTY = it.qty,
                                                    S_SUPPLIER_NO = it.vendorCode,
                                                    S_SERIAL_NO = it.serialNo,
                                                    D_PRD_DATE = it.productDate,
                                                    N_ITEM_STATE = it.qualityInspectionFlag,
                                                    S_ITEM_STATE = it.qualityInspectionFlag == 0 ? "未质检" : it.qualityInspectionFlag == 1 ? "质检合格" : it.qualityInspectionFlag == 2 ? "质检不合格" : "",
                                                    T_MODIFY = DateTime.Now
                                                };
                                                db.Insertable(item).ExecuteCommand();
                                            }
                                        });

                                    }


                                    if (loc == null)
                                    {
                                        LocCntrRel newloc = new LocCntrRel { S_LOC_CODE = model.endLocation, S_CNTR_CODE = model.cntrNo };
                                        db.Insertable(newloc).ExecuteCommand();
                                    }


                                    locinfo.N_CURRENT_NUM = 1;
                                    db.Updateable(locinfo).UpdateColumns(it => new { it.N_CURRENT_NUM }).ExecuteCommand();
                                    var cn = db.Queryable<Container>().Where(it => it.S_CODE == cntr).First();
                                    if (cn == null)
                                    {
                                        var newcntr = new Container { S_CODE = model.cntrNo, N_DETAIL_COUNT = model.data.Count };
                                        db.Insertable(newcntr).ExecuteCommand();
                                    }
                                    else
                                    {
                                        cn.N_DETAIL_COUNT += model.data.Count;
                                        db.Updateable(cn).UpdateColumns(it => new { it.N_DETAIL_COUNT }).ExecuteCommand();
                                    }

                                    WCSTask task = new WCSTask { S_OP_CODE = workNo, S_CNTR_CODE = "", S_END_LOC = model.endLocation };
                                    WMSHelper.OpState(task);
                                }
                                else
                                {
                                    LogHelper.Info($"人工库升量失败");
                                    result.resultCode = -1;
                                    result.resultMsg = "人工库入库升量失败";
                                }
                            }

                        }
                        else
                        {
                            LogHelper.Info($"人工入库终点不存在");
                            result.resultCode = 1;
                            result.resultMsg = "人工入库终点不存在";
                        }
                    }
                    else
                    {
                        LogHelper.Info($"人工库入库托盘和终点不能为空");
                        result.resultCode = 1;
                        result.resultMsg = "人工库入库托盘和终点不能为空";
                    }
                }

                db.Ado.CommitTran();
            }
            catch (Exception ex)
            {
                LogHelper.Error($"码盘入库接口异常 异常信息={ex.Message}", ex);
                result.resultCode = 3;
                result.resultMsg = $"码盘入库接口异常 异常信息={ex.Message}";
                db.Ado.RollbackTran();
            }




            return result;
        }


        public class ReceivingNoteSerialNo
        {
            public List<serial> data { get; set; } = new List<serial>();
            public class serial
            {
                public string rowID { get; set; }
                public List<string> serialNo { get; set; } = new List<string>();
            }
        }


        private static string WeiLiGetType(string tasktype)
        {
            var result = "";

            switch (tasktype)
            {
                case "1":
                    result = "码盘入库";
                    break;
                case "2":
                    result = "备料入库";
                    break;
                case "3":
                    result = "分拣回";
                    break;
            }

            return result;
        }

        internal static SimpleResult OutboundOrder(OutboundOrder model)
        {
            var result = new SimpleResult();
            //创建发货单，人工点确认后生成分拣单，没有缺货的自动更新为失败，有货的更新为执行中
            //创建入库单主子表
            var po = WMSHelper.GetShippingOrder(model.Data.out_no);
            if (po == null)
            {
                po = new ShippingOrder { S_NO = model.Data.out_no, S_BS_TYPE = model.Data.op_type, LINE_AREA = model.Data.line_area };
                po.Details = new List<ShippingDetail>();
                if (model.Data.items.Count > 0)
                {
                    model.Data.items.ForEach(a =>
                    {
                        po.Details.Add(new ShippingDetail
                        {
                            S_SHIPPING_NO = model.Data.out_no,
                            N_ROW_NO = po.Details.Count + 1,
                            S_ITEM_CODE = a.item_code,
                            F_QTY = a.qty,
                            S_BATCH_NO = a.batch_no,
                        });
                    });
                    WMSHelper.CreateShippingOrder(po);
                }

            }
            return result;
        }

        internal static SimpleResult ShippingOrderExecute(ShippingOrderCheck model)
        {
            var result = new SimpleResult();
            //检查库存，更新发货单，生成分拣单，自动合并波次
            //这个后台做比较麻烦，mobox3库存在内存中，任务完成的时候无法增加，还是用c#直接管内存，计算比较方便
            WMSHelper.CreateSortingOrder(model.out_nos.Split(',').ToList());
            return result;
        }

        /// <summary>
        /// 后面要把方法放到wmsHelper中
        /// </summary>
        /// <param name="models"></param>
        /// <returns></returns>
        internal static SimpleResult SortingResultCheck(List<SortingResultCheck> models)
        {
            //生成分拣结果，更新分拣明细状态
            var result = new SimpleResult();
            WMSHelper.SortingConfrim(models);
            return result;
        }



        /// <summary>
        /// 后面要把方法放到wmsHelper中
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult Instock(InstockInfo model)
        {
            var result = new SimpleResult();
            //pda入库，目前人工放货在巷道口，扫托盘，后台只能计算当前巷道的终点，单深位立库
            //1，判断托盘信息，一种是码盘后的，默认enable是N，另一种是分拣回的
            var cntr = ContainerHelper.GetCntr(model.cntr);
            if (cntr != null)
            {
                var sortingInfo = WMSHelper.GetSortingDetailByCntr(model.cntr);
                if (cntr.C_ENABLE == "Y" && sortingInfo != null && sortingInfo.Count > 0)
                {
                    result.resultCode = 2;
                    result.resultMsg = $"托盘{model.cntr}未分拣完成";
                }
            }
            else
            {
                result.resultCode = 1;
                result.resultMsg = $"托盘{model.cntr}不存在";
            }
            if (result.resultCode == 0)
            {
                //获取接驳位所在的巷道, 查找功能区，入库接驳位找逻辑库区（每个巷道一个逻辑库区）
                var fa = LocationHelper.GetFunctionAreaByCode(model.start, 2, 10);
                if (fa != null)
                {
                    //创建入库作业，简单判断一下是否有可入货位，如果不判断，人工货放上去一直不能入，也不知道原因
                    var end = LocationHelper.GetZoneLoc(fa.S_MASTER_CODE);
                    if (end != null)
                    {
                        //判断托盘是否已经生成任务，如果没有则生成
                        var wmsTask = WMSHelper.GetWmsTaskByCntr(model.cntr);
                        if (wmsTask != null)
                        {
                            result.resultCode = 3;
                            result.resultMsg = $"起点{model.start} 托盘{model.cntr}已经创建任务，请勿重复申请";
                        }
                        else
                        {
                            wmsTask = new WMSTask
                            {
                                S_CNTR_CODE = model.cntr,
                                S_CODE = WMSHelper.GenerateTaskNo(),
                                S_START_LOC = model.start,
                                S_END_LOC = end.S_LOC_CODE,
                                N_TYPE = 1,
                                S_TYPE = WMSTask.GetTypeStr(1),
                                S_OP_DEF_CODE = "",
                                S_OP_DEF_NAME = "pda入立库"
                            };
                            if (WMSHelper.CreateWmsTask(wmsTask))
                            {
                                LocationHelper.LockLoc(model.start, 1);
                                result.resultMsg = $"创建作业成功，作业号{wmsTask.S_CODE}";
                            }
                        }
                    }
                    else
                    {
                        result.resultCode = 3;
                        result.resultMsg = $"起点{model.start}对应的逻辑库区{fa.S_MASTER_CODE}没有可用货位，请更换巷道";
                    }
                }
                else
                {
                    result.resultCode = 3;
                    result.resultMsg = $"起点{model.start}没有对应的逻辑库区，请在逻辑库区设置功能区-入库接驳位";
                }
            }
            return result;
        }

        internal static SimpleResult SortingOrderExecute(SortingOrderCheck model)
        {
            var result = new SimpleResult();
            //分拣单配货执行
            WMSHelper.CreateSortingOrderDetail(model.s_no);
            return result;
        }


        internal static SimpleResult CheckSortingWholeCntr(CheckSortingWholeCntr model)
        {
            var result = new SimpleResult();
            if (WMSHelper.CheckSortingWholeCntr(model.cntr, model.autoSort == 1))
            {
                result.resultCode = 1;
                result.resultMsg = "整托分拣";
            }
            return result;
        }
        internal static CodeInfo GetCodeInfo(string code, string org)
        {
            //return new CodeInfo {  Fitemid_XK=code, FSourceNo="123456"};
            CodeInfo result = null;
            try
            {
                var db = new SqlHelper<object>().GetInstance(Settings.SqlServer1);
                var nameP = new SugarParameter("@FBarCode", code);
                var orgP = new SugarParameter("@Forg", org);
                //var ageP = new SugarParameter("@age", null, true);//设置为output
                //var dt = db.Ado.UseStoredProcedure().GetDataTable("sp_school", nameP, ageP);//返回dt
                result = db.Ado.UseStoredProcedure().SqlQuery<CodeInfo>("WMS_FBarCode", nameP, orgP).First();//返回List
                Console.WriteLine($"读存储过程成功,result={result}");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            return result;
        }

        internal static SimpleResult PalletSorting1(PalletSorting1 model)
        {
            var result = new SimpleResult();
            //校验入库单数量，不可以超，成功后插入托盘物料表，更新入库单累计数量
            //也可以直接lua查询入库单数量，做校验
            //先用bar_code读存储过程获取信息
            var codeInfo = GetCodeInfo(model.bar_code, model.org);
            var info = WMSHelper.GetPutawayOrderDetail(model.bar_code);
            if (info != null)
            {
                if (info.F_QTY - info.F_ACC_B_QTY >= model.qty)
                {
                    // 插入到托盘明细表

                    var cntr = ContainerHelper.GetCntr(model.cntr_code, true);
                    if (cntr != null)
                    {
                        ContainerHelper.BindCntrItem(cntr, model.bar_code, info.S_BATCH_NO, model.qty, info.S_BATCH_NO);
                        //更新入库单累计绑定数量
                        info.F_ACC_B_QTY += model.qty;
                        WMSHelper.UpdatePutawayOrderDetailQty(info);
                    }
                    else
                    {
                        result.resultCode = 2;
                        result.resultMsg = "获取托盘信息失败";
                    }


                }
                else
                {
                    result.resultCode = 1;
                    result.resultMsg = "累计码盘数量超出入库单数量";
                }
            }
            else
            {
                result.resultCode = 3;
                result.resultMsg = $"未获取到该物料{model.bar_code}的入库单明细信息";
            }

            return result;
        }


        //public class AddTaskModel
        //{
        //    public string From { get; set; }
        //    public string To { get; set; }
        //    public string No { get; set; }
        //}
        public class TN_LocationModel
        {
            public string TN_Location { get; set; }
        }
        public class CodeInfo
        {
            /// <summary>
            /// 生产订单内码
            /// </summary>
            public string FInterID { get; set; }
            /// <summary>
            /// 生产订单编号
            /// </summary>
            public string FSourceNo { get; set; }
            /// <summary>
            /// 批号
            /// </summary>
            public string FGMPBatchNo { get; set; }
            public string FState { get; set; }
            /// <summary>
            /// 物料编码（内码就是编码）
            /// </summary>
            public string Fitemid_XK { get; set; }
            /// <summary>
            /// 分录id
            /// </summary>
            public string Fentryid { get; set; }
        }
        public class NoteInfo : CodeInfo
        {
            public string WmsBillNo { get; set; }
        }
    }
}