diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/ResultAnalysisController.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/ResultAnalysisController.java index b518489..cf83597 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/ResultAnalysisController.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/ResultAnalysisController.java @@ -7,6 +7,7 @@ import com.inspect.analysis.domain.*; import com.inspect.analysis.service.IResultAnalysisService; import com.inspect.base.core.constant.Color; import com.inspect.base.core.domain.Response; +import com.inspect.base.core.enums.PointStatusEnum; import com.inspect.base.core.utils.StringUtils; import com.inspect.base.core.utils.poi.ExcelUtil; import com.inspect.base.core.web.controller.BaseController; @@ -397,30 +398,43 @@ public class ResultAnalysisController extends BaseController { if (patrolTaskInfo.getLineIds() == null) { patrolTaskInfo.setLineIds(patrolTaskInfo.getLineId() + ""); } - + // 初筛 忽略,不用改大模型状态 跟踪确认,初筛、大模型都改成跟踪确认 + // 初筛、大模型,改成跟踪确认忽略,初筛、大模型都改成跟踪确认忽略 + // 大模型,跟踪确认忽略,大模型都改成跟踪确认忽略 logger.info("[ANALYSIS] lineIds: {}", patrolTaskInfo.getLineIds()); String[] strs = patrolTaskInfo.getLineIds().split(StringUtils.COMMA); + for (String str : strs) { ResultAnalysis resultAnalysis = new ResultAnalysis(); resultAnalysis.setLineId(Long.valueOf(str)); List resultAnalysisList = resultAnalysisService.selectResultAnalysisList(resultAnalysis); if (!resultAnalysisList.isEmpty()) { ResultAnalysis analysis = resultAnalysisList.get(0); + // 初筛结果,跟踪确认,大模型的结果状态也要改为跟踪确认 初筛 meter,其余算法不覆盖 + if (strs.length == 1 + && (PointStatusEnum.CONFIRMED.getCode().equals(patrolTaskInfo.getStatus()) + || PointStatusEnum.TRACKING.getCode().equals(patrolTaskInfo.getStatus())) + && "1".equals(analysis.getFilter()) && !"meter".equals(analysis.getAlgType())) { + // 初筛大模型都改 都覆盖 + analysis.setLineId(null); + analysis.setDescription("缺陷"); + } logger.info("[ANALYSIS] lineId: {}", analysis.getLineId()); - // 告警确认状态 3-已撤销(忽略) 4-跟踪(告警) 5-确认 + // 告警确认状态 3-已撤销(忽略) 4-跟踪(告警) 5-确认 6-缺陷 analysis.setPointStatus(patrolTaskInfo.getStatus()); analysis.setSuggestion(patrolTaskInfo.getSuggestion()); - if ("5".equals(patrolTaskInfo.getStatus())) { + // meter初筛结果不变,大模型结果不变 + if (PointStatusEnum.CONFIRMED.getCode().equals(patrolTaskInfo.getStatus())) { // 确认 analysis.setResultType("0");//缺陷 - } else if ("3".equals(patrolTaskInfo.getStatus())) { + } else if (PointStatusEnum.REVOKED.getCode().equals(patrolTaskInfo.getStatus())) { // 忽略 analysis.setResultType("1");//结果正常 - } else if ("4".equals(patrolTaskInfo.getStatus())) { + analysis.setDescription("忽略"); + } else if (PointStatusEnum.TRACKING.getCode().equals(patrolTaskInfo.getStatus())) { // 跟踪 analysis.setResultType("0");//缺陷 } - // resultAnalysisService.updateResultAnalysis(analysis); resultAnalysisService.updateResultAnalysisByCondition(analysis); } @@ -698,7 +712,7 @@ public class ResultAnalysisController extends BaseController { patrolData.setDeviceName(value.stream().map(item -> item.getDeviceName() != null ? item.getDeviceName() : "").distinct().findFirst().orElse("")); patrolData.setDeviceSource(value.stream().map(item -> item.getDeviceSource() != null ? item.getDeviceSource() : "").distinct().findFirst().orElse("")); patrolData.setImgType(value.stream().map(item -> item.getImgType() != null ? item.getImgType() : "").distinct().findFirst().orElse("")); - patrolData.setLineId(value.stream().map(item -> item.getLineId() != null ? item.getLineId() : "").distinct().findFirst().orElse("")); + patrolData.setLineId(value.stream().map(PatrolData::getLineId).distinct().collect(Collectors.joining(","))); patrolData.setPatrolTime(value.stream().map(item -> item.getPatrolTime() != null ? item.getPatrolTime() : "").distinct().findFirst().orElse("")); patrolData.setPointId(value.stream().map(item -> item.getPointId() != null ? item.getPointId() : "").distinct().findFirst().orElse("")); patrolData.setPointName(value.stream().map(item -> item.getPointName() != null ? item.getPointName() : "").distinct().findFirst().orElse("")); diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java index bea876f..f880501 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java @@ -178,6 +178,10 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService { bDefect, analyseResPoint.getType(), algType); + if (algType.equals("filter")) { + log.info("**************配置初筛算法,不走大模型*****************"); + bDefect = false; + } if (bDefect || AlgConstants.BIG_MODEL_ALG_LIST.contains(algType)) { /* * 先检查结果有缺无缺陷,如果有缺陷不用判断算法直接调用大模型;* diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java index ac7a50c..362d008 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java @@ -473,13 +473,14 @@ public class PatrolTaskController extends BaseController { // 异常置顶 newList.sort(Comparator.comparingInt(obj -> { switch (obj.getPointStatus()) { - case "0": return 1; // 异常 + case "6": return 1; // 缺陷 case "5": return 2; // 确认 case "4": return 3; // 跟踪(告警) - case "1": return 4; // 正常 - case "2": return 5; // 待人工确认 - case "3": return 6; // 已撤销(忽略) - default: return 7; + case "0": return 4; // 异常 + case "1": return 5; // 正常 + case "2": return 6; // 待人工确认 + case "3": return 7; // 已撤销(忽略) + default: return 8; } })); } @@ -3406,6 +3407,11 @@ public class PatrolTaskController extends BaseController { map1.put("label", MessageUtils.get("确认")); } + if (item.getPointStatus().equals(PointStatusEnum.DEFECT.getCode())) { + map1.put("value", "6"); + map1.put("label", MessageUtils.get("缺陷")); + } + listPointStatus.add(item.getPointStatus()); mapList.add(map1); } diff --git a/inspect-main/inspect-main-task/src/main/resources/mapper/task/ResultAnalysisMapper.xml b/inspect-main/inspect-main-task/src/main/resources/mapper/task/ResultAnalysisMapper.xml index 6849537..9df78ed 100644 --- a/inspect-main/inspect-main-task/src/main/resources/mapper/task/ResultAnalysisMapper.xml +++ b/inspect-main/inspect-main-task/src/main/resources/mapper/task/ResultAnalysisMapper.xml @@ -411,29 +411,15 @@ update result_analysis result_type = #{resultType}, - business_id = #{businessId}, - result_content = #{resultContent}, - res_status = #{resStatus}, point_status = #{pointStatus}, - objectId = #{objectId}, suggestion = #{suggestion}, description = #{description}, - request_id = #{requestId}, - task_patrol_id = #{taskPatrolId}, - alg_type = #{algType}, - res_value = #{resValue}, - res_code = #{resCode}, - res_conf = #{resConf}, - res_desc = #{resDesc}, - result = #{result}, - res_img_url = #{resImgUrl}, - image_normal_url_path = #{imageNormalUrlPath}, - res_pos = #{resPos}, - filter = #{filter}, - original_value = #{originalValue}, objectId = #{objectId} and alg_type = #{algType} and task_patrol_id = #{taskPatrolId} + + and line_id = #{lineId} +