package com.ruoyi.utils.sdk.dhsdk.service.impl;
|
|
import com.ruoyi.alarm.global.domain.GuidePriorityQueue;
|
import com.ruoyi.alarm.global.domain.GuideTask;
|
import com.ruoyi.alarm.global.service.impl.QueueHandler;
|
import com.ruoyi.common.annotation.SdkOperate;
|
import com.ruoyi.common.config.ARDConfig;
|
import com.ruoyi.common.constant.Constants;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.file.FileUtils;
|
import com.ruoyi.common.utils.file.MimeTypeUtils;
|
import com.ruoyi.common.utils.spring.SpringUtils;
|
import com.ruoyi.common.utils.uuid.IdUtils;
|
import com.ruoyi.device.camera.factory.CameraSDK;
|
import com.ruoyi.device.camera.domain.ArdCameras;
|
import com.ruoyi.device.camera.domain.CameraCmd;
|
import com.ruoyi.device.camera.service.IArdCamerasService;
|
import com.ruoyi.device.camera.service.ICameraSdkService;
|
import com.ruoyi.device.channel.domain.ArdChannel;
|
import com.ruoyi.device.channel.service.IArdChannelService;
|
import com.ruoyi.media.domain.Vtdu;
|
import com.ruoyi.media.service.IVtduService;
|
import com.ruoyi.utils.gis.GisUtil;
|
import com.ruoyi.utils.minio.MinioUtil;
|
import com.ruoyi.utils.sdk.common.GlobalVariable;
|
import com.ruoyi.utils.sdk.common.SdkErrorCodeEnum;
|
import com.ruoyi.utils.sdk.dhsdk.common.ErrorCode;
|
import com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib;
|
import com.ruoyi.utils.sdk.dhsdk.lib.ToolKits;
|
import com.ruoyi.utils.sdk.dhsdk.lib.enumeration.EM_NEW_CONFIG;
|
import com.ruoyi.utils.sdk.dhsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
|
import com.ruoyi.utils.sdk.dhsdk.lib.structure.CFG_INFRARED_INFO;
|
import com.ruoyi.utils.sdk.dhsdk.lib.structure.CFG_VIDEO_IN_FOCUS;
|
import com.ruoyi.utils.sdk.dhsdk.lib.structure.DH_OUT_PTZ_VIEW_RANGE_STATUS;
|
import com.ruoyi.utils.sdk.dhsdk.module.*;
|
import com.sun.jna.Native;
|
import com.sun.jna.Pointer;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.*;
|
import java.nio.ByteBuffer;
|
import java.nio.file.Files;
|
import java.nio.file.Paths;
|
import java.text.DecimalFormat;
|
import java.util.*;
|
import java.util.concurrent.PriorityBlockingQueue;
|
|
import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.*;
|
import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_DEVSTATE_PTZ_VIEW_RANGE;
|
import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_MOVE_CONTROL;
|
import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_SET_CONTROL;
|
import static com.ruoyi.utils.sdk.dhsdk.lib.ToolKits.getErrorCodePrint;
|
import static com.ruoyi.utils.sdk.dhsdk.module.LoginModule.netsdk;
|
|
/**
|
* @Description: 大华sdk策略
|
* @ClassName: DhSdkStrategy
|
* @Author: 刘苏义
|
* @Date: 2023年11月07日10:51:09
|
**/
|
@Slf4j(topic = "dhSdk")
|
@Service
|
public class DahuaSDK implements CameraSDK {
|
|
@Resource
|
private IArdCamerasService ardCamerasService;
|
@Resource
|
private IArdChannelService ardChannelService;
|
@Resource
|
private IVtduService vtduService;
|
|
@Resource
|
ICameraSdkService cameraSdkService;
|
@Value("${minio.endpoint}")
|
private String minioEndPoint;
|
@Resource
|
private QueueHandler queueHandler;
|
|
// 设备断线通知回调
|
private static DisConnect disConnect = new DisConnect();
|
// 网络连接恢复
|
private static HaveReConnect haveReConnect = new HaveReConnect();
|
|
|
/**
|
* 登录
|
* 刘苏义
|
* 2023/10/17 8:28:13
|
*
|
* @return
|
*/
|
@Override
|
public AjaxResult login(ArdCameras camera) {
|
try {
|
LoginModule.init(disConnect, haveReConnect);
|
NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
NetSDKLib.LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword(), m_stDeviceInfo);
|
if (loginId.longValue() <= 0) {
|
camera.setChanNum(0);
|
camera.setLoginId(-1);
|
camera.setState("0");
|
ardCamerasService.updateArdCameras(camera);
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
log.error("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败:" + getErrorCodePrint());
|
return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
|
}
|
|
camera.setState("1");
|
camera.setChanNum(m_stDeviceInfo.byChanNum);
|
camera.setStartDChan(1);
|
camera.setLoginId((int) loginId.longValue());
|
GlobalVariable.loginMap.put(camera.getId(), loginId);
|
//获取最新通道
|
List<ArdChannel> ardChannelList = getChannels(camera);
|
if (ardChannelList.size() > 0) {
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
ardChannelList.stream().forEach(channel -> {
|
ardChannelService.insertArdChannel(channel);
|
});
|
camera.setChanNum(ardChannelList.size());
|
camera.setChannelList(ardChannelList);
|
ardCamerasService.updateArdCameras(camera);
|
//配置到流媒体
|
addVtdu(camera);
|
}
|
//创建引导队列
|
createGuideQueue(camera);
|
return AjaxResult.success("设备登录成功");
|
} catch (Exception ex) {
|
log.error("设备登录异常:" + ex.getMessage());
|
return AjaxResult.error("设备登录异常:" + ex.getMessage());
|
}
|
}
|
|
@Override
|
@Async("loginExecutor")
|
public AjaxResult asyncLogin(ArdCameras camera) {
|
try {
|
LoginModule.init(disConnect, haveReConnect);
|
NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
NetSDKLib.LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword(), m_stDeviceInfo);
|
if (loginId.longValue() <= 0) {
|
camera.setChanNum(0);
|
camera.setLoginId(-1);
|
camera.setState("0");
|
ardCamerasService.updateArdCameras(camera);
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
log.error("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败:" + getErrorCodePrint());
|
return AjaxResult.warn(getErrorCodePrint());
|
}
|
camera.setState("1");
|
camera.setChanNum(m_stDeviceInfo.byChanNum);
|
camera.setStartDChan(1);
|
camera.setLoginId((int) loginId.longValue());
|
ardCamerasService.updateArdCameras(camera);
|
GlobalVariable.loginMap.put(camera.getId(), loginId);
|
|
//获取最新通道
|
List<ArdChannel> ardChannelList = getChannels(camera);
|
if (ardChannelList.size() > 0) {
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
ardChannelList.stream().forEach(channel -> {
|
ardChannelService.insertArdChannel(channel);
|
});
|
camera.setChanNum(ardChannelList.size());
|
camera.setChannelList(ardChannelList);
|
ardCamerasService.updateArdCameras(camera);
|
//配置到流媒体
|
addVtdu(camera);
|
}
|
//创建引导队列
|
createGuideQueue(camera);
|
return AjaxResult.success("登录成功");
|
} catch (Exception ex) {
|
log.error("登录异常:" + ex.getMessage());
|
return AjaxResult.error("登录异常:" + ex.getMessage());
|
}
|
}
|
|
//添加到流媒体
|
private void addVtdu(ArdCameras camera) {
|
camera.getChannelList().stream().forEach(channel -> {
|
String name = camera.getId() + "_" + channel.getChanNo();
|
String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/cam/realmonitor?channel=" + channel.getChanNo() + "&subtype=0";
|
//删除流媒体
|
if (vtduService.selectVtduByName(name) != null) {
|
vtduService.deleteVtduByName(name);
|
}
|
//添加到流媒体
|
CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo());
|
Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);
|
Vtdu vtdu = new Vtdu();
|
if (videoCompressionCfg.get("videoEncType") != null) {
|
if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {
|
vtdu.setIsCode("0");//默认不转码
|
} else {
|
vtdu.setIsCode("1");//默认转码
|
}
|
} else {
|
vtdu.setIsCode("0");//默认不转码
|
}
|
vtdu.setRtspSource(rtspSource);
|
vtdu.setName(name);
|
vtdu.setMode("1");//默认CPU软解码
|
vtdu.setCameraId(camera.getId());
|
vtduService.insertVtdu(vtdu);
|
});
|
}
|
|
//创建引导队列
|
private void createGuideQueue(ArdCameras camera) {
|
if (camera.getGdtype().equals("1")) {
|
if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
|
Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
|
PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
|
GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
|
//启动队列处理器
|
queueHandler.process(camera.getId());
|
}
|
}
|
}
|
|
//获取通道
|
public List<ArdChannel> getChannels(ArdCameras camera) {
|
LLong loginId = new LLong(camera.getLoginId());
|
List<ArdChannel> ardChannelList = new ArrayList<>();
|
for (int i = 1; i < camera.getChanNum() + 1; i++) {
|
ArdChannel channel = new ArdChannel();
|
String chanName = ConfigModule.getChannelName(loginId, i - 1).trim();
|
log.debug("获取通道名称：" + chanName);
|
channel.setName(chanName.equals("") ? "通道" + i : chanName);
|
channel.setDeviceId(camera.getId());
|
channel.setChanNo(i);
|
if (camera.getGdtype().equals("2")) {
|
//NVR过滤不在线的通道
|
if (!ConfigModule.queryCameraState(loginId, camera.getChanNum(), i)) {
|
continue;
|
}
|
}
|
ardChannelList.add(channel);
|
}
|
return ardChannelList;
|
}
|
|
/**
|
* 注销
|
* 刘苏义
|
* 2023/10/17 8:28:13
|
*
|
* @return
|
*/
|
@Override
|
public boolean logout(String cameraId) {
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
|
return LoginModule.logout(loginId);
|
}
|
|
/**
|
* 是否在线检测
|
* 刘苏义
|
* 2023/10/17 8:28:13
|
*/
|
@Override
|
public boolean isOnLine(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
|
NetSDKLib.NET_WORKSTATE dh_ptz_location_info = new NetSDKLib.NET_WORKSTATE();
|
boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_ONLINE, dh_ptz_location_info);
|
if (!b) {
|
return false;
|
}
|
} catch (Exception ex) {
|
log.error("检测在线异常：" + ex.getMessage());
|
return false;
|
}
|
return true;
|
}
|
|
|
/**
|
* 云台控制
|
* 刘苏义
|
* 2023/10/17 8:28:13
|
*/
|
@Override
|
@SdkOperate
|
public AjaxResult pTZControl(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer chanNo = cmd.getChanNo();
|
Integer speed = cmd.getSpeed();
|
Integer code = cmd.getCode();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
|
int dwStop;
|
if (enable) {
|
dwStop = 0;//开启
|
} else {
|
dwStop = 1;//关闭
|
}
|
int dwPTZCommand = -1;
|
switch (code) {
|
/*方向*/
|
case 1:
|
dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTTOP;
|
break;
|
case 2:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_UP_CONTROL;
|
break;
|
case 3:
|
dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTTOP;
|
break;
|
case 4:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LEFT_CONTROL;
|
break;
|
case 5:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_LOOP_CONTROL;
|
break;
|
case 6:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_RIGHT_CONTROL;
|
break;
|
case 7:
|
dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTDOWN;
|
break;
|
case 8:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_DOWN_CONTROL;
|
break;
|
case 9:
|
dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTDOWN;
|
break;
|
/*焦距*/
|
case 10:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_ADD_CONTROL;
|
break;
|
case 11:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_DEC_CONTROL;
|
break;
|
/*焦点*/
|
case 12:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_ADD_CONTROL;
|
break;
|
case 13:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_DEC_CONTROL;
|
break;
|
/*光圈*/
|
case 14:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_ADD_CONTROL;
|
break;
|
case 15:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_DEC_CONTROL;
|
break;
|
case 16:
|
dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LAMP_CONTROL;
|
break;
|
}
|
boolean bool = PtzControlModule.ptzControl(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);
|
if (!bool) {
|
log.error("控制失败,请稍后重试" + getErrorCodePrint());
|
return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
|
}
|
return AjaxResult.success("云台控制成功");
|
}
|
|
/**
|
* 获取PTZ值
|
* 刘苏义
|
* 2023/10/17 8:28:13
|
*/
|
@Override
|
public AjaxResult getPtz(CameraCmd cmd) {
|
Map<String, Object> ptzMap = new HashMap<>();
|
String cameraId = cmd.getCameraId();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
|
NetSDKLib.NET_PTZ_LOCATION_INFO dh_ptz_location_info = new NetSDKLib.NET_PTZ_LOCATION_INFO();
|
boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, dh_ptz_location_info);
|
if (!b) {
|
int code = netsdk.CLIENT_GetLastError();
|
log.error("设置ptz失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
|
}
|
DecimalFormat df = new DecimalFormat("0.0");//设置保留位数
|
String nPTZPan = df.format((float) dh_ptz_location_info.nPTZPan / 10);
|
float t = (float) dh_ptz_location_info.nPTZTilt / 10 * -1;
|
String nPTZTilt = df.format(t < 0 ? t + 360 : t);
|
String nPTZZoom = df.format((float) dh_ptz_location_info.nPTZZoom);
|
ptzMap.put("p", nPTZPan);
|
ptzMap.put("t", nPTZTilt);
|
ptzMap.put("z", nPTZZoom);
|
return AjaxResult.success(ptzMap);
|
}
|
|
@Override
|
public AjaxResult getPtzHigh(CameraCmd cmd) {
|
return getPtz(cmd);
|
}
|
|
@Override
|
public AjaxResult getPtzScope(CameraCmd cmd) {
|
return AjaxResult.success("未实现该功能");
|
}
|
|
@Override
|
public AjaxResult setPtzHigh(CameraCmd cmd) {
|
return setPtz(cmd);
|
}
|
|
/**
|
* @描述 设置ptz信息
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置
|
*/
|
@Override
|
@SdkOperate
|
public AjaxResult setPtz(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
Map<String, Double> ptz = cmd.getPtzMap();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
if (ptz.get("p") == null || ptz.get("t") == null || ptz.get("z") == null) {
|
return AjaxResult.warn("ptz参数不能为空");
|
}
|
int p = (int) (ptz.get("p") * 10);
|
int t = (int) (ptz.get("t") * 10);
|
t = t > 900 ? 3600 - t : t * -1;
|
|
int z = ptz.get("z").intValue() == 0 ? 1 : ptz.get("z").intValue();
|
boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_EXACTGOTO, p, t, z, 0);
|
if (!bool) {
|
log.error("设置ptz失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("设置ptz成功");
|
} catch (Exception ex) {
|
log.error("设置ptz异常:" + ex.getMessage());
|
return AjaxResult.error("设置ptz异常:" + ex.getMessage());
|
}
|
}
|
|
/**
|
* @描述 设置零方位角
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置
|
*/
|
@Override
|
@SdkOperate
|
public AjaxResult setZeroPtz(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
boolean bool = NetSDKLib.NETSDK_INSTANCE.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RESETZERO, 0, 0, 0, 0);
|
if (!bool) {
|
log.error("设置零方位角失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("设置零方位角成功");
|
}
|
|
/**
|
* @描述 截图 存服务器
|
* @参数 [cameraId, channelNum]
|
* @返回值 java.lang.String
|
* @创建人 刘苏义
|
* @创建时间 2023/2/2 14:59
|
* @修改人和其它信息
|
*/
|
@Override
|
public String picCutCate(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
String bucketName = "pic";
|
String picUrl = "";
|
String bucketObject = "/capture/" + IdUtils.simpleUUID() + ".jpeg";
|
fCaptureReceiveCB m_CaptureReceiveCB = new fCaptureReceiveCB(minioEndPoint, bucketName, bucketObject);
|
CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);
|
boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);
|
if (b) {
|
picUrl = minioEndPoint + "/" + bucketName + bucketObject;
|
}
|
return picUrl;
|
|
}
|
|
@Override
|
public AjaxResult localCapture(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String imagePath = FileUtils.createFile(tempPath + "/" + cameraId + ".jpeg");
|
fCaptureReceiveCB1 m_CaptureReceiveCB = new fCaptureReceiveCB1(imagePath);
|
CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);
|
boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);
|
if (!b) {
|
return AjaxResult.warn("本地抓图失败");
|
}
|
Thread.sleep(200);
|
byte[] imageBytes = Files.readAllBytes(Paths.get(imagePath));
|
//OutputStream outputStream = response.getOutputStream();
|
//outputStream.write(imageBytes);
|
// 创建ByteBuffer并将字节数组写入其中
|
//ByteBuffer jpegBuffer = ByteBuffer.wrap(imageBytes);
|
//Base64.Encoder decoder = Base64.getEncoder();
|
//String png_base64 = decoder.encodeToString(jpegBuffer.array());//转换成base64串
|
return AjaxResult.success(imageBytes);
|
} catch (Exception ex) {
|
return AjaxResult.error("本地抓图异常:" + ex);
|
}
|
}
|
|
//本地录像开始
|
@Override
|
public AjaxResult localRecordStart(CameraCmd cmd) {
|
try {
|
String operator = cmd.getOperator();
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
//if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
// lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
|
// RealPlayModule.stopRealPlay(lRealHandle);
|
// GlobalVariable.previewMap.remove(cameraId);
|
// log.debug("停止当前录像");
|
//}
|
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String path = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
|
LLong lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
|
if (lRealHandle.longValue() <= 0) {
|
log.error("取流失败" + getErrorCodePrint());
|
}
|
log.debug("本地录像开始取流成功");
|
//GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
|
//GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());
|
//if (!netsdk.CLIENT_SaveRealData(lRealHandle, path)) {
|
// log.error("保存视频文件到临时文件夹失败 错误码为: " +getErrorCodePrint());
|
// return false;
|
//}
|
log.debug("本地录像开始");
|
return AjaxResult.success("本地录像开始", lRealHandle);
|
} catch (Exception ex) {
|
log.error("本地录像开始异常" + ex.getMessage());
|
return AjaxResult.error("本地录像开始异常" + ex.getMessage());
|
}
|
}
|
|
//本地录像停止
|
@Override
|
public AjaxResult localRecordStop(CameraCmd cmd) {
|
try {
|
String operator = cmd.getOperator();
|
String cameraId = cmd.getCameraId();
|
LLong lRealHandle = new LLong(cmd.getRecordId());
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
RealPlayModule.stopRealPlay(lRealHandle);
|
log.debug("本地录像停止");
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String recordPath = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
|
byte[] imageBytes = Files.readAllBytes(Paths.get(recordPath));
|
return AjaxResult.success(imageBytes);
|
} catch (Exception ex) {
|
log.error("本地录像停止异常" + ex.getMessage());
|
return AjaxResult.error("本地录像停止异常" + ex.getMessage());
|
}
|
}
|
|
/**
|
* @描述 短时录像
|
* @参数 [userId, channelNum, enable]
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/1/20 11:18
|
* @修改人和其它信息
|
*/
|
@Override
|
public String record(CameraCmd cmd) {
|
try {
|
String url = "";
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
|
boolean enable = cmd.isEnable();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
|
if (enable) {
|
LLong lRealHandle = new LLong(0);
|
if (!GlobalVariable.previewMap.containsKey(cameraId)) {
|
lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
|
if (lRealHandle.longValue() <= 0) {
|
log.error("取流失败" + getErrorCodePrint());
|
return "";
|
}
|
log.debug("取流成功");
|
GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
|
}
|
log.debug("录像开始");
|
} else {
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
LLong lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
|
RealPlayModule.stopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
}
|
log.debug("录像停止");
|
}
|
return url;
|
} catch (Exception ex) {
|
log.error("录像异常" + ex.getMessage());
|
return "";
|
}
|
}
|
|
@Override
|
public boolean recordStart(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
LLong lRealHandle;
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
|
RealPlayModule.stopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
log.debug("停止当前录像");
|
}
|
lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
|
if (lRealHandle.longValue() <= 0) {
|
log.error("取流失败" + getErrorCodePrint());
|
}
|
log.debug("取流成功");
|
GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
|
GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());
|
//if (!netsdk.CLIENT_SaveRealData(lRealHandle, path)) {
|
// log.error("保存视频文件到临时文件夹失败 错误码为: " +getErrorCodePrint());
|
// return false;
|
//}
|
log.debug("录像开始");
|
return true;
|
} catch (Exception ex) {
|
log.error("开始录像异常" + ex.getMessage());
|
return false;
|
}
|
}
|
|
@Override
|
public String recordStopToMinio(CameraCmd cmd) {
|
String url = "";
|
try {
|
String cameraId = cmd.getCameraId();
|
// 本地临时录像地址
|
String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
|
String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
LLong lRealHandle;
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
|
RealPlayModule.stopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
log.debug("停止当前录像");
|
}
|
//存入minio
|
String BucketName = cmd.getRecordBucketName();
|
String ObjectName = cmd.getRecordObjectName() + ".mp4";
|
FileInputStream stream = new FileInputStream(path);
|
boolean b = MinioUtil.uploadObject(BucketName, ObjectName, stream, stream.available(), "video/MP4");
|
if (b) {
|
url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName);
|
log.debug("上传文件成功!" + url);
|
}
|
return url;
|
} catch (Exception ex) {
|
log.error("录像异常" + ex.getMessage());
|
return "";
|
}
|
}
|
|
@Override
|
public boolean recordStopNotToMinio(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
LLong lRealHandle;
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
|
RealPlayModule.stopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
log.debug("停止当前录像");
|
}
|
|
result = true;
|
} catch (Exception ex) {
|
log.error("录像异常" + ex.getMessage());
|
}
|
return result;
|
}
|
|
|
/**
|
* 引导目标位置
|
* 刘苏义
|
* 2023/10/17 8:27:48
|
*/
|
@Override
|
public AjaxResult guideTargetPosition(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
ArdCameras cameras = ardCamerasService.selectArdCamerasById(cameraId);
|
double[] cameraPositon = new double[]{cameras.getLongitude(), cameras.getLatitude(), cameras.getAltitude()};
|
double[] targetPositions = cmd.getTargetPosition();
|
double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150);
|
//修正俯仰
|
double correctPitch = cameraSdkService.correctPitch(cmd);
|
double newt = cameraPTZ[1] + correctPitch;
|
int p = (int) (cameraPTZ[0] * 10);
|
int t = (int) (newt * 10);
|
int z = (int) (cameraPTZ[2]);
|
boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_EXACTGOTO, p, t, z, 0);
|
if (!bool) {
|
log.error("设置ptz失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("引导目标位置成功", correctPitch);
|
} catch (Exception ex) {
|
log.error("引导目标位置异常:" + ex.getMessage());
|
return AjaxResult.error("引导目标位置异常:" + ex.getMessage());
|
}
|
}
|
|
//转至预置点
|
@Override
|
public AjaxResult gotoPreset(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
Integer PresetIndex = cmd.getPresetIndex();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NET_PTZ_POINT_MOVE_CONTROL, 0, PresetIndex, 0, 0);
|
if (!bool) {
|
log.error("转至预置点失败:" + getErrorCodePrint());
|
return AjaxResult.warn("转至预置点失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("转至预置点成功");
|
} catch (Exception ex) {
|
log.error("转至预置点异常:" + ex.getMessage());
|
return AjaxResult.error("转至预置点异常:" + ex.getMessage());
|
}
|
}
|
|
@Override
|
//设置预置位
|
public AjaxResult setPreset(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
Integer PresetIndex = cmd.getPresetIndex();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NET_PTZ_POINT_SET_CONTROL, 0, PresetIndex, 0, 0);
|
if (!bool) {
|
log.error("设置预置点失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置预置点失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("设置预置点成功");
|
} catch (Exception ex) {
|
log.error("设置预置点异常:" + ex.getMessage());
|
return AjaxResult.error("设置预置点异常:" + ex.getMessage());
|
}
|
}
|
|
//切换聚焦模式
|
@Override
|
public AjaxResult controlFocusMode(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
boolean enable = cmd.isEnable();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
CFG_VIDEO_IN_FOCUS cfg_video_in_focus = new CFG_VIDEO_IN_FOCUS();
|
cfg_video_in_focus.nVideoInFocusRealNum = 3;//配置使用个数
|
for (int i = 0; i < 3; i++) {
|
cfg_video_in_focus.stVideoInFocusUnit[i].nSensitivity = 1;//聚焦灵敏度, 0-高, 1-默认, 2-低
|
|
cfg_video_in_focus.stVideoInFocusUnit[i].nIRCorrection = 2;//红外光聚焦修正, 0-不修正, 1-修正, 2-自动修正
|
cfg_video_in_focus.stVideoInFocusUnit[i].nFocusLimit = 10000;//聚焦极限值, 单位毫米
|
if (enable) {//聚焦模式, 0-关闭, 1-辅助聚焦, 2-自动聚焦, 3-半自动聚焦, 4-手动聚焦
|
cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 4;//手动聚焦
|
cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 0;//聚焦极限Manual
|
log.debug("当前为手动聚焦模式");
|
} else {
|
cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 2;//自动聚焦
|
cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 1;//聚焦极限Auto
|
log.debug("当前为自动聚焦模式");
|
}
|
}
|
cfg_video_in_focus.nChannelIndex = chanNo - 1;
|
boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, NetSDKLib.CFG_CMD_VIDEOIN_FOCUS, cfg_video_in_focus);
|
if (!bool) {
|
log.error("切换聚焦模式失败:" + getErrorCodePrint());
|
return AjaxResult.warn("切换聚焦模式失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("切换聚焦模式成功");
|
} catch (Exception ex) {
|
log.error("切换聚焦模式异常:" + ex.getMessage());
|
return AjaxResult.error("切换聚焦模式异常:" + ex.getMessage());
|
}
|
}
|
|
//获取聚焦模式
|
@Override
|
public AjaxResult getFocusMode(CameraCmd cmd) {
|
String mode = "";
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
NET_VIDEOIN_FOCUSMODE_INFO focusModeInfo = new NET_VIDEOIN_FOCUSMODE_INFO();
|
int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VIDEOIN_FOCUSMODE;
|
boolean bool = ConfigModule.GetConfig(loginId, chanNo - 1, emCfgOpType, focusModeInfo);
|
if (!bool) {
|
log.error("获取聚焦模式失败:" + getErrorCodePrint());
|
return AjaxResult.warn("获取聚焦模式失败:" + getErrorCodePrint());
|
}
|
//System.out.println("配置类型:" + focusModeInfo.emCfgType); // 具体信息，参考库里的枚举
|
//System.out.println("聚焦模式:" + focusModeInfo.emFocusMode);
|
switch (focusModeInfo.emFocusMode) {
|
case 0:
|
mode = "关闭";
|
break;
|
case 1:
|
mode = "辅助聚焦";
|
break;
|
case 2:
|
mode = "自动聚焦";
|
break;
|
case 3:
|
mode = "半自动聚焦";
|
break;
|
case 4:
|
mode = "手动聚焦";
|
break;
|
}
|
return AjaxResult.success(mode);
|
} catch (Exception ex) {
|
log.error("获取聚焦模式异常:" + ex.getMessage());
|
return AjaxResult.error("获取聚焦模式异常:" + ex.getMessage());
|
}
|
}
|
|
@Override
|
public AjaxResult controlPTHeateRpwron(CameraCmd cmd) {
|
return AjaxResult.success("该功能未实现");
|
}
|
|
@Override
|
public AjaxResult controlCameraDeicing(CameraCmd cmd) {
|
return AjaxResult.success("该功能未实现");
|
}
|
|
@Override
|
public AjaxResult getPTZLockInfo(CameraCmd cmd) {
|
return AjaxResult.success("该功能未实现");
|
}
|
|
|
//切换透雾
|
@Override
|
public AjaxResult controlDefogcfg(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
boolean enable = cmd.isEnable();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
String command = EM_NEW_CONFIG.CFG_CMD_VIDEOINDEFOG.getValue();
|
NET_VIDEOIN_DEFOG_INFO netVideoinDefogInfo = new NET_VIDEOIN_DEFOG_INFO();
|
boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, command, netVideoinDefogInfo);
|
if (!bool) {
|
log.error("切换透雾失败:" + getErrorCodePrint());
|
return AjaxResult.warn("切换透雾失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("切换透雾成功");
|
} catch (Exception ex) {
|
return AjaxResult.error("切换透雾异常:" + ex.getMessage());
|
}
|
}
|
|
//切换红外
|
@Override
|
public AjaxResult controlInfrarecfg(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
CFG_INFRARED_INFO cfg_infrared_info = new CFG_INFRARED_INFO();
|
boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_INFRARED_CONFIG, cfg_infrared_info);
|
if (!bool) {
|
log.error("切换红外失败:" + getErrorCodePrint());
|
return AjaxResult.warn("切换红外失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("切换红外成功");
|
} catch (Exception ex) {
|
return AjaxResult.error("切换红外异常:" + getErrorCodePrint());
|
}
|
}
|
|
//获取聚焦值
|
@Override
|
public AjaxResult getFocusPos(CameraCmd cmd) {
|
int result = 0;
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
NET_PTZ_LOCATION_INFO net_ptz_location_info = new NET_PTZ_LOCATION_INFO();
|
net_ptz_location_info.nChannelID = chanNo - 1;
|
boolean bool = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, net_ptz_location_info);
|
if (!bool) {
|
log.error("获取聚焦值失败:" + getErrorCodePrint());
|
return AjaxResult.warn("获取聚焦值失败:" + getErrorCodePrint());
|
}
|
result = net_ptz_location_info.nFocusMapValue;
|
return AjaxResult.success(result);
|
} catch (Exception ex) {
|
log.error("获取聚焦值异常:" + ex.getMessage());
|
return AjaxResult.error("获取聚焦值异常:" + getErrorCodePrint());
|
}
|
|
}
|
|
//设置聚焦值
|
@Override
|
public AjaxResult setFocusPos(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
boolean enable = cmd.isEnable();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
try {
|
CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();
|
cfg_lighting_info.nLightingDetailNum = 1;
|
if (enable) {
|
cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;
|
} else {
|
cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;
|
}
|
boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
|
if (!bool) {
|
log.error("设置聚焦值失败:" + getErrorCodePrint());
|
return AjaxResult.warn("设置聚焦值失败:" + getErrorCodePrint());
|
}
|
return AjaxResult.success("设置聚焦值成功");
|
} catch (Exception ex) {
|
log.error("设置聚焦值异常:" + ex.getMessage());
|
return AjaxResult.error("设置聚焦值失败:" + ex.getMessage());
|
}
|
}
|
|
//获取码流压缩参数
|
@Override
|
public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {
|
Map<String, Object> map = new HashMap<>();
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return null;
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();
|
cfg_encode_info.nChannelID = chanNo - 1;
|
boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);
|
if (b) {
|
int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式
|
String videoEncType = "";
|
switch (emCompression) {
|
case 0:
|
videoEncType = "MPEG4";
|
break;
|
case 1:
|
videoEncType = "MS-MPEG4";
|
break;
|
case 2:
|
videoEncType = "MPEG2";
|
break;
|
case 3:
|
videoEncType = "MPEG1";
|
break;
|
case 4:
|
videoEncType = "H.263";
|
break;
|
case 5:
|
videoEncType = "MJPG";
|
break;
|
case 6:
|
videoEncType = "FCC-MPEG4";
|
break;
|
case 7:
|
videoEncType = "标准h264";
|
break;
|
case 8:
|
videoEncType = "标准h265";
|
break;
|
case 9:
|
videoEncType = "SVAC";
|
break;
|
default:
|
videoEncType = "未知";
|
break;
|
}
|
int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;
|
int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;
|
int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;
|
String resolution = nWidth + "*" + nHeight;
|
float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;
|
map.put("resolution", resolution);//分辨率
|
map.put("videoBitrate", String.valueOf(nBitRate));//比特率
|
map.put("videoEncType", videoEncType);//编码
|
map.put("nFrameRate", String.valueOf(nFrameRate));//帧率
|
}
|
} catch (Exception ex) {
|
log.error("取码流压缩参数异常:" + ex.getMessage());
|
}
|
return map;
|
}
|
|
//获取云台可视域
|
@Override
|
public AjaxResult getGisInfo(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return AjaxResult.warn("设备未登录");
|
}
|
LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
|
DH_OUT_PTZ_VIEW_RANGE_STATUS dh_out_ptz_view_range_status = new DH_OUT_PTZ_VIEW_RANGE_STATUS();
|
boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_VIEW_RANGE, dh_out_ptz_view_range_status);
|
if (!b) {
|
log.error("获取云台可视域失败:" + getErrorCodePrint());
|
return AjaxResult.warn("获取云台可视域失败:" + getErrorCodePrint());
|
}
|
float nAngelH = (float) dh_out_ptz_view_range_status.nAngelH / 10;
|
float nAngelV = (float) dh_out_ptz_view_range_status.nAngelV / 10;
|
Map<String, Object> map = getPtz(cmd);//获取ptz
|
map.put("fHorFieldAngle", nAngelH);// 水平视场角
|
map.put("fVerFieldAngle", nAngelV);// 垂直视场角
|
return AjaxResult.success(map);
|
} catch (Exception ex) {
|
log.error("获取云台可视域异常" + ex.getMessage());
|
return AjaxResult.error("获取云台可视域异常:" + getErrorCodePrint());
|
}
|
}
|
|
// 设备断线回调: 当设备出现断线时，SDK会调用该函数
|
private static class DisConnect implements NetSDKLib.fDisConnect {
|
public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
log.warn("Device[" + pchDVRIP + ":" + nDVRPort + "] DisConnect!");
|
}
|
}
|
|
// 网络连接恢复回调:设备重连成功回调，当已断线的设备重连成功时，SDK会调用该函数
|
private static class HaveReConnect implements NetSDKLib.fHaveReConnect {
|
@Override
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
log.warn("ReConnect Device[" + pchDVRIP + ":" + nDVRPort + "]");
|
}
|
}
|
|
// 抓图接收回调:当抓图成功，sdk会调用该函数
|
public static class fCaptureReceiveCB implements NetSDKLib.fSnapRev {
|
private String minioEndPoint;
|
private String ObjectName;
|
private String bucketName;
|
|
public fCaptureReceiveCB(String minioEndPoint, String bucketName, String ObjectName) {
|
this.minioEndPoint = minioEndPoint;
|
this.bucketName = bucketName;
|
this.ObjectName = ObjectName;
|
}
|
|
public void invoke(LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
|
if (pBuf != null && RevLen > 0) {
|
byte[] buf = pBuf.getByteArray(0, RevLen);
|
//存储到minio
|
InputStream input = new ByteArrayInputStream(buf);
|
|
try {
|
boolean b = MinioUtil.uploadObject(bucketName, ObjectName, input, input.available(), MimeTypeUtils.IMAGE_JPEG);
|
if (b) {
|
String url = minioEndPoint + "/" + bucketName + ObjectName;
|
log.debug("上传文件成功!" + url);
|
}
|
} catch (IOException ex) {
|
log.error("上传文件异常：" + ex.getMessage());
|
}
|
}
|
}
|
}
|
|
// 抓图接收回调:当抓图成功，sdk会调用该函数
|
public static class fCaptureReceiveCB1 implements NetSDKLib.fSnapRev {
|
private String picPath;
|
|
public fCaptureReceiveCB1(String picPath) {
|
this.picPath = picPath;
|
}
|
|
public void invoke(LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
|
if (pBuf != null && RevLen > 0) {
|
byte[] buf = pBuf.getByteArray(0, RevLen);
|
//存储到本地
|
InputStream input = new ByteArrayInputStream(buf);
|
OutputStream output = null;
|
try {
|
output = new FileOutputStream(picPath);
|
byte[] buffer = new byte[1024];
|
int bytesRead;
|
while ((bytesRead = input.read(buffer)) != -1) {
|
output.write(buffer, 0, bytesRead);
|
}
|
input.close();
|
output.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
