diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/EtlRuleController.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/EtlRuleController.java index 122feba..c9171d7 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/EtlRuleController.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/EtlRuleController.java @@ -57,6 +57,7 @@ public class EtlRuleController { List list = etlRuleService.selectList(req); + return Result.success(list); } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java index 29840d3..c98f343 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java @@ -10,10 +10,7 @@ import lombok.RequiredArgsConstructor; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; /** * @Author:张承志 @@ -47,7 +44,33 @@ public class RuleEngineVersionController { return Result.success(); } + /** + * 激活引擎请求 + * @param id + * @return + */ + @PostMapping("/activate/{id}") + @Operation(summary = "规则引擎的激活", description = "通过Id激活规则引擎") + public Result activate(@PathVariable("id") Long id){ + versionService.activate(id); + + return Result.success(); + } + + /** + * 取消引擎请求 + */ + + + @PostMapping("/disable/{id}") + @Operation(summary = "规则引擎的取消", description = "通过Id取消规则引擎") + public Result disable(@PathVariable("id") Long id){ + + versionService.disable(id); + + return Result.success(); + } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java index 05d7947..963af77 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java @@ -22,7 +22,7 @@ public interface RuleEngineVersionService extends IService { List selectRuleEngineVersion(Long id); + void activate(Long id); - - + void disable(Long id); } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java index 109668c..7b1e504 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java @@ -2,8 +2,11 @@ package com.muyu.rule.server.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.common.core.enums.SystemYesNo; +import com.muyu.rule.common.domain.RuleEngine; import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.server.mapper.RuleEngineVersionMapper; import com.muyu.rule.server.service.RuleEngineVersionService; @@ -36,4 +39,33 @@ public class RuleEngineServiceImpl extends ServiceImpl updateWrapper = new UpdateWrapper<>(); + + updateWrapper.eq("id",id).set("open",open); + + this.update(updateWrapper); + + } + + + }