| | |
|---|
| | | import com.ruoyi.app.position.domain.ArdAppPosition; |
|---|
| | | import com.ruoyi.app.position.service.IArdAppPositionService; |
|---|
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
|---|
| | | import com.ruoyi.common.utils.StringUtils; |
|---|
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
|---|
| | | import com.ruoyi.utils.websocket.util.WebSocketUtils; |
|---|
| | | import com.ruoyi.system.service.ISysUserService; |
|---|
| | |
|---|
| | | |
|---|
| | | // 初始定时任务，根据用户设置的频率定期推送实时位置信息 |
|---|
| | | public static void initPushTask(String userId, Session session, int pushFrequency) { |
|---|
| | | |
|---|
| | | initDataMap.put(userId, getAppPositionList()); |
|---|
| | | List<ArdAppPosition> appPositionList = initDataMap.get(userId); |
|---|
| | | if (appPositionList.size() == 0) { |
|---|
| | |
|---|
| | | //获取所有app用户 |
|---|
| | | List<SysUser> list = sysUserService.selectAllAppUserList(new SysUser()); |
|---|
| | | for (SysUser sysUser : list) { |
|---|
| | | if(sysUser.getAppOnlineState().equals(0)) |
|---|
| | | {continue; } |
|---|
| | | if (StringUtils.isNull(sysUser.getAppOnlineState())) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (sysUser.getAppOnlineState().equals("0")) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | IArdAppPositionService ardAppPositionService = SpringUtils.getBean(IArdAppPositionService.class); |
|---|
| | | ArdAppPosition ardAppPosition = ardAppPositionService.selectLastArdAppPositionByUserId(sysUser.getUserId()); |
|---|
| | | ArdAppPositions.add(ardAppPosition); |
|---|
