|
@@ -41,8 +41,6 @@ public class EmailFundNavServiceImpl implements EmailFundNavService {
|
|
@Override
|
|
@Override
|
|
public void reparseFileNav(String sourceFundName,String registerNumber, String targetFundId,String sourceFundId) {
|
|
public void reparseFileNav(String sourceFundName,String registerNumber, String targetFundId,String sourceFundId) {
|
|
List<EmailFundNavDO> fundNavDOList = emailFundNavMapper.selectNotMappingNav(sourceFundName,registerNumber);
|
|
List<EmailFundNavDO> fundNavDOList = emailFundNavMapper.selectNotMappingNav(sourceFundName,registerNumber);
|
|
- Map<String,List<EmailFundNavDO>> fundNavDOGroup = fundNavDOList.stream().collect(Collectors.groupingBy(e -> DateUtils.format(e.getPriceDate(),DateUtils.YYYY_MM_DD)));
|
|
|
|
- List<EmailFundNavDO> dataList = new ArrayList<>();
|
|
|
|
if(fundNavDOList.size() > 0){
|
|
if(fundNavDOList.size() > 0){
|
|
//修改采集库的数据
|
|
//修改采集库的数据
|
|
for(EmailFundNavDO fundNavDO : fundNavDOList){
|
|
for(EmailFundNavDO fundNavDO : fundNavDOList){
|
|
@@ -53,7 +51,7 @@ public class EmailFundNavServiceImpl implements EmailFundNavService {
|
|
}
|
|
}
|
|
emailFundNavMapper.batchUpdate(fundNavDOList);
|
|
emailFundNavMapper.batchUpdate(fundNavDOList);
|
|
//净值入库
|
|
//净值入库
|
|
- List<NavDO> navDOList = dataList.stream().filter(e -> StrUtil.isNotBlank(e.getFundId()))
|
|
|
|
|
|
+ List<NavDO> navDOList = fundNavDOList.stream().filter(e -> StrUtil.isNotBlank(e.getFundId()))
|
|
.map(e -> BeanUtil.copyProperties(e, NavDO.class)).collect(Collectors.toList());
|
|
.map(e -> BeanUtil.copyProperties(e, NavDO.class)).collect(Collectors.toList());
|
|
navDOList.forEach(e -> e.setUpdateTime(DateUtils.getNowDate()));
|
|
navDOList.forEach(e -> e.setUpdateTime(DateUtils.getNowDate()));
|
|
emailParseService.saveNavDo(navDOList,null);
|
|
emailParseService.saveNavDo(navDOList,null);
|