| | |
|---|
| | | 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.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; |
|---|
| | |
|---|
| | | log.info("用户登录：" + message); |
|---|
| | | WebSocketUtils.sendMessage(session, message); |
|---|
| | | //每个用户连接时，启动初始所有app用户位置发送 |
|---|
| | | |
|---|
| | | List<ArdAppPosition> positionList = AppPositionPush.defaultDataMap.get(userId); |
|---|
| | | AppPositionPush.defaultDataMap.put(userId,positionList); |
|---|
| | | AppPositionPush.initDataMap.put(userId,AppPositionPush.getAppPositionList()); |
|---|
| | | AppPositionPush.initPushTask(userId,session,3000); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | Integer frequency = (Integer)map.get("frequency"); |
|---|
| | | String uId = (String) map.get("userId"); |
|---|
| | | Map<String, List<ArdAppPosition>> dataMap = new HashMap<>(); |
|---|
| | | List<ArdAppPosition> positionList = AppPositionPush.defaultDataMap.get(userId);//获取当前用户的默认发送的数据map |
|---|
| | | List<ArdAppPosition> positionList = AppPositionPush.initDataMap.get(userId);//获取当前用户的默认发送的数据map |
|---|
| | | if(frequency>0) |
|---|
| | | { |
|---|
| | | //接收到频率大于0，属于申请引导，获取除引导外的其他app用户的位置List |
|---|
| | |
|---|
| | | //接收到频率等于0，属于释放引导，获取到全部app用户的位置List |
|---|
| | | dataMap.put(userId,AppPositionPush.getAppPositionList()); |
|---|
| | | } |
|---|
| | | AppPositionPush.defaultDataMap.putAll(dataMap);//更新初始会话默认数据map |
|---|
| | | AppPositionPush.initDataMap.putAll(dataMap);//更新初始会话默认数据map |
|---|
| | | AppPositionPush.startLocationPushTask(userId,session,uId, frequency);//开启新任务 |
|---|
| | | } |
|---|
| | | } |
|---|
