package com.ld.igds.protocol.fzmedia;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.camera.CameraUtil;
|
import com.ld.igds.camera.data.ApiCameraData;
|
import com.ld.igds.camera.data.ApiCameraResp;
|
import com.ld.igds.camera.data.ApiSnapReq;
|
import com.ld.igds.data.ConfigData;
|
import com.ld.igds.protocol.snap.SnapPluginService;
|
import com.ld.igds.sec.dto.SecCameraDto;
|
import com.ld.igds.camera.ApiCameraService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 风正致远自有流媒体服务器
|
*/
|
@Slf4j
|
@Component
|
public class FzzyMediaService implements ApiCameraService {
|
|
private static String URL_PLAY = "http://ip:port/api/v1/remote/play";
|
|
public static String URL_PTZ = "http://ip:port/api/v1/remote/ptz";
|
|
// http://124.71.187.17:15080/rtp/
|
private static String URL_PLAY_FLV = "http://ip:15080/rtp/sn_channel.flv";
|
|
@Autowired
|
private SnapPluginService snapPluginService;
|
@Autowired
|
private FzzyProp prop;
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Override
|
public String getPlayType() {
|
return CameraUtil.PLAY_TYPE_FZZY_GB;
|
}
|
|
@Override
|
public ApiCameraResp getPlayAddr(ApiCameraData apiCameraDto) {
|
|
try {
|
String mediaIp = prop.getIp();
|
|
if (null == mediaIp) {
|
log.warn("-----------没有获取到多媒体服务地址-----");
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "没有获取到多媒体服务地址");
|
}
|
String sn = apiCameraDto.getSn();
|
String ipTag = apiCameraDto.getIp();
|
|
URL_PLAY = URL_PLAY.replace("ip", mediaIp).replace("port",
|
prop.getPort() + "");
|
|
String url = URL_PLAY + "?sn={sn}&channel={channel}&ip={ip}";
|
|
|
String channel = sn;
|
if (sn.indexOf("_") > 0) {
|
channel = sn.substring(sn.indexOf("_") + 1);
|
sn = sn.substring(0, sn.indexOf("_"));
|
}
|
|
log.info("-------获取多媒体播放信息---------URL-{}", url);
|
Map<String, String> map = new HashMap<>();
|
map.put("sn", sn);
|
map.put("channel", channel);
|
map.put("ip", ipTag);
|
|
ResponseEntity<JSONObject> responseEntity = restTemplate
|
.getForEntity(url, JSONObject.class, map);
|
|
JSONObject result = responseEntity.getBody();
|
|
// 自己封装
|
String flv = URL_PLAY_FLV;
|
flv = flv.replace("ip", mediaIp)
|
.replace("port", prop.getPort()+"")
|
.replace("sn", sn).replace("channel", channel);
|
result.put("flv", flv);
|
|
log.info("-------获取多媒体播放信息---------result-{}", result);
|
|
return new ApiCameraResp((String) result.get("code"),
|
(String) result.get("flv"), (String) result.get("msg"));
|
|
} catch (Exception e) {
|
log.debug("调用流媒体服务器异常：{}", e);
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR,
|
"调用流媒体服务器异常：请联系管理员查看原因");
|
}
|
}
|
|
/**
|
* 云台控制
|
* <p>
|
* 执行命令 1=上，2=下，3=左，4=右，5=左上，6=左下，7=右上，8=右下，0=停止，9=变倍小，10 = 变倍加
|
*
|
* @param dto
|
* @return
|
*/
|
@Override
|
public ApiCameraResp ptzMedia(ApiCameraData dto) {
|
|
if (StringUtils.isEmpty(dto.getSn()) && StringUtils.isEmpty(dto.getIp())) {
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "没有获取到当前摄像机IP/SN，不支持云台控制");
|
|
}
|
|
try {
|
String mediaIp = prop.getIp();
|
|
if (null == mediaIp) {
|
log.warn("-----------没有获取到多媒体服务地址-----");
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "没有获取到多媒体服务地址");
|
}
|
|
URL_PTZ = URL_PTZ.replace("ip", mediaIp).replace("port",
|
prop.getPort()+"");
|
|
String url = URL_PTZ + "?sn={sn}&channel={channel}&ip={ip}&command={command}";
|
|
log.debug("-------调用流媒体PTZ路径---------URL-{}", url);
|
|
// 命令进行转换 控制指令 允许值: left, right, up, down, upleft, upright,
|
// downleft, downright, zoomin, zoomout, stop
|
if ("1".equals(dto.getCommand())) {
|
dto.setCommand("up");
|
}
|
if ("2".equals(dto.getCommand())) {
|
dto.setCommand("down");
|
}
|
if ("3".equals(dto.getCommand())) {
|
dto.setCommand("left");
|
}
|
if ("4".equals(dto.getCommand())) {
|
dto.setCommand("right");
|
}
|
if ("5".equals(dto.getCommand())) {
|
dto.setCommand("upleft");
|
}
|
if ("6".equals(dto.getCommand())) {
|
dto.setCommand("downleft");
|
}
|
if ("7".equals(dto.getCommand())) {
|
dto.setCommand("upright");
|
}
|
if ("8".equals(dto.getCommand())) {
|
dto.setCommand("downright");
|
}
|
if ("9".equals(dto.getCommand())) {
|
dto.setCommand("zoomin");
|
}
|
if ("10".equals(dto.getCommand())) {
|
dto.setCommand("zoomout");
|
}
|
if ("0".equals(dto.getCommand())) {
|
dto.setCommand("stop");
|
}
|
|
String sn = dto.getSn();
|
String channel = sn;
|
if (sn.indexOf("_") > 0) {
|
channel = sn.substring(sn.indexOf("_") + 1);
|
sn = sn.substring(0, sn.indexOf("_"));
|
dto.setSn(sn);
|
dto.setChannel(channel);
|
}
|
|
Map<String, String> map = new HashMap<>();
|
map.put("sn", dto.getSn());
|
map.put("channel", dto.getChannel());
|
map.put("ip", dto.getIp());
|
map.put("command", dto.getCommand());
|
|
ResponseEntity<JSONObject> responseEntity = restTemplate
|
.getForEntity(url, JSONObject.class, map);
|
|
JSONObject result = responseEntity.getBody();
|
|
log.info("-------调用流媒体PTZ路径---执行-{}--result-{}", dto.getCommand(),
|
result);
|
return new ApiCameraResp((String) result.get("code"), (String) result.get("msg"));
|
|
} catch (Exception e) {
|
|
log.error("调用流媒体服务器异常：{}", e);
|
return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "调用流媒体服务器异常：请联系管理员查看原因");
|
}
|
}
|
|
@Override
|
public ApiCameraResp ptzPreset(ApiCameraData apiCameraDto) {
|
//TODO
|
return null;
|
}
|
|
@Override
|
public ApiCameraResp keepAlive(ApiCameraData apiCameraDto) {
|
//TODO
|
return null;
|
}
|
|
@Override
|
public List<SecCameraDto> searchCamera(ApiCameraData apiCameraDto) {
|
//TODO
|
return null;
|
}
|
|
@Override
|
public ApiCameraResp snapImg(ApiSnapReq apiCameraDto) {
|
|
if (CameraUtil.SNAP_TYPE_FZZY_PLUGIN.equals(apiCameraDto.getSnapType())) {
|
return snapPluginService.snapImg(apiCameraDto);
|
}
|
|
return null;
|
}
|
}
|
