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.common.core.domain.entity.SysUser; 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.HashMap; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.stream.Collectors; /** * @ClassName ChatServerEndpoint * @Description: * @Author 刘苏义 * @Date 2023/1/27 7:42 * @Version 1.0 */ @Component @Slf4j(topic = "websocket") @ServerEndpoint("/websocket/{userId}") public class ChatServerEndpoint { @OnOpen public void openSession(@PathParam("userId") String userId, Session session) { WebSocketUtils.ONLINE_USER_SESSIONS.put(userId, session); String message = "用户[" + userId + "] 成功连接!"; log.info("用户登录:" + message); WebSocketUtils.sendMessage(session, message); //每个用户连接时,启动初始所有app用户位置发送 List positionList = AppPositionPush.initDataMap.get(userId); AppPositionPush.initDataMap.put(userId,positionList); AppPositionPush.initPushTask(userId,session,3000); } @OnMessage public void onMessage(@PathParam("userId") String userId, String message) { log.info("收到消息:" + message); Session session = WebSocketUtils.ONLINE_USER_SESSIONS.get(userId); // WebSocketUtils.sendMessage(session, message); // sendMessageAll("用户[" + userid + "] : " + message); // 根据用户新的频率重新调整定时任务 Map map = JSONObject.parseObject(message, Map.class); if(map.size()>0) { Integer frequency = (Integer)map.get("frequency"); String uId = (String) map.get("userId"); Map> dataMap = new HashMap<>(); List positionList = AppPositionPush.initDataMap.get(userId);//获取当前用户的默认发送的数据map if(frequency>0) { //接收到频率大于0,属于申请引导,获取除引导外的其他app用户的位置List List appPositionList = positionList.stream() .filter(obj -> !obj.getUserId().equals(uId)) .collect(Collectors.toList()); dataMap.put(userId,appPositionList); } else { //接收到频率等于0,属于释放引导,获取到全部app用户的位置List dataMap.put(userId,AppPositionPush.getAppPositionList()); } AppPositionPush.initDataMap.putAll(dataMap);//更新初始会话默认数据map AppPositionPush.startLocationPushTask(userId,session,uId, frequency);//开启新任务 } } @OnClose public void onClose(@PathParam("userId") String userId, Session session) { //当前的Session 移除 WebSocketUtils.ONLINE_USER_SESSIONS.remove(userId); // //并且通知其他人当前用户已经离开聊天室了 String message="用户[" + userId + "] 断开连接!"; // sendMessage(session,message); log.info("消息:"+message); try { session.close(); AppPositionPush.stopLocationPushTask(session); } catch (IOException e) { log.error("onClose error", e); } } @OnError public void onError(Session session, Throwable throwable) { try { session.close(); } catch (IOException e) { log.error("onError excepiton", e); } log.info("Throwable msg " + throwable.getMessage()); } }