#region << 版 本 注 释 >>

/*----------------------------------------------------------------
 * 命名空间：WIDESEAWCS_Tasks.ConveyorLineJob
 * 创建者：胡童庆
 * 创建时间：2024/8/2 16:13:36
 * 版本：V1.0.0
 * 描述：
 *
 * ----------------------------------------------------------------
 * 修改人：
 * 修改时间：
 * 版本：V1.0.1
 * 修改说明：
 *
 *----------------------------------------------------------------*/

#endregion << 版 本 注 释 >>

using AutoMapper;
using HslCommunication;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using Quartz;
using SqlSugar;
using System.Net;
using System.Reflection;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_BasicInfoService;
using WIDESEAWCS_Common;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_Core.HttpContextUser;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_ISystemServices;
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.DTO;
using WIDESEAWCS_QuartzJob.Service;
using WIDESEAWCS_SignalR;
using WIDESEAWCS_Tasks.ConveyorLineJob;
using WIDESEAWCS_Tasks.StackerCraneJob;
using static Microsoft.EntityFrameworkCore.DbLoggerCategory.Database;
using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;

namespace WIDESEAWCS_Tasks
{
    [DisallowConcurrentExecution]
    public class CommonConveyorLineTTJob : JobBase, IJob
    {
        private readonly ITaskService _taskService;
        private readonly ITaskRepository _taskRepository;
        private readonly ITaskExecuteDetailService _taskExecuteDetailService;
        private readonly IRouterService _routerService;
        private readonly IMapper _mapper;
        private readonly IDt_StationManagerService _stationManagerService;
        private readonly ISys_ConfigService _sys_ConfigService;
        private readonly ICacheService _cacheService;
        private readonly INoticeService _noticeService;
        private readonly IDt_needBarcodeRepository _needBarcodeRepository;
        private readonly IDt_StationManagerRepository _stationManagerRepository;
        private static List<string>? userTokenIds;
        private static List<int>? userIds;

        public CommonConveyorLineTTJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IDt_StationManagerService stationManagerService, ISys_ConfigService sys_ConfigService, ICacheService cacheService, INoticeService noticeService, IDt_needBarcodeRepository needBarcodeRepository, IDt_StationManagerRepository stationManagerRepository)
        {
            _taskService = taskService;
            _taskExecuteDetailService = taskExecuteDetailService;
            _routerService = routerService;
            _mapper = mapper;
            _taskRepository = taskRepository;
            _stationManagerService = stationManagerService;
            _sys_ConfigService = sys_ConfigService;
            _cacheService = cacheService;
            _noticeService = noticeService;
            _needBarcodeRepository = needBarcodeRepository;
            _stationManagerRepository = stationManagerRepository;
        }

        static Dictionary<string, string> TCRoadWay = new Dictionary<string, string>()
        {
             { "TC05", "SC02-SC04" },
             { "TC06", "SC06-SC08" },
        };

