| | |
| | | |
| | | @Override |
| | | public int syncHourData() { |
| | | int window = config.getSync().getHourWindow() != null ? config.getSync().getHourWindow() : 2; |
| | | LocalDateTime end = LocalDateTime.now().withMinute(0).withSecond(0).withNano(0); |
| | | LocalDateTime start = end.minusHours(window); |
| | | int window = config.getSync().getHourWindow() != null ? config.getSync().getHourWindow() : 1; |
| | | if (window < 1) { |
| | | window = 1; |
| | | } |
| | | // 结束于上一完整小时,不包含当前未结束的小时 |
| | | LocalDateTime currentHourStart = LocalDateTime.now().withMinute(0).withSecond(0).withNano(0); |
| | | LocalDateTime end = currentHourStart.minusHours(1); |
| | | LocalDateTime start = end.minusHours(window - 1L); |
| | | String startTime = start.format(HOUR_FMT); |
| | | String endTime = end.format(HOUR_FMT); |
| | | return syncDimension("hour", startTime, endTime); |