From aa683a62c4f8f35804eac636e8cba8c8d2e27b6d Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Tue, 9 Sep 2025 10:57:56 +0800 Subject: [PATCH] =?UTF-8?q?refactor(task):=20=E4=BC=98=E5=8C=96=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E8=8E=B7=E5=8F=96=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在 TaskTaskServiceImpl 中添加 limit(1) 以限制获取的任务数量为 1 - 在 TaskMapper.xml 中移除 selectNotRunning 查询中的 limit 1条件 --- .../com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java | 2 +- src/main/resources/mapper/TaskMapper.xml | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index d5d101a..3fb6ded 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -201,7 +201,7 @@ public class TaskTaskServiceImpl implements TaskService { taskList = _taskList.stream().filter(task -> { boolean workerSelfHostedScenic = isWorkerSelfHostedScenic(task.getScenicId()); return !workerSelfHostedScenic; - }).toList(); + }).limit(1).toList(); } resp.setTasks(taskList); resp.setTemplates(updTemplateList); diff --git a/src/main/resources/mapper/TaskMapper.xml b/src/main/resources/mapper/TaskMapper.xml index 6274ca5..6e51e0f 100644 --- a/src/main/resources/mapper/TaskMapper.xml +++ b/src/main/resources/mapper/TaskMapper.xml @@ -84,7 +84,6 @@ from task where status = 0 and worker_id is null - limit 1