暂存4

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/scan/param/VideoScanParamDTO.java

@@ -0,0 +1,35 @@
+package com.epmet.commons.tools.scan.param;
+
+import lombok.Data;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * （异步检测）请求参数
+ *
+ * @author yinzuomei@elink-cn.com
+ * @date 2021/1/10 21:05
+ */
+@Data
+public class VideoScanParamDTO implements Serializable {
+    private static final long serialVersionUID = -7261993744367287072L;
+    /**
+     * 是否开启回调
+     */
+    @NotNull(message = "openCallBack必填,true开启;false不开启")
+    private Boolean openCallBack;
+
+    /**
+     * 异步检测结果回调地址,执行异步审查内容时 必填
+     * openCallBack=true时,callback必填
+     */
+    private String callback;
+
+    @Valid
+    @NotEmpty(message = "任务列表不能为空")
+    private List<VideoTaskDTO> tasks;
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/scan/param/VideoTaskDTO.java

@@ -0,0 +1,32 @@
+package com.epmet.commons.tools.scan.param;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * （异步检测）请求参数
+ *
+ * @author yinzuomei@elink-cn.com
+ * @date 2021/1/10 21:06
+ */
+@Data
+public class VideoTaskDTO implements Serializable {
+    private static final long serialVersionUID = -5268462578193403270L;
+    /**
+     * 不必填
+     * 要检测的数据id 非必填
+     * 检测对象对应的数据ID。
+     * 由大小写英文字母、数字、下划线（_）、短划线（-）、英文句号（.）组成，不超过128个字符，可以用于唯一标识您的业务数据。
+     * */
+    @NotBlank(message = "dataId不能为空")
+    private String dataId;
+
+    /**
+     * 必填
+     * 待检测视频的URL。该字段不能和frames同时为空，也不能和frames同时有值。
+     */
+    @NotBlank(message = "音频URL不能为空")
+    private String url;
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/scan/result/AsyncScanResult.java

@@ -8,7 +8,7 @@ import java.util.List;
 
 /**
  * 语音异步检测 返参
- *
+ * 视频异步检测 返参通用
  * @author yinzuomei@elink-cn.com
  * @date 2020/12/18 10:09
  */

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/scan/result/VideoAsyncScanResultDTO.java

@@ -0,0 +1,47 @@
+package com.epmet.commons.tools.scan.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 视频异步检测结果查询接口返参
+ * 正在检测中的不返回,调用方继续轮询查询结果
+ * @author yinzuomei@elink-cn.com
+ * @date 2020/12/29 15:37
+ */
+@Data
+public class VideoAsyncScanResultDTO implements Serializable {
+    private static final long serialVersionUID = -7302168989456734818L;
+    /**
+     * 执行成功的任务Id集合
+     * code=200,且所有语音+视频所有场景返回结果都为pass时则为成功
+     */
+    private List<String> passDataIds = new ArrayList<>();
+    /**
+     * 执行失败的任务Id集合
+     */
+    private List<String> noPassDataIds = new ArrayList<>();
+
+    private List<String> passTaskIds = new ArrayList<>();
+    private List<String> noPassTaskIds = new ArrayList<>();
+
+    /**
+     * desc:阿里内容审核API返回结果详情
+     */
+    private List<VideoScanDetailDTO> details = new ArrayList<>();
+
+    /**
+     * 本地是否全部通过
+     */
+    private Boolean isAllPass;
+
+    public boolean isAllPass() {
+        if (noPassTaskIds.isEmpty() && !passTaskIds.isEmpty()) {
+            return true;
+        }
+        return isAllPass;
+    }
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/scan/result/VideoScanDetailDTO.java

@@ -0,0 +1,56 @@
+package com.epmet.commons.tools.scan.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ *
+ * @author yinzuomei@elink-cn.com
+ * @date 2021/1/10 21:24
+ */
+@Data
+public class VideoScanDetailDTO implements Serializable {
+    /**
+     * 错误码，和HTTP状态码一致。
+     * 更多信息，请参见公共错误码。
+     */
+    private Integer code;
+
+    private String codeDesc;
+
+    /**
+     * 错误描述信息。
+     */
+    private String msg;
+    /**
+     * 检测对象对应的数据ID。
+     */
+    private String dataId;
+
+    /**
+     * 检测任务的ID
+     */
+    private String taskId;
+
+    /**
+     * 返回结果，调用成功时（code=200），返回结果中包含一个或多个元素。每个元素是个结构体，具体结构描述，请参见result。
+     * 说明 视频流检测场景中，code返回280表示在检测中，返回200表示检测完成。在检测中状态时，检测结果中包含从开始检测到当前时间的检测到结果。
+     */
+    private List<ResultDetail> results;
+
+    /**
+     * 视频语音检测结果。具体结构描述，请参见audioScanResult。
+     */
+    private ResultDetail audioScanResults;
+
+
+    @Data
+    public static class ResultDetail {
+        private String scene;
+        private String label;
+        private String suggestion;
+        private Float rate;
+    }
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/ScanContentUtils.java

@@ -8,6 +8,7 @@ import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.scan.param.*;
 import com.epmet.commons.tools.scan.result.AsyncScanResult;
 import com.epmet.commons.tools.scan.result.SyncScanResult;
+import com.epmet.commons.tools.scan.result.VideoAsyncScanResultDTO;
 import com.epmet.commons.tools.scan.result.VoiceResultDTO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -136,6 +137,65 @@ public class ScanContentUtils {
 		}
 	}
 
+	/**
+	 * @param url 视频地址
+	 * @param param
+	 * @author yinzuomei
+	 * @description 异步检测-提交检测任务
+	 **/
+	public static Result<AsyncScanResult> videoAsyncScan(String url, VideoScanParamDTO param){
+		log.debug("videoAsyncScan param:{}", JSON.toJSONString(param));
+		if (StringUtils.isBlank(url) || param == null) {
+			throw new RenException("参数错误");
+		}
+		if (param.getOpenCallBack() && StringUtils.isBlank(param.getCallback())) {
+			throw new RenException("参数错误,开启回调,callback必填");
+		}
+		try {
+			Result<String> result = HttpClientManager.getInstance().sendPostByJSON(url, JSON.toJSONString(param));
+			log.debug("videoAsyncScan result:{}", JSON.toJSONString(result));
+			if (result.success()) {
+				return JSON.parseObject(result.getData(),new TypeReference<Result<AsyncScanResult>>(){});
+			}
+			Result<AsyncScanResult> resultResult = new Result<>();
+			resultResult.error(result.getCode(),result.getMsg());
+			resultResult.setInternalMsg(result.getInternalMsg());
+			return resultResult;
+		} catch (Exception e) {
+			log.error("videoAsyncScan exception:", e);
+			throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode(), e.getMessage());
+		}
+	}
+
+	/**
+	 * @param url
+	 * @param taskIds
+	 * @author yinzuomei
+	 * @description 查询视频检测结果
+	 **/
+	public static Result<VideoAsyncScanResultDTO> videoResults(String url, List<String> taskIds) {
+		if (StringUtils.isBlank(url) || CollectionUtils.isEmpty(taskIds)) {
+			throw new RenException("参数错误");
+		}
+		if (taskIds.size() > NumConstant.ONE_HUNDRED) {
+			throw new RenException("参数错误,查询检测任务最大不能超过100");
+		}
+		try {
+			Result<String> result = HttpClientManager.getInstance().sendPostByJSON(url, JSON.toJSONString(taskIds));
+			log.debug("videoResults result:{}", JSON.toJSONString(result));
+			if (result.success()) {
+				return JSON.parseObject(result.getData(), new TypeReference<Result<VideoAsyncScanResultDTO>>() {
+				});
+			}
+			Result<VideoAsyncScanResultDTO> resultResult = new Result<>();
+			resultResult.error(result.getCode(), result.getMsg());
+			resultResult.setInternalMsg(result.getInternalMsg());
+			return resultResult;
+		} catch (Exception e) {
+			log.error("voiceResults exception:", e);
+			throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode(), e.getMessage());
+		}
+	}
 
 	public static void main(String[] args) {
 		//测试文本检测
@@ -143,7 +203,11 @@ public class ScanContentUtils {
 		//测试语音检测
 		// testVoiceAsyncScan();
 		//语音检测结果
-		testVoiceResults();
+		// testVoiceResults();
+		//视频检测任务提交
+		testVideoAsyncScan();
+		//查询视频检测结果
+		// testVideoResults();
 	}
 
 	public static void testTextSyncScan(){
@@ -200,4 +264,26 @@ public class ScanContentUtils {
 		Result<List<VoiceResultDTO>> asyncScanResultResult = ScanContentUtils.voiceResults(url, taskIds);
 		System.out.println("================" + JSON.toJSONString(asyncScanResultResult));
 	}
+
+	public static void testVideoAsyncScan(){
+		String url = "http://localhost:8107/epmetscan/api/videoAsyncScan";
+		VideoTaskDTO p = new VideoTaskDTO();
+		p.setDataId("1");
+		p.setUrl("???");
+		List<VideoTaskDTO> list = new ArrayList<>();
+		list.add(p);
+		VideoScanParamDTO param = new VideoScanParamDTO();
+		param.setTasks(list);
+		param.setOpenCallBack(false);
+		Result<AsyncScanResult> asyncScanResultResult = ScanContentUtils.videoAsyncScan(url, param);
+		System.out.println(JSON.toJSONString(asyncScanResultResult));
+	}
+
+	public static void testVideoResults(){
+		String url = "http://localhost:8107/epmetscan/api/videoResults";
+		List<String> taskIds=new ArrayList<>();
+		taskIds.add("???");
+		Result<VideoAsyncScanResultDTO> result = ScanContentUtils.videoResults(url, taskIds);
+		System.out.println("================" + JSON.toJSONString(result));
+	}
 }