Browse Source

/*修改monitor接口查询不存在的点位报异常问题。*/

master
htjcAdmin 9 months ago
parent
commit
c84da043c4
3 changed files with 20 additions and 14 deletions
  1. +1
    -0
      inspect-gateway/src/main/java/com/inspect/gateway/handler/GatewayExceptionHandler.java
  2. +3
    -3
      inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java
  3. +16
    -11
      inspect-metadata/src/main/java/com/inspect/metadata/patrolpointmnt/service/impl/BasedataPatrolPointServiceImpl.java

+ 1
- 0
inspect-gateway/src/main/java/com/inspect/gateway/handler/GatewayExceptionHandler.java View File

@ -32,6 +32,7 @@ public class GatewayExceptionHandler implements ErrorWebExceptionHandler {
msg = "INTERNAL SERVER ERROR!";
}
ex.printStackTrace();
log.error("[GATEWAY EXCEPTION] PATH: {}, INFO: {}", exchange.getRequest().getPath(), ex.getMessage());
return ServletUtils.webFluxResponseWriter(response, msg);
}


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

@ -735,11 +735,11 @@ public class PatrolResultController extends BaseController {
if (patrolResultTemp.getAlgId() != null && !patrolResultTemp.getAlgId().isEmpty()) {
algInfoList = patrolResultService.selectAlgInfo(patrolResultTemp);
}
logger.info("callRemoteAlgorithm algInfoList start: " + algInfoList);
logger.info("callRemoteAlgorithm algInfoList start: {}", algInfoList);
reqItem.setImageUrlList(image.split(StringUtils.COMMA));
String pictureFrame = patrolTaskService.selectConfigByKey("PICTURE_FRAME");
logger.info("callRemoteAlgorithm pictureFrame: " + pictureFrame);
logger.info("callRemoteAlgorithm pictureFrame: {}", pictureFrame);
String type;
if (!algInfoList.isEmpty()) {
@ -838,7 +838,7 @@ public class PatrolResultController extends BaseController {
}
}
logger.info("callRemoteAlgorithm firList.isEmpty(): " + firList.isEmpty());
logger.info("callRemoteAlgorithm firList.isEmpty(): {}", firList.isEmpty());
if (!firList.isEmpty() && "true".equals(pictureFrame)) {
String uuid = UUID.randomUUID().toString().trim().replaceAll(StringUtils.DASH, StringUtils.EMPTY);
redisService.setCacheObject(uuid, patrolResultList.get(0).getTaskPatrolledId(), 1L, TimeUnit.DAYS);


+ 16
- 11
inspect-metadata/src/main/java/com/inspect/metadata/patrolpointmnt/service/impl/BasedataPatrolPointServiceImpl.java View File

@ -2,6 +2,7 @@ package com.inspect.metadata.patrolpointmnt.service.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.inspect.base.core.constant.Color;
import com.inspect.base.core.utils.StringUtils;
import com.inspect.metadata.alg.domain.BasedataAlgSubtype;
import com.inspect.metadata.alg.mapper.BasedataAlgSubtypeMapper;
@ -75,25 +76,29 @@ public class BasedataPatrolPointServiceImpl implements IBasedataPatrolPointServi
}
public List<BasedataPatrolPoint> selectBasedataMonitorList(BasedataPatrolPoint basedataPatrolpoint) {
List<BasedataPatrolPoint> pointList = this.basedataPatrolpointMapper.selectBasedataMonitorList(basedataPatrolpoint);
List<BasedataPatrolPoint> pointList = basedataPatrolpointMapper.selectBasedataMonitorList(basedataPatrolpoint);
logger.info("[META] pointList cnt: {}", pointList.size());
if (null != basedataPatrolpoint.getDeviceId()) {
BasedataDevice basedataDevice = this.basedataDeviceMapper.selectBasedataDeviceByDeviceId(basedataPatrolpoint.getDeviceId());
basedataPatrolpoint.setDeviceTypeId(basedataDevice.getDeviceTypeId());
List<BasedataPatrolPoint> stdPointList = this.basedataPatrolpointMapper.selectBasedataMonitorUnionList(basedataPatrolpoint);
logger.info("[META] stdPointList cnt: {}", stdPointList.size());
for (BasedataPatrolPoint stdPoint : stdPointList) {
if (!pointList.isEmpty()) {
if (pointList.stream().filter((item) -> stdPoint.getStdParolPointId().equals(item.getStdParolPointId())).count() == 0) {
BasedataDevice basedataDevice = basedataDeviceMapper.selectBasedataDeviceByDeviceId(basedataPatrolpoint.getDeviceId());
if(basedataDevice != null) {
basedataPatrolpoint.setDeviceTypeId(basedataDevice.getDeviceTypeId());
List<BasedataPatrolPoint> stdPointList = basedataPatrolpointMapper.selectBasedataMonitorUnionList(basedataPatrolpoint);
logger.info("[META] stdPointList cnt: {}", stdPointList.size());
for (BasedataPatrolPoint stdPoint : stdPointList) {
if (!pointList.isEmpty()) {
if (pointList.stream().filter((item) -> stdPoint.getStdParolPointId().equals(item.getStdParolPointId())).count() == 0) {
pointList.add(stdPoint);
}
} else {
pointList.add(stdPoint);
}
} else {
pointList.add(stdPoint);
}
} else {
logger.warn(Color.RED + "[META] basedataDevice deviceId: {} not exist!" + Color.END, basedataPatrolpoint.getDeviceId());
}
}
List<BasedataAlgSubtype> basedataAlgSubtypes = this.basedataAlgSubtypeMapper.selectBasedataAlgSubtypeList(new BasedataAlgSubtype());
List<BasedataAlgSubtype> basedataAlgSubtypes = basedataAlgSubtypeMapper.selectBasedataAlgSubtypeList(new BasedataAlgSubtype());
logger.info("[META] basedataAlgSubtypes cnt: {}", basedataAlgSubtypes.size());
Map<String, String> algSubtypeMap = new HashMap<>();
basedataAlgSubtypes.forEach((item) -> {


Loading…
Cancel
Save