Procházet zdrojové kódy

fix: 别名匹配之后,采集数据净值振幅检测优化

chenjianhua před 4 měsíci
rodič
revize
535a126939

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

@@ -517,7 +517,6 @@ public class EmailParseService {
                 updateNavDoList = updateNavDoList.stream().sorted(Comparator.comparing(NavDO::getPriceDate)).collect(Collectors.toList());
             }
             //因为要做振幅检测,所以不能使用批量插入的方式
-            List<NavDO> finallyNavDOList = new ArrayList<>();
             for(NavDO insertDO : insertNavDoList){
                BigDecimal  amplitude = amplitudeNav(insertDO);
                if(amplitude.compareTo(BigDecimal.valueOf(1)) >= 0){
@@ -528,13 +527,9 @@ public class EmailParseService {
                    if(amplitude.compareTo(BigDecimal.valueOf(0.2)) >= 0){
                        saveAmplitudeFundNav(insertDO,fileId,NavParseStatusConst.AMPLITUDE_EXCEPTION,1);
                    }
-                   finallyNavDOList.add(insertDO);
+                   navMapper.batchInsert(CollUtil.toList(insertDO));
                }
             }
-            if(CollUtil.isEmpty(finallyNavDOList)){
-                navMapper.batchInsert(finallyNavDOList);
-            }
-            List<NavDO> finallyUpdateNavDOList = new ArrayList<>();
             for(NavDO updateDO : updateNavDoList){
                 BigDecimal  amplitude = amplitudeNav(updateDO);
                 if(amplitude.compareTo(BigDecimal.valueOf(1)) >= 0){
@@ -544,12 +539,9 @@ public class EmailParseService {
                     if(amplitude.compareTo(BigDecimal.valueOf(0.2)) >= 0){
                         saveAmplitudeFundNav(updateDO,fileId,NavParseStatusConst.AMPLITUDE_EXCEPTION,1);
                     }
-                    finallyUpdateNavDOList.add(updateDO);
+                    navMapper.batchUpdate(CollUtil.toList(updateDO));
                 }
             }
-            if(CollUtil.isEmpty(finallyNavDOList)){
-                navMapper.batchUpdate(finallyUpdateNavDOList);
-            }
         }
     }