using Common;
using DataBase;
using Model;
using Model.MessageModel;
using Model.WcsModel;
using Model.WmsModel;
using NPOI.SS.Formula.Functions;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlTypes;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace BLL.DAL
{
    public class DALWMSApi
    {
        public ApiLocationModel GetLocation(string palno, int height)
        {
            try
            {
                if (string.IsNullOrWhiteSpace(palno))
                {
                    new LogHelper().WriteLog("GetLocation方法:托盘号为空 [-11]");
                    return new ApiLocationModel() { Code = "-11" }; // 参数为空
                }

                string ordNo = "";
                string locationCode = "";
                string oldLocationCode = "";
                StringBuilder strSQL = new StringBuilder();

                // 1.查看绑定托盘 
                strSQL.Append($"select OrdNo,LocationCode from IPalletBind where palNo ='{palno}' and Statu = '01' and IsDel = '0';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                if (dt != null && dt.Rows.Count > 0)
                {
                    ordNo = dt.Rows[0]["OrdNo"].ToString();
                    // 1.1 指定库位
                    locationCode = dt.Rows[0]["LocationCode"].ToString();
                }

                // 2.查看是否是空托盘
                strSQL.Clear();
                strSQL.Append($"select LocationCode from IPalletEmptyIn where palNo ='{palno}' and Statu = '01' and IsDel = '0';");
                DataTable dtIn = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);

                //// 已分配储位生成入库任务
                //strSQL.Clear();
                //strSQL.Append($"select TargetAddre from TaskMonitor where Palno ='{palno}' and TaskType = 'in' and IsDel = '0' and Statu = '1';");
                //DataTable dtI = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                //if (dtI != null && dtI.Rows.Count > 0)
                //{
                //    locationCode = dt.Rows[0]["TargetAddre"].ToString();
                //}

                // 3.托盘出库后重新回库,返回原库位地址.
                strSQL.Clear();
                strSQL.Append($@"
SELECT dl.LocationCode
FROM dbo.log_Store ls
    LEFT OUTER JOIN dbo.DepotsLocation dl
        ON dl.LocationCode = ls.LocationCode
WHERE ls.Palno = '{palno}'
      AND ls.IsDel = 0
      AND dl.TurnoverDemand = '03';");
                DataTable dtDL = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);

                if (dtDL != null && dtDL.Rows.Count > 0)
                {
                    oldLocationCode = dtDL.Rows[0]["LocationCode"].ToString();
                }

                // 4.1 判断是否是空托
                if (dtIn == null || dtIn.Rows.Count <= 0)
                {
                    // 4.2 不是空托,并且不是回库的不可调用
                    if (string.IsNullOrWhiteSpace(ordNo)
                        && string.IsNullOrWhiteSpace(oldLocationCode))
                    {
                        new LogHelper().WriteLog("GetLocation方法:无组盘,无空托盘入库 [-101]");
                        return new ApiLocationModel() { Code = "-101" }; //没贴该条码的托盘
                    }
                }
                else
                {
                    // 4.2 是空托盘,是否指定库位
                    if (string.IsNullOrWhiteSpace(locationCode))
                    {
                        locationCode = dtIn.Rows[0]["LocationCode"].ToString();
                    }
                }

                // 5. 是否指定库位 
                if (string.IsNullOrWhiteSpace(locationCode))
                {
                    // 5.1 没指定库位,将回库库位给定 其他情况上面已排除.
                    locationCode = oldLocationCode;
                }
                else
                {
                    // 5.2 指定库位,原库位数据全部变动.更新为指定的库位
                    strSQL.Clear();
                    strSQL.Append($@"
UPDATE dbo.DepotsLocation SET TurnoverDemand='02' WHERE LocationCode='{oldLocationCode}' AND IsDel=0;
UPDATE dbo.Picking SET Addre='{locationCode}' WHERE Addre='{oldLocationCode}' AND Palno='{palno}' AND IsDel=0;
UPDATE dbo.log_Store SET LocationCode='{locationCode}' WHERE LocationCode='{oldLocationCode}' AND Palno='{palno}' AND IsDel=0;
");
                    DataFactory.SqlDataBase().ExecuteBySql(strSQL);
                }

                // 6. 根据库位地址,查询库位详细信息
                strSQL.Clear();
                if (string.IsNullOrWhiteSpace(locationCode))
                {
                    // 6.1 自动分配库位.
                    strSQL.Append($@"
select top(1) * 
from View_GetEmptyPos 
where Height >={height} 
order by Height, LLayer, LRow, LColumn");
                }
                else
                {
                    // 6.2 回库,或已指定库位.
                    strSQL.Append($@"
select top(1) * 
from dbo.DepotsLocation 
where LocationCode='{locationCode}'");
                }

                IDataReader dtReader = DataFactory.SqlDataBase().GetDataReaderBySQL(strSQL);
                if (dtReader != null)
                {
                    DepotsLocation dl = ModelConvertHelper<DepotsLocation>.ReaderToModel(dtReader);
                    if (dl == null)
                    {
                        new LogHelper().WriteLog($"GetLocation方法:错误,无库位 [-105] LocationCode='{locationCode}' palNo='{palno}'");
                        return new ApiLocationModel() { Code = "-105" };
                    }
                    DAL_Pub pub = new DAL_Pub();
                    locationCode = dl.LocationCode;
                    pub.UpdateDeopotsLocation(dl.LocationCode, "03");   //待入库
                    if (string.IsNullOrEmpty(ordNo)) //订单号为空则为空托盘入库.
                    {
                        pub.UpdatePalletEmptyInStatus(palno, "02");
                    }
                    else
                    {
                        pub.UpdatePalletBind(palno, 2);//托盘绑定正在处理
                    }

                    new LogHelper().WriteLog($"GetLocation方法:访问成功 [01] LocationCode='{locationCode}' palNo='{palno}' height='{height}'");
                    InsOrUpLog(new WhCmd()
                    {
                        CMDStatu = 2,
                        CMDType = "in",
                        CreateUser = "WCS",
                        Height = height,
                        Palno = palno,
                        OldAddre = locationCode,
                        TaskID = ordNo,
                        IsDel = 1
                    });
                    return new ApiLocationModel()
                    {
                        Code = "01",
                        LocationCode = dl.LocationCode,
                        LocationX = dl.LColumn.ToString(),
                        LocationY = dl.LRow.ToString(),
                        LocationZ = dl.LLayer.ToString(),
                        LocationD = dl.Long.ToString()
                    };
                }
                new LogHelper().WriteLog($"GetLocation方法:错误,无库位 [-104] LocationCode='{locationCode}' palNo='{palno}'");
                return new ApiLocationModel() { Code = "-104" };
            }
            catch (Exception ex)
            {
                new LogHelper().WriteLog($"GetLocation方法:异常 [-103] palNo='{palno}'  " + ex.ToString());
                return new ApiLocationModel() { Code = "-103" };
            }
        }

        /// <summary>
        /// 上架成功
        /// </summary>
        /// <returns></returns>
        public ApiLocationModel PutStorage(string palno, string locationCode)
        {
            try
            {
                DAL_Pub pub = new DAL_Pub();

                string ordNo = "";
                string departGuid = "";
                StringBuilder strSQL = new StringBuilder();
                strSQL.Append($@"
SELECT 1
FROM dbo.log_Store ls
    LEFT OUTER JOIN dbo.DepotsLocation dl
        ON dl.LocationCode = ls.LocationCode
WHERE ls.Palno = '{palno}'
      AND ls.IsDel = 0
      AND dl.TurnoverDemand = '03';");
                // 待入库,直接更新库位状态即可.
                DataTable dtPan = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                if (dtPan != null && dtPan.Rows.Count > 0)
                {
                    pub.UpdateDeopotsLocation(locationCode, "02");   //合格

                    strSQL.Clear();
                    strSQL.Append($"UPDATE CheckTask SET statu='03' WHERE LocationCode1='{locationCode}' AND Palno1='{palno}'");
                    DataFactory.SqlDataBase().ExecuteBySql(strSQL);

                    // 回库表删除
                    strSQL.Clear();
                    strSQL.Append($"UPDATE dbo.Picking SET IsDel=1 WHERE Addre='{locationCode}' AND Palno='{palno}'");
                    DataFactory.SqlDataBase().ExecuteBySql(strSQL);
                }

                strSQL.Clear();
                strSQL.Append($"select * from IPalletBind where palNo ='{palno}' and Statu = '02' and IsDel = '0';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                if (dt != null && dt.Rows.Count > 0)
                {
                    ordNo = dt.Rows[0]["OrdNo"].ToString();
                    departGuid = dt.Rows[0]["DepartGuid"].ToString();
                }
                //排除出库重新组盘的业务点.如果是则继续执行后续操作即可.
                if (string.IsNullOrWhiteSpace(ordNo) && dtPan != null && dtPan.Rows.Count > 0)
                {
                    new LogHelper().WriteLog($"PutStorage:托盘入库成功-回库/盘库 [01] LocationCode='{locationCode}' palNo='{palno}'");
                    InsOrUpLog(new WhCmd()
                    {
                        CMDStatu = 1,
                        CMDType = "out",
                        CreateUser = "WCS",
                        OldAddre = locationCode,
                        Palno = palno,
                        IsDel = 1,
                        TaskID = ordNo
                    });
                    return new ApiLocationModel() { Code = "01" };
                }

                strSQL.Clear();
                strSQL.Append($"select 1 from IPalletEmptyIn where palNo ='{palno}' and Statu = '02' and IsDel = '0';");
                DataTable dtIn = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
                if (dtIn == null || dtIn.Rows.Count <= 0)
                {
                    if (string.IsNullOrWhiteSpace(ordNo))
                    {
                        new LogHelper().WriteLog($"PutStorage:错误,无组盘,无空托入库单 [-101] LocationCode='{locationCode}' palNo='{palno}'");
                        return new ApiLocationModel() { Code = "-101" }; //没贴该条码的托盘
                    }
                }

                if (!string.IsNullOrEmpty(ordNo))
                {
                    //非空托处理
                    IDALPalletBind pb = new DALPalletBind();

                    //修改库位状态
                    pub.UpdateDeopotsLocation(locationCode, "02");
                    //修改托盘绑定状态 入库完成
                    pub.UpdatePalletBindStatus(palno, ordNo, "03");

                    IList<PalletBind> pbLst = new List<PalletBind>();
                    bool br = pb.GetPalletBind(palno, ref pbLst);
                    //修改库存明细表
                    pub.UpdateLogStore(locationCode, pbLst);
                    //修改库存表
                    pub.UpdateLogStoreMat(palno, pbLst);

                    //修改入库单状态  所有数据调整完毕后才可以修改单据状态
                    pub.UpdateErp(palno);

                    new LogHelper().WriteLog($"PutStorage:组盘-托盘入库成功 [01] LocationCode='{locationCode}' palNo='{palno}'");
                    InsOrUpLog(new WhCmd()
                    {
                        CMDStatu = 1,
                        CMDType = "in",
                        CreateUser = "WCS",
                        OldAddre = locationCode,
                        Palno = palno,
                        IsDel = 1,
                        TaskID = ordNo
                    });
                    return new ApiLocationModel() { Code = "01" };
                }
                else
                {
                    //修改空托入库表状态
                    int count = 0;
                    var r = pub.GetPalletEmptyCount(palno, ref count);
                    if (r != -1)
                    {
                        //更新库存明细表
                        pub.UpdatePalletLogStore(locationCode, palno, count);
                        // 修改库位状态
                        pub.UpdateDeopotsLocation(locationCode, "02");   //合格/空托盘
                        pub.UpdatePalletEmptyInStatus(palno, "03"); //更新库存表
                        pub.DelPalletEmptyIn(palno);

                        new LogHelper().WriteLog($"PutStorage:空托-托盘入库成功 [01] LocationCode='{locationCode}' palNo='{palno}'");
                        InsOrUpLog(new WhCmd()
                        {
                            CMDStatu = 1,
                            CMDType = "in",
                            CreateUser = "WCS",
                            OldAddre = locationCode,
                            Palno = palno,
                            IsDel = 1,
                            TaskID = ordNo
                        });
                        return new ApiLocationModel() { Code = "01" };
                    }
                }
                new LogHelper().WriteLog($"PutStorage:错误,无业务覆盖 [-201] LocationCode='{locationCode}' palNo='{palno}'");
                return new ApiLocationModel() { Code = "-201" };
            }
            catch (Exception ex)
            {
                new LogHelper().WriteLog($"PutStorage:异常 [-202] LocationCode='{locationCode}' palNo='{palno}'  " + ex.ToString());
                return new ApiLocationModel() { Code = "-202" };//异常
            }
        }

        /// <summary>
        /// 出库完成
        /// </summary>
        /// <param name="palno"></param>
        /// <param name="locationCode"></param>
        /// <returns></returns>
        public ApiLocationModel OutStorage(string palno, string locationCode)
        {
            try
            {
                DAL_Pub pub = new DAL_Pub();
                string ordNo = "";
                // 盘库的出库流程是什么? log_Store记录不进行修改吗?
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select DISTINCT OrdNo from View_ErpOutDetail where Palno='{palno}' and LocationCode='{locationCode}' and Statu='02'");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
                if (dt != null && dt.Rows.Count > 0)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        ordNo = dr["OrdNo"].ToString();

                        int r = pub.UpdateStore(ordNo, palno, locationCode);
                        if (r == 1)
                        {
                            pub.InsertPicking(ordNo, palno, locationCode);
                            pub.UpdateOut(ordNo, palno, locationCode);
                        }
                    }
                }
                else// 没有出库单的出库,重新组盘.
                {
                    strSql.Clear();
                    strSql.Append($"UPDATE dbo.DepotsLocation SET TurnoverDemand='03' WHERE LocationCode='{locationCode}' AND TurnoverDemand='04'");
                    DataFactory.SqlDataBase().ExecuteBySql(strSql);
                }

                // 盘库出库
                strSql.Clear();
                strSql.Append($"SELECT CDNO FROM View_CheckTask_Userinfo WHERE IsDel=0 AND Palno1='{palno}' AND LocationCode1='{locationCode}'");
                DataTable dtCT = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
                if (dtCT != null && dtCT.Rows.Count > 0)
                {
                    string CDNO = dtCT.Rows[0]["CDNO"].ToString();
                    strSql.Clear();
                    strSql.Append($"UPDATE CheckTask SET statu='04' WHERE CDNO='{CDNO}'");
                    DataFactory.SqlDataBase().ExecuteBySql(strSql);

                    strSql.Clear();
                    strSql.Append($"UPDATE dbo.DepotsLocation SET TurnoverDemand='03' WHERE LocationCode='{locationCode}'");
                    DataFactory.SqlDataBase().ExecuteBySql(strSql);
                }

                new LogHelper().WriteLog($"OutStorage:出库成功 [01] LocationCode='{locationCode}' palNo='{palno}'");
                InsOrUpLog(new WhCmd()
                {
                    CMDStatu = 1,
                    CMDType = "out",
                    CreateUser = "WCS",
                    OldAddre = locationCode,
                    Palno = palno,
                    IsDel = 1,
                    TaskID = ordNo
                });
                return new ApiLocationModel() { Code = "01" };
            }
            catch (Exception ex)
            {
                new LogHelper().WriteLog($"OutStorage:异常 [-202] LocationCode='{locationCode}' palNo='{palno}'  " + ex.ToString());
                return new ApiLocationModel() { Code = "-202" }; //异常
            }
        }

        /// <summary>
        /// 给wcs发送指令.
        /// </summary>
        /// <param name="depotsLocation"></param>
        /// <returns></returns>
        public bool Send(string palno, string locationCode, string OutMode)
        {
            //return true;
            try
            {
                StringBuilder stringBuilder = new StringBuilder();
                // 02 出库单使用  04：出库中 空托盘根据此判断
                stringBuilder.Append($"SELECT * FROM dbo.DepotsLocation WHERE LocationCode='{locationCode}' AND TurnoverDemand ='02'");
                IDataReader dtReader = DataFactory.SqlDataBase().GetDataReaderBySQL(stringBuilder);
                if (dtReader == null)
                {
                    new LogHelper().WriteLog($"Send:错误,无库存[-301] LocationCode='{locationCode}'");
                    return false;
                }
                DepotsLocation depotsLocation = ModelConvertHelper<DepotsLocation>.ReaderToModel(dtReader);
                if (depotsLocation == null)
                {
                    new LogHelper().WriteLog($"Send:错误,无库存[-301] LocationCode='{locationCode}'");
                    return false;
                }
                ApiLocationModel apiLocation = new ApiLocationModel()
                {
                    Code = "1",
                    LocationCode = depotsLocation.LocationCode,
                    LocationX = depotsLocation.LColumn.ToString(),
                    LocationY = depotsLocation.LRow.ToString(),
                    LocationZ = depotsLocation.LLayer.ToString(),
                    LocationD = depotsLocation.Long.ToString(),
                    OutMode = OutMode //出库口,后续看是哪个字段.
                };

                #region 使用接口对接
                //string jsonLoc = JsonHelper.ObjectToJson(apiLocation);

                //string serviceUrl = ConfigHelper.GetAppSettings("WCSAPI") + jsonLoc;
                ////创建Web访问对象
                //HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(new Uri(serviceUrl));
                ////通过Web访问对象获取响应内容
                //HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
                ////通过响应内容流创建StreamReader对象，因为StreamReader更高级更快
                //StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
                ////string returnXml = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
                //string returnXml = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾

                //reader.Close();
                //if (myResponse != null)
                //    myResponse.Close();
                //if (myRequest != null)
                //    myRequest.Abort();
                #endregion

                #region 利用中间表对接
                stringBuilder.Clear();
                // 插入任务表
                stringBuilder.Append("INSERT INTO TaskMonitor(TaskNo,TaskType,InitialAddre, Palno, TargetAddre, State, IsSucceed, ErrorStr, PriorityLevel, Source,Demo,CreateTime,IsDel) values ");
                stringBuilder.Append($"('out','out','{locationCode}','{palno}','{OutMode}','0','0','','0','WMS','',GETDATE(),'0')");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(stringBuilder);
                #endregion

                string ordNo = "";
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select DISTINCT OrdNo from View_ErpOutDetail where Palno='{palno}' and LocationCode='{locationCode}' and Statu='01'");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
                if (dt != null && dt.Rows.Count > 0)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        ordNo = dr["OrdNo"].ToString();
                    }
                }
                new LogHelper().WriteLog($"Send:出库指令下发成功[01] LocationCode='{locationCode}' OutMode='{OutMode}'");
                InsOrUpLog(new WhCmd()
                {
                    CMDStatu = 0,
                    CMDType = "out",
                    CreateUser = "WCS",
                    OldAddre = locationCode,
                    Palno = palno,
                    Demo = "出库口:" + OutMode,
                    TaskID = ordNo

                });
                return true;
            }
            catch (Exception ex)
            {
                new LogHelper().WriteLog($"OutStorage:异常 [-302] LocationCode='{locationCode}' " + ex.ToString());
                return false;
            }
        }


        /// <summary>
        /// 空托盘给wcs发送指令.
        /// </summary>
        /// <param name="depotsLocation"></param>
        /// <returns></returns>
        public bool Send1(string palno, string locationCode, string OutMode)
        {
            //return true;
            try
            {
                StringBuilder stringBuilder = new StringBuilder();
                // 02 出库单使用  04：出库中 空托盘根据此判断
                stringBuilder.Append($"SELECT * FROM dbo.DepotsLocation WHERE LocationCode='{locationCode}' AND TurnoverDemand in ('02','04')");
                IDataReader dtReader = DataFactory.SqlDataBase().GetDataReaderBySQL(stringBuilder);
                if (dtReader == null)
                {
                    new LogHelper().WriteLog($"Send:错误,无库存[-301] LocationCode='{locationCode}'");
                    return false;
                }
                DepotsLocation depotsLocation = ModelConvertHelper<DepotsLocation>.ReaderToModel(dtReader);
                if (depotsLocation == null)
                {
                    new LogHelper().WriteLog($"Send:错误,无库存[-301] LocationCode='{locationCode}'");
                    return false;
                }
                ApiLocationModel apiLocation = new ApiLocationModel()
                {
                    Code = "1",
                    LocationCode = depotsLocation.LocationCode,
                    LocationX = depotsLocation.LColumn.ToString(),
                    LocationY = depotsLocation.LRow.ToString(),
                    LocationZ = depotsLocation.LLayer.ToString(),
                    LocationD = depotsLocation.Long.ToString(),
                    OutMode = OutMode //出库口,后续看是哪个字段.
                };

                #region 使用接口对接
                //string jsonLoc = JsonHelper.ObjectToJson(apiLocation);

                //string serviceUrl = ConfigHelper.GetAppSettings("WCSAPI") + jsonLoc;
                ////创建Web访问对象
                //HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(new Uri(serviceUrl));
                ////通过Web访问对象获取响应内容
                //HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
                ////通过响应内容流创建StreamReader对象，因为StreamReader更高级更快
                //StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
                ////string returnXml = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
                //string returnXml = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾

                //reader.Close();
                //if (myResponse != null)
                //    myResponse.Close();
                //if (myRequest != null)
                //    myRequest.Abort();
                #endregion

                #region 利用中间表对接
                stringBuilder.Clear();
                // 插入任务表
                stringBuilder.Append("INSERT INTO TaskMonitor(TaskNo,TaskType,InitialAddre, Palno, TargetAddre, State, IsSucceed, ErrorStr, PriorityLevel, Source,Demo,CreateTime,IsDel) values ");
                stringBuilder.Append($"('out','out','{locationCode}','{palno}','{OutMode}','0','0','','0','WMS','',GETDATE(),'0')");
                int rowCount = DataFactory.SqlDataBase().ExecuteBySql(stringBuilder);
                #endregion

                string ordNo = "";
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select DISTINCT OrdNo from View_ErpOutDetail where Palno='{palno}' and LocationCode='{locationCode}' and Statu='01'");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
                if (dt != null && dt.Rows.Count > 0)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        ordNo = dr["OrdNo"].ToString();
                    }
                }
                new LogHelper().WriteLog($"Send:出库指令下发成功[01] LocationCode='{locationCode}' OutMode='{OutMode}'");
                InsOrUpLog(new WhCmd()
                {
                    CMDStatu = 0,
                    CMDType = "out",
                    CreateUser = "WCS",
                    OldAddre = locationCode,
                    Palno = palno,
                    Demo = "出库口:" + OutMode,
                    TaskID = ordNo

                });
                return true;
            }
            catch (Exception ex)
            {
                new LogHelper().WriteLog($"OutStorage:异常 [-302] LocationCode='{locationCode}' " + ex.ToString());
                return false;
            }
        }

        /// <summary>
        /// 插入或修改whcmd表数据.
        /// </summary>
        /// <param name="whCmd"></param>
        /// <returns></returns>
        private bool InsOrUpLog(WhCmd whCmd)
        {
            try
            {
                // 1.1 根据订单,没有则插入
                StringBuilder sb = new StringBuilder();
                sb.Append($"SELECT 1 FROM dbo.WH_CMD WHERE OldAddre='{whCmd.OldAddre}' AND Palno='{whCmd.Palno}' AND CMDStatu<>1 AND IsDel=0");
                DataTable dtCMD = DataFactory.SqlDataBase().GetDataTableBySQL(sb);
                //if (dtCMD != null && dtCMD.Rows.Count > 0)
                //{
                //    // 1.2 已经有值,不需要插入,更改即可
                //    sb.Clear();
                //    string NowAddre = string.IsNullOrWhiteSpace(whCmd.NowAddre) ? whCmd.OldAddre : whCmd.NowAddre;
                //    sb.Append($"UPDATE dbo.WH_CMD SET CMDStatu={whCmd.CMDStatu},IsDel={whCmd.IsDel},OldAddre='{NowAddre}' WHERE Palno='{whCmd.Palno}' AND OldAddre='{whCmd.OldAddre}' AND CMDType='{whCmd.CMDType}' AND CMDStatu<>1 AND IsDel=0;");
                //    int resU = DataFactory.SqlDataBase().ExecuteBySql(sb);
                //    if (resU > 0)
                //    {
                //        return true;
                //    }
                //    return false;
                //}
                sb.Clear();
                sb.Append($@"
INSERT INTO dbo.WH_CMD
(
    TaskID,
    Palno,
    Height,
    CMDType,
    OldAddre,
    CMDStatu,
    CreateUser,
    CreateTime,
    Demo,
    IsDel
)
VALUES
(   '{whCmd.TaskID}',
    '{whCmd.Palno}',
    {whCmd.Height},
    '{whCmd.CMDType}',
    '{whCmd.OldAddre}',
    {whCmd.CMDStatu},
    '{whCmd.CreateUser}',
    GETDATE(),
    '{whCmd.Demo}',
    '{whCmd.IsDel}');");
                int res = DataFactory.SqlDataBase().ExecuteBySql(sb);
                if (res > 0)
                {
                    return true;
                }
                return false;
            }
            catch (Exception)
            {
                return false;
            }
        }


        #region WCS提供的添加任务接口  Liudl
        /// <summary>
        /// WCS接受WMS下发的任务(单条任务)
        /// </summary>
        /// <param name="models">任务信息</param>
        /// <returns>反馈信息</returns>
        public WCSResultModel AddWcsTasks(WCSTasks models)
        {
            WCSResultModel result = new WCSResultModel();
            result.stateCode = "0";
            try
            {
                models.Type = models.TaskType;
                var res = AddWcsTask(models);
                if (res.stateCode == "-1")
                {
                    result.stateCode = "-1";
                    result.errMsg = res.errMsg + ";";
                }
                else if (res.stateCode == "1")
                {
                    result.stateCode = "0";
                    result.errMsg = models.TaskNo + "任务" + res.errMsg + ";";
                }
            }
            catch (Exception ex)
            {
                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }

            return result;
        }


        /// <summary>
        /// WCS接受WMS下发的任务(单条任务)
        /// </summary>
        /// <param name="models">任务信息</param>
        /// <returns>反馈信息</returns>
        public WCSResultModel AddWcsTask(WCSTasks models)
        {
            WCSResultModel result = new WCSResultModel();
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                sqlString.Append($"select count(Id) from WCSTasks where TaskNo = '{models.TaskNo}';");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt.Rows[0][0].ToString() != "0")
                {
                    result.stateCode = "-1";
                    result.errMsg = "任务:" + models.TaskNo + ";已存在!";
                    return result;
                }
                if (models.Type == "0")
                {
                    models.Levels = "1.5";
                }
                else
                {
                    models.Levels = "2";
                }

                // 新增任务
                sqlString.Clear();
                sqlString.Append("INSERT INTO WCSTasks (TaskNo,Type,Status,Origin,StartRoadway,StartLocat,EndLocat,EndRoadway,PalletNo,");
                sqlString.Append("PalletType,LotNo,SupplierLot,SkuNo,SkuName,Qty,Levels) VALUES (");
                sqlString.Append($"'{models.TaskNo}','{models.Type}','0','WMS','{models.StartRoadway}','{models.StartLocate}',");
                sqlString.Append($"'{models.EndLocate}','{models.EndRoadway}','{models.PalletNo}','{models.PalletType}','{models.LotNo}','{models.SupplierLot}',");
                sqlString.Append($"'{models.SkuNo}','{models.SkuName}','{models.Qty}','{models.Levels}');");//,'{models.IsBale}','{models.IsBelt}',
                //sqlString.Append($"'{models.IsStacking1}','{models.IsStacking2}','{models.IsStacking3}','{models.Dismantling}');");
                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (num <= 0)
                {
                    return new WCSResultModel() { stateCode = "-1", errMsg = "插入失败" };
                }
                else if (num >= 1)
                {
                    return new WCSResultModel() { stateCode = "1", errMsg = "插入成功" };
                }
            }
            catch (Exception ex)
            {
                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }

            return new WCSResultModel() { stateCode = "0" };
        }

        /// <summary>
        /// WCS自申请储位任务(单条任务)
        /// </summary>
        /// <param name="models">任务信息</param>
        /// <returns>反馈信息</returns>
        public WCSResultModel AddItsWcsTask(WCSTasks models)
        {
            WCSResultModel result = new WCSResultModel();
            StringBuilder sqlString = new StringBuilder();
            try
            {
                if (models.Type == "0")
                {
                    //入库
                    models.Levels = "1.5";
                }
                else
                {
                    //出、移库
                    models.Levels = "2";
                }

                // 新增任务
                models.TaskNo = GetTaskNo();
                sqlString.Append( "insert into WCSTasks (TaskNo,Type,Status,Origin,StartRoadway,StartLocat,EndLocat,EndRoadway,PalletNo,PalletType,LotNo,SupplierLot,SkuNo,SkuName,Qty,Levels,SyncWms,Demo) VALUES (");
                sqlString.Append($"'{models.TaskNo}','{models.Type}','0','{models.Origin}','{models.StartRoadway}','{models.StartLocate}',");
                sqlString.Append($"'{models.EndLocate}','{models.EndRoadway}','{models.PalletNo}','{models.PalletType}','{models.LotNo}','{models.SupplierLot}',");
                sqlString.Append($"'{models.SkuNo}','{models.SkuName}','{models.Qty}','{models.Levels}','0','因WMS断开链接，WCS自申请。');");
                
                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (num <= 0)
                {
                    return new WCSResultModel() { stateCode = "-1", errMsg = "插入失败" };
                }
                else if (num >= 1)
                {
                    return new WCSResultModel() { stateCode = "1", errMsg = "插入成功" };
                }
            }
            catch (Exception ex)
            {
                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }

            return new WCSResultModel() { stateCode = "0" };
        }
        /// <summary>
        /// 获取最新任务号
        /// </summary>
        /// <returns></returns>
        public string GetTaskNo()
        {
            try
            {
                var taskStr = "";
                //TK2023091900003
                var codeFlag = "CS";
                var time = DateTime.Now.ToString("yyyyMMdd").Trim();


                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                sqlString.Append($"select TaskNo from WCSTasks where TaskNo like '{codeFlag + time}%' order by TaskNo desc;");

                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt.Rows.Count != 0)
                {
                    var s = dt.Rows[0];
                    var maxNo = dt.Rows[0][0].ToString();
                    if (string.IsNullOrWhiteSpace(maxNo))
                    {
                        taskStr = codeFlag + time + "00001";
                    }
                    else
                    {
                        int lastNo = Convert.ToInt32(maxNo.Substring(10, 5)) + 1;
                        taskStr = codeFlag + time + (lastNo.ToString().PadLeft(5, '0'));

                    }
                }
                else
                {
                    taskStr = codeFlag + time + "00001";
                }


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

        /// <summary>
        /// wms多条任务取消\完成接口
        /// </summary>
        /// <param name="models">任务信息</param>
        /// <returns>反馈信息</returns>
        public WCSResultModel FinshTasks(WCSTasks models)
        {
            WCSResultModel result = new WCSResultModel();
            result.stateCode = "0";
            try
            {
                var res = FinshTask(models);
                if (res.stateCode == "-1")
                {
                    result.stateCode = "-1";
                    result.errMsg = res.errMsg + ";";
                }
                else if (res.stateCode == "1")
                {
                    result.stateCode = "1";
                    result.errMsg = models.TaskNo + "任务" + res.errMsg + ";";

                }
            }
            catch (Exception ex)
            {
                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }

            return result;
        }

        /// <summary>
        /// WCS接受WMS下发的任务(单条任务)
        /// </summary>
        /// <param name="models">任务信息</param>
        /// <returns>反馈信息</returns>
        public WCSResultModel FinshTask(WCSTasks models)
        {
            WCSResultModel result = new WCSResultModel();
            DALWcsMessage wcsMySql = new DALWcsMessage();
            try
            {
                StringBuilder sqlString = new StringBuilder();

                // 修改任务
                sqlString.Clear();
                int a = models.Status == "2" ? 0 : 1;
                //判断任务是否完成
                sqlString.Append($"Update WCSTasks set Status = 2,IsSuccess = {a},FinishDate = '{DateTime.Now}' where TaskNo = '{models.TaskNo}'");
                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
                if (num <= 0)
                {
                    return new WCSResultModel() { stateCode = "-1", errMsg = "修改失败" };
                }
                else if (num >= 1)
                {
                    // 任务明细实体类
                    WCSTasksMonitor tasksMonitor = new WCSTasksMonitor();
                    tasksMonitor.TaskNo = models.TaskNo;
                    tasksMonitor.PlcId = 0;
                    tasksMonitor.PlcName = "";
                    tasksMonitor.Status = "2";                  // 执行完成
                    // 写入任务明细表
                    tasksMonitor.StartLocat = models.StartLocate;
                    tasksMonitor.InteractiveMsg = models.Status == "2" ? "任务已手动完成" : "任务已手动取消";
                    tasksMonitor.PalletNo = models.PalletNo;
                    tasksMonitor.EndLocat = models.EndLocate;
                    wcsMySql.AddWCSTasksMonitor(tasksMonitor);

                    return new WCSResultModel() { stateCode = "1", errMsg = "修改成功" };
                }
            }
            catch (Exception ex)
            {
                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }

            return new WCSResultModel() { stateCode = "0" };
        }

        public WCSResultModel EditLocaetStatus(List<WmsLocat> model)
        {
            try
            {
                StringBuilder sqlString = new StringBuilder();
                sqlString.Clear();

                sqlString.Append($"update WCSStorageLocat set Status = '{model[0].Status}',Flag = '{model[0].Flag}' where LocatNo in (");
                string str = "";
                foreach (var item in model)
                {
                    str += "'"+ item.LocatNo +"',";
                }
                str = str.Substring(0, str.Length-1);
                sqlString.Append($"{str});");

                int num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num <= 0)
                {
                    return new WCSResultModel() { stateCode = "-1", errMsg = "失败" };
                }
                else if(num > 0)
                {
                    return new WCSResultModel() { stateCode = "0", errMsg = "成功" };
                }
            }
            catch (Exception ex)
            {

                return new WCSResultModel() { stateCode = "-1", errMsg = ex.Message };
            }
            return new WCSResultModel() { stateCode = "0" };
        }

        #endregion

        #region 调用WMS接口

        #endregion
    }
}