| | |
|---|
| | | package com.ruoyi.utils.websocket.service; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.ruoyi.app.position.domain.ArdAppPosition; |
|---|
| | | import com.ruoyi.app.position.service.IArdAppPositionService; |
|---|
| | | import com.ruoyi.app.position.service.impl.AppPositionPush; |
|---|
| | | import com.ruoyi.app.position.service.impl.AppPositionPushService; |
|---|
| | | import com.ruoyi.app.position.service.impl.ArdAppPositionServiceImpl; |
|---|
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
|---|
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
|---|
| | | import com.ruoyi.system.service.ISysUserService; |
|---|
| | | import com.ruoyi.utils.websocket.util.WebSocketUtils; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import javax.websocket.*; |
|---|
| | | import javax.websocket.server.PathParam; |
|---|
| | | import javax.websocket.server.ServerEndpoint; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @ClassName ChatServerEndpoint |
|---|
| | |
|---|
| | | String message = "用户[" + userId + "] 成功连接！"; |
|---|
| | | log.info("用户登录：" + message); |
|---|
| | | WebSocketUtils.sendMessage(session, message); |
|---|
| | | //region 旧方法 |
|---|
| | | // //每个用户连接时，启动初始所有app用户位置发送 |
|---|
| | | // AppPositionPush.initDataMap.put(userId,AppPositionPush.getAppPositionList()); |
|---|
| | | // AppPositionPush.initPushTask(userId,session,3000); |
|---|
| | | //endregion |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OnMessage |
|---|
