对接前端线程池列表报警配置.

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

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
      */

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);
+
 }

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));
 

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);
+    }
+
 }

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();
+    }
+
 }