Browse Source

发送信息

wangqifan 3 years ago
parent
commit
bdbd5f6522

+ 4 - 2
src/main/java/com/izouma/nineth/domain/netease/Team.java

@@ -40,8 +40,10 @@ public class Team extends BaseEntityNoID {
     private String password;
 
     @Transient
-    private boolean inTeam;
+    private boolean        inTeam;
     @Transient
-    private Long    unread;
+    private Long           unread;
+    @Transient
+    private NeteaseMessage lastMsg;
 
 }

+ 2 - 0
src/main/java/com/izouma/nineth/repo/netease/NeteaseMessageRepo.java

@@ -22,4 +22,6 @@ public interface NeteaseMessageRepo extends JpaRepository<NeteaseMessage, Long>,
     Long countAllByToIdAndOpeAndCreatedAtAfter(String toId, Integer ope, LocalDateTime createdAt);
 
     Long countAllByToIdAndOpe(String toId, Integer ope);
+
+    NeteaseMessage findFirstByToIdAndOpeOrderByCreatedAtDesc(String toId, Integer ope);
 }

+ 6 - 0
src/main/java/com/izouma/nineth/service/netease/TeamService.java

@@ -3,6 +3,7 @@ package com.izouma.nineth.service.netease;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.izouma.nineth.config.RedisKeys;
+import com.izouma.nineth.domain.netease.NeteaseMessage;
 import com.izouma.nineth.domain.netease.Team;
 import com.izouma.nineth.dto.PageQuery;
 import com.izouma.nineth.exception.BusinessException;
@@ -52,6 +53,7 @@ public class TeamService {
                     }
                 }
             }
+            team.setLastMsg(getTeamLastMessage(team.getTid()));
             team.setUnread(getUnreadCount(userId.toString(), team.getTid().toString()));
             team.setInTeam(inTeam);
             newContent.add(team);
@@ -119,4 +121,8 @@ public class TeamService {
         }
         return unreadCount;
     }
+
+    public NeteaseMessage getTeamLastMessage(Long tid) {
+        return neteaseMessageRepo.findFirstByToIdAndOpeOrderByCreatedAtDesc(tid.toString(), 1);
+    }
 }

+ 1 - 1
src/main/java/com/izouma/nineth/web/netease/NeteaseMessageController.java

@@ -51,7 +51,7 @@ public class NeteaseMessageController extends BaseController {
     }
 
     @PostMapping("/record")
-    public List<NeteaseMessage> all(String toId, Integer ope) {
+    public List<NeteaseMessage> record(String toId, Integer ope) {
         return neteaseMessageRepo.findAllByToIdAndOpe(toId, ope);
     }