diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/model/ConfigInfoBase.java b/hippo4j-config/src/main/java/cn/hippo4j/config/model/ConfigInfoBase.java index 2c607381..ba11acce 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/model/ConfigInfoBase.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/model/ConfigInfoBase.java @@ -22,7 +22,7 @@ public class ConfigInfoBase implements Serializable { * ID */ @TableId(type = IdType.AUTO) - private Integer id; + private Long id; /** * tenantId diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ThreadPoolRespDTO.java b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ThreadPoolRespDTO.java index 769e717b..3c564e4f 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ThreadPoolRespDTO.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ThreadPoolRespDTO.java @@ -14,6 +14,11 @@ import java.util.Date; @Data public class ThreadPoolRespDTO { + /** + * id + */ + private String id; + /** * tenantId */ diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/ThreadPoolService.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/ThreadPoolService.java index c3f3d15f..55002e09 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/ThreadPoolService.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/ThreadPoolService.java @@ -55,4 +55,12 @@ public interface ThreadPoolService { */ void deletePool(ThreadPoolDelReqDTO reqDTO); + /** + * Alarm enable. + * + * @param id + * @param isAlarm + */ + void alarmEnable(String id, Integer isAlarm); + } diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java index 20d9f9cd..e78e3f41 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java @@ -78,7 +78,7 @@ public class ConfigServiceImpl implements ConfigService { ConfigChangePublisher.notifyConfigChange(new LocalDataChangeEvent(identify, ContentUtil.getGroupKey(configInfo))); } - public Integer addConfigInfo(ConfigAllInfo config) { + public Long addConfigInfo(ConfigAllInfo config) { config.setContent(ContentUtil.getPoolContent(config)); config.setMd5(Md5Util.getTpContentMd5(config)); diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ThreadPoolServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ThreadPoolServiceImpl.java index 7665f716..d238a7c0 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ThreadPoolServiceImpl.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ThreadPoolServiceImpl.java @@ -74,4 +74,12 @@ public class ThreadPoolServiceImpl implements ThreadPoolService { ); } + @Override + public void alarmEnable(String id, Integer isAlarm) { + ConfigAllInfo configAllInfo = configInfoMapper.selectById(id); + configAllInfo.setIsAlarm(isAlarm); + // TODO: 是否报警变更, 虽然通知了客户端, 但是并没有在客户端实时生效, 需要考虑一个好的场景思路 + configService.insertOrUpdate(null, configAllInfo); + } + } diff --git a/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java b/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java index 2e1fc691..c5d831a1 100644 --- a/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java +++ b/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java @@ -88,4 +88,10 @@ public class ThreadPoolController { return Results.success(); } + @PostMapping("/alarm/enable/{id}/{isAlarm}") + public Result alarmEnable(@PathVariable("id") String id, @PathVariable("isAlarm") Integer isAlarm) { + threadPoolService.alarmEnable(id, isAlarm); + return Results.success(); + } + }