| | |
| | | // Date yesterday = DateUtils.addDays(new Date(), -1); |
| | | Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | List<MonitorQualifyResult> oneMachineFileResults = mongoTemplate.find(query, MonitorQualifyResult.class); |
| | | if(!CollectionUtils.isEmpty(oneMachineFileResults)) { |
| | | //mongo品牌数据 |
| | | Query OSDQuery = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))); |
| | | Map<String, OsdCheckResult> osdMap = mongoTemplate.find(query, OsdCheckResult.class).stream().collect(Collectors.toMap(OsdCheckResult::getDeviceNo, Function.identity())); |
| | |
| | | //老设备状态改为不参与考核 |
| | | if (!points.contains(key)) { |
| | | value.setExamineStatus(Boolean.FALSE); |
| | | //单位设置为空 |
| | | //单位设置为空(TODO:为啥) |
| | | value.setUnitId(null); |
| | | ywPointList.add(value); |
| | | } |
| | |
| | | } |
| | | //新的数据放入Redis中等待考核指标任务使用(弃用,改为标签形式) |
| | | // redisTemplate.opsForValue().set(RedisConstant.New_Monitor_Set, JSONArray.toJSONString(newMonitorList)); |
| | | } |
| | | log.info("结束同步mongodb一机一档到数据库"); |
| | | } |
| | | |