|
|
|
|
@ -570,7 +570,7 @@ public class DataProcessServiceImpl implements DataProcessService {
|
|
|
|
|
private Map<Date, Optional<CollectionParamsManage>> dealAndInsertChillers(List<CollectionParamsManage> dataList, String mtType) { |
|
|
|
|
// 格式化时间点,然后取同样时间点的最大值
|
|
|
|
|
Map<Date, Optional<CollectionParamsManage>> collect = dataList.stream() |
|
|
|
|
.peek(val -> val.setCurTime(DateUtils.stringToDate(DateUtils.getTimeMin(val.getCurTime(), 1), "yyyy-MM-dd HH:mm:ss"))) |
|
|
|
|
.peek(val -> val.setCurTime(DateUtils.stringToDate(DateUtils.getTimeMin(val.getCurTime(), 5), "yyyy-MM-dd HH:mm:ss"))) |
|
|
|
|
.collect( |
|
|
|
|
Collectors.groupingBy( |
|
|
|
|
CollectionParamsManage::getCurTime, |
|
|
|
|
|