using Common;
using Model;
using Newtonsoft.Json;
using NLog;
using NPOI.XWPF.UserModel;
using Org.BouncyCastle.Asn1.X509;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Threading.Tasks;

namespace BLL.DAL
{
    [Obsolete]
    public class DALWcsMessage
    {
        #region 标准版数据交互

        /// <summary>
        /// 获取与设备交互信息
        /// </summary>
        /// <returns></returns>
        public DataTable GetPlcInfos(string level, string plcIP, string dbNumber)
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append($"select * from WCSPlcInfo where isDel = 0 ");
                if (level != "")
                {
                    sqlString.Append($"and Level = '{level}' ");
                }
                if (plcIP != "")
                {
                    sqlString.Append($"and plcIP = '{plcIP}' ");
                }
                if (dbNumber != "")
                {
                    sqlString.Append($"and dbNumber = '{dbNumber}' ");
                }
                sqlString.Append(";");

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

            return null;
        }

        /// <summary>
        /// 获取任务信息
        /// </summary>
        /// <param name="status">0 等待执行 1 正在执行 2 执行完成 3 异常结束   4 任务取消 5 防断电执行</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 endRoadway = "")
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select top 1 * from WCSTasks ");
                sqlString.Append($"where Status in ({status}) and IsDel = '0' ");
                if (palletNo != "")
                {
                    sqlString.Append($" and palletNo = '{palletNo}' ");
                }
                if (startRoadway != "")
                {
                    sqlString.Append($" and startRoadway = '{startRoadway}' ");
                }
                if (endRoadway == "111")
                {

                }
                else if (endRoadway != "")
                {
                    sqlString.Append($" and endRoadway = '{endRoadway}' ");
                }
                if (type != "")
                {
                    sqlString.Append($" and Type in ({type}) ");
                }
                if (endRoadway == "111")
                {
                    sqlString.Append(" order by  Levels,CreateTime desc; ");
                }
                else if (endRoadway != "111")
                {
                    sqlString.Append(" order by  Levels desc,CreateTime asc; ");
                }
                
                return DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, "系统错误:");
            }

            return null;
        }

        /// <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 任务取消 5 防断电执行</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.137:8081/api/DownAPi/RequestLocation", json);
                    //var response = Utility.Extra.HttpHelper.DoPost("http://localhost:13243/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.StartLocat = 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.EndLocat + "\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 = $"{palletNo}:向WMS申请储位信息成功";
                            tasksMonitor.PalletNo = palletNo;
                            tasksMonitor.EndLocat = task.EndLocat;
                            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(out string palletNo1,string skuNo = "", string endLocat = "")
        {
            try
            {
                palletNo1 = "";
                string returnStr = "";
                StringBuilder sqlString = new StringBuilder();
                //string sku = skuNo + ";" + endLocat;
                var data = new
                {
                    SkuNo = skuNo,
                    EndLocat = endLocat,
                };
                sqlString.Clear();
                string json = JsonConvert.SerializeObject(data);
                var response = Utility.Extra.HttpHelper.DoPost("http://192.168.220.137: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" || skuNo == "100096" ? "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 = $"{task.PalletNo}:向WMS申请空托盘信息成功";
                            tasksMonitor.PalletNo = task.PalletNo;
                            palletNo1 = 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;
            }
        }

        /// <summary>
        /// 更新任务状态
        /// </summary>
        /// <param name="palletNo">托盘号</param>
        /// <param name="StateValue">任务状态</param>
        /// <returns>true:成功 flase:失败</returns>
        public bool SetWCSTasks(string palletNo, string StateValue, string EndLocatNo)
        {
            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}'");
                }
                sqlString.Append(" where PalletNo = '" + palletNo + "' and Status not in ('3','2','4');");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (rowCount > 0)
                {
                    bl = true;
                }

                return bl;
            }
            catch (Exception ex)
            {
                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>
        /// 调用WMS接口反馈任务接口
        /// </summary>
        /// <param name="model">任务完成状态</param>
        /// <returns></returns>
        public bool RequestTasks(TaskReques model)
        {
            bool bl = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                string json = JsonConvert.SerializeObject(model);
                var response = Utility.Extra.HttpHelper.DoPost("http://192.168.220.137:8081/api/DownAPi/ReceiveWcsSignal", json);
                //var response = Utility.Extra.HttpHelper.DoPost("http://localhost:13243/api/DownAPi/ReceiveWcsSignal", json);
                var response1 = JsonConvert.DeserializeObject(response);
                ResponseTasks taskModels = JsonConvert.DeserializeObject<ResponseTasks>(response1.ToString());
                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);
                }
            }
            catch (Exception ex)
            {
                Logger logger = LogManager.GetCurrentClassLogger();
                logger.Error(ex.Message, $"{model.taskNo}:程序异常：任务反馈失败!");
            }

            return bl;
        }
        #endregion


        #region 07版本，标准版弄好后删除
        /// <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="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
    }

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

}