fix:增加消息扩展

application-webadmin/src/main/java/com/tourism/webadmin/app/website/dto/MessageDTO.java

@@ -2,6 +2,8 @@ package com.tourism.webadmin.app.website.dto;
 
 import lombok.Data;
 
+import java.util.Map;
+
 @Data
 public class MessageDTO extends MessageContentBase{
     private String groupId;
@@ -19,4 +21,6 @@ public class MessageDTO extends MessageContentBase{
      * 0未到限制 1已到限制
      */
     private Integer messageLimit = 0;
+    /**扩展*/
+    private Map<String,Object> map;
 }

application-webadmin/src/main/java/com/tourism/webadmin/app/website/vo/InteractionListVo.java

@@ -13,14 +13,14 @@ public class InteractionListVo {
     /**业务ID*/
     private String businessId;
 
-    /**业务类型    1 游记*/
+    /**业务类型  1 游记*/
     private String businessType;
 
     /**封面*/
     private String imageUrl;
     /** 评论ID */
     private String reviewId;
-    /**类型  -1全部 4关注信息 5点赞 6评论 7评论区艾特 8文章内艾特 9访问*/
+    /**类型   4关注消息 5点赞通知 6评论通知 7收藏通知 8浏览通知 9访问主页通知 10评论区艾特通知 11文章内艾特通知*/
     private String noticeType;
     /**
      * 消息内容。
@@ -37,7 +37,7 @@ public class InteractionListVo {
     private String showName;
 
     /**发送时间*/
-    private String createTime;
+    private String creatTime;
 
     /**发送人和自己的关系*/
     private String state;

application-webadmin/src/main/java/com/tourism/webadmin/ws/handle/SystemMessageHandler.java

@@ -209,7 +209,6 @@ public class SystemMessageHandler extends AbstractWebSocketHandler {
             }
         }
         //群聊ID
-        String gid=messageDTO.getGroupId();
         TourImGroup tourImGroup = tourImGroupService.getById(messageDTO.getGroupId());
 
         //当前的会话是否存在
@@ -279,7 +278,7 @@ public class SystemMessageHandler extends AbstractWebSocketHandler {
                             .eq(TourImMessage::getGroupId, messageDTO.getGroupId())
                     );
                 }
-                if (messageCount >= 1 && fansList.isEmpty()) {
+                if (messageCount == 1 ||fansList.isEmpty()) {
                     messageDTO.setMessageLimit(1);
                     return;
                 }
@@ -305,12 +304,13 @@ public class SystemMessageHandler extends AbstractWebSocketHandler {
         }
         //单聊
         if (groupMap.containsKey(messageDTO.getGroupId())) {
-            sendGroupAllMessage(messageDTO.getGroupId(),new TextMessage(JSON.toJSONString(messageDTO)));
             Map<String, WebSocketSession> groupSingleMessageMap = groupMap.get(messageDTO.getGroupId());
             String getUserId = messageDTO.getGetUserId();
             messageDTO.setSendUserId(id);
             messageService.save(messageDTO);
+            messageDTO.setSendUserId(id);
             //在线情况
+            sendGroupAllMessage(messageDTO.getGroupId(),new TextMessage(JSON.toJSONString(messageDTO)));
             //不在线情况 直接入库 默认全未读
             return;
         }