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

数据接入

master
Qin Dong Ming 2024-09-06 19:45:50 +08:00
parent d7cb415f76
commit 3c6f1078cc
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -15,8 +15,6 @@ import com.muyu.service.EngIneService;
import com.muyu.service.EngineVersionService; import com.muyu.service.EngineVersionService;
import com.muyu.test.JavaClass; import com.muyu.test.JavaClass;
import com.muyu.test.TestService; import com.muyu.test.TestService;
import com.muyu.utils.OssUpload;
import io.swagger.v3.core.util.Json;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -216,11 +214,11 @@ public class EngIneController extends BaseController {
* @return * @return
*/ */
@PostMapping("/generate") @PostMapping("/generate")
public EngineVersion generate(@RequestBody EngineVersion engineVersion) { public EngineVersion generate(@RequestBody EngineVersion engineVersion) {
EngineMaintenance byId = engIneService.selectById(engineVersion.getId()); EngineMaintenance byId = engIneService.selectById(engineVersion.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;
} }
/** /**
@ -234,6 +232,7 @@ public class EngIneController extends BaseController {
/** /**
* 测试代码 * 测试代码
*
* @param ruleEdition * @param ruleEdition
* @return * @return
*/ */
@ -242,10 +241,9 @@ public class EngIneController extends BaseController {
OSSFileDownload.streamingDownload(ruleEdition.getName()); OSSFileDownload.streamingDownload(ruleEdition.getName());
JavaClass.compile(String.valueOf(ruleEdition.getId())); JavaClass.compile(String.valueOf(ruleEdition.getId()));
log.error("错误原因:{}"+ruleEdition); log.error("错误原因:{}" + ruleEdition);
//测试 //测试
TestService.test(ruleEdition); TestService.test(ruleEdition);
return Result.success(engIneService.measurementList(ruleEdition)); return Result.success(engIneService.measurementList(ruleEdition));
} }
} }