| | |
| | | using WIDESEAWCS_ITaskInfoRepository; |
| | | using WIDESEAWCS_QuartzJob; |
| | | |
| | | namespace WIDESEAWCS_Tasks.AGVJob |
| | | namespace WIDESEAWCS_Tasks |
| | | { |
| | | [DisallowConcurrentExecution] |
| | | public class CommonAGVJob : JobBase, IJob, IDisposable |
| | | { |
| | | private readonly ITaskRepository _taskRepository; |
| | | private readonly ITaskCZRepository _taskCZRepository; |
| | | private readonly ITaskCZDetailsRepository _detailsRepository; |
| | | |
| | | public CommonAGVJob(ITaskRepository taskRepository) |
| | | public CommonAGVJob(ITaskRepository taskRepository,ITaskCZRepository taskCZRepository, ITaskCZDetailsRepository detailsRepository) |
| | | { |
| | | _taskRepository = taskRepository; |
| | | _taskCZRepository = taskCZRepository; |
| | | _detailsRepository = detailsRepository; |
| | | } |
| | | |
| | | public void Dispose() |
| | |
| | | public Task Execute(IJobExecutionContext context) |
| | | { |
| | | AGV agv = (AGV)context.JobDetail.JobDataMap.Get("JobParams"); |
| | | SendTaskAGV.SendAGVTask(agv, _taskRepository); |
| | | UpdateTaskAGV.UpdateTask(agv, _taskRepository); |
| | | |
| | | //SendTaskAGV.SendAGVTask1(_taskRepository); |
| | | //SendTaskAGV.SendAGVTask(agv, _taskRepository); |
| | | //UpdateTaskAGV.UpdateTask(agv, _taskRepository, _taskCZRepository, _detailsRepository); |
| | | return Task.CompletedTask; |
| | | } |
| | | } |