From 4d6599bf1ce637c58ecb7f977c2b271fd5840699 Mon Sep 17 00:00:00 2001
From: Qin Dong Ming <2720806930@qq.com>
Date: Fri, 23 Aug 2024 10:01:37 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=AF=BC=E5=87=BA=E6=96=B9?=
 =?UTF-8?q?=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/controller/EngIneController.java | 40 +++++++++++++++++++
 .../java/com/muyu/service/EngIneService.java  |  8 ++++
 .../serviceImpl/EngIneServiceImpl.java        | 33 +++++++++++++++
 3 files changed, 81 insertions(+)

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<EngineMaintenance> 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<EngineMaintenance> {
     Result<EngineMaintenance> 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<EngineMapper, EngineMaintenan
                 .engineVersionList(engineConfigList)
                 .build();
     }
+
+    @Override
+    public void forbiddenEngine(Long id) {
+        this.update(new LambdaUpdateWrapper<>() {{
+            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");
+        }});
+    }
 }