消息处理

hx-saas-project/saas-entity/src/main/java/com/fjhx/message/MessageNotice.java

@@ -1,11 +1,12 @@
 package com.fjhx.message;
 
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.fjhx.base.BasicEntity;
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 import org.springframework.data.annotation.Id;
 import org.springframework.data.redis.core.index.Indexed;
 
-import java.io.Serializable;
-import java.util.Date;
 
 /**
  * @ClassName: MessageNotice
@@ -14,14 +15,8 @@ import java.util.Date;
  * @Version: 1.0
  */
 @Data
-public class MessageNotice implements Serializable {
-
-    /**
-     * 消息id
-     */
-    @Id
-    @Indexed
-    private String id;
+@EqualsAndHashCode(callSuper = true)
+public class MessageNotice extends BasicEntity {
 
     /**
      * 业务id
@@ -47,8 +42,4 @@ public class MessageNotice implements Serializable {
     @Indexed
     private String userId;
 
-    /**
-     * 创建时间
-     */
-    private Date createTime;
 }

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/message/controller/StockMessageController.java

@@ -0,0 +1,27 @@
+package com.fjhx.rocketmq.message.controller;
+
+import com.fjhx.rocketmq.message.service.StockMessageService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 业务附件表 前端控制器
+ * </p>
+ *
+ * @author ${author}
+ * @since 2022-07-19
+ */
+@RestController
+@RequestMapping("/stockMessage")
+public class StockMessageController {
+
+    @Autowired
+    private StockMessageService stockMessageService;
+
+
+}
+

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/message/mapper/StockMessageMapper.java

@@ -0,0 +1,16 @@
+package com.fjhx.rocketmq.message.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fjhx.message.MessageNotice;
+
+/**
+ * <p>
+ * 业务附件表 Mapper 接口
+ * </p>
+ *
+ * @author ${author}
+ * @since 2022-07-19
+ */
+public interface StockMessageMapper extends BaseMapper<MessageNotice> {
+
+}

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/message/mapper/StockMessageMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fjhx.rocketmq.message.mapper.StockMessageMapper">
+
+</mapper>

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/message/service/StockMessageService.java

@@ -0,0 +1,21 @@
+package com.fjhx.rocketmq.message.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fjhx.message.MessageNotice;
+import org.springblade.core.mp.base.BaseService;
+
+/**
+ * <p>
+ * 业务附件表 服务类
+ * </p>
+ *
+ * @author ${author}
+ * @since 2022-07-19
+ */
+public interface StockMessageService extends IService<MessageNotice> {
+
+
+    void add(MessageNotice messageNotice);
+
+
+}

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/message/service/impl/StockMessageServiceImpl.java

@@ -0,0 +1,27 @@
+package com.fjhx.rocketmq.message.service.impl;
+
+import com.fjhx.message.MessageNotice;
+import com.fjhx.rocketmq.message.mapper.StockMessageMapper;
+import com.fjhx.rocketmq.message.service.StockMessageService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+
+/**
+ * <p>
+ * 业务附件表 服务实现类
+ * </p>
+ *
+ * @author ${author}
+ * @since 2022-07-19
+ */
+@Service
+public class StockMessageServiceImpl extends ServiceImpl<StockMessageMapper, MessageNotice> implements StockMessageService {
+
+
+    @Override
+    public void add(MessageNotice messageNotice) {
+        save(messageNotice);
+    }
+
+}

hx-saas-project/saas-rocketmq/src/main/java/com/fjhx/rocketmq/service/Impl/RocketMqServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.fjhx.message.MessageNotice;
 import com.fjhx.message.enums.MsgSourceEnum;
 import com.fjhx.rocketmq.Message;
+import com.fjhx.rocketmq.message.service.StockMessageService;
 import com.fjhx.rocketmq.service.RocketMqService;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.rocketmq.client.producer.SendCallback;
@@ -31,6 +32,9 @@ public class RocketMqServiceImpl implements RocketMqService {
 
     @Autowired
     private IUserClient iUserClient;
+
+    @Autowired
+    private StockMessageService stockMessageService;
     /**
      * 普通消息
      * @param msg
@@ -100,10 +104,11 @@ public class RocketMqServiceImpl implements RocketMqService {
             notice.setContent(content);
             notice.setMsgType(msgType);
             notice.setUserId(userId);
-            notice.setCreateTime(new Date());
+            notice.setCreatedTime(new Date());
             notices.add(notice);
         }
         //储存消息体
+        stockMessageService.saveBatch(notices);
         try {
             // -------------------- 往websocket推送消息 --------------------
             // 查询用户数据