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

生成引擎类工具类

master
Qin Dong Ming 2024-09-02 21:16:43 +08:00
parent 76f8b6dce7
commit a907cbf5b3
2 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-etl-common/src/main/java/com/muyu/context/GenerateConstant.java
View File

@ -41,7 +41,7 @@ public class GenerateConstant {
" * @Description: " + ruleVersion.getName() + "_" + ruleVersion.getVersionCode() + "\n" + " * @Description: " + ruleVersion.getName() + "_" + ruleVersion.getVersionCode() + "\n" +
" * @Version: 1.0\n" + " * @Version: 1.0\n" +
" */\n" + " */\n" +
"public class " + getClassName(ruleVersion.getVersionClass()) + " extends " + level + " {\n" + "public class " + getClassName(ruleVersion.getVersionCode()) + " extends " + level + " {\n" +
" @Override\n" + " @Override\n" +
" public void run () {\n" + " public void run () {\n" +
" }\n" + " }\n" +

23
cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java
View File

@ -86,7 +86,7 @@ public class EngIneController extends BaseController {
@PostMapping("/insert") @PostMapping("/insert")
public Boolean insert(@RequestBody EngineMaintenance engineMaintenance) { public Boolean insert(@RequestBody EngineMaintenance engineMaintenance) {
//使用mabits-plus-plus的添加方法 //使用mabits-plus-plus的添加方法
Boolean b = engIneService.save(engineMaintenance); Boolean b = engIneService.save(engineMaintenance);
return b; return b;
// return engIneService.add(engineMaintenance); // return engIneService.add(engineMaintenance);
} }
@ -185,7 +185,7 @@ public class EngIneController extends BaseController {
//使用mybatis-plus的查询方法 //使用mybatis-plus的查询方法
// return Result.success(engineVersionService.getByIds(id)); // return Result.success(engineVersionService.getByIds(id));
return Result.success(engineVersionService.list(new LambdaQueryWrapper<>() {{ return Result.success(engineVersionService.list(new LambdaQueryWrapper<>() {{
eq(EngineVersion::getEngineMaintenanceId,id); eq(EngineVersion::getEngineMaintenanceId, id);
}})); }}));
} }
@ -198,25 +198,28 @@ public class EngIneController extends BaseController {
// List<EngineMaintenance> engineMaintenances = engIneService.list(new LambdaQueryWrapper<>() {{ // List<EngineMaintenance> engineMaintenances = engIneService.list(new LambdaQueryWrapper<>() {{
// eq(EngineMaintenance::getVersionId, versionId); // eq(EngineMaintenance::getVersionId, versionId);
// }}); // }});
List<EngineMaintenance> engineMaintenances = engineVersionService.getByIds(versionId); List<EngineMaintenance> engineMaintenances = engineVersionService.getByIds(versionId);
return engineMaintenances; return engineMaintenances;
} }
/** /**
* 生成引擎类 * 生成引擎类
*
* @param engineVersion * @param engineVersion
* @return * @return
*/ */
@PostMapping("/generate") @PostMapping("/generate")
public EngineVersion generate(@RequestBody EngineVersion engineVersion){ public EngineVersion generate(@RequestBody EngineVersion engineVersion) {
EngineVersion byId1 = engineVersionService.getById(engineVersion.getId()); EngineVersion byId1 = engineVersionService.getById(engineVersion.getId());
EngineMaintenance byId = engIneService.selectById(byId1.getId()); EngineMaintenance byId = engIneService.selectById(byId1.getId());
byId.setName("generate"+"_"+byId.getEngineCode()+"_"+engineVersion.getVersionCode()); byId.setName("generate" + "_" + byId.getEngineCode() + "_" + engineVersion.getVersionCode());
engineVersion.setRuleContent(GenerateConstant.generateConstant(byId,engineVersion)); engineVersion.setRuleContent(GenerateConstant.generateConstant(byId, engineVersion));
return engineVersion; return engineVersion;
} }
//通过id查询版本version信息 传入id 和versionId /**
* 通过id查询版本version信息 传入id 和 versionId
*/
@GetMapping("/findVersionById/{id}") @GetMapping("/findVersionById/{id}")
public Result findVersionById(@PathVariable("id") Long id) { public Result findVersionById(@PathVariable("id") Long id) {
return Result.success(engineVersionService.getById(id)); return Result.success(engineVersionService.getById(id));