| | |
|---|
| | | //同步mongodb一机一档到数据库 |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void synchronize() { |
|---|
| | | // 获取Calendar实例，默认使用当前时区和语言环境 |
|---|
| | | Calendar calendar = Calendar.getInstance(); |
|---|
| | | // 清除Calendar中的所有字段值，以避免它们对当前日期时间有影响 |
|---|
| | | calendar.clear(); |
|---|
| | | // 设置年份、月份（注意：月份是从0开始的，所以8月是7）、日期 |
|---|
| | | calendar.set(Calendar.YEAR, 2024); |
|---|
| | | calendar.set(Calendar.MONTH, Calendar.AUGUST); |
|---|
| | | calendar.set(Calendar.DAY_OF_MONTH, 13); |
|---|
| | | // Calendar.getTime()方法返回一个表示此Calendar时间值的Date对象 |
|---|
| | | Date date = calendar.getTime(); |
|---|
| | | log.info("开始同步mongodb一机一档到数据库"); |
|---|
| | | Date date = DateUtils.getDay(2024,7,13); |
|---|
| | | Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date))); |
|---|
| | | // 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); |
|---|
| | |
|---|
| | | } |
|---|
| | | //新的数据放入Redis中等待考核指标任务使用 |
|---|
| | | redisTemplate.opsForValue().set(RedisConstant.New_Monitor_Set, JSONArray.toJSONString(newMonitorList)); |
|---|
| | | log.info("结束同步mongodb一机一档到数据库"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private YwPoint getPoint(MonitorQualifyResult result, Map<String, YwPoint> pointMap, List<String> importantSite) { |
|---|
