测试数美的直播

liwei2917
1 parent 5fa3cb57
Showing 2 changed files with 204 additions and 0 deletions
src/main/java/com/cnlive/shenhe/api/VideoStreamCallbackApi.java
src/main/java/com/cnlive/shenhe/utils/AntiFraudUtil.java
+package com.cnlive.shenhe.api;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.utils.AntiFraudUtil;
+
+import java.util.UUID;
+
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+import com.cnlive.shenhe.utils.AntiFraudUtil;
+
+
+@SuppressWarnings("unused")
+@Controller
+@RequestMapping("/api/videoStream")
+public class VideoStreamCallbackApi {
+	 private static Logger logger = LoggerFactory.getLogger(VideoStreamCallbackApi.class);
+
+    @RequestMapping(value = "callbackVideoStreamResult", method = RequestMethod.POST)
+    @ResponseBody
+    public void getFilterVideoResult(@RequestBody String json) {
+        logger.info("数美视频过滤回调,json:{}", json);
+        if (StringUtils.isNotEmpty(json)) {
+            JSONObject jsonObj = JSON.parseObject(json);
+            JSONObject resultObj = jsonObj.getJSONObject("result");
+            Integer code = resultObj.getInteger("code");
+            if (code != null && code == 1100) {
+                String riskLevel = resultObj.getString("riskLevel");
+                if ("PASS".equals(riskLevel)) {
+
+                }
+                if ("REJECT".equals(riskLevel)) {
+                    JSONArray detail = resultObj.getJSONArray("detail");
+                    JSONArray addition = resultObj.getJSONArray("addition");
+                    if (detail == null || detail.size() == 0) {
+                        if (addition != null || addition.size() > 0) {
+                            for (int i = 0; i < addition.size(); i++) {
+                                JSONObject additionObj = (JSONObject) addition.get(i);
+                                String audio_evidence = additionObj.getString("audio_evidence");
+                            }
+//                            resultObj.put("desc",
+//                                    String.format("(%s-%s)", audio_evidence.getString("description"), addition.getString("audio_matchedItem")));
+                        }
+                    }
+//                    resultObj.put("desc",
+//                            String.format("(%s-%s)", detail.getString("description"), detail.getString("matchedItem")));
+                }
+
+                if ("REVIEW".equals(riskLevel)) {
+                }
+            }else{
+            	//数美请求结果code为失败状态
+//            	jsonObj.put("type", "REJECT");
+//            	jsonObj.put("desc","code:"+code+",message:"+resultObj.getString("message") );
+            }
+        }
+    }
+    
+    /**
+     * 测试视频流
+     * @param videoStream
+     */
+    @RequestMapping(value="ceshiVideo")
+    @ResponseBody
+    public void ceshiVideo(String videoStream){
+    	//调用数美接口
+    	JSONObject result =  AntiFraudUtil.filterVideoStream(videoStream, UUID.randomUUID().toString(), "测试流的名称", "");
+    	logger.info("code="+result.getString("code"));
+    	logger.info("requestId="+result.getString("requestId"));
+    	logger.error("直播流开始测试,result:{}", result);
+    }
+    
+    /**
+     * 测试视频流
+     * @param videoStream
+     */
+    @RequestMapping(value="ceshiFinishVideo")
+    @ResponseBody
+    public void ceshiFinishVideo(String url,String requestId){
+    	//调用数美接口
+    	JSONObject result =  AntiFraudUtil.finishVideoStream(url,requestId);
+    	logger.info("code="+result.getString("code"));
+    	logger.info("requestId="+result.getString("requestId"));
+    	logger.error("直播流结束测试,result:{}", result);
+    }
+    
+    /**
+     * 测试视频流
+     * @param videoStream
+     */
+    @RequestMapping(value="queryVideo")
+    @ResponseBody
+    public void queryVideo(){
+    	//调用数美接口
+    	JSONObject result =  AntiFraudUtil.queryVideoStreamResult();
+    	logger.info("code="+result.getString("code"));
+    	logger.info("requestId="+result.getString("requestId"));
+    	logger.error("直播流查询,result:{}", result);
+    }
+    
+    
+}
@@ -23,6 +23,9 @@ public class AntiFraudUtil {
     private static final String REQUEST_URL_IMG = "http://img-api-bj.fengkongcloud.com/v2/saas/anti_fraud/imgs";
     private static final String REQUEST_URL_VIDEO = "http://video-api-bj.fengkongcloud.com/v2/saas/anti_fraud/video";
     private static final String RESPONSE_URL_VIDEO = "http://video-api-bj.fengkongcloud.com/v2/saas/anti_fraud/query_video";
+    private static final String REQUEST_URL_VIDEOSTREAM = "http://video-api.fengkongcloud.com/v2/saas/anti_fraud/videostream";
+    private static final String RESPONSE_URL_VIDEOSTREAM = "http://video-api.fengkongcloud.com/v2/saas/anti_fraud/query_videostream";
+    private static final String FINISH_URL_VIDEOSTREAM = "http://video-api.fengkongcloud.com/v2/saas/anti_fraud/finish_videostream";
     public static void main(String[] args) {
         String jsonArray = "[{\"imageUrl\":\"http://ffyl.ys2.cnliveimg.com/223/img/2018/0820/ff80808164a7163a016555c9a6ac0208/000002.jpg?imageView2/1/w/704/h/396\"},\n" +
                 "{\"imageUrl\":\"https://wjj.ys1.cnliveimg.com/769/img/2018/0129/fitnessPhotos.jpg\"},{\"imageUrl\":\"http://ffyl.ys2.cnliveimg.com/223/img/2018/0820/ff80808164a7163a016555c9a6ac0208/000002.jpg?imageView2/1/w/704/h/396\"},{\"imageUrl\":\"http://yweb3.cnliveimg.com/828/img/2018/0802/180802161358328_692.jpg\"},{\"imageUrl\":\"http://ffyl.ys2.cnliveimg.com/223/img/2018/0820/ff80808164a7163a016555c9a6ac0208/000002.jpg?imageView2/1/w/704/h/396\"},\n" +
@@ -211,6 +214,68 @@ public class AntiFraudUtil {
             return null;
         }
     }
+    
+    /**
+     * 智能视频流过滤（直播）
+     *
+     * @param url    需要过滤的视频的url
+     * @param uuid    需要过滤的视频的唯一标识
+     * @return 通过:PASS  拒绝:REJECT  异常:null
+     */
+    public static JSONObject filterVideoStream(String url,String uuid,String videoName, String channel) {
+    	try {
+    		JSONObject result = reqVideoFilterStream(url, uuid,videoName, channel);
+    		/**
+    		 * 接口会返回code， code=1100 时说明请求成功，根据不同的 riskLevel 风险级别进行业务处理
+    		 * 当 code!=1100 时，如果是 1902 错误，需要检查参数配置
+    		 * 其余情况需要根据错误码进行重试或者其它异常处理
+    		 */
+    		return result;
+    	} catch (Exception e) {
+    		return null;
+    	}
+    }
+    
+    /**
+     * 智能视频流过滤（直播）
+     *
+     * @param uuid    需要查看的视频的唯一标识
+     * @return 通过:PASS  拒绝:REJECT  异常:null
+     */
+    public static JSONObject queryVideoStreamResult() {
+    	try {
+    		JSONObject userData = new JSONObject();
+    		userData.put("accessKey", ACCESSKEY);
+    		JSONObject result = HttpClientUtils.httpPost(RESPONSE_URL_VIDEOSTREAM, userData,false);
+    		System.out.println("响应:" + result);
+    		return result;
+    	} catch (Exception e) {
+    		System.out.println("...................接口请求失败:");
+    		e.printStackTrace();
+    		return null;
+    	}
+    }
+    
+    /**
+     * 视频流关闭（直播--关闭）
+     *
+     * @param url    关闭的视频流的地址
+     * @param requestId    关闭的视频流的requestId
+     * @return 通过:PASS  拒绝:REJECT  异常:null
+     */
+    public static JSONObject finishVideoStream(String url,String requestId) {
+    	try {
+    		JSONObject result = reqFinishVideoStream(url, requestId);
+    		/**
+    		 * 接口会返回code， code=1100 时说明请求成功，根据不同的 riskLevel 风险级别进行业务处理
+    		 * 当 code!=1100 时，如果是 1902 错误，需要检查参数配置
+    		 * 其余情况需要根据错误码进行重试或者其它异常处理
+    		 */
+    		return result;
+    	} catch (Exception e) {
+    		return null;
+    	}
+    }
@@ -260,6 +325,35 @@ public class AntiFraudUtil {
         return HttpClientUtils.httpPost(REQUEST_URL_VIDEO, userData,false);
     }
+    
+    private static JSONObject reqVideoFilterStream(String url,String uuid,String videoName, String channel) throws Exception {
+    	JSONObject userData = new JSONObject();
+    	userData.put("accessKey", ACCESSKEY);
+//    	userData.put("btId", uuid);
+    	userData.put("callback","http://test.shen.cnlive.com/api/videoStream/callbackVideoStreamResult");
+    	userData.put("type", "DEFAULT");
+    	
+    	
+    	JSONObject data = new JSONObject();
+    	data.put("url", url);
+    	data.put("VideoName", videoName);
+    	data.put("callbackLevel", true);//true表示返回所有图片的审核结果，false表示只返回非pass的审核结果
+    	data.put("detectFrequency",10);//视频流截帧频率范围：0.5-60（0.5秒一帧-60秒一帧），默认为5
+    	data.put("tokenId", uuid);//客户端用户账号唯一标识，用于用户行为分析，建议传入用户UID；
+    	data.put("channel", StringUtils.isNotEmpty(channel) ? channel : "COMMENT");
+    	userData.put("data", data);
+    	
+    	return HttpClientUtils.httpPost(REQUEST_URL_VIDEOSTREAM, userData,false);
+    }
+  
+    private static JSONObject reqFinishVideoStream(String url,String requestId) throws Exception {
+    	JSONObject userData = new JSONObject();
+    	userData.put("accessKey", ACCESSKEY);
+    	userData.put("requestId",requestId);
+    	userData.put("url", url);
+    	
+    	return HttpClientUtils.httpPost(FINISH_URL_VIDEOSTREAM, userData,false);
+    }
     private static JSONObject reqArticleFilter(String tokenId,String contents ,String channel) throws Exception {
         JSONObject userData = new JSONObject();