|
@@ -279,7 +279,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,13 +305,12 @@ 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;
|
|
|
}
|