|
|
|
@ -662,7 +662,7 @@ public class AnalysisServiceImpl implements IAnalysisService { |
|
|
|
patrolResult = resMap.get(resItem.getObjectId()); |
|
|
|
List<ResultAnalysis> resultAnalysisList = new ArrayList<>(); |
|
|
|
StringJoiner valueJoiner = new StringJoiner(StringUtils.COMMA); |
|
|
|
|
|
|
|
StringJoiner validJoiner = new StringJoiner(StringUtils.COMMA); |
|
|
|
for (AnalyseResPoint analyseResPoint : resItem.getResults()) { |
|
|
|
ResultAnalysis resultAnalysis = combineAnalyse(analyseResult, |
|
|
|
String.valueOf(resMap.get(resItem.getObjectId()).getLineId()), |
|
|
|
@ -671,6 +671,20 @@ public class AnalysisServiceImpl implements IAnalysisService { |
|
|
|
analyseResPoint); |
|
|
|
resultAnalysisList.add(resultAnalysis); |
|
|
|
valueJoiner.add(resultAnalysis.getResValue()); |
|
|
|
String pointStatus = resultAnalysis.getPointStatus(); |
|
|
|
String resultType = resultAnalysis.getResultType(); |
|
|
|
String resStatus = resultAnalysis.getResStatus(); |
|
|
|
// resultType:0-告警 1-正常 2-异常 |
|
|
|
if ("0".equals(resultType)) { |
|
|
|
// 判别异常 |
|
|
|
validJoiner.add("2"); |
|
|
|
} else if ("1".equals(resultType)) { |
|
|
|
// 成功 |
|
|
|
validJoiner.add("1"); |
|
|
|
} else if ("2".equals(resultType)) { |
|
|
|
// 失败 |
|
|
|
validJoiner.add("0"); |
|
|
|
} |
|
|
|
log.info(Color.GREEN + "[analysis] createTime: {}, insertResultAnalysis: {}" + Color.END, resultAnalysis.getCreateTime(), resultAnalysis); |
|
|
|
try { |
|
|
|
resultAnalysisService.insertResultAnalysis(resultAnalysis); |
|
|
|
@ -680,6 +694,7 @@ public class AnalysisServiceImpl implements IAnalysisService { |
|
|
|
} |
|
|
|
|
|
|
|
patrolResult.setValue(valueJoiner.toString()); |
|
|
|
patrolResult.setValid(validJoiner.toString()); |
|
|
|
List<SysDictData> algAliasList = DictUtils.getDictCache(Tags.DEFECT_TYPE); |
|
|
|
JSONObject algAliasMap = new JSONObject(); |
|
|
|
Objects.requireNonNull(algAliasList).stream().filter((item) -> { |
|
|
|
|