| | |
|---|
| | | private readonly INoticeService _noticeService; |
|---|
| | | private readonly IDt_needBarcodeRepository _needBarcodeRepository; |
|---|
| | | private readonly IDeviceInfoRepository _deviceInfoRepository; |
|---|
| | | private static List<string>? userTokenIds; |
|---|
| | | private static List<int>? userIds; |
|---|
| | | |
|---|
| | | public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService, IDt_needBarcodeRepository needBarcodeRepository, IDeviceInfoRepository deviceInfoRepository) |
|---|
| | | { |
|---|
| | |
|---|
| | | var task = _taskService.QueryBarCodeConveyorLineTask(command.ConveyorLineBarcode, childDeviceCode); |
|---|
| | | //HandleTaskOut(conveyorLine, command, childDeviceCode, task); |
|---|
| | | // && command.ConveyorLineBarcode != "NoRead" && !command.ConveyorLineBarcode.IsNotEmptyOrNull() |
|---|
| | | ConsoleHelper.WriteSuccessLine($"【{conveyorLine.DeviceName}】托盘号：【{command.ConveyorLineBarcode}】任务号：【{command.ConveyorLineTaskNum}】设备编码：【{childDeviceCode}】"); |
|---|
| | | var log = $"【{conveyorLine.DeviceName}】托盘号：【{command.ConveyorLineBarcode}】任务号：【{command.ConveyorLineTaskNum}】设备编码：【{childDeviceCode}】"; |
|---|
| | | ConsoleHelper.WriteSuccessLine(log); |
|---|
| | | |
|---|
| | | _noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" }); |
|---|
| | | WriteInfo(conveyorLine.DeviceName, log); |
|---|
| | | |
|---|
| | | if (task == null) |
|---|
| | | { |
|---|
| | | HandleNewTask(conveyorLine, command, childDeviceCode); |
|---|
| | |
|---|
| | | Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress); |
|---|
| | | if (newTask != null) |
|---|
| | | { |
|---|
| | | |
|---|
| | | //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTaskNum, newTask.TaskNum, childDeviceCode); |
|---|
| | | //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, newTask.NextAddress, childDeviceCode); |
|---|
| | | //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineBarcode, command.ConveyorLineBarcode, childDeviceCode); |
|---|
| | |
|---|
| | | conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 1, childDeviceCode); |
|---|
| | | _taskService.UpdateTaskStatusToNext(task); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | private async Task CheckAndCreateTask(TaskOutboundTypeEnum taskType, string childDeviceCode, int index, Platform platform) |
|---|
| | | { |
|---|
| | | var tasks = _taskRepository.QueryData(x => x.TaskType == (int)taskType && x.TargetAddress == childDeviceCode); |
|---|
| | | if (tasks.Count < index) |
|---|
| | | if (tasks.Count < platform.Capacity) |
|---|
| | | { |
|---|
| | | #region 调用WMS获取出库任务 |
|---|
| | | |
|---|
