package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.customize.JordanPSD.FileDownLoadPosCallBack;
|
import com.netsdk.demo.customize.JordanPSD.FileDownloadDataCallBack;
|
import com.netsdk.demo.customize.JordanPSD.module.RecordModule;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetFinalVar;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_NEW_CONFIG;
|
import com.netsdk.lib.enumeration.EM_STORAGE_DISK_PREDISKCHECK;
|
import com.netsdk.lib.enumeration.ENUMERROR;
|
import com.netsdk.lib.enumeration.NET_VOLUME_TYPE;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Memory;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
import static com.netsdk.lib.NetSDKLib.NET_DEVSTATE_SOFTWARE;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description ERR220614207
|
* @date 2022/6/17 9:28
|
*/
|
public class HaoyunDemo extends Initialization {
|
|
static Scanner sc = new Scanner(System.in);
|
|
private TimeDownLoadDataCallBack m_DownLoadData = new TimeDownLoadDataCallBack(); // 录像下载数据回调
|
// 按时间下载数据回调
|
public class TimeDownLoadDataCallBack implements NetSDKLib.fDataCallBack {
|
public int invoke(NetSDKLib.LLong lRealHandle, int dwDataType, Pointer pBuffer, int dwBufSize, Pointer dwUser) {
|
// System.out.println("TimeDownLoadDataCallBack [ " + dwUser +" ]");
|
return 0;
|
}
|
}
|
|
private static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
/**
|
* 下载录像
|
* @param nStreamType 码流类型
|
* @param nChannel 通道号
|
* @param stTimeStart 开始时间
|
* @param stTimeEnd 结束时间
|
* @param savedFileName 保存录像文件名
|
*/
|
|
NetSDKLib.LLong n_hDownLoadHandle =new NetSDKLib.LLong();
|
public boolean downloadRecordFile(int nStreamType, int nChannel,
|
NetSDKLib.NET_TIME stTimeStart, NetSDKLib.NET_TIME stTimeEnd, String savedFileName) {
|
|
if (!setStreamType(nStreamType)) {
|
System.err.println("Set Stream Type Failed!." + ToolKits.getErrorCode());
|
return false;
|
}
|
|
int scType = 3; // scType: 码流转换类型,0-DAV码流(默认); 1-PS流,3-MP4
|
int nRecordFileType = NetSDKLib.EM_QUERY_RECORD_TYPE.EM_RECORD_TYPE_ALL; // 下载所有录像
|
|
n_hDownLoadHandle
|
= netSdk.CLIENT_DownloadByTimeEx2(loginHandle, nChannel, nRecordFileType,
|
stTimeStart, stTimeEnd, savedFileName,
|
DownloadPosCallback.getInstance(), null, m_DownLoadData, null, scType, null);
|
|
if(n_hDownLoadHandle.longValue() != 0) {
|
System.out.println("Downloading RecordFile...");
|
} else {
|
System.err.println("Download RecordFile Failed!" + ToolKits.getErrorCode() + ENUMERROR.getErrorMessage());
|
return false;
|
}
|
|
return true;
|
}
|
/**
|
* 下载进度回调
|
* 回调建议写成单例模式, 回调里处理数据，需要另开线程
|
*/
|
public static class DownloadPosCallback implements NetSDKLib.fDownLoadPosCallBack {
|
|
private DownloadPosCallback() {}
|
|
private static class CallBackHolder {
|
private static final DownloadPosCallback cb = new DownloadPosCallback();
|
}
|
|
public static final DownloadPosCallback getInstance() {
|
return DownloadPosCallback.CallBackHolder.cb;
|
}
|
|
@Override
|
public void invoke(NetSDKLib.LLong lPlayHandle, int dwTotalSize, int dwDownLoadSize, Pointer dwUser) {
|
|
System.out.println("Download pos： " + dwDownLoadSize*100 / dwTotalSize);
|
if(dwDownLoadSize == -1) { // 下载结束
|
System.out.println("Downloading Complete. ");
|
new StopDownloadTask(lPlayHandle).start();
|
}
|
System.out.println(dwDownLoadSize);
|
}
|
|
private class StopDownloadTask extends Thread {
|
private NetSDKLib.LLong lDownloadHandle;
|
|
public StopDownloadTask(NetSDKLib.LLong lDownloadHandle) {
|
this.lDownloadHandle = lDownloadHandle;
|
}
|
|
public void run() {
|
stopDownLoadRecordFile(lDownloadHandle);
|
}
|
}
|
}
|
/**
|
* 停止下载录像
|
* @param hDownLoadHandle 下载句柄
|
*/
|
private static void stopDownLoadRecordFile(NetSDKLib.LLong hDownLoadHandle) {
|
if (hDownLoadHandle.longValue() == 0) {
|
return;
|
}
|
netSdk.CLIENT_StopDownload(hDownLoadHandle);
|
}
|
/**
|
* 下载录像
|
*/
|
public void downloadRecordFile() {
|
|
int nStreamType = 0; // 0-主辅码流,1-主码流,2-辅码流
|
int nChannel = 0; // 通道号
|
NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME(); // 开始时间
|
NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME(); // 结束时间
|
|
Calendar calendar = Calendar.getInstance();
|
|
System.out.println("默认下载通道0主辅码流的最近10分钟录像 如果想要自己设置通道或时间段请输入1: ");
|
String s
|
= sc.nextLine();
|
if ("1".equals(s.trim())) {
|
try {
|
System.out.println("请输入通道号(从0开始),开始时间,结束时间：如 0,2022-6-22 16:10:00,2022-6-22 16:30:00");
|
|
String all=sc.nextLine();
|
String[] split
|
= all.split(",");
|
nChannel = Integer.parseInt(split[0]);
|
|
Date start
|
= format.parse(split[1]);
|
calendar.setTime(start);
|
setTime(calendar, stTimeStart);
|
// System.out.println("startTime:"+stTimeStart);
|
|
Date end
|
= format.parse(split[2]);
|
calendar.setTime(end);
|
setTime(calendar, stTimeEnd);
|
|
// System.out.println("stTimeEnd:"+stTimeEnd);
|
} catch (ParseException e) {
|
System.err.println("时间输入非法");
|
return;
|
}
|
|
}else {
|
calendar.setTime(new Date());
|
setTime(calendar, stTimeEnd);
|
|
calendar.add(Calendar.MINUTE, -10);
|
setTime(calendar, stTimeStart);
|
|
}
|
System.out.println("startTime:"+stTimeStart);
|
System.out.println("stTimeEnd:"+stTimeEnd);
|
System.out.println("nChannel:"+nChannel);
|
String savedFileName = "dowload_" + System.currentTimeMillis() + ".mp4"; // 保存录像文件名
|
|
boolean b
|
= downloadRecordFile(nStreamType, nChannel, stTimeStart, stTimeEnd, savedFileName);
|
if(!b){
|
System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
|
}
|
}
|
|
private void setTime(Calendar calendar, NetSDKLib.NET_TIME stuTime) {
|
stuTime.setTime(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH) + 1, calendar.get(Calendar.DAY_OF_MONTH),
|
calendar.get(Calendar.HOUR_OF_DAY), calendar.get(Calendar.MINUTE), calendar.get(Calendar.SECOND));
|
}
|
NetSDKLib.LLong n_hDownLoadFileHandle =new NetSDKLib.LLong();
|
|
/**
|
* 通用录像文件下载 按文件信息筛选
|
*/
|
public void DownloadRecordByFile() throws UnsupportedEncodingException {
|
|
if (loginHandle.longValue() == 0) {
|
System.err.println("请先登录");
|
return;
|
}
|
|
List<NetSDKLib.NET_RECORDFILE_INFO> files = QueryRecordFile();
|
if (files.isEmpty()) {
|
System.err.println("查询不到录像文件");
|
return;
|
}
|
|
|
System.out.println("请选择需要下载的文件序号");
|
int idx = sc.nextInt();
|
NetSDKLib.NET_RECORDFILE_INFO fileInfo = files.get(idx);
|
|
// LPNET_RECORDFILE_INFO 和 NET_RECORDFILE_INFO 内部字段完全一样 可以互相替换 因此我加了个重载接口
|
// 这里直接使用 fileInfo 作查询条件
|
|
// 默认保存路径
|
String savePath = new File(".").getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".MP4";
|
System.out.println("SavedFileName:" + savePath);
|
NetSDKLib.fTimeDownLoadPosCallBack posCallBack = FileDownLoadPosCallBack.getInstance(); // 进度回调
|
NetSDKLib.fDataCallBack dataCallBack = FileDownloadDataCallBack.getInstance(); // 下载数据回调
|
|
n_hDownLoadFileHandle = RecordModule.DownloadRecordFileByFileEx(loginHandle, fileInfo, savePath, posCallBack, dataCallBack);
|
if (n_hDownLoadFileHandle.longValue() == 0) {
|
System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
|
} else {
|
System.out.println("Start Download By File Succeed");
|
}
|
}
|
|
class LockFileInfo {
|
public int nCluster; // 簇号
|
public int nDriveNo; // 磁盘号
|
public int type;//0 普通（非加密） 1重要（加密）
|
|
public LockFileInfo(int nCluster, int nDriveNo,int type) {
|
this.nCluster = nCluster;
|
this.nDriveNo = nDriveNo;
|
this.type=type;
|
}
|
|
@Override
|
public String toString() {
|
return "LockFileInfo{" +
|
"nCluster=" + nCluster +
|
", nDriveNo=" + nDriveNo +
|
", type=" + type +
|
'}';
|
}
|
}
|
|
// 加锁文件列表
|
private List<LockFileInfo> lstLockFile = new ArrayList<LockFileInfo>();
|
private List<LockFileInfo> unlstLockFile = new ArrayList<LockFileInfo>();
|
|
/**
|
* 按文件录像解锁/加密
|
*/
|
public void lockRecordByFile() {
|
if (lstLockFile.isEmpty()) {
|
queryRecordFile();
|
}
|
Scanner scanner=new Scanner(System.in);
|
System.out.println("1 解密 ，其他加密");
|
int next = scanner.nextInt();
|
|
if(next==1){//解密
|
if(lstLockFile.size()==0){
|
System.out.println("没有找到加密的文件");
|
return;
|
}
|
for (int i=0;i<lstLockFile.size();i++) {
|
LockFileInfo lockFileInfo
|
= lstLockFile.get(i);
|
System.out.println("index:"+i+";lockFileInfo:"+lockFileInfo.toString());
|
|
}
|
System.out.println("选择需要解密的下标：如1,2,3");
|
String indexs
|
= sc.nextLine();
|
String[] split
|
= indexs.split(",");
|
for(int i=0;i<split.length;i++){
|
|
lockRecordByFile(lstLockFile.get(Integer.parseInt(split[i])),0);
|
|
}
|
|
}else {//加密
|
if(unlstLockFile.size()==0){
|
System.out.println("没有找到未加密的文件");
|
return;
|
}
|
|
for (int i=0;i<unlstLockFile.size();i++) {
|
|
LockFileInfo unlockFileInfo
|
= unlstLockFile.get(i);
|
System.out.println("index:"+i+";unlockFileInfo:"+unlockFileInfo.toString());
|
|
}
|
|
System.out.println("选择需要加密的下标：如1,2,3");
|
String indexs
|
= sc.nextLine();
|
String[] split
|
= indexs.split(",");
|
for(int i=0;i<split.length;i++){
|
|
lockRecordByFile(unlstLockFile.get(Integer.parseInt(split[i])),1);
|
|
}
|
|
}
|
|
lstLockFile.clear();
|
unlstLockFile.clear();
|
}
|
|
|
|
|
/**
|
* 按文件解锁录像
|
* @param stFileInfo 文件信息 (queryMarkFile获取)
|
*/
|
public boolean lockRecordByFile(LockFileInfo stFileInfo,int key) {
|
|
NetSDKLib.NET_IN_SET_MARK_FILE stuIn = new NetSDKLib.NET_IN_SET_MARK_FILE();
|
stuIn.emLockMode = NetSDKLib.EM_MARKFILE_MODE.EM_MARK_FILE_BY_NAME_MODE; // 通过文件名方式对录像加锁
|
stuIn.emFileNameMadeType = NetSDKLib.EM_MARKFILE_NAMEMADE_TYPE.EM_MARKFILE_NAMEMADE_JOINT; // 拼接文件名方式
|
stuIn.nDriveNo = stFileInfo.nDriveNo;
|
stuIn.nStartCluster = stFileInfo.nCluster;
|
// stuIn.byImportantRecID = (byte)0; // 清除 0:普通录像（清除） 1:重要录像（加密）
|
stuIn.byImportantRecID = (byte)key; // 0:普通录像（清除） 1:重要录像（加密）
|
NetSDKLib.NET_OUT_SET_MARK_FILE stuOut = new NetSDKLib.NET_OUT_SET_MARK_FILE();
|
|
boolean bRet = netSdk.CLIENT_SetMarkFile(loginHandle, stuIn, stuOut, 3000);
|
if(bRet) {
|
System.out.printf("Unlock Record DriveNo[%d] Cluster[%d] Success. \n", stFileInfo.nDriveNo, stFileInfo.nCluster);
|
} else {
|
System.err.printf("Unlock Record DriveNo[%d] Cluster[%d] Failed! %s \n", stFileInfo.nDriveNo, stFileInfo.nCluster, ToolKits.getErrorCode());
|
return false;
|
}
|
return bRet;
|
}
|
|
|
// 查询录像视频
|
public void queryRecordFile() {
|
NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
|
|
NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
|
|
Calendar calendar = Calendar.getInstance();
|
|
System.out.println("请输入通道号(从0开始),开始时间,结束时间：如 0,2022-6-22 16:10:00,2022-6-22 16:30:00");
|
|
String all=sc.nextLine();
|
String[] split
|
= all.split(",");
|
|
int nchannel
|
= Integer.parseInt(split[0]) ;
|
|
|
Date start
|
= null;
|
try {
|
start = format.parse(split[1]);
|
calendar.setTime(start);
|
setTime(calendar, stTimeStart);
|
|
Date end
|
= format.parse(split[2]);
|
calendar.setTime(end);
|
setTime(calendar, stTimeEnd);
|
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
|
|
//**************按时间查找视频文件**************
|
int nFileCount = 200; //每次查询的最大文件个数
|
NetSDKLib.NET_RECORDFILE_INFO[] numberFile = (NetSDKLib.NET_RECORDFILE_INFO[]) new NetSDKLib.NET_RECORDFILE_INFO().toArray(nFileCount);
|
int maxlen = nFileCount * numberFile[0].size();
|
|
IntByReference outFileCoutReference = new IntByReference(0);
|
|
boolean cRet = netSdk.CLIENT_QueryRecordFile(
|
loginHandle, nchannel, 0, stTimeStart, stTimeEnd, null, numberFile, maxlen, outFileCoutReference, 5000, false);
|
|
if (cRet) {
|
System.out.println("QueryRecordFile Succeed! \n" + "查询到的视频个数：" + outFileCoutReference.getValue()
|
+ "\n" + "码流类型：" + numberFile[0].bRecType);
|
for(int i=0;i<outFileCoutReference.getValue();i++){
|
NetSDKLib.NET_RECORDFILE_INFO info
|
= numberFile[i];
|
System.out.println("fileName"+ new String(info.filename));
|
System.out.println("bImportantRecID:"+info.bImportantRecID);// 0:普通录像(未加密) 1:重要录像（已加密）
|
if(info.bImportantRecID==0){
|
unlstLockFile.add(new LockFileInfo(info.startcluster,info .driveno,info.bImportantRecID));
|
}else {
|
lstLockFile.add(new LockFileInfo(info.startcluster,info .driveno,info.bImportantRecID));
|
}
|
|
}
|
|
} else {
|
System.err.println("QueryRecordFile Failed!" + netSdk.CLIENT_GetLastError());
|
}
|
|
|
}
|
|
|
/**
|
* 查找录像 需要指定查询录像的最大个数
|
* 这个接口只是用于协助演示录像下载用的 比较简单 需要手动预填最大文件数量 实际开发请走 FindFile 接口
|
*/
|
public List<NetSDKLib.NET_RECORDFILE_INFO> QueryRecordFile() throws UnsupportedEncodingException {
|
NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
|
// stTimeStart.setTime(2022, 6, 21, 0, 0, 0);
|
|
NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
|
// stTimeEnd.setTime(2022, 6, 21, 10, 15, 0);
|
Calendar calendar = Calendar.getInstance();
|
System.out.println("开始时间,结束时间：如 2022-6-22 16:10:00,2022-6-22 16:30:00");
|
|
String all=sc.nextLine();
|
String[] split
|
= all.split(",");
|
|
|
Date start
|
= null;
|
Date end
|
= null;
|
try {
|
start = format.parse(split[0]);
|
end = format.parse(split[1]);
|
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
calendar.setTime(start);
|
setTime(calendar, stTimeStart);
|
|
calendar.setTime(end);
|
setTime(calendar, stTimeEnd);
|
|
|
//////////// 按时间查找视频文件 //////////
|
////////////////////////////////////////
|
|
int maxFileCount = 50; // 查询的最大文件个数
|
NetSDKLib.NET_RECORDFILE_INFO[] fileInfos = new NetSDKLib.NET_RECORDFILE_INFO[maxFileCount];
|
for (int i = 0; i < maxFileCount; i++) {
|
fileInfos[i] = new NetSDKLib.NET_RECORDFILE_INFO();
|
}
|
int retCount = RecordModule.QueryRecordFileByTimeLimit(loginHandle, maxFileCount, fileInfos, stTimeStart, stTimeEnd);
|
if (retCount == -1) {
|
System.err.println("查询录像文件失败!" + ENUMERROR.getErrorMessage());
|
}
|
System.out.println("查询录像文件成功 共查询到录像数: " + retCount);
|
|
// 打印看一下
|
StringBuilder info = new StringBuilder()
|
.append("QueryRecordFile Succeed! \n" + "查询到的视频个数：")
|
.append(retCount).append("\n")
|
.append("码流类型：").append(fileInfos[0].bRecType).append("\n");
|
for (int i = 0; i < retCount; i++) {
|
info.append("【").append(i).append("】：").append("\n")
|
.append("文件名：").append(new String(fileInfos[i].filename, encode)).append("\n")
|
.append("文件长度：").append(fileInfos[i].size).append("\n")
|
.append("开始时间：").append(fileInfos[i].starttime).append("\n")
|
.append("结束时间：").append(fileInfos[i].endtime).append("\n")
|
.append("通道号：").append(fileInfos[i].ch).append("\n")
|
.append("加密：").append(fileInfos[i].bImportantRecID).append("\n");//0:普通录像（清除） 1:重要录像（加密）
|
}
|
System.out.println(info.toString());
|
|
return new ArrayList<>(Arrays.asList(fileInfos).subList(0, retCount));
|
}
|
|
/**
|
* 设置回放时的码流类型
|
* @param m_streamType 码流类型
|
*/
|
public boolean setStreamType(int m_streamType) {
|
int emType = NetSDKLib.EM_USEDEV_MODE.NET_RECORD_STREAM_TYPE; // 回放录像枚举
|
IntByReference steamType = new IntByReference(m_streamType); // 0-主辅码流,1-主码流,2-辅码流
|
return netSdk.CLIENT_SetDeviceMode(loginHandle, emType, steamType.getPointer());
|
}
|
|
/**
|
* 获取设备软件版本
|
*
|
*/
|
public void QueryDevDeviceVersionStateTest() {
|
NetSDKLib.NETDEV_VERSION_INFO info = new NetSDKLib.NETDEV_VERSION_INFO();
|
info.write();
|
boolean bRet = netSdk.CLIENT_QueryDevState(loginHandle, NET_DEVSTATE_SOFTWARE, info.getPointer(), info.size(), new IntByReference(0), 3000);
|
if (!bRet) {
|
System.err.println("QueryDevState DEV STATE of SOFTWARE failed: " + ToolKits.getErrorCode());
|
return;
|
}
|
info.read();
|
System.out.println("QueryDevState DEV STATE of SOFTWARE succeed");
|
|
System.out.println("szSoftWareVersion 软件版本: " + new String(info.szSoftWareVersion).trim());
|
System.out.println("szDevSerialNo 序列号: " + new String(info.szDevSerialNo).trim());
|
int buildData = info.dwSoftwareBuildDate;
|
int day = buildData & 0xff;
|
buildData >>= 8;
|
int month = buildData & 0xff;
|
int year = buildData >> 8;
|
System.out.println("BuildData 编译日期: " + year + "-" + month + "-" + day);
|
}
|
|
/**
|
* 获取远程设备编码配置
|
* 三代协议
|
* 注：
|
* 1) 我们建议把主码流配置看成一个整体, 即主码流组统一做相同配置
|
* 2) 辅码流在不同设备上能力集差异较大 我们建议只使用辅码流 1, 即只关注辅码流组的第一个配置
|
*/
|
public void getDeviceEncode() {
|
final String cfgCmd = EM_NEW_CONFIG.CFG_CMD_ENCODE.getValue();
|
NetSDKLib.CFG_ENCODE_INFO encodeInfo = new NetSDKLib.CFG_ENCODE_INFO();
|
encodeInfo.nChannelID = 0;
|
boolean ret = ToolKits.GetDevConfig(loginHandle, 0, cfgCmd, encodeInfo);
|
if (!ret) {
|
System.err.println("获取远程设备编码配置失败:" + ENUMERROR.getErrorMessage());
|
return;
|
}
|
// 打印下当前的设备参数: 主/辅 码流的分辨率, 帧率和码率
|
StringBuilder info = null;
|
try {
|
info = new StringBuilder()
|
.append(String.format("SN:%s, Chn:%03d, Encode Config:\n", new String(m_stDeviceInfo.sSerialNumber, encode).trim(), 0));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
// 主码流
|
if (encodeInfo.nValidCountMainStream > 0) {
|
info.append("Main Stream 主码流:\n")
|
.append(" Resolution 分辨率: ").append(String.format("( %04d x %04d )\n",
|
encodeInfo.stuMainStream[0].stuVideoFormat.nWidth,
|
encodeInfo.stuMainStream[0].stuVideoFormat.nHeight))
|
.append(" BitRate 视频码流(kbps): ").append(encodeInfo.stuMainStream[0].stuVideoFormat.nBitRate).append("\n")
|
.append(" FrameRate 帧率: ").append(encodeInfo.stuMainStream[0].stuVideoFormat.nFrameRate).append("\n")
|
.append(" IFrameInterval I帧间隔: ").append(encodeInfo.stuMainStream[0].stuVideoFormat.nIFrameInterval).append("\n")
|
.append(" 音频编码模式: ").append(encodeInfo.stuMainStream[0].stuAudioFormat.nMode).append("\n")
|
.append(" 音频压缩模式: ").append(encodeInfo.stuMainStream[0].stuAudioFormat.emCompression).append("\n")
|
.append(" 音频使能: ").append(encodeInfo.stuMainStream[0].bAudioEnable).append("\n");
|
}
|
|
// 辅码流
|
if (encodeInfo.nValidCountExtraStream > 0) {
|
info.append("Sub Stream 辅码流(1):\n")
|
.append(" Resolution 分辨率: ").append(String.format("( %04d x %04d )\n",
|
encodeInfo.stuExtraStream[0].stuVideoFormat.nWidth,
|
encodeInfo.stuExtraStream[0].stuVideoFormat.nHeight))
|
.append(" BitRate 视频码流(kbps): ").append(encodeInfo.stuExtraStream[0].stuVideoFormat.nBitRate).append("\n")
|
.append(" FrameRate 帧率: ").append(encodeInfo.stuExtraStream[0].stuVideoFormat.nFrameRate).append("\n")
|
.append(" IFrameInterval I帧间隔: ").append(encodeInfo.stuExtraStream[0].stuVideoFormat.nIFrameInterval).append("\n")
|
.append(" 音频编码模式: ").append(encodeInfo.stuMainStream[0].stuAudioFormat.nMode).append("\n")
|
.append(" 音频压缩模式: ").append(encodeInfo.stuMainStream[0].stuAudioFormat.emCompression).append("\n")
|
.append(" 音频使能: ").append(encodeInfo.stuMainStream[0].bAudioEnable).append("\n");
|
|
|
}
|
|
System.out.println(info.toString());
|
}
|
|
|
public void GetIVSSDisk() {
|
Scanner scanner=new Scanner(System.in);
|
NET_IN_STORAGE_DEV_INFOS inInfo = new NET_IN_STORAGE_DEV_INFOS();
|
// * 6、阵列信息：CLIENT_QueryDevInfo+NET_QUERY_DEV_STORAGE_INFOS，emVolumeType=VOLUME_TYPE_RAID
|
// * 7、硬盘容量：CLIENT_QueryDevInfo+NET_QUERY_DEV_STORAGE_INFOS，emVolumeType=VOLUME_TYPE_ALL
|
System.out.println("输入1 VOLUME_TYPE_RAID，输入2 VOLUME_TYPE_ALL");
|
int nextInt
|
= scanner.nextInt();
|
|
if(nextInt==1){
|
inInfo.emVolumeType=NET_VOLUME_TYPE.VOLUME_TYPE_RAID;
|
}else {
|
inInfo.emVolumeType = NET_VOLUME_TYPE.VOLUME_TYPE_ALL; // 单盘可以查询支持的工作组
|
}
|
|
NET_OUT_STORAGE_DEV_INFOS outInfo = new NET_OUT_STORAGE_DEV_INFOS();
|
for (int i = 0; i < outInfo.stuStoregeDevInfos.length; i ++)
|
{
|
outInfo.stuStoregeDevInfos[i].dwSize = outInfo.stuStoregeDevInfos[0].dwSize;
|
}
|
inInfo.write();
|
outInfo.write();
|
boolean bRet = netSdk.CLIENT_QueryDevInfo(loginHandle, NetSDKLib.NET_QUERY_DEV_STORAGE_INFOS, inInfo.getPointer(), outInfo.getPointer(), null, 5000);
|
inInfo.read();
|
outInfo.read();
|
if (!bRet) {
|
System.err.println("CLIENT_QueryDevInfo Failed!" + ToolKits.getErrorCode());
|
return;
|
}
|
for (int i = 0; i < outInfo.nDevInfosNum; i ++)
|
{
|
NET_STORAGE_DEVICE device = outInfo.stuStoregeDevInfos[i];
|
System.out.println("槽位:"+device.nPhysicNo); // 槽位
|
System.out.println("名称:"+new String(device.szName).trim()); // 名称
|
System.out.println("总空间, byte:"+device.nTotalSpace);
|
System.out.println("剩余空间, byte:"+device.nFreeSpace);
|
System.out.println("型号:"+new String(device.szModule).trim()); // 型号
|
String valume[] = {"0-物理卷", "1-Raid卷", "2-VG虚拟卷", "3-ISCSI", "4-独立物理卷", "5-全局热备卷", "6-NAS卷(包括FTP, SAMBA, NFS)", "7-独立RAID卷（指没有加入到，虚拟卷组等组中）"};
|
System.out.println("卷类型:"+valume[device.byVolume]); //
|
if (device.byVolume == 1) {
|
System.out.println("Raid Stat: " + device.stuRaid.nState);
|
} else { // 单盘问题
|
String arState[] =
|
{
|
"Offline-物理硬盘脱机状态", "Running-物理硬盘运行状态", "Active-RAID活动", "Sync-RAID同步", "Spare-RAID热备(局部)",
|
"Faulty-RAID失效", "Rebuilding-RAID重建", "Removed-RAID移除", "WriteError-RAID写错误", "WantReplacement-RAID需要被替换",
|
"Replacement-RAID是替代设备", "GlobalSpare-全局热备", "Error-一般错误，部分分区可用", "RaidSub-该盘目前是单盘，原先是块Raid子盘,有可能在重启后自动加入Raid",
|
};
|
if ((int)device.byState != NetFinalVar.NET_STORAGE_DEV_RUNNING) {//物理硬盘运行状态
|
System.out.println("物理硬盘运行状态:"+arState[(int)device.byState]); // 状态
|
continue;
|
}
|
if (device.emPreDiskCheck != EM_STORAGE_DISK_PREDISKCHECK.EM_STORAGE_DISK_PREDISKCHECK_UNKNOWN) {
|
System.out.println("device.emPreDiskCheck " + device.emPreDiskCheck);
|
}
|
}
|
}
|
}
|
//8、移动侦测配置
|
|
|
public void SetVideoAnalyseModule() {
|
int channel = 0;
|
String command = NetSDKLib.CFG_CMD_MOTIONDETECT;
|
|
CFG_MOTION_INFO msg = new CFG_MOTION_INFO();
|
|
// 获取
|
if (ToolKits.GetDevConfig(loginHandle, channel, command, msg)) {
|
System.out.println("bEnable:"+msg.bEnable);
|
msg.bEnable = 1;
|
|
if (ToolKits.SetDevConfig(loginHandle, channel, command, msg)) {
|
System.out.println("设置使能成功!");
|
} else {
|
System.err.println("设置使能失败!" + ToolKits.getErrorCode());
|
}
|
}
|
}
|
|
/**
|
* StartListen
|
*/
|
public static void startListenAlarm() {
|
/// Alarm CallBack
|
netSdk.CLIENT_SetDVRMessCallBack(MessCallBack.getInstance(), null);
|
|
boolean b
|
= netSdk.CLIENT_StartListenEx(loginHandle);
|
if(!b){
|
System.err.println("CLIENT_StartListenEx Failed." + ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* StopListen
|
*/
|
public static void stopListenAlarm() {
|
|
boolean b
|
= netSdk.CLIENT_StopListen(loginHandle);
|
if(!b){
|
System.err.println("CLIENT_StopListen Failed." + ToolKits.getErrorCode());
|
}
|
}
|
|
// 获取摄像机通道状态
|
public void QueryChannelState() {
|
int nQueryType = NetSDKLib.NET_QUERY_GET_CAMERA_STATE;
|
|
// 入参
|
NetSDKLib.NET_IN_GET_CAMERA_STATEINFO stIn = new NetSDKLib.NET_IN_GET_CAMERA_STATEINFO();
|
stIn.bGetAllFlag = 1; // 1-true,查询所有摄像机状态
|
|
// 摄像机通道信息
|
int chnCount = m_stDeviceInfo.byChanNum; // 通道个数
|
NetSDKLib.NET_CAMERA_STATE_INFO[] cameraInfo = new NetSDKLib.NET_CAMERA_STATE_INFO[chnCount];
|
for(int i = 0; i < chnCount; i++) {
|
cameraInfo[i] = new NetSDKLib.NET_CAMERA_STATE_INFO();
|
}
|
|
// 出参
|
NetSDKLib.NET_OUT_GET_CAMERA_STATEINFO stOut = new NetSDKLib.NET_OUT_GET_CAMERA_STATEINFO();
|
stOut.nMaxNum = chnCount;
|
stOut.pCameraStateInfo = new Memory(cameraInfo[0].size() * chnCount);
|
stOut.pCameraStateInfo.clear(cameraInfo[0].size() * chnCount);
|
|
ToolKits.SetStructArrToPointerData(cameraInfo, stOut.pCameraStateInfo); // 将数组内存拷贝到Pointer
|
|
stIn.write();
|
stOut.write();
|
boolean bRet = netSdk.CLIENT_QueryDevInfo(loginHandle, nQueryType, stIn.getPointer(), stOut.getPointer(), null, 3000);
|
stIn.read();
|
stOut.read();
|
|
if(bRet) {
|
ToolKits.GetPointerDataToStructArr(stOut.pCameraStateInfo, cameraInfo); // 将 Pointer 的内容 输出到 数组
|
|
System.out.println("查询到的摄像机通道状态有效个数：" + stOut.nValidNum);
|
|
for(int i = 0; i < stOut.nValidNum; i++) {
|
System.out.println("通道号：" + cameraInfo[i].nChannel);
|
//对应 EM_CAMERA_STATE_TYPE
|
System.out.println("连接状态：" +cameraInfo[i].emConnectionState);
|
}
|
} else {
|
System.err.println("QueryDev Failed!" + ToolKits.getErrorCode());
|
}
|
}
|
private static class MessCallBack implements NetSDKLib.fMessCallBack {
|
private MessCallBack() {
|
}
|
|
private static class MessCallBackHolder {
|
private static HaoyunDemo.MessCallBack msgCallBack = new HaoyunDemo.MessCallBack();
|
}
|
|
public static MessCallBack getInstance() {
|
return MessCallBack.MessCallBackHolder.msgCallBack;
|
}
|
|
public boolean invoke(int lCommand, final NetSDKLib.LLong lLoginID,
|
Pointer pStuEvent, int dwBufLen, String strDeviceIP,
|
NativeLong nDevicePort, Pointer dwUser) {
|
|
|
if (pStuEvent == null || dwBufLen <= 0) {
|
return false;
|
}
|
|
/// 具体事件类,
|
switch (lCommand) {
|
case NetSDKLib.NET_ALARM_VIDEOBLIND: // alarm of video blind 视频遮挡事件
|
{
|
NetSDKLib.ALARM_VIDEO_BLIND_INFO msg = new NetSDKLib.ALARM_VIDEO_BLIND_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("视频遮挡事件");
|
System.out.println("nAction : " + msg.nAction);
|
System.out.println("Time : " + msg.stuTime.toString());
|
break;
|
}
|
case NetSDKLib.NET_ALARM_AUDIO_ANOMALY: // 音频异常事件
|
{
|
ALARM_AUDIO_ANOMALY msg= new ALARM_AUDIO_ANOMALY();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("音频异常事件");
|
System.out.println("nAction : " + msg.dwAction);
|
System.out.println("dwChannelID : " + msg.dwChannelID);
|
System.out.println("nDecibel : " + msg.nDecibel);
|
System.out.println("nFrequency : " + msg.nFrequency);
|
break;
|
}
|
case NetSDKLib.NET_EVENT_VIDEOABNORMALDETECTION: // 视频异常事件 对应ALARM_VIDEOABNORMAL_DETECTION_INFO
|
{
|
NetSDKLib.ALARM_VIDEOABNORMAL_DETECTION_INFO msg= new NetSDKLib.ALARM_VIDEOABNORMAL_DETECTION_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("视频异常事件");
|
System.out.println("nChannelID : " + msg.nChannelID);
|
System.out.println("PTS : " + msg.PTS);
|
System.out.println("UTC : " + msg.UTC);
|
System.out.println("nEventAction : " + msg.nEventAction);//事件动作,0表示脉冲事件,1表示持续性事件开始,2表示持续性事件结束;
|
System.out.println("nType : " + msg.nType);//检测类型,0-视频丢失, 1-视频遮挡, 2-画面冻结, 3-过亮, 4-过暗, 5-场景变化
|
System.out.println("nValue : " + msg.nValue);//检测值,值越高表示视频质量越差, GB30147定义
|
break;
|
}
|
default:
|
System.out.println("lCommand:"+lCommand);
|
break;
|
}
|
|
return true;
|
|
}
|
|
}
|
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();
|
menu.addItem((new CaseMenu.Item(this , "下载录像" , "downloadRecordFile")));
|
menu.addItem((new CaseMenu.Item(this , "录像锁状态查询" , "DownloadRecordByFile")));
|
menu.addItem((new CaseMenu.Item(this , "录像文件加锁/解锁" , "lockRecordByFile")));
|
menu.addItem((new CaseMenu.Item(this , "查询录像视频" , "queryRecordFile")));
|
menu.addItem((new CaseMenu.Item(this , "获取设备软件版本" , "QueryDevDeviceVersionStateTest")));
|
menu.addItem((new CaseMenu.Item(this , "分辨率、码流、音视频编码" , "getDeviceEncode"))); // 是否有声音
|
menu.addItem((new CaseMenu.Item(this , "阵列信息 硬盘容量" , "GetIVSSDisk")));
|
menu.addItem((new CaseMenu.Item(this , "移动侦测配置" , "SetVideoAnalyseModule")));
|
menu.addItem((new CaseMenu.Item(this , "通道是否在线" , "QueryChannelState")));
|
menu.addItem((new CaseMenu.Item(this , "开始监听" , "startListenAlarm")));
|
menu.addItem((new CaseMenu.Item(this , "停止监听" , "stopListenAlarm")));
|
menu.run();
|
}
|
|
public static void main(String[] args) {
|
HaoyunDemo haoyunDemo=new HaoyunDemo();
|
System.out.println("输入 ip,port,user, password 格式如：172.11.243.30,37777,admin,admin123");
|
String s
|
= sc.nextLine();
|
String[] split
|
= s.split(",");
|
InitTest(split[0],Integer.parseInt(split[1]),split[2],split[3]);
|
haoyunDemo.RunTest();
|
LoginOut();
|
}
|
}
|
