【message】接口开发

kernel-d-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/MessageApi.java

@@ -1,14 +0,0 @@
-package cn.stylefeng.roses.kernel.message.api;
-
-/**
- * 系统消息相关接口
- * <p>
- * 接口可以有多种实现，目前只实现数据库存储方式
- *
- * @author liuhanqing
- * @date 2021/1/1 20:21
- */
-public interface MessageApi {
-
-
-}

kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/MessageApi.java

@@ -0,0 +1,87 @@
+package cn.stylefeng.roses.kernel.message.api;
+
+import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageResponse;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageSendParam;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageParam;
+
+
+import java.util.List;
+
+/**
+ * 系统消息相关接口
+ * <p>
+ * 接口可以有多种实现，目前只实现数据库存储方式
+ *
+ * @author liuhanqing
+ * @date 2021/1/2 21:21
+ */
+public interface MessageApi {
+
+    /**
+     * 发送系统消息
+     *
+     * @param messageSendParam 系统消息参数
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    void sendMessage(MessageSendParam messageSendParam);
+
+    /**
+     * 更新阅读状态
+     *
+     * @param messageParam 系统消息参数
+     * @author liuhanqing
+     * @date 2021/1/2 22:15
+     */
+    void updateReadFlag(MessageParam messageParam);
+
+    /**
+     * 删除系统消息
+     *
+     * @param messageId 消息id
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    void deleteByMessageId(Long messageId);
+
+    /**
+     * 批量删除系统消息
+     *
+     * @param messageIds 消息id字符串，多个用逗号分隔
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    void batchDeleteByMessageId(String messageIds);
+
+    /**
+     * 查看系统消息
+     *
+     * @param messageParam 查看参数
+     * @return 系统消息
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    MessageResponse messageDetail(MessageParam messageParam);
+
+    /**
+     * 查询系统消息
+     *
+     * @param messageParam 查询参数
+     * @return 查询分页结果
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    PageResult<MessageResponse> queryMessagePage(MessageParam messageParam);
+
+    /**
+     * 查询系统消息
+     *
+     * @param messageParam 查询参数
+     * @return 系统消息列表
+     * @author liuhanqing
+     * @date 2021/1/2 21:21
+     */
+    List<MessageResponse> queryMessageList(MessageParam messageParam);
+
+}

kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageParam.java

@@ -1,4 +1,4 @@
-package cn.stylefeng.roses.kernel.message.api.pojo.manage;
+package cn.stylefeng.roses.kernel.message.api.pojo;
 
 import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
 import lombok.Data;

kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageResponse.java

@@ -0,0 +1,67 @@
+package cn.stylefeng.roses.kernel.message.api.pojo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 系统消息的查询参数
+ *
+ * @author liuhanqing
+ * @date 2021/1/2 21:23
+ */
+@Data
+public class MessageResponse implements Serializable {
+
+    /**
+     * 消息id
+     */
+    private Long messageId;
+
+    /**
+     * 接收用户id
+     */
+    private Long receiveUserId;
+
+    /**
+     * 发送用户id
+     */
+    private Long sendUserId;
+
+    /**
+     * 消息标题
+     */
+    private String messageTitle;
+
+    /**
+     * 消息的内容
+     */
+    private String messageContent;
+
+    /**
+     * 消息类型
+     */
+    private String messageType;
+
+    /**
+     * 消息发送时间
+     */
+    private Date messageSendTime;
+
+    /**
+     * 业务id
+     */
+    private Long businessId;
+
+    /**
+     * 业务类型
+     */
+    private String businessType;
+
+    /**
+     * 阅读状态：0-未读，1-已读
+     */
+    private Integer readFlag;
+
+}

kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageSendParam.java

@@ -1,4 +1,4 @@
-package cn.stylefeng.roses.kernel.message.api.pojo.manage;
+package cn.stylefeng.roses.kernel.message.api.pojo;
 
 import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
 import lombok.Data;

kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java

@@ -0,0 +1,63 @@
+package cn.stylefeng.roses.kernel.message.db;
+
+import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
+import cn.stylefeng.roses.kernel.message.api.MessageApi;
+import cn.stylefeng.roses.kernel.message.api.constants.MessageConstants;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageParam;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageResponse;
+import cn.stylefeng.roses.kernel.message.api.pojo.MessageSendParam;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 系统消息，数据库实现
+ *
+ * @author liuhanqing
+ * @date 2021/1/2 22:00
+ */
+@Slf4j
+@Service
+public class MessageDbServiceImpl implements MessageApi {
+
+    @Override
+    public void sendMessage(MessageSendParam messageSendParam) {
+        String receiveUserIds = messageSendParam.getReceiveUserIds();
+        // 发送所有人判断
+        if (MessageConstants.RECEIVE_ALL_USER_FLAG.equals(receiveUserIds)) {
+
+        }
+
+    }
+
+    @Override
+    public void updateReadFlag(MessageParam messageParam) {
+
+    }
+
+    @Override
+    public void deleteByMessageId(Long messageId) {
+
+    }
+
+    @Override
+    public void batchDeleteByMessageId(String messageIds) {
+
+    }
+
+    @Override
+    public MessageResponse messageDetail(MessageParam messageParam) {
+        return null;
+    }
+
+    @Override
+    public PageResult<MessageResponse> queryMessagePage(MessageParam messageParam) {
+        return null;
+    }
+
+    @Override
+    public List<MessageResponse> queryMessageList(MessageParam messageParam) {
+        return null;
+    }
+}

kernel-s-message/pom.xml

@@ -11,7 +11,7 @@
         <relativePath>../pom.xml</relativePath>
     </parent>
 
-    <artifactId>kernel-d-message</artifactId>
+    <artifactId>kernel-s-message</artifactId>
 
     <packaging>pom</packaging>
 

pom.xml

@@ -74,7 +74,7 @@
         <module>kernel-s-dict</module>
 
         <!--系统消息模块-->
-        <module>kernel-d-message</module>
+        <module>kernel-s-message</module>
 
         <!--系统管理基础业务-->
         <module>kernel-s-system</module>