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

修改分页条数

master
Cui YongXing 2024-09-08 22:17:52 +08:00
parent b656312de9
commit 155f69db3b
1 changed files with 29 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -391,18 +391,19 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
List<NodeRule> list = nodeRuleService.list(wrapper);
// 提交第一个任务
Future<DataValue[][]> currentFuture = executor.submit(tasks.poll());
for (NodeRule nodeRule : list) {
Result<RuleEngineVersion> result = ruleFeign.findVersionById(nodeRule.getRuleId());
RuleEngineVersion data = result.getData();
final Future<DataValue[][]> finalCurrentFuture = currentFuture;
log.info(finalCurrentFuture);
Callable<DataValue[][]> task = () -> {
DataValue[][] prevResult = finalCurrentFuture.get();
log.info(data.getClassName());
if (data.getRuleId().equals("3")) {
if (!CollectionUtils.isEmpty(list)) {
for (NodeRule nodeRule : list) {
Result<RuleEngineVersion> result = ruleFeign.findVersionById(nodeRule.getRuleId());
RuleEngineVersion data = result.getData();
final Future<DataValue[][]> finalCurrentFuture = currentFuture;
log.info(finalCurrentFuture);
Callable<DataValue[][]> task = () -> {
DataValue[][] prevResult = finalCurrentFuture.get();
log.info(data.getClassName());
if (data.getRuleId().equals("3")) {
}
if (data.getRuleId().equals("1")) {
}
if (data.getRuleId().equals("1")) {
// for (DataValue[] values : prevResult) {
// for (DataValue value : values) {
// log.info(value.getValue());
@ -411,8 +412,8 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
// }
// }
}
if (data.getRuleId().equals("2")) {
}
if (data.getRuleId().equals("2")) {
// for (DataValue[] values : prevResult) {
// for (DataValue value : values) {
// log.info(value.getValue());
@ -421,23 +422,25 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
// }
// }
}
return prevResult;
};
// 提交任务并更新当前Future
currentFuture = executor.submit(task);
// 等待当前任务完成
try {
currentFuture.get();
} catch (InterruptedException | ExecutionException e) {
Thread.currentThread().interrupt();
System.out.println("Task execution failed: " + e.getMessage());
break;
}
return prevResult;
};
// 提交任务并更新当前Future
currentFuture = executor.submit(task);
// 等待当前任务完成
try {
currentFuture.get();
} catch (InterruptedException | ExecutionException e) {
Thread.currentThread().interrupt();
System.out.println("Task execution failed: " + e.getMessage());
break;
}
}
try {
DataValue[][] afterFilteringDataValue = currentFuture.get();
for (DataValue[] datum : afterFilteringDataValue) {