diff --git a/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java b/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java index 69ab1c1..7adb1bb 100644 --- a/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java +++ b/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java @@ -67,4 +67,44 @@ public class EngIneController extends BaseController { ExcelUtil engineMaintenanceExcelUtil = new ExcelUtil<>(EngineMaintenance.class); engineMaintenanceExcelUtil.exportExcel(httpServletResponse, list, "规则引擎版本"); } + + /** + * 通过引擎维护编号禁用引擎 + */ + @RequiresPermissions("rule-engine:maintenance:edit") + @PutMapping("/forbiddenEngine/{id}") + public Result forbiddenEngine(@PathVariable Long id) { + engIneService.forbiddenEngine(id); + return Result.success(); + } + + /** + * 通过引擎维护编号开启引擎 + */ + @RequiresPermissions("rule-engine:maintenance:edit") + @PutMapping("/onEngine/{id}") + public Result onEngine(@PathVariable Long id) { + engIneService.onEngine(id); + return Result.success(); + } + + /** + * 通过引擎维护编号关闭引擎 + */ + @RequiresPermissions("rule-engine:maintenance:edit") + @PutMapping("/closeEngine/{id}") + public Result closeEngine(@PathVariable Long id) { + engIneService.closeEngine(id); + return Result.success(); + } + + /** + * 通过引擎维护编号激活引擎 + */ + @RequiresPermissions("rule-engine:maintenance:edit") + @PutMapping("/activateEngine/{id}") + public Result activateEngine(@PathVariable Long id) { + engIneService.activateEngine(id); + return Result.success(); + } } diff --git a/cloud-etl-server/src/main/java/com/muyu/service/EngIneService.java b/cloud-etl-server/src/main/java/com/muyu/service/EngIneService.java index ce30544..ee37003 100644 --- a/cloud-etl-server/src/main/java/com/muyu/service/EngIneService.java +++ b/cloud-etl-server/src/main/java/com/muyu/service/EngIneService.java @@ -25,4 +25,12 @@ public interface EngIneService extends IService { Result insert(EngineMaintenance engineMaintenance); EngineVersionListResp getRuleEngineInfo(Long id); + + void forbiddenEngine(Long id); + + void onEngine(Long id); + + void closeEngine(Long id); + + void activateEngine(Long id); } diff --git a/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngIneServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngIneServiceImpl.java index 46b2de5..054c0ad 100644 --- a/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngIneServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngIneServiceImpl.java @@ -1,6 +1,7 @@ package com.muyu.service.serviceImpl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.muyu.common.core.domain.Result; import com.muyu.common.core.utils.StringUtils; @@ -110,4 +111,36 @@ public class EngIneServiceImpl extends ServiceImpl() {{ + eq(EngineMaintenance::getId, id); + set(EngineMaintenance::getIsActivate, "N"); + }}); + } + + @Override + public void onEngine(Long id) { + this.update(new LambdaUpdateWrapper<>() {{ + eq(EngineMaintenance::getId, id); + set(EngineMaintenance::getStatus, "Y"); + }}); + } + + @Override + public void closeEngine(Long id) { + this.update(new LambdaUpdateWrapper<>() {{ + eq(EngineMaintenance::getId, id); + set(EngineMaintenance::getStatus, "N"); + }}); + } + + @Override + public void activateEngine(Long id) { + this.update(new LambdaUpdateWrapper<>() {{ + eq(EngineMaintenance::getId, id); + set(EngineMaintenance::getIsActivate, "Y"); + }}); + } }