2112A-ONE
/
muyu-quest
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增规则远程调用依赖

master
面包骑士 2024-09-09 17:28:33 +08:00
parent 3fdc279d0e
commit e25fe74342
2 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
muyu-quest-server/pom.xml
View File

@ -94,6 +94,12 @@
<groupId>com.muyu</groupId>
<artifactId>muyu-quest-remote</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>etl-rule-remote</artifactId>
<version>3.6.5</version>
</dependency>
</dependencies>
<build>
<finalName>muyu-quest</finalName>

12
muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java
View File

@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.etl.rule.remote.RemoteRuleVersion;
import com.muyu.quest.domain.*;
import com.muyu.quest.manager.TaskManager;
import com.muyu.quest.model.DataModel;
@ -49,6 +50,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
private RemoteDataSourceService remoteDataSourceService;
@Resource
private ITaskExportService taskExportService;
@Resource
private RemoteRuleVersion remoteRuleVersion;
private static TaskManager taskManager = null;
@ -180,13 +183,13 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
taskManager.execute(() -> {
String exportCode = UUID.randomUUID().toString().replace("-","");
// 获取新SQL 并执行
StringBuilder newAddSql = new StringBuilder(findSql);
newAddSql.append(" LIMIT ")
StringBuilder newFindSql = new StringBuilder(findSql);
newFindSql.append(" LIMIT ")
.append(limitNum)
.append(" OFFSET ")
.append((index-1)*limitNum);
String addSql = getAddSql(nodeMap, newAddSql.toString());
TaskExport entity = new TaskExport(taskCode,exportCode, newAddSql.toString(), 0, "");
String addSql = getAddSql(nodeMap, newFindSql.toString());
TaskExport entity = new TaskExport(taskCode,exportCode, newFindSql.toString(), 0, "");
taskExportService.save(entity);
Result addResult = remoteDataSourceService.addTableValue(new DataValueModel(4L, addSql));
log.info("任务 {} 第 {} 线程执行结果 {}",taskCode,index,addResult.getMsg());
@ -270,7 +273,6 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
s1[1] = "COUNT(" + s1[1].split(",")[0]+ ")";
findCountSql = StringUtils.join(s1," ");
}else {
String[] split = s1[s1.length-1].split("\\.");
stringBuilder.append("SELECT TABLE_ROWS ")
.append("FROM INFORMATION_SCHEMA.TABLES ")