xiaojiao
2026-03-26 02dd21ca9a064b98aacfdc8c6ffec5a2b575967d
项目代码/WCS/WIDESEA_WCSServer/WIDESEA_WCS/Jobs/ConveyorLine/ConveyorLineDispatchJob.cs
@@ -1,30 +1,31 @@
锘縰sing Quartz;
锘縰sing HslCommunication;
using Microsoft.EntityFrameworkCore;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
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.TaskEnum;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.Extensions;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.Jobs;
using WIDESEA_WCS.Jobs.ConveyorLine;
using WIDESEA_WCS.Jobs.ConveyorLine.InboundArea;
using WIDESEA_WCS.Jobs.ConveyorLine.OutboundArea;
using WIDESEA_WCS.WCSClient;
using static System.Collections.Specialized.BitVector32;
namespace WIDESEA_WCS
{
@@ -47,10 +48,8 @@
        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");
@@ -80,7 +79,6 @@
                            InboundAreaDispatch.MeasureStationAction(taskWCSinfoRepository, client, "Measure_B");
                            //鍏ュ簱绔欏彴纭
                            InboundAreaDispatch.InboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                            //鍑哄簱绔欏彴纭
                            InboundAreaDispatch.OutboundStationAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                        }
@@ -145,6 +143,7 @@
                    {
                        //鍑哄簱鍖哄煙璋冨害
                        OutboundAreaDispatch.OutboundAreaDispathAction(taskWCSinfoRepository, taskRGVinfoRepository, client);
                        OutboundAreaDispatch.OutboundAreaJZ(taskWCSinfoRepository, taskRGVinfoRepository, client); // 鍑哄簱鍖哄煙鏍″噯
                    }
                    else if (modelResult == 2)
                    {