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

Oss上传测试类

master
Qin Dong Ming 2024-09-03 20:24:19 +08:00
parent 54ce3c73d7
commit 580074173d
15 changed files with 117 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cloud-etl-client/src/main/java/com/muyu/Engineclient/RuleEngineClientRunner.java
View File

@ -1,6 +1,5 @@
package com.muyu.Engineclient;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.EngineVersion;
import com.muyu.remote.RemoteVersionService;
import lombok.extern.log4j.Log4j2;

3
cloud-etl-common/pom.xml
View File

@ -18,14 +18,17 @@
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-security</artifactId>
</dependency>
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>

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

@ -11,12 +11,12 @@ import java.util.Date;
@Component
public class GenerateConstant {
public static final String DATA_FIELD = "DataEngineValueActuator";
public static final String DATA_RECORD = "DataEngineRecordActuator";
public static final String DATA_SET = "DataEngineSetActuator";
public static final String ACTION_IMPORT = "import com.muyu.abstracts.DataValue;";
public static final String SCOPE_IMPORT = "import com.muyu.engine.basic.abstracts.";
public static final String PACKAGE_PATH = "package com.muyu.generate;\n";
public static final String DATA_FIELD = "DataEngineValueActuator";
public static final String DATA_RECORD = "DataEngineRecordActuator";
public static final String DATA_SET = "DataEngineSetActuator";
public static final String ACTION_IMPORT = "import com.muyu.abstracts.DataValue;";
public static final String SCOPE_IMPORT = "import com.muyu.engine.basic.abstracts.";
public static final String PACKAGE_PATH = "package com.muyu.generate;\n";
public static String getClassName(String versionCode) {
String[] splits = versionCode.split("_");

81
cloud-etl-common/src/main/java/com/muyu/domain/JavaClass.java 100644
View File

@ -0,0 +1,81 @@
package com.muyu.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.util.Date;
/**
* @Author：qdm
* @Package：com.muyu.domain
* @Project：cloud-etl-engine
* @name：JavaClass
* @Date：2024/9/3 19:04
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class JavaClass {
/**
* 主键
*/
private Integer id;
/**
* 姓名
*/
private String name;
/**
* 性别
*/
private String sex;
/**
* 描述
*/
private String desc;
/**
* 价格
*/
private BigDecimal price;
/**
* 分数
*/
private Double score;
/**
* 身份证
*/
private String idCard;
/**
* 年龄
*/
private Integer age;
/**
* 地址
*/
private String address;
/**
* 邮箱
*/
private String email;
/**
* 电话
*/
private String phone;
/**
* 创建人
*/
private Integer createBy;
/**
* 修改人
*/
private Integer updateBy;
/**
* 创建时间
*/
private Date createTime;
/**
* 修改时间
*/
private Date updateTime;
}

8
cloud-etl-server/pom.xml
View File

@ -19,7 +19,6 @@
<version>1.0.0</version>
</dependency>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
@ -44,8 +43,7 @@
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- //创建测试工程，引入依赖-->
<!-- //创建测试工程，引入依赖-->
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
@ -57,6 +55,7 @@
<artifactId>jaxb-api</artifactId>
<version>2.3.1</version>
</dependency>
<dependency>
<groupId>javax.activation</groupId>
<artifactId>activation</artifactId>
@ -114,8 +113,6 @@
<artifactId>junit</artifactId>
</dependency>
<!-- &lt;!&ndash; XllJob定时任务 &ndash;&gt;-->
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
@ -132,7 +129,6 @@
<build>
<finalName>cloud-engine</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>

2
cloud-etl-server/src/main/java/com/muyu/abstracts/DataValue.java
View File

@ -14,7 +14,7 @@ import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public abstract class DataValue {
public abstract class DataValue {
/**
* 键
*/

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

@ -97,7 +97,7 @@ public class EngIneController extends BaseController {
@PutMapping("/getRuleEngineInfo/{id}")
public Result getRuleEngineInfo(@PathVariable(name = "id") Long id) {
//使用mabits-plus-plus的查询方法
// engIneService.getRuleEngineInfo(id);
// engIneService.getRuleEngineInfo(id);
EngineVersionListResp engineConfigListResp = engIneService.getRuleEngineInfo(id);
return Result.success(engineConfigListResp);
}
@ -209,15 +209,15 @@ public class EngIneController extends BaseController {
* @return
*/
@PostMapping("/generate")
public EngineVersion generate(@RequestBody EngineVersion engineVersion) {
EngineMaintenance byId = engIneService.selectById(engineVersion.getId());
byId.setName("generate" + "_" + byId.getEngineCode() + "_" + engineVersion.getVersionCode());
engineVersion.setRuleContent(GenerateConstant.generateConstant(byId, engineVersion));
return engineVersion;
public EngineVersion generate(@RequestBody EngineVersion engineVersion) {
EngineMaintenance byId = engIneService.selectById(engineVersion.getId());
byId.setName("generate" + "_" + byId.getEngineCode() + "_" + engineVersion.getVersionCode());
engineVersion.setRuleContent(GenerateConstant.generateConstant(byId, engineVersion));
return engineVersion;
}
/**
* 通过id查询版本version信息 传入id 和 versionId
* 通过id查询版本version信息
*/
@GetMapping("/findVersionById/{id}")
public Result findVersionById(@PathVariable("id") Long id) {

4
cloud-etl-server/src/main/java/com/muyu/controller/EngineLevelController.java
View File

@ -1,13 +1,9 @@
package com.muyu.controller;
import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.domain.EngineLevelEntity;
import com.muyu.domain.EngineMaintenance;
import com.muyu.domain.EngineVersion;
import com.muyu.domain.constants.Result;
import com.muyu.service.EngineLevelService;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

1
cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java
View File

@ -176,6 +176,7 @@ public class EngineVersionController extends BaseController {
*/
@PostMapping("/insertVersion")
public boolean insertVersion(@RequestBody EngineVersion engineVersion) {
System.out.println("88888888888888888888888888888"+engineVersion.getRuleContent());
OssUpload.uploadFiles(engineVersion.getRuleContent(), engineVersion.getVersionCode());
engineVersion.setId(null);
boolean insert = engineVersionService.insert(engineVersion);

1
cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_PHONE_TEST_V1.java
View File

@ -2,5 +2,4 @@ package com.muyu.engine.value;
public class ENGINE_PHONE_TEST_V1 {
}

6
cloud-etl-server/src/main/java/com/muyu/handler/DataEngineDataSetHandler.java
View File

@ -4,9 +4,11 @@ import com.muyu.abstracts.DataValue;
public class DataEngineDataSetHandler {
public static void set(DataValue[][] dataDescribe){DataEngineHandler.set(dataDescribe);}
public static void set(DataValue[][] dataDescribe) {
DataEngineHandler.set(dataDescribe);
}
public static DataValue[][] get(){
public static DataValue[][] get() {
return DataEngineHandler.get();
}

17
cloud-etl-server/src/main/java/com/muyu/handler/DataEngineHandler.java
View File

@ -2,27 +2,22 @@ package com.muyu.handler;
public class DataEngineHandler {
private static final ThreadLocal<Object> dataEngineHandler = new ThreadLocal<>();
private static final ThreadLocal<Object> dataEngineHandler = new ThreadLocal<>();
public static void set(final Object handler){
public static void set(final Object handler) {
dataEngineHandler.set(handler);
}
public static <T> T get(){
public static <T> T get() {
return (T) dataEngineHandler.get();
return (T) dataEngineHandler.get();
}
public static void remove(){
public static void remove() {
dataEngineHandler.remove();
}
}
}

6
cloud-etl-server/src/main/java/com/muyu/handler/DataEngineRowHandler.java
View File

@ -4,9 +4,11 @@ import com.muyu.abstracts.DataValue;
public class DataEngineRowHandler {
public static void set(DataValue[] dataDescribe){DataEngineHandler.set(dataDescribe);}
public static void set(DataValue[] dataDescribe) {
DataEngineHandler.set(dataDescribe);
}
public static DataValue[] get(){
public static DataValue[] get() {
return DataEngineHandler.get();
}

1
cloud-etl-server/src/main/java/com/muyu/mapper/EngineMapper.java
View File

@ -2,7 +2,6 @@ package com.muyu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.EngineMaintenance;
import com.muyu.domain.EngineVersion;
import com.muyu.req.EngineMaintenanceQueryReq;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

2
pom.xml
View File

@ -21,9 +21,11 @@
<module>cloud-etl-remote</module>
<module>cloud-etl-server</module>
</modules>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.parameters>true</maven.compiler.parameters>
</properties>
</project>