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

namespace HH.WCS.Hexafluo.core
{
    /// <summary>
    /// 定时轮询任务
    /// </summary>
    public class MonitorDeadckRoll
    {
        private static object locko3 = new object();
        /// <summary>
        /// 入库
        /// </summary>
        public static void CheckCamera()
        {
            try
            {
                var logPara = LogType.LogPara("完工回报");
                var chi = new SqlHelper<object>().GetInstance();
                var newDb = chi.CopyNew();
                List<string> strings = new List<string>() { "22", "2", "7" };
                var tas = newDb.Queryable<deadlockRollEntitys>().Where(e => e.S_READ_LOCK == "N" && strings.Contains(e.S_INTER_STATE))
                 .ToList();
                var TaskList2 = tas.FindAll(e => e.S_INTER_STATE == "22");
                if (TaskList2.Any())
                {
                    var Tas = newDb.Queryable<WMSTask>().Where(e => TaskList2.Select(d => d.S_VALUE_JSON).ToList().Contains(e.S_TASK_NO))
                  .ToList();
                    TaskList2 = TaskList2.OrderBy(e => e.T_CREATE).ToList();
                    foreach (var item in TaskList2)
                    {
                        //查询这个任务的状态  如果是完成则直接标记为Y
                        //查询这个任务的状态
                        var ttg = Tas.Find(e => e.S_TASK_NO == item.S_VALUE_JSON);
                        if (ttg.S_B_STATE != "完成" && ttg.S_B_STATE != "取消")
                        {
                            var ta = BLLCreator.Create<StateTaskBLL>().ExecuteState(item.S_VALUE_JSON, "完成", logPara);
                            if (ta.Success)
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                    newDb.CommitTran();
                                }
                                catch (Exception)
                                {
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        else
                        {
                            //修改标记为Y
                            try
                            {
                                newDb.BeginTran();
                                var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception)
                            {
                                newDb.RollbackTran();
                            }
                        }
                    }
                }

                var TaskList = tas.FindAll(e => e.S_INTER_STATE == "2");
                if (TaskList.Any())
                {
                    var Tas = newDb.Queryable<WMSTask>().Where(e => TaskList.Select(d => d.S_VALUE_JSON).ToList().Contains(e.S_TASK_NO))
                  .ToList();
                    TaskList = TaskList.OrderBy(e => e.T_CREATE).ToList();
                    foreach (var item in TaskList)
                    {
                        //查询这个任务的状态  如果是完成则直接标记为Y
                        //查询这个任务的状态
                        var ttg = Tas.Find(e => e.S_TASK_NO == item.S_VALUE_JSON);
                        if (ttg.S_B_STATE != "完成" && ttg.S_B_STATE != "取消")
                        {
                            var ta = BLLCreator.Create<StateTaskBLL>().ExecuteState(item.S_VALUE_JSON, "完成", logPara);
                            if (ta.Success)
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                    newDb.CommitTran();
                                }
                                catch (Exception)
                                {
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        else
                        {
                            //修改标记为Y
                            try
                            {
                                newDb.BeginTran();
                                var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception)
                            {
                                newDb.RollbackTran();
                            }
                        }
                    }
                }


                var TaskList3 = tas.FindAll(e => e.S_INTER_STATE == "7");
                if (TaskList3.Any())
                {
                    var Tas = newDb.Queryable<WMSTask>().Where(e => TaskList3.Select(d => d.S_VALUE_JSON).ToList().Contains(e.S_TASK_NO))
                  .ToList();
                    TaskList3 = TaskList3.OrderBy(e => e.T_CREATE).ToList();
                    foreach (var item in TaskList3)
                    {
                        //查询这个任务的状态  如果是完成则直接标记为Y
                        //查询这个任务的状态
                        var ttg = Tas.Find(e => e.S_TASK_NO == item.S_VALUE_JSON);
                        if (ttg.S_B_STATE != "完成" && ttg.S_B_STATE != "取消")
                        {
                            var ta = BLLCreator.Create<StateTaskBLL>().ExecuteState(item.S_VALUE_JSON, "取消", logPara);
                            if (ta.Success)
                            {
                                try
                                {
                                    newDb.BeginTran();
                                    var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                    newDb.CommitTran();
                                }
                                catch (Exception)
                                {
                                    newDb.RollbackTran();
                                }
                            }
                        }
                        else
                        {
                            //修改标记为Y
                            try
                            {
                                newDb.BeginTran();
                                var I = newDb.Updateable<deadlockRollEntitys>().SetColumns(it => new deadlockRollEntitys() { S_READ_LOCK = "Y" }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
                                newDb.CommitTran();
                            }
                            catch (Exception)
                            {
                                newDb.RollbackTran();
                            }
                        }
                    }
                }
            }
            catch (System.Exception ex)
            {
                LogHelper.DanInfo("完工回报", "死锁回滚报错 " + ex.Message);
            }
        }
    }
}