using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Commom.Utility;
using Common;
using Model;

namespace BLL.DAL
{
    public class DAL_CheckMonitor
    {
        /// <summary>
        /// 获取机器人信息
        /// </summary>
        /// <param name="Json"></param>
        /// <param name="pageInfo"></param>
        /// <returns></returns>
        public IList<WCSPickLino> GetList(AjaxGetRobotList Json, ref PageInfo pageInfo)
        {
            try
            {
                // test
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

               
                strSql.Append("select Id,RobotNo,RobotName,PickType,IDState,Picked");
                strSql.Append(" from WCSPickLino where IsDel = 0 ");


                if (!string.IsNullOrWhiteSpace(Json.RobotNo))
                {
                    strSql.Append(" and RobotNo like '%" + Json.RobotNo + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.PickType))
                {
                    strSql.Append(" and PickType = '" + Json.PickType + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.IDState))
                {
                    strSql.Append(" and IDState = '" + Json.IDState + "'  ");
                }

                SqlParam[] param = null;
                if (para != null)
                {
                    param = para.ToArray();
                }

                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "RobotNo", "", ref pageInfo);
                return ModelConvertHelper<WCSPickLino>.DataTableToModel(dt);
            }
            catch
            {
                throw new NotImplementedException();
            }
        }

        /// <summary>
        /// 获取任务控制信息明细
        /// </summary>
        /// <param name="Json"></param>
        /// <param name="pageInfo"></param>
        /// <returns></returns>
        public IList<PickLinoBind> GetDetailList(AjaxGetBindList Json, ref PageInfo pageInfo)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                //  
                strSql.Append("select PickLinoID,TaskNo,Type,LotNo,SkuNo,SkuName,Chang,Kuan,Gao,AddTime,IDState,LineDao,Level,Finish from WCSPickLinoBind  where IsDel = '0' ");
                if (!string.IsNullOrWhiteSpace(Json.PickLinoID))
                {
                    strSql.Append(" and PickLinoID = '" + Json.PickLinoID + "'  ");
                }
                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "AddTime", "", ref pageInfo);
                return ModelConvertHelper<PickLinoBind>.DataTableToModel(dt);
            }
            catch
            {
                throw new NotImplementedException();
            }
        }


        /// <summary>
        /// 手动添加任务 liudl Del 20231026
        /// </summary>
        /// <param name="model"></param>
        /// <param name="loginUser"></param>
        /// <returns></returns>
        public bool Add(TaskMonitorModel model, string loginUser)
        {
            bool result = false;
            try
            {
                Hashtable ht = new Hashtable();

                ht["TaskType"] = model.TaskType.AddQuotes();
                ht["InitialAddre"] = "'" + model.InitialAddre + "'";
                ht["Palno"] = "'" + model.Palno + "'";
                ht["TargetAddre"] = "'" + model.TargetAddre + "'";
                ht["State"] = "'0'";
                ht["IsSucceed"] = "'" + model.IsSucceed + "'";
                ht["ErrorStr"] = "'" + model.ErrorStr + "'";
                ht["PriorityLevel"] = model.PriorityLevel;
                ht["Source"] = "'手动'";
                ht["Demo"] = "'" + model.Demo + "'";

                ht["CreateUser"] = "'" + loginUser + "'";
                ht["CreateTime"] = "Getdate()";


                int _ret = DataFactory.SqlDataBase().InsertByHashtableNullParam("TaskMonitor", ht);

                if (_ret == 1) result = true;

                return result;

            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        /// 任务绑定工位
        /// </summary>
        /// <param name="models"></param> 
        /// <param name="loginName">登录人</param> 
        /// <returns></returns>
        public bool BindTask(WCSTasks models,string loginName)
        {
            bool result = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                sqlString.Append($"select count(Id) from WCSTasks where PalletNo = '{models.PalletNo}' adn (Status = '0' or Status = '1') ;");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                if (dt != null)
                {
                    if (dt.Rows[0][0].ToString() != "0")
                    {
                        throw new Exception("等待或正在执行任务中托盘号:" + models.PalletNo + ";已存在!");
                    }
                }
                models.TaskNo = GetTaskNo();
                if (models.Type == "0")//0入  1出
                {
                    var str = int.Parse(models.EndLocate.Substring(0, 2));
                    if (str <= 2)
                    {
                        models.EndRoadway = "R01";
                    }
                    else if (str > 2)
                    {
                        models.EndRoadway = "R02";
                    }
                }
                else if (models.Type == "1")
                {
                    var str = int.Parse(models.StartLocate.Substring(0, 2));
                    if (str <= 2)
                    {
                        models.StartRoadway = "R01";
                    }
                    else if (str > 2)
                    {
                        models.StartRoadway = "R02";
                    }
                }
                else
                {
                    return false;
                }
                // 新增任务
                sqlString.Clear();
                sqlString.Append("INSERT INTO WCSTasks (TaskNo,Type,Status,Origin,StartRoadway,StartLocat,EndLocat,EndRoadway,PalletNo,");
                sqlString.Append("LotNo,SupplierLot,SkuNo,SkuName,Qty,Levels,CreateUser) VALUES (");
                sqlString.Append($"'{models.TaskNo}','{models.Type}','0','{models.Origin}','{models.StartRoadway}','{models.StartLocate}',");
                sqlString.Append($"'{models.EndLocate}','{models.EndRoadway}','{models.PalletNo}','{models.LotNo}','{models.SupplierLot}',");
                sqlString.Append($"'{models.SkuNo}','{models.SkuName}','{models.Qty}','{models.Levels}','{loginName}');");
                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num == 1) 
                {
                    DAL_OperationRecord oper = new DAL_OperationRecord();
                    var operation = new OperationModel()
                    {
                        MenuName = "任务管理",
                        FkNo = models.TaskNo+"-"+models.PalletNo,
                        Msg = "新增任务信息",
                        Type = "新增",
                    };
                    oper.AddOperation(operation, loginName);
                    result = true;
                } 

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

        /// <summary>
        /// 机器人禁用/恢复
        /// </summary>
        /// <param name="Id"></param>
        /// <param name="loginName"></param>
        /// <returns></returns>
        public bool MonitorForbidden(string[] Id, string loginName)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSPickLino", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        // 获取当前任务详细信息
                        sql.Append($"select * from WCSPickLino where Id = '{Id[i]}';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            int tag = 1;
                            if (monitorDt.Rows[0]["IDState"].ToString() != "0")
                            {
                                tag = 0;
                            }
                            sql.Clear();
                            // 修改任务状态
                            sql.Append($"update WCSPickLino set IDState={tag},UpdateTime = getdate() where Id='{Id[i]}';");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= 1) 
                            {
                                /*DAL_OperationRecord oper = new DAL_OperationRecord();
                                var operation = new OperationModel()
                                {
                                    MenuName = "设备管理",
                                    FkNo = monitorDt.Rows[0]["ID"].ToString() + "号机器人",
                                    Msg = "禁用机器人",
                                    Type = "完成",
                                };
                                oper.AddOperation(operation, loginName);*/
                                result = true;
                            } 
                        }
                        i++;
                    }

                }
                return result;
            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        /// 手动结批信号修改
        /// </summary>
        /// <param name="Id"></param>
        /// <param name="loginName"></param>
        /// <returns></returns>
        public bool EndBatchTask(string[] Id)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSPickLino", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        // 获取当前任务详细信息
                        sql.Append($"select * from WCSPickLino where Id = '{Id[i]}';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            int tag = 2;
                            if (monitorDt.Rows[0]["IDState"].ToString() != "0")
                            {
                                tag = 0;
                            }
                            sql.Clear();
                            // 修改任务状态
                            sql.Append($"update WCSPickLino set IDState={tag},UpdateTime = getdate() where Id='{Id[i]}';");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= 1)
                            {
                                /*DAL_OperationRecord oper = new DAL_OperationRecord();
                                var operation = new OperationModel()
                                {
                                    MenuName = "设备管理",
                                    FkNo = monitorDt.Rows[0]["ID"].ToString() + "号机器人",
                                    Msg = "禁用机器人",
                                    Type = "完成",
                                };
                                oper.AddOperation(operation, loginName);*/
                                result = true;
                            }
                        }
                        i++;
                    }

                }
                return result;
            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        ///  取消任务
        /// </summary>
        /// <param name="Id"></param>
        /// <param name="loginName"></param>
        /// <returns></returns>
        public bool TaskMonitorCancel(string[] Id,string loginName)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        // 获取当前任务详细信息
                        sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            if (monitorDt.Rows[0]["Status"].ToString() != "0")
                            {
                                i++;
                                continue;
                            }
                            // 完成上架任务
                            var wcsSql = new DALWcsMessage();
                            if (monitorDt.Rows[0]["Origin"].ToString() == "WMS")      
                            {
                                var task = new TaskReques
                                {
                                    taskNo = monitorDt.Rows[0]["TaskNo"].ToString(),
                                    PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(),
                                    TaskType = monitorDt.Rows[0]["Type"].ToString(),
                                    TaskStatus = "4",
                                };

                                wcsSql.RequestTasks(task);
                            }

                            sql.Clear();
                            // 修改任务状态
                            sql.Append("update WCSTasks set Status = 4,CancelDate=getdate() where Id='" + Id[i] + "'");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= 1) 
                            {
                                DAL_OperationRecord oper = new DAL_OperationRecord();
                                var operation = new OperationModel()
                                {
                                    MenuName = "任务管理",
                                    FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
                                    Msg = "手动取消任务信息",
                                    Type = "取消",
                                };
                                oper.AddOperation(operation, loginName);
                                result = true;
                            } 
                        } 
                        
                        i++;

                    }

                }
                return result;

            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        /// 手动再次回传WMS
        /// </summary>
        /// <param name="Id">任务ID集合</param>
        /// <param name="loginName"></param>
        /// <returns></returns>
        public bool TaskMonitorBackhaul(string[] Id, string loginName,bool tuoji) 
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        // 获取当前任务详细信息
                        sql.Append($"select * from WCSTasks where Id = '{Id[i]}' and IsSuccess = '1';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            string taskStatus = monitorDt.Rows[0]["Status"].ToString();
                            if (taskStatus == "0" || taskStatus == "1" || taskStatus =="4")
                            {
                                i++;
                                continue;
                            }
                            DAL_OperationRecord oper = new DAL_OperationRecord();
                            var operation = new OperationModel()
                            {
                                MenuName = "任务管理",
                                FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
                                Msg = "手动回传任务信息",
                                Type = "回传",
                            };
                            oper.AddOperation(operation, loginName);
                            // 完成上架任务
                            var wcsSql = new DALWcsMessage();
                            if (monitorDt.Rows[0]["Origin"].ToString() == "WMS")
                            {
                                var task = new TaskReques
                                {
                                    taskNo = monitorDt.Rows[0]["TaskNo"].ToString(),
                                    PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(),
                                    TaskType = monitorDt.Rows[0]["Type"].ToString(),
                                    TaskStatus = monitorDt.Rows[0]["Status"].ToString(),                // 获取再次
                                };

                                result = wcsSql.RequestTasks(task);
                            }
                        }

                        i++;

                    }

                }
                return result;

            }
            catch
            {
                return result;
            }
        }


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

    }
}