using HanHe.Message;
using HH.WCS.Hexafluo;
using HH.WCS.Hexafluo.util;
using HH.WCS.Hexafluo.wms;
using HH.WCS.SJML.Bll;
using HH.WCS.SJML.Entitys;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;

namespace HH.WCS.ZCQTJ.core
{
    public class TaskOver
    {

        private static object locko7 = new object();
        private static object locko8 = new object();
        public static void CheckCameraTask()
        {
            try
            {
                lock (locko7)
                {
                    //任务超时通知
                    var chi = new SqlHelper<object>().GetInstance();
                    var newDb = chi.CopyNew();
                    DateTime currentTime = DateTime.Now;
                    TimeSpan tenMinutes = TimeSpan.FromMinutes(20);
                    DateTime newTime = currentTime - tenMinutes;
                    try
                    {
                        var State = new List<string> { "完成", "取消" };
                        var TaskList = newDb.Queryable<WMSTask>().Where(e => !State.Contains(e.S_B_STATE) && e.T_CREATE < newTime)
                            .OrderBy(st => st.N_PRIORITY, OrderByType.Desc)
                            .OrderBy(st => st.T_CREATE)
                            .ToList();
                        if (TaskList.Any())
                        {
                            var loList = newDb.Queryable<Location>().Where(a => TaskList.Select(e => e.S_START_LAREA).Contains(a.S_LOC_CODE.Trim()) || TaskList.Select(e => e.S_END_LAREA).Contains(a.S_LOC_CODE.Trim())).ToList();
                            foreach (var item in TaskList)
                            {

                                if (item.S_TYPE == "入库")
                                {
                                    var ghh = "";
                                    ghh = $" 任务号:{item.S_TASK_NO.Substring(item.S_TASK_NO.Length - 4)} 库区:{item.S_END_LAREA} 巷道:{loList.Find(e => e.S_LOC_CODE == item.S_END_LOC).N_ROADWAY} 超时时间(创建至今):{(DateTime.Now - item.T_CREATE).TotalMinutes}分钟 任务目的地:{item.S_END_LOC}";
                                    BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(ghh);
                                }
                                if (item.S_TYPE == "出库")
                                {
                                    var ghh = "";
                                    ghh = $" 任务号:{item.S_TASK_NO.Substring(item.S_TASK_NO.Length - 4)} 库区:{item.S_START_LAREA} 巷道:{loList.Find(e => e.S_LOC_CODE == item.S_START_LOC).N_ROADWAY} 超时时间(创建至今):{(DateTime.Now - item.T_CREATE).TotalMinutes}分钟 任务目的地:{item.S_END_LOC}";
                                    BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(ghh);
                                }
                            }
                        }
                    }
                    catch (Exception ex)
                    {

                        LogHelper.DanInfo("钉钉通知", ex.Message + ex.StackTrace);
                    }


                    //try
                    //{
                    //    MonitorAgvDate.CheckCamera();
                    //}
                    //catch (System.Exception)
                    //{

                    //    throw;
                    //}

                    //Agv任务五分钟没车号发送到钉钉
                    //try
                    //{
                    //    DateTime datt = DateTime.Now;
                    //    var State1 = new List<string> { "已推送", "执行中" };
                    //    var TaskList1 = newDb.Queryable<WMSTask>().Where(e => e.S_NOTE == "agv任务" && State1.Contains(e.S_B_STATE) && datt.AddMinutes(-5) <= e.T_MODIFY && e.T_MODIFY <= datt)
                    //        .ToList();

                    //    foreach (var item in TaskList1)
                    //    {
                    //        if (string.IsNullOrEmpty(item.S_EQ_NO) && item.S_EQ_NO == "0")
                    //        {
                    //            var Val = $"任务号:{item.S_TASK_NO.Substring(item.S_TASK_NO.Length - 4)} \n\n 创建时间:{item.T_CREATE.ToString()} \n\n 开始时间:{item.T_START_TIME?.ToString()} \n\n  业务类型:{item.S_TYPE} \n\n 容器号:{item.S_CNTRS} \n\n 起点:{item.S_START_LOC} \n\n 终点:{item.S_END_LOC}  ";
                    //            BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(Val);
                    //        }
                    //    }
                    //    //agv任务十五分钟未完成
                    //    var State2 = new List<string> { "完成", "取消" };
                    //    var TaskList2 = newDb.Queryable<WMSTask>().Where(e => e.S_NOTE == "agv任务" && !State2.Contains(e.S_B_STATE) && datt.AddMinutes(-15) <= e.T_MODIFY && e.T_MODIFY <= datt)
                    //        .ToList();
                    //    foreach (var item in TaskList2)
                    //    {
                    //        var Val = $"任务号:{item.S_TASK_NO.Substring(item.S_TASK_NO.Length - 4)} \n\n 创建时间:{item.T_CREATE.ToString()} \n\n 开始时间:{item.T_START_TIME?.ToString()} \n\n  业务类型:{item.S_TYPE} \n\n 容器号:{item.S_CNTRS} \n\n 起点:{item.S_START_LOC} \n\n 终点:{item.S_END_LOC}  ";
                    //        BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(Val);
                    //    }
                    //}
                    //catch (Exception ex)
                    //{

                    //    LogHelper.DanInfo("钉钉通知", ex.Message + ex.StackTrace);
                    //}
                    try
                    {
                        //每个库区的未完成的任务数量大于？（大于多少可不可以让现场管理人员自动调节）就推送钉钉（当前未完成的任务数量多少）
                        var transportTask = chi.Queryable<ConfigJsonEntitys>().Where(e => e.Autoindex == "钉钉未完成任务推送数")?.First();
                        var TaryJb = string.IsNullOrEmpty(transportTask.TypeJson) ? 0 : int.Parse(transportTask.TypeJson);
                        var State3 = new List<string> { "完成", "取消" };
                        var TaskList3 = newDb.Queryable<WMSTask>().Where(e => !State3.Contains(e.S_B_STATE) && e.S_Main_task == "主任务")
                            .ToList();
                        var ck = TaskList3.FindAll(e => e.S_TYPE == "出库").ToList();
                        var Rk = TaskList3.FindAll(e => e.S_TYPE == "入库").ToList();
                        if (ck.Count > 0)
                        {
                            var gghf = TaskList3.GroupBy(e => e.S_START_LAREA).Select(e => e.Key).ToList();
                            foreach (var item in gghf)
                            {
                                var cks = ck.FindAll(e => e.S_START_LAREA == item).ToList();
                                if (cks.Count() >= TaryJb)
                                {
                                    var Val = $"出库:起点库区为 {item} 未完成任务数为:{cks.Count()}";
                                    BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(Val);
                                }
                            }
                        }
                        if (Rk.Count > 0)
                        {
                            var gghf = TaskList3.GroupBy(e => e.S_END_LAREA).Select(e => e.Key).ToList();
                            foreach (var item in gghf)
                            {
                                var Rks = Rk.FindAll(e => e.S_END_LAREA == item).ToList();
                                if (Rks.Count() >= TaryJb)
                                {
                                    var Val = $"入库:终点库区为 {item} 未完成任务数为:{Rks.Count()}";
                                    BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(Val);
                                }
                            }
                        }
                    }
                    catch (Exception ex)
                    {

                        LogHelper.DanInfo("钉钉通知", ex.Message + ex.StackTrace);
                    }
                }
            }
            catch (System.Exception ex)
            {
                LogHelper.DanInfo("钉钉通知", ex.Message + ex.StackTrace);
            }
        }

