From 98ea0dfccb4e6caefbd31a26064d4995e6474582 Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Wed, 4 Sep 2024 00:29:31 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../task/server/service/impl/TaskInfoServiceImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java index c1c1604..5a3ac09 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java @@ -243,7 +243,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i long count = data/10000==0?1:data/10000; if (Weight.high.getValue().equals(weight)){ - for (long i = 0; i < count; i++) { + for (long i = 1; i <= count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{ getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map); @@ -251,7 +251,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i } } if (Weight.centre.getValue().equals(weight)){ - for (long i = 0; i < count; i++) { + for (long i = 1; i <= count; i++) { long pageNum = (i - 1) * 10000; System.out.println(pageNum); submitHighPriorityTask(()->{ @@ -260,7 +260,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i } } if (Weight.low.getValue().equals(weight)){ - for (long i = 0; i < count; i++) { + for (long i = 1; i <= count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{ getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map); @@ -268,7 +268,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i } } if (Weight.urgency.getValue().equals(weight)){ - for (long i = 0; i < count; i++) { + for (long i = 1; i <= count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{ getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map);