package com.whyc.service;
|
|
import com.google.gson.internal.LinkedTreeMap;
|
import com.whyc.dto.Mp4FileDTO;
|
import com.whyc.dto.Response;
|
import com.whyc.dto.Response4Http;
|
import com.whyc.util.HttpUtil;
|
import com.whyc.util.JsonUtil;
|
import org.springframework.stereotype.Service;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
import java.util.stream.Stream;
|
|
import static com.whyc.util.HttpUtil.urlEncode;
|
|
/**
|
* 视频相关服务封装
|
*/
|
@Service
|
public class VideoService {
|
|
/**
|
* 获取视频流id
|
* @return
|
*/
|
public Response4Http getVideoStreamIds() {
|
Response4Http responseResult = new Response4Http<>();
|
|
Map<String, Object> params = new HashMap<>();//组合参数
|
params.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
String queryParams = urlEncode(params);
|
String httpUrl ="http://127.0.0.1:9092/index/api/getMediaList";
|
Response response = HttpUtil.doGet(httpUrl, queryParams);
|
Integer httpResponseCode = response.getCode();
|
String responseJson = (String) response.getData();
|
if(httpResponseCode == 1) { //请求成功
|
Response4Http responseHttp = JsonUtil.getGson().fromJson(responseJson, Response4Http.class);
|
if(responseHttp.getCode() == 0 ) { //接口返回状态码为成功
|
if(responseHttp.getData()!=null) {
|
List<LinkedTreeMap<String, Object>> list = (List) responseHttp.getData();
|
Stream<LinkedTreeMap<String, Object>> linkedTreeMapStream = list.stream().filter(item -> ((String) item.get("schema")).equals("rtsp"));
|
return responseResult.setII(1,true,linkedTreeMapStream.map(item -> (String) item.get("stream")).collect(Collectors.toList()),null);
|
}{
|
return responseResult.set(1,true,"未查询到已开启的流");
|
}
|
}else{ //接口返回状态码为失败,获取msg
|
return responseResult.set(1,false,responseHttp.getMsg());
|
}
|
}else{ //请求失败
|
return responseResult.set(0,response.getData(),response.getMsg());
|
}
|
}
|
|
/**
|
* 1个小时录制为视频录制单个时长 :
|
* max_second = 1*60*60
|
*
|
* @param streamId
|
* @return
|
*/
|
public Response4Http startRecord(String streamId){
|
Map<String, Object> params = new HashMap<>();//组合参数
|
params.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
params.put("type", 1);
|
params.put("vhost", "__defaultVhost__");
|
params.put("app", "rtp");
|
params.put("stream", streamId);
|
params.put("max_second",3600);
|
String httpUrl ="http://127.0.0.1:9092/index/api/startRecord";
|
//Response response = HttpUtil.doGet(httpUrl, queryParams);
|
//Integer code = response.getCode();
|
//String responseJson = (String) response.getData();
|
return HttpUtil.doGet(httpUrl,params);
|
|
}
|
|
public Response4Http stopRecord(String streamId){
|
Map<String, Object> params = new HashMap<>();//组合参数
|
params.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
params.put("type", 1);
|
params.put("vhost", "__defaultVhost__");
|
params.put("app", "rtp");
|
params.put("stream", streamId);
|
String httpUrl ="http://127.0.0.1:9092/index/api/stopRecord";
|
return HttpUtil.doGet(httpUrl,params);
|
/*String queryParams = urlEncode(params);
|
String httpUrl ="http://127.0.0.1:9092/index/api/stopRecord";
|
Response response = HttpUtil.doGet(httpUrl, queryParams);
|
Integer code = response.getCode();
|
String responseJson = (String) response.getData();
|
if(code == 1) { //请求成功
|
Response4Http responseHttp = HttpUtil.getGson().fromJson(responseJson, Response4Http.class);
|
if(responseHttp.getCode() == 0 && responseHttp.getMsg().equals("success")) { //请求成功
|
}else{
|
System.out.println(responseHttp.getMsg());
|
}
|
}*/
|
|
}
|
|
/**
|
* getMp4RecordFile
|
*/
|
public Response4Http<String> getMp4RecordFile(String streamId, String period){
|
Map<String, Object> params = new HashMap<>();//组合参数
|
params.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
params.put("type", 1);
|
params.put("vhost", "__defaultVhost__");
|
params.put("app", "rtp");
|
params.put("stream", streamId);
|
params.put("period",period);
|
String httpUrl ="http://127.0.0.1:9092/index/api/getMp4RecordFile";
|
Response4Http response4Http = HttpUtil.doGet(httpUrl, params);
|
//data格式为:"data" : {
|
// "paths" : [ "2020-01-25", "2020-01-24" ],
|
// "rootPath" : "/www/record/live/ss/"
|
// }
|
String dataStr = (String) response4Http.getData2();
|
Mp4FileDTO mp4FileDTO = JsonUtil.getGson().fromJson(dataStr, Mp4FileDTO.class);
|
response4Http.setData2(mp4FileDTO);
|
return response4Http;
|
|
/*if(code == 1) { //请求成功
|
Response responseHttp = HttpUtil.getGson().fromJson(responseJson, Response.class);
|
if(responseHttp.getCode() == 0 && responseHttp.getMsg().equals("success")) { //请求成功
|
System.out.println(responseHttp.getData());
|
return responseJson;
|
}else{
|
System.out.println(responseHttp.getMsg());
|
}
|
}*/
|
|
}
|
|
public Response4Http<String> openRtpServer(String streamId) {
|
HashMap<String, Object> paramMap = new HashMap<>();
|
paramMap.put("port", 0);
|
paramMap.put("tcp_mode", 1);
|
paramMap.put("stream_id", streamId);
|
paramMap.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
return HttpUtil.doGet("http://127.0.0.1:9092/index/api/openRtpServer", paramMap);
|
}
|
|
public Response4Http<String> addStreamProxy(String streamId) {
|
HashMap<String, Object> paramMap = new HashMap<>();
|
paramMap.put("vhost", "__defaultVhost__");
|
paramMap.put("app", "rtp");
|
paramMap.put("stream", streamId);
|
paramMap.put("url", "rtsp://127.0.0.1:554/rtp/"+streamId);
|
paramMap.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
return HttpUtil.doGet("http://127.0.0.1:9092/index/api/addStreamProxy", paramMap);
|
}
|
|
public Response4Http isRecording(String streamId){
|
Map<String, Object> params = new HashMap<>();//组合参数
|
params.put("secret", "TWSYFgYJOQWB4ftgeYut8DW4wbs7pQnj");
|
params.put("type", 1);
|
params.put("vhost", "__defaultVhost__");
|
params.put("app", "rtp");
|
params.put("stream", streamId);
|
String httpUrl ="http://127.0.0.1:9092/index/api/isRecording";
|
return HttpUtil.doGet(httpUrl, params);
|
}
|
|
}
|
