refactor: 简化DateTypeEnum
This commit is contained in:
dhb52
parent
9aa8bbced8
commit
9d54c5b5b8
@ -1,19 +1,18 @@
|
|||||||
package com.aizuda.snailjob.server.web.model.enums;
|
package com.aizuda.snailjob.server.web.model.enums;
|
||||||
|
|
||||||
import com.aizuda.snailjob.server.web.model.response.DashboardLineResponseVO;
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
||||||
|
import com.aizuda.snailjob.common.core.util.StreamUtils;
|
||||||
import com.aizuda.snailjob.server.web.model.response.DashboardLineResponseVO;
|
import com.aizuda.snailjob.server.web.model.response.DashboardLineResponseVO;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.time.LocalTime;
|
|
||||||
import java.time.format.DateTimeFormatter;
|
import java.time.format.DateTimeFormatter;
|
||||||
import java.time.temporal.TemporalAdjusters;
|
import java.time.temporal.TemporalAdjusters;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Objects;
|
import java.util.Optional;
|
||||||
import java.util.function.Consumer;
|
import java.util.function.Consumer;
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
import java.util.stream.Collectors;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author: byteblogs
|
* @author: byteblogs
|
||||||
@ -23,162 +22,114 @@ public enum DateTypeEnum {
|
|||||||
/**
|
/**
|
||||||
* 天（按小时）
|
* 天（按小时）
|
||||||
*/
|
*/
|
||||||
DAY(dashboardLineResponseVOList -> {
|
DAY(
|
||||||
Map<String, DashboardLineResponseVO> dashboardLineResponseVOMap = dashboardLineResponseVOList.stream().collect(Collectors.toMap(DashboardLineResponseVO::getCreateDt, i -> i));
|
voList -> {
|
||||||
for (int i = 0; i <= LocalDateTime.now().with(TemporalAdjusters.lastDayOfMonth()).getHour(); i++) {
|
Map<String, DashboardLineResponseVO> responseVoMap = StreamUtils.toIdentityMap(voList,
|
||||||
|
DashboardLineResponseVO::getCreateDt);
|
||||||
String format = LocalDateTime.of(LocalDate.now(), LocalTime.MIN).plusHours(i).format(DateTimeFormatter.ofPattern("HH"));
|
int hourNow = LocalDateTime.now().getHour();
|
||||||
DashboardLineResponseVO dashboardLineResponseVO = dashboardLineResponseVOMap.get(format);
|
for (int hourOffset = 0; hourOffset <= hourNow; hourOffset++) {
|
||||||
if (Objects.isNull(dashboardLineResponseVO)) {
|
String createDt = LocalDateTime.now().plusHours(hourOffset).format(DateTimeFormatter.ofPattern("HH"));
|
||||||
dashboardLineResponseVO = new DashboardLineResponseVO()
|
if (!responseVoMap.containsKey(createDt)) {
|
||||||
.setTotal(0L)
|
voList.add(buildZeroedVoWithCreateDt(createDt));
|
||||||
.setTotalNum(0L)
|
}
|
||||||
.setFail(0L)
|
|
||||||
.setFailNum(0L)
|
|
||||||
.setMaxCountNum(0L)
|
|
||||||
.setRunningNum(0L)
|
|
||||||
.setSuccess(0L)
|
|
||||||
.setSuccessNum(0L)
|
|
||||||
.setSuspendNum(0L)
|
|
||||||
.setStop(0L)
|
|
||||||
.setCancel(0L)
|
|
||||||
.setCreateDt(format);
|
|
||||||
dashboardLineResponseVOList.add(dashboardLineResponseVO);
|
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
}, (startTime) -> {
|
(startTime) -> LocalDateTimeUtil.beginOfDay(Optional.ofNullable(startTime).orElse(LocalDateTime.now())),
|
||||||
return Objects.isNull(startTime) ?
|
(endTime) -> LocalDateTimeUtil.endOfDay(Optional.ofNullable(endTime).orElse(LocalDateTime.now()))
|
||||||
LocalDateTime.of(LocalDate.now(), LocalTime.MIN.withNano(0)) :
|
),
|
||||||
LocalDateTime.of(startTime.toLocalDate(), LocalTime.MIN.withNano(0));
|
|
||||||
}, (endTime) -> {
|
|
||||||
return Objects.isNull(endTime) ?
|
|
||||||
LocalDateTime.of(LocalDate.now(), LocalTime.MAX.withNano(0)) :
|
|
||||||
LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX.withNano(0));
|
|
||||||
}),
|
|
||||||
/**
|
/**
|
||||||
* 周
|
* 周
|
||||||
*/
|
*/
|
||||||
WEEK(dashboardLineResponseVOList -> {
|
WEEK(
|
||||||
Map<String, DashboardLineResponseVO> dispatchQuantityResponseVOMap = dashboardLineResponseVOList.stream().collect(Collectors.toMap(DashboardLineResponseVO::getCreateDt, i -> i));
|
voList -> {
|
||||||
for (int i = 0; i < 7; i++) {
|
Map<String, DashboardLineResponseVO> responseVoMap = StreamUtils.toIdentityMap(
|
||||||
|
voList, DashboardLineResponseVO::getCreateDt);
|
||||||
String format = LocalDateTime.of(LocalDate.now().minusDays(i), LocalTime.MIN).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
|
for (int dayOffset = 0; dayOffset < 7; dayOffset++) {
|
||||||
DashboardLineResponseVO dashboardLineResponseVO = dispatchQuantityResponseVOMap.get(format);
|
String createDt = LocalDateTime.now().minusDays(dayOffset).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
|
||||||
if (Objects.isNull(dashboardLineResponseVO)) {
|
if (!responseVoMap.containsKey(createDt)) {
|
||||||
dashboardLineResponseVO = new DashboardLineResponseVO()
|
voList.add(buildZeroedVoWithCreateDt(createDt));
|
||||||
.setTotal(0L)
|
}
|
||||||
.setTotalNum(0L)
|
|
||||||
.setFail(0L)
|
|
||||||
.setFailNum(0L)
|
|
||||||
.setMaxCountNum(0L)
|
|
||||||
.setRunningNum(0L)
|
|
||||||
.setSuccess(0L)
|
|
||||||
.setSuccessNum(0L)
|
|
||||||
.setSuspendNum(0L)
|
|
||||||
.setStop(0L)
|
|
||||||
.setCancel(0L)
|
|
||||||
.setCreateDt(format);
|
|
||||||
dashboardLineResponseVOList.add(dashboardLineResponseVO);
|
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
}, (startTime) -> {
|
(startTime) -> LocalDateTimeUtil.beginOfDay(Optional.ofNullable(startTime).orElse(LocalDateTime.now()).minusDays(7)),
|
||||||
return Objects.isNull(startTime) ?
|
(endTime) -> LocalDateTimeUtil.endOfDay(Optional.ofNullable(endTime).orElse(LocalDateTime.now()))
|
||||||
LocalDateTime.of(LocalDate.now().minusDays(7), LocalTime.MIN.withNano(0)) :
|
),
|
||||||
LocalDateTime.of(startTime.toLocalDate().minusDays(7), LocalTime.MIN.withNano(0));
|
|
||||||
}, (endTime) -> {
|
|
||||||
return Objects.isNull(endTime) ?
|
|
||||||
LocalDateTime.of(LocalDate.now(), LocalTime.MAX.withNano(0)) :
|
|
||||||
LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX.withNano(0));
|
|
||||||
}),
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 月
|
* 月
|
||||||
*/
|
*/
|
||||||
MONTH(dashboardLineResponseVOList -> {
|
MONTH(
|
||||||
Map<String, DashboardLineResponseVO> dispatchQuantityResponseVOMap = dashboardLineResponseVOList.stream().collect(Collectors.toMap(DashboardLineResponseVO::getCreateDt, i -> i));
|
voList -> {
|
||||||
for (int i = 0; i < LocalDateTime.now().with(TemporalAdjusters.lastDayOfMonth()).getDayOfMonth(); i++) {
|
Map<String, DashboardLineResponseVO> responseVoMap = StreamUtils.toIdentityMap(
|
||||||
|
voList, DashboardLineResponseVO::getCreateDt);
|
||||||
String format = LocalDateTime.of(LocalDate.now().minusDays(i), LocalTime.MIN).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
|
int lastDayOfMonth = LocalDateTime.now().with(TemporalAdjusters.lastDayOfMonth()).getDayOfMonth();
|
||||||
DashboardLineResponseVO dashboardLineResponseVO = dispatchQuantityResponseVOMap.get(format);
|
for (int dayOffset = 0; dayOffset < lastDayOfMonth; dayOffset++) {
|
||||||
if (Objects.isNull(dashboardLineResponseVO)) {
|
String createDt = LocalDate.now().minusDays(dayOffset).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
|
||||||
dashboardLineResponseVO = new DashboardLineResponseVO()
|
if (!responseVoMap.containsKey(createDt)) {
|
||||||
.setTotal(0L)
|
voList.add(buildZeroedVoWithCreateDt(createDt));
|
||||||
.setTotalNum(0L)
|
}
|
||||||
.setFail(0L)
|
|
||||||
.setFailNum(0L)
|
|
||||||
.setMaxCountNum(0L)
|
|
||||||
.setRunningNum(0L)
|
|
||||||
.setSuccess(0L)
|
|
||||||
.setSuccessNum(0L)
|
|
||||||
.setSuspendNum(0L)
|
|
||||||
.setStop(0L)
|
|
||||||
.setCancel(0L)
|
|
||||||
.setCreateDt(format);
|
|
||||||
dashboardLineResponseVOList.add(dashboardLineResponseVO);
|
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
}, (startTime) -> {
|
(startTime) -> LocalDateTimeUtil.beginOfDay(Optional.ofNullable(startTime).orElse(LocalDateTime.now()).minusMonths(1)),
|
||||||
return Objects.isNull(startTime) ?
|
(endTime) -> LocalDateTimeUtil.endOfDay(Optional.ofNullable(endTime).orElse(LocalDateTime.now()))
|
||||||
LocalDateTime.of(LocalDate.now().minusMonths(1), LocalTime.MIN.withNano(0)) :
|
),
|
||||||
LocalDateTime.of(startTime.toLocalDate().minusMonths(1), LocalTime.MIN.withNano(0));
|
|
||||||
}, (endTime) -> {
|
|
||||||
return Objects.isNull(endTime) ?
|
|
||||||
LocalDateTime.of(LocalDate.now(), LocalTime.MAX.withNano(0)) :
|
|
||||||
LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX.withNano(0));
|
|
||||||
}),
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 年
|
* 年
|
||||||
*/
|
*/
|
||||||
YEAR(dashboardLineResponseVOList -> {
|
YEAR(
|
||||||
Map<String, DashboardLineResponseVO> dispatchQuantityResponseVOMap = dashboardLineResponseVOList.stream().collect(Collectors.toMap(DashboardLineResponseVO::getCreateDt, i -> i));
|
voList -> {
|
||||||
for (int i = 0; i < 12; i++) {
|
Map<String, DashboardLineResponseVO> responseVoMap = StreamUtils.toIdentityMap(
|
||||||
|
voList, DashboardLineResponseVO::getCreateDt);
|
||||||
String format = LocalDateTime.of(LocalDate.now().minusMonths(i), LocalTime.MIN).format(DateTimeFormatter.ofPattern("yyyy-MM"));
|
for (int monthOffset = 0; monthOffset < 12; monthOffset++) {
|
||||||
DashboardLineResponseVO dashboardLineResponseVO = dispatchQuantityResponseVOMap.get(format);
|
String createDt = LocalDateTime.now().minusMonths(monthOffset).format(DateTimeFormatter.ofPattern("yyyy-MM"));
|
||||||
if (Objects.isNull(dashboardLineResponseVO)) {
|
if (!responseVoMap.containsKey(createDt)) {
|
||||||
dashboardLineResponseVO = new DashboardLineResponseVO()
|
voList.add(buildZeroedVoWithCreateDt(createDt));
|
||||||
.setTotal(0L)
|
}
|
||||||
.setTotalNum(0L)
|
|
||||||
.setFail(0L)
|
|
||||||
.setFailNum(0L)
|
|
||||||
.setMaxCountNum(0L)
|
|
||||||
.setRunningNum(0L)
|
|
||||||
.setSuccess(0L)
|
|
||||||
.setSuccessNum(0L)
|
|
||||||
.setSuspendNum(0L)
|
|
||||||
.setStop(0L)
|
|
||||||
.setCancel(0L)
|
|
||||||
.setCreateDt(format);
|
|
||||||
dashboardLineResponseVOList.add(dashboardLineResponseVO);
|
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
}, (startTime) -> {
|
(startTime) -> LocalDateTimeUtil.beginOfDay(LocalDateTime.now().with(TemporalAdjusters.firstDayOfYear())),
|
||||||
return LocalDateTime.of(LocalDate.now().with(TemporalAdjusters.firstDayOfYear()), LocalTime.MIN.withNano(0));
|
(endTime) -> LocalDateTimeUtil.endOfDay(LocalDateTime.now().with(TemporalAdjusters.lastDayOfYear()))
|
||||||
}, (endTime) -> {
|
),
|
||||||
return LocalDateTime.of(LocalDate.now().with(TemporalAdjusters.lastDayOfYear()), LocalTime.MAX.withNano(0));
|
|
||||||
}),
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 其他类型
|
* 其他类型
|
||||||
*/
|
*/
|
||||||
OTHERS(dashboardLineResponseVOList -> {
|
OTHERS(
|
||||||
}, (startTime) -> {
|
voList -> {
|
||||||
return LocalDateTime.of(startTime.toLocalDate(), LocalTime.MIN.withNano(0));
|
},
|
||||||
}, (endTime) -> {
|
(startTime) -> LocalDateTimeUtil.beginOfDay(startTime),
|
||||||
return LocalDateTime.of(endTime.toLocalDate(), LocalTime.MAX.withNano(0));
|
(endTime) -> LocalDateTimeUtil.endOfDay(endTime));
|
||||||
});
|
|
||||||
|
|
||||||
private Consumer<List<DashboardLineResponseVO>> consumer;
|
private Consumer<List<DashboardLineResponseVO>> consumer;
|
||||||
private Function<LocalDateTime, LocalDateTime> startTime;
|
private Function<LocalDateTime, LocalDateTime> startTime;
|
||||||
private Function<LocalDateTime, LocalDateTime> endTime;
|
private Function<LocalDateTime, LocalDateTime> endTime;
|
||||||
|
|
||||||
DateTypeEnum(Consumer<List<DashboardLineResponseVO>> listConsumer, Function<LocalDateTime, LocalDateTime> startTime, Function<LocalDateTime, LocalDateTime> endTime) {
|
DateTypeEnum(Consumer<List<DashboardLineResponseVO>> consumer,
|
||||||
this.consumer = listConsumer;
|
Function<LocalDateTime, LocalDateTime> startTime,
|
||||||
|
Function<LocalDateTime, LocalDateTime> endTime) {
|
||||||
|
this.consumer = consumer;
|
||||||
this.startTime = startTime;
|
this.startTime = startTime;
|
||||||
this.endTime = endTime;
|
this.endTime = endTime;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private static DashboardLineResponseVO buildZeroedVoWithCreateDt(String createDt) {
|
||||||
|
return new DashboardLineResponseVO()
|
||||||
|
.setTotal(0L)
|
||||||
|
.setTotalNum(0L)
|
||||||
|
.setFail(0L)
|
||||||
|
.setFailNum(0L)
|
||||||
|
.setMaxCountNum(0L)
|
||||||
|
.setRunningNum(0L)
|
||||||
|
.setSuccess(0L)
|
||||||
|
.setSuccessNum(0L)
|
||||||
|
.setSuspendNum(0L)
|
||||||
|
.setStop(0L)
|
||||||
|
.setCancel(0L)
|
||||||
|
.setCreateDt(createDt);
|
||||||
|
}
|
||||||
|
|
||||||
public Function<LocalDateTime, LocalDateTime> getStartTime() {
|
public Function<LocalDateTime, LocalDateTime> getStartTime() {
|
||||||
return startTime;
|
return startTime;
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user