diff --git a/mall-im/src/main/java/com/suisung/mall/im/controller/admin/ChatSocketInfoController.java b/mall-im/src/main/java/com/suisung/mall/im/controller/admin/ChatSocketInfoController.java
index 5fd72d69..dc36e35c 100644
--- a/mall-im/src/main/java/com/suisung/mall/im/controller/admin/ChatSocketInfoController.java
+++ b/mall-im/src/main/java/com/suisung/mall/im/controller/admin/ChatSocketInfoController.java
@@ -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()) {