        public async Task Execute(IJobExecutionContext context)
        {
            try
            {
                CommonConveyorLineTT conveyorLine = (CommonConveyorLineTT)context.JobDetail.JobDataMap.Get("JobParams");
                if (conveyorLine != null)
                {
                    List<Dt_StationManager> stationManagers = _stationManagerService.GetAllStationByDeviceCode(conveyorLine.DeviceCode);

                    foreach (var station in stationManagers)
                    {
                        var Getrequest = conveyorLine.GetValue<ConveyorLineDBName, bool>(ConveyorLineDBName.Spare1, station.stationChildCode);//横移机空车取料信号
                        if (Getrequest)
                        {
                            Dt_Task task = null;
                            if (station.stationChildCode == "TC05")
                            {
                                //var executeTaks =  _taskRepository.QueryData(x => (x.Roadway == "SC02" || x.Roadway == "SC04") && x.TaskState <= (int)TaskOutStatusEnum.SC_OutFinish).OrderBy(x => x.CreateDate).FirstOrDefault();

                                var leftTask = _taskRepository.QueryData(x => (x.Roadway == "SC02" || x.Roadway == "SC04") && x.TaskState <= (int)TaskOutStatusEnum.SC_OutFinish).OrderBy(x => x.CreateDate).FirstOrDefault();

                                if (leftTask != null && leftTask.TaskState == (int)TaskOutStatusEnum.SC_OutFinish)
                                {
                                    task = leftTask;
                                }

                                if (task != null)
                                {
                                    _taskService.UpdateTaskStatusToNext(task.TaskNum, (int)TaskOutStatusEnum.SC_OutFinish);

                                    var sattion = _stationManagerRepository.QueryFirst(x => x.stationChildCode == task.CurrentAddress);
                                    WriteDebug("CommonConveyorLineTTJob任务", $"任务：{task.Serialize()}，站台信息：{sattion.Serialize()}");
                                    conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.GetConvNo, Convert.ToInt16(sattion.stationTCLocation), station.stationChildCode);
                                    conveyorLine.SetValue<ConveyorLineDBName, string>(ConveyorLineDBName.PVI_W, task.PVI, station.stationChildCode);
                                    //conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.AllowRelease, 1, station.stationChildCode);
                                }
                            }
                            else if (station.stationChildCode == "TC06")
                            {
                                var rightTask = _taskRepository.QueryData(x => (x.Roadway == "SC06" || x.Roadway == "SC08") && x.TaskState <= (int)TaskOutStatusEnum.SC_OutFinish).OrderBy(x => x.CreateDate).FirstOrDefault();

                                if (rightTask != null && rightTask.TaskState == (int)TaskOutStatusEnum.SC_OutFinish)
                                {
                                    task = rightTask;
                                }

                                if (task != null)
                                {
                                    _taskService.UpdateTaskStatusToNext(task.TaskNum, (int)TaskOutStatusEnum.SC_OutFinish);

                                    var sattion = _stationManagerRepository.QueryFirst(x => x.stationChildCode == task.CurrentAddress);
                                    WriteDebug("CommonConveyorLineTTJob任务", $"任务：{task.Serialize()}，站台信息：{sattion.Serialize()}");
                                    conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.GetConvNo, Convert.ToInt16(sattion.stationTCLocation), station.stationChildCode);
                                    conveyorLine.SetValue<ConveyorLineDBName, string>(ConveyorLineDBName.PVI_W, task.PVI, station.stationChildCode);
                                    //conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.AllowRelease, 1, station.stationChildCode);
                                }
                            }
                        }

                        var Putrequest = conveyorLine.GetValue<ConveyorLineDBName, bool>(ConveyorLineDBName.Spare2, station.stationChildCode);//横移机载货放车信号
                        if (Putrequest)
                        {
                            //conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.AllowRelease, 1, station.stationChildCode);
                            //todo:请求WMS是否是精排队列首辆车  如不是 不可放行
                            string fristPVI = conveyorLine.GetValue<ConveyorLineDBName, string>(ConveyorLineDBName.PVI_W, station.stationChildCode);
                            if (!String.IsNullOrEmpty(fristPVI))
                            {
                                if (station.stationChildCode == "TC05")
                                {
                                    var task = _taskRepository.QueryData(X => X.TargetAddress == "RB043" && (X.NextAddress == station.stationChildCode && X.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting/*|| X.CurrentAddress == station.stationChildCode*/)).OrderBy(x => x.CreateDate).FirstOrDefault();

                                    if (task != null)
                                    {
                                        _taskService.UpdatePosition(task.TaskNum, station.stationChildCode);
                                        conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.AllowRelease, 1, station.stationChildCode);
                                    }
                                }
                                else
                                {
                                    var task = _taskRepository.QueryData(X => X.TargetAddress == "RB043").OrderBy(x => x.CreateDate).FirstOrDefault();
                                    if (task != null && task.PVI == fristPVI)
                                    {
                                        _taskService.UpdatePosition(task.TaskNum, station.stationChildCode);
                                        conveyorLine.SetValue<ConveyorLineDBName, Int16>(ConveyorLineDBName.AllowRelease, 1, station.stationChildCode);
                                    }
                                }
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                Console.Out.WriteLine(nameof(CommonConveyorLineTTJob) + ":" + ex.ToString());
            }
            finally
            {
                //WriteDebug("CommonConveyorLineTTJob", "test");
                //Console.Out.WriteLine(DateTime.Now);
            }
            return;
        }
    }
}