package com.sinata.system.service.biz;
|
|
import cn.hutool.crypto.digest.DigestUtil;
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.sinata.common.exception.ServiceException;
|
import com.sinata.system.config.DeviceConfig;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Slf4j
|
@RequiredArgsConstructor
|
public class MonitorDeviceApiNewService {
|
|
@Autowired
|
private DeviceConfig deviceConfig;
|
|
//登录
|
private final String LOGIN_URL = "/api/v1/login?username=%s&password=%s&url_token_only=%s";
|
//根据状态获取视频列表
|
private final String LIST_URL = "/api/v1/device/list?online=%s";
|
//查询设备通道列表接口（新）
|
private final String channellist_URL = "/api/v1/device/channellist?serial=%s";
|
//根据设备号获取视频链接
|
private final String STREAM_URL = "/api/v1/stream/start?serial=%s&channel=%s";
|
//查询通道录像列表接口（新）
|
private final String recordlist_URL = "/api/v1/playback/recordlist?serial=%s&channel=%s&starttime=%s&endtime=%s";
|
//开始回放接口（新）
|
private final String playbackStart_URL = "/api/v1/playback/start?serial=%s&channel=%s&starttime=%s&endtime=%s";
|
//回放流停止接口（新）
|
private final String playbackStop_URL = "/api/v1/playback/stop?streamid=%s";
|
|
//在线数据
|
Boolean url_token_only = true;
|
//获取视频列表参数
|
Boolean online = true;//设备是否在线
|
|
private final RedisTemplate<Object, Object> redisTemplate;
|
private final RestTemplate restTemplate;
|
|
/**
|
* 登录
|
* type==1 重新调起登录
|
*
|
* @return
|
*/
|
public String getJSession(Integer type) {
|
String key = "monitor:device:jsession:now";
|
String jsession = redisTemplate.opsForValue().get(key).toString();
|
Long timeOut = 604800L;
|
if (jsession == null || type == 1) {
|
String loginUrl = String.format(
|
deviceConfig.getBaseUrl() + LOGIN_URL, deviceConfig.getUserName(), DigestUtil.md5Hex(deviceConfig.getPassword()), url_token_only);
|
log.info("视频服务器:登录接口传参数据:{}", loginUrl);
|
JSONObject result = restTemplate.getForObject(loginUrl, JSONObject.class);
|
log.info("视频服务器:登录接口返回数据:{}", result);
|
if (result == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
if (result != null) {
|
timeOut = result.getLong("TokenTimeout");//缓存过期时间
|
jsession = result.getString("URLToken");//token
|
} else {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
}
|
redisTemplate.opsForValue().set(key, jsession, timeOut);
|
return jsession;
|
}
|
|
/**
|
* 获取设备列表
|
*
|
* @return
|
*/
|
public List<String> getDeviceList() {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + LIST_URL, online);
|
try {
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
List<String> list = new ArrayList<>();
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
JSONArray jsonArray = jsonBody.getJSONArray("DeviceList");
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String ID = jsonObject.getString("ID");
|
list.add(ID);
|
}
|
return list;
|
} catch (Exception e) {
|
getJSession(1);
|
return getDeviceList();
|
}
|
}
|
|
/**
|
* 获取通道列表
|
*
|
* @return
|
*/
|
public List<Map<String, String>> getChannelList(String serial) {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + channellist_URL, serial);
|
try {
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
List<Map<String, String>> list = new ArrayList<>();
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
JSONArray jsonArray = jsonBody.getJSONArray("ChannelList");
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String channel = jsonObject.getString("Channel");
|
Map<String, String> map = new HashMap<>();
|
map.put("channel", channel);
|
list.add(map);
|
}
|
return list;
|
} catch (Exception e) {
|
getJSession(1);
|
return getChannelList(serial);
|
}
|
}
|
|
/**
|
* 获取设备播放路径
|
*
|
* @param devIdno
|
* @return
|
*/
|
public Map<String, Object> getDeviceUrl(String devIdno, Integer channelNum) {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
if (channelNum == null) {
|
channelNum = 1;
|
}
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + STREAM_URL, devIdno, channelNum);
|
System.out.println(completeUrl);
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
String flv = jsonBody.getString("FLV");
|
String snapURL = jsonBody.getString("SnapURL");
|
Map<String, Object> reMap = new HashMap<>();
|
reMap.put("flv", flv);
|
reMap.put("snapURL", deviceConfig.getBaseUrl() + snapURL);
|
return reMap;
|
}
|
|
/**
|
* 查询通道录像列表
|
*
|
* @return
|
*/
|
public List<Map<String, String>> getPlaybackRecordlist(String serial, Integer channel, String starttime, String endtime) {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + recordlist_URL, serial, channel, starttime, endtime);
|
try {
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
List<Map<String, String>> list = new ArrayList<>();
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
JSONArray jsonArray = jsonBody.getJSONArray("RecordList");
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Map<String, String> map = JSON.parseObject(jsonObject.toJSONString(), Map.class);
|
list.add(map);
|
}
|
return list;
|
} catch (Exception e) {
|
getJSession(1);
|
return null;
|
//return getPlaybackRecordlist(serial,channel,starttime,endtime);
|
}
|
}
|
|
/**
|
* 开始回放接口
|
*
|
* @param serial
|
* @return
|
*/
|
public Map<String, Object> playbackStart(String serial, Integer channel, String starttime, String endtime) {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
if (channel == null) {
|
channel = 1;
|
}
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + playbackStart_URL, serial, channel, starttime, endtime);
|
System.out.println(completeUrl);
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
String flv = jsonBody.getString("FLV");
|
String snapURL = jsonBody.getString("SnapURL");
|
String streamID = jsonBody.getString("StreamID");
|
Map<String, Object> reMap = new HashMap<>();
|
reMap.put("flv", flv);
|
reMap.put("snapURL", deviceConfig.getBaseUrl() + snapURL);
|
reMap.put("streamID", streamID);
|
return reMap;
|
}
|
|
/**
|
* 回放流停止接口
|
*
|
* @param streamID
|
* @return
|
*/
|
public Map<String, Object> playbackStop(String streamID) {
|
String token = getJSession(0);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("token", token);
|
HttpEntity request = new HttpEntity(httpHeaders);
|
String completeUrl = String.format(deviceConfig.getBaseUrl() + playbackStop_URL, streamID);
|
System.out.println(completeUrl);
|
ResponseEntity<JSONObject> resultEntity = restTemplate.exchange(completeUrl, HttpMethod.GET, request, JSONObject.class, "");
|
|
if (resultEntity == null) {
|
throw new ServiceException("视频服务器连接失败");
|
}
|
JSONObject jsonBody = resultEntity.getBody();
|
//log.info("视频服务器:获取设备状态接口返回数据:{}", jsonBody);
|
String playbackFileURL = jsonBody.getString("PlaybackFileURL");
|
Map<String, Object> reMap = new HashMap<>();
|
reMap.put("playbackFileURL", playbackFileURL);
|
return reMap;
|
}
|
|
|
}
|
