using HH.WCS.ZhongCeJinTan.api;
using HH.WCS.ZhongCeJinTan.dispatch;
using HH.WCS.ZhongCeJinTan.process;
using HH.WCS.ZhongCeJinTan.util;
using HH.WCS.ZhongCeJinTan.wms;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web.Services.Description;
using static HH.WCS.ZhongCeJinTan.api.ApiModel;

namespace HH.WCS.ZhongCeJinTan.core
{
    /// <summary>
    /// 定时轮询任务
    /// </summary>
    internal class Monitor
    {
        /// <summary>
        /// 根据作业创建对应任务
        /// </summary>
        public static void CreateTask()
        {
            var db = new SqlHelper<object>().GetInstance();

            // 获取所有等待中的作业
            var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList();
            foreach (var operation in operations)
            {
                TaskHelper.CreateTask(operation);
            }
        }


        /// <summary>
        /// 根据任务状态更新作业状态
        /// </summary>
        public static void UpdateWorkState() {

            var db = new SqlHelper<object>().GetInstance();

            var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 1).ToList();

            foreach (var operation in operations)
            {
                // 判断该任务是否全部完成
                var tasks = db.Queryable<WMSTask>().Where(p => p.S_OP_CODE == operation.S_CODE).ToList();



                if (tasks.Count > 1 && tasks.Count(p => p.N_B_STATE == 3) == 1)
                {
                    operation.S_B_STATE = "完成一半";
                    operation.T_MODIFY = DateTime.Now;
                    db.Updateable(operation).UpdateColumns(it => new { it.S_B_STATE, it.T_MODIFY }).ExecuteCommand();
                }

                if (tasks.Count == tasks.Count(p => p.N_B_STATE == 3))
                {
                    operation.N_B_STATE = 2;
                    operation.S_B_STATE = "完成";
                    operation.T_MODIFY = DateTime.Now;
                    operation.T_END_TIME = DateTime.Now;
                    db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_MODIFY, it.T_END_TIME }).ExecuteCommand();

                }
                else if (tasks.Count(p => p.N_B_STATE == 5) > 0)
                {
                    operation.N_B_STATE = 7;
                    operation.S_B_STATE = "取消";
                    operation.T_MODIFY = DateTime.Now;
                    operation.T_END_TIME = DateTime.Now;

                    db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_MODIFY, it.T_END_TIME }).ExecuteCommand();
                }
            }
        }

        //出库任务 动作码有1无3 每隔一段时间提高一次优先级

        public static void UpdateOutTaskPriority()
        {
            //var ts1 = DateTime.Now.Subtract(datetime).TotalMinutes;


        }

        /// <summary>
        /// 自动出库空托
        /// </summary>
        public static void ktAuto() {
            var db = new SqlHelper<object>().GetInstance();

            try
            {
                var ktTaskList = db.Queryable<MesKtTask>().Where(a => a.Status == "N" ).ToList();
                foreach (var kt in ktTaskList)
                {
                    if (DateTime.Now.Subtract(kt.CreateDate).TotalMinutes < 1)
                    {
                        continue;
                    }

                    var workFlow = TaskHelper.selectWorkFlowByType(kt.BUSI_TYPE, kt.TOOLS_TPYE);


                    if (workFlow == null)
                    {
                        LogHelper.Info($"空托出库任务下发失败，流程编号:{kt.BUSI_TYPE},工装类型{kt.TOOLS_TPYE},没找到对应作业流程", "空托出库");
                        throw new Exception($"BUSI_TYpe:{kt.BUSI_TYPE},没找到对应作业流程");
                    }
                    else
                    {
                        LogHelper.Info($"空托出库作业流程信息" + JsonConvert.SerializeObject(workFlow), "空托出库");
                    }



                    //出库任务

                    //接驳位
                    var connection = "";

                    //接驳位库区
                    var connectionArea = "";


                    //查找给定终点
                    var end = LocationHelper.GetLoc(kt.Location_To);
                    LogHelper.Info($"空托出库任务下发终点信息" + JsonConvert.SerializeObject(end), "空托出库");


                    if (end == null)
                    {
                        LogHelper.Info($"空托出库任务下发失败，终点:{kt.Location_To},没找到", "空托出库");
                        throw new Exception($"终点:{kt.Location_To},没找到");
                    }





                    //查找起点
                    List<Location> strrtList;

                    Location start = null;


                    if (!string.IsNullOrEmpty(workFlow.ZONECODE))
                    {
                        strrtList = LocationHelper.GetZoneLoc(workFlow.ZONECODE);
                    }
                    else
                    {
                        strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
                    }




                    //寻找立库区空托
                    start = LocationHelper.FindStartcolByLoclistAndcntr(strrtList, workFlow.STARTAREA);


                    LogHelper.Info($"空托出库任务下发起点信息" + JsonConvert.SerializeObject(start), "空托出库");

                    if (start == null)
                    {
                        LogHelper.Info($"空托出库任务下发失败，起点库区{workFlow.STARTAREA},没找到起点", "空托出库");
                        throw new Exception($"起点库区{workFlow.STARTAREA},没找到起点");
                    }




                    //获取托盘码
                    var cntrCode = LocationHelper.GetLocCntrCode(start.S_CODE);

                    if (workFlow.SENDWCS == "Y")
                    {

                        //正式代码，调用接口寻找可用接驳位
                        var connectionList = LocationHelper.GetConnectionList(workFlow.CONNECTION);

                        var balanceConnectionList = LocationHelper.GetBalanceConnectionList(connectionList);
                        foreach (var item in balanceConnectionList)
                        {
                            if (item.loc.N_CURRENT_NUM < 2)
                            {
                                connection = item.loc.S_CODE;
                                connectionArea = item.loc.S_AREA_Name;
                                LogHelper.Info($"空托出库任务下发寻找到可用接驳位{connection}", "空托出库");
                                break;
                            }
                        }

                        if (connection == "")
                        {
                            LogHelper.Info($"空托出库任务下发寻找接驳位失败", "Mes任空托出库务下发");
                            throw new Exception($"空托出库任务下发寻找接驳位失败");
                        }
                    }


                    //起点终点查找成功，创建作业

                    var taskType = int.Parse(workFlow.FLOWCODE);

                    var operation = new WmsWork
                    {
                        // 作业号
                        S_CODE = kt.task_no,
                        // 作业类型
                        N_TYPE = taskType,
                        // 作业类型
                        S_TYPE = workFlow.FLOWNAME,
                        // 起点货位
                        S_START_LOC = start.S_CODE,
                        // 起点库区编码
                        S_START_AREA = start.S_AREA_CODE,
                        //接驳位
                        CONNECTION = connection,
                        // 终点货位
                        S_END_LOC = end.S_CODE,
                        // 终点库区编码
                        S_END_AREA = end.S_AREA_CODE,
                        // 容器编码
                        S_CNTR_CODE = cntrCode,
                        // 作业定义名称
                        S_OP_DEF_NAME = workFlow.FLOWNAME,
                        //优先级
                        N_PRIORITY = kt.Priority,
                        //工装类型
                        TOOLSTYPE = kt.TOOLS_TPYE,
                        //起点库区名称
                        S_START_AREA_NAME = start.S_AREA_Name,
                        //起点库区名称
                        S_END_AREA_NAME = end.S_AREA_Name,
                        //起点库区名称
                        CONNECTION_AREA = connectionArea
                    };

                    //创建作业
                    if (WMSHelper.CreateWmsWork(operation) && TaskHelper.ChangeMesKtTask(kt))
                    {
                        
                        LogHelper.Info($"空托出库作业创建成功{operation.S_CODE}", "空托出库");
                    }
                    else
                    {
                        LogHelper.Info($"空托出库任务下发创建作业失败", "空托出库");
                        throw new Exception($"空托出库任务下发创建作业失败");
                    }

                }
               
    
            }
            catch (Exception ex)
            {

                LogHelper.Info($"空托出库异常信息" + ex.Message, "空托出库");
            }
        }
    }
}