SuZhouGuanHong/ShanMeiXinNengYuan.git

			@@ -4,7 +4,6 @@
			using Newtonsoft.Json;
			using Quartz;
			using SqlSugar;
			using System.Text.Json;
			using WIDESEA_Core;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Core;
			@@ -15,6 +14,7 @@
			using WIDESEAWCS_Model.Models;
			using WIDESEAWCS_QuartzJob;
			using WIDESEAWCS_QuartzJob.Service;
			using ManualInboundTaskHandler = WIDESEAWCS_Tasks.ConveyorLineNewJob.ManualInbound.ManualInboundTaskHandler;

			namespace WIDESEAWCS_Tasks
			{
			@@ -78,6 +78,13 @@
			private readonly ILogger<CommonConveyorLineNewJob> _logger;

			/// <summary>
			/// 目标地址到设备类型的映射
			/// </summary>
			/// <remarks>
			/// </remarks>
			private static List<string> AddressToDeviceType = new List<string> { "11020", "11028" };

			/// <summary>
			/// 构造函数
			/// </summary>
			/// <param name="taskService">任务服务</param>
			@@ -138,8 +145,8 @@
			// MaxDegreeOfParallelism = Math.Min(childDeviceCodes.Count, Environment.ProcessorCount * 2),
			//};

			_logger.LogDebug("Execute：开始并行处理输送线 {DeviceCode}，子设备数量: {Count}", conveyorLine.DeviceCode, childDeviceCodes.Count);
			QuartzLogger.Debug($"开始并行处理输送线，子设备数量: {childDeviceCodes.Count}", conveyorLine.DeviceCode);
			//_logger.LogDebug("Execute：开始并行处理输送线 {DeviceCode}，子设备数量: {Count}", conveyorLine.DeviceCode, childDeviceCodes.Count);
			//QuartzLogger.Debug($"开始并行处理输送线，子设备数量: {childDeviceCodes.Count}", conveyorLine.DeviceCode);

			// 并行处理每个子设备
			//Parallel.For(0, childDeviceCodes.Count, parallelOptions, i =>
			@@ -157,12 +164,10 @@
			{
			_logger.LogDebug("Execute：子设备 {ChildDeviceCode} 命令为空，跳过", childDeviceCode);
			QuartzLogger.Debug($"子设备 {childDeviceCode} 命令为空，跳过", conveyorLine.DeviceCode);
			return Task.CompletedTask;
			continue;
			}

			// 如果 WCS_ACK 为 1，先清除（表示处理过上一次请求）
			if (command.WCS_ACK == 1)
			conveyorLine.SetValue(ConveyorLineDBNameNew.WCS_ACK, 0, childDeviceCode);
			#region 检测是否需要空托盘

			// ========== 检查特定位置是否有托盘 ==========
			// 从配置中读取需要检查托盘的位置列表
			@@ -173,7 +178,7 @@
			if (checkPalletPositions.Any(x => x.Code == childDeviceCode))
			{
			// 检查输送线状态（是否有托盘）
			if (command.CV_State == 1)
			if (command.CV_State == 2)
			{
			// 检查该位置是否已有任务
			var existingTask = _taskService.Db.Queryable<Dt_Task>().First(x => x.TargetAddress == childDeviceCode);
			@@ -202,13 +207,32 @@
			}
			}

			#endregion

			// ========== 检查 PLC_STB 标志 ==========
			// 只有当 PLC_STB 为 1 时才处理任务
			if (command.PLC_STB != 1)
			{
			//_logger.LogDebug("Execute：子设备 {ChildDeviceCode} PLC_STB 不为1，跳过", childDeviceCode);
			//QuartzLogger.Debug($"子设备 {childDeviceCode} PLC_STB 不为1，跳过", conveyorLine.DeviceCode);
			return Task.CompletedTask;
			// 如果 WCS_ACK 为 1，先清除（表示处理过上一次请求）
			if (command.WCS_ACK == 1)
			conveyorLine.SetValue(ConveyorLineDBNameNew.WCS_ACK, (short)0, childDeviceCode);

			// 处理手动入库任务（起点为线体点位的任务）
			try
			{
			var task = _taskService.QueryManualInboundTask(childDeviceCode);
			if (task != null)
			{
			var handler = new ManualInboundTaskHandler(_taskService);
			handler.WriteTaskToPlc(conveyorLine, childDeviceCode, task);
			}
			}
			catch (Exception ex)
			{
			_logger.LogError(ex, "处理手动入库任务异常");
			QuartzLogger.Error($"处理手动入库任务异常: {ex.Message}", "CommonConveyorLineNewJob", ex);
			}
			continue;
			}

			// ========== 处理无托盘条码的情况 ==========
			@@ -218,11 +242,11 @@
			_logger.LogDebug("Execute：子设备 {ChildDeviceCode} 无托盘条码，请求出库任务", childDeviceCode);
			QuartzLogger.Debug($"子设备 {childDeviceCode} 无托盘条码，请求出库任务", conveyorLine.DeviceCode);
			_conveyorLineDispatch.RequestOutbound(conveyorLine, command, childDeviceCode);
			return Task.CompletedTask;
			continue;
			}

			// ========== 处理已有任务号的情况 ==========
			if (command.TaskNo > 0)
			if (command.TaskNo > 0 && !command.Barcode.IsNullOrEmpty())
			{
			// 查询正在执行的任务
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNo, childDeviceCode);
			@@ -287,7 +311,13 @@
			{
			case InExecuting:
			// 入库执行中，调用下一地址处理
			_conveyorLineDispatch.RequestInNextAddress(conveyorLine, command, childDeviceCode);

			if (AddressToDeviceType.Contains(childDeviceCode))
			// 到达目标地址，调用入库完成
			_conveyorLineDispatch.ConveyorLineInFinish(conveyorLine, command, childDeviceCode);
			else
			// 未到达目标地址，调用入库下一地址处理
			_conveyorLineDispatch.RequestInNextAddress(conveyorLine, command, childDeviceCode);
			break;

			case OutExecuting:
			@@ -312,4 +342,4 @@
			}
			}
			}
			}
			}