using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.IRepositories;
using WIDESEA_WCS.Jobs;
using WIDESEA_WCS.WCSClient;
using static System.Collections.Specialized.BitVector32;
using System.Threading;
using Microsoft.EntityFrameworkCore;
using Newtonsoft.Json;
using WIDESEA_Core.Extensions;
using HslCommunication;
using WIDESEA_Services;
using WIDESEA_Core.Utilities;
using WIDESEA_Services.Services;
using WIDESEA_Common.TaskEnum;
using WIDESEA_WCS.Jobs.ConveyorLine;
using WIDESEA_Common.LogEnum;
using WIDESEA_Common.Tools;
using WIDESEA_WCS.Jobs.ConveyorLine.InboundArea;
using WIDESEA_WCS.Jobs.ConveyorLine.OutboundArea;

namespace WIDESEA_WCS
{
    [DisallowConcurrentExecution]
    public class ConveyorLineDispatchJob : JobBase, IJob
    {
        /// <summary>
        /// 获取输送线信息
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(() =>
            {
                var executeLog = ExecuteJob(context, () => Run(context));
            });
        }


        public string Run(IJobExecutionContext context)
        {

            using (VOLContext dbCcontext = new VOLContext())
            {
                IDt_PLCinfoHeadRepository _PLCinfoHeadRepository = new Dt_PLCinfoHeadRepository(dbCcontext);
                IDt_StationManagerRepository stationManagerRepository = new Dt_StationManagerRepository(dbCcontext);
                List<Dt_PLCinfoHead> _PLCinfoHeads = _PLCinfoHeadRepository.Find(r => r.plcinfo_equiptype == "ConveyorLine" && r.plcinfo_state == "Enable");
                IDt_TaskWCSinfoRepository taskWCSinfoRepository = new Dt_TaskWCSinfoRepository(dbCcontext);
                IDt_TaskRGVinfoRepository taskRGVinfoRepository = new Dt_TaskRGVinfoRepository(dbCcontext);
                if (null != _PLCinfoHeads)
                {
                    PLCClient client = WCSService.Clients.Find(r => r.PLCName == "LineDevice");
                    if (null == client || !client.IsConnected)
                    {
                        string str = "PLC: " + client.PLCName + ", Ip: " + client.PLCIPAddress + ", 与调度系统断开连接";
                        WriteLog.Info("PLC异常").Write(str, "PLC异常");
                        return "";
                    }
                    //说明是入库区的调度，查看入库区线体的运行模式                    
                    int modelResult = int.Parse(client.ReadValue(CLineInfoDBName.R_System_Inline_Run_Model.ToString(), "System").ToString());
                    if (modelResult == 3)
                    {
                        //1=手动  2=单机 3=联机
                        //入库申请站台调度 20101
                        bool modelResult1 = bool.Parse(client.ReadValue(CLineInfoDBName.R_System_Normal_Model.ToString(), "System").ToString());
                        if (modelResult1)
                        {
                            //入库口
                            InboundAreaDispatch.InboundRequestStationAction(taskWCSinfoRepository, client, "InBound");
                            //测量站台逻辑  10301
                            InboundAreaDispatch.MeasureStationAction(taskWCSinfoRepository, client, "Measure_B");
                            //入库站台确认
                            InboundAreaDispatch.InboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);

                            //出库站台确认
                            InboundAreaDispatch.OutboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                        }
                        else
                        {
                            //应急模式
                            modelResult1 = bool.Parse(client.ReadValue(CLineInfoDBName.R_System_Emery_Model.ToString(), "System").ToString());
                            if (modelResult1)
                            {
                                //左侧可用
                                modelResult1 = bool.Parse(client.ReadValue(CLineInfoDBName.R_System_LeftState.ToString(), "System").ToString());
                                if (!modelResult1)
                                {
                                    //入库站台确认
                                    InboundAreaDispatch.InboundStationAction_YJ(taskWCSinfoRepository, taskRGVinfoRepository, client, true);
                                    //出库站台确认
                                    InboundAreaDispatch.OutboundStationAction_YJ(taskWCSinfoRepository, taskRGVinfoRepository, client, true);

                                    InboundAreaDispatch.MeasureStationAction(taskWCSinfoRepository, client, "Measure_B_YJ");

                                    InboundAreaDispatch.InboundRequestStationAction(taskWCSinfoRepository, client, "InBound_YJ");
                                }
                                else
                                {
                                    //右侧可用
                                    modelResult1 = bool.Parse(client.ReadValue(CLineInfoDBName.R_System_RightState.ToString(), "System").ToString());
                                    if (!modelResult1)
                                    {
                                        InboundAreaDispatch.InboundStationAction_YJ(taskWCSinfoRepository, taskRGVinfoRepository, client, false);

                                        //出库站台确认
                                        InboundAreaDispatch.OutboundStationAction_YJ(taskWCSinfoRepository, taskRGVinfoRepository, client, false);

                                        InboundAreaDispatch.MeasureStationAction(taskWCSinfoRepository, client, "Measure_B");

                                        InboundAreaDispatch.InboundRequestStationAction(taskWCSinfoRepository, client, "InBound");
                                    }
                                }
                            }
                        }

                        //InboundAreaDispatch.InboundRequestStationAction(taskWCSinfoRepository, client, "InBound");
                        ////测量站台逻辑  10301
                        //InboundAreaDispatch.MeasureStationAction(taskWCSinfoRepository, client, "Measure_B");
                        ////入库站台确认
                        //InboundAreaDispatch.InboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                        ////出库站台确认
                        //InboundAreaDispatch.OutboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);

                        //称重站台调度 20201
                        InboundAreaDispatch.InboundWeighAction(taskWCSinfoRepository, client);
                        //出库RFID确认(测量)
                        InboundAreaDispatch.CheckBarcodeAction(taskWCSinfoRepository, client, "30301");
                        InboundAreaDispatch.CheckBarcodeAction(taskWCSinfoRepository, client, "30302");

                    }
                    //说明是出库区的调度，查看入库区线体的运行模式                    
                    modelResult = int.Parse(client.ReadValue(CLineInfoDBName.R_System_Inline_Run_Model.ToString(), "OutSystem").ToString());

                    //string rel = client.ReadValue(CLineInfoDBName.W_System_RGVState.ToString()).ToString();
                    if (modelResult == 3)
                    {
                        //出库区域调度
                        OutboundAreaDispatch.OutboundAreaDispathAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                    }
                    else if (modelResult == 2)
                    {
                        client.WriteValue(CLineInfoDBName.W_System_RGVState.ToString(), true);
                    }
                }

            }
            return "";
        }
    }
}