From 30435efa805a07b0ed5e60ca16ceb06dd6ff98c9 Mon Sep 17 00:00:00 2001
From: zhizhi wu <2377881365@qq.com>
Date: Mon, 8 Jun 2020 15:38:47 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E6=B6=88=E6=81=AF=E6=8E=A5?=
 =?UTF-8?q?=E6=94=B6=E4=BA=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tall/bean/dto/message/BaseMessageDto.java       | 13 +++++++++++++
 .../ccsens/tall/service/ProjectMessageService.java  |  2 ++
 2 files changed, 15 insertions(+)

diff --git a/tall/src/main/java/com/ccsens/tall/bean/dto/message/BaseMessageDto.java b/tall/src/main/java/com/ccsens/tall/bean/dto/message/BaseMessageDto.java
index cadb02e0..c80889bd 100644
--- a/tall/src/main/java/com/ccsens/tall/bean/dto/message/BaseMessageDto.java
+++ b/tall/src/main/java/com/ccsens/tall/bean/dto/message/BaseMessageDto.java
@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.ccsens.util.bean.message.common.InMessage;
 import lombok.Data;
 
+import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
@@ -21,6 +22,10 @@ public class BaseMessageDto {
         public MessageUser(){
             hasRead = false;
         }
+        public MessageUser(Long userId){
+            hasRead = false;
+            this.userId = userId;
+        }
         public MessageUser(Long id,Long userId,String nickname,String avatarUrl){
             this();
             this.id = id;
@@ -28,6 +33,14 @@ public class BaseMessageDto {
             this.nickname = nickname;
             this.avatarUrl = avatarUrl;
         }
+
+        public static List<MessageUser> userIdToUsers(List<Long> userIds) {
+            List<MessageUser> users = new ArrayList<>();
+            userIds.forEach(userId ->{
+                users.add(new MessageUser(userId));
+            });
+            return users;
+        }
     }
 
     private Long time;
diff --git a/tall/src/main/java/com/ccsens/tall/service/ProjectMessageService.java b/tall/src/main/java/com/ccsens/tall/service/ProjectMessageService.java
index 7096c95d..b3900a81 100644
--- a/tall/src/main/java/com/ccsens/tall/service/ProjectMessageService.java
+++ b/tall/src/main/java/com/ccsens/tall/service/ProjectMessageService.java
@@ -5,6 +5,7 @@ import cn.hutool.core.lang.Snowflake;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.ccsens.tall.bean.dto.ProjectMessageDto;
+import com.ccsens.tall.bean.dto.message.BaseMessageDto;
 import com.ccsens.tall.bean.po.SysMessageSend;
 import com.ccsens.tall.bean.po.SysMessageSendExample;
 import com.ccsens.tall.bean.po.SysOperation;
@@ -98,6 +99,7 @@ public class ProjectMessageService implements IProjectMessageService {
 //        log.info("mq通知消息:{}", inMessage);
 
         com.ccsens.tall.bean.dto.message.ProjectMessageDto dto = new com.ccsens.tall.bean.dto.message.ProjectMessageDto();
+        dto.setReceivers(BaseMessageDto.MessageUser.userIdToUsers(userIds));
         List<com.ccsens.tall.bean.dto.message.ProjectMessageDto.Message> messages = JSONObject.parseArray(JSONObject.toJSONString(newMessages), com.ccsens.tall.bean.dto.message.ProjectMessageDto.Message.class);
         dto.getData().setMessages(messages);