#region << 版 本 注 释 >>
|
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEAWCS_Tasks.ConveyorLineJob
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using Quartz;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.Service;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
[DisallowConcurrentExecution]
|
public class CommonConveyorLineNewJob : IJob
|
{
|
private readonly ITaskService _taskService;
|
private readonly ITaskExecuteDetailService _taskExecuteDetailService;
|
private readonly IRouterService _routerService;
|
private readonly IMapper _mapper;
|
ConveyorLineDispatchHandler _conveyorLineDispatch;
|
|
public CommonConveyorLineNewJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper)
|
{
|
_taskService = taskService;
|
_taskExecuteDetailService = taskExecuteDetailService;
|
_routerService = routerService;
|
_mapper = mapper;
|
_conveyorLineDispatch = new ConveyorLineDispatchHandler(_taskService, _taskExecuteDetailService, _routerService, _mapper);
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
|
if (conveyorLine != null)
|
{
|
List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);
|
if (childDeviceCodes == null || childDeviceCodes.Count == 0)
|
{
|
Console.WriteLine($"输送线 {conveyorLine.DeviceCode} 没有子设备");
|
return Task.CompletedTask;
|
}
|
|
// 创建并行选项
|
var parallelOptions = new ParallelOptions
|
{
|
MaxDegreeOfParallelism = Math.Min(childDeviceCodes.Count, Environment.ProcessorCount * 2), // 合理限制并发数
|
};
|
Parallel.For(0, childDeviceCodes.Count, parallelOptions, i =>
|
{
|
string childDeviceCode = childDeviceCodes[i];
|
var correlationId = Guid.NewGuid().ToString("N");
|
try
|
{
|
ConveyorLineTaskCommandNew command = conveyorLine.ReadCustomer<ConveyorLineTaskCommandNew>(childDeviceCode);
|
if (command == null || command.PLC_STB == 0)
|
{
|
return;
|
}
|
|
if (command.Barcode.IsNullOrEmpty())
|
{
|
//无托盘号时
|
_conveyorLineDispatch.RequestOutbound(conveyorLine, command, childDeviceCode);
|
return;
|
}
|
|
Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNo, childDeviceCode);
|
if (task.IsNullOrEmpty())
|
{
|
_conveyorLineDispatch.RequestInbound(conveyorLine, command, childDeviceCode);
|
return;
|
}
|
|
// 处理任务状态
|
ProcessTaskState(conveyorLine, command, task, childDeviceCode);
|
}
|
catch (Exception innerEx)
|
{
|
Console.Error.WriteLine($"{DateTime.UtcNow:O} [{childDeviceCode}] CorrelationId={correlationId} {innerEx}");
|
}
|
});
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.Error.WriteLine(ex);
|
}
|
return Task.CompletedTask;
|
}
|
|
|
/// <summary>
|
/// 处理任务状态
|
/// </summary>
|
/// <param name="conveyorLine">输送线实例对象</param>
|
/// <param name="command">读取的请求信息</param>
|
/// <param name="task">子设备编号</param>
|
/// <param name="childDeviceCode"></param>
|
private void ProcessTaskState(CommonConveyorLine conveyorLine, ConveyorLineTaskCommandNew command, Dt_Task task, string childDeviceCode)
|
{
|
// 定义状态常量（如果类中已定义则可移除）
|
const int InExecuting = (int)TaskInStatusEnum.Line_InExecuting;
|
const int OutExecuting = (int)TaskOutStatusEnum.Line_OutExecuting;
|
const int InFinish = (int)TaskInStatusEnum.InFinish;
|
const int OutFinish = (int)TaskOutStatusEnum.OutFinish;
|
|
int state = task.TaskState;
|
bool isTargetAddress = task.TargetAddress == childDeviceCode;
|
|
// 处理状态逻辑
|
switch (state)
|
{
|
case InExecuting:
|
if (isTargetAddress)
|
_conveyorLineDispatch.ConveyorLineInFinish(conveyorLine, command, childDeviceCode);
|
else
|
_conveyorLineDispatch.RequestInNextAddress(conveyorLine, command, childDeviceCode);
|
break;
|
|
case OutExecuting:
|
if (isTargetAddress)
|
_conveyorLineDispatch.ConveyorLineOutFinish(conveyorLine, command, childDeviceCode);
|
else
|
_conveyorLineDispatch.RequestOutNextAddress(conveyorLine, command, childDeviceCode);
|
break;
|
|
case InFinish:
|
_conveyorLineDispatch.ConveyorLineInFinish(conveyorLine, command, childDeviceCode);
|
break;
|
|
case OutFinish:
|
_conveyorLineDispatch.ConveyorLineOutFinish(conveyorLine, command, childDeviceCode);
|
break;
|
}
|
}
|
|
|
}
|
}
|
