using HH.WCS.Mobox3.HD.core;
using HH.WCS.Mobox3.HD.models;
using HH.WCS.Mobox3.HD.util;
using HH.WCS.Mobox3.HD.wms;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using static HH.WCS.Mobox3.HD.api.ApiModel;
using static HH.WCS.Mobox3.HD.api.MoboxController;
using static HH.WCS.Mobox3.HD.api.OtherModel;
using static HH.WCS.Mobox3.HD.api.WmsController;
using static HH.WCS.Mobox3.HD.util.Settings;
using static HH.WCS.Mobox3.HD.wms.WMSHelper;

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

        }
        /// <summary>
        /// 创建任务
        /// </summary>
        /// <param name="model"></param>
        internal static void AddTask(AddTaskModel model) {
            if (!WCSHelper.CheckExist(model.No)) {
                if (LocationHelper.CheckExist(model.From) && LocationHelper.CheckExist(model.To)) {
                    WCSHelper.CreateTask(model.No, model.From, model.To, "搬运", 99, "");
                }

            }
        }
        /// <summary>
        /// 创建入库单主子表
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        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;
        }

        /// <summary>
        /// 创建发货单主子表
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        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 };
                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;
        }

        /// <summary>
        /// pad入库
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult Instock(InstockInfo model) {
            var result = new SimpleResult();
            //pda入库
            //1 判断起点有没有任务，有没有入库锁
            var loc = LocationHelper.GetLoc(model.start);
            if (loc != null && loc.N_LOCK_STATE == 0) {
                //2 根据终点库区计算终点
                var end = WMSHelper.GetInstockEnd(model.item, model.endArea);
                if (end != null) {
                    var cntrCode = ContainerHelper.GenerateCntrNo();
                    var wcsTask = new WCSTask
                    {
                        S_OP_NAME = "入库",
                        S_CODE = WCSHelper.GenerateTaskNo(),
                        S_TYPE = "下线入库",
                        S_START_LOC = model.start,
                        S_END_LOC = end.S_CODE,
                        S_SCHEDULE_TYPE = "NDC",
                        N_CNTR_COUNT = 1,
                        S_CNTR_CODE = cntrCode,
                        N_START_LAYER = 1,
                        N_END_LAYER = end.N_CURRENT_NUM + 1
                    };
                    if (ContainerHelper.BindNewCntrItem(model.start, cntrCode, model.item) && WCSHelper.CreateTask(wcsTask)) {
                        LocationHelper.LockLoc(model.start, 2);
                        LocationHelper.LockLoc(end.S_CODE, 1);
                        result.resultCode = 0;
                        result.resultMsg = $"任务创建成功,任务号为{wcsTask.S_CODE},终点为{end.S_CODE}";
                    }
                }
                else {
                    result.resultCode = 2;
                    result.resultMsg = "未获取到入库终点";
                }
            }
            else {
                result.resultCode = 1;
                result.resultMsg = "起点有任务未完成";
            }
            return result;
        }

        /// <summary>
        /// 移库
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult shiftStock(ShiftStockInfo model)
        {
            var result = new SimpleResult();
            //1 根据起点库区、排 确定起始货位
            var startLoc = WMSHelper.GetShiftStockStart(model.item, model.startArea, model.startRow);
            if (startLoc != null && startLoc.N_LOCK_STATE == 0)
            {
                //2 根据终点库区计算终点
                var end = WMSHelper.GetShiftStockEnd(model.item, model.endArea, model.startRow);
                if (end != null && end.N_LOCK_STATE == 0)
                {
                    var wcsTask = new WCSTask
                    {
                        S_OP_NAME = "移库",
                        S_CODE = WCSHelper.GenerateTaskNo(),
                        S_TYPE = "移库",
                        S_START_LOC = startLoc.S_CODE,
                        S_END_LOC = end.S_CODE,
                        S_SCHEDULE_TYPE = "NDC",
                        N_CNTR_COUNT = 1,
                        S_CNTR_CODE = startLoc.LocCntrRel.S_CNTR_CODE,
                        N_START_LAYER = startLoc.N_CURRENT_NUM,
                        N_END_LAYER = end.N_CURRENT_NUM + 1
                    };
                    if (WCSHelper.CreateTask(wcsTask))
                    {
                        LocationHelper.LockLoc(startLoc.S_CODE, 2);
                        LocationHelper.LockLoc(end.S_CODE, 1);
                        result.resultCode = 0;
                        result.resultMsg = $"任务创建成功,任务号为{wcsTask.S_CODE},终点为{end.S_CODE}";
                    }
                }
                else
                {
                    result.resultCode = 2;
                    result.resultMsg = "未获取到移库终点";
                }
            }
            else
            {
                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;
        }
        // ---------------------------------- 哈电 -------------------------------------
       
        private static readonly object in_lock = new object();

        /// <summary>
        /// 入库请求参数验证
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static ResponseResult inStockRequestParamVerify(InStockInfo model) {
            ResponseResult responseResult = new ResponseResult() { success = false };
            if (model.taskType.Equals("半成品/成品入库") && (model.trayItemInfoList == null || model.trayItemInfoList.Count == 0))
            {
                responseResult.message = "物料信息不能为空！";
                return responseResult;
            }
            LocCntrRel locCntrRel = ContainerHelper.getLocCntr(model.trayCode);
            if (locCntrRel != null && !locCntrRel.S_LOC_CODE.Equals(model.startBit))
            {
                responseResult.message = $"起点货位与容器货位不匹配,当前起点货位：{model.startBit}，系统显示容器应该所在货位：{locCntrRel.S_LOC_CODE}";
                return responseResult;
            }
            var existWmsTask = WMSHelper.GetWmsTaskByCntr(model.trayCode);
            if (existWmsTask != null)
            {
                responseResult.message = $"相关容器存在未完成任务【已有{existWmsTask.T_CREATE.ToString("yyyy-MM-dd HH:mm:ss")}的{existWmsTask.S_TYPE}任务】";
                return responseResult;
            }
            return null;
        }

        internal static int freqFlag = 0;

        /// <summary>
        /// 按一定频率分配库区（频率  1栋立库:7栋立库:横栋立库 = 1:2:1）
        /// </summary>
        /// <returns></returns>
        public static Dictionary<int, string> distributeArea() {
            Dictionary<int, string> map = new Dictionary<int, string>();
            List<StoreAreaInfo> areaInfos = Settings.storeAreaInfos.Where(a => a.cargoType == 1).ToList();
            int index = 0;
            foreach (var item in areaInfos)
            {
                for (int i = 0; i < item.frequency; i++)
                {
                    map.Add(index, item.areaCode);
                    index++;
                }
            }
            return map;
        }

        /// <summary>
        /// 查询半成品/成品入库任务终点
        /// </summary>
        /// <param name="model"></param>
        public static TaskEndData getInStcokTaskEnd(InStockInfo model) {
            TaskEndData taskEndData = new TaskEndData();
            List<string> conLocCodes = new List<string>();
            Location endLoc = null;
            Location firstTaskEnd = null;
            var map = distributeArea(); //按规定频率分配库区
            string areaCode = Settings.getStoreAreaByAccessArea(model.endArea);
            // 优先选定库区入库
            if (areaCode != null)
            {
                LogHelper.Info("车间任务号：" + JsonConvert.SerializeObject(model.taskNo), "Mobox");
                conLocCodes = LocationHelper.GetConnectLocation(areaCode, 1, 1, 1, model.startArea);
                if (conLocCodes != null && conLocCodes.Count > 0)
                {
                    foreach (var item in conLocCodes)
                    {
                        LogHelper.Info("接驳位：" + JsonConvert.SerializeObject(item), "Mobox");
                        var conLoc = LocationHelper.GetLoc(item);
                        endLoc = WMSHelper.GetEndLocation(areaCode, model.trayItemInfoList[0].itemCode, conLoc.N_ROADWAY, conLoc.N_ROW,4);
                        if (endLoc != null)
                        {
                            firstTaskEnd = conLoc;
                            endLoc.S_CODE = "虚拟货位";
                            break;
                        }
                    }
                }
            }
            // 如选定库区不能入库，则选择其他库区
            /*if (endLoc == null)
            {
                // TODO freqFlag = 1 
                freqFlag = 1;
                if (map.TryGetValue(freqFlag, out areaCode))
                {
                    conLocCodes = LocationHelper.GetConnectLocation(areaCode, 1, freqFlag == 2 ? 2 : 1, 1, model.startArea);
                    if (conLocCodes != null && conLocCodes.Count > 0)
                    {
                        foreach (var item in conLocCodes)
                        {
                            var conLoc = LocationHelper.GetLoc(item);
                            endLoc = WMSHelper.GetEndLocation(areaCode, model.trayItemInfoList[0].itemCode, conLoc.N_ROADWAY, conLoc.N_ROW);
                            if (endLoc != null)
                            {
                                firstTaskEnd = conLoc;

                                freqFlag += 1;
                                if (freqFlag == 4)
                                {
                                    freqFlag = 0;
                                }
                                break;
                            }
                        }
                    }
                }
            }*/

            if (endLoc != null)
            {
                // 绑定容器物料信息
                model.trayItemInfoList.ForEach(it =>
                {
                    CntrItemRel cntrItemRel = new CntrItemRel()
                    {
                        S_ITEM_CODE = it.itemCode,
                        S_ITEM_NAME = it.itemName,
                        S_WORK_NO = it.workNo,
                        S_WORK_NAME = it.workName,
                        S_DEPART_NO = it.dePartNo,
                        S_PART_TASK_ID = it.partTaskId,
                        S_PARTDRAW_NO = it.partDrawNo,
                        S_PART_NAME = it.partName,
                        S_OPER_NO = it.operNo,
                        S_OPER_NAME = it.operName,
                        F_QTY = float.Parse(it.quantity == null ? "0" : it.quantity),
                        F_WEIGHT = float.Parse(it.weight == null ? "0" : it.weight),
                        S_ITEM_SPEC = it.spec,
                        S_ITEM_TYPE = it.isFinish
                    };
                    ContainerHelper.initContainer(model.trayCode);
                    ContainerHelper.BindCntrItemSingle(model.trayCode, cntrItemRel);
                });
            }
            taskEndData.endLoc = endLoc;
            taskEndData.firstTaskEnd = firstTaskEnd;
            return taskEndData;
        }

        /// <summary>
        /// 查询钢卷入库任务终点
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static TaskEndData steelCoilInStock(InStockInfo model) {
            TaskEndData taskEndData = new TaskEndData();
            List<string> conLocCodes = new List<string>();
            Location endLoc = null;
            Location firstTaskEnd = null;
            var coil = ItemHelper.GetCoilItemInfo(model.trayCode);
            if (coil != null)
            {
                coil.S_WORK_NAME = model.trayItemInfoList[0].workName;
                ItemHelper.UpdateCntrItemInfo(coil);
                ContainerHelper.addCntr(model.trayCode);
            }
            else
            {
                return null;
            }
            endLoc = new Location() { S_CODE = "虚拟库位", S_AREA_CODE = "虚拟库区" };
            List<string> gjkAreaCodes = Settings.getStoreAreaCodes(1, 2);
            foreach (var gjArea in gjkAreaCodes)
            {
                var connectLoc = LocationHelper.GetConnectLocation(gjArea, 1).FirstOrDefault();
                if (connectLoc != null)
                {
                    firstTaskEnd = LocationHelper.GetLoc(connectLoc);
                    break;
                }
            }
            taskEndData.endLoc = endLoc;
            taskEndData.firstTaskEnd = firstTaskEnd;
            return taskEndData;
        }

        /// <summary>
        /// 查询空盘垛入库终点
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static TaskEndData emptyTrayInStock(InStockInfo model) {
            TaskEndData taskEndData = new TaskEndData();
            List<string> conLocCodes = new List<string>();
            Location endLoc = null;
            Location firstTaskEnd = null;
            var map = distributeArea(); //按规定频率分配库区
            string areaCode = Settings.getStoreAreaByAccessArea(model.endArea);

            if (freqFlag == 4 || freqFlag % 4 == 3)
            {
                freqFlag = 0;
            }
            if (map.TryGetValue(freqFlag, out areaCode))
            {
                conLocCodes = LocationHelper.GetConnectLocation(areaCode, 1, 1, 1);
                foreach (var item in conLocCodes)
                {
                    var conLoc = LocationHelper.GetLoc(item);
                    endLoc = WMSHelper.GetEndLocation(areaCode, null, conLoc.N_ROADWAY, conLoc.N_ROW);
                    if (endLoc != null)
                    {
                        firstTaskEnd = conLoc;
                        endLoc.S_CODE = "虚拟货位";
                        break;
                    }
                }
            }
            freqFlag += 1;

            taskEndData.endLoc = endLoc;
            taskEndData.firstTaskEnd = firstTaskEnd;
            return taskEndData;
        }

        /// <summary>
        /// 查询模具入库终点
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static TaskEndData mouldInStock(InStockInfo model) {
            TaskEndData taskEndData = new TaskEndData();
            Location endLoc = null;
            Location firstTaskEnd = null;

            MouldCntr mouldCntr = MouldHelper.GetMouldCntr(new MouldCntr() { S_CNTR_CODE = model.trayCode });
            if (mouldCntr != null)
            {
                ContainerHelper.addCntr(model.trayCode);
                endLoc = LocationHelper.GetLocation(mouldCntr.S_LOC_CODE);
                firstTaskEnd = endLoc;
            }

            taskEndData.endLoc = endLoc;
            taskEndData.firstTaskEnd = firstTaskEnd;
            return taskEndData;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static TaskEndData finishInStockTemporaryArea(InStockInfo model) {
            TaskEndData taskEndData = new TaskEndData();
            Location endLoc = null;
            Location firstTaskEnd = null;

            if (model.endArea != null)
            {
                endLoc = WMSHelper.GetDeliverEndLocation(model.endArea);
            }

            if (endLoc == null)
            {
                List<string> areaCodes = Settings.getDispatchAreaCodes();
                foreach (var item in areaCodes)
                {
                    endLoc = WMSHelper.GetDeliverEndLocation(item);
                    if (endLoc != null)
                    {
                        break;
                    }
                }
            }

            firstTaskEnd = endLoc;
            if (endLoc != null)
            {
                // 绑定容器物料信息
                model.trayItemInfoList.ForEach(it =>
                {
                    CntrItemRel cntrItemRel = new CntrItemRel()
                    {
                        S_ITEM_CODE = it.itemCode,
                        S_ITEM_NAME = it.itemName,
                        S_WORK_NO = it.workNo,
                        S_WORK_NAME = it.workName,
                        S_DEPART_NO = it.dePartNo,
                        S_PARTDRAW_NO = it.partDrawNo,
                        S_PART_NAME = it.partName,
                        S_OPER_NO = it.operNo,
                        S_OPER_NAME = it.operName,
                        F_QTY = float.Parse(it.quantity == null ? "0" : it.quantity),
                        F_WEIGHT = float.Parse(it.weight == null ? "0" : it.weight),
                        S_ITEM_SPEC = it.spec,
                        S_ITEM_TYPE = it.isFinish
                    };
                    ContainerHelper.BindCntrItemSingle(model.trayCode, cntrItemRel);
                });
            }

            taskEndData.endLoc = endLoc;
            taskEndData.firstTaskEnd = firstTaskEnd;
            return taskEndData;
        }

        public class TaskEndData { 
            public Location endLoc { get; set; }
            public Location firstTaskEnd { get; set; }
        }


        /// <summary>
        /// 创建入库搬运任务
        /// * 钢卷\模具入库需要传起点库位
        /// * 任务类型分为 半成品/成品入库 、钢卷入库 、模具入库、模具托盘回库
        /// * 半成品/成品入库 横栋、1栋、7栋的分配频率为 1:1:2
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static ResponseResult createInOrder(InStockInfo model)
        {
            ResponseResult responseResult = new ResponseResult() { success = true };
            InStockRetureData retureData = new InStockRetureData(){ startStationCode = model.startBit,startAreaCode = model.startArea };

            var response = inStockRequestParamVerify(model); // 参数验证
            if (response != null) {
                return response;
            }
             
            var map = distributeArea(); //按规定频率分配库区

            
            Location startLoc = LocationHelper.GetLoc(model.startBit);
            Location endLoc = null;
            Location firstTaskEnd = null;  // 一阶段任务终点
            TaskEndData taskEndData = null;
            List<string> conLocCodes = new List<string>();
            lock (in_lock) {
                switch (model.taskType)
                {
                    case "半成品/成品入库":
                        taskEndData = getInStcokTaskEnd(model);
                        if (taskEndData.firstTaskEnd == null) 
                        {
                            responseResult.success = false;
                            responseResult.message = "当前区域无可用接驳位，请排查";
                            return responseResult;
                        }
                        break;
                    case "钢卷入库":
                        taskEndData = steelCoilInStock(model);
                        break;
                    case "模具入库":
                    case "模具托盘入库":
                        taskEndData = mouldInStock(model);
                        break;
                    case "空盘垛入库":
                        taskEndData = emptyTrayInStock(model);
                        break;
                    case "成品入库备货区":
                        taskEndData = finishInStockTemporaryArea(model);
                        break;
                    default:
                        responseResult.success = false;
                        responseResult.message = "没有相应的任务类型";
                        return responseResult;
                }
            }

            if (startLoc == null)
            {
                if (model.taskType.Contains("模具") || model.taskType.Contains("钢卷"))
                {
                    responseResult.success = false;
                    responseResult.message = "开始货位未指定或不存在";
                    return responseResult;
                }
                startLoc = new Location() { S_CODE = model.startBit, S_AREA_CODE = model.startArea };
            }
            else
            {
                if (startLoc.N_LOCK_STATE != 0)
                {
                    responseResult.success = false;
                    responseResult.message = "开始货位已上锁";
                    return responseResult;
                }
            }

            if (taskEndData != null)
            {
                endLoc = taskEndData.endLoc;
                firstTaskEnd = taskEndData.firstTaskEnd;
            }

            // 2.创建入库作业任务
            if (endLoc != null )
            {
                var wmsTask = new WMSTask()
                {
                    S_CNTR_CODE = model.trayCode,
                    S_CODE = WMSHelper.GenerateTaskNo(),
                    S_START_LOC = startLoc.S_CODE,
                    S_START_AREA = startLoc.S_AREA_CODE,
                    S_END_LOC = endLoc.S_CODE,
                    S_END_AREA = endLoc.S_AREA_CODE,
                    S_TYPE = model.taskType,
                    S_OP_DEF_CODE = model.taskNo,
                    S_OP_DEF_NAME = "入库搬运任务",
                    N_PRIORITY = model.taskPri == null ? 1 : int.Parse(model.taskPri),
                    T_START_TIME = DateTime.Now,
                };

                if (WMSHelper.CreateWmsTask(wmsTask))
                {
                    string S_SCHEDULE_TYPE = "HL";
                    if (model.taskType.Equals("半成品/成品入库") || model.taskType.Equals("空盘垛入库") || model.taskType.Equals("成品入库备货区"))
                    {
                        S_SCHEDULE_TYPE = "LD-AUTO";
                    }

                    // 创建一段入库任务
                    WCSTask wcsTask = new WCSTask()
                    {
                        S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                        S_OP_CODE = wmsTask.S_CODE,
                        S_CODE = WCSHelper.GenerateTaskNo(),
                        S_CNTR_CODE = wmsTask.S_CNTR_CODE,
                        S_TYPE = wmsTask.S_TYPE + "-1",
                        S_START_LOC = startLoc.S_CODE,
                        S_START_AREA = startLoc.S_AREA_CODE,
                        S_END_LOC = firstTaskEnd.S_CODE,
                        S_END_AREA = firstTaskEnd.S_AREA_CODE,
                        S_SCHEDULE_TYPE = S_SCHEDULE_TYPE,
                        N_PRIORITY = 1,
                        T_START_TIME = DateTime.Now,
                    };

                    if (WCSHelper.CreateTask(wcsTask))
                    {
                        // 起点、接驳点、终点加锁
                        LocationHelper.LockLoc(wcsTask.S_START_LOC, 2);
                        LocationHelper.LockLoc(firstTaskEnd.S_CODE, 1);
                        
                        // 更新作业任务状态
                        wmsTask.N_B_STATE = 1;
                        WMSHelper.UpdateTaskState(wmsTask);
                    }
                    retureData.wmsId = wmsTask.S_CODE;
                    retureData.endStationCode = firstTaskEnd.S_CODE;
                    retureData.endAreaCode = firstTaskEnd.S_AREA_CODE;
                    responseResult.result = retureData;
                }
            }
            else
            {
                responseResult.success = false;
                responseResult.message = "未获取到终点库位,剩余货位不足";
            }
            return responseResult;
        }
        
        private static readonly object out_lock = new object();

        /// <summary>
        /// 移库（立库出库阻塞）
        /// </summary>
        /// <param name="outLoc"></param>
        /// <param name="wmsTaskId"></param>
        /// <returns></returns>
        public static bool shiftStock(Location outLoc,string wmsTaskId) {
            bool result = false;
            string outCntrCode = ContainerHelper.getLocCntrByLoc(outLoc.S_CODE).S_CNTR_CODE;
            var cntrItemRels = ItemHelper.GetCntrItemByCntrCode(outCntrCode);
            string itemCode = null;
            if(cntrItemRels != null && cntrItemRels.Count > 0)
            {
                itemCode = cntrItemRels[0].S_ITEM_CODE;
            }
            Location inLoc = WMSHelper.GetEndLocation(outLoc.S_AREA_CODE, itemCode, outLoc.N_ROADWAY, 1);

            // 进行移库操作
            if (inLoc != null)
            {
                var shiftWcsTask = new WCSTask
                {
                    S_CODE = WCSHelper.GenerateTaskNo(),
                    S_TYPE = "移库",
                    S_START_LOC = outLoc.S_CODE,
                    S_START_AREA = outLoc.S_AREA_CODE,
                    S_END_LOC = inLoc.S_CODE,
                    S_END_AREA = inLoc.S_AREA_CODE,
                    S_CNTR_CODE = outCntrCode,
                    S_SCHEDULE_TYPE = "RB",
                    S_OP_CODE = wmsTaskId,
                    S_EQ_NO = getEqNo(outLoc.S_AREA_CODE, outLoc.N_ROADWAY),
                    N_PRIORITY = 9,
                    T_START_TIME = DateTime.Now,
                };
                if (WCSHelper.CreateTask(shiftWcsTask))
                {
                    LocationHelper.LockLoc(outLoc.S_CODE, 2);
                    LocationHelper.LockLoc(inLoc.S_CODE, 1);
                    result = true;
                }
            }
            return result;
        }


        /// <summary>
        /// 创建出库搬运任务
        /// *钢卷/模具出库需要指定终点
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static ResponseResult createOutOrder(OutStockInfo model) {
            ResponseResult responseResult = new ResponseResult(){success = false};

            Location endLoc = LocationHelper.GetLoc(model.endBit);
            if (endLoc == null)
            {
                if (model.taskType.Contains("模具") || model.taskType.Contains("钢卷"))
                {
                    responseResult.message = "终点货位未指定或不存在";
                    return responseResult;
                }
                endLoc = new Location() { S_CODE = model.endBit, S_AREA_CODE = model.endArea };
            }
            else
            {
                if (endLoc.N_LOCK_STATE != 0)
                {
                    responseResult.message = "终点货位已上锁";
                    return responseResult;
                }
            }

            Location startLoc = null;
            Location firstTaskEnd = null;
            ItemStartLoc itemStartLoc = new ItemStartLoc();
            MouldCntr mouldCntr = null;
            // 1、查询开始货位、终点货位
            lock (out_lock)
            {
                switch (model.taskType)
                {
                    case "半成品/成品出库":
                        itemStartLoc = WMSHelper.GetStartLocation(model.itemCode, model.partTaskId, model.workNo, null, model.endArea);
                        if (itemStartLoc.type != 0)
                        {
                            startLoc = itemStartLoc.loc;
                            firstTaskEnd = itemStartLoc.connectloc;
                            if (startLoc != null &&  firstTaskEnd == null) {
                                responseResult.message = "堆垛机或输送线设备可能存在故障，请排查";
                                return responseResult;
                            }
                        }
                        else
                        {
                            responseResult.message = "库区没有该物料";
                            return responseResult;
                        }
                        break;
                    case "钢卷出库":
                        startLoc = WMSHelper.GetGJStartLocation(model.itemCode, model.coilNo, model.workNo, model.weight, model.width);
                        break;
                    case "模具出库":
                        var mouldCntrs = MouldHelper.GetMouldCntrList(new MouldCntr() { S_ITEM_CODE = model.itemCode, S_MOULD_NO = model.itemCode });
                        if (mouldCntrs != null && mouldCntrs.Count > 0)
                        {
                            mouldCntr = mouldCntrs[0];
                            startLoc = LocationHelper.GetLocation(mouldCntr.S_LOC_CODE);
                            if (startLoc.N_LOCK_STATE != 0 || startLoc.N_CURRENT_NUM == 0)
                            {
                                responseResult.message = "模具库位已出库或已上锁";
                                return responseResult;
                            }
                        }
                        break;
                    case "模具托盘出库":
                        mouldCntr = MouldHelper.GetMouldCntr(new MouldCntr() { S_ITEM_CODE = model.itemCode, S_MOULD_NO = model.itemCode });
                        if (mouldCntr != null)
                        {
                            startLoc = LocationHelper.GetLocation(mouldCntr.S_LOC_CODE);
                            if (startLoc.N_LOCK_STATE != 0 || startLoc.N_CURRENT_NUM == 0)
                            {
                                responseResult.message = "模具托盘已出库或已上锁";
                                return responseResult;
                            }
                        }
                        break;
                    case "叫托盘出库":
                        if (model.trayCode != null)
                        {
                            itemStartLoc = WMSHelper.GetStartLocationByTrayCode(model.trayCode, model.endArea);
                            if (itemStartLoc.type != 0)
                            {
                                startLoc = itemStartLoc.loc;
                                firstTaskEnd = itemStartLoc.connectloc;
                            }
                            else
                            {
                                responseResult.message = "该托盘处于不可用状态：锁定、禁用、阻塞、不存在";
                                return responseResult;
                            }
                        }
                        else 
                        {
                            responseResult.message = "托盘号不能为空";
                            return responseResult;
                        }
                        break;
                    case "空盘垛出库":
                        itemStartLoc = WMSHelper.GetStartLocation(null, null, null, null,model.endArea);
                        if (itemStartLoc.type != 0)
                        {
                            startLoc = itemStartLoc.loc;
                            firstTaskEnd = itemStartLoc.connectloc;
                        }
                        else
                        {
                            responseResult.message = "库区没有该物料";
                            return responseResult;
                        }
                        break;
                }

                if (startLoc == null){
                    responseResult.message = "未找到符合出库条件的物料";
                    return responseResult;
                }

                // 2、创建出库作业任务
                string cntrCode = null;
                LocCntrRel locCntrRel = ContainerHelper.getLocCntrByLoc(startLoc.S_CODE);
                if (locCntrRel != null){
                    cntrCode = locCntrRel.S_CNTR_CODE;
                }

                var existWmsTask = WMSHelper.GetWmsTaskByCntr(cntrCode);
                if (existWmsTask != null){
                    responseResult.message = "相关容器存在未完成任务";
                    return responseResult;
                }

                Location externalTaskStartLoc =  null;
                // 模具钢卷出库只有一段任务
                if (model.taskType.Contains("模具") || model.taskType.Contains("钢卷"))
                {
                    externalTaskStartLoc = startLoc;
                    firstTaskEnd = endLoc;
                }
                else
                {
                    if (firstTaskEnd != null) {
                        externalTaskStartLoc = LocationHelper.GetLoc(WCSHelper.GetLinePlcInfoByLoc(firstTaskEnd.S_CODE).descLocation);
                    }
                }

                WMSTask wmsTask = null;
                if (firstTaskEnd != null)
                {
                    wmsTask = new WMSTask(){
                        S_CNTR_CODE = cntrCode,
                        S_CODE = WMSHelper.GenerateTaskNo(),
                        S_START_LOC = startLoc.S_CODE,
                        S_START_AREA = startLoc.S_AREA_CODE,
                        S_END_LOC = endLoc.S_CODE,
                        S_END_AREA = endLoc.S_AREA_CODE,
                        S_TYPE = model.taskType,
                        S_OP_DEF_CODE = model.taskNo,
                        S_OP_DEF_NAME = "出库搬运任务",
                        N_PRIORITY = int.Parse(model.taskPri),
                        T_START_TIME = DateTime.Now};

                    LogHelper.Info($"开始创建作业任务，创建时间：" + DateTime.Now, "车间控制器");

                    if (WMSHelper.CreateWmsTask(wmsTask)){

                        LogHelper.Info($"创建作业任务完成，创建时间：" + DateTime.Now, "车间控制器");
                        // 物料不可取货位,需先进行移库
                        if ((model.taskType.Equals("半成品/成品出库") || model.taskType.Equals("空盘垛出库") || model.taskType.Equals("叫托盘出库")) && itemStartLoc.type == 2){
                            bool shiftResult = shiftStock(itemStartLoc.outLoc,wmsTask.S_CODE);
                            if (!shiftResult) {
                                wmsTask.N_B_STATE = 3;
                                WMSHelper.UpdateTaskState(wmsTask);

                                responseResult.message = "取货阻塞且巷道两边货物已满，无法取货";
                                return responseResult;
                            }
                        }

                        // 查询立体库库区
                        string S_SCHEDULE_TYPE = null;
                        List<string> areaCodes = Settings.getStoreAreaCodes(2, 1);
                        if (areaCodes.Contains(startLoc.S_AREA_CODE)){
                            S_SCHEDULE_TYPE = "RB";
                          /*  string firstEndLoc = WCSHelper.GetLinePlcInfoByDesc(firstTaskEnd.S_CODE).localtion;
                            firstTaskEnd = LocationHelper.GetLoc(firstEndLoc);*/
                        }
                        else{
                            S_SCHEDULE_TYPE = "HL";
                        }

                        var wcsTask = new WCSTask{
                            S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                            S_CODE = WCSHelper.GenerateTaskNo(),
                            S_TYPE = wmsTask.S_TYPE + "-1",
                            S_START_LOC = startLoc.S_CODE,
                            S_START_AREA = startLoc.S_AREA_CODE,
                            S_END_LOC = firstTaskEnd.S_CODE,
                            S_END_AREA = firstTaskEnd.S_AREA_CODE,
                            S_CNTR_CODE = cntrCode,
                            S_SCHEDULE_TYPE = S_SCHEDULE_TYPE,
                            S_OP_CODE = wmsTask.S_CODE,
                            S_EQ_NO = getEqNo(startLoc.S_AREA_CODE, startLoc.N_ROADWAY),
                            N_PRIORITY = 1,
                            T_START_TIME = DateTime.Now};

                        LogHelper.Info($"开始创建任务，创建时间：" + DateTime.Now, "车间控制器");

                        if (WCSHelper.CreateTask(wcsTask)){

                            LogHelper.Info($"创建任务完成，创建时间：" + DateTime.Now, "车间控制器");
                            // 开始货位、终点货位进行加锁
                            LocationHelper.LockLoc(startLoc.S_CODE, 2);
                            LocationHelper.LockLoc(firstTaskEnd.S_CODE, 1);
                            LocationHelper.LockLoc(endLoc.S_CODE, 1);
                            // 更新作业任务状态
                            wmsTask.N_B_STATE = 1;
                            WMSHelper.UpdateTaskState(wmsTask);
                        }
                    }
                }
                else{
                    responseResult.message = "接驳位处于锁定状态，请联系管理人员解锁";
                    return responseResult;
                }
                // 3、组装返回数据
                return assembleResponseData(externalTaskStartLoc, endLoc, model.taskType, wmsTask);
            }
        }

        /// <summary>
        /// 组装返回数据
        /// </summary>
        /// <param name="externalTaskStartLoc"></param>
        /// <param name="endLoc"></param>
        /// <param name="taskType"></param>
        /// <param name="wmsTask"></param>
        /// <returns></returns>
        public static ResponseResult assembleResponseData(Location externalTaskStartLoc,Location endLoc ,string taskType ,WMSTask wmsTask ) {
            ResponseResult responseResult = new ResponseResult() { success = true };
            OutStockReturnData outStockReturnData = new OutStockReturnData()
            {
                startStationCode = externalTaskStartLoc.S_CODE,
                startAreaCode = externalTaskStartLoc.S_AREA_CODE,
                endStationCode = endLoc.S_CODE,
                endAreaCode = endLoc.S_AREA_CODE,
                wmsId = wmsTask.S_CODE
            };
            List<TrayItemInfoRes> trayItemInfos = new List<TrayItemInfoRes>();

            if ("模具出库".Equals(taskType) || "模具托盘出库".Equals(taskType))
            {
                MouldCntr mouldCntr = MouldHelper.GetMouldCntr(new MouldCntr() { S_CNTR_CODE = wmsTask.S_CNTR_CODE });
                foreach (var item in mouldCntr.mouldDetails)
                {
                    TrayItemInfoRes trayItemInfo = new TrayItemInfoRes()
                    {
                        trayCode = mouldCntr.S_CNTR_CODE,
                        itemCode = item.S_MOULD_NO,
                        itemName = item.S_NAME,
                        quantity = item.N_QTY.ToString()
                    };
                    trayItemInfos.Add(trayItemInfo);
                }
            }
            else
            {
                List<CntrItemRel> cntrItemRels = ContainerHelper.GetCntrItemRel(wmsTask.S_CNTR_CODE);
                foreach (var item in cntrItemRels)
                {
                    TrayItemInfoRes trayItemInfo = new TrayItemInfoRes()
                    {
                        trayCode = item.S_CNTR_CODE,
                        workNo = item.S_WORK_NO,
                        dePartNo = item.S_DEPART_NO,
                        partTaskId = item.S_PART_TASK_ID,
                        partDrawNo = item.S_PARTDRAW_NO,
                        partName = item.S_PART_NAME,
                        operNo = item.S_OPER_NO,
                        operName = item.S_OPER_NAME,
                        itemCode = item.S_ITEM_CODE,
                        itemName = item.S_ITEM_NAME,
                        spec = item.S_ITEM_SPEC,
                        quantity = item.F_QTY.ToString(),
                        weight = item.F_WEIGHT.ToString(),
                        width = item.S_WIDTH,
                        isFinish = item.S_ITEM_TYPE,
                    };
                    trayItemInfos.Add(trayItemInfo);
                }
            }
            outStockReturnData.trayItemInfo = trayItemInfos;
            responseResult.result = outStockReturnData;
            return responseResult;
        }

        /// <summary>
        /// 获取堆垛机设备号
        /// </summary>
        /// <param name="areaCode"></param>
        /// <param name="roadWay"></param>
        /// <returns></returns>
        public static string getEqNo(string areaCode,int roadWay) {
            DevicePlcInfo devicePlcInfo = Settings.devicePlcInfos.Where(a => a.area == areaCode && a.roadway == roadWay).FirstOrDefault();
            if (devicePlcInfo != null) {
              return  devicePlcInfo.deviceNo;
            }
            return null;
        }

        /// <summary>
        /// 钢卷入库
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static SimpleResult steelCoilIntoStorage(SteelCoilInStockInfo model) {
            SimpleResult result = new SimpleResult();   
            var startLoc = LocationHelper.GetLoc(model.locCode);
            if (startLoc == null ) {
                result.resultCode = 1;
                result.resultMsg = "开始货位不存在";
                return result;
            }
            var mst = WMSHelper.GetWmsTaskByCntr(model.coilNo);
            if (mst != null) 
            {
                result.resultCode = 1;
                result.resultMsg = "该钢卷存在执行中的任务";
                return result;
            }
            var coil = ItemHelper.GetCoilItemInfo(model.coilNo);
            if (coil != null)
            {
                var gjWeight = WCSCore.getGjWeight(model.locCode, model.coilNo);
                if (gjWeight == 0) {
                    result.resultCode = 1;
                    result.resultMsg = "钢卷重量为0";
                    return result;
                }

                Location  endLoc = WMSHelper.GetGJEndLocation(gjWeight);

                if ( endLoc != null)
                {
                    var wmsTask = new WMSTask()
                    {
                        S_CNTR_CODE = model.coilNo,
                        S_CODE = WMSHelper.GenerateTaskNo(),
                        S_START_LOC = startLoc.S_CODE,
                        S_START_AREA = startLoc.S_AREA_CODE,
                        S_END_LOC = endLoc.S_CODE,
                        S_END_AREA = endLoc.S_AREA_CODE,
                        S_TYPE = "钢卷来料入库",
                        S_OP_DEF_NAME = "入库搬运任务",
                        N_PRIORITY = 1,
                    };

                    if (WMSHelper.CreateWmsTask(wmsTask))
                    {
                        var wcsTask = new WCSTask
                        {
                            S_OP_CODE = wmsTask.S_CODE,
                            S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                            S_CODE = WCSHelper.GenerateTaskNo(),
                            S_TYPE = wmsTask.S_TYPE,
                            S_START_LOC = startLoc.S_CODE,
                            S_START_AREA = startLoc.S_AREA_CODE,
                            S_END_LOC = endLoc.S_CODE,
                            S_END_AREA = endLoc.S_AREA_CODE,
                            S_CNTR_CODE = model.coilNo,
                            S_SCHEDULE_TYPE = "HL",
                        };
                        if (WCSHelper.CreateTask(wcsTask))
                        {
                            // 开始货位、终点货位进行加锁
                            LocationHelper.LockLoc(startLoc.S_CODE, 2);
                            LocationHelper.LockLoc(endLoc.S_CODE, 1);

                            wmsTask.N_B_STATE = 1;
                            WMSHelper.UpdateTaskState(wmsTask);
                        }
                    }
                }
                else {
                    result.resultCode = 1;
                    result.resultMsg = "没有可入的钢卷货位";
                }
            }
            else
            {
                result.resultCode = 1;
                result.resultMsg = "未查询到钢卷信息";
            }
            return result;
        }

        /// <summary>
        /// 初始化模具
        /// </summary>
        /// <param name="model"></param>
        public static void initMould(mouldModel model) {
            var oldMouldCntr = MouldHelper.GetMouldCntrByCntr(model.trayCode);
            if (oldMouldCntr != null) 
            {
                MouldHelper.deleteMouldByCntr(model.trayCode);
            }

            MouldCntr mouldCntr = new MouldCntr()
            {
                S_ITEM_CODE = model.itemCode,
                S_CNTR_CODE = model.trayCode,
                S_MOULD_NO = model.mouldNo,
                S_MOULD_TYPE = model.mouldType,
                S_LOC_CODE = model.locCode,
                S_ABLE_FLAG = model.ableFlag
            };
            MouldHelper.addMould(mouldCntr);
            ContainerHelper.addCntr(mouldCntr.S_CNTR_CODE);

            List<MouldDetail> mouldDetails = new List<MouldDetail>();

            MouldDetail aMouldDetail = new MouldDetail()
            {
                S_MOULD_NO = model.mouldNo,
                S_NAME = "主片模块",
                N_INIT_QTY = model.aMouldNum,
                N_QTY = model.aMouldNum,
            };
            mouldDetails.Add(aMouldDetail);

            MouldDetail bMouldDetail = new MouldDetail()
            {
                S_MOULD_NO = model.mouldNo,
                S_NAME = "项号片模块",
                N_INIT_QTY = model.bMouldNum,
                N_QTY = model.bMouldNum,
            };
            mouldDetails.Add(bMouldDetail);

            MouldDetail cMouldDetail = new MouldDetail()
            {
                S_MOULD_NO = model.mouldNo,
                S_NAME = "冲头",
                N_INIT_QTY = model.cMouldNum,
                N_QTY = model.cMouldNum,
            };
            mouldDetails.Add(cMouldDetail);

            MouldHelper.batchAddChildMould(mouldDetails);
        }

        /// <summary>
        /// 初始化模具
        /// </summary>
        /// <param name="mouldNo"></param>
        /// <param name="aMouldNum">主片模块</param>
        /// <param name="bMouldNum">项号片模块</param>
        /// <param name="cMouldNum">冲头</param>
        public static void updateMouldNum(string mouldNo , int aMouldNum ,int bMouldNum ,int cMouldNum)
        {
            List<MouldDetail> mouldDetails = MouldHelper.GetMouldDetails(mouldNo);
            if (mouldDetails != null && mouldDetails.Count > 0) {
                foreach (var detail in mouldDetails)
                {
                    if (detail.S_NAME == "主片模块")
                    {
                        detail.N_QTY = aMouldNum;
                    }
                    if (detail.S_NAME == "项号片模块")
                    {
                        detail.N_QTY = bMouldNum;
                    }
                    if (detail.S_NAME == "冲头")
                    {
                        detail.N_QTY = cMouldNum;
                    }
                }
                MouldHelper.updateMouldNum(mouldDetails);
            }
        }

        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; }
        }
    }
}