From cf62bbf47cfa0a4ccb154424e33e1a27ed405dba Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com>
Date: Mon, 9 Sep 2024 01:57:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=BA=BF=E7=A8=8B=E6=B1=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/muyu/service/impl/TaskServiceImpl.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
index 101d701..ed2497c 100644
--- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
@@ -199,7 +199,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行紧急任务");
                 log.info("sql为{}",finalSql);
                 executeUrgently(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -207,7 +207,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行高级任务");
                 log.info("sql为{}",finalSql);
                 executeHigh(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -215,7 +215,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行中级任务");
                 log.info("sql为{}",finalSql);
                 executeMedium(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -223,7 +223,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行低级任务");
                 log.info("sql为{}",finalSql);
                 executeLow(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
         }