#region << 版 本 注 释 >> /*---------------------------------------------------------------- * 命名空间:WIDESEAWCS_Tasks.ConveyorLineJob * 创建者:胡童庆 * 创建时间:2024/8/2 16:13:36 * 版本:V1.0.0 * 描述: * * ---------------------------------------------------------------- * 修改人: * 修改时间: * 版本:V1.0.1 * 修改说明: * *----------------------------------------------------------------*/ #endregion << 版 本 注 释 >> using OfficeOpenXml.FormulaParsing.Excel.Functions.Text; using Quartz; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEAWCS_Core.Helper; using WIDESEAWCS_IBasicInfoService; using WIDESEAWCS_ITaskInfoService; using WIDESEAWCS_Model.Models; using WIDESEAWCS_QuartzJob; using WIDESEAWCS_QuartzJob.DTO; using WIDESEAWCS_Tasks.ConveyorLineJob; namespace WIDESEAWCS_Tasks { [DisallowConcurrentExecution] public class CommonConveyorLineJob : IJob { private readonly ITaskService _taskService; private readonly ITaskExecuteDetailService _taskExecuteDetailService; private readonly IRouterService _routerService; public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService) { _taskService = taskService; _taskExecuteDetailService = taskExecuteDetailService; _routerService = routerService; } public Task Execute(IJobExecutionContext context) { try { CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams"); //if (conveyorLine != null) //{ // List childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode); // foreach (string childDeviceCode in childDeviceCodes) // { // ConveyorLineTaskCommand command = conveyorLine.ReadCustomer(childDeviceCode); // if (command != null) // { // DeviceProtocolDetailDTO? deviceProtocolDetail = conveyorLine.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.ProtocalDetailValue == command.InteractiveSignal.ToString()); // if (deviceProtocolDetail != null) // { // SignalType signalType = Enum.Parse(deviceProtocolDetail.ProtocolDetailType); // switch (signalType) // { // case SignalType.InEntranceRequest: // break; // case SignalType.InEntranceRequestReset: // break; // case SignalType.OutEntranceRequest: // break; // case SignalType.OutEntranceRequestReset: // break; // case SignalType.InStationRequest: // break; // case SignalType.InStationRequestReset: // break; // case SignalType.OutStationRequest: // break; // case SignalType.OutStationRequestReset: // break; // default: // break; // } // } // } // } //} } catch (Exception ex) { Console.Out.WriteLine(nameof(CommonConveyorLineJob) + ":" + ex.ToString()); } return Task.CompletedTask; } } }