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_TaskMonitor
    {
        /// <summary>
        /// 获取任务控制信息
        /// </summary>
        /// <param name="Json"></param>
        /// <param name="pageInfo"></param>
        /// <returns></returns>
        public IList<WCSTasks> GetList(AjaxGetTaskList Json, ref PageInfo pageInfo)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                // 0 未下发 1 已下发 2 ？ 3已完成
                strSql.Append("select Id,TaskNo,CASE Type when '0' then '入库' when '1' then '出库' when '2' then '移库' else Type end as Type,");
                strSql.Append("Status,IsSuccess,Information,Origin,StartLocat,EndLocat,PalletNo,CancelDate,Levels,FinishDate,CreateTime ");
                strSql.Append(" from WCSTasks where IsDel = '0' ");


                if (!string.IsNullOrWhiteSpace(Json.TaskNo))
                {
                    strSql.Append(" and TaskNo like '%" + Json.TaskNo + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.TaskType))
                {
                    strSql.Append(" and Type = '" + Json.TaskType + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.Status))
                {
                    strSql.Append(" and Status = '" + Json.Status + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.StartLocat))
                {
                    strSql.Append(" and StartLocat like '%" + Json.StartLocat + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.PalletNo))
                {
                    strSql.Append(" and PalletNo like '%" + Json.PalletNo + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.EndLocat))
                {
                    strSql.Append(" and EndLocat like '%" + Json.EndLocat + "%'  ");
                }
                // strSql.Append(" order by state ,TaskNo1 ");

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

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

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

                //  
                strSql.Append("select Id,TaskNo,PlcId,PlcName,StartLocat,EndLocat,InteractiveMsg,ErrorMsg,IsDel,CreateTime,CreateUser,UpdateTime,UpdateUser from WCSTasksMonitor where IsDel = '0' ");
                if (!string.IsNullOrWhiteSpace(Json.TaskNo))
                {
                    strSql.Append(" and TaskNo like '%" + Json.TaskNo + "%' ");
                }
                if (!string.IsNullOrWhiteSpace(Json.StartLocat))
                {
                    strSql.Append(" and StartLocat like '%" + Json.StartLocat + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.EndLocat))
                {
                    strSql.Append(" and EndLocat like '%" + Json.EndLocat + "%'  ");
                }
                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "CreateTime", "desc", ref pageInfo);
                return ModelConvertHelper<WCSTasksMonitor>.DataTableToModel(dt);
            }
            catch
            {
                throw new NotImplementedException();
            }
        }


        /// <summary>
        /// 手动添加任务
        /// </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="ID"></param>
        /// <returns></returns>
        public bool TaskMonitorComplete(string[] ID)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("TaskMonitor", "Guid", ID);
                if (dt >= ID.Length)
                {
                    int i = 0;
                    while (i < ID.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        // 获取当前任务详细信息
                        sql.Append("select * from TaskMonitor where guid = '" + ID[i] + "' and State != '3';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            // 完成上架任务
                            DALWcsMessage wcsSql = new DALWcsMessage();
                            if (monitorDt.Rows[0]["TaskType"].ToString() == "out")          // 出库任务
                            {
                                wcsSql.WcsinWms(monitorDt.Rows[0]["Palno"].ToString(), monitorDt.Rows[0]["InitialAddre"].ToString(), "2");
                                // 更改储位状态
                                //StringBuilder hql = new StringBuilder();
                                //hql.Append("update DepotsLocation set TurnoverDemand ='01' where LocationCode = '" + monitorDt.Rows[0]["InitialAddre"].ToString() + "'");
                                //DataFactory.SqlDataBase().ExecuteBySql(hql);
                            }
                            else    // 入库任务
                            {

                                wcsSql.WcsinWms(monitorDt.Rows[0]["Palno"].ToString(), monitorDt.Rows[0]["TargetAddre"].ToString(), "1");

                                //// 更改储位状态
                                //StringBuilder hql = new StringBuilder();
                                //hql.Append("update DepotsLocation set TurnoverDemand ='03' where LocationCode = '" + monitorDt.Rows[0]["TargetAddre"].ToString() + "'");
                                //DataFactory.SqlDataBase().ExecuteBySql(hql);
                            }

                            // 修改任务状态
                            sql.Append("update TaskMonitor set State=3 where Guid='" + ID[i] + "'");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= ID.Length) result = true;
                        }
                        i++;
                    }

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

        /// <summary>
        ///  取消任务
        /// </summary>
        /// <param name="ID"></param>
        /// <returns></returns>
        public bool TaskMonitorCancel(string[] ID)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("TaskMonitor", "Guid", ID);
                if (dt >= ID.Length)
                {
                    int i = 0;
                    while (i < ID.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        sql.Append("update TaskMonitor set IsDel=1 where Guid='" + ID[i] + "'");
                        int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                        if (_ret >= ID.Length) result = true;
                        i++;

                        //// 更改储位状态
                        //sql.Clear();
                        //sql.Append("select * from TaskMonitor where Guid='" + ID[i] + "';");
                        //DataTable dtt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        //if (dtt.Rows[0][""].ToString() == "in") 
                        //{
                        //    // 将目标储位更改为
                        //}
                    }

                }
                return result;

            }
            catch
            {
                return result;
            }
        }
    }
}