浏览代码

fix: 数据净值小于等于0不入库

chenjianhua 5 月之前
父节点
当前提交
1388fa3179
共有 1 个文件被更改,包括 4 次插入4 次删除
  1. 4 4
      service-daq/src/main/java/com/simuwang/daq/service/EmailParseService.java

+ 4 - 4
service-daq/src/main/java/com/simuwang/daq/service/EmailParseService.java

@@ -556,8 +556,8 @@ public class EmailParseService {
         if (assetNet == null) {
             return fundAssetDOList;
         }
-        Integer isStored = fundNavDTO.getParseStatus() != null
-                && (fundNavDTO.getParseStatus().equals(NavParseStatusConst.ASSET_NET_NEGATIVE) || fundNavDTO.getParseStatus().equals(NavParseStatusConst.SUCCESS)) ? 1 : 0;
+        Integer isStored = fundNavDTO.getParseStatus() != null && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.ASSET_NET_NEGATIVE)
+                && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NOT_MATCH)? 1 : 0;
         Date priceDate = DateUtil.parse(fundNavDTO.getPriceDate(), DateConst.YYYY_MM_DD);
         if (CollUtil.isNotEmpty(fundNavDTO.getFundIdList())) {
             for (String fundId : fundNavDTO.getFundIdList()) {
@@ -586,7 +586,7 @@ public class EmailParseService {
             emailFundAssetDO.setRegisterNumber(fundNavDTO.getRegisterNumber());
             emailFundAssetDO.setAssetNet(assetNet);
             emailFundAssetDO.setAssetShare(assetShare);
-            emailFundAssetDO.setIsStored(isStored);
+            emailFundAssetDO.setIsStored(0);//未匹配基金统一不入库
             emailFundAssetDO.setExceptionStatus(fundNavDTO.getParseStatus());
             emailFundAssetDO.setIsvalid(1);
             emailFundAssetDO.setCreatorId(0);
@@ -604,7 +604,7 @@ public class EmailParseService {
         BigDecimal nav = StrUtil.isNotBlank(fundNavDTO.getNav()) ? new BigDecimal(fundNavDTO.getNav()) : null;
         BigDecimal cumulativeNavWithdrawal = StrUtil.isNotBlank(fundNavDTO.getCumulativeNavWithdrawal()) ? new BigDecimal(fundNavDTO.getCumulativeNavWithdrawal()) : null;
         Integer isStored = fundNavDTO.getParseStatus() != null && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NAV_DEFICIENCY)
-                && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NOT_MATCH) && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NAV_NEGATIVE) && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.ASSET_NET_NEGATIVE) ? 1 : 0;
+                && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NOT_MATCH) && !fundNavDTO.getParseStatus().equals(NavParseStatusConst.NAV_NEGATIVE) ? 1 : 0;
         if (CollUtil.isNotEmpty(fundNavDTO.getFundIdList())) {
             for (String fundId : fundNavDTO.getFundIdList()) {
                 EmailFundNavDO emailFundNavDO = new EmailFundNavDO();