using Common;
using DataBase;
using Model;
using Model.ApiModel;
using Model.WcsModel;
using Newtonsoft.Json;
using NLog;
using NPOI.SS.Formula;
using NPOI.SS.Formula.Functions;
using NPOI.SS.Formula.PTG;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlTypes;
using System.Reflection;
using System.Text;
using static ICSharpCode.SharpZipLib.Zip.ExtendedUnixData;

namespace BLL.DAL
{
    [Obsolete]
    public class DALWcsMessage
    {
        #region JC09
        /// <summary>
        /// 获取与PLC交互的所有IP地址
        /// </summary>
        /// <returns></returns>
        public DataTable GetPlcIps()
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select * from WCSIP where isDel = 0;");
                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 获取与设备交互信息
        /// </summary>
        /// <returns></returns>
        public DataTable GetPlcInfos()
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select tb1.*,tb2.IP from WCSPlcInfo as tb1 " +
                    $"left join WCSIP as tb2 on tb1.PlcIP = tb2.Id where tb1.isDel = 0; ");

                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 判断WCS是否自动模式 链接DB1
        /// </summary>
        /// <returns>true：自动模式 false：手动模式</returns>
        public bool GetIsWcsAutoDB1()
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select code from [dbo].[Dictionary] where TypeName = 'WCSAuto';");
                DataRow row = DataFactory.SqlDataBaseDB1().GetDataRowBySQL(sqlString);
                if (row != null)
                {
                    if (row["code"].ToString() == "0")
                    {
                        bl = true;
                    }
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }


