Browse Source

/*云深处机器狗调试:上报两个点,第二个点请求初筛没有coordinatePixel信息问题解决*/

master
htjcAdmin 3 months ago
parent
commit
6efb711987
2 changed files with 12 additions and 7 deletions
  1. +1
    -1
      inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/constant/AnalyseConstants.java
  2. +11
    -6
      inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java

+ 1
- 1
inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/constant/AnalyseConstants.java View File

@ -49,7 +49,7 @@ public class AnalyseConstants {
public static final String ALGORITHM_REQUEST_QUEUE = "algorithm:request:queue";
public static final String ALGORITHM_RESPONSE_QUEUE = "algorithm:response:queue";
public static final String ALGORITHM_REQUEST_DELAY_QUEUE = "algorithm:request:delay:queue";
public static final String ALGORITHM_REQUEST_DELAY_QUEUE = "algorithm:delay:queue";
public static final String LUMINOSITY_REQUEST_QUEUE = "luminosity:request:queue";
}

+ 11
- 6
inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java View File

@ -1422,7 +1422,7 @@ public class PatrolResultController extends BaseController {
}
}
List<PatrolResult> resultList = new ArrayList<>();
List<PatrolResult> algrithomPatrolResultList = new ArrayList<>();
for (PatrolResult patrolResult : patrolResultList) {
logger.info(Color.CYAN + "PatrolResult: {}" + Color.END, patrolResult);
datetype = "";
@ -1485,7 +1485,9 @@ public class PatrolResultController extends BaseController {
List<PatrolResult> results = patrolResultService.selectPatrolResultList(patrolResultParam);
if (!results.isEmpty()) {
//patrol_result记录已存在则更新
logger.info("SEND_MESSAGE UPDATE dateType: {}, patrol_result: {}", datetype, patrolResult);
PatrolResult patrolResult2 = results.get(0);
patrolResult2.setCoordinatePixel(patrolResult.getCoordinatePixel());
if (StringUtils.isNotEmpty(patrolResult.getFilePath())) {
patrolResult2.setFilePath(patrolResult.getFilePath());
}
@ -1547,12 +1549,14 @@ public class PatrolResultController extends BaseController {
}
}
logger.info("SEND_MESSAGE UPDATE patrolResult2: {}", patrolResult2);
i = patrolResultService.updatePatrolResult(patrolResult2);
// if (!"2".equals(Jqtype)) {
resultList.add(patrolResult2);
algrithomPatrolResultList.add(patrolResult2);
// }
} else {
//patrol_result记录不存在则新增
logger.info("SEND_MESSAGE NEW dateType: {}, patrol_result: {}", datetype, patrolResult);
patrolResult.setMainId(mainID + "");
Map<String, String> stringStringMap = patrolResultService.selectThresholdByPointId(patrolResult.getDeviceId());
if (stringStringMap != null && StringUtils.isNotEmpty(stringStringMap.get("alarm_threshold"))) {
@ -1605,18 +1609,19 @@ public class PatrolResultController extends BaseController {
}
}
logger.info("SEND_MESSAGE NEW patrolResult: {}", patrolResult);
i = patrolResultService.insertPatrolResult(patrolResult);//
resultStatistics.compare(patrolResult);
// if (!"2".equals(Jqtype)) {
resultList.add(patrolResult);
algrithomPatrolResultList.add(patrolResult);
// }
}
}
if (!resultList.isEmpty()) {
if (!algrithomPatrolResultList.isEmpty()) {
logger.info(Color.CYAN + "+++++++ callAlgorithm start +++++++" + Color.END);
if (jsonRootBean.getTotalNumber() == null && !tasks.isEmpty()) {
logger.info("jsonRootBean.getTotalNumber() == null");
logger.info("jsonRootBean.getTotalNumber not NULL: {}", algrithomPatrolResultList);
String taskId = String.valueOf(tasks.get(0).getTaskId());
logger.info("taskId: {}", taskId);
List<String> algList = patrolResultMapper.selectAlgList(taskId);
@ -1630,7 +1635,7 @@ public class PatrolResultController extends BaseController {
jsonRootBean.setTotalNumber(algCount);
}
if (!tasks.isEmpty()) {
callRemoteAlgorithm(jsonRootBean.getTotalNumber(), resultList);
callRemoteAlgorithm(jsonRootBean.getTotalNumber(), algrithomPatrolResultList);
} else {
logger.info(Color.CYAN + "callAlgorithm task: {} not exist!!!" + Color.END, code);
}


Loading…
Cancel
Save