| | |
|---|
| | | @Autowired |
|---|
| | | private RedisTemplate redisTemplate; |
|---|
| | | |
|---|
| | | //同步点位在线率到mongo |
|---|
| | | //同步点位在线率到mongo(弃用) |
|---|
| | | public void siteOnline() { |
|---|
| | | log.info("开始同步点位在线率到mongo"); |
|---|
| | | List<TMonitorResult> tMonitorResults = monitorMapper.selectMonitorResult(null); |
|---|
| | | if (!CollectionUtils.isEmpty(tMonitorResults)) { |
|---|
| | | //如果存在之前的数据先删除 |
|---|
| | | 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中 |
|---|
| | | mongoTemplate.insertAll(tMonitorResults); |
|---|
| | | log.info("结束同步点位在线率到mongo"); |
|---|
| | | } |
|---|
| | | // log.info("开始同步点位在线率到mongo"); |
|---|
| | | // List<TMonitorResult> tMonitorResults = monitorMapper.selectMonitorResult(null); |
|---|
| | | // if (!CollectionUtils.isEmpty(tMonitorResults)) { |
|---|
| | | // //如果存在之前的数据先删除 |
|---|
| | | // 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中 |
|---|
| | | // mongoTemplate.insertAll(tMonitorResults); |
|---|
| | | // log.info("结束同步点位在线率到mongo"); |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //同步mongodb一机一档到数据库 |
|---|