        public static void CheckCameraTask2()
        {
            try
            {
                lock (locko8)
                {
                    //任务超时通知
                    var chi = new SqlHelper<object>().GetInstance();
                    var newDb = chi.CopyNew();
                    DateTime datt = DateTime.Now;
                    var Val = "";
                    //出库，入库的总任务数量（半个小时之内完成跟未完成的任务综合）
                    var TaskList4 = newDb.Queryable<WMSTask>().Where(e => e.S_Main_task == "主任务" && datt.AddMinutes(-30) <= e.T_CREATE && e.T_CREATE <= datt)
                      .ToList();

                    var ck = TaskList4.FindAll(e => e.S_TYPE == "出库").ToList();
                    var Rk = TaskList4.FindAll(e => e.S_TYPE == "入库").ToList();

                    if (ck.Count > 0)
                    {
                        var gghf = TaskList4.GroupBy(e => e.S_START_LAREA).Select(e => e.Key).ToList();
                        foreach (var item in gghf)
                        {
                            var cks = ck.FindAll(e => e.S_START_LAREA == item).ToList();

                            Val += $"半小时内库区: {item} 出库数为:{cks.Count()} \n\n ";
                        }
                    }
                    if (Rk.Count > 0)
                    {
                        var gghf = TaskList4.GroupBy(e => e.S_END_LAREA).Select(e => e.Key).ToList();
                        foreach (var item in gghf)
                        {
                            var Rks = Rk.FindAll(e => e.S_END_LAREA == item).ToList();
                            Val = $"半小时内库区: {item} 入库数为:{Rks.Count()} \n\n ";
                        }
                    }

                    BLLCreator.CreateSingleton<DingDingHelper>().button1_Click(Val);
                }
            }
            catch (System.Exception ex)
            {
                LogHelper.Info("处理自管任务", ex.Message + ex.StackTrace);
            }
        }
    }
}