diff --git a/cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java b/cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java index 53f1219..67d5456 100644 --- a/cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java +++ b/cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java @@ -175,4 +175,26 @@ public class EngineVersionController extends BaseController { boolean insert = engineVersionService.insert(engineVersion); return insert; } + + /** + * 开启 + * @param id + * @return + */ + @PostMapping("/open/{id}") + public Result open(@PathVariable Integer id) { + engineVersionService.onEngine(id); + return Result.success(); + } + + /** + * 关闭 + * @param id + * @return + */ + @PostMapping("/close/{id}") + public Result close(@PathVariable Integer id) { + engineVersionService.close(id); + return Result.success(); + } } diff --git a/cloud-etl-server/src/main/java/com/muyu/mapper/EngineVersionMapper.java b/cloud-etl-server/src/main/java/com/muyu/mapper/EngineVersionMapper.java index 67bdf8f..e156f1f 100644 --- a/cloud-etl-server/src/main/java/com/muyu/mapper/EngineVersionMapper.java +++ b/cloud-etl-server/src/main/java/com/muyu/mapper/EngineVersionMapper.java @@ -20,4 +20,8 @@ public interface EngineVersionMapper extends BaseMapper { Integer add(EngineVersion engineVersion); List getByIds(@Param("versionId") Integer versionId); + + void onEngine(@Param("id") Integer id); + + void close(@Param("id") Integer id); } diff --git a/cloud-etl-server/src/main/java/com/muyu/service/EngineVersionService.java b/cloud-etl-server/src/main/java/com/muyu/service/EngineVersionService.java index bad1cf0..43b4d0f 100644 --- a/cloud-etl-server/src/main/java/com/muyu/service/EngineVersionService.java +++ b/cloud-etl-server/src/main/java/com/muyu/service/EngineVersionService.java @@ -45,4 +45,8 @@ public interface EngineVersionService extends IService { List getByIds(Integer versionId); boolean insert(EngineVersion engineVersion); + + void onEngine(Integer id); + + void close(Integer id); } diff --git a/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngineVersionServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngineVersionServiceImpl.java index 11b83d5..643769a 100644 --- a/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngineVersionServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngineVersionServiceImpl.java @@ -178,4 +178,14 @@ public class EngineVersionServiceImpl extends ServiceImpl + + update engine_version + set status = 1 + where id = #{id} + + + update engine_version + set status = 2 + where id = #{id} +