etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改分页条数

master
Cui YongXing 2024-09-09 00:11:39 +08:00
parent 155f69db3b
commit 824a1b2761
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -14,8 +14,8 @@ import com.muyu.common.domian.req.TaskInfoListReq;
import com.muyu.common.domian.resp.TaskInfoResp; import com.muyu.common.domian.resp.TaskInfoResp;
import com.muyu.remote.feign.DatasourceFeign; import com.muyu.remote.feign.DatasourceFeign;
import com.muyu.remote.feign.RuleFeign; import com.muyu.remote.feign.RuleFeign;
import com.muyu.rule.common.basic.BasicEngine;
import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.common.domain.RuleEngineVersion;
import com.muyu.rule.common.utils.LoadEngineClass;
import com.muyu.task.server.mapper.TaskInfoMapper; import com.muyu.task.server.mapper.TaskInfoMapper;
import com.muyu.task.server.service.*; import com.muyu.task.server.service.*;
import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool; import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool;
@ -29,8 +29,6 @@ import javax.annotation.Resource;
import java.util.*; import java.util.*;
import java.util.concurrent.*; 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.*; import static com.muyu.task.server.thread.OptimizedPrioritizedThreadPool.*;
/** /**
@ -370,8 +368,8 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
* 存放实例化引擎的容器 * 存放实例化引擎的容器
*/ */
@Autowired
private LoadEngineClass loadEngineClass;
private void executeTheRule(DataValue[][] dataValues, HashMap<String, String> map, Long newBasicId, private void executeTheRule(DataValue[][] dataValues, HashMap<String, String> map, Long newBasicId,
Long tableId, Long taskId) { Long tableId, Long taskId) {
@ -404,13 +402,16 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
} }
if (data.getRuleId().equals("1")) { if (data.getRuleId().equals("1")) {
// for (DataValue[] values : prevResult) { for (DataValue[] values : prevResult) {
// for (DataValue value : values) { for (DataValue value : values) {
// log.info(value.getValue()); log.info(value.getValue());
// Result result1 = ruleFeign.testEngine(data.getClassName(), value); try {
// log.info(result1); DataValue dataValue = loadEngineClass.testEngine(data.getClassName(), value);
// } } catch (Exception e) {
// } log.error(e.getMessage());
}
}
}
} }
if (data.getRuleId().equals("2")) { if (data.getRuleId().equals("2")) {