Browse Source

图片检测异常是处理

dev_shibei_match
jianjun 5 years ago
parent
commit
2452395e4a
  1. 25
      epmet-openapi/epmet-openapi-scan/src/main/java/com/epmet/openapi/scan/service/impl/ScanServiceImpl.java

25
epmet-openapi/epmet-openapi-scan/src/main/java/com/epmet/openapi/scan/service/impl/ScanServiceImpl.java

@ -12,7 +12,6 @@ import com.aliyuncs.green.model.v20180509.TextScanRequest;
import com.aliyuncs.http.FormatType; import com.aliyuncs.http.FormatType;
import com.aliyuncs.http.HttpResponse; import com.aliyuncs.http.HttpResponse;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.ValidatorUtils;
import com.epmet.openapi.scan.common.constant.SysConstant; import com.epmet.openapi.scan.common.constant.SysConstant;
import com.epmet.openapi.scan.common.enu.ImgSceneEnum; import com.epmet.openapi.scan.common.enu.ImgSceneEnum;
import com.epmet.openapi.scan.common.enu.SuggestionEnum; import com.epmet.openapi.scan.common.enu.SuggestionEnum;
@ -24,9 +23,9 @@ import com.epmet.openapi.scan.support.param.ImgScanParam;
import com.epmet.openapi.scan.support.param.ImgTask; import com.epmet.openapi.scan.support.param.ImgTask;
import com.epmet.openapi.scan.support.param.TextScanParam; import com.epmet.openapi.scan.support.param.TextScanParam;
import com.epmet.openapi.scan.support.param.TextTask; import com.epmet.openapi.scan.support.param.TextTask;
import com.epmet.openapi.scan.support.result.SceneDetailResult;
import com.epmet.openapi.scan.support.result.ImgAsyncScanResult; import com.epmet.openapi.scan.support.result.ImgAsyncScanResult;
import com.epmet.openapi.scan.support.result.ScanTaskResult; import com.epmet.openapi.scan.support.result.ScanTaskResult;
import com.epmet.openapi.scan.support.result.SceneDetailResult;
import com.epmet.openapi.scan.support.result.SyncScanResult; import com.epmet.openapi.scan.support.result.SyncScanResult;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpStatus; import org.apache.http.HttpStatus;
@ -189,14 +188,19 @@ public class ScanServiceImpl implements ScanService {
//如果是多个场景 则为对个 BaseScanResult //如果是多个场景 则为对个 BaseScanResult
List<SceneDetailResult> sceneResults = taskResult.getResults(); List<SceneDetailResult> sceneResults = taskResult.getResults();
//是文本检测 目前就一种场景 //是文本检测 目前就一种场景
boolean isSuccess = true;
for (SceneDetailResult sceneResult : sceneResults) { for (SceneDetailResult sceneResult : sceneResults) {
String suggestion = sceneResult.getSuggestion(); String suggestion = sceneResult.getSuggestion();
if (SuggestionEnum.BLOCK.getCode().equals(suggestion)) { if (SuggestionEnum.BLOCK.getCode().equals(suggestion)) {
isSuccess = false;
break;
}
}
if (isSuccess){
result.getFailDataIds().add(taskResult.getDataId()); result.getFailDataIds().add(taskResult.getDataId());
} else { } else {
result.getSuccessDataIds().add(taskResult.getDataId()); result.getSuccessDataIds().add(taskResult.getDataId());
} }
}
} else { } else {
result.getFailDataIds().add(taskResult.getDataId()); result.getFailDataIds().add(taskResult.getDataId());
log.warn("executeSyncText task process fail:code:{},msg:{}", taskResult.getCode(), taskResult.getMsg()); log.warn("executeSyncText task process fail:code:{},msg:{}", taskResult.getCode(), taskResult.getMsg());
@ -284,20 +288,19 @@ public class ScanServiceImpl implements ScanService {
} }
//如果是多个场景 则为对个 BaseScanResult //如果是多个场景 则为对个 BaseScanResult
List<SceneDetailResult> sceneResults = taskResult.getResults(); List<SceneDetailResult> sceneResults = taskResult.getResults();
//是文本检测 目前就一种场景
boolean isSuccess = true;
for (SceneDetailResult sceneResult : sceneResults) { for (SceneDetailResult sceneResult : sceneResults) {
String suggestion = sceneResult.getSuggestion(); String suggestion = sceneResult.getSuggestion();
if (SuggestionEnum.BLOCK.getCode().equals(suggestion)) { if (SuggestionEnum.BLOCK.getCode().equals(suggestion)) {
if (result.getFailDataIds().contains(taskResult.getDataId())) { isSuccess = false;
continue; break;
} }
result.getFailDataIds().add(taskResult.getDataId());
} else {
if (result.getSuccessDataIds().contains(taskResult.getDataId())) {
continue;
} }
if (isSuccess){
result.getSuccessDataIds().add(taskResult.getDataId()); result.getSuccessDataIds().add(taskResult.getDataId());
} }else{
result.getFailDataIds().add(taskResult.getDataId());
} }
} }
return result; return result;

Loading…
Cancel
Save