| | |
|---|
| | | } else { |
|---|
| | | log.error("请配置离线次数，此次设置为默认值2"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 现在需要查出状态为未知的设备 |
|---|
| | | |
|---|
| | | // 先查出设备IP集合,剔除掉在线情况是未知的,并且只检测正在考核的设备避免多余工单 |
|---|
| | | List<TMonitorResult> monitorList = monitorMapper.getDistinctIP(); |
|---|
| | | //补充错误时间点 |
|---|
| | |
|---|
| | | CompletableFuture<Void> allOf = CompletableFuture.allOf( |
|---|
| | | futureList.toArray(new CompletableFuture[0]) |
|---|
| | | ); |
|---|
| | | |
|---|
| | | try { |
|---|
| | | allOf.get(60, TimeUnit.SECONDS); // 给予额外的5秒来收集结果 |
|---|
| | | } catch (TimeoutException e) { |
|---|
| | |
|---|
| | | Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
|---|
| | | DeleteResult result = mongoTemplate.remove(query, TMonitorResult.class); |
|---|
| | | //存放在mongo中 |
|---|
| | | |
|---|
| | | log.error("存入同步在线mongo数据{}" , monitorList ); |
|---|
| | | mongoTemplate.insertAll(mongoList); |
|---|
| | | } |
|---|
| | | //工单（同一IP只生成一个工单） |
|---|
