完善报警通知增删改功能.

hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/notify/NotifyReqDTO.java

@@ -11,6 +11,11 @@ import lombok.Data;
 @Data
 public class NotifyReqDTO {
 
+    /**
+     * id
+     */
+    private String id;
+
     /**
      * 租户id
      */

hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/notify/NotifyRespDTO.java

@@ -11,6 +11,11 @@ import lombok.Data;
 @Data
 public class NotifyRespDTO {
 
+    /**
+     * id
+     */
+    private String id;
+
     /**
      * 租户id
      */

hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/NotifyServiceImpl.java

@@ -68,20 +68,18 @@ public class NotifyServiceImpl implements NotifyService {
 
     @Override
     public void save(NotifyReqDTO reqDTO) {
-        try {
+        if (existNotify(reqDTO)) {
-            notifyInfoMapper.insert(BeanUtil.convert(reqDTO, NotifyInfo.class));
-        } catch (DuplicateKeyException ex) {
             throw new ServiceException("新增通知报警配置重复.");
         }
+
+        notifyInfoMapper.insert(BeanUtil.convert(reqDTO, NotifyInfo.class));
     }
 
     @Override
     public void update(NotifyReqDTO reqDTO) {
         NotifyInfo notifyInfo = BeanUtil.convert(reqDTO, NotifyInfo.class);
         LambdaUpdateWrapper<NotifyInfo> updateWrapper = Wrappers.lambdaUpdate(NotifyInfo.class)
-                .eq(NotifyInfo::getTenantId, reqDTO.getTenantId())
+                .eq(NotifyInfo::getId, reqDTO.getId());
-                .eq(NotifyInfo::getItemId, reqDTO.getItemId())
-                .eq(NotifyInfo::getTpId, reqDTO.getTpId());
 
         try {
             notifyInfoMapper.update(notifyInfo, updateWrapper);
@@ -93,9 +91,7 @@ public class NotifyServiceImpl implements NotifyService {
     @Override
     public void delete(NotifyReqDTO reqDTO) {
         LambdaUpdateWrapper<NotifyInfo> updateWrapper = Wrappers.lambdaUpdate(NotifyInfo.class)
-                .eq(NotifyInfo::getTenantId, reqDTO.getTenantId())
+                .eq(NotifyInfo::getId, reqDTO.getId());
-                .eq(NotifyInfo::getItemId, reqDTO.getItemId())
-                .eq(NotifyInfo::getTpId, reqDTO.getTpId());
 
         notifyInfoMapper.delete(updateWrapper);
     }
@@ -111,4 +107,16 @@ public class NotifyServiceImpl implements NotifyService {
         return notifyInfos;
     }
 
+    private boolean existNotify(NotifyReqDTO reqDTO) {
+        LambdaQueryWrapper<NotifyInfo> queryWrapper = Wrappers.lambdaQuery(NotifyInfo.class)
+                .eq(NotifyInfo::getTenantId, reqDTO.getTenantId())
+                .eq(NotifyInfo::getItemId, reqDTO.getItemId())
+                .eq(NotifyInfo::getTpId, reqDTO.getTpId())
+                .eq(NotifyInfo::getPlatform, reqDTO.getPlatform())
+                .eq(NotifyInfo::getType, reqDTO.getType());
+
+        List<NotifyInfo> existNotifyInfos = notifyInfoMapper.selectList(queryWrapper);
+        return CollUtil.isNotEmpty(existNotifyInfos);
+    }
+
 }