        /// <summary>
        /// 判断WCS是否自动模式 链接db2
        /// </summary>
        /// <returns>true：自动模式 false：手动模式</returns>
        public bool GetIsWcsAutoDB2()
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select code from [dbo].[Dictionary] where TypeName = 'WCSAuto';");
                DataRow row = DataFactory.SqlDataBaseDB2().GetDataRowBySQL(sqlString);
                if (row != null)
                {
                    if (row["code"].ToString() == "0")
                    {
                        bl = true;
                    }
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 获取当前工位偏移量信息
        /// </summary>
        /// <param name="plcInfoId">工位Id</param>
        /// <returns></returns>
        public DataTable GetPlcPos(string plcInfoId)
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select * from WCSPlcPos where isDel = 0 and PlcInfoId = '{plcInfoId}';");

                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 调用WMS接口获取储位地址
        /// </summary>
        /// <param name="palletNo">托盘号</param>
        /// <param name="startLocat">起始工位</param>
        /// <param name="endLocat">目标工位号（取货工位）</param>
        /// <param name="taskNo">任务号</param>
        /// <returns>返回wms反馈的信息</returns>
        public string GetLocations(string palletNo, string startLocat, ref string endLocat, ref string taskNo)
        {
            Logger logger = LogManager.GetCurrentClassLogger();
            try
            {
                string returnStr = "";
                StringBuilder sqlString = new StringBuilder();
                // 先判断此托盘的任务是否已生成任务
                sqlString.Append("select * from WCSTasks where Status in ('0','1') and Type = '0' ");
                sqlString.Append($"and PalletNo = '{palletNo}' and isdel = '0';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt == null || dt.Rows.Count <= 0)
                {
                    LocatModel model = new LocatModel();
                    model.PalletNo = palletNo;
                    model.HouseNo = "W01";
                    model.RoadwayNo = "";
                    string json = JsonConvert.SerializeObject(model);
                    var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/RequestLocation", json);
                    logger.Error(palletNo + "申请储位:" + response);
                    Tasks taskModels = JsonConvert.DeserializeObject<Tasks>(response);
                    if (taskModels.Success == "0")
                    {
                        // 永远只返回一条信息，因为是集合所以用循环插入写法；
                        DALWMSApi dal = new DALWMSApi();
                        var task = taskModels.TaskList;
                        task.Type = "0";                                // 任务类型 0：入库任务 1出库任务 2 移库任务
                        task.Origin = "WMS";
                        task.StartLocate = startLocat;                   // 起始位置
                        WCSResultModel result = dal.AddWcsTask(task);
                        taskNo = taskModels.TaskList.TaskNo; //任务号
                        if (result.stateCode == "1")
                        {
                            //修改储位信息 任务类型 执行状态 起始位置 目标位置
                            EditLocaetStatus("0", "0", "", task.EndLocate);

                            endLocat = task.EndRoadway;
                            returnStr = task.EndLocate;//"托盘号:" + palletNo + "\n" + "储位地址:" + task.EndLocate + "\n";
                        }
                        else
                        {
                            returnStr = "-1:" + result.errMsg;
                            return returnStr;
                        }
                    }
                    else
                    {
                        returnStr = "-1:" + taskModels.Message;
                        return returnStr;
                    }
                }
                else
                {
                    returnStr = dt.Rows[0]["EndLocat"].ToString();
                    endLocat = dt.Rows[0]["EndRoadway"].ToString();
                    taskNo = dt.Rows[0]["TaskNo"].ToString();
                }

                // 确定取货工位
                switch (endLocat)
                {
                    case "R01":
                        endLocat = "10";
                        break;
                    case "R02":
                        endLocat = "6";
                        break;
                }

                //returnStr = endLocat;
                return returnStr;
            }
            catch (Exception ex)
            {
                logger.Error("程序错误:" + ex.Message);
                throw ex;
            }
        }

        /// <summary>
        /// WCS自申请储位
        /// </summary>
        /// <param name="palletNo">托盘号</param>
        /// <param name="startLocat">起始工位</param>
        /// <param name="endLocat">目标工位号（取货工位）</param>
        /// <param name="taskNo">任务号</param>
        /// <returns>返回wms反馈的信息</returns>
        public string GetWcsLocations(string palletNo, string startLocat, ref string endLocat, ref string taskNo)
        {
            Logger logger = LogManager.GetCurrentClassLogger();
            try
            {
                string returnStr = "";
                StringBuilder sqlString = new StringBuilder();
                // 先判断此托盘的任务是否已生成任务
                // 验证任务是否已存在
                sqlString.Append($"select * from WCSTasks where IsDel = '0' and (Status = '0' or Status = '1') and PalletNo = '{palletNo}';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt != null || dt.Rows.Count > 0)
                {
                    returnStr = "托盘" + palletNo + ";任务已存在!";
                    return returnStr;
                }
                if (dt == null || dt.Rows.Count <= 0)
                {
                    var response = GetLocateByRoadways(); //申请储位
                    logger.Error(palletNo + "申请储位:" + response);
                    // 永远只返回一条信息，因为是集合所以用循环插入写法；
                    DALWMSApi dal = new DALWMSApi();
                    WCSTasks task = new WCSTasks();
                    task.Type = "0";                                // 任务类型 0：入库任务 1出库任务 2 移库任务
                    task.Origin = "WCS";                            //来源
                    task.StartLocate = startLocat;                   // 起始位置
                    task.EndLocate = response.LocatNo;                   // 目标位置
                    task.EndRoadway = response.RoadwayNo;                   // 目标巷道
                    task.PalletNo = palletNo;                   // 托盘号
                    WCSResultModel result = dal.AddItsWcsTask(task);
                    if (result.stateCode == "1")
                    {
                        //修改储位信息 任务类型 执行状态 起始位置 目标位置
                        var IsUptLocate = EditLocaetStatus("0", "0", "", response.LocatNo);
                        if (IsUptLocate)
                        {
                            endLocat = response.RoadwayNo;
                            returnStr = response.LocatNo;
                        }
                        else
                        {
                            returnStr = "-1:" + "申请储位后任务储位修改失败";
                            return returnStr;
                        }
                    }
                    else
                    {
                        returnStr = "-1:" + result.errMsg;
                        return returnStr;
                    }
                }
                else
                {
                    returnStr = "-1:" + "申请储位失败";
                    return returnStr;
                }

                // 确定取货工位
                switch (endLocat)
                {
                    case "R01":
                        endLocat = "1";
                        break;
                    case "R02":
                        endLocat = "2";
                        break;
                    case "R03":
                        endLocat = "3";
                        break;
                    case "R04":
                        endLocat = "4";
                        break;
                    case "R05":
                        endLocat = "5";
                        break;
                    case "R06":
                        endLocat = "6";
                        break;
                    case "R07":
                        endLocat = "7";
                        break;
                }

                //returnStr = endLocat;
                return returnStr;
            }
            catch (Exception ex)
            {
                logger.Error("程序错误:" + ex.Message);
                throw ex;
            }
        }

        /// <summary>
        /// 插入任务明细表
        /// </summary>
        /// <param name="model">任务明细信息</param>
        public bool AddWCSTasksMonitor(WCSTasksMonitor model)
        {
            bool bl = false;
            StringBuilder sqlString = new StringBuilder();
            try
            {
                // 判断任务号是否位""
                if (model.TaskNo == "")
                {
                    // 根据托盘号获取对应的任务号
                    sqlString.Append($"select TaskNo from WCSTasks where Status = '1' and IsDel = '0' and PalletNo = '{model.PalletNo}';");
                    DataRow row = DataFactory.SqlDataBase().GetDataRowBySQL(sqlString);
                    if (row != null)
                    {
                        model.TaskNo = row["TaskNo"].ToString();
                    }
                }

                if (model.TaskNo == "")
                {
                    return bl;
                }

                // 插入任务明细表
                sqlString.Clear();
                sqlString.Append(@"INSERT INTO WCSTasksMonitor 
                 ( TaskNo , PlcId , PlcName , StartLocat , EndLocat , InteractiveMsg 
                , ErrorMsg,PalletNo,Status,IsDel ) VALUES (");
                sqlString.Append($"'{model.TaskNo}',{model.PlcId},'{model.PlcName}','{model.StartLocat}','{model.EndLocat}',");
                sqlString.Append($"'{model.InteractiveMsg}','{model.ErrorMsg}','{model.PalletNo}','{model.Status}','0');");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                }
            }
            catch (Exception ex)
            {
                // 记录日志文件
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "AddWCSTasksMonitor添加任务明细失败！");

                return bl;
            }

            return bl;
        }

        /// <summary>
        /// 更新任务状态
        /// </summary>
        /// <param name="TrayCode">托盘号</param>
        /// <param name="StateValue">任务状态  0: 等待执行 1: 正在执行 2: 执行完成 3: 异常结束 4: 任务取消</param>
        /// <returns>true:成功 flase:失败</returns>
        public bool SetWCSTasks(string palletNo, string StateValue, string EndLocatNo, string taskNo = "")
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"Update WCSTasks set FinishDate = '{DateTime.Now}', Status = '{StateValue}' ");
                //判断目标工位是否为空
                if (!string.IsNullOrEmpty(EndLocatNo))
                {
                    sqlString.Append($" ,EndLocat = '{EndLocatNo}'");
                }
                if (StateValue == "1")
                {
                    //任务状态为正在执行时修改为最高优先级
                    sqlString.Append($" ,Levels = '2'");
                }
                else if (StateValue == "2")
                {
                    //任务状态为执行完成时修改为正常优先级
                    sqlString.Append($" ,Levels = '2'");
                }
                sqlString.Append(" where Status not in ('3','2','4') ");
                if (!string.IsNullOrWhiteSpace(palletNo))
                {
                    sqlString.Append($" and PalletNo = '{palletNo}' ");

                }
                if (!string.IsNullOrWhiteSpace(taskNo))
                {
                    sqlString.Append($" and TaskNo = '{taskNo}' ");
                }
                else
                {
                    sqlString.Append(" ;");
                }


                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 获取任务信息
        /// </summary>
        /// <param name="status">0 等待执行 1 正在执行 2 执行完成 3 异常结束   4 任务取消</param>
        /// <param name="type">0 入库任务 1 出库任务  2 移库任务</param>
        /// <param name="palletNo">托盘号</param>
        /// <returns></returns>
        public DataTable GetWCSTasks(string status, string type, string palletNo = "", string startRoadway = "", string taskNo = "", string endRoadway = "")
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select top 1 * from WCSTasks ");
                sqlString.Append($"where Status = '{status}' and IsDel = '0' ");
                if (taskNo != "")
                {
                    sqlString.Append($" and TaskNo = '{taskNo}' ");
                }
                if (palletNo != "")
                {
                    sqlString.Append($" and palletNo = '{palletNo}' ");
                }
                if (startRoadway != "")
                {
                    sqlString.Append($" and startRoadway = '{startRoadway}' ");
                }
                if (endRoadway != "")
                {
                    sqlString.Append($" and endRoadway = '{endRoadway}' ");
                }
                if (type != "")
                {
                    sqlString.Append($" and Type = '{type}' ");
                }

                sqlString.Append(" order by  Levels,Status,StartLocat,CreateTime asc; ");
                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 获取储位任务信息
        /// </summary>
        /// <param name="startlocat">起始货位</param>
        /// <returns></returns>
        public DataTable GetLocateTasks(string startlocat = "",string endlocat = "")
        {
            StringBuilder sqlString = new StringBuilder();
            sqlString.Append("select top 1 * from WCSTasks ");
            sqlString.Append($"where  IsDel = '0'");
            if (startlocat != "")
            {
                sqlString.Append($" and StartLocat = '{startlocat}' ");
            }
            if (endlocat != "")
            {
                sqlString.Append($" and EndLocat = '{endlocat}' ");
            }
            sqlString.Append(" order by  Levels,Status,StartLocat,CreateTime asc; ");
            return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
        }

        /// <summary>
        /// 获取储位任务信息
        /// </summary>
        /// <param name="startlocat">起始货位</param>
        /// <returns></returns>
        public DataTable GetWCSDX(string skuno = "")
        {
            StringBuilder sqlString = new StringBuilder();
            sqlString.Append("select top 1 * from WCSMaterialRules where SkuNo = "+skuno);
            return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
        }

        /// <summary>
        /// 调用WMS接口反馈任务接口
        /// </summary>
        /// <param name="model">任务完成状态</param>
        /// <returns></returns>
        public bool RequestTasks(TaskReques model)
        {
            bool bl = false;
            Logger logger = LogManager.GetCurrentClassLogger();
            try
            {
                StringBuilder sqlString = new StringBuilder();
                string json = JsonConvert.SerializeObject(model);
                var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/ReceiveWcsSignal", json);
                logger.Error(model.taskNo + "任务反馈:" + response);

                //var response1 = JsonConvert.DeserializeObject(response);
                ResponseTasks taskModels = JsonConvert.DeserializeObject<ResponseTasks>(response);
                if (taskModels.StatusCode == "0")
                {

                    sqlString.Append($"Update WCSTasks set IsSuccess = '0' where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    bl = true;
                }
                else
                {
                    sqlString.Append($"Update WCSTasks set IsSuccess = '1',Information='{taskModels.Message}' where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    bl = false;
                }
            }
            catch (Exception ex)
            {
                logger.Error("程序错误:" + ex.Message);
            }

            return bl;
        }

        /// <summary>
        /// 调用WMS接口反馈任务满入异常接口
        /// </summary>
        /// <param name="model">任务信息</param>
        /// <returns></returns>
        public string RequestFullException(TaskReques model, string startLocat, ref string taskNo)
        {
            string returnStr = "";
            taskNo = ""; //任务号
            Logger logger = LogManager.GetCurrentClassLogger();
            try
            {
                StringBuilder sqlString = new StringBuilder();
                string json = JsonConvert.SerializeObject(model);
                var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/FullException", json);
                logger.Error(model.taskNo + "任务反馈:" + response);

                //var response1 = JsonConvert.DeserializeObject(response);
                Tasks taskModels = JsonConvert.DeserializeObject<Tasks>(response);
                if (taskModels.Success == "0")
                {
                    // 永远只返回一条信息，因为是集合所以用循环插入写法；
                    DALWMSApi dal = new DALWMSApi();
                    var task = taskModels.TaskList;
                    task.Type = "0";                                // 任务类型 0：入库任务 1出库任务 2 移库任务
                    task.Origin = "WMS";
                    task.StartLocate = startLocat;                   // 起始位置
                    WCSResultModel result = dal.AddWcsTask(task);

                    if (result.stateCode == "1")
                    {
                        taskNo = taskModels.TaskList.TaskNo; //任务号
                        returnStr = task.EndLocate;
                    }
                    else
                    {
                        returnStr = "-1:" + result.errMsg;
                    }
                    sqlString.Append($"Update WCSTasks set IsSuccess = '0',  where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                }
                else
                {
                    returnStr = "-1:" + taskModels.Message;
                    sqlString.Append($"Update WCSTasks set IsSuccess = '1', where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                }
            }
            catch (Exception ex)
            {
                returnStr = "-1程序错误:" + ex.Message;
                logger.Error(returnStr);
            }

            return returnStr;
        }

        /// <summary>
        /// 调用WMS接口反馈空取异常接口
        /// </summary>
        /// <param name="model">任务信息</param>
        /// <returns></returns>
        public bool RequestEmptyException(TaskReques model)
        {
            bool bl = false;
            Logger logger = LogManager.GetCurrentClassLogger();
            try
            {
                StringBuilder sqlString = new StringBuilder();
                string json = JsonConvert.SerializeObject(model);
                var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/EmptyException", json);
                logger.Error(model.taskNo + "任务反馈:" + response);

                //var response1 = JsonConvert.DeserializeObject(response);
                ResponseTasks taskModels = JsonConvert.DeserializeObject<ResponseTasks>(response);
                if (taskModels.Success == "0")
                {

                    sqlString.Append($"Update WCSTasks set IsSuccess = '0' where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    bl = true;
                }
                else
                {
                    sqlString.Append($"Update WCSTasks set IsSuccess = '1',Information='{taskModels.Message}' where TaskNo = '{model.taskNo}';");
                    DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    bl = false;
                }
            }
            catch (Exception ex)
            {
                logger.Error("-1程序错误:" + ex.Message);
            }

            return bl;
        }

        /// <summary>
        /// 向赋码系统获取箱码信息
        /// </summary>
        /// <param name="boxCode"></param>
        /// <returns></returns>
        public WcsBoxInfo GetBoxInfo(string boxCode)
        {
            try
            {
                //获取是否存在当前箱码信息
                StringBuilder sqlString = new StringBuilder();
                // 先判断此托盘的任务是否已生成任务
                sqlString.Append($"select * from WcsBoxInfo where IsDel = '0' and BoxNo = '{boxCode}' ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);

                if (dt == null || dt.Rows.Count == 0)
                {
                    //调用赋码系统
                    var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/RequestLocation", boxCode);
                    WcsBoxInfo boxInfo = JsonConvert.DeserializeObject<WcsBoxInfo>(response);

                    //添加箱码信息
                    sqlString.Clear();
                    sqlString.Append("insert into WcsBoxInfo (OrderCode,Line_No,LineDao,PORT,BoxNo,BoxNo2,BoxNo3,PalletNo,Qty,FullQty,Aflag,Status,SkuNo,SkuName,LotNo,LotText,Custom,CustomName,ProductionTime,ExpirationTime,CompleteTime,InspectMark,BitBoxMark,Standard,PackageStandard,StoreTime,QtyCount,QtyOrd,Opuser,IsDel,CreateTime,CreateUser,UpdateTime,UpdateUser)");
                    sqlString.Append($"Values ('{boxInfo.OrderCode}','{boxInfo.Line_No}','{boxInfo.LineDao}','{boxInfo.PORT}','{boxInfo.BoxNo}','{boxInfo.BoxNo2}','{boxInfo.BoxNo3}','','{boxInfo.Qty}','{boxInfo.FullQty}','{boxInfo.Aflag}','{boxInfo.Status}','{boxInfo.SkuNo}','{boxInfo.SkuName}','{boxInfo.LotNo}','{boxInfo.LotText}','{boxInfo.Custom}','{boxInfo.CustomName}','{boxInfo.ProductionTime}','{boxInfo.ExpirationTime}','{boxInfo.CompleteTime}','{boxInfo.InspectMark}','{boxInfo.BitBoxMark}','{boxInfo.Standard}','{boxInfo.PackageStandard}','{boxInfo.StoreTime}','{boxInfo.QtyCount}','{boxInfo.QtyOrd}','{boxInfo.Opuser}','0',getdate(),null,null,null)");
                    int isAdd = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    if (isAdd == 1)
                    {
                        return boxInfo;
                    }
                    else
                    {
                        return null;
                    }


                }
                else
                {
                    return null;
                }
            }
            catch (Exception ex)
            {

                throw ex;
            }
        }

        /// <summary>
        /// 变更储位(需要的值 任务类型 状态 (入库与PLC:目标位置、出库:起始位置、移库两个都需要)
        /// </summary>
        /// <param name="type">任务类型 0:入库 1:出库 2:移库 3:PLC申请</param>
        /// <param name="status">执行状态 0 等待执行 1 正在执行 2 执行完成 3 异常结束 4 任务取消</param>
        /// <param name="startLocat">起始位置</param>
        /// <param name="endLocat">目标位置</param>
        /// <returns></returns>
        public bool EditLocaetStatus(string type, string status, string startLocat, string endLocat)
        {
            try
            {
                bool isTrue = false;
                int upt = 0;
                StringBuilder sqlString = new StringBuilder();
                #region 赋值状态

                string start = ""; //起始储位状态
                string end = ""; //目标储位状态
                string qita = ""; //用于WMS
                //修改的状态 0:空储位 1:有物品 2:入库中 3:出库中 4:移入中 5:移除中
                //任务类型 0入 1出 2移 3 PLC申请
                switch (type)
                {
                    case "0"://入库
                    case "3"://PLC入库
                        //任务状态
                        switch (status)
                        {
                            case "0": //等待执行
                            case "1": //正在执行
                                end = "2"; //目标储位状态 //入库中
                                break;
                            case "2": //执行完成
                                end = "1"; //目标储位状态 //有物品
                                break;
                            case "3": //异常结束
                                //不变
                                break;
                            case "4": //取消
                                end = "0"; //目标储位状态 //空储位
                                break;
                            default: //其它
                                break;
                        }

                        break;
                    case "1": //出库
                        //任务状态
                        switch (status)
                        {
                            case "0": //等待执行
                            case "1": //正在执行
                                start = "3"; //起始储位状态 出库中
                                break;
                            case "2": //执行完成
                                start = "0"; //起始储位状态 空储位
                                break;
                            case "3": //异常结束
                                //不变
                                break;
                            case "4": //取消
                                start = "1"; //起始储位状态 有物品
                                break;
                            default: //其它
                                break;
                        }

                        break;
                    case "2": //移库
                        //任务状态
                        switch (status)
                        {
                            case "0": //等待执行
                            case "1": //正在执行
                                end = "4"; //目标储位状态 移入中
                                start = "5"; //起始储位状态 移出中
                                break;
                            case "2": //执行完成
                                end = "1"; //目标储位状态 有物品
                                start = "0"; //起始储位状态 空储位
                                break;
                            case "3": //异常结束
                                //不变
                                break;
                            case "4": //取消
                                end = "0"; //目标储位状态 空储位
                                start = "1"; //起始储位状态 有物品
                                break;
                            default: //其它
                                break;
                        }

                        break;
                    default:

                        break;
                }

                #endregion
                //验证起始状态或目标状态不为空
                if (!string.IsNullOrEmpty(end))
                {
                    sqlString.Append($"update WCSStorageLocat set Status = '{end}' where LocatNo = '{endLocat}';");
                }
                if (!string.IsNullOrEmpty(start))
                {
                    sqlString.Append($"update WCSStorageLocat set Status = '{start}' where LocatNo = '{startLocat}';");
                }
                if (!string.IsNullOrEmpty(end) || !string.IsNullOrEmpty(start))
                {
                    upt = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                }

                if (upt >= 1)
                {
                    isTrue = true;
                }
                return isTrue;
            }
            catch (Exception ex)
            {

                throw ex;
            }
        }
        #endregion

        #region 申请储位

        //申请储位（包含组托的信息）
        public WCSStorageLocat RequestLocation()
        {
            try
            {
                #region

                try
                {
                    WCSStorageLocat locate = new WCSStorageLocat();
                    locate = GetLocateByRoadways();

                    return locate;
                }
                catch (Exception ex)
                {
                    throw new Exception(ex.Message);
                }
                #endregion

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 申请储位（包含组托的信息）
        /// <returns></returns>
        private WCSStorageLocat GetLocateByRoadways()
        {
            try
            {
                #region 入库分配规则
                StringBuilder sqlString = new StringBuilder();
                WCSStorageLocat locate = new WCSStorageLocat();
                //string txt = !string.IsNullOrEmpty(roadway) ? $" and RoadwayNo = '{roadway}'" : "";
                sqlString.Append("select RoadwayNo from WCSStorageLocat where IsDel = '0' and WareHouseNo = 'W01' group by RoadwayNo order by RoadwayNo");

                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);

                if (dt == null || dt.Rows.Count == 0)
                {
                    return null;
                }
                else
                {
                    for (int i = 0; i < dt.Rows.Count; i++)
                    {
                        locate = GetLocateByRoadway(dt.Rows[i]["RoadwayNo"].ToString());
                        if (locate != null)
                        {
                            break;
                        }
                    }
                }

                #endregion

                return locate;
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 取当前巷最优位置
        /// </summary>
        /// <param name="roadwayNo">巷道号</param>
        /// <returns></returns>
        private WCSStorageLocat GetLocateByRoadway(string roadwayNo)
        {
            var str = "''";
            StringBuilder sqlString = new StringBuilder();
            //查询该巷道并且标志为正常的的储位
            do
            {
                sqlString.Clear();
                //var sql = $"select * from WCSStorageLocat where IsDel = 0 and Flag = 0 and [Status] = 0 and RoadwayNo = '{roadwayNo}' and LocatNo not in({str}) ";
                //sql += "order by ";
                //sql += "Row , Depth desc, ";
                sqlString.Append($"select * from WCSStorageLocat where IsDel = 0 and Flag = 0 and [Status] = 0 and RoadwayNo = '{roadwayNo}' and LocatNo not in({str}) order by Row , Depth desc");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                List<WCSStorageLocat> list = (List<WCSStorageLocat>)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
                if (dt != null || dt.Rows.Count >= 1)
                {
                    foreach (var item in list)
                    {
                        var isOk = LocateIsOk(item);
                        if (isOk)
                        {
                            return item;
                        }
                        else
                        {
                            if (str.Length > 0)
                            {
                                str += ",";
                            }
                            str += $"'{item.LocatNo}'";
                        }
                    }
                }
                else
                {
                    return null;
                }

            } while (true);
        }


        public bool LocateIsOk(WCSStorageLocat model)
        {

            if (model.Depth == "01")
            {
                return true;
            }
            else
            {
                //获取深度为1的储位信息
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select top 1 * from WCSStorageLocat where IsDel = '0' and [Row] = {model.Row} and [Column] = {model.Column} and Layer = {model.Layer} and Depth = '01' ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //var locate = db.Queryable<WCSStorageLocat>().First(m => m.IsDel == "0" && m.LocateGroup == model.LocateGroup && m.Depth == "01");
                if (dt == null || dt.Rows.Count == 0)
                {
                    return false;
                }
                else
                {
                    //前面储位状态为空且不能是损坏状态的
                    if (dt.Rows[0]["Status"].ToString() == "0" && dt.Rows[0]["Flag"].ToString() != "2")
                    {
                        return true;
                    }
                    else
                    {
                        return false;
                    }
                }
            }
        }

        #endregion



        #region 标准版数据交互



        /// <summary>
        /// 根据托盘号获取组盘信息
        /// </summary>
        /// <param name="palletNo"></param>
        /// <returns></returns>
        public DataRow GetWcsPalletBind(string palletNo)
        {
            try
            {
                //select Top 1 * from WCSPalletBind where PalletNo = 'T2300017'
                StringBuilder sqlString = new StringBuilder();
                sqlString.Clear();
                sqlString.Append("select Top 1 * from WCSPalletBind ");
                sqlString.Append($" where palletNo = '{palletNo}' ");
                sqlString.Append(" order by  CreateTime desc ");
                DataRow aa = DataFactory.SqlDataBase().GetDataRowBySQL(sqlString);
                return aa;
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }
            return null;
        }

        /// <summary>
        /// 获取空托盘任务信息
        /// </summary>
        /// <param name="status">0 等待执行 1 正在执行 2 执行完成 3 异常结束   4 任务取消</param>
        /// <param name="type">0 入库任务 1 出库任务  2 移库任务</param>
        /// <param name="lotNo">批次号</param>
        /// <returns></returns>
        public DataTable GetWCSSupallTasks(string status, string type, string lotNo = "")
        {
            bool bl = false;
            try
            {
                //获取空托盘入库任务
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select top 1 * from WCSTasks ");
                sqlString.Append($"where Status = '{status}' and IsDel = '0' ");
                if (lotNo != "")
                {
                    sqlString.Append($" and LotNo = '{lotNo}' ");
                }
                if (type != "")
                {
                    sqlString.Append($" and Type = '{type}' ");
                }

                sqlString.Append(" and StartRoadway != '' order by  Levels desc,CreateTime asc; ");
                var taskList = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //获取数据后清空sqlString
                sqlString.Clear();
                //修改空托盘入库任务改为出库任务
                sqlString.Append($"Update WCSTasks set Type);");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                    return taskList;
                }
                return null;

            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 获取指定入口货物信息
        /// </summary>
        /// <param name="conveyor">入库口</param>
        /// <returns></returns>
        public DataTable GetWCSConveyorInfo(string conveyor = "")
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select * from WCSConveyorInfo ");
                sqlString.Append("where Status = '1' and IsDel = '0' and isEndLot = '0' ");
                if (!string.IsNullOrWhiteSpace(conveyor))
                {
                    sqlString.Append($" and Conveyor = '{conveyor}';");
                }

                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <summary>
        /// 存储托盘组托信息
        /// </summary>
        /// <param name="model">组托信息</param>
        /// <returns>true:成功  false:失败</returns>
        public bool AddWCSPalletBind(WCSPalletBind model)
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append(@"INSERT INTO WCSPalletBind 
                 ( LocatNo , PalletNo , SkuQty , SkuWeight , Status , ErrorMsg 
                , TaskType , SkuType , SubPallet , LotNo  , LotText , SupplierLot , IsBale ,
		         IsBelt  ) VALUES (");
                sqlString.Append($"'{model.LocatNo}','{model.PalletNo}','{model.SkuQty}','{model.SkuWeight}','{model.Status}',");
                sqlString.Append($"'{model.ErrorMsg}','{model.TaskType}','{model.SkuType}','{model.SubPallet}','{model.LotNo}',");
                sqlString.Append($"'{model.LotText}','{model.SupplierLot}','{model.IsBale}','{model.IsBelt}');");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                }
            }
            catch (Exception ex)
            {
                // 记录日志文件
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "SetWCSPalletBind存储组盘信息失败");

                return bl;

            }

            return bl;
        }

        /// <summary>
        /// 调用WMS接口获取储位地址
        /// </summary>
        /// <param name="PalletNo">托盘号</param>
        /// <param name="model">组盘信息</param>
        /// <param name="endLocat">目标工位号（取货工位）</param>
        /// <returns>返回wms反馈的信息</returns>
        public string GetLocation(string palletNo, WCSPalletBind model, ref string endLocat)
        {
            try
            {
                string returnStr = "";
                StringBuilder sqlString = new StringBuilder();
                // 先判断此托盘的任务是否已生成任务
                sqlString.Append("select * from WCSTasks where Status in ('0','1') and Type = '0' ");
                sqlString.Append($"and PalletNo = '{palletNo}' and isdel = '0';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt == null || dt.Rows.Count <= 0)
                {
                    string json = JsonConvert.SerializeObject(model);
                    var response = Utility.Extra.HttpHelper.DoPost("http://192.168.220.130:8081/api/DownAPi/RequestLocation", json);
                    ResponseTasks taskModels = JsonConvert.DeserializeObject<ResponseTasks>(response);
                    //Logger logger = LogManager.GetCurrentClassLogger();
                    //logger.Error("申请储位原因：", response);
                    if (taskModels.Success == "0")
                    {
                        // 永远只返回一条信息，因为是集合所以用循环插入写法；
                        DALWMSApi dal = new DALWMSApi();
                        WCSTasks task = taskModels.TaskList;

                        // 添加任务信息
                        task.StartLocate = model.StationNum;
                        task.LotNo = model.LotNo;
                        task.SupplierLot = model.SupplierLot;
                        task.PalletType = model.SubPallet == "0" ? "0" : "1";
                        WCSResultModel result = dal.AddWcsTask(task);
                        if (result.stateCode == "1")
                        {
                            endLocat = task.EndRoadway;
                            returnStr = "托盘号:" + palletNo + "\n" + "储位地址:" + task.EndLocate + "\n";
                            // 插入组托信息
                            this.AddWCSPalletBind(model);

                            // 插入任务明细表
                            WCSTasksMonitor tasksMonitor = new WCSTasksMonitor();
                            tasksMonitor.TaskNo = task.TaskNo;
                            tasksMonitor.PlcId = int.Parse(model.PlcId);
                            tasksMonitor.PlcName = model.StationNum;
                            tasksMonitor.StartLocat = model.StationNum;
                            tasksMonitor.InteractiveMsg = "向WMS申请储位信息成功";
                            tasksMonitor.PalletNo = palletNo;
                            tasksMonitor.EndLocat = task.EndLocate;
                            tasksMonitor.Status = "2";              // 执行完成
                            this.AddWCSTasksMonitor(tasksMonitor);
                        }
                        else
                        {
                            returnStr = "-1:" + result.errMsg;
                            return returnStr;
                        }

                    }
                    else
                    {
                        returnStr = "-1:" + taskModels.Message;
                        return returnStr;
                    }
                }
                else
                {
                    endLocat = dt.Rows[0]["EndRoadway"].ToString();
                }

                // 确定取货工位
                switch (endLocat)
                {
                    case "R11":
                        endLocat = "2";
                        break;
                    case "R12":
                        endLocat = "6";
                        break;
                    case "R13":
                        endLocat = "10";
                        break;
                }

                // 记录日志文件
                returnStr = endLocat;
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(returnStr, "申请储位");

                return returnStr;
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "程序异常：申请储位失败!");
                throw ex;
            }
        }

        /// <summary>
        /// 调用WMS接口申请空托盘垛
        /// </summary>
        /// <param name="skuNo">物料号</param>
        /// <param name="endLocat">送货工位号</param>
        /// <returns></returns>
        public string GetSupperPalletLocation(string skuNo = "", string endLocat = "")
        {
            try
            {
                return "";
                //string returnStr = "";
                //StringBuilder sqlString = new StringBuilder();
                //sqlString.Clear();
                //string json = JsonConvert.SerializeObject(skuNo);
                //var response = Utility.Extra.HttpHelper.DoPost("http://192.168.220.130:8081/api/DownAPi/PalletLocation", json);
                ////var response = Utility.Extra.HttpHelper.DoPost("http://localhost:13243/api/DownAPi/PalletLocation", json);
                //var taskModels = JsonConvert.DeserializeObject<Tasks>(response);


                //if (taskModels.Success == "0")
                //{
                //    if (taskModels.Message == "任务已申请！")
                //    {
                //        return null;
                //    }
                //    // 永远只返回一条信息，因为是集合所以用循环插入写法；
                //    DALWMSApi dal = new DALWMSApi();
                //    foreach (var item in taskModels.TaskList)
                //    {
                //        WCSTasks task = item;
                //        //根据托盘号获取

                //        // 添加任务信息
                //        task.EndLocat = item.EndLocat != "" ? item.EndLocat : skuNo == "100099" ? "41" : skuNo == "100098" ? "23" : "33";
                //        task.LotNo = "";
                //        task.SupplierLot = "";
                //        task.PalletType = "";
                //        WCSResultModel result = dal.AddWcsTask(task);
                //        if (result.stateCode == "1")
                //        {
                //            endLocat = task.EndRoadway;
                //            returnStr = "托盘号:" + task.PalletNo + "\n" + "储位地址:" + task.StartLocat + "\n";

                //            // 插入任务明细表
                //            WCSTasksMonitor tasksMonitor = new WCSTasksMonitor();
                //            tasksMonitor.TaskNo = task.TaskNo;
                //            tasksMonitor.PlcId = 0;
                //            tasksMonitor.PlcName = "";
                //            tasksMonitor.StartLocat = task.StartLocat;
                //            tasksMonitor.InteractiveMsg = "向WMS申请空托盘信息成功";
                //            tasksMonitor.PalletNo = task.PalletNo;
                //            tasksMonitor.EndLocat = task.EndLocat;
                //            tasksMonitor.Status = "2";              // 执行完成
                //            this.AddWCSTasksMonitor(tasksMonitor);
                //        }
                //        else
                //        {
                //            returnStr = "-1:" + result.errMsg;
                //            return returnStr;
                //        }

                //        // 确定取货工位
                //        switch (task.StartRoadway)
                //        {
                //            case "R11":
                //                endLocat = "3";
                //                break;
                //            case "R12":
                //                endLocat = "4";
                //                break;
                //            case "R13":
                //                endLocat = "11";
                //                break;
                //        }

                //        // 记录日志文件
                //        returnStr += "目标位置:" + endLocat + "\n";
                //        Logger logger = LogManager.GetCurrentClassLogger();
                //        logger.Error(returnStr, "申请空托盘");


                //    }

                //    return returnStr;


                //}
                //else
                //{
                //    returnStr = "-1:" + taskModels.Message;
                //    return returnStr;
                //}

            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "程序异常：申请空托盘失败!");
                throw ex;
            }
        }

        /// <summary>
        /// 获取报警基础信息
        /// </summary>
        /// <returns>报警信息基础表</returns>
        public DataTable GetWcsAlarmInfo()
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select * from WCSAlarmInfo order by PlcIP;");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                return dt;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }






        #endregion

        #region 07版本，标准版弄好后删除


        /// <summary>
        /// 获取未完成的任务自动
        /// </summary>
        /// <param name="state">任务状态0:未下发 1:已下发 3:已完成</param>
        /// <returns>任务信息</returns>
        public DataTable GetWmsTasks(string state, string taskType, string Palno = "")
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select top 1 * from TaskMonitor ");
                sqlString.Append("where State = '" + state + "' and Source = 'WMS' and IsDel = '0' ");
                if (Palno != "")
                {
                    sqlString.Append(" and Palno = '" + Palno + "' ");
                }
                sqlString.Append(" and taskType = '" + taskType + "' ");
                sqlString.Append(" order by  PriorityLevel desc,CreateTime asc; ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt == null || dt.Rows.Count == 0)
                {
                    return null;
                }

                return dt;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据出入库口获取正在执行的出入库任务
        /// </summary>
        /// <param name="InitialAddre">通道口</param>
        /// <param name="taskType">in：入库  out:出库</param>
        /// <returns>true:不存在任务  false：存在任务</returns>
        public bool GetTasks(string InitialAddre, string taskType)
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select * from TaskMonitor ");
                sqlString.Append("where State = '1' and Source = 'WMS' and IsDel = '0' ");
                sqlString.Append("and taskType = '" + taskType + "' and InitialAddre = '" + InitialAddre + "' ");
                sqlString.Append("order by  PriorityLevel desc,CreateTime asc; ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt == null || dt.Rows.Count == 0)
                {
                    bl = true;
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 创建任务
        /// </summary>
        /// <param name="taskModel">任务表实体类</param>
        public int SetTaskMonitor(TaskMonitorDto taskModel)
        {
            try
            {
                int isSucceed = 0;
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append(@"INSERT INTO TaskMonitor(TaskNo,TaskType,InitialAddre
, Palno, TargetAddre, State, IsSucceed, ErrorStr, PriorityLevel, Source
, Demo, CreateTime, IsDel) values ('");
                sqlString.Append(taskModel.TaskNo + "','" + taskModel.TaskType + "','" + taskModel.InitialAddre + "','");
                sqlString.Append(taskModel.Palno + "','" + taskModel.TargetAddre + "',0,'0','0','0','WMS','',GETDATE(),'0')");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    return isSucceed;
                }
                else
                {
                    return -1;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 更新任务状态
        /// </summary>
        /// <param name="TrayCode">托盘号</param>
        /// <param name="StateValue">任务状态</param>
        /// <returns>true:成功 flase:失败</returns>
        public bool SetWmsTasks(string TrayCode, string StateValue)
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("Update TaskMonitor set State = '" + StateValue + "' where Palno = '" + TrayCode + "' and State != '3';");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 获取报警基础信息
        /// </summary>
        /// <returns>报警信息基础表</returns>
        public DataTable GetErrorInfor()
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select * from [CS_AlarmInfo] order by M;");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                return dt;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 向报警表写入错误信息
        /// </summary>
        public void SetErrorMessage(string errorType, string errorCode, string messageStr)
        {
            try
            {
                // State: 0=未处理  1=已处理
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("insert into CS_Alarm (Name,ErrorCode,AlarmName,State) ");
                sqlString.Append("VALUES ('" + errorType + "','" + errorCode + "','" + messageStr + "','0');");
                DataFactory.SqlDataBase().ExecuteBySql(sqlString);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 判断当前报警信息是否已存在
        /// </summary>
        /// <param name="errorCode">MB点位</param>
        /// <returns>false:不存在  true：已存在</returns>
        public bool GetErrorMessage(string errorCode)
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select count(*) from CS_Alarm where errorCode = '" + errorCode + "';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt.Rows[0][0].ToString() != "0")
                {
                    bl = true;
                }

                return bl;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 删除跺机和运输线所有报警信息
        /// </summary>
        public void DelErrorMessage()
        {
            try
            {
                // State: 0=未处理  1=已处理
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("delete from CS_Alarm;");
                DataFactory.SqlDataBase().ExecuteBySql(sqlString);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 通知wms任务完成
        /// </summary>
        /// <param name="palNo">托盘号</param>
        /// <param name="locationCode">储位地址</param>
        /// <param name="taskType">任务类型 1 入库任务 2：出库任务</param>
        public void WcsinWms(string palNo, string locationCode, string taskType)
        {
            try
            {
                string returnStr = "";
                DALWMSApi api = new DALWMSApi();
                var LocationModel = new ApiLocationModel();
                if (taskType == "1")
                {
                    // 入库完成
                    LocationModel = api.PutStorage(palNo, locationCode);
                }
                else
                {
                    // 出库完成
                    LocationModel = api.OutStorage(palNo, locationCode);
                }

                if (LocationModel.Code == "01")
                {
                    returnStr = "托盘号:'" + palNo + "'任务完成";
                }
                else
                {
                    this.SetErrorMessage(LocationModel.OutMode, LocationModel.Code, palNo + "任务失败！");
                    returnStr = "托盘号:'" + palNo + "'任务失败";
                    //switch (LocationModel.Code)
                    //{
                    //    case "-11": returnStr = palNo + ":-11参数错误!"; break;
                    //    case "-101": returnStr = palNo + ":-101无组盘信息!"; break;
                    //    case "-102": returnStr = palNo + ":-102非仓库托盘"; break;
                    //    default: break;
                    //}
                }


            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 调用WMS接口获取储位地址
        /// </summary>
        /// <param name="Palno">托盘号</param>
        /// <returns>返回wms反馈的信息</returns>
        public string GetLocation(string palNo, string height, string inPort)
        {
            try
            {
                string returnStr = "";
                // 向WMS申请储位
                LocationInfo location = new LocationInfo();
                location.palNo = palNo;
                location.height = int.Parse(height);
                string json = JsonConvert.SerializeObject(location);
                DALWMSApi api = new DALWMSApi();
                var LocationModel = api.GetLocation(palNo, int.Parse(height));
                // Liudl 2022-12-31 Edit 接口调用改为程序内部调用
                //var response = Utility.Extra.HttpHelper.DoPost("192.168.1.35:57061/api/WMSApi/getLocation", json);
                //ApiLocationModel LocationModel = JsonConvert.DeserializeObject<ApiLocationModel>(response);
                // 判断储位是否申请成功   01:成功  -11:参数错误 -101:没有组盘信息 -102：没有此托盘
                if (LocationModel.Code == "01")
                {
                    // 生成入库任务，插入任务表
                    TaskMonitorDto taskModel = new TaskMonitorDto();
                    taskModel.TaskNo = "in";
                    taskModel.TaskType = "in";
                    taskModel.InitialAddre = inPort;
                    taskModel.Palno = palNo;
                    taskModel.TargetAddre = LocationModel.LocationCode;
                    taskModel.State = "0";
                    taskModel.IsSucceed = LocationModel.Code;
                    taskModel.ErrorStr = LocationModel.OutMode;
                    taskModel.PriorityLevel = 0;
                    taskModel.Source = "WMS";
                    taskModel.IsDel = 0;

                    this.SetTaskMonitor(taskModel);

                    returnStr = "托盘号:'" + palNo + "'申请储位成功，储位地址为:'" + LocationModel.LocationCode + "'";
                }
                else
                {
                    // 向led屏幕插入信息 Liudl 未完成
                    // 插入报警信息
                    this.SetErrorMessage(LocationModel.OutMode, LocationModel.Code, palNo + "申请储位地址失败！");
                    switch (LocationModel.Code)
                    {
                        case "-11": returnStr = palNo + ":-S11参数错误!"; break;
                        case "-101": returnStr = palNo + ":-S101无组盘信息!"; break;
                        case "-102": returnStr = palNo + ":-S102非仓库托盘"; break;
                        default: break;
                    }
                }

                // 记录日志文件
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(returnStr, "申请储位");

                return returnStr;
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "程序异常：申请储位失败!");
                throw ex;
            }
        }

        /// <summary>
        /// 判断此托盘是否已分配任务
        /// </summary>
        /// <param name="palNo">托盘号</param>
        /// <returns></returns>
        public string IsTaskMonitor(string palNo)
        {
            string Location = "";
            try
            {
                StringBuilder strSQL = new StringBuilder();
                strSQL.Append($"select TargetAddre from TaskMonitor where Palno ='{palNo}' and TaskType = 'in' and IsDel = '0' and State <> '3';");
                DataTable dtI = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                if (dtI != null && dtI.Rows.Count > 0)
                {
                    Location = "托盘号:'" + palNo + "'申请储位成功，储位地址为:'" + dtI.Rows[0]["TargetAddre"] + "'";
                }

                return Location;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion


        #region 分拣方法
        /// <summary>
        /// 查询任务是否绑定并获取分道
        /// </summary>
        /// <param name="barcode">条码信息</param>
        /// <returns></returns>
        public string GetBarcodeAndRoute(string barcode)
        {
            StringBuilder sqlString = new StringBuilder();
            try
            {
                sqlString.Append($"select * from WCSBoxInfo where BoxNo = '{barcode}' ;");
                DataRow row = DataFactory.SqlDataBase().GetDataRowBySQL(sqlString);
                //已获取箱支关系
                if (row != null)
                {
                    sqlString.Clear();
                    DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                    var SkuNo = dt2.Rows[0]["SkuNo"].ToString();
                    var LotNo = dt2.Rows[0]["LotNo"].ToString();
                    var SkuName = dt2.Rows[0]["SkuName"].ToString();
                    var EndLotFlag = dt2.Rows[0]["EndLotFlag"].ToString(); //结批标识0:未结批，1：已结批
                    //更改分拣任务状态为预结批
                    if (EndLotFlag == "1")
                    {
                        sqlString.Clear();
                        sqlString.Append($"update WCSPickLinoBind set IDState = '2' where SkuNo = '{SkuNo}' and LotNo = '{LotNo}';");
                        int count = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                        if (count == 0)
                        {
                            return "4";
                        }
                    }

                    sqlString.Append($"select * from WCSPickLinoBind where SkuNo = '{SkuNo}' and LotNo = '{LotNo}' and IDState = '1' ;");
                    int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    //箱码已绑定
                    if (rowCount >= 1)
                    {
                        //下发分道信息（预留：在同一种物料绑定多个通道时，通过随机数，随机分配物料已绑定的道号）
                        //PS:需要和PLC确定访问方式，分配完成后是否需要清空扫码仪缓存位，如果不清空，则需要在
                        //WcsBoxInfo表中添加“已分配状态”，用来控制每次的分道号和上次分配的是一样的
                        DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                        int[] array = new int[rowCount];

                        for (int j = 0; j < rowCount; j++)
                        {
                            array[j] = int.Parse(dt.Rows[j]["LineDao"].ToString());
                        }
                        Random random = new Random();
                        int randomIndex = random.Next(0, array.Length);
                        int randomElement = array[randomIndex];
                        Console.WriteLine("随机取出的分道为: " + randomElement);

                        //给PLC下发道号码垛规则等信息
                        string lineDao = randomElement.ToString();
                        PickLinoBind LineInfo = new PickLinoBind();
                        LineInfo.Chang = dt.Rows[randomElement]["Chang"].ToString();
                        LineInfo.Kuan = dt.Rows[randomElement]["Kuan"].ToString();
                        LineInfo.Gao = dt.Rows[randomElement]["Gao"].ToString();
                        //通过PLC提供的地址写入
                        //写入………


                        return "0";
                    }
                    //箱码未绑定
                    else
                    {
                        //自动绑定分道,并下发给PLC道号
                        sqlString.Clear();
                        sqlString.Append($"select * from WCSPickLino where PickType = 0 and Picked < '4' and IDState =0 ;");
                        rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                        if (rowCount >= 1)//有可分配的码垛工位
                        {

                            //获取码垛规则
                            StringBuilder skuSql = new StringBuilder();
                            skuSql.Append($"select * from WCSMaterialRules where SkuNo = '{SkuNo}'  and IsDel = '0' ;");
                            DataTable sku = DataFactory.SqlDataBase().GetDataTableBySQL(skuSql);
                            if (sku == null || sku.Rows.Count == 0)
                            {
                                return "1";//未获取到该品种码垛规则，需要人工维护
                            }

                            //创建到PickLindBind表该物料的绑定任务
                            DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                            //查找可用道号
                            int[] array = { 1, 2, 3, 4 };
                            StringBuilder LineDao = new StringBuilder();
                            LineDao.Append($"select * from WCSPickLinoBind where " +
                                $"PickLinoID = {int.Parse(dt.Rows[0]["ID"].ToString())} and LineDao = {""}");
                            DataTable dt1 = DataFactory.SqlDataBase().GetDataTableBySQL(skuSql);

                            PickLinoBind locat = new PickLinoBind()
                            {
                                PickLinoID = int.Parse(dt.Rows[0]["ID"].ToString()),
                                TaskNo = "固定值，测试",
                                Type = "固定值，测试",
                                LotNo = LotNo,
                                SkuNo = SkuNo,
                                SkuName = SkuName,
                                Chang = sku.Rows[0]["Chang"].ToString(),//……需要修改通过物料
                                Kuan = sku.Rows[0]["Kuan"].ToString(),
                                Gao = sku.Rows[0]["Gao"].ToString(),
                                AddTime = DateTime.Parse(DateTime.Now.ToString()),
                                IDState = "1",
                                LineDao = dt1.Rows[0]["LineDao"].ToString(),
                                Level = "1",
                            };
                            //将locat insert到pickLinoBind中
                            // 插入任务明细表
                            sqlString.Clear();
                            sqlString.Append(@"INSERT INTO WCSPickLinoBind 
                                            ( PickLinoID , TaskNo , Type , LotNo , SkuNo , SkuName 
                                            , Chang,Kuan,Gao,AddTime,IDState,LineDao,Level) VALUES (");
                            sqlString.Append($"{locat.PickLinoID},{locat.TaskNo},'{locat.Type}','{locat.LotNo}','{locat.SkuNo}',");
                            sqlString.Append($"'{locat.SkuName}','{locat.Chang}','{locat.Kuan}','{locat.Gao}',{locat.AddTime},");
                            sqlString.Append($"'1','{locat.LineDao}','1');");
                            rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                            if (rowCount > 0)
                            {
                                //给PLC下发道号码垛规则等信息
                                string lineDao = locat.LineDao;
                                PickLinoBind LineInfo = new PickLinoBind();
                                LineInfo.Chang = locat.Chang;
                                LineInfo.Kuan = locat.Kuan;
                                LineInfo.Gao = locat.Gao;
                                //通过PLC提供的地址写入
                                //写入………

                                return "0";
                            }
                            else
                            {
                                return "3";
                            }

                        }
                        else//码垛工位已满，不分配
                        {
                            return "2";
                        }
                    }
                }
                //未获取箱支关系
                else
                {
                    //未获取到箱码信息，调用赋码系统接口程序获取箱信息,并将箱信息写入WCSPickLinoBind表中
                    WcsBoxInfo BoxInfo = new WcsBoxInfo();
                    BoxInfo = GetBoxInfo(barcode);
                    return "5";
                }

            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 机器人请求插码
        /// </summary>
        /// <param name="model">任务信息</param>
        /// <returns></returns>
        public string GetBarcodeIN(string barcode, string palletNo)
        {
            StringBuilder sqlString = new StringBuilder();
            try
            {
                if (palletNo.Length > 8)
                {
                    return "1";//托盘号错误
                }
                if (CheckBarcodeRepeat(barcode))
                {
                    return "2";//箱码重复
                }
                //允许插码，更改箱支关系表中此箱码Aflag状态为2
                sqlString.Append($"UPDATE WCSBoxInfo set Aflag = '2' where BoxNo = '{barcode}'  and Aflag = '1' and Status = '0';");
                int IsUptLocate = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (IsUptLocate == 1)
                {
                    return "0";
                }
                else
                {
                    return "3";//修改插码状态失败
                }
            }
            catch (Exception)
            {

                throw;
            }
        }

        public bool CheckBarcodeRepeat(string barcode)
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select * from WCSBoxInfo where BoxNo = '{barcode}' and Aflag in ('0','2');");//查找当前箱码是否 0：未分道或 2：已插码
                DataRow row = DataFactory.SqlDataBase().GetDataRowBySQL(sqlString);
                if (row == null)
                {
                    return false;
                }
                return true;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 组盘
        /// </summary>
        /// <param name="model">任务信息</param>
        /// <returns></returns>
        public bool GroupPallno(string stationNum, string palletNo)
        {
            bool T = false;
            StringBuilder sqlString = new StringBuilder();
            try
            {
                sqlString.Append($"select * form WCSPickLinoBind where  LineDao = '{stationNum}'");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                var Sku = dt.Rows[0]["Sku"].ToString();
                var LotNo = dt.Rows[0]["LotNo"].ToString();

                //判断箱支表已插码未组盘的当前托盘号箱信息
                sqlString.Clear();
                sqlString.Append($"select * from WCSBoxInfo where Sku = '{Sku}' and LotNo = '{LotNo}'" +
                    $" and PalletNo = '{palletNo}' and Aflag = '2'");
                DataTable dt1 = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt1.Rows.Count == 0)
                {
                    return T;//空托盘不需要组盘
                }

                //提交组盘信息……
                foreach (var item in dt1.Rows)
                {
                    //提交当前托盘上的箱支关系
                    if (GroupBoxInfo(palletNo))
                    {
                        //提交成功后更改组盘状态
                        sqlString.Clear();
                        sqlString.Append($"UPDATE WCSBoxInfo set Status = '1' where Sku = '{Sku}' and LotNo = '{LotNo}'" +
                            $" and PalletNo = '{palletNo}' and Aflag = '2'");
                        int count = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                        if (count == 0)
                        {
                            return T;//修改组盘状态失败
                        }
                        T = true;
                    }
                }
                return T;
            }
            catch (Exception ex)
            {

                throw ex;
            }
        }

        /// <summary>
        /// 向WMS提交组盘信息
        /// </summary>
        /// <param name="palletNo"></param>
        /// <returns></returns>
        public bool GroupBoxInfo(string palletNo)
        {
            try
            {
                //获取是否存在当前箱码信息
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select * from WcsBoxInfo where IsDel = '0' and PalletNo = '{palletNo}' ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);

                if (dt == null || dt.Rows.Count == 0)
                {
                    //调用WMS系统
                    var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/RequestLocation", palletNo);
                    WcsBoxInfo boxInfo = JsonConvert.DeserializeObject<WcsBoxInfo>(response);

                    //添加箱码信息
                    sqlString.Clear();
                    sqlString.Append("insert into WcsBoxInfo (OrderCode,Line_No,LineDao,PORT,BoxNo,BoxNo2,BoxNo3,PalletNo,Qty,FullQty,Aflag,Status,SkuNo,SkuName,LotNo,LotText,Custom,CustomName,ProductionTime,ExpirationTime,CompleteTime,InspectMark,BitBoxMark,Standard,PackageStandard,StoreTime,QtyCount,QtyOrd,Opuser,IsDel,CreateTime,CreateUser,UpdateTime,UpdateUser)");
                    sqlString.Append($"Values ('{boxInfo.OrderCode}','{boxInfo.Line_No}','{boxInfo.LineDao}','{boxInfo.PORT}','{boxInfo.BoxNo}','{boxInfo.BoxNo2}','{boxInfo.BoxNo3}','','{boxInfo.Qty}','{boxInfo.FullQty}','{boxInfo.Aflag}','{boxInfo.Status}','{boxInfo.SkuNo}','{boxInfo.SkuName}','{boxInfo.LotNo}','{boxInfo.LotText}','{boxInfo.Custom}','{boxInfo.CustomName}','{boxInfo.ProductionTime}','{boxInfo.ExpirationTime}','{boxInfo.CompleteTime}','{boxInfo.InspectMark}','{boxInfo.BitBoxMark}','{boxInfo.Standard}','{boxInfo.PackageStandard}','{boxInfo.StoreTime}','{boxInfo.QtyCount}','{boxInfo.QtyOrd}','{boxInfo.Opuser}','0',getdate(),null,null,null)");
                    int isAdd = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                    if (isAdd == 1)
                    {
                        return true;
                    }
                    else
                    {
                        return false;
                    }


                }
                else
                {
                    return false;
                }
            }
            catch (Exception ex)
            {

                throw ex;
            }
        }

        #endregion
    }

    /// <summary>
    /// 返回wms实体类
    /// </summary>
    public class ExportLibraryDto
    {
        /// <summary>
        /// 任务号
        /// </summary>
        public string TaskNo { get; set; }
        /// <summary>
        /// 任务类型
        /// </summary>
        public string TaskType { get; set; }
        /// <summary>
        /// 托盘编码
        /// </summary>
        public string StockCode { get; set; }
        /// <summary>
        /// 储位编码
        /// </summary>
        public string SlotCode { get; set; }
        /// <summary>
        /// 目标地址（可能是仓库口、可能是移库后的储位）
        /// </summary>
        public string TargetPosition { get; set; }
        /// <summary>
        /// 托盘要经过的巷道口
        /// </summary>
        public string LaneWayPosition { get; set; }
        /// <summary>
        /// 目标储位经过的巷道口
        /// </summary>
        public string TargetLaneWayPosition { get; set; }

        public int Order { get; set; }

    }

    /// <summary>
    /// 任务监控实体类
    /// </summary>
    public class TaskMonitorDto
    {
        /// <summary>
        /// 任务号
        /// </summary>
        public string TaskNo { get; set; }
        /// <summary>
        /// 任务类型
        /// </summary>
        public string TaskType { get; set; }
        /// <summary>
        /// 托盘编码
        /// </summary>
        public string Palno { get; set; }
        /// <summary>
        /// 起始地址
        /// </summary>
        public string InitialAddre { get; set; }
        /// <summary>
        /// 目标地址
        /// </summary>
        public string TargetAddre { get; set; }

        /// <summary>
        /// 状态 01等待  02进行中 03已完成
        /// </summary>
        public string State { get; set; }

        /// <summary>
        /// 是否成功
        /// </summary>
        public string IsSucceed { get; set; }

        /// <summary>
        /// 错误信息
        /// </summary>
        public string ErrorStr { get; set; }

        /// <summary>
        /// 优先级
        /// </summary>
        public int? PriorityLevel { get; set; }

        /// <summary>
        /// 来源
        /// </summary>
        public string Source { get; set; }

        /// <summary>
        /// 是否成功
        /// </summary>
        public string Demo { get; set; }

        /// <summary>
        /// 是否删除
        /// </summary>
        public int? IsDel { get; set; }
    }

    /// <summary>
    /// 申请储位实体类
    /// </summary>
    public class LocationInfo
    {
        /// <summary>
        /// 托盘号
        /// </summary>
        public string palNo { get; set; }
        /// <summary>
        /// 高度
        /// </summary>
        public int height { get; set; }
    }
}