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-18 11:41:03 +08:00
parent e79b5727b3
commit a6c1b9bf95
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
mall-im/src/main/java/com/suisung/mall/im/controller/admin/ChatSocketInfoController.java
View File

@ -8,11 +8,13 @@ import cn.hutool.core.util.ObjectUtil;
import com.suisung.mall.common.api.CommonResult;
import com.suisung.mall.common.service.impl.BaseControllerImpl;
import com.suisung.mall.common.utils.I18nUtil;
import com.suisung.mall.im.common.websocket.service.DistributedSessionService;
import com.suisung.mall.im.common.websocket.service.onchat.MallsuiteImSocketHandler;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@ -32,6 +34,9 @@ public class ChatSocketInfoController {
private static Logger logger = LoggerFactory.getLogger(ChatSocketInfoController.class);
@Autowired
private DistributedSessionService distributedSessionService;
/**
* 获取socket在线用户信息
*/
@ -40,7 +45,7 @@ public class ChatSocketInfoController {
@RequestMapping(value = "/getUserOnline", method = RequestMethod.POST)
public List<Integer> getUserOnline(@RequestBody List<Integer> user_ids) {
logger.info(I18nUtil._("接收的用户ids:") + CollUtil.join(user_ids, ","));
List<Integer> onlineLoginUserIds = new MallsuiteImSocketHandler().getOnlineLoginUserId();
List<Integer> onlineLoginUserIds = distributedSessionService.getOnlineUserIds();
Iterator<Integer> online_user_ids_iter = onlineLoginUserIds.iterator();
// 处理移除非本店铺客服
while (online_user_ids_iter.hasNext()) {