|
@@ -155,6 +155,11 @@ public class AnalysisServiceImpl implements AnalysisService {
|
|
|
private final static String ZREO_STR = "0";
|
|
|
|
|
|
/**
|
|
|
+ * 当分析类型不按照机型分析的话 总图数据库表中风机类型编号的值为total
|
|
|
+ */
|
|
|
+ private final static String GENERAL_FILE_TYPE_CODE = "total";
|
|
|
+
|
|
|
+ /**
|
|
|
* 风机编号正则
|
|
|
*/
|
|
|
private static final String ENGINE_CODE_PATTEN = IdPrefixEnum.WIND_EILL_NUMBER.getCode() + "\\d{3," + IdGeneratorUtil.DEC_INIT_LENGTH + "}";
|
|
@@ -670,13 +675,17 @@ public class AnalysisServiceImpl implements AnalysisService {
|
|
|
private List<AnalysisGeneralFileVo> getNewGeneralFiles(String batchCode,String analysisTypeCode, boolean isIntranet){
|
|
|
//从数据库获取当前批次、当前分析类型的所有的分析总文件
|
|
|
List<AnalysisGeneralFileVo> generalFileVos = generalFileMapper.selectByCondition(batchCode,analysisTypeCode);
|
|
|
- generalFileVos = generalFileVos.stream().filter(item-> StringUtils.isBlank(item.getEngineTypeCode()))
|
|
|
+ generalFileVos = generalFileVos.stream().filter(item-> StringUtils.isNotBlank(item.getEngineTypeCode()))
|
|
|
.collect(Collectors.groupingBy(
|
|
|
AnalysisGeneralFileVo::getEngineTypeCode,
|
|
|
Collectors.maxBy(Comparator.comparing(AnalysisGeneralFileVo::getCreateTime)))
|
|
|
).values().stream().map(Optional::get).collect(Collectors.toList());
|
|
|
//添加内外网前缀
|
|
|
generalFileVos.forEach(item -> item.setFileAddr(getFilePath(isIntranet,item.getFileAddr())));
|
|
|
+ //当同一个批次、同一个分析类型下,存在多个总文件时,说明一定是按照机型分析,需过滤掉total机型的文件
|
|
|
+ if(generalFileVos.size() > 1){
|
|
|
+ generalFileVos = generalFileVos.stream().filter(item -> !item.getAnalysisTypeCode().equals(GENERAL_FILE_TYPE_CODE)).collect(Collectors.toList());
|
|
|
+ }
|
|
|
return generalFileVos;
|
|
|
}
|
|
|
|