|
|
|
@ -92,7 +92,8 @@ public class BusinDataTaskServiceImpl extends ServiceImpl<BusinDataTaskMapper, B |
|
|
|
BusinDataTask one = this.getOne(lqwDataTask); |
|
|
|
BusinDataTask one = this.getOne(lqwDataTask); |
|
|
|
|
|
|
|
|
|
|
|
LambdaQueryWrapper<BusinDataTask> lqwDataTask1 = new LambdaQueryWrapper<BusinDataTask>() |
|
|
|
LambdaQueryWrapper<BusinDataTask> lqwDataTask1 = new LambdaQueryWrapper<BusinDataTask>() |
|
|
|
.eq(BusinDataTask::getTaskCode, taskId); |
|
|
|
.eq(BusinDataTask::getTaskCode, taskId) |
|
|
|
|
|
|
|
.ne(BusinDataTask::getTaskStatus,TaskStatusEnum.clean.getValue()); |
|
|
|
BusinDataTask one1 = this.getOne(lqwDataTask1); |
|
|
|
BusinDataTask one1 = this.getOne(lqwDataTask1); |
|
|
|
if (dataChange.equals("1")) { |
|
|
|
if (dataChange.equals("1")) { |
|
|
|
if (one != null) { |
|
|
|
if (one != null) { |
|
|
|
@ -148,7 +149,7 @@ public class BusinDataTaskServiceImpl extends ServiceImpl<BusinDataTaskMapper, B |
|
|
|
if(one.getTaskStatus().equals(TaskStatusEnum.wait_callback.getValue())){ |
|
|
|
if(one.getTaskStatus().equals(TaskStatusEnum.wait_callback.getValue())){ |
|
|
|
RcsCancelTaskDto rcsCancelTaskDto = new RcsCancelTaskDto(); |
|
|
|
RcsCancelTaskDto rcsCancelTaskDto = new RcsCancelTaskDto(); |
|
|
|
rcsCancelTaskDto.setRobotTaskCode(taskId); |
|
|
|
rcsCancelTaskDto.setRobotTaskCode(taskId); |
|
|
|
rcsCancelTaskDto.setCancelType("DROP"); |
|
|
|
rcsCancelTaskDto.setCancelType("cancel"); |
|
|
|
rcsCancelTaskDto.setReason("上游取消"); |
|
|
|
rcsCancelTaskDto.setReason("上游取消"); |
|
|
|
Result result = rcsUtil.rcsTaskCancel(rcsCancelTaskDto); |
|
|
|
Result result = rcsUtil.rcsTaskCancel(rcsCancelTaskDto); |
|
|
|
if (!Result.isOk(result)) { |
|
|
|
if (!Result.isOk(result)) { |
|
|
|
@ -180,8 +181,8 @@ public class BusinDataTaskServiceImpl extends ServiceImpl<BusinDataTaskMapper, B |
|
|
|
slotName = "SC-G2-00-00-43022"; |
|
|
|
slotName = "SC-G2-00-00-43022"; |
|
|
|
} |
|
|
|
} |
|
|
|
LambdaQueryWrapper<BusinDataTask> queryWrapper = new LambdaQueryWrapper<BusinDataTask>() |
|
|
|
LambdaQueryWrapper<BusinDataTask> queryWrapper = new LambdaQueryWrapper<BusinDataTask>() |
|
|
|
.eq(BusinDataTask::getTaskCode, robotTaskCode); |
|
|
|
.eq(BusinDataTask::getTaskCode, robotTaskCode) |
|
|
|
// .eq(BusinDataTask::getContainerCode, carrierCode);
|
|
|
|
.eq(BusinDataTask::getTaskStatus, TaskStatusEnum.wait_callback.getValue()); |
|
|
|
BusinDataTask businDataTask; |
|
|
|
BusinDataTask businDataTask; |
|
|
|
try { |
|
|
|
try { |
|
|
|
businDataTask = iBusinDataTaskService.getOne(queryWrapper, true); |
|
|
|
businDataTask = iBusinDataTaskService.getOne(queryWrapper, true); |
|
|
|
|