LiveControllerApi.java
4.1 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
package com.cnlive.shenhe.api;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cnlive.shenhe.bean.ErrorEnum;
import com.cnlive.shenhe.bean.ResponseBean;
import com.cnlive.shenhe.utils.AntiFraudUtil;
import java.util.HashMap;
import java.util.Map;
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.PostMapping;
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/live")
public class LiveControllerApi {
private static Logger logger = LoggerFactory.getLogger(LiveControllerApi.class);
@RequestMapping("/import")
@ResponseBody
public JSONObject impotVideo(String param) {
JSONObject map = new JSONObject();
JSONObject result = new JSONObject();
result.put("errorCode", "0");
result.put("errorMessage", "直播审核请求收到成功");
map.put("statusCode", "200");
map.put("result", result);
return map;
}
@RequestMapping(value = "callbackLiveResult", 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)) {
JSONObject detail = resultObj.getJSONObject("detail");
logger.info("数美视频回调--REJECT,detail:{}", detail);
// 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);
}
}