package com.ruoyi.utils.sdk.hiksdk.service.impl;
|
|
import com.ruoyi.alarm.global.domain.GuidePriorityQueue;
|
import com.ruoyi.alarm.global.domain.GuideTask;
|
import com.ruoyi.common.utils.file.FileUtils;
|
import com.ruoyi.common.utils.file.MimeTypeUtils;
|
import com.ruoyi.common.utils.uuid.IdUtils;
|
import com.ruoyi.device.camera.service.IArdCamerasService;
|
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.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.hiksdk.lib.ExceptionCallBack;
|
import com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Platform;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.io.*;
|
import java.math.BigDecimal;
|
import java.nio.ByteBuffer;
|
import java.text.DecimalFormat;
|
import java.util.*;
|
import java.util.concurrent.PriorityBlockingQueue;
|
|
import static com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK.*;
|
import static com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK.NET_DVR_GET_GISINFO;
|
|
/**
|
* @Description: 海康sdk策略
|
* @ClassName: DhSdkStrategy
|
* @Author: 刘苏义
|
* @Date: 2023年11月07日10:51:09
|
**/
|
@Service
|
@Slf4j(topic = "hikSdk")
|
public class HikvisionSDK implements CameraSDK {
|
@Resource
|
private IArdCamerasService ardCamerasService;
|
@Resource
|
private IArdChannelService ardChannelService;
|
@Resource
|
private IVtduService vtduService;
|
|
public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;
|
private static HCNetSDK.FExceptionCallBack fExceptionCallBack;//异常回调
|
|
/**
|
* @描述 注册登录 只支持同步登陆，且官方不建议直接在此接口下写耗时操作
|
* @参数 [dvrLogin]
|
* @返回值 java.lang.Integer
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:12
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean login(ArdCameras camera) {
|
try {
|
// 初始化
|
if (!hCNetSDK.NET_DVR_Init()) {
|
log.error("SDK初始化失败");
|
}
|
//打印海康sdk日志
|
if (Platform.isWindows()) {
|
String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
|
hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);
|
} else {
|
hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);
|
}
|
String m_sDeviceIP = camera.getIp();
|
String m_sUsername = camera.getUsername();
|
String m_sPassword = camera.getPassword();
|
short m_sPort = camera.getPort().shortValue();
|
//设置连接时间与重连时间
|
hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
|
hCNetSDK.NET_DVR_SetReconnect(5000, true);
|
//设备信息, 输出参数
|
HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
|
HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();
|
|
// 注册设备-登录参数，包括设备地址、登录用户、密码等
|
m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
|
System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
|
m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
|
System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
|
m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
|
System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
|
m_strLoginInfo.wPort = m_sPort;
|
m_strLoginInfo.byVerifyMode = 0;
|
m_strLoginInfo.byLoginMode = 0;
|
//是否异步登录：0- 否，1- 是 windowsSDK里是true和false
|
m_strLoginInfo.bUseAsynLogin = false;
|
m_strLoginInfo.write();
|
//同步登录
|
int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
|
if (lUserID < 0) {
|
log.debug("Login Failed [ " + camera.getIp() + ":" + camera.getPort() + " ],错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
camera.setChanNum(0);
|
camera.setLoginId(-1);
|
camera.setState("0");
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
ardCamerasService.updateArdCameras(camera);
|
return false;
|
}
|
|
log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]");
|
if (fExceptionCallBack == null) {
|
fExceptionCallBack = new ExceptionCallBack();//异常回调
|
//设置异常回调函数(可在回调函数中获取设备上下线状态等)
|
if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {
|
log.debug("Set fExceptionCallBack function fail");
|
return false;
|
} else {
|
log.debug("Set fExceptionCallBack function successfully!");
|
}
|
}
|
|
if (GlobalVariable.loginMap.containsKey(camera.getId())) {
|
GlobalVariable.loginMap.remove(camera.getId());
|
}
|
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
GlobalVariable.loginMap.put(camera.getId(), lUserID);
|
GlobalVariable.loginCameraMap.put(lUserID, camera);
|
|
camera.setLoginId(lUserID);
|
camera.setState("1");
|
camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum);
|
camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);
|
ardCamerasService.updateArdCameras(camera);
|
//获取最新通道
|
List<ArdChannel> cameraChannelList = getCameraChannelList(camera);
|
if (cameraChannelList.size() > 0) {
|
for (ArdChannel channel : cameraChannelList) {
|
channel.setId(IdUtils.simpleUUID());
|
ardChannelService.insertArdChannel(channel);
|
}
|
//添加到流媒体
|
for (ArdChannel channel : cameraChannelList) {
|
String name = camera.getId() + "_" + channel.getChanNo();
|
String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";
|
Vtdu vtdu = vtduService.selectVtduByName(name);
|
if (vtdu != null) {
|
vtduService.deleteVtduByName(name);
|
}
|
//添加到流媒体
|
vtdu = new Vtdu();
|
vtdu.setRtspSource(rtspSource);
|
vtdu.setName(camera.getId() + "_" + channel.getChanNo());
|
CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo());
|
Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);
|
if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {
|
vtdu.setIsCode("0");//默认不转码
|
} else {
|
vtdu.setIsCode("1");//默认转码
|
}
|
vtdu.setMode("1");//默认CPU软解码
|
vtdu.setCameraId(camera.getId());
|
vtduService.insertVtdu(vtdu);
|
}
|
}
|
//创建引导队列
|
if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
|
Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
|
PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
|
GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
|
}
|
|
} catch (Exception ex) {
|
log.error("注册设备异常", ex);
|
}
|
return true;
|
}
|
|
/**
|
* @描述 注册登录 集成于NET_DVR_Login_V30，支持同步和异步登录
|
* @参数 [dvrLogin]
|
* @返回值 java.lang.Integer
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:12
|
* @修改人和其它信息
|
*/
|
@Override
|
@Async("loginExecutor")
|
public void asyncLogin(ArdCameras camera) {
|
try {
|
// 初始化
|
if (!hCNetSDK.NET_DVR_Init()) {
|
log.error("SDK初始化失败");
|
}
|
//打印海康sdk日志
|
if (Platform.isWindows()) {
|
String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
|
hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);
|
} else {
|
hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);
|
}
|
String m_sDeviceIP = camera.getIp();
|
String m_sUsername = camera.getUsername();
|
String m_sPassword = camera.getPassword();
|
short m_sPort = camera.getPort().shortValue();
|
//设置连接时间与重连时间
|
hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
|
hCNetSDK.NET_DVR_SetReconnect(5000, true);
|
//设备信息, 输出参数
|
HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
|
HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();
|
|
// 注册设备-登录参数，包括设备地址、登录用户、密码等
|
m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
|
System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
|
m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
|
System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
|
m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
|
System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
|
m_strLoginInfo.wPort = m_sPort;
|
m_strLoginInfo.byVerifyMode = 0;
|
m_strLoginInfo.byLoginMode = 0;
|
//是否异步登录：0- 否，1- 是 windowsSDK里是true和false
|
m_strLoginInfo.bUseAsynLogin = false;
|
m_strLoginInfo.write();
|
//同步登录
|
int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
|
if (lUserID < 0) {
|
log.debug("Login Failed [ " + camera.getIp() + ":" + camera.getPort() + " ],错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
camera.setChanNum(0);
|
camera.setLoginId(-1);
|
camera.setState("0");
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
ardCamerasService.updateArdCameras(camera);
|
return ;
|
}
|
|
log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]");
|
if (fExceptionCallBack == null) {
|
fExceptionCallBack = new ExceptionCallBack();//异常回调
|
//设置异常回调函数(可在回调函数中获取设备上下线状态等)
|
if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {
|
log.debug("Set fExceptionCallBack function fail");
|
return ;
|
} else {
|
log.debug("Set fExceptionCallBack function successfully!");
|
}
|
}
|
|
if (GlobalVariable.loginMap.containsKey(camera.getId())) {
|
GlobalVariable.loginMap.remove(camera.getId());
|
}
|
|
//删除管理通道
|
ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
GlobalVariable.loginMap.put(camera.getId(), lUserID);
|
GlobalVariable.loginCameraMap.put(lUserID, camera);
|
|
camera.setLoginId(lUserID);
|
camera.setState("1");
|
camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum);
|
camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);
|
ardCamerasService.updateArdCameras(camera);
|
//获取最新通道
|
List<ArdChannel> cameraChannelList = getCameraChannelList(camera);
|
if (cameraChannelList.size() > 0) {
|
for (ArdChannel channel : cameraChannelList) {
|
channel.setId(IdUtils.simpleUUID());
|
ardChannelService.insertArdChannel(channel);
|
}
|
//添加到流媒体
|
for (ArdChannel channel : cameraChannelList) {
|
String name = camera.getId() + "_" + channel.getChanNo();
|
String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";
|
Vtdu vtdu = vtduService.selectVtduByName(name);
|
if (vtdu != null) {
|
vtduService.deleteVtduByName(name);
|
}
|
//添加到流媒体
|
vtdu = new Vtdu();
|
vtdu.setRtspSource(rtspSource);
|
vtdu.setName(camera.getId() + "_" + channel.getChanNo());
|
CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo());
|
Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);
|
if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {
|
vtdu.setIsCode("0");//默认不转码
|
} else {
|
vtdu.setIsCode("1");//默认转码
|
}
|
vtdu.setMode("1");//默认CPU软解码
|
vtdu.setCameraId(camera.getId());
|
vtduService.insertVtdu(vtdu);
|
}
|
}
|
//创建引导队列
|
if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
|
Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
|
PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
|
GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
|
}
|
|
} catch (Exception ex) {
|
log.error("注册设备异常", ex);
|
}
|
}
|
|
/**
|
* @描述 注销登录
|
* @参数 [dvrLogin]
|
* @返回值 java.lang.Integer
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:12
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean logout(String cameraId) {
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
boolean b = hCNetSDK.NET_DVR_Logout(userId);
|
if (b) {
|
GlobalVariable.loginMap.remove(cameraId);
|
}
|
return b;
|
}
|
|
/**
|
* 是否在线
|
*
|
* @param cmd 相机命令
|
*/
|
@Override
|
public boolean isOnLine(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
return hCNetSDK.NET_DVR_RemoteControl(userId, NET_DVR_CHECK_USER_STATUS, null, 0);
|
} catch (Exception ex) {
|
log.error("检测在线异常：" + ex.getMessage());
|
return false;
|
}
|
}
|
|
/**
|
* @描述 带速度的云台控制操作
|
* Code:1-左上 2-上 3-右上 4-左 5-巡航 6-右 7-左下 8-下 9-右下 10-焦距变大 11-焦距变小
|
* 12-焦点前调 13-焦点后调 14-光圈扩大 15-光圈缩小 16-雨刷开启
|
* @参数 [userId, channelNum, speed]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:14
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean pTZControl(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer channelNum = cmd.getChanNo();
|
Integer speed = cmd.getSpeed();
|
Integer code = cmd.getCode();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
int dwStop;
|
if (enable) {
|
dwStop = 0;//开启
|
} else {
|
dwStop = 1;//关闭
|
}
|
int dwPTZCommand = -1;
|
switch (code) {
|
/*方向*/
|
case 1:
|
dwPTZCommand = HCNetSDK.UP_LEFT;
|
break;
|
case 2:
|
dwPTZCommand = HCNetSDK.TILT_UP;
|
break;
|
case 3:
|
dwPTZCommand = HCNetSDK.UP_RIGHT;
|
break;
|
case 4:
|
dwPTZCommand = HCNetSDK.PAN_LEFT;
|
break;
|
case 5:
|
dwPTZCommand = HCNetSDK.RUN_SEQ;
|
break;
|
case 6:
|
dwPTZCommand = HCNetSDK.PAN_RIGHT;
|
break;
|
case 7:
|
dwPTZCommand = HCNetSDK.DOWN_LEFT;
|
break;
|
case 8:
|
dwPTZCommand = HCNetSDK.TILT_DOWN;
|
break;
|
case 9:
|
dwPTZCommand = HCNetSDK.DOWN_RIGHT;
|
break;
|
/*焦距*/
|
case 10:
|
dwPTZCommand = HCNetSDK.ZOOM_IN;
|
break;
|
case 11:
|
dwPTZCommand = HCNetSDK.ZOOM_OUT;
|
break;
|
/*焦点*/
|
case 12:
|
dwPTZCommand = HCNetSDK.FOCUS_NEAR;
|
break;
|
case 13:
|
dwPTZCommand = HCNetSDK.FOCUS_FAR;
|
break;
|
/*光圈*/
|
case 14:
|
dwPTZCommand = HCNetSDK.IRIS_OPEN;
|
break;
|
case 15:
|
dwPTZCommand = HCNetSDK.IRIS_CLOSE;
|
break;
|
/*雨刷*/
|
case 16:
|
dwPTZCommand = HCNetSDK.WIPER_PWRON;
|
break;
|
}
|
boolean bool = hCNetSDK.NET_DVR_PTZControlWithSpeed_Other(userId, channelNum, dwPTZCommand, dwStop, speed);
|
if (!bool) {
|
int errorCode = hCNetSDK.NET_DVR_GetLastError();
|
log.error("控制失败,请稍后重试" + errorCode);
|
}
|
return bool;
|
}
|
|
/**
|
* 设置聚焦值
|
*
|
* @param cmd 相机命令
|
*/
|
@Override
|
public boolean setFocusPos(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
Integer dwFocusPos = cmd.getDwFocusPos();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
// 获取参数
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG();
|
HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO();
|
struGisInfo.struPtzPosEx.dwFocus = dwFocusPos;
|
struStdCfg.read();
|
IntByReference lchannel = new IntByReference(channelNum);
|
struStdCfg.lpInBuffer = struGisInfo.getPointer();
|
struStdCfg.lpCondBuffer = lchannel.getPointer();
|
struStdCfg.dwCondSize = 4;
|
struStdCfg.dwInSize = struGisInfo.size();
|
struStdCfg.write();//设置前之前要write()
|
boolean bool = hCNetSDK.NET_DVR_SetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置GIS信息数据失败,请稍后重试" + code);
|
return false;
|
} else {
|
return true;
|
}
|
}
|
|
/**
|
* 获取聚焦值
|
*
|
* @param cmd 相机命令
|
*/
|
@Override
|
public int getFocusPos(CameraCmd cmd) {
|
int result = 0;
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return result;
|
}
|
// 获取参数
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG();
|
HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO();
|
struStdCfg.read();
|
IntByReference lchannel = new IntByReference(channelNum);
|
struStdCfg.lpCondBuffer = lchannel.getPointer();
|
struStdCfg.dwCondSize = 4;
|
struStdCfg.lpOutBuffer = struGisInfo.getPointer();
|
struStdCfg.dwOutSize = struGisInfo.size();
|
struStdCfg.write();//设置前之前要write()
|
boolean bool = hCNetSDK.NET_DVR_GetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("获取GIS信息数据失败,请稍后重试" + code);
|
return result;
|
} else {
|
struGisInfo.read();
|
result = struGisInfo.struPtzPosEx.dwFocus;
|
}
|
return result;
|
}
|
|
/**
|
* 设置预置点
|
*
|
* @param cmd 相机命令
|
*/
|
@Override
|
public boolean setPreset(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
Integer PresetIndex = cmd.getPresetIndex();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
boolean bool = hCNetSDK.NET_DVR_PTZPreset_Other(userId, channelNum, SET_PRESET, PresetIndex);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("预置点设置失败,请稍后重试" + code);
|
}
|
return bool;
|
}
|
|
/**
|
* 转到预置点
|
*
|
* @param cmd 相机命令
|
*/
|
@Override
|
public boolean gotoPreset(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
Integer PresetIndex = cmd.getPresetIndex();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
boolean bool = hCNetSDK.NET_DVR_PTZPreset_Other(userId, channelNum, GOTO_PRESET, PresetIndex);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("预置点设置失败,请稍后重试" + code);
|
}
|
return bool;
|
}
|
|
/**
|
* @描述 获取通道压缩参数
|
* @参数 [cameraId, channelNum]
|
* @返回值 java.lang.String
|
* @创建人 刘苏义
|
* @创建时间 2023/2/3 8:36
|
* @修改人和其它信息
|
*/
|
@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;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
|
NET_DVR_COMPRESSIONCFG_V30 compressioncfg = new NET_DVR_COMPRESSIONCFG_V30();
|
compressioncfg.write();
|
Pointer pioint = compressioncfg.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
|
boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_COMPRESSCFG_V30, chanNo, pioint, compressioncfg.size(), ibrBytesReturned);
|
if (bool) {
|
compressioncfg.read();
|
//码流类型：0-视频流，1-复合流，0xfe- 自动（和源一致）
|
String streamType = "";
|
switch (compressioncfg.struNormHighRecordPara.byStreamType) {
|
case 0:
|
streamType = "视频流";
|
break;
|
case 1:
|
streamType = "复合流";
|
break;
|
default:
|
streamType = "未知";
|
break;
|
}
|
//视频编码类型：0-私有264，1-标准h264，2-标准mpeg4，7-M-JPEG，8-MPEG2，9-SVAC，10-标准h265，0xfe- 自动（和源一致），0xff-无效
|
String videoEncType = "";
|
switch (compressioncfg.struNormHighRecordPara.byVideoEncType) {
|
case 0:
|
videoEncType = "私有264";
|
break;
|
case 1:
|
videoEncType = "标准h264";
|
break;
|
case 2:
|
videoEncType = "标准mpeg4";
|
break;
|
case 7:
|
videoEncType = "M-JPEG";
|
break;
|
case 8:
|
videoEncType = "MPEG2";
|
break;
|
case 9:
|
videoEncType = "SVAC";
|
break;
|
case 10:
|
videoEncType = "标准h265";
|
break;
|
default:
|
videoEncType = "未知";
|
break;
|
}
|
//视频码率
|
String videoBitrate = "";
|
switch (compressioncfg.struNormHighRecordPara.dwVideoBitrate) {
|
case 0:
|
videoBitrate = "保留";
|
break;
|
case 1:
|
videoBitrate = "16(保留)";
|
break;
|
case 2:
|
videoBitrate = "32";
|
break;
|
case 3:
|
videoBitrate = "48";
|
break;
|
case 4:
|
videoBitrate = "64";
|
break;
|
case 5:
|
videoBitrate = "80";
|
break;
|
case 6:
|
videoBitrate = "96";
|
break;
|
case 7:
|
videoBitrate = "128";
|
break;
|
case 8:
|
videoBitrate = "160";
|
break;
|
case 9:
|
videoBitrate = "192";
|
break;
|
case 10:
|
videoBitrate = "224";
|
break;
|
case 11:
|
videoBitrate = "256";
|
break;
|
case 12:
|
videoBitrate = "320";
|
break;
|
case 13:
|
videoBitrate = "384";
|
break;
|
case 14:
|
videoBitrate = "448";
|
break;
|
case 15:
|
videoBitrate = "512";
|
break;
|
case 16:
|
videoBitrate = "640";
|
break;
|
case 17:
|
videoBitrate = "768";
|
break;
|
case 18:
|
videoBitrate = "896";
|
break;
|
case 19:
|
videoBitrate = "1024";
|
break;
|
case 20:
|
videoBitrate = "1280";
|
break;
|
case 21:
|
videoBitrate = "1536";
|
break;
|
case 22:
|
videoBitrate = "1792";
|
break;
|
case 23:
|
videoBitrate = "2048K";
|
break;
|
case 24:
|
videoBitrate = "3072";
|
break;
|
case 25:
|
videoBitrate = "4096";
|
break;
|
case 26:
|
videoBitrate = "8192";
|
break;
|
case 27:
|
videoBitrate = "16384";
|
break;
|
default:
|
videoBitrate = "其他";
|
break;
|
}
|
//视频输出口分辨率：0- 1024x768，1- 1280x720，2-1280x1024，3- 1680x1050，4- 1920x1080，5- 3840*2160
|
String resolution = "";
|
switch (compressioncfg.struNormHighRecordPara.byResolution) {
|
case 0:
|
resolution = "528*384/528*320";
|
break;
|
case 1:
|
resolution = "352*288/352*240";
|
break;
|
case 2:
|
resolution = "176*144/176*120";
|
break;
|
case 3:
|
resolution = "704*576/704*480";
|
break;
|
case 4:
|
resolution = "704*288/704*240";
|
break;
|
case 6:
|
resolution = "320*240";
|
break;
|
case 7:
|
resolution = "160*120";
|
break;
|
case 16:
|
resolution = "640*480";
|
break;
|
case 17:
|
resolution = "1600*1200";
|
break;
|
case 18:
|
resolution = "800*600";
|
break;
|
case 19:
|
resolution = "1280*720";
|
break;
|
case 20:
|
resolution = "1280*960";
|
break;
|
case 21:
|
resolution = "1600*900";
|
break;
|
case 22:
|
resolution = "1360*1024";
|
break;
|
case 23:
|
resolution = "1536*1536";
|
break;
|
case 24:
|
resolution = "1920*1920";
|
break;
|
case 27:
|
resolution = "1920*1080";
|
break;
|
case 28:
|
resolution = "2560*1920";
|
break;
|
case 29:
|
resolution = "1600*304";
|
break;
|
case 30:
|
resolution = "2048*1536";
|
break;
|
default:
|
resolution = "不在当前分辨率索引，请联系管理员添加";
|
break;
|
}
|
//帧率
|
String nFrameRate = "";
|
switch (compressioncfg.struNormHighRecordPara.dwVideoFrameRate) {
|
case 0:
|
nFrameRate = "0";
|
break;
|
case 1:
|
nFrameRate = "1/16";
|
break;
|
case 2:
|
nFrameRate = "1/8";
|
break;
|
case 3:
|
nFrameRate = "1/4";
|
break;
|
case 4:
|
nFrameRate = "1/2";
|
break;
|
case 5:
|
nFrameRate = "1";
|
break;
|
case 6:
|
nFrameRate = "2";
|
break;
|
case 7:
|
nFrameRate = "4";
|
break;
|
case 8:
|
nFrameRate = "6";
|
break;
|
case 9:
|
nFrameRate = "8";
|
break;
|
case 10:
|
nFrameRate = "10";
|
break;
|
case 11:
|
nFrameRate = "12";
|
break;
|
case 12:
|
nFrameRate = "16";
|
break;
|
case 13:
|
nFrameRate = "20";
|
break;
|
case 14:
|
nFrameRate = "15";
|
break;
|
case 15:
|
nFrameRate = "18";
|
break;
|
case 16:
|
nFrameRate = "22";
|
break;
|
case 17:
|
nFrameRate = "25";
|
break;
|
case 18:
|
nFrameRate = "30";
|
break;
|
case 19:
|
nFrameRate = "35";
|
break;
|
case 20:
|
nFrameRate = "40";
|
break;
|
default:
|
nFrameRate = "未知";
|
break;
|
}
|
map.put("resolution", resolution);//分辨率
|
map.put("videoBitrate", videoBitrate);//比特率
|
map.put("videoEncType", videoEncType);//编码
|
map.put("nFrameRate", nFrameRate);//帧率
|
|
} else {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("控制失败,请稍后重试" + code);
|
}
|
} catch (Exception ex) {
|
log.error(ex.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* @描述 获取ptz信息
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息
|
*/
|
@Override
|
public Map<String, Object> getPtz(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return new HashMap<>();
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
|
NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS();
|
Pointer pioint = m_ptzPosCurrent.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
m_ptzPosCurrent.write();
|
boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_PTZPOS, channelNum, pioint, m_ptzPosCurrent.size(), ibrBytesReturned);
|
if (bool) {
|
m_ptzPosCurrent.read();
|
// DecimalFormat df = new DecimalFormat("0.0");//设置保留位数
|
//16进制转Integer后除10，保留小数点1位
|
//实际显示的PTZ值是获取到的十六进制值的十分之一，
|
//如获取的水平参数P的值是0x1750，实际显示的P值为175度；
|
//获取到的垂直参数T的值是0x0789，实际显示的T值为78.9度；
|
//获取到的变倍参数Z的值是0x1100，实际显示的Z值为110倍。
|
BigDecimal b = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wPanPos)) / 10);
|
BigDecimal c = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPos)) / 10);
|
BigDecimal d = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPos)) / 10);
|
double p = b.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
|
double t = c.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
|
double z = d.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
|
//log.debug("T垂直参数为: " + p + "P水平参数为: " + t + "Z变倍参数为: " + z);
|
Map<String, Object> ptzMap = new HashMap<>();
|
ptzMap.put("p", p);
|
ptzMap.put("t", t);
|
ptzMap.put("z", z);
|
return ptzMap;
|
} else {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("控制失败,请稍后重试" + code);
|
return new HashMap<>();
|
}
|
}
|
|
/**
|
* @描述 设置ptz信息
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置
|
*/
|
@Override
|
public boolean setPtz(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
Map<String, Double> ptz = cmd.getPtzMap();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS();
|
m_ptzPosCurrent.wAction = 1;
|
try {
|
String p = String.valueOf((int) (ptz.get("p") * 10));
|
String t = String.valueOf((int) (ptz.get("t") * 10));
|
String z = String.valueOf((int) (ptz.get("z") * 10));
|
m_ptzPosCurrent.wPanPos = (short) (Integer.parseInt(p, 16));
|
m_ptzPosCurrent.wTiltPos = (short) (Integer.parseInt(t, 16));
|
m_ptzPosCurrent.wZoomPos = (short) (Integer.parseInt(z, 16));
|
Pointer point = m_ptzPosCurrent.getPointer();
|
m_ptzPosCurrent.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_PTZPOS, channelNum, point, m_ptzPosCurrent.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置ptz失败,请稍后重试" + code);
|
}
|
return bool;
|
} catch (Exception ex) {
|
log.error(ex.getMessage());
|
return false;
|
}
|
}
|
|
@Override
|
public boolean guideTargetPosition(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS();
|
m_ptzPosCurrent.wAction = 1;
|
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);
|
String p = String.valueOf((int) (cameraPTZ[0] * 10));
|
String t = String.valueOf((int) (cameraPTZ[1] * 10));
|
String z = String.valueOf((int) (cameraPTZ[2] * 10));
|
m_ptzPosCurrent.wPanPos = (short) (Integer.parseInt(p, 16));
|
m_ptzPosCurrent.wTiltPos = (short) (Integer.parseInt(t, 16));
|
m_ptzPosCurrent.wZoomPos = (short) (Integer.parseInt(z, 16));
|
Pointer point = m_ptzPosCurrent.getPointer();
|
m_ptzPosCurrent.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_PTZPOS, channelNum, point, m_ptzPosCurrent.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置ptz失败,请稍后重试" + code);
|
}
|
return bool;
|
} catch (Exception ex) {
|
log.error("引导异常:" + ex.getMessage());
|
return false;
|
}
|
}
|
|
|
/**
|
* @描述 获取ptz锁定信息
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 0-解锁 1-锁定
|
*/
|
public int getPTZLockInfo(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return -1;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_PTZ_LOCKCFG netDvrPtzLockcfg = new NET_DVR_PTZ_LOCKCFG();
|
Pointer point = netDvrPtzLockcfg.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
netDvrPtzLockcfg.write();
|
boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_PTZLOCKCFG, channelNum, point, netDvrPtzLockcfg.size(), ibrBytesReturned);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("获取ptz锁定信息失败,请稍后重试" + code);
|
return -1;
|
} else {
|
netDvrPtzLockcfg.read();
|
return netDvrPtzLockcfg.byWorkMode;
|
}
|
}
|
|
/**
|
* @描述 设置零方位角
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置
|
*/
|
@Override
|
public boolean setZeroPtz(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_INITIALPOSITIONCTRL initialpositionctrl = new NET_DVR_INITIALPOSITIONCTRL();
|
|
initialpositionctrl.dwSize = initialpositionctrl.size();
|
initialpositionctrl.byWorkMode = 0;
|
initialpositionctrl.dwChan = Short.parseShort(channelNum.toString());
|
|
Pointer point = initialpositionctrl.getPointer();
|
initialpositionctrl.write();
|
boolean bool = hCNetSDK.NET_DVR_RemoteControl(userId, NET_DVR_PTZ_INITIALPOSITIONCTRL, point, initialpositionctrl.size());
|
if (!bool) {
|
int i = hCNetSDK.NET_DVR_GetLastError();
|
log.error("错误码：" + i);
|
}
|
return bool;
|
}
|
|
/**
|
* @描述 获取球机PTZ参数取值范围
|
* @参数 [cameraId, channelNum]
|
* @返回值 java.util.Map<java.lang.String, java.lang.Object>
|
* @创建人 刘苏义
|
* @创建时间 2023/2/8 10:58
|
* @修改人和其它信息
|
*/
|
@Override
|
public Map<String, Object> getPtzScope(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return new HashMap<>();
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_PTZSCOPE m_ptzPosCurrent = new NET_DVR_PTZSCOPE();
|
Pointer point = m_ptzPosCurrent.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
m_ptzPosCurrent.write();
|
boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_PTZSCOPE, channelNum, point, m_ptzPosCurrent.size(), ibrBytesReturned);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置ptz失败,请稍后重试" + code);
|
return new HashMap<>();
|
} else {
|
m_ptzPosCurrent.read();
|
DecimalFormat df = new DecimalFormat("0.0");//设置保留位数
|
|
String wPanPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wPanPosMax)) / 10);
|
String wPanPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMax)) / 10);
|
String wTiltPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMax)) / 10);
|
String wTiltPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMin)) / 10);
|
String wZoomPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPosMax)) / 10);
|
String wZoomPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPosMin)) / 10);
|
Map<String, Object> ptzScopeMap = new HashMap<>();
|
ptzScopeMap.put("pMax", wPanPosMax);
|
ptzScopeMap.put("pMin", wPanPosMin);
|
ptzScopeMap.put("tMax", wTiltPosMax);
|
ptzScopeMap.put("tMin", wTiltPosMin);
|
ptzScopeMap.put("zMax", wZoomPosMax);
|
ptzScopeMap.put("zMin", wZoomPosMin);
|
return ptzScopeMap;
|
}
|
|
}
|
|
/**
|
* @描述 透雾开关
|
* @参数 [userId, channelNum, enable]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlDefogcfg(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_CAMERAPARAMCFG_EX struCameraParam = new NET_DVR_CAMERAPARAMCFG_EX();
|
Pointer point = struCameraParam.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, channelNum, point, struCameraParam.size(), ibrBytesReturned);
|
if (!b_GetCameraParam) {
|
log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
}
|
struCameraParam.read();
|
log.debug("是否开启透雾：" + struCameraParam.struDefogCfg.byMode);
|
|
NET_DVR_DEFOGCFG defogcfg = new NET_DVR_DEFOGCFG();
|
if (enable) {
|
defogcfg.byMode = 2;//0-不启用 1-自动模式 2-常开模式
|
defogcfg.byLevel = 100;//取值范围0-100
|
} else {
|
defogcfg.byMode = 0;//0-不启用 1-自动模式 2-常开模式
|
}
|
struCameraParam.struDefogCfg = defogcfg;
|
struCameraParam.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, channelNum, point, struCameraParam.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置透雾失败,请稍后重试" + code);
|
}
|
log.debug("设置透雾成功");
|
return bool;
|
}
|
|
/**
|
* @描述 红外开关
|
* @参数 [userId, channelNum, enable]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlInfrarecfg(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer chanNo = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_CAMERAPARAMCFG_EX struDayNigh = new NET_DVR_CAMERAPARAMCFG_EX();
|
Pointer point = struDayNigh.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, chanNo, point, struDayNigh.size(), ibrBytesReturned);
|
if (!b_GetCameraParam) {
|
log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
}
|
struDayNigh.read();
|
String current = struDayNigh.struDayNight.byDayNightFilterType == 1 ? "开启" : "关闭";
|
log.debug("当前状态:" + current);
|
|
NET_DVR_DAYNIGHT daynight = new NET_DVR_DAYNIGHT();
|
if (enable) {
|
daynight.byDayNightFilterType = 1;//夜晚
|
} else {
|
daynight.byDayNightFilterType = 0;//白天
|
}
|
daynight.bySwitchScheduleEnabled = 1;
|
daynight.byDayNightFilterTime = 60;
|
struDayNigh.struDayNight = daynight;
|
struDayNigh.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, chanNo, point, struDayNigh.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置夜视失败,请稍后重试" + code);
|
}
|
else {
|
log.debug("设置夜视成功");
|
}
|
|
return bool;
|
}
|
|
/**
|
* @描述 聚焦开关
|
* @参数 [userId, channelNum, enable]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlFocusMode(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG();
|
Pointer point = struFocusMode.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, struFocusMode.size(), ibrBytesReturned);
|
if (!b_GetCameraParam) {
|
log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
}
|
struFocusMode.read();
|
log.debug("当前聚焦模式：" + struFocusMode.byFocusMode);
|
|
if (enable) {
|
struFocusMode.byFocusMode = 1;//手动聚焦
|
} else {
|
struFocusMode.byAutoFocusMode = 1;
|
struFocusMode.byFocusMode = 2;//自动聚焦
|
}
|
struFocusMode.byFocusDefinitionDisplay = 1;
|
struFocusMode.byFocusSpeedLevel = 3;
|
struFocusMode.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_FOCUSMODECFG, channelNum, point, struFocusMode.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置聚焦模式失败,请稍后重试" + code);
|
}
|
log.debug("设置聚焦模式成功");
|
return bool;
|
}
|
|
/**
|
* @描述 获取聚焦模式
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
public String getFocusMode(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG();
|
Pointer point = struFocusMode.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, struFocusMode.size(), ibrBytesReturned);
|
if (!b_GetCameraParam) {
|
log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
}
|
struFocusMode.read();
|
log.debug("当前聚焦模式：" + struFocusMode.byFocusMode);
|
return String.valueOf(struFocusMode.byFocusMode);
|
}
|
|
/**
|
* @描述 云台加热开关
|
* @参数 [userId, channelNum, enable]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlPTHeateRpwron(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
int dwStop;
|
if (enable) {
|
dwStop = 0;//开启
|
} else {
|
dwStop = 1;//关闭
|
}
|
boolean bool = hCNetSDK.NET_DVR_PTZControl_Other(userId, channelNum, HEATER_PWRON, dwStop);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置云台加热失败,请稍后重试" + code);
|
}
|
log.debug("设置云台加热成功");
|
return bool;
|
}
|
|
/**
|
* @描述 镜头加热开关
|
* @参数 [userId, channelNum, enable]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/18 13:07
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlCameraDeicing(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
boolean enable = cmd.isEnable();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_DEVSERVER_CFG struDeicing = new NET_DVR_DEVSERVER_CFG();
|
Pointer point = struDeicing.getPointer();
|
IntByReference ibrBytesReturned = new IntByReference(0);
|
boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_DEVSERVER_CFG, channelNum, point, struDeicing.size(), ibrBytesReturned);
|
if (!b_GetCameraParam) {
|
log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
|
}
|
struDeicing.read();
|
log.debug("是否开启除冰：" + struDeicing.byEnableDeicing);
|
|
if (enable) {
|
struDeicing.byEnableDeicing = 1;//开启
|
} else {
|
struDeicing.byEnableDeicing = 0;//关闭
|
}
|
struDeicing.write();
|
boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_DEVSERVER_CFG, channelNum, point, struDeicing.size());
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("设置镜头除冰失败,请稍后重试" + code);
|
}
|
log.debug("设置镜头除冰成功");
|
return bool;
|
}
|
|
/**
|
* 截图 返给前端
|
*
|
* @param cmd 相机命令
|
*/
|
public String captureJPEGPicture(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
NET_DVR_WORKSTATE_V30 devwork = new NET_DVR_WORKSTATE_V30();
|
if (!hCNetSDK.NET_DVR_GetDVRWorkState_V30(userId, devwork)) {
|
// 返回Boolean值，判断是否获取设备能力
|
log.error("抓图失败，请稍后重试");
|
}
|
//图片质量
|
NET_DVR_JPEGPARA jpeg = new NET_DVR_JPEGPARA();
|
//设置图片分辨率
|
jpeg.wPicSize = 0;
|
//设置图片质量
|
jpeg.wPicQuality = 0;
|
IntByReference a = new IntByReference();
|
//设置图片大小
|
ByteBuffer jpegBuffer = ByteBuffer.allocate(1024 * 1024);
|
// 抓图到内存，单帧数据捕获并保存成JPEG存放在指定的内存空间中
|
boolean is = hCNetSDK.NET_DVR_CaptureJPEGPicture_NEW(userId, channelNum, jpeg, jpegBuffer, 1024 * 1024, a);
|
log.debug("-----------这里开始图片存入内存----------" + is);
|
|
Base64.Encoder decoder = Base64.getEncoder();
|
// BASE64Encoder encoder = new BASE64Encoder();
|
String png_base64 = decoder.encodeToString(jpegBuffer.array());//转换成base64串
|
png_base64 = png_base64.replaceAll("\n", "").replaceAll("\r", "");//删除 \r\n
|
log.debug("-----------处理完成截图数据----------");
|
return png_base64;
|
}
|
|
/**
|
* @描述 截图 存服务器
|
* @参数 [cameraId, channelNum]
|
* @返回值 java.lang.String
|
* @创建人 刘苏义
|
* @创建时间 2023/2/2 14:59
|
* @修改人和其它信息
|
*/
|
@Override
|
public String picCutCate(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
//图片信息
|
NET_DVR_JPEGPARA jpeg = new NET_DVR_JPEGPARA();
|
//设置图片分辨率
|
//图片尺寸：0-CIF(352*288/352*240)，1-QCIF(176*144/176*120)，2-4CIF(704*576/704*480)或D1(720*576/720*486)，3-UXGA(1600*1200)，
|
// 4-SVGA(800*600)，5-HD720P(1280*720)，6-VGA(640*480)，7-XVGA(1280*960)，8-HD900P(1600*900)，9-HD1080P(1920*1080)，10-2560*1920，
|
// 11-1600*304，12-2048*1536，13-2448*2048，14-2448*1200，15-2448*800，16-XGA(1024*768)，17-SXGA(1280*1024)，18-WD1(960*576/960*480),
|
// 19-1080I(1920*1080)，20-576*576，21-1536*1536，22-1920*1920，23-320*240，24-720*720，25-1024*768，26-1280*1280，27-1600*600，
|
// 28-2048*768，29-160*120，75-336*256，78-384*256，79-384*216，80-320*256，82-320*192，83-512*384，127-480*272，128-512*272， 161-288*320，
|
// 162-144*176，163-480*640，164-240*320，165-120*160，166-576*720，167-720*1280，168-576*960，180-180*240, 181-360*480, 182-540*720,
|
// 183-720*960, 184-960*1280, 185-1080*1440, 500-384*288, 0xff-Auto(使用当前码流分辨率)
|
jpeg.wPicSize = 0;
|
//设置图片质量：0-最好，1-较好，2-一般
|
jpeg.wPicQuality = 0;
|
IntByReference a = new IntByReference();
|
//设置图片大小
|
ByteBuffer jpegBuffer = ByteBuffer.allocate(1024 * 1024);
|
// 抓图到内存，单帧数据捕获并保存成JPEG存放在指定的内存空间中
|
log.debug("-----------这里开始封装 NET_DVR_CaptureJPEGPicture_NEW---------");
|
boolean is = hCNetSDK.NET_DVR_CaptureJPEGPicture_NEW(userId, channelNum, jpeg, jpegBuffer, 1024 * 1024, a);
|
log.debug("-----------这里开始图片存入内存----------" + is);
|
if (is) {
|
log.debug("hksdk(抓图)-结果状态值(0表示成功):" + hCNetSDK.NET_DVR_GetLastError());
|
byte[] array = jpegBuffer.array();
|
//存储到minio
|
String BucketName = "pic";
|
String ObjectName = "capture/" + IdUtils.simpleUUID() + ".jpeg";
|
InputStream input = new ByteArrayInputStream(array);
|
String url = "";
|
try {
|
boolean b = MinioUtil.uploadObject(BucketName, ObjectName, input, input.available(), MimeTypeUtils.IMAGE_JPEG);
|
if (b) {
|
url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName);
|
log.debug("上传文件成功!" + url);
|
}
|
} catch (IOException ex) {
|
log.error("上传文件异常：" + ex.getMessage());
|
}
|
return url;
|
} else {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("抓图失败,请稍后重试" + code);
|
return "";
|
}
|
}
|
|
/**
|
* @描述 短时录像
|
* @参数 [userId, channelNum, enable]
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/1/20 11:18
|
* @修改人和其它信息
|
*/
|
@Override
|
public String record(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
|
boolean enable = cmd.isEnable();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
//强制I帧结构体对象
|
HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象
|
netDvrIFrame.read();
|
netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置
|
netDvrIFrame.byStreamType = 0;
|
netDvrIFrame.dwSize = netDvrIFrame.size();
|
netDvrIFrame.write();
|
if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) {
|
log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
}
|
//预览参数
|
NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO();
|
previewinfo.read();
|
previewinfo.lChannel = channelNum;
|
previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
|
previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ
|
previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。
|
previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流
|
previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式
|
previewinfo.write();
|
String url = "";
|
if (enable) {
|
if (!GlobalVariable.previewMap.containsKey(cameraId)) {
|
int lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null);
|
if (lRealHandle == -1) {
|
log.error("取流失败" + hCNetSDK.NET_DVR_GetLastError());
|
return "";
|
}
|
log.debug("取流成功");
|
GlobalVariable.previewMap.put(cameraId, lRealHandle);
|
}
|
if (!hCNetSDK.NET_DVR_SaveRealData_V30(GlobalVariable.previewMap.get(cameraId), 2, path)) {
|
log.error("保存视频文件到临时文件夹失败 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
return "";
|
}
|
log.debug("录像开始");
|
} else {
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
Integer lRealHandle = GlobalVariable.previewMap.get(cameraId);
|
hCNetSDK.NET_DVR_StopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
}
|
log.debug("录像停止");
|
//存入minio
|
String BucketName = "record";
|
String ObjectName = IdUtils.simpleUUID() + ".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 recordStart(CameraCmd cmd) {
|
try {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
//强制I帧结构体对象
|
HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象
|
netDvrIFrame.read();
|
netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置
|
netDvrIFrame.byStreamType = 0;
|
netDvrIFrame.dwSize = netDvrIFrame.size();
|
netDvrIFrame.write();
|
if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) {
|
log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
}
|
//预览参数
|
NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO();
|
previewinfo.read();
|
previewinfo.lChannel = channelNum;
|
previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
|
previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ
|
previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。
|
previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流
|
previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式
|
previewinfo.write();
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
Integer lRealHandle = GlobalVariable.previewMap.get(cameraId);
|
hCNetSDK.NET_DVR_StopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
log.debug("停止当前录像");
|
}
|
int lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null);
|
if (lRealHandle == -1) {
|
log.error("取流失败" + hCNetSDK.NET_DVR_GetLastError());
|
return false;
|
}
|
log.debug("取流成功");
|
GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());
|
GlobalVariable.previewMap.put(cameraId, lRealHandle);
|
if (!hCNetSDK.NET_DVR_SaveRealData_V30(GlobalVariable.previewMap.get(cameraId), 2, path)) {
|
log.error("保存视频文件到临时文件夹失败 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
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();
|
Integer channelNum = cmd.getChanNo();
|
String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return "";
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
//region 强制I帧
|
HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象
|
netDvrIFrame.read();
|
netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置
|
netDvrIFrame.byStreamType = 0;
|
netDvrIFrame.dwSize = netDvrIFrame.size();
|
netDvrIFrame.write();
|
if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) {
|
log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
}
|
//endregion
|
//region 预览参数
|
NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO();
|
previewinfo.read();
|
previewinfo.lChannel = channelNum;
|
previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
|
previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ
|
previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。
|
previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流
|
previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式
|
previewinfo.write();
|
//endregion
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
Integer lRealHandle = GlobalVariable.previewMap.get(cameraId);
|
hCNetSDK.NET_DVR_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();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return false;
|
}
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
//强制I帧结构体对象
|
HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象
|
netDvrIFrame.read();
|
netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置
|
netDvrIFrame.byStreamType = 0;
|
netDvrIFrame.dwSize = netDvrIFrame.size();
|
netDvrIFrame.write();
|
if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) {
|
log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError());
|
}
|
//预览参数
|
NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO();
|
previewinfo.read();
|
previewinfo.lChannel = channelNum;
|
previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
|
previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ
|
previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。
|
previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流
|
previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式
|
previewinfo.write();
|
if (GlobalVariable.previewMap.containsKey(cameraId)) {
|
Integer lRealHandle = GlobalVariable.previewMap.get(cameraId);
|
hCNetSDK.NET_DVR_StopRealPlay(lRealHandle);
|
GlobalVariable.previewMap.remove(cameraId);
|
}
|
log.debug("录像停止");
|
result = true;
|
} catch (Exception ex) {
|
log.error("录像停止异常" + ex.getMessage());
|
result = false;
|
}
|
return result;
|
}
|
|
//获取IP通道
|
@Override
|
public List<ArdChannel> getCameraChannelList(ArdCameras camera) {
|
/*获取通道*/
|
List<ArdChannel> channelList = new ArrayList<>();
|
try {
|
Integer chanNum = camera.getChanNum();
|
Integer startDChan = camera.getStartDChan();
|
if (chanNum > 0) {
|
// 获取通道号
|
for (int iChannum = 0; iChannum < chanNum; iChannum++) {
|
ArdChannel ardChannel = new ArdChannel();
|
int channum = iChannum + startDChan + 1;
|
HCNetSDK.NET_DVR_PICCFG_V40 strPicCfg = new HCNetSDK.NET_DVR_PICCFG_V40();
|
strPicCfg.dwSize = strPicCfg.size();
|
strPicCfg.write();
|
Pointer pStrPicCfg = strPicCfg.getPointer();
|
NativeLong lChannel = new NativeLong(channum);
|
IntByReference pInt = new IntByReference(0);
|
boolean b_GetPicCfg = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId(), HCNetSDK.NET_DVR_GET_PICCFG_V40, lChannel.intValue(),
|
pStrPicCfg, strPicCfg.size(), pInt);
|
if (b_GetPicCfg) {
|
strPicCfg.read();
|
String channelName = new String(strPicCfg.sChanName, "GBK").trim();
|
ardChannel.setName(channelName);
|
}
|
ardChannel.setDeviceId(camera.getId());
|
ardChannel.setChanNo(iChannum + 1);
|
channelList.add(ardChannel);
|
}
|
}
|
} catch (Exception ex) {
|
log.error("获取相机通道异常:" + ex.getMessage());
|
}
|
return channelList;
|
}
|
|
/**
|
* @描述 获取GIS信息数据
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 0-解锁 1-锁定
|
*/
|
@Override
|
public Map<String, Object> getGisInfo(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();
|
Integer channelNum = cmd.getChanNo();
|
if (!GlobalVariable.loginMap.containsKey(cameraId)) {
|
return new HashMap<>();
|
}
|
// 获取参数
|
Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);
|
HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG();
|
HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO();
|
struStdCfg.read();
|
IntByReference lchannel = new IntByReference(channelNum);
|
struStdCfg.lpCondBuffer = lchannel.getPointer();
|
struStdCfg.dwCondSize = 4;
|
struStdCfg.lpOutBuffer = struGisInfo.getPointer();
|
struStdCfg.dwOutSize = struGisInfo.size();
|
struStdCfg.write();//设置前之前要write()
|
boolean bool = hCNetSDK.NET_DVR_GetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg);
|
if (!bool) {
|
int code = hCNetSDK.NET_DVR_GetLastError();
|
log.error("获取GIS信息数据失败,请稍后重试" + code);
|
return new HashMap<>();
|
} else {
|
struGisInfo.read();
|
Map<String, Object> map = new HashMap<>();
|
map.put("p", struGisInfo.struPtzPos.fPanPos);
|
map.put("t", struGisInfo.struPtzPos.fTiltPos < 0 ? struGisInfo.struPtzPos.fTiltPos + 360 : struGisInfo.struPtzPos.fTiltPos);
|
map.put("z", struGisInfo.struPtzPos.fZoomPos);
|
map.put("fHorFieldAngle", struGisInfo.fHorizontalValue);// 水平视场角
|
map.put("fVerFieldAngle", struGisInfo.fVerticalValue);// 垂直视场角
|
return map;
|
}
|
}
|
}
|
