user Message with rabbitMQ

luoo_common/src/main/java/dto/UserMessageDto.java

@@ -0,0 +1,51 @@
+package dto;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class UserMessageDto implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+
+    /**
+     * 消息ID
+     */
+    private String messageId;
+
+    /**
+     * 消息ID
+     */
+    private String userId;
+
+
+    /**
+     * 消息标题
+     */
+    private String title;
+
+    /**
+     * 消息内容
+     */
+    private String content;
+
+
+    /**
+     * 是否已读 0为未读  1为已读
+     */
+    private Integer havaRead;
+
+
+    /**
+     * 发送时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date sendTime;
+}

luoo_user/src/main/java/com/luoo/user/controller/UserMessageController.java

@@ -0,0 +1,45 @@
+package com.luoo.user.controller;
+
+
+import api.Result;
+import com.luoo.user.pojo.UserMessage;
+import com.luoo.user.service.UserMessageService;
+import dto.UserMessageDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/userMessage")
+public class UserMessageController {
+
+    @Autowired
+    private UserMessageService userMessageService;
+
+
+    /**
+     * 测试时用的，忽略这个方法
+     * * @param userMessageDto
+     * @return
+     */
+
+    @PostMapping("/sendUserMessage")
+    public Result sendUserMessage(@RequestBody UserMessageDto userMessageDto) {
+
+        userMessageService.sendUserMessage(userMessageDto);
+        return Result.success();
+    }
+
+
+    /**测试时用的，获取当前登录用户ID请走TOKEN
+     * 根据登录的用户ID获取消息
+     * @return
+     */
+    @GetMapping("/list/{userId}")
+    public Result list(@PathVariable String userId){
+        List list = userMessageService.findByUserId(userId);
+        return Result.success(list);
+    }
+
+}

luoo_user/src/main/java/com/luoo/user/dao/UserMessageDao.java

@@ -0,0 +1,11 @@
+package com.luoo.user.dao;
+
+import com.luoo.user.pojo.UserMessage;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+import java.util.List;
+
+public interface UserMessageDao extends MongoRepository<UserMessage,String> {
+
+    List<UserMessage> findAllByUserId(String userId);
+}

luoo_user/src/main/java/com/luoo/user/listener/UserMessageListener.java

@@ -0,0 +1,29 @@
+package com.luoo.user.listener;
+
+
+import com.luoo.user.dao.UserMessageDao;
+import com.luoo.user.pojo.UserMessage;
+import dto.UserMessageDto;
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "userMessage")
+public class UserMessageListener {
+
+    @Autowired
+    private UserMessageDao userMessageDao;
+
+    @RabbitHandler
+    public void executeSendUserMessage(UserMessageDto userMessageDto) {
+
+        UserMessage userMessage = new UserMessage();
+        BeanUtils.copyProperties(userMessageDto,userMessage);
+
+        userMessageDao.save(userMessage);
+    }
+
+}

luoo_user/src/main/java/com/luoo/user/pojo/UserMessage.java

@@ -0,0 +1,53 @@
+package com.luoo.user.pojo;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.springframework.data.annotation.Id;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class UserMessage implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+
+    /**
+     * 消息ID
+     */
+    @Id
+    private String messageId;
+
+    /**
+     * 消息ID
+     */
+    private String userId;
+
+
+    /**
+     * 消息标题
+     */
+    private String title;
+
+    /**
+     * 消息内容
+     */
+    private String content;
+
+
+    /**
+     * 是否已读 0为未读  1为已读
+     */
+    private Integer havaRead;
+
+
+    /**
+     * 发送时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date sendTime;
+}

luoo_user/src/main/java/com/luoo/user/service/UserMessageService.java

@@ -0,0 +1,42 @@
+package com.luoo.user.service;
+
+import com.luoo.user.dao.UserMessageDao;
+import com.luoo.user.pojo.UserMessage;
+import dto.UserMessageDto;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import util.IdWorker;
+
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class UserMessageService {
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    @Autowired
+    private UserMessageDao userMessageDao;
+    @Autowired
+    private IdWorker idWorker;
+    public void sendUserMessage(UserMessageDto userMessageDto) {
+
+        userMessageDto.setMessageId(idWorker.nextId()+"");
+        userMessageDto.setHavaRead(0);
+        userMessageDto.setSendTime(new Date());
+        rabbitTemplate.convertAndSend("userMessage",userMessageDto);
+    }
+
+
+    public List list() {
+
+        return userMessageDao.findAll();
+    }
+
+    public  List findByUserId(String userId) {
+
+        return userMessageDao.findAllByUserId(userId);
+    }
+}