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 23821d0..0b22b4c 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
@@ -274,19 +274,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
             for (long i = 1; i <= count; i++) {
                 long pageNum = (i - 1) * 5000;
                 submitEmergencyTask(()->{
-                    String sqlSelect = " SELECT " + finalFieName + " FROM " + finalJoint +" limit "+pageNum +",5000 ";
-                    log.info(sqlSelect);
-                    Result<List<List<DataValue>>> tableValueResult = datasourceFeign.findTableValue(basicId, sql);
-                    List<List<DataValue>> tableValue = tableValueResult.getData();
-                    for (List<DataValue> dataValues : tableValue) {
-                        for (DataValue dataValue : dataValues) {
-                            String key = dataValue.getKey();
-                            String newKey = map.get(key);
-                            dataValue.setKey(newKey);
-                        }
-                    }
-                    Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue);
-                    log.info(result);
+
                     //getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map);
                 });
             }
@@ -296,7 +284,19 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
 
     @NotNull
     private void getString(Long pageNum,String fieName,String joint,Long basicId,Long newBasicId,Long tableId,HashMap<String, String> map ) {
-
+        String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +",5000 ";
+        log.info(sqlSelect);
+        Result<List<List<DataValue>>> tableValueResult = datasourceFeign.findTableValue(basicId, sqlSelect);
+        List<List<DataValue>> tableValue = tableValueResult.getData();
+        for (List<DataValue> dataValues : tableValue) {
+            for (DataValue dataValue : dataValues) {
+                String key = dataValue.getKey();
+                String newKey = map.get(key);
+                dataValue.setKey(newKey);
+            }
+        }
+        Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue);
+        log.info(result);
 
     }