package com.fzzy.igds.camera.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.igds.camera.AbstractApiCameraService;
|
import com.fzzy.igds.camera.data.*;
|
import com.fzzy.igds.camera.data.ydqly.YdQlyCamera;
|
import com.fzzy.igds.camera.data.ydqly.YdQlyDto;
|
import com.fzzy.igds.camera.data.ydqly.YdQlyNode;
|
import com.fzzy.igds.camera.data.ydqly.YdQlyResp;
|
import com.fzzy.igds.constant.CameraPlayType;
|
import com.fzzy.igds.constant.Constant;
|
import com.fzzy.igds.constant.RedisConst;
|
import com.fzzy.igds.domain.Camera;
|
import com.fzzy.igds.domain.CameraMedia;
|
import com.fzzy.igds.service.CameraMediaService;
|
import com.fzzy.igds.service.SecCameraService;
|
import com.fzzy.igds.utils.ContextUtil;
|
import com.fzzy.igds.utils.HttpUtils;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.common.utils.StringUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import org.apache.commons.codec.binary.Hex;
|
import org.apache.commons.codec.digest.DigestUtils;
|
import java.security.*;
|
import java.security.spec.PKCS8EncodedKeySpec;
|
|
/**
|
* @Desc 移动千里眼播放
|
* @Author CZT
|
* @Date 2026/01/04 16:09
|
*/
|
@Slf4j
|
@Component
|
public class ApiPlayYdQlyService extends AbstractApiCameraService {
|
|
/**
|
* 获取accessToken接口路径
|
*/
|
private static final String URL_ACCESS_TOKEN = "https://open.qly.cmviot.cn/v3/open/api/token";
|
private static final String URL_PLAY_LIVE = "https://open.qly.cmviot.cn/v3/open/api/websdk/live";
|
private static final String URL_CAMERA_LIST = "https://open.qly.cmviot.cn/v3/open/api/node/tree";
|
|
@Resource
|
private CameraMediaService cameraMediaService;
|
@Resource
|
private SecCameraService cameraService;
|
@Resource
|
private RedisCache redisCache;
|
|
@Override
|
public String getType() {
|
return CameraPlayType.PLAY_TYPE_YD_QLY.getCode();
|
}
|
|
@Override
|
public ApiCameraResp getPlayAddr(ApiCameraData apiCameraDto) {
|
|
if (StringUtils.isBlank(apiCameraDto.getCameraId())) {
|
log.error("获取摄像头信息失败，监控ID为空！");
|
return null;
|
}
|
|
if (StringUtils.isBlank(apiCameraDto.getDeptId())) {
|
log.error("获取摄像头信息失败，库区编码为空！");
|
return null;
|
}
|
|
//查询库区流媒体配置，获取库区节点
|
CameraMedia cameraMedia = cameraMediaService.getByDeptId(apiCameraDto.getDeptId(), apiCameraDto.getCompanyId());
|
if(null == cameraMedia || StringUtils.isBlank(cameraMedia.getYdStoreId())){
|
log.error("获取摄像头信息失败，库区节点未配置！");
|
return null;
|
}
|
|
//接口获取播放地址
|
YdQlyResp resp = getPlayUrl(cameraMedia, apiCameraDto.getCameraId());
|
|
if("11503".equals(resp.getResultCode()) || "11504".equals(resp.getResultCode())){
|
delAccessToken();
|
|
resp = getPlayUrl(cameraMedia, apiCameraDto.getCameraId());
|
}
|
|
if(!"000000".equals(resp.getResultCode())){
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, resp.getResultMsg());
|
}
|
YdQlyDto dto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);
|
if (null == dto || StringUtils.isBlank(dto.getUrl())) {
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "未获取到摄像头播放地址！");
|
}
|
|
return new ApiCameraResp(dto.getUrl());
|
}
|
|
@Override
|
public List<Camera> searchCamera(ApiCameraData apiCameraDto) {
|
|
if (StringUtils.isEmpty(apiCameraDto.getDeptId())) {
|
log.error("获取摄像头信息失败，库区编码为空！");
|
return null;
|
}
|
|
//查询库区流媒体配置，获取库区节点
|
CameraMedia cameraMedia = cameraMediaService.getByDeptId(apiCameraDto.getDeptId(), apiCameraDto.getCompanyId());
|
if(null == cameraMedia || StringUtils.isEmpty(cameraMedia.getYdStoreId())){
|
log.error("同步失败，库区节点未配置，请到库区配置->流媒体配置！");
|
return null;
|
}
|
|
//接口获取播放地址
|
YdQlyResp resp = getCameraList(cameraMedia);
|
|
if("11503".equals(resp.getResultCode()) || "11504".equals(resp.getResultCode())){
|
delAccessToken();
|
|
resp = getCameraList(cameraMedia);
|
}
|
|
if(!"000000".equals(resp.getResultCode())){
|
return null;
|
}
|
|
YdQlyDto ydQlyDto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);
|
|
if(null== ydQlyDto || null == ydQlyDto.getDevice()){
|
log.error("获取摄像头信息失败，库区节点未配置！");
|
return null;
|
}
|
|
//持久化
|
List<Camera> listCamera = new ArrayList<>();
|
Camera camera;
|
for (YdQlyCamera dto : ydQlyDto.getDevice()) {
|
camera = new Camera();
|
camera.setId(dto.getDeviceId());
|
camera.setCompanyId(cameraMedia.getCompanyId());
|
camera.setDeptId(cameraMedia.getDeptId());
|
camera.setSn(dto.getDeviceId());
|
camera.setName(dto.getDeviceName());
|
camera.setType("01");
|
camera.setOrderNum(null);
|
camera.setPlayType(CameraPlayType.PLAY_TYPE_YD_QLY.getCode());
|
cameraService.pullUpdateCamera(camera);
|
}
|
return listCamera;
|
}
|
|
/**
|
* 清除token
|
*/
|
private void delAccessToken() {
|
//请清除token
|
String key = RedisConst.buildKey(ContextUtil.getCompanyId(), Constant.KEY_ACCESS_TOKEN_YD_QLY);
|
redisCache.deleteObject(key);
|
}
|
|
/**
|
* 获取accessToken
|
*
|
* @param cameraMedia
|
* @return
|
*/
|
private String getAccessToken(CameraMedia cameraMedia) {
|
//默认先从缓存获取
|
String key = RedisConst.buildKey(ContextUtil.getCompanyId(), Constant.KEY_ACCESS_TOKEN_YD_QLY);
|
String accessToken = (String) redisCache.getCacheObject(key);
|
|
//若缓存获取为空，则通过接口请求获取
|
if (null == accessToken) {
|
String result = getAccessTokenApi(cameraMedia);
|
|
YdQlyDto dto = JSONObject.parseObject(result, YdQlyDto.class);
|
if (null == dto) {
|
return null;
|
}
|
accessToken = dto.getToken();
|
Integer expiresIn = dto.getExpires_in();
|
|
//将token存入缓存，默认7天
|
redisCache.setCacheObject(key, accessToken, 7*60*24, TimeUnit.MINUTES);
|
}
|
|
return accessToken;
|
}
|
|
/**
|
* 接口获取授权accessToken
|
* @param cameraMedia
|
* @return
|
*/
|
private String getAccessTokenApi(CameraMedia cameraMedia) {
|
try {
|
String timestamp = String.valueOf(System.currentTimeMillis());
|
String sig = Hex.encodeHexString(MessageDigest.getInstance("MD5").digest(StringUtils.getBytes(cameraMedia.getYdAppKey()+cameraMedia.getYdAppSecret(),"UTF-8")));
|
JSONObject requestBody = new JSONObject();
|
requestBody.put("operatorType", 1);
|
requestBody.put("sig", sig);
|
String requestBodyStr = requestBody.toString();
|
|
// 2. 计算请求体MD5
|
String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));
|
|
// 3. 构建签名字符串
|
LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();
|
herderParams.put("appid", cameraMedia.getYdAppKey());
|
herderParams.put("md5", md5);
|
herderParams.put("timestamp", timestamp);
|
herderParams.put("version", "1.0.0");
|
String jsonString = JSONObject.toJSONString(herderParams);
|
|
// 4. RSA签名
|
byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
|
PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
|
PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
|
|
Signature signature = Signature.getInstance("SHA1WithRSA");
|
signature.initSign(priKey);
|
signature.update(jsonString.getBytes("UTF-8"));
|
String signatureString = Base64.getEncoder().encodeToString(signature.sign());
|
|
herderParams.put("signature", signatureString);
|
herderParams.put("content-type", "application/json");
|
|
// 5. 发送请求
|
String response = HttpUtils.doPost(URL_ACCESS_TOKEN, herderParams, requestBodyStr);
|
|
YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);
|
if(!"000000".equals(ydQlyResp.getResultCode())){
|
return null;
|
}
|
return ydQlyResp.getData();
|
} catch (Exception e) {
|
log.error("-----获取身份认证异常-----，原因={}", e.toString());
|
return null;
|
}
|
}
|
|
/**
|
* 接口获取播放地址
|
* @param cameraMedia
|
* @param cameraId
|
* @return
|
*/
|
private YdQlyResp getPlayUrl(CameraMedia cameraMedia, String cameraId) {
|
try {
|
|
String timestamp = String.valueOf(System.currentTimeMillis());
|
|
JSONObject requestBody = new JSONObject();
|
requestBody.put("deviceId", cameraId);
|
|
String requestBodyStr = requestBody.toString();
|
|
// 2. 计算请求体MD5
|
String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));
|
|
// 3. 构建签名字符串
|
LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();
|
|
herderParams.put("appid", cameraMedia.getYdAppKey());
|
herderParams.put("md5", md5);
|
herderParams.put("timestamp", timestamp);
|
herderParams.put("token", getAccessToken(cameraMedia));
|
herderParams.put("version", "1.0.0");
|
String jsonString = JSONObject.toJSONString(herderParams);
|
|
// 4. RSA签名
|
byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
|
PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
|
PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
|
|
Signature signature = Signature.getInstance("SHA1WithRSA");
|
signature.initSign(priKey);
|
signature.update(jsonString.getBytes("UTF-8"));
|
String signatureString = Base64.getEncoder().encodeToString(signature.sign());
|
|
herderParams.put("signature", signatureString);
|
herderParams.put("content-type", "application/json");
|
|
// 5. 发送请求
|
String response = HttpUtils.doPost(URL_PLAY_LIVE, herderParams, requestBodyStr);
|
|
YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);
|
|
return ydQlyResp;
|
} catch (Exception e) {
|
return null;
|
}
|
}
|
|
/**
|
* 接口获取播放地址
|
* @param cameraMedia
|
* @return
|
*/
|
private YdQlyResp getCameraList(CameraMedia cameraMedia) {
|
try {
|
|
String timestamp = String.valueOf(System.currentTimeMillis());
|
|
JSONObject requestBody = new JSONObject();
|
requestBody.put("queryType", 0);
|
requestBody.put("page", 1);
|
requestBody.put("pageSize", 100);
|
requestBody.put("nodeId", cameraMedia.getYdStoreId());
|
|
String requestBodyStr = requestBody.toString();
|
|
// 2. 计算请求体MD5
|
String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));
|
|
// 3. 构建签名字符串
|
LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();
|
|
herderParams.put("appid", cameraMedia.getYdAppKey());
|
herderParams.put("md5", md5);
|
herderParams.put("timestamp", timestamp);
|
herderParams.put("token", getAccessToken(cameraMedia));
|
herderParams.put("version", "1.0.0");
|
String jsonString = JSONObject.toJSONString(herderParams);
|
|
// 4. RSA签名
|
byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
|
PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
|
PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
|
|
Signature signature = Signature.getInstance("SHA1WithRSA");
|
signature.initSign(priKey);
|
signature.update(jsonString.getBytes("UTF-8"));
|
String signatureString = Base64.getEncoder().encodeToString(signature.sign());
|
|
herderParams.put("signature", signatureString);
|
herderParams.put("content-type", "application/json");
|
|
// 5. 发送请求
|
String response = HttpUtils.doPost(URL_CAMERA_LIST, herderParams, requestBodyStr);
|
|
YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);
|
return ydQlyResp;
|
} catch (Exception e) {
|
return null;
|
}
|
}
|
|
/**
|
* 获取监控所在节点编码
|
* @param cameraMedia
|
* @return
|
*/
|
public List<YdQlyNode> getNodeId(CameraMedia cameraMedia) {
|
try {
|
|
String timestamp = String.valueOf(System.currentTimeMillis());
|
|
JSONObject requestBody = new JSONObject();
|
requestBody.put("queryType", 0);
|
if(StringUtils.isNotBlank(cameraMedia.getYdStoreId())){
|
requestBody.put("nodeId", cameraMedia.getYdStoreId());
|
}
|
|
String requestBodyStr = requestBody.toString();
|
|
// 2. 计算请求体MD5
|
String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));
|
|
// 3. 构建签名字符串
|
LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();
|
|
herderParams.put("appid", cameraMedia.getYdAppKey());
|
herderParams.put("md5", md5);
|
herderParams.put("timestamp", timestamp);
|
herderParams.put("token", getAccessToken(cameraMedia));
|
herderParams.put("version", "1.0.0");
|
String jsonString = JSONObject.toJSONString(herderParams);
|
|
// 4. RSA签名
|
byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
|
PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
|
PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
|
|
Signature signature = Signature.getInstance("SHA1WithRSA");
|
signature.initSign(priKey);
|
signature.update(jsonString.getBytes("UTF-8"));
|
String signatureString = Base64.getEncoder().encodeToString(signature.sign());
|
|
herderParams.put("signature", signatureString);
|
herderParams.put("content-type", "application/json");
|
|
// 5. 发送请求
|
String response = HttpUtils.doPost(URL_CAMERA_LIST, herderParams, requestBodyStr);
|
|
YdQlyResp resp = JSONObject.parseObject(response, YdQlyResp.class);
|
|
if(!"000000".equals(resp.getResultCode())){
|
return null;
|
}
|
|
YdQlyDto ydQlyDto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);
|
if(null == ydQlyDto || null == ydQlyDto.getNode() || ydQlyDto.getNode().isEmpty()){
|
return null;
|
}
|
return ydQlyDto.getNode();
|
} catch (Exception e) {
|
return null;
|
}
|
}
|
|
/**
|
* 获取所有节点
|
* @param cameraMedia
|
*/
|
public void getAllNodeId(CameraMedia cameraMedia) {
|
|
List<YdQlyNode> nodeList = this.getNodeId(cameraMedia);
|
if(null != nodeList && !nodeList.isEmpty()){
|
for (YdQlyNode node : nodeList) {
|
if(node.getHasChild() == 1){
|
cameraMedia.setYdStoreId(node.getNodeId());
|
this.getAllNodeId(cameraMedia);
|
}else {
|
ContextUtil.nodeList.add(node);
|
}
|
}
|
}
|
}
|
}
|
