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 b217365..d22506d 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
@@ -14,6 +14,7 @@ import com.muyu.common.domian.req.TaskInfoListReq;
 import com.muyu.common.domian.resp.TaskInfoResp;
 import com.muyu.remote.feign.DatasourceFeign;
 import com.muyu.remote.feign.RuleFeign;
+import com.muyu.rule.common.basic.BasicEngine;
 import com.muyu.rule.common.domain.RuleEngineVersion;
 import com.muyu.task.server.mapper.TaskInfoMapper;
 import com.muyu.task.server.service.*;
@@ -28,6 +29,8 @@ import javax.annotation.Resource;
 import java.util.*;
 import java.util.concurrent.*;
 
+import static com.muyu.rule.common.map.EngineHashMap.engineDataSetMap;
+import static com.muyu.rule.common.map.EngineHashMap.engineMap;
 import static com.muyu.task.server.thread.OptimizedPrioritizedThreadPool.*;
 
 /**
@@ -396,9 +399,19 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
             Callable<DataValue[][]> task = () -> {
                 DataValue[][] prevResult = finalCurrentFuture.get();
                 if (data.getRuleId().equals("3")) {
-
+                    BasicEngine<DataValue[][]> basicEngine = engineDataSetMap.get(data.getClassName());
+                    basicEngine.set(prevResult);
+                    basicEngine.execution();
+                    DataValue[][] dataValues1 = basicEngine.get();
                 }
                 if (data.getRuleId().equals("1")) {
+                    for (DataValue[] values : prevResult) {
+                        for (DataValue value : values) {
+                            BasicEngine<DataValue> dataValueBasicEngine = engineMap.get(data.getClassName());
+                            dataValueBasicEngine.set(value);
+                            dataValueBasicEngine.execution();
+                        }
+                    }
 
                 }
                 return prevResult;