删除任务时同时处理堆垛机队列
This commit is contained in:
@@ -100,6 +100,13 @@ public class MydoJobServiceImpl implements IMydoJobService
|
|||||||
{
|
{
|
||||||
for (String jobId : jobIds) {
|
for (String jobId : jobIds) {
|
||||||
mydoJobMapper.insertHistory(jobId);
|
mydoJobMapper.insertHistory(jobId);
|
||||||
|
//当执行任务的【删除】操作时(特殊场景需要手动处理异常导致不需要入库时,此时不需要向回传异常)
|
||||||
|
// 此处顺便处理对应任务号生成的堆垛机执行队列,省去sql直接表中删记录的操作
|
||||||
|
if (ddjDeviceExecutionQueueService.selectDdjDeviceExecutionQueueByTaskNo(jobId) != null) {
|
||||||
|
MydoJob mydoJob = selectMydoJobByJobId(jobId);
|
||||||
|
ddjDeviceExecutionQueueService.deleteDdjDeviceExecutionQueueByTaskNo(mydoJob.getTaskNo());
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
return mydoJobMapper.deleteMydoJobByJobIds(jobIds);
|
return mydoJobMapper.deleteMydoJobByJobIds(jobIds);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -90,7 +90,7 @@ public class DdjThread implements Runnable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
Thread.sleep(1500);
|
Thread.sleep(3000);
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user