feat(sj_1.0.0): 新增通知人接口和更新通知人

doc/sql/snail_job_mysql.sql

@@ -72,7 +72,6 @@ CREATE TABLE `sj_notify_recipient`
 (
     `id`               bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
     `namespace_id`     varchar(64)  NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
-    `group_name`       varchar(64)  NOT NULL COMMENT '组名称',
     `recipient_name`   varchar(64)  NOT NULL COMMENT '接收人名称',
     `notify_type`      tinyint(4) NOT NULL DEFAULT 0 COMMENT '通知类型 1、钉钉 2、邮件 3、企业微信 4 飞书',
     `notify_attribute` varchar(512) NOT NULL COMMENT '配置属性',

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/po/NotifyRecipient.java

@@ -37,11 +37,6 @@ public class NotifyRecipient implements Serializable {
      */
     private String namespaceId;
 
-    /**
-     * 组名称
-     */
-    private String groupName;
-
     /**
      * 接收人名称
      */

snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/NotifyRecipientMapper.xml

@@ -6,7 +6,6 @@
     <resultMap id="BaseResultMap" type="com.aizuda.snailjob.template.datasource.persistence.po.NotifyRecipient">
         <id column="id" property="id" />
         <result column="namespace_id" property="namespaceId" />
-        <result column="group_name" property="groupName" />
         <result column="recipient_name" property="recipientName" />
         <result column="notify_type" property="notifyType" />
         <result column="notify_attribute" property="notifyAttribute" />

snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/annotation/Update.java

@@ -0,0 +1,10 @@
+package com.aizuda.snailjob.server.web.annotation;
+
+/**
+ * @author: opensnail
+ * @date : 2024-04-18
+ * @since : sj_1.0.0
+ */
+public @interface Update {
+
+}

snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/request/NotifyRecipientRequestVO.java

@@ -1,9 +1,41 @@
 package com.aizuda.snailjob.server.web.model.request;
 
+import com.aizuda.snailjob.server.web.annotation.Update;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
 /**
  * @author opensnail
  * @date 2024-04-17 22:03:33
  * @since sj_1.0.0
  */
+@Data
 public class NotifyRecipientRequestVO {
+
+    @NotNull(message = "id不能为空", groups = Update.class)
+    private Long id;
+
+    /**
+     * 接收人名称
+     */
+    @NotBlank(message = "接收人名称不能为空")
+    private String recipientName;
+
+    /**
+     * 通知类型 1、钉钉 2、邮件 3、企业微信 4 飞书
+     */
+    @NotNull(message = "通知类型不能为空")
+    private Integer notifyType;
+
+    /**
+     * 配置属性
+     */
+    @NotBlank(message = "配置属性不能为空")
+    private String notifyAttribute;
+
+    /**
+     * 描述
+     */
+    private String description;
 }

snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/convert/NotifyRecipientConverter.java

@@ -1,5 +1,6 @@
 package com.aizuda.snailjob.server.web.service.convert;
 
+import com.aizuda.snailjob.server.web.model.request.NotifyRecipientRequestVO;
 import com.aizuda.snailjob.server.web.model.response.NotifyRecipientResponseVO;
 import com.aizuda.snailjob.template.datasource.persistence.po.NotifyRecipient;
 import org.mapstruct.Mapper;
@@ -13,10 +14,11 @@ import java.util.List;
  * @since sj_1.0.0
  */
 @Mapper
-public interface NotifyRecipientResponseVOConverter {
+public interface NotifyRecipientConverter {
 
-    NotifyRecipientResponseVOConverter INSTANCE = Mappers.getMapper(NotifyRecipientResponseVOConverter.class);
+    NotifyRecipientConverter INSTANCE = Mappers.getMapper(NotifyRecipientConverter.class);
 
     List<NotifyRecipientResponseVO> toNotifyRecipientResponseVOs(List<NotifyRecipient> notifyRecipients);
 
+    NotifyRecipient toNotifyRecipient(NotifyRecipientRequestVO requestVO);
 }

snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java

@@ -1,11 +1,12 @@
 package com.aizuda.snailjob.server.web.service.impl;
 
+import cn.hutool.core.lang.Assert;
 import com.aizuda.snailjob.server.web.model.base.PageResult;
 import com.aizuda.snailjob.server.web.model.request.NotifyRecipientQueryVO;
 import com.aizuda.snailjob.server.web.model.request.NotifyRecipientRequestVO;
 import com.aizuda.snailjob.server.web.model.response.NotifyRecipientResponseVO;
 import com.aizuda.snailjob.server.web.service.NotifyRecipientService;
-import com.aizuda.snailjob.server.web.service.convert.NotifyRecipientResponseVOConverter;
+import com.aizuda.snailjob.server.web.service.convert.NotifyRecipientConverter;
 import com.aizuda.snailjob.template.datasource.persistence.mapper.NotifyRecipientMapper;
 import com.aizuda.snailjob.template.datasource.persistence.po.NotifyRecipient;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -31,16 +32,16 @@ public class NotifyRecipientServiceImpl implements NotifyRecipientService {
 
         PageDTO<NotifyRecipient> notifyRecipientPageDTO = notifyRecipientMapper.selectPage(pageDTO, new LambdaQueryWrapper<>());
 
-        return new PageResult<>(pageDTO, NotifyRecipientResponseVOConverter.INSTANCE.toNotifyRecipientResponseVOs(notifyRecipientPageDTO.getRecords()));
+        return new PageResult<>(pageDTO, NotifyRecipientConverter.INSTANCE.toNotifyRecipientResponseVOs(notifyRecipientPageDTO.getRecords()));
     }
 
     @Override
     public Boolean saveNotifyRecipient(NotifyRecipientRequestVO requestVO) {
-        return null;
+        return 1 == notifyRecipientMapper.insert(NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO));
     }
 
     @Override
     public Boolean updateNotifyRecipient(NotifyRecipientRequestVO requestVO) {
-        return null;
+        return 1 == notifyRecipientMapper.updateById(NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO));
     }
 }