| | |
|---|
| | | checkTimes = (Integer) map.get("checkTimes") + 1; |
|---|
| | | offLineTimes = (Integer) map.get("offLineTimes"); |
|---|
| | | } |
|---|
| | | monitor.setOnline(Boolean.FALSE); |
|---|
| | | monitor.setPingOnline(Boolean.FALSE); |
|---|
| | | monitor.setCheckCount(checkTimes); |
|---|
| | | monitor.setOffLineCount(offLineTimes); |
|---|
| | | if (monitor.getOffLineCount() >= time) { |
|---|
| | |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | //筛选出ping离线的设备，更改数据库为离线 |
|---|
| | | Date now = new Date(); |
|---|
| | | List<UpdateOnlineVO> willUpdateList = dataList.stream().filter(result->!result.getOnline()).map(item -> { |
|---|
| | | List<UpdateOnlineVO> willUpdateList = dataList.stream().filter(result->!result.getPingOnline()).map(item -> { |
|---|
| | | UpdateOnlineVO vo = new UpdateOnlineVO(); |
|---|
| | | vo.setOnline(item.getOnline()?ApiConstants.UY_OnlineSite_Online:ApiConstants.UY_OnlineSite_Offline); |
|---|
| | | vo.setOnline(item.getPingOnline()?ApiConstants.UY_OnlineSite_Online:ApiConstants.UY_OnlineSite_Offline); |
|---|
| | | vo.setIp(item.getIp()); |
|---|
| | | vo.setUpdateTime(now); |
|---|
| | | return vo; |
|---|
| | |
|---|
| | | .where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
|---|
| | | DeleteResult result = mongoTemplate.remove(query, VideoOnlineResult.class); |
|---|
| | | //打标签 |
|---|
| | | records.forEach(item -> { |
|---|
| | | if (Objects.nonNull(item.getDeviceId())) { |
|---|
| | | item.setNo(item.getDeviceId()); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | pointService.setDeviceTagByGB(records); |
|---|
| | | //存放在mongo中 |
|---|
| | | mongoTemplate.insertAll(records); |
|---|
