任务锁任务类型而非点位+任务类型
This commit is contained in:
@@ -176,10 +176,10 @@ public abstract class AbstractTask {
|
|||||||
Integer tcmn = taskConfig.getTask_create_max_num();
|
Integer tcmn = taskConfig.getTask_create_max_num();
|
||||||
// 获取执行中的任务
|
// 获取执行中的任务
|
||||||
List<SchBaseTask> unFinishTasksByTaskConfig = taskService.findUnFinishTasksByTaskConfig(
|
List<SchBaseTask> unFinishTasksByTaskConfig = taskService.findUnFinishTasksByTaskConfig(
|
||||||
taskConfig.getConfig_code(), apply_point_code, taskConfig.getTask_direction());
|
taskConfig.getConfig_code());
|
||||||
|
|
||||||
Assert.isFalse(unFinishTasksByTaskConfig.size() >= tcmn,
|
Assert.isFalse(unFinishTasksByTaskConfig.size() >= tcmn,
|
||||||
"该点位申请的任务未完成数已超过上限,无法申请任务");
|
"该任务类型申请的任务未完成数已超过上限,无法申请任务");
|
||||||
// 获取对接位点位对象
|
// 获取对接位点位对象
|
||||||
SchBasePoint pointObj = pointService.getOne(new LambdaQueryWrapper<SchBasePoint>()
|
SchBasePoint pointObj = pointService.getOne(new LambdaQueryWrapper<SchBasePoint>()
|
||||||
.eq(SchBasePoint::getPoint_code, apply_point_code));
|
.eq(SchBasePoint::getPoint_code, apply_point_code));
|
||||||
|
|||||||
Reference in New Issue
Block a user