add get rule, receiver by id endpoint

manager/src/main/java/com/zmops/open/manager/controller/NoticeConfigController.java

@@ -41,6 +41,7 @@
 import org.springframework.web.bind.annotation.RestController;
 import javax.persistence.criteria.Predicate;
 import javax.validation.Valid;
+import java.util.HashSet;
 import java.util.List;
 import static com.zmops.open.common.util.CommonConstants.FAIL_CODE;
 import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
@@ -85,6 +86,17 @@ public ResponseEntity<Message<Void>> deleteNoticeReceiver(
         return ResponseEntity.ok(new Message<>("Delete success"));
     }
 
+
+    @DeleteMapping(path = "/receivers")
+    @Operation(summary = "Delete existing recipient information", description = "删除已存在的接收人信息")
+    public ResponseEntity<Message<Void>> deleteNoticeReceivers(
+            @Parameter(description = "接收人IDS", example = "6565463543") @RequestParam(required = false) List<Long> ids) {
+        if (ids != null && !ids.isEmpty()) {
+            noticeConfigService.deleteReceivers(new HashSet<>(ids));
+        }
+        return ResponseEntity.ok(new Message<>("Delete success"));
+    }
+
     @GetMapping(path = "/receiver/{id}")
     @Operation(summary = "Get existing recipient information", description = "查询已存在的接收人信息")
     public ResponseEntity<Message<NoticeReceiver>> getNoticeReceiver(
@@ -145,6 +157,16 @@ public ResponseEntity<Message<Void>> deleteNoticeRule(
         return ResponseEntity.ok(new Message<>("Delete success"));
     }
 
+
+    @DeleteMapping(path = "/rules")
+    @Operation(summary = "Delete existing notification policy information", description = "删除已存在的通知策略信息")
+    public ResponseEntity<Message<Void>> deleteNoticeRules(
+            @Parameter(description = "en: Notification Policy ID,zh: 通知策略ID", example = "6565463543") @RequestParam(required = false) List<Long> ids) {
+        noticeConfigService.deleteNoticeRules(new HashSet<>(ids));
+        return ResponseEntity.ok(new Message<>("Delete success"));
+    }
+
+
     @GetMapping(path = "/rule/{id}")
     @Operation(summary = "Get existing notification policy information", description = "查询已存在的通知策略信息")
     public ResponseEntity<Message<NoticeRule>> getNoticeRule(

manager/src/main/java/com/zmops/open/manager/dao/NoticeReceiverDao.java

@@ -21,11 +21,18 @@
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 
+import java.util.Set;
+
 /**
  * NoticeReceiver数据库操作
  * @author tom from <a href="https://github.com/dromara/hertzbeat">hertzbeat</a>
  * @date 2021/12/16 16:12
  */
 public interface NoticeReceiverDao extends JpaRepository<NoticeReceiver, Long>, JpaSpecificationExecutor<NoticeReceiver> {
 
+    /**
+     * 根据IDS删除
+     * @param ids ids
+     */
+    void deleteNoticeReceiversByIdIn(Set<Long> ids);
 }

manager/src/main/java/com/zmops/open/manager/dao/NoticeRuleDao.java

@@ -22,6 +22,7 @@
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 
 import java.util.List;
+import java.util.Set;
 
 /**
  * NoticeRule数据库操作
@@ -35,4 +36,10 @@ public interface NoticeRuleDao extends JpaRepository<NoticeRule, Long>, JpaSpeci
      * @return 通知策略
      */
     List<NoticeRule> findNoticeRulesByEnableTrue();
+
+    /**
+     * 根据IDS删除
+     * @param ids ids
+     */
+    void deleteNoticeRulesByIdIn(Set<Long> ids);
 }

manager/src/main/java/com/zmops/open/manager/service/NoticeConfigService.java

@@ -24,6 +24,7 @@
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.jpa.domain.Specification;
 
+import java.util.HashSet;
 import java.util.List;
 
 /**
@@ -135,4 +136,16 @@ public interface NoticeConfigService {
      * @return true send success | false send fail
      */
     boolean sendTestMsg(NoticeReceiver noticeReceiver);
+
+    /**
+     * delete receivers
+     * @param longs ids
+     */
+    void deleteReceivers(HashSet<Long> longs);
+
+    /**
+     * delete rules
+     * @param ids ids
+     */
+    void deleteNoticeRules(HashSet<Long> ids);
 }

manager/src/main/java/com/zmops/open/manager/service/impl/NoticeConfigServiceImpl.java

@@ -34,10 +34,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Set;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -166,4 +163,14 @@ public boolean sendTestMsg(NoticeReceiver noticeReceiver) {
         alert.setPriority(CommonConstants.ALERT_PRIORITY_CODE_CRITICAL);
         return dispatcherAlarm.sendNoticeMsg(noticeReceiver, alert);
     }
+
+    @Override
+    public void deleteReceivers(HashSet<Long> longs) {
+        noticeReceiverDao.deleteNoticeReceiversByIdIn(longs);
+    }
+
+    @Override
+    public void deleteNoticeRules(HashSet<Long> ids) {
+        noticeRuleDao.deleteNoticeRulesByIdIn(ids);
+    }
 }