using HslCommunication;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Common.LoctionEnum;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS
{
    public partial class StackerExecutor
    {
        public static object requestZJGFUP = new object();//requestZJJK
        private static int _readGFBUPSignalsoZ = 0;//_readZTBUPSignalso
        /// <summary>
        /// 正极辊分上料工作逻辑
        /// </summary>
        /// <param name="client"></param>
        public static void Z_GFSB_UpTask()
        {
            if (Interlocked.Exchange(ref _readGFBUPSignalsoZ, 1) == 0)
            {
                Task.Run(() =>
                {
                    try
                    {
                        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);
                        List<string> TBSBS = new List<string> { "辊分机正极1", "辊分机正极2", "辊分机正极3", "辊分机正极4" };

                        foreach (var TBSB in TBSBS)
                        {
                            //string SBID = TBSB.Replace("辊分机正极", "");//设备号
                            PLCClient plc = WCSService.Clients.Find(v => v.PLCName == TBSB);
                            if (plc == null)
                            {
                                //WriteLog.GetLog("GFZ上料呼叫").Write($"设备：{TBSB} 内容：未连接PLC  时间记录:{DateTime.Now}", "GFZ上料呼叫");
                                continue;
                            }
                            //当前设备有没有上料请求
                            //bool GYR_RFX = Convert.ToBoolean(plc.ReadValue("R_Feedingrequest".ToString(), plc.EquipType));
                            //if (GYR_RFX)

                            OperateResult<bool> GYR_RFX = plc.MelsecPLCClient.MelsecMcNetClient.ReadBool("D5493.0");
                            Int16 tf = Convert.ToInt16(GYR_RFX.Content);
                            if (GYR_RFX.Content)
                            {
                                //查看当前辊分机设备是否有AGV任务
                                var SBtask = agvRepository.FindFirst(f => f.agv_toaddress == plc.EquipType);
                                //有结束本次循环
                                if (SBtask != null) { continue; }
                                #region 记录上料请求信号
                                WriteLog.GetLog().Write($"{plc.PLCName}上料请求：{GYR_RFX.Content}---{DateTime.Now}", $"正极棍分上料请求");
                                #endregion
                                List<base_routing_table> Routing_Table = routingRepository.Find(d => d.route_end == plc.EquipType);
                                List<base_ware_location> loctionList = new List<base_ware_location>();
                                foreach (var item in Routing_Table)
                                {
                                    base_ware_location ware_Locations = locRepository.FindFirst(d => d.upper_code == item.route_began && d.status == 1 && d.location_state == LoctionStateEnum.LocationState_Stored.ToString() && d.logic_col == 1 && d.task == 2);
                                    if (ware_Locations == null)
                                    {
                                        continue;
                                    }
                                    loctionList.Add(ware_Locations);
                                }

                                if (loctionList.Count != 0)
                                {
                                    base_ware_location Location = loctionList.OrderBy(d => d.update_time).FirstOrDefault();


                                    //生成辊分机上料任务
                                    dt_agvtask agvtask = new dt_agvtask()
                                    {
                                        agv_id = Guid.NewGuid(),
                                        agv_tasknum = "KH-" + IdenxManager.GetTaskNo(),
                                        agv_fromaddress = Location.upper_code,
                                        agv_toaddress = plc.EquipType,
                                        agv_code = "正极AGV调度",
                                        agv_remark = "辊分上料任务",
                                        agv_taskstate = AGVTaskStateEnum.Create.ToString(),
                                        agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString(),
                                        agv_worktype = 1,//工作类型
                                        agv_materielid = "",
                                        agv_qty = 1,
                                        agv_createtime = DateTime.Now,
                                        agv_grade = 0,//任务优先级
                                        agv_userid = "WCS",
                                        agv_barcode = "",
                                    };


                                    //Location.update_time = DateTime.Now;

                                    Location.task = 1;
                                    Location.logic_col = 1;
                                    var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
                                    if (entry != null)
                                    {
                                        entry.State = EntityState.Detached;
                                    }
                                    int a = locRepository.Update(Location, d => new { d.task, d.logic_col }, true);
                                    if (a == 1)
                                    {
                                        agvRepository.Add(agvtask, true);
                                        //WriteDBLog.Info($"【{TBSB}】上料任务生成").Write($"生成任务:{agvtask.agv_tasknum},起点货位状态：托盘光电检测：{Location.tpgd},状态：{Location.location_state},更新时间：{Location.wireless_time}", $"【{TBSB}】上料任务生成");
                                        //WriteDBLog.Info($"【{TBSB}】上料任务生成").Write($"----------------任务生成成功  {DateTime.Now} -------------- {Environment.NewLine}", $"【{TBSB}】上料任务生成");
                                    }

                                }


                            }

                        }
                    }
                    catch (Exception ex)
                    {
                        WriteLog.GetLog().Write($"正极棍分上料：{DateTime.Now} --------------{ex}", $"正极棍分上料");
                    }
                    finally
                    {
                        Interlocked.Exchange(ref _readGFBUPSignalsoZ, 0);
                    }
                });
                
            }
        }

    }
}