|
1 | 1 | package root.core.usecase.implement; |
2 | 2 |
|
3 | 3 | import java.util.ArrayList; |
| 4 | +import java.util.Comparator; |
4 | 5 | import java.util.List; |
5 | 6 | import java.util.Locale; |
6 | 7 | import java.util.Map; |
@@ -54,6 +55,62 @@ public <T extends MonitoringResult> Map<String, List<T>> getMonitoringReportData |
54 | 55 | .collect(Collectors.groupingBy(m -> m.getMonitoringDateTime(), |
55 | 56 | Collectors.mapping(m -> m, Collectors.toList()))); |
56 | 57 | } |
| 58 | + |
| 59 | + @Override |
| 60 | + public <T extends MonitoringResult> Map<String, List<T>> getPrevMonitoringReportDataByTime(Class<T> clazz, |
| 61 | + String alias, FileSize unit, int round, String inquiryDateTime) { |
| 62 | + |
| 63 | + String prevDateTime = getPrevHistoryDateTime(clazz, alias, unit, round, inquiryDateTime); |
| 64 | + |
| 65 | + return getMonitoringReportData(clazz, alias, unit, round) |
| 66 | + .stream() |
| 67 | + .filter(m -> prevDateTime.equals(m.getMonitoringDateTime())) |
| 68 | + .sorted(Comparator.comparing(MonitoringResult::getMonitoringDateTime).reversed()) |
| 69 | + .collect(Collectors.groupingBy(m -> m.getMonitoringDateTime(), |
| 70 | + Collectors.mapping(m -> m, Collectors.toList()))); |
| 71 | + } |
| 72 | + |
| 73 | + private <T extends MonitoringResult> String getPrevHistoryDateTime(Class<T> clazz, String alias, FileSize unit, |
| 74 | + int round, String curHistoryDateTime) { |
| 75 | + |
| 76 | + // TODO 날짜 컬럼만 읽기 |
| 77 | + MonitoringResult result = getMonitoringReportData(clazz, alias, unit, round) |
| 78 | + .stream() |
| 79 | + .filter(m -> DateUtils.compareTo("yyyyMMddHHmmss", curHistoryDateTime, m.getMonitoringDateTime()) == 1) |
| 80 | + .sorted(Comparator.comparing(MonitoringResult::getMonitoringDateTime).reversed()) |
| 81 | + .findFirst() |
| 82 | + .orElse(null); |
| 83 | + |
| 84 | + return result == null ? curHistoryDateTime : result.getMonitoringDateTime(); |
| 85 | + } |
| 86 | + |
| 87 | + @Override |
| 88 | + public <T extends MonitoringResult> Map<String, List<T>> getNextMonitoringReportDataByTime(Class<T> clazz, |
| 89 | + String alias, FileSize unit, int round, String inquiryDateTime) { |
| 90 | + |
| 91 | + String nextDateTime = getNextHistoryDateTime(clazz, alias, unit, round, inquiryDateTime); |
| 92 | + |
| 93 | + return getMonitoringReportData(clazz, alias, unit, round) |
| 94 | + .stream() |
| 95 | + .filter(m -> nextDateTime.equals(m.getMonitoringDateTime())) |
| 96 | + .sorted(Comparator.comparing(MonitoringResult::getMonitoringDateTime)) |
| 97 | + .collect(Collectors.groupingBy(m -> m.getMonitoringDateTime(), |
| 98 | + Collectors.mapping(m -> m, Collectors.toList()))); |
| 99 | + } |
| 100 | + |
| 101 | + private <T extends MonitoringResult> String getNextHistoryDateTime(Class<T> clazz, String alias, FileSize unit, |
| 102 | + int round, String curHistoryDateTime) { |
| 103 | + |
| 104 | + // TODO 날짜 컬럼만 읽기 |
| 105 | + MonitoringResult result = getMonitoringReportData(clazz, alias, unit, round) |
| 106 | + .stream() |
| 107 | + .filter(m -> DateUtils.compareTo("yyyyMMddHHmmss", curHistoryDateTime, m.getMonitoringDateTime()) == -1) |
| 108 | + .sorted(Comparator.comparing(MonitoringResult::getMonitoringDateTime)) |
| 109 | + .findFirst() |
| 110 | + .orElse(null); |
| 111 | + |
| 112 | + return result == null ? curHistoryDateTime : result.getMonitoringDateTime(); |
| 113 | + } |
57 | 114 |
|
58 | 115 | @Override |
59 | 116 | public <T extends MonitoringResult> Map<Integer, Long> getMonitoringReportCountByTime(Class<T> clazz, |
|
0 commit comments