From fcb3c8097fede17377c569f8629ae7acd18c26ea Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Wed, 4 Sep 2024 00:23:30 +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, 3 insertions(+), 5 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 8570afd..c1c1604 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 @@ -240,8 +240,9 @@ public class TaskInfoServiceImpl extends ServiceImpl i String finalJoint = joint; System.out.println(weight); System.out.println(Weight.centre.getValue()); + long count = data/10000==0?1:data/10000; if (Weight.high.getValue().equals(weight)){ - long count = data/10000; + for (long i = 0; i < count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{ @@ -249,8 +250,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i }); } } - if ("1".equals(weight)){ - long count = data/10000; + if (Weight.centre.getValue().equals(weight)){ for (long i = 0; i < count; i++) { long pageNum = (i - 1) * 10000; System.out.println(pageNum); @@ -260,7 +260,6 @@ public class TaskInfoServiceImpl extends ServiceImpl i } } if (Weight.low.getValue().equals(weight)){ - long count = data/10000; for (long i = 0; i < count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{ @@ -269,7 +268,6 @@ public class TaskInfoServiceImpl extends ServiceImpl i } } if (Weight.urgency.getValue().equals(weight)){ - long count = data/10000; for (long i = 0; i < count; i++) { long pageNum = (i - 1) * 10000; submitHighPriorityTask(()->{