using Microsoft.EntityFrameworkCore;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Logical;
using System;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Common.DBHelper;
using WIDESEA_Common.LoctionEnum;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;

namespace WIDESEA_WCS
{
    public partial class StackerExecutor
    {
        public static object requestZJBCK = new object();//requestZJJK
        private static int _readZBCKSignalsoZ = 0;//_readZTBUPSignalso

        /// <summary>
        /// 正极箔材库搬运工作逻辑
        /// </summary>
        /// <param name="client"></param>
        public static void Z_BCK_Task()
        {
            if (Interlocked.Exchange(ref _readZBCKSignalsoZ, 1) == 0)
            {
                Task.Run(() =>
                {
                    try
                    {
                        FreeDB freeDB = new FreeDB();
                        VOLContext Context = new VOLContext();
                        Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
                        Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
                        Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);

                        //34出口，供给辊分上料口
                        var location_34 = freeDB.Select<base_ware_location>().Where(t => t.upper_code == "ZJ-BCHCJ32" && t.task == 2 && t.status == 1).First();
                        //34空架立即补料
                        dt_agvtask dt_Agvtask34 = agvRepository.FindFirst(x => x.agv_toaddress == "ZJ-BCHCJ32");
                        if (dt_Agvtask34 != null && location_34.task == 2)
                        {
                            location_34.update_time = DateTime.Now;
                            location_34.task = 1;
                            location_34.logic_col = 1;
                            var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                            if (entrys != null)
                            {
                                entrys.State = EntityState.Detached;
                            }
                            int end = locRepository.Update(location_34, true);
                        }
                        if (location_34 != null && dt_Agvtask34 == null)
                        {
                            if (location_34.location_state == LoctionStateEnum.LocationState_Empty.ToString() && location_34.tpgd == 0)
                            {
                                var location_34_cp = freeDB.Select<base_ware_location>().Where(t => t.location_state == "LocationState_Stored" && t.logic_row.ToString() == "TBXL-BCK" && t.logic_col == 1/*正常料*/  && t.status == 1 && t.upper_code.Contains("ZJ-BCHCJ") && t.status == 1 && t.light_color != "SB" && t.task == 2).OrderBy(t => t.update_time).First();

                                //dt_agvtask task_34 = agvRepository.Find(t => t.agv_fromaddress == "FJ-BCHCJ34" || t.agv_toaddress == "FJ-BCHCJ34").FirstOrDefault();

                                if (location_34_cp != null)//找到合适货位，生成补料搬运任务
                                {

                                    //34货位补料任务
                                    dt_agvtask agvtask = new dt_agvtask();
                                    agvtask.agv_id = Guid.NewGuid();
                                    agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
                                    agvtask.agv_fromaddress = location_34_cp.upper_code;
                                    agvtask.agv_toaddress = location_34.upper_code;
                                    agvtask.agv_code = "正极AGV调度";
                                    agvtask.agv_remark = "正极箔材库搬运(34补料)";
                                    agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                    agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
                                    agvtask.agv_worktype = 1;//工作类型
                                    agvtask.agv_materielid = "";
                                    agvtask.agv_qty = 1;
                                    agvtask.agv_createtime = DateTime.Now;
                                    agvtask.agv_grade = 0;//任务优先级
                                    agvtask.agv_userid = "WCS";
                                    agvtask.agv_barcode = "";

                                    //锁定首尾货位
                                    location_34_cp.task = 1;

                                    location_34_cp.update_time = DateTime.Now;
                                    var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                    if (entry != null)
                                    {
                                        entry.State = EntityState.Detached;
                                    }
                                    int begin = locRepository.Update(location_34_cp, d => new { d.update_time, d.task }, true);

                                    location_34.task = 1;
                                    location_34.logic_col = 1;
                                    location_34.update_time = DateTime.Now;
                                    var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                    if (entrys != null)
                                    {
                                        entrys.State = EntityState.Detached;
                                    }
                                    int end = locRepository.Update(location_34, d => new { d.update_time, d.task, d.logic_col }, true);
                                    if (begin == 1 && end == 1)
                                    {

                                        agvRepository.Add(agvtask, true);

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"生成任务:{agvtask.agv_tasknum}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"起点货位【{location_34_cp.upper_code}】状态：托盘光电检测：{location_34_cp.tpgd},状态：{location_34_cp.location_state},更新时间：{location_34_cp.wireless_time}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"终点货位【{location_34.upper_code}】状态：托盘光电检测：{location_34.tpgd},状态：{location_34.location_state},更新时间：{location_34.wireless_time}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"----------------任务生成成功  {DateTime.Now} -------------- {Environment.NewLine}", $"箔材库任务生成");
                                    }
                                }

                            }
                        }

                        //36出口，供给涂布上料口
                        var location_36 = freeDB.Select<base_ware_location>().Where(t => t.upper_code == "ZJ-BCHCJ34" && t.task == 2 && t.status == 1).First();
                        //36空架立即补料
                        dt_agvtask dt_Agvtask36 = agvRepository.FindFirst(x => x.agv_toaddress == "ZJ-BCHCJ34");
                        if (dt_Agvtask36 != null && location_36.task == 2)
                        {
                            location_36.update_time = DateTime.Now;
                            location_36.task = 1;
                            location_36.logic_col = 1;
                            var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                            if (entrys != null)
                            {
                                entrys.State = EntityState.Detached;
                            }
                            int end = locRepository.Update(location_36, true);
                        }
                        if (location_36 != null && dt_Agvtask36==null)
                        {
                            if (location_36.location_state == LoctionStateEnum.LocationState_Empty.ToString() && location_36.tpgd == 0)
                            {
                                var location_36_cp = freeDB.Select<base_ware_location>().Where(t => t.location_state == "LocationState_Stored" && t.logic_row.ToString() == "TSJXL-BCK" && t.logic_col == 1 && t.status == 1 && t.upper_code.Contains("ZJ-BCHCJ") && t.light_color != "SB" && t.task == 2).OrderBy(t => t.update_time).First();

                                //dt_agvtask task_36 = agvRepository.Find(t => t.agv_fromaddress == "FJ-BCHCJ36" || t.agv_toaddress == "FJ-BCHCJ36").FirstOrDefault();

                                if (location_36_cp != null)//找到合适货位，生成补料搬运任务
                                {

                                    //36货位补料任务
                                    dt_agvtask agvtask = new dt_agvtask();
                                    agvtask.agv_id = Guid.NewGuid();
                                    agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
                                    agvtask.agv_fromaddress = location_36_cp.upper_code;
                                    agvtask.agv_toaddress = location_36.upper_code;
                                    agvtask.agv_code = "正极AGV调度";
                                    agvtask.agv_remark = "正极箔材库搬运(36补料)";
                                    agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                    agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
                                    agvtask.agv_worktype = 1;//工作类型
                                    agvtask.agv_materielid = "";
                                    agvtask.agv_qty = 1;
                                    agvtask.agv_createtime = DateTime.Now;
                                    agvtask.agv_grade = 0;//任务优先级
                                    agvtask.agv_userid = "WCS";
                                    agvtask.agv_barcode = "";

                                    //锁定首尾货位
                                    location_36_cp.update_time = DateTime.Now;
                                    location_36_cp.task = 1;

                                    var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                    if (entrys != null)
                                    {
                                        entrys.State = EntityState.Detached;
                                    }
                                    int begin = locRepository.Update(location_36_cp, d => new { d.update_time, d.task }, true);

                                    location_36.update_time = DateTime.Now;
                                    location_36.task = 1;
                                    location_36.logic_col = 1;
                                    var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                    if (entry != null)
                                    {
                                        entry.State = EntityState.Detached;
                                    }
                                    int end = locRepository.Update(location_36, d => new { d.update_time, d.task, d.logic_col }, true);
                                    if (begin == 1 && end == 1)
                                    {
                                        agvRepository.Add(agvtask, true);

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"生成任务:{agvtask.agv_tasknum}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"起点货位【{location_36_cp.upper_code}】状态：托盘光电检测：{location_36_cp.tpgd},状态：{location_36_cp.location_state},更新时间：{location_36_cp.wireless_time}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"终点货位【{location_36.upper_code}】状态：托盘光电检测：{location_36.tpgd},状态：{location_36.location_state},更新时间：{location_36.wireless_time}", $"箔材库任务生成");

                                        //WriteDBLog.Info($"箔材库任务生成").Write($"----------------任务生成成功  {DateTime.Now} -------------- {Environment.NewLine}", $"箔材库任务生成");
                                    }
                                }

                            }
                        }
                        //35入口，供涂布下料
                        var location_35 = freeDB.Select<base_ware_location>().Where(t => t.upper_code == "ZJ-BCHCJ33" && t.location_state == "LocationState_Stored" && t.status == 1 && t.task == 2).First();
                        //35有料立即搬走
                        if (location_35 != null)
                        {
                            if (location_35.location_state == LocationStateEnum.LocationState_Stored.ToString() && location_35.tpgd == 1 && (location_35.logic_row == "TBXL-BCK" || location_35.logic_col == 1))
                            {
                                int index = 0;
                                int b = 7;
                                DateTime time = DateTime.Now;
                                Double STAMP = 0;
                                do
                                {
                                    DateTime time2 = DateTime.Now;
                                    STAMP = (time2 - time).TotalSeconds;
                                    base_ware_location ware_Location = locRepository.FindFirst(d => d.upper_code == location_35.upper_code
                        && d.location_state == LocationStateEnum.LocationState_Stored.ToString() && d.status == 1 && location_35.tpgd == 1 && (location_35.logic_row == "TBXL-BCK" || location_35.logic_col == 1) && d.task == 2);
                                    if (ware_Location == null)
                                    {
                                        index = 3;
                                        break;
                                    }

                                } while (STAMP < b);
                                if (index != 3)
                                {
                                    var location_35_cp = freeDB.Select<base_ware_location>().Where(t => t.location_state == "LocationState_Empty" && t.upper_code.Contains("ZJ-BCHCJ") && t.status == 1 && t.light_color != "SB" && t.task == 2).OrderBy(d => Int32.Parse(d.light_color)).First();
                                    //dt_agvtask task_35 = agvRepository.Find(t => t.agv_fromaddress == "FJ-BCHCJ35" || t.agv_toaddress == "FJ-BCHCJ35").FirstOrDefault();

                                    if (location_35_cp != null)//找到合适货位，生成搬运任务
                                    {
                                        //35货位补料任务
                                        dt_agvtask agvtask = new dt_agvtask();
                                        agvtask.agv_id = Guid.NewGuid();
                                        agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
                                        agvtask.agv_fromaddress = location_35.upper_code;
                                        agvtask.agv_toaddress = location_35_cp.upper_code;
                                        agvtask.agv_code = "正极AGV调度";
                                        agvtask.agv_remark = "正极箔材库搬运(35)";
                                        agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                        agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
                                        agvtask.agv_worktype = 1;//工作类型
                                        agvtask.agv_materielid = "";
                                        agvtask.agv_qty = 1;
                                        agvtask.agv_createtime = DateTime.Now;
                                        agvtask.agv_grade = 0;//任务优先级
                                        agvtask.agv_userid = "WCS";
                                        agvtask.agv_barcode = "";

                                        //锁定首尾货位
                                        location_35_cp.task = 1;
                                        location_35_cp.update_time = DateTime.Now;
                                        //location_35_cp.logic_row = "TBXL-BCK";
                                        var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                        if (entry != null)
                                        {
                                            entry.State = EntityState.Detached;
                                        }
                                        int end = locRepository.Update(location_35_cp, d => new { d.update_time, d.task }, true);

                                        location_35.update_time = DateTime.Now;
                                        location_35.task = 1;
                                        var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                        if (entrys != null)
                                        {
                                            entrys.State = EntityState.Detached;
                                        }
                                        int begin = locRepository.Update(location_35, d => new { d.update_time, d.task }, true);

                                        if (begin == 1 && end == 1)
                                        {
                                            agvRepository.Add(agvtask, true);

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"生成任务:{agvtask.agv_tasknum}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"起点货位【{location_35.upper_code}】状态：托盘光电检测：{location_35.tpgd},状态：{location_35.location_state},更新时间：{location_35.wireless_time}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"终点货位【{location_35_cp.upper_code}】状态：托盘光电检测：{location_35_cp.tpgd},状态：{location_35_cp.location_state},更新时间：{location_35_cp.wireless_time}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"----------------任务生成成功  {DateTime.Now} -------------- {Environment.NewLine}", $"箔材库任务生成");
                                        }
                                    }
                                }
                            }
                        }

                        //37入口，供提升机下料
                        var location_37 = freeDB.Select<base_ware_location>().Where(t => t.upper_code == "ZJ-BCHCJ35" && t.location_state == "LocationState_Stored" && t.status == 1 && t.task == 2).First();
                        //37有料立即搬走
                        if (location_37 != null)
                        {
                            if (location_37.location_state == LocationStateEnum.LocationState_Stored.ToString() && location_37.tpgd == 1 && (location_37.logic_row == "TSJXL-BCK" || location_37.logic_col == 1))
                            {
                                int index = 0;
                                int b = 7;
                                DateTime time = DateTime.Now;
                                Double STAMP = 0;
                                do
                                {
                                    DateTime time2 = DateTime.Now;
                                    STAMP = (time2 - time).TotalSeconds;
                                    base_ware_location ware_Location = locRepository.FindFirst(d => d.upper_code == location_37.upper_code
                        && d.location_state == LocationStateEnum.LocationState_Stored.ToString() && location_37.tpgd == 1 && d.status == 1 && (location_37.logic_row == "TSJXL-BCK" || location_37.logic_col == 1) && d.task == 2);
                                    if (ware_Location == null)
                                    {
                                        index = 3;
                                        break;
                                    }

                                } while (STAMP < b);
                                if (index != 3)
                                {
                                    var location_37_cp = freeDB.Select<base_ware_location>().Where(t => t.location_state == "LocationState_Empty" && t.upper_code.Contains("ZJ-BCHCJ") && t.status == 1 && t.light_color != "SB" && t.task == 2).OrderBy(d => Int32.Parse(d.light_color)).First();
                                    //dt_agvtask task_37 = agvRepository.Find(t => t.agv_fromaddress == "FJ-BCHCJ37" || t.agv_toaddress == "FJ-BCHCJ37").FirstOrDefault();
                                    if (location_37_cp != null)//找到合适货位，生成搬运任务
                                    {
                                        //36货位补料任务
                                        dt_agvtask agvtask = new dt_agvtask();
                                        agvtask.agv_id = Guid.NewGuid();
                                        agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
                                        agvtask.agv_fromaddress = location_37.upper_code;
                                        agvtask.agv_toaddress = location_37_cp.upper_code;
                                        agvtask.agv_code = "正极AGV调度";
                                        agvtask.agv_remark = "正极箔材库搬运(37)";
                                        agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                        agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
                                        agvtask.agv_worktype = 1;//工作类型
                                        agvtask.agv_materielid = "";
                                        agvtask.agv_qty = 1;
                                        agvtask.agv_createtime = DateTime.Now;
                                        agvtask.agv_grade = 0;//任务优先级
                                        agvtask.agv_userid = "WCS";
                                        agvtask.agv_barcode = "";

                                        //锁定首尾货位
                                        location_37_cp.task = 1;
                                        location_37_cp.update_time = DateTime.Now;
                                        //location_37_cp.logic_row = "TSJXL-BCK";
                                        var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                        if (entry != null)
                                        {
                                            entry.State = EntityState.Detached;
                                        }
                                        int end = locRepository.Update(location_37_cp, d => new { d.task, d.update_time }, true);

                                        location_37.task = 1;
                                        location_37.update_time = DateTime.Now;
                                        var entrys = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                        if (entrys != null)
                                        {
                                            entrys.State = EntityState.Detached;
                                        }
                                        int begin = locRepository.Update(location_37, d => new { d.task, d.update_time }, true);



                                        if (begin == 1 && end == 1)
                                        {
                                            agvRepository.Add(agvtask, true);

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"生成任务:{agvtask.agv_tasknum}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"起点货位【{location_37.upper_code}】状态：托盘光电检测：{location_37.tpgd},状态：{location_37.location_state},更新时间：{location_37.wireless_time}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"终点货位【{location_37_cp.upper_code}】状态：托盘光电检测：{location_37_cp.tpgd},状态：{location_37_cp.location_state},更新时间：{location_37_cp.wireless_time}", $"箔材库任务生成");

                                            //WriteDBLog.Info($"箔材库任务生成").Write($"----------------任务生成成功  {DateTime.Now} -------------- {Environment.NewLine}", $"箔材库任务生成");
                                        }
                                    }
                                }


                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        WriteLog.GetLog().Write($"箔材库任务生成：{DateTime.Now} --------------{ex}", $"箔材库任务生成");
                    }
                    finally
                    {

                        Interlocked.Exchange(ref _readZBCKSignalsoZ, 0);
                    }
                });
                
            }
        }

    }
}