MainRepositories/InfrastructureWCS.git

			@@ -15,13 +15,17 @@
			----------------------------------------------------------------/
			#endregion << 版本注释 >>

			using AutoMapper;
			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;
			using WIDESEAWCS_Core.Helper;
			using WIDESEAWCS_IBasicInfoService;
			using WIDESEAWCS_ITaskInfoService;
			using WIDESEAWCS_Model.Models;
			using WIDESEAWCS_QuartzJob;
			@@ -35,11 +39,15 @@
			{
			private readonly ITaskService _taskService;
			private readonly ITaskExecuteDetailService _taskExecuteDetailService;
			private readonly IRouterService _routerService;
			private readonly IMapper _mapper;

			public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService)
			public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper)
			{
			_taskService = taskService;
			_taskExecuteDetailService = taskExecuteDetailService;
			_routerService = routerService;
			_mapper = mapper;
			}

			public Task Execute(IJobExecutionContext context)
			@@ -47,83 +55,114 @@
			try
			{
			CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
			// List<Dt_StationManager> stationManagers = _stationManagerService.GetStationManagers();
			// foreach (var item in stationManagers)
			// {
			// try
			// {
			// ushort value = conveyorLine.GetValue<ConveyorLineDBName, ushort>(ConveyorLineDBName.InteractiveSignal, item.StationCode);
			if (conveyorLine != null)
			{
			List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);

			// DeviceProtocolDetailDTO? deviceProtocolDetail = conveyorLine.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.ProtocalDetailValue == value.ToString());
			foreach (string childDeviceCode in childDeviceCodes)
			{
			ConveyorLineTaskCommand command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(childDeviceCode);
			if (command != null)
			{
			List<int> signalTypes = Enum.GetValues(typeof(PLCSignalType)).Cast<int>().ToList();
			if (!signalTypes.Contains(command.InteractiveSignal))
			{
			continue;
			}

			// if (deviceProtocolDetail != null)
			// {
			// ConveyorLineTaskCommand? command = new ConveyorLineTaskCommand()
			// {
			// InteractiveSignal = 0,
			// Barcode = "",
			// TargetAddress = Convert.ToInt32(item.DeviceCode),
			// TaskNum = 9988,
			// TrayType = 3
			// };
			DeviceProtocolDetailDTO? deviceProtocolDetail = conveyorLine.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.ProtocalDetailValue == command.InteractiveSignal.ToString() && x.DeviceProParamName == nameof(ConveyorLineTaskCommand.InteractiveSignal));
			if (deviceProtocolDetail != null)
			{
			PLCSignalType signalType = Enum.Parse<PLCSignalType>(deviceProtocolDetail.ProtocolDetailType);
			switch (signalType)
			{
			case PLCSignalType.RequestInbound:
			{
			if (_taskService.RequestWMsTask(command.Barcode, childDeviceCode).Status)
			{
			Dt_Task task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			if (task != null)
			{
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			bool t = conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// SignalType signalType = Enum.Parse<SignalType>(deviceProtocolDetail.ProtocolDetailType);
			// switch (signalType)
			// {
			// case SignalType.InEntranceRequest:
			// command.Barcode = "InEntranceRequest";
			// break;
			// case SignalType.InEntranceResponse:
			// command.Barcode = "InEntranceResponse";
			// break;
			// case SignalType.InEntranceRequestReset:
			// command.Barcode = "InEntranceRequestReset";
			// break;
			// case SignalType.OutEntranceRequest:
			// command.Barcode = "OutEntranceRequest";
			// break;
			// case SignalType.OutEntranceResponse:
			// command.Barcode = "OutEntranceResponse";
			// break;
			// case SignalType.OutEntranceRequestReset:
			// command.Barcode = "OutEntranceRequestReset";
			// break;
			// case SignalType.InStationRequest:
			// command.Barcode = "InStationRequest";
			// break;
			// case SignalType.InStationResponse:
			// command.Barcode = "InStationResponse";
			// break;
			// case SignalType.InStationRequestReset:
			// command.Barcode = "InStationRequestReset";
			// break;
			// case SignalType.OutStationRequest:
			// command.Barcode = "OutStationRequest";
			// break;
			// case SignalType.OutStationResponse:
			// command.Barcode = "OutStationResponse";
			// break;
			// case SignalType.OutStationRequestReset:
			// command.Barcode = "OutStationRequestReset";
			// break;
			// default:
			// command = null;
			// break;
			// }
			// if (command != null)
			// {
			// conveyorLine.SendCommand(command, item.StationCode);
			// Console.Out.WriteLine(command.Serialize());
			// }
			_taskService.UpdateTaskStatusToNext(task.TaskNum);
			}
			}
			}
			break;
			case PLCSignalType.RequestInNextAddress:
			{
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress);
			if (newTask != null)
			{
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(newTask);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			bool t = conveyorLine.SendCommand(taskCommand, childDeviceCode);
			}
			}
			}
			break;
			case PLCSignalType.ConveyorLineInFinish:
			{
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			bool t = conveyorLine.SetValue(ConveyorLineDBName.WriteInteractiveSignal, 0, childDeviceCode);
			WebResponseContent content = _taskService.UpdateTaskStatusToNext(task.TaskNum);
			Console.Out.WriteLine(content.Serialize());
			}
			}
			break;
			case PLCSignalType.RequestOutbound:
			{
			Dt_Task task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			if (task != null)
			{
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			bool t = conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// }
			_taskService.UpdateTaskStatusToNext(task.TaskNum);
			}
			}
			break;
			case PLCSignalType.RequestOutNextAddress:
			{
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress);
			if (newTask != null)
			{
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(newTask);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			bool t = conveyorLine.SendCommand(taskCommand, childDeviceCode);
			}
			}
			}
			break;
			case PLCSignalType.ConveyorLineOutFinish:
			{
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			bool t = conveyorLine.SetValue(ConveyorLineDBName.WriteInteractiveSignal, 0, childDeviceCode);
			WebResponseContent content = _taskService.UpdateTaskStatusToNext(task.TaskNum);
			Console.Out.WriteLine(content.Serialize());
			}
			}
			break;
			}
			}
			}
			}
			}

			// }
			// catch (Exception ex)
			// {
			// Console.Out.WriteLine(item.StationCode + ":" + ex.ToString());
			// }
			// }
			}
			catch (Exception ex)
			{