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

修改分页条数

master
Cui YongXing 2024-09-08 20:14:10 +08:00
parent 07436331f3
commit 880307cc01
2 changed files with 11 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-task-server/pom.xml
View File

@ -19,6 +19,11 @@
<dependencies> <dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-rule-server</artifactId>
<version>1.0.0</version>
</dependency>
<!-- SpringCloud Alibaba Nacos --> <!-- SpringCloud Alibaba Nacos -->
<dependency> <dependency>
<groupId>com.alibaba.cloud</groupId> <groupId>com.alibaba.cloud</groupId>

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

@ -3,7 +3,6 @@ package com.muyu.task.server.service.impl;
import com.muyu.common.domian.*; import com.muyu.common.domian.*;
import com.muyu.common.domian.basic.abstracts.DataTaskAbstracts; import com.muyu.common.domian.basic.abstracts.DataTaskAbstracts;
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.task.server.service.*; import com.muyu.task.server.service.*;
import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool; import com.muyu.task.server.thread.OptimizedPrioritizedThreadPool;
@ -367,9 +366,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
/** /**
* 存放实例化引擎的容器 * 存放实例化引擎的容器
*/ */
public static Map<String, BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[]>> engineRowMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[][]>> engineDataSetMap = new ConcurrentHashMap<>();
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) {
@ -397,19 +397,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
Callable<DataValue[][]> task = () -> { Callable<DataValue[][]> task = () -> {
DataValue[][] prevResult = finalCurrentFuture.get(); DataValue[][] prevResult = finalCurrentFuture.get();
if (data.getRuleId().equals("3")) { 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")) { 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; return prevResult;
}; };