From b99e4e26ce2750eafdb8e10c7c9e243328fc12c2 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 26 May 2021 19:19:08 +0800
Subject: [PATCH] 20210526  聊天

---
 src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcMsgServiceImpl.java |   30 ++++++++++++++++++++++++++++--
 1 files changed, 28 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcMsgServiceImpl.java b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcMsgServiceImpl.java
index 3b8212a..61e92c7 100644
--- a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcMsgServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcMsgServiceImpl.java
@@ -45,18 +45,33 @@
     public IPage<MsgListVo> getMsgList(MsgListDto msgListDto) {
         MemberEntity member = LoginUserUtils.getAppLoginUser();
         Long memberId = member.getId();
-//        Long memberId = 444L;
+//        Long memberId = 445L;
         Page<MsgListVo> page = new Page<>(msgListDto.getPageNum(), msgListDto.getPageSize());
 
         OtcMsgUserListEntity otcMsgUserListEntity = new OtcMsgUserListEntity();
         otcMsgUserListEntity.setMemberId(memberId);
-        return otcMsgUserListDao.getMsgList(otcMsgUserListEntity, page);
+        IPage<MsgListVo> msgList = otcMsgUserListDao.getMsgList(otcMsgUserListEntity, page);
+        List<MsgListVo> records = msgList.getRecords();
+        if(CollUtil.isNotEmpty(records)){
+            for(MsgListVo msgListVo : records){
+                long targetId = msgListVo.getTargetId();
+                if(memberId == targetId){
+                    MemberEntity memberEntity = memberDao.selectById(msgListVo.getMemberId());
+                    msgListVo.setNickname(memberEntity.getName());
+                }else{
+                    MemberEntity memberEntity = memberDao.selectById(targetId);
+                    msgListVo.setNickname(memberEntity.getName());
+                }
+            }
+        }
+        return msgList;
     }
 
     @Override
     @Transactional
     public Result getChatBox(ChatBoxDto chatBoxDto) {
         MemberEntity member = LoginUserUtils.getAppLoginUser();
+//        MemberEntity member = memberDao.selectById(443L);
         //对话是否存在
         long id = chatBoxDto.getId();
         if(ObjectUtil.isEmpty(id)){
@@ -77,6 +92,17 @@
         otcMsgHistoryEntity.setMemberId(memberId);
         otcMsgHistoryEntity.setTargetId(targetId);
         IPage<ChatBoxVo> chatBoxVos= otcMsgHistoryDao.getChatBoxMsgList(page,otcMsgHistoryEntity);
+        List<ChatBoxVo> records = chatBoxVos.getRecords();
+        if(CollUtil.isNotEmpty(records)){
+            for(ChatBoxVo chatBoxVo : records){
+                long memberIds = chatBoxVo.getMemberId();
+                if(memberIds == member.getId()){
+                    chatBoxVo.setIsSelf(1);
+                }else{
+                    chatBoxVo.setIsSelf(2);
+                }
+            }
+        }
         return Result.ok(chatBoxVos);
     }
 

--
Gitblit v1.9.1