Commit dc2967c6 authored by 钱坤's avatar 钱坤

私募的latest_nav更新startDate逻辑调整

parent e1df123d
......@@ -49,6 +49,8 @@ public class FundLatestNavService {
Date startTime = list.get(0).getCreateTime();
List<FundLatestNav> latestList = fundInfoCustomMapper.getFundLatestNet(startTime);
List<FundLatestNav> latestListRH = fundInfoCustomMapper.getFundLatestNetInRH(startTime);
Date newStartTime = latestList.stream().map(FundLatestNav::getCreateTime).max(Date::compareTo).orElseGet(null);
Date newStartTimeRH = latestListRH.stream().map(FundLatestNav::getCreateTime).max(Date::compareTo).orElseGet(null);
List<FundLatestNav> navList = new ArrayList<>(latestListRH.size() + latestList.size() + 1);
navList.addAll(latestList);
navList.addAll(latestListRH);
......@@ -104,8 +106,10 @@ public class FundLatestNavService {
p += 200;
}
Date newStartTime = latestList.stream().map(FundLatestNav::getCreateTime).max(Date::compareTo).get();
Date newStartTimeRH = latestListRH.stream().map(FundLatestNav::getCreateTime).max(Date::compareTo).get();
if (newStartTime == null || newStartTimeRH == null) {
log.info("私募新净值起始时间本次不需要更新,newStartTime: {}, start: {}", newStartTime, newStartTimeRH);
return;
}
FundLatestNav target = new FundLatestNav();
// 存储较小的那个,保证两个表里的都能被扫描到.
target.setCreateTime(newStartTime.before(newStartTimeRH) ? newStartTime : newStartTimeRH);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment