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 54898c1..1ff82fd 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
@@ -344,8 +344,16 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
 
         DataValue[][] data = tableValueResult.getData();
         log.info("执行{}查询的方法结束", sqlSelect);
-
-        executeTheRule(data,map,newBasicId,tableId);
+        for (DataValue[] datum : data) {
+            for (DataValue dataValue : datum) {
+                String key = dataValue.getKey();
+                String newKey = map.get(key);
+                dataValue.setKey(newKey);
+            }
+        }
+        Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
+        log.info("{}添加结束", result);
+        //executeTheRule(data,map,newBasicId,tableId);
 
     }
 
@@ -389,15 +397,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
         }
         try {
             DataValue[][] afterFilteringDataValue = currentFuture.get();
-            for (DataValue[] datum : afterFilteringDataValue) {
-                for (DataValue dataValue : datum) {
-                    String key = dataValue.getKey();
-                    String newKey = map.get(key);
-                    dataValue.setKey(newKey);
-                }
-            }
-            Result result = datasourceFeign.addProduct(newBasicId, tableId, afterFilteringDataValue);
-            log.info("{}添加结束", result);
+
 
         } catch (InterruptedException e) {
             throw new RuntimeException(e);