using Furion.JsonSerialization;
using Microsoft.CodeAnalysis;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using Quartz;
using System;
using System.Collections.Generic;
using System.IO;
using System.Runtime.Serialization.Json;
using System.Security.Policy;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using WIDESEA_Common.Tools;
using WIDESEA_Entity.DomainModels.Equipment;
using WIDESEA_Services.Services;
using WIDESEA_WCS.Jobs;
using WIDESEA_WCS.JobsPart.AGV;
using WIDESEA_WCS.SchedulerExecute.AGV;
using WIDESEA_WCS.WCSClient;
using static FreeSql.Internal.GlobalFilter;

namespace WIDESEA_WCS
{
    /// <summary>
    /// AGV调度
    /// </summary>
    [DisallowConcurrentExecution]
    public class AGVUpdateStatusJob : JobBase, IJob
    {
        private static int lockObj1 = 0;
        public Task Execute(IJobExecutionContext context)
        {
            try
            {
                ExecuteJob(context, DoAction);
            }
            catch { }
            return Task.FromResult(string.Empty);
        }
        private void DoAction(IJobExecutionContext context)
        {
            if (lockObj1 == 0)
            {
                try
                {
                    lockObj1 = 1;
                    Task task = Task.Run(() =>
                    {
                        List<string> AGVS = new List<string> { "组装AGV调度", "正极AGV调度", "负极AGV调度" };
                        while (true) 
                        {
                            foreach (var item in AGVS)
                            {
                                PLCClient pLCClient = WCSService.Clients.Find(v => v.PLCName == item);
                                if (pLCClient == null)
                                {
                                    continue;
                                }
                                AGVSchedulerExecute.UpdateAgvTaskText(pLCClient);
                            }
                            Thread.Sleep(200);
                        }
                    });
                }
                catch (Exception ex)
                {
                    lockObj1 = 0;
                    throw new Exception(ex.Message);
                }
            }

        }
    }
}