使用Mybatis-Plus方法

master
Qin Dong Ming 2024-09-01 09:38:41 +08:00
parent 585aed0321
commit 63bb6f5965
23 changed files with 108 additions and 301 deletions

View File

@ -44,6 +44,9 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/getMaintenanceList") @PostMapping("/getMaintenanceList")
public Result<PageResult<EngineMaintenance>> getMaintenanceList(@RequestBody EngineMaintenanceQueryReq engineMaintenanceQueryReq) { public Result<PageResult<EngineMaintenance>> getMaintenanceList(@RequestBody EngineMaintenanceQueryReq engineMaintenanceQueryReq) {
//使用mabits-plus-plus的查询方法
// engineMaintenanceQueryReq.setPageNum(engineMaintenanceQueryReq.getPageNum());
// engineMaintenanceQueryReq.setPageSize(engineMaintenanceQueryReq.getPageSize());
return engIneService.getMaintenanceList(engineMaintenanceQueryReq); return engIneService.getMaintenanceList(engineMaintenanceQueryReq);
} }
@ -55,6 +58,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/delete/{id}") @PostMapping("/delete/{id}")
public Integer remove(@PathVariable Long id) { public Integer remove(@PathVariable Long id) {
//使用mabits-plusplus的删除方法
// engIneService.delete(id);
return engIneService.deletes(id); return engIneService.deletes(id);
} }
@ -66,6 +71,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/update") @PostMapping("/update")
public Result<EngineMaintenance> update(@RequestBody EngineMaintenance engineMaintenance) { public Result<EngineMaintenance> update(@RequestBody EngineMaintenance engineMaintenance) {
//使用mabits-plusplus的修改方法
// engIneService.updateMsg(engineMaintenance);
return engIneService.updateMsg(engineMaintenance); return engIneService.updateMsg(engineMaintenance);
} }
@ -77,6 +84,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/insert") @PostMapping("/insert")
public Result<EngineMaintenance> insert(@RequestBody EngineMaintenance engineMaintenance) { public Result<EngineMaintenance> insert(@RequestBody EngineMaintenance engineMaintenance) {
//使用mabits-plus-plus的添加方法
// engIneService.add(engineMaintenance);
return engIneService.add(engineMaintenance); return engIneService.add(engineMaintenance);
} }
@ -85,6 +94,8 @@ public class EngIneController extends BaseController {
*/ */
@PutMapping("/getRuleEngineInfo/{id}") @PutMapping("/getRuleEngineInfo/{id}")
public Result getRuleEngineInfo(@PathVariable(name = "id") Long id) { public Result getRuleEngineInfo(@PathVariable(name = "id") Long id) {
//使用mabits-plus-plus的查询方法
// engIneService.getRuleEngineInfo(id);
EngineVersionListResp engineConfigListResp = engIneService.getRuleEngineInfo(id); EngineVersionListResp engineConfigListResp = engIneService.getRuleEngineInfo(id);
return Result.success(engineConfigListResp); return Result.success(engineConfigListResp);
} }
@ -104,6 +115,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/forbiddenEngine/{id}") @PostMapping("/forbiddenEngine/{id}")
public Result forbiddenEngine(@PathVariable Integer id) { public Result forbiddenEngine(@PathVariable Integer id) {
//使用mybatis-plus的禁用方法
// engIneService.forbiddenEngine(id);
return engIneService.forbiddenEngine(id); return engIneService.forbiddenEngine(id);
} }
@ -112,6 +125,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/onEngine/{id}") @PostMapping("/onEngine/{id}")
public Result onEngine(@PathVariable Integer id) { public Result onEngine(@PathVariable Integer id) {
//使用mybatis-plus的开启方法
// engIneService.onEngine(id);
engIneService.onEngine(id); engIneService.onEngine(id);
return Result.success(); return Result.success();
} }
@ -121,6 +136,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/closeEngine/{id}") @PostMapping("/closeEngine/{id}")
public Result closeEngine(@PathVariable Integer id) { public Result closeEngine(@PathVariable Integer id) {
//使用mybatis-plus的关闭方法
// engIneService.closeEngine(id);
engIneService.closeEngine(id); engIneService.closeEngine(id);
return Result.success(); return Result.success();
} }
@ -130,6 +147,8 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/activateEngine/{id}") @PostMapping("/activateEngine/{id}")
public Result activateEngine(@PathVariable Integer id) { public Result activateEngine(@PathVariable Integer id) {
//使用mybatis-plus的激活方法
// engIneService.activateEngine(id);
engIneService.activateEngine(id); engIneService.activateEngine(id);
return Result.success(); return Result.success();
} }
@ -142,6 +161,11 @@ public class EngIneController extends BaseController {
*/ */
@GetMapping("/findById/{id}") @GetMapping("/findById/{id}")
public Result findById(@PathVariable Long id) { public Result findById(@PathVariable Long id) {
//使用mybatis-plus的查询方法
//List<EngineMaintenance> list = engIneService.list();
//List<EngineMaintenance> list = engIneService.list(new LambdaQueryWrapper<>() {{
// eq(EngineMaintenance::getId, id);
//}});
List<EngineMaintenance> list = engIneService.list(new LambdaQueryWrapper<>() {{ List<EngineMaintenance> list = engIneService.list(new LambdaQueryWrapper<>() {{
eq(EngineMaintenance::getId, id); eq(EngineMaintenance::getId, id);
}}); }});
@ -156,6 +180,8 @@ public class EngIneController extends BaseController {
*/ */
@GetMapping("/findByIds/{id}") @GetMapping("/findByIds/{id}")
public Result findVersionByIds(@PathVariable("id") Long id) { public Result findVersionByIds(@PathVariable("id") Long id) {
//使用mybatis-plus的查询方法
// return Result.success(engineVersionService.getByIds(id));
return Result.success(engineVersionService.list(new LambdaQueryWrapper<>() {{ return Result.success(engineVersionService.list(new LambdaQueryWrapper<>() {{
eq(EngineVersion::getId, id); eq(EngineVersion::getId, id);
}})); }}));
@ -166,6 +192,10 @@ public class EngIneController extends BaseController {
*/ */
@PostMapping("/selectEngineById/{versionId}") @PostMapping("/selectEngineById/{versionId}")
public List<EngineMaintenance> selectEngineById(@PathVariable Integer versionId) { public List<EngineMaintenance> selectEngineById(@PathVariable Integer versionId) {
//使用mybatis-plus的查询方法
// List<EngineMaintenance> engineMaintenances = engIneService.list(new LambdaQueryWrapper<>() {{
// eq(EngineMaintenance::getVersionId, versionId);
// }});
List<EngineMaintenance> engineMaintenances = engineVersionService.getByIds(versionId); List<EngineMaintenance> engineMaintenances = engineVersionService.getByIds(versionId);
return engineMaintenances; return engineMaintenances;
} }

View File

@ -1,6 +1,7 @@
package com.muyu.controller; package com.muyu.controller;
import com.muyu.common.core.utils.poi.ExcelUtil; 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.EngineLevelEntity;
import com.muyu.domain.EngineMaintenance; import com.muyu.domain.EngineMaintenance;
import com.muyu.domain.EngineVersion; import com.muyu.domain.EngineVersion;
@ -21,7 +22,7 @@ import java.util.List;
*/ */
@RestController @RestController
@RequestMapping("/level") @RequestMapping("/level")
public class EngineLevelController { public class EngineLevelController extends BaseController {
@Autowired @Autowired
EngineLevelService engineLevelService; EngineLevelService engineLevelService;
@ -31,6 +32,8 @@ public class EngineLevelController {
*/ */
@PostMapping("/selectLevelList") @PostMapping("/selectLevelList")
public List<EngineLevelEntity> selectLevelList() { public List<EngineLevelEntity> selectLevelList() {
//使用mybatis-plus查询
// List<EngineLevelEntity> lists = engineLevelService.selectLevelList();
return engineLevelService.selectLevelLists(); return engineLevelService.selectLevelLists();
} }
@ -39,6 +42,8 @@ public class EngineLevelController {
*/ */
@PostMapping("/insert") @PostMapping("/insert")
public Result<EngineLevelEntity> insert(EngineLevelEntity engineLevelEntity) { public Result<EngineLevelEntity> insert(EngineLevelEntity engineLevelEntity) {
//使用mybatis-plus新增
// engineLevelService.insert(engineLevelEntity);
return engineLevelService.insert(engineLevelEntity); return engineLevelService.insert(engineLevelEntity);
} }
@ -47,6 +52,8 @@ public class EngineLevelController {
*/ */
@PostMapping("/update") @PostMapping("/update")
public Result<EngineLevelEntity> update(EngineLevelEntity engineLevelEntity) { public Result<EngineLevelEntity> update(EngineLevelEntity engineLevelEntity) {
//使用mybatis-plus修改
// engineLevelService.update(engineLevelEntity);
return engineLevelService.update(engineLevelEntity); return engineLevelService.update(engineLevelEntity);
} }
@ -55,6 +62,8 @@ public class EngineLevelController {
*/ */
@PostMapping("/delete/{id}") @PostMapping("/delete/{id}")
public Result delete(@PathVariable Integer id) { public Result delete(@PathVariable Integer id) {
//使用mybatis-plus删除
// return engineLevelService.delete(id);
return engineLevelService.delete(id); return engineLevelService.delete(id);
} }
@ -71,6 +80,8 @@ public class EngineLevelController {
*/ */
@PostMapping("/selectById/{id}") @PostMapping("/selectById/{id}")
public Result selectById(@PathVariable Integer id) { public Result selectById(@PathVariable Integer id) {
//使用mybatis-plus回显
// return engineLevelService.selectById(id);
return engineLevelService.selectById(id); return engineLevelService.selectById(id);
} }
} }

View File

@ -2,6 +2,7 @@ package com.muyu.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.security.annotation.RequiresPermissions; import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.domain.EngineVersion; import com.muyu.domain.EngineVersion;
import com.muyu.domain.model.TestData; import com.muyu.domain.model.TestData;
@ -25,7 +26,7 @@ import java.util.List;
*/ */
@RestController @RestController
@RequestMapping("/version") @RequestMapping("/version")
public class EngineVersionController { public class EngineVersionController extends BaseController {
@Autowired @Autowired
EngineVersionService engineVersionService; EngineVersionService engineVersionService;
@ -44,6 +45,8 @@ public class EngineVersionController {
*/ */
@GetMapping("/selectVersionList") @GetMapping("/selectVersionList")
public Result<List<EngineVersion>> selectVersionList() { public Result<List<EngineVersion>> selectVersionList() {
//使用mybatis-plus 查询所有
// return Result.success(engineVersionService.list());
return Result.success(engineVersionService.list()); return Result.success(engineVersionService.list());
} }
@ -54,6 +57,8 @@ public class EngineVersionController {
*/ */
@PostMapping("/insert") @PostMapping("/insert")
public Result<EngineVersion> insert(@RequestBody EngineVersion engineVersion) { public Result<EngineVersion> insert(@RequestBody EngineVersion engineVersion) {
//使用mybatis-plus 添加
// engineVersionService.save(engineVersion);
return engineVersionService.add(engineVersion); return engineVersionService.add(engineVersion);
} }
@ -64,6 +69,8 @@ public class EngineVersionController {
*/ */
@PostMapping("/update") @PostMapping("/update")
public EngineVersion update(@RequestBody EngineVersion engineVersion) { public EngineVersion update(@RequestBody EngineVersion engineVersion) {
//使用mybatis-plus 修改
// engineVersionService.updateById(engineVersion);
return engineVersionService.updateMsg(engineVersion); return engineVersionService.updateMsg(engineVersion);
} }
@ -74,6 +81,8 @@ public class EngineVersionController {
*/ */
@PostMapping("/delete/{id}") @PostMapping("/delete/{id}")
public Result delete(@PathVariable Long id) { public Result delete(@PathVariable Long id) {
//使用mybatis-plus 删除
// engineVersionService.removeById(id);
boolean b = engineVersionService.removeById(id); boolean b = engineVersionService.removeById(id);
return Result.success(b); return Result.success(b);
} }
@ -85,6 +94,8 @@ public class EngineVersionController {
*/ */
@GetMapping("/getVersion/{id}") @GetMapping("/getVersion/{id}")
public Result<EngineVersion> getVersion(@PathVariable("id") Long id) { public Result<EngineVersion> getVersion(@PathVariable("id") Long id) {
//使用mybatis-plus 查询
// engineVersionService.getById(id);
EngineVersion engineVersion = engineVersionService.getById(id); EngineVersion engineVersion = engineVersionService.getById(id);
return Result.success(engineVersion); return Result.success(engineVersion);
} }
@ -94,6 +105,8 @@ public class EngineVersionController {
*/ */
@GetMapping("/getScopeList") @GetMapping("/getScopeList")
public Result<List<EngineConfigScopeResp>> getScopeList() { public Result<List<EngineConfigScopeResp>> getScopeList() {
//使用mybatis-plus 查询
//return Result.success(engineVersionService.getScopeList());
return Result.success(engineVersionService.getScopeList()); return Result.success(engineVersionService.getScopeList());
} }
@ -103,6 +116,8 @@ public class EngineVersionController {
@RequiresPermissions("rule-engine:version:list") @RequiresPermissions("rule-engine:version:list")
@GetMapping("/getScopeInfo/{id}") @GetMapping("/getScopeInfo/{id}")
public Result<EngineConfigScopeResp> getScopeInfoById(@PathVariable Integer id) { public Result<EngineConfigScopeResp> getScopeInfoById(@PathVariable Integer id) {
//使用mybatis-plus 查询
//return Result.success(engineVersionService.getScopeInfoById(id));
return Result.success(engineVersionService.getScopeInfoById(id)); return Result.success(engineVersionService.getScopeInfoById(id));
} }
@ -111,6 +126,8 @@ public class EngineVersionController {
*/ */
@PostMapping(value = "/test") @PostMapping(value = "/test")
public Result<Object> ruleTest(@RequestBody TestData testData) { public Result<Object> ruleTest(@RequestBody TestData testData) {
//使用mybatis-plus 测试
// testData.setId(1L);
return Result.success(engineVersionService.ruleTest(testData)); return Result.success(engineVersionService.ruleTest(testData));
} }
@ -140,6 +157,8 @@ public class EngineVersionController {
*/ */
@PostMapping("/selectListById/{id}") @PostMapping("/selectListById/{id}")
public Result selectListById(@PathVariable Long id){ public Result selectListById(@PathVariable Long id){
//使用mybatis-plus 查询
// return Result.success(engineVersionService.getByIds(id));
return Result.success(engineVersionService.getById(id)); return Result.success(engineVersionService.getById(id));
} }
@ -149,6 +168,8 @@ public class EngineVersionController {
*/ */
@PostMapping("/insertVersion") @PostMapping("/insertVersion")
public boolean insertVersion(@RequestBody EngineVersion engineVersion) { public boolean insertVersion(@RequestBody EngineVersion engineVersion) {
//使用mybatis-plus 添加
// engineVersionService.add(engineVersion);
return engineVersionService.save(engineVersion); return engineVersionService.save(engineVersion);
} }
} }

View File

@ -1,6 +1,7 @@
package com.muyu.controller; package com.muyu.controller;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.domain.EngineType; import com.muyu.domain.EngineType;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
import com.muyu.service.TypeService; import com.muyu.service.TypeService;
@ -20,7 +21,7 @@ import java.util.List;
*/ */
@RestController @RestController
@RequestMapping("/type") @RequestMapping("/type")
public class TypeController { public class TypeController extends BaseController {
@Autowired @Autowired
TypeService typeService; TypeService typeService;

View File

@ -1,5 +1,6 @@
package com.muyu.mapper; package com.muyu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.EngineLevelEntity; import com.muyu.domain.EngineLevelEntity;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@ -14,10 +15,10 @@ import java.util.List;
* @Date2024/8/25 18:54 * @Date2024/8/25 18:54
*/ */
@Mapper @Mapper
public interface EnginLevelMapper { public interface EnginLevelMapper extends BaseMapper<EngineLevelEntity> {
List<EngineLevelEntity> selectLevelList(); List<EngineLevelEntity> selectLevelList();
Integer insert(EngineLevelEntity engineLevelEntity); // Integer insert(EngineLevelEntity engineLevelEntity);
Integer update(EngineLevelEntity engineLevelEntity); Integer update(EngineLevelEntity engineLevelEntity);

View File

@ -1,5 +1,6 @@
package com.muyu.mapper; package com.muyu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.EngineType; import com.muyu.domain.EngineType;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@ -14,7 +15,7 @@ import java.util.List;
* @Date2024/8/23 22:36 * @Date2024/8/23 22:36
*/ */
@Mapper @Mapper
public interface TypseMapper { public interface TypseMapper extends BaseMapper<EngineType> {
List<EngineType> list(); List<EngineType> list();

View File

@ -1,5 +1,6 @@
package com.muyu.service; package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.controller.EngineLevelController; import com.muyu.controller.EngineLevelController;
import com.muyu.domain.EngineLevelEntity; import com.muyu.domain.EngineLevelEntity;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
@ -13,7 +14,7 @@ import java.util.List;
* @nameEngineLevelService * @nameEngineLevelService
* @Date2024/8/25 18:52 * @Date2024/8/25 18:52
*/ */
public interface EngineLevelService { public interface EngineLevelService extends IService<EngineLevelEntity> {
List<EngineLevelEntity> selectLevelList(); List<EngineLevelEntity> selectLevelList();
Result<EngineLevelEntity> insert(EngineLevelEntity engineLevelEntity); Result<EngineLevelEntity> insert(EngineLevelEntity engineLevelEntity);

View File

@ -1,5 +1,7 @@
package com.muyu.service; package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.EngineMaintenance;
import com.muyu.domain.EngineType; import com.muyu.domain.EngineType;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
@ -13,7 +15,7 @@ import java.util.List;
* @nameTypeService * @nameTypeService
* @Date2024/8/23 22:35 * @Date2024/8/23 22:35
*/ */
public interface TypeService { public interface TypeService extends IService<EngineType> {
List<EngineType> list(); List<EngineType> list();
Result add(EngineType type); Result add(EngineType type);

View File

@ -1,13 +1,17 @@
package com.muyu.service.serviceImpl; package com.muyu.service.serviceImpl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.EngineLevelEntity; import com.muyu.domain.EngineLevelEntity;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
import com.muyu.mapper.EnginLevelMapper; import com.muyu.mapper.EnginLevelMapper;
import com.muyu.mapper.EngineMapper;
import com.muyu.service.EngineLevelService; import com.muyu.service.EngineLevelService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* @Authorqdm * @Authorqdm
@ -17,7 +21,7 @@ import java.util.List;
* @Date2024/8/25 18:52 * @Date2024/8/25 18:52
*/ */
@Service @Service
public class EngineLevelServiceImpl implements EngineLevelService { public class EngineLevelServiceImpl extends ServiceImpl<EnginLevelMapper, EngineLevelEntity> implements EngineLevelService {
@Autowired @Autowired
EnginLevelMapper enginLevelMapper; EnginLevelMapper enginLevelMapper;
@ -78,4 +82,29 @@ public class EngineLevelServiceImpl implements EngineLevelService {
List<EngineLevelEntity> list = enginLevelMapper.lists(); List<EngineLevelEntity> list = enginLevelMapper.lists();
return list; return list;
} }
@Override
public boolean save(EngineLevelEntity entity) {
return super.save(entity);
}
@Override
public boolean saveBatch(Collection<EngineLevelEntity> entityList) {
return super.saveBatch(entityList);
}
@Override
public boolean saveOrUpdateBatch(Collection<EngineLevelEntity> entityList) {
return super.saveOrUpdateBatch(entityList);
}
@Override
public boolean removeById(EngineLevelEntity entity) {
return super.removeById(entity);
}
@Override
public boolean removeByMap(Map<String, Object> columnMap) {
return super.removeByMap(columnMap);
}
} }

View File

@ -1,5 +1,6 @@
package com.muyu.service.serviceImpl; package com.muyu.service.serviceImpl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.EngineType; import com.muyu.domain.EngineType;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
@ -18,7 +19,7 @@ import java.util.List;
* @Date2024/8/23 22:35 * @Date2024/8/23 22:35
*/ */
@Service @Service
public class TypeServiceImpl implements TypeService { public class TypeServiceImpl extends ServiceImpl<TypseMapper, EngineType> implements TypeService {
@Autowired @Autowired
TypseMapper typseMapper; TypseMapper typseMapper;

View File

@ -1,32 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-engine</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>elt-data-access</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-client</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
</project>

View File

@ -1,39 +0,0 @@
//package com.bwie.muyu;
//
//import com.bwie.muyu.base.EngineException;
//import com.muyu.config.EngineConfig;
//import lombok.Data;
//import lombok.extern.log4j.Log4j2;
//import org.springframework.stereotype.Component;
//
//import java.util.HashMap;
//import java.util.Map;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu
// * @Projectcloud-etl-engine
// * @nameEngIneTest
// * @Date2024/8/30 9:27
// */
//@Component
//@Log4j2
//@Data
//public class EngIneTest {
//
// private static Object SouRceCodeCompiler;
//
// public static void main(String[] args) {
// EngineConfig engineConfig = new EngineConfig();
// //扫描源码进行注释
// SouRceCodeCompiler.javaCompilerPath(engineConfig.getLocation());
// Map<String, Class<?>> stringClassMap = JavaBinaryClassLoader.loadClassByLocation(engineConfig.getPack(), engineConfig, getLocation);
// stringClassMap.forEach((key, value) -> {
// EngineContainer.loadEngineInstance(key, value);
// }); jn
// HashMap<String, Object> params = new HashMap<>();
// params.put("idCard", "142021200212215977");
// EngineException.engineExe("Engine_2020_11_3_2347", params);
// System.out.println("Engine_2020_11_3_2347");
// }
//}

View File

@ -1,17 +0,0 @@
package com.bwie.muyu;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @Authorqdm
* @Packagecom.bwie.muyu
* @Projectcloud-etl-engine
* @nameMuyuApplication
* @Date2024/8/29 20:19
*/
@SpringBootApplication
public class MuyuApplication {
public static void main(String[] args) {
org.springframework.boot.SpringApplication.run(MuyuApplication.class, args);
}
}

View File

@ -1,12 +0,0 @@
//package com.bwie.muyu.base;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameBaseEngine
// * @Date2024/8/29 20:23
// */
//public interface BaseEngine {
//
//}

View File

@ -1,24 +0,0 @@
//package com.bwie.muyu.base;
//
//import lombok.AllArgsConstructor;
//import lombok.Builder;
//import lombok.Data;
//import lombok.NoArgsConstructor;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameEngineContainer
// * @Date2024/8/30 11:32
// */
//@Data
//@AllArgsConstructor
//@NoArgsConstructor
//@Builder
//public class EngineContainer {
//
// public static Integer getSumEngine() {
// return null;
// }
//}

View File

@ -1,20 +0,0 @@
//package com.bwie.muyu.base;
//
//import java.util.HashMap;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameEngineExcepion
// * @Date2024/8/30 10:50
// */
//public class EngineException {
//// public engineException(String message){
//// super.(message);
//// }
//
// public static void engineExe(String engine20201132347, HashMap<String, Object> params) {
//
// }
//}

View File

@ -1,22 +0,0 @@
//package com.bwie.muyu.base;
//
//import java.lang.annotation.ElementType;
//import java.lang.annotation.Retention;
//import java.lang.annotation.RetentionPolicy;
//import java.lang.annotation.Target;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameEngineParam
// * @Date2024/8/30 10:46
// */
//@Retention(RetentionPolicy.RUNTIME)
//@Target(ElementType.PARAMETER)
//public @interface EngineParam {
// /**
// * 输入字段名称
// */
// public String name();
//}

View File

@ -1,34 +0,0 @@
//package com.bwie.muyu.base;
//
//import com.muyu.common.core.utils.SpringUtils;
//import org.springframework.boot.autoconfigure.security.SecurityProperties;
//
//import java.util.Date;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameEngine_2020_11_3_2347
// * @Date2024/8/30 10:32
// */
//public class Engine_2020_11_3_2347 {
// public String execute(@EngineParam(name="idCard")String idCard){
// String msg = "";
// Integer year = Integer.valueOf(idCard.substring(6, 10));
// Date date = new Date();
// int thisYear = date.getYear() + 1900;
// msg = "这个身份证的年龄是:"+ (thisYear - year);
// Integer two = Integer.valueOf(idCard.substring(16, 17));
// if (two % 2 == 0){
// msg += ",这个身份证是男生";
// }else {
// msg += ",这个身份证是女生";
// }
// Integer sumEngine = EngineContainer.getSumEngine();
// System.out.println("项目中规则引擎数量为:"+sumEngine);
// User bean = SpringUtils.getBean(User.class);
// System.out.println(bean.getName()+"--"+bean.getAge);
// return msg;
// }
//}

View File

@ -1,17 +0,0 @@
//package com.bwie.muyu.base;
//
//import com.muyu.config.EngineConfig;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameTest
// * @Date2024/8/30 11:16
// */
//public class Test {
// public static void main(String[] args) {
// EngineConfig engineConfig = new EngineConfig();
//
// }
//}

View File

@ -1,22 +0,0 @@
//package com.bwie.muyu.base;
//
//import lombok.AllArgsConstructor;
//import lombok.Builder;
//import lombok.Data;
//import lombok.NoArgsConstructor;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base
// * @Projectcloud-etl-engine
// * @nameUser
// * @Date2024/8/30 11:33
// */
//@Data
//@AllArgsConstructor
//@NoArgsConstructor
//@Builder
//public class User {
// public String getAge;
// private String name;
//}

View File

@ -1,23 +0,0 @@
//package com.bwie.muyu.base.hander;
//
//import lombok.Data;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base.hander
// * @Projectcloud-etl-engine
// * @nameDataEngineHandler
// * @Date2024/8/29 20:26
// */
//@Data
//public class DataEngineHandler {
// public static final ThreadLocal<Object> DataEngineHandler = new ThreadLocal<>();
//
// public static void set(final Object handler) {
// DataEngineHandler.set(handler);
// }
//
// public static <T> T get() {
// return (T) DataEngineHandler.get();
// }
//}

View File

@ -1,28 +0,0 @@
//package com.bwie.muyu.base.hander;
//
///**
// * @Authorqdm
// * @Packagecom.bwie.muyu.base.hander
// * @Projectcloud-etl-engine
// * @nameDataEngineValue
// * @Date2024/8/29 20:31
// */
//
//public class DataEngineValue {
//
// public static void set(DataEngineValue dataEngineValue) {
// DataEngineHandler.set(dataEngineValue);
// }
//
// public static DataEngineValue get() {
// return DataEngineHandler.get();
// }
//
// public static Object getValue() {
// return get().getValue();
// }
//
// public static Integer getIntegerValue() {
// return get().getIntegerValue();
// }
//}

View File

@ -20,7 +20,6 @@
<module>cloud-etl-common</module> <module>cloud-etl-common</module>
<module>cloud-etl-remote</module> <module>cloud-etl-remote</module>
<module>cloud-etl-server</module> <module>cloud-etl-server</module>
<module>elt-data-access</module>
</modules> </modules>
<properties> <properties>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>