using HslCommunication;
|
using Mapster;
|
using Microsoft.AspNetCore.Components.Routing;
|
using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
|
using Quartz;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core.Caches;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_IBasicInfoRepository;
|
using WIDESEAWCS_ISystemServices;
|
using WIDESEAWCS_ITaskInfoRepository;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.Service;
|
using WIDESEAWCS_SignalR;
|
using WIDESEAWCS_Tasks.OtherDeviceJob;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
[DisallowConcurrentExecution]
|
public class CommonOtherDevicesJob : JobBase, IJob
|
{
|
private readonly ITaskService _taskService;
|
private readonly ITaskExecuteDetailService _taskExecuteDetailService;
|
private readonly ITaskRepository _taskRepository;
|
private readonly IRouterService _routerService;
|
private readonly ICacheService _cacheService;
|
private readonly INoticeService _noticeService;
|
private readonly IDt_StationManagerRepository _stationManagerRepository;
|
private readonly ITask_HtyRepository _task_htyRepository;
|
private readonly ISys_ConfigService _sys_ConfigService;
|
private static List<string>? userTokenIds;
|
private static List<int>? userIds;
|
|
public CommonOtherDevicesJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, ICacheService cacheService, INoticeService noticeService, IDt_StationManagerRepository stationManagerRepository, ITask_HtyRepository task_htyRepository, ISys_ConfigService sys_ConfigService)
|
{
|
_taskService = taskService;
|
_taskExecuteDetailService = taskExecuteDetailService;
|
_taskRepository = taskRepository;
|
_routerService = routerService;
|
_cacheService = cacheService;
|
_noticeService = noticeService;
|
_stationManagerRepository = stationManagerRepository;
|
_task_htyRepository = task_htyRepository;
|
_sys_ConfigService = sys_ConfigService;
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
OtherDevice otherDevice = (OtherDevice)context.JobDetail.JobDataMap.Get("JobParams");
|
if (otherDevice != null)
|
{
|
#region 上料
|
|
var UpRequest = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.UpRequest);
|
ConsoleHelper.WriteInfoLine($"接收上料请求信号：【{UpRequest}】");
|
|
if (UpRequest == 1)
|
{
|
var UpPosition = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.UpPosition);
|
ConsoleHelper.WriteInfoLine($"上料位置信息：【{UpPosition}】");
|
var task = _taskRepository.QueryFirst(x => x.SourceAddress == UpPosition.ToString());
|
if (task == null)
|
{
|
Dt_Task taskNew = new Dt_Task()
|
{
|
TaskNum = _taskRepository.GetTaskNo().Result,
|
PalletCode = Random.Shared.Next(1, 100).ToString(),
|
Roadway = "R001",
|
TaskType = (int)TaskInboundTypeEnum.Inbound,
|
TaskState = (int)TaskInStatusEnum.AGV_InExecuting,
|
SourceAddress = UpPosition.ToString(),
|
TargetAddress = "TargetAddress",
|
CurrentAddress = UpPosition.ToString(),
|
NextAddress = "TargetAddress",
|
Grade = 1,
|
AGVSign = 1.ToString()
|
};
|
_taskRepository.AddData(taskNew);
|
Thread.Sleep(2000);
|
//回复收到信号
|
otherDevice.SetValue(OtherDeviceDBName.UpReplyRequest, 1);
|
Thread.Sleep(2000);
|
//请求放料
|
otherDevice.SetValue(OtherDeviceDBName.RequestPut, 1);
|
}
|
else
|
{
|
ConsoleHelper.WriteInfoLine($"已有任务不允许重复生成【{task.Serialize()}】");
|
}
|
}
|
|
var AllowPut = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.AllowPut);
|
ConsoleHelper.WriteInfoLine($"读取允许放料信号：【{AllowPut}】");
|
|
if (AllowPut == 1)
|
{
|
var task = _taskRepository.QueryFirst(x => x.AGVSign != null && x.TaskType == (int)TaskInboundTypeEnum.Inbound);
|
|
otherDevice.SetValue(OtherDeviceDBName.PutFinish, 1);
|
otherDevice.SetValue(OtherDeviceDBName.UpBarcode, task != null ? task.PalletCode : "1111");
|
_taskRepository.DeleteData(task);
|
}
|
|
#endregion
|
|
#region 下料
|
|
var DownRequest = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.DownRequest);
|
ConsoleHelper.WriteInfoLine($"接收下料请求信号：【{UpRequest}】");
|
|
if (DownRequest == 1)
|
{
|
var DownPosition = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.DownPosition);
|
ConsoleHelper.WriteInfoLine($"下料位置信息：【{DownPosition}】");
|
|
var task = _taskRepository.QueryFirst(x => x.TargetAddress == DownPosition.ToString());
|
if (task == null)
|
{
|
Dt_Task taskNew = new Dt_Task()
|
{
|
TaskNum = _taskRepository.GetTaskNo().Result,
|
PalletCode = Random.Shared.Next(1, 100).ToString(),
|
Roadway = "R001",
|
TaskType = (int)TaskOutboundTypeEnum.Outbound,
|
TaskState = (int)TaskOutStatusEnum.AGV_OutExecuting,
|
SourceAddress = "SourceAddress",
|
TargetAddress = DownPosition.ToString(),
|
CurrentAddress = "SourceAddress",
|
NextAddress = DownPosition.ToString(),
|
Grade = 1,
|
AGVSign = 1.ToString()
|
};
|
_taskRepository.AddData(taskNew);
|
Thread.Sleep(2000);
|
//回复收到信号
|
otherDevice.SetValue(OtherDeviceDBName.DownReplyRequest, 1);
|
Thread.Sleep(2000);
|
//请求取料
|
otherDevice.SetValue(OtherDeviceDBName.RequestPickUp, 1);
|
}
|
else
|
{
|
ConsoleHelper.WriteInfoLine($"已有任务不允许重复生成【{task.Serialize()}】");
|
}
|
}
|
|
var AllowPickUp = otherDevice.GetValue<OtherDeviceDBName, short>(OtherDeviceDBName.AllowPickUp);
|
ConsoleHelper.WriteInfoLine($"读取允许取料信号：【{AllowPickUp}】");
|
|
if (AllowPickUp == 1)
|
{
|
var task = _taskRepository.QueryFirst(x => x.AGVSign != null && x.TaskType == (int)TaskOutboundTypeEnum.Outbound);
|
otherDevice.SetValue(OtherDeviceDBName.PickUpFinish, 1);
|
otherDevice.SetValue(OtherDeviceDBName.DownBarcode, task != null ? task.PalletCode : "1111");
|
|
_taskRepository.DeleteData(task);
|
}
|
|
#endregion
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteError("CommonOtherDevicesJob", "test", ex);
|
//ConsoleHelper.WriteErrorLine($"{ex.Message}");
|
}
|
return Task.CompletedTask;
|
}
|
}
|
}
|
