backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

im客服问题修改

Browse Source
This commit is contained in:
liyj 2025-11-13 18:47:03 +08:00
parent 3518b927da
commit 8c3c81d523
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
View File

@ -1,11 +1,9 @@
package com.suisung.mall.im.common.websocket.service.onchat;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.IdUtil;
import cn.hutool.json.JSONUtil;
import com.suisung.mall.common.feignService.AccountService;
import com.suisung.mall.common.utils.CheckUtil;
import com.suisung.mall.im.common.websocket.service.DistributedMessageService;
import com.suisung.mall.im.common.websocket.service.DistributedSessionService;
import com.suisung.mall.im.common.websocket.service.LocalSessionManager;
@ -65,6 +63,8 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
// 存储到本地会话管理
localSessionManager.addUserSession(loginUserId, session);
logger.info("添加会话到本地成功：{}", localSessionManager.userSessions.values());
// 注册到分布式会话服务
Map<String, Object> attributes = new HashMap<>();
attributes.put("user_id", session.getAttributes().get("user_id"));
@ -306,7 +306,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
// 获取本地所有用户会话
for (List<WebSocketSession> sessions : localSessionManager.userSessions.values()) {
for (WebSocketSession session : sessions) {
if (session.isOpen()) {
if (session!=null&&session.isOpen()) {
try {
session.sendMessage(new TextMessage(message.toString()));
} catch (IOException e) {