Browse Source

Merge branches 'dev' and 'dev_partybranch' of http://git.elinkit.com.cn:7070/r/epmet-cloud into dev_partybranch

dev_shibei_match
yinzuomei 5 years ago
parent
commit
4830ae9ead
  1. 2
      epmet-openapi/epmet-openapi-scan/deploy/docker-compose-dev.yml
  2. 2
      epmet-openapi/epmet-openapi-scan/pom.xml
  3. 27
      epmet-openapi/epmet-openapi-scan/src/main/java/com/epmet/openapi/scan/service/impl/ScanServiceImpl.java
  4. 4
      epmet-openapi/epmet-openapi-scan/src/main/java/com/epmet/openapi/scan/support/param/TextScanParam.java

2
epmet-openapi/epmet-openapi-scan/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
epmet-openapi-scan: epmet-openapi-scan:
container_name: epmet-openapi-scan-dev container_name: epmet-openapi-scan-dev
image: 192.168.1.130:10080/epmet-cloud-dev/epmet-openapi-scan:0.3.8 image: 192.168.1.130:10080/epmet-cloud-dev/epmet-openapi-scan:0.3.11
ports: ports:
- "8107:8107" - "8107:8107"
network_mode: host # 不会创建新的网络 network_mode: host # 不会创建新的网络

2
epmet-openapi/epmet-openapi-scan/pom.xml

@ -4,7 +4,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.8</version> <version>0.3.11</version>
<artifactId>epmet-openapi-scan</artifactId> <artifactId>epmet-openapi-scan</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>

27
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.PASS.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;

4
epmet-openapi/epmet-openapi-scan/src/main/java/com/epmet/openapi/scan/support/param/TextScanParam.java

@ -26,14 +26,14 @@ public class TextScanParam implements Serializable {
* *
* @see com.epmet.openapi.scan.common.enu.ImgSceneEnum; * @see com.epmet.openapi.scan.common.enu.ImgSceneEnum;
*/ */
@Valid
@NotEmpty(message = "任务列表不能为空")
private List<String> scenes; private List<String> scenes;
/** /**
* 要检测的内容列表必填 * 要检测的内容列表必填
* remark一组任务列表中的taskId不能相同 * remark一组任务列表中的taskId不能相同
*/ */
@Valid
@NotEmpty(message = "任务列表不能为空")
private List<TextTask> tasks; private List<TextTask> tasks;
/** /**

Loading…
Cancel
Save