package com.netsdk.demo.customize; import com.netsdk.demo.util.CaseMenu; import com.netsdk.lib.NetSDKLib; import com.netsdk.lib.ToolKits; import com.netsdk.lib.callback.impl.DefaultDisconnectCallback; import com.netsdk.lib.callback.impl.DefaultHaveReconnectCallBack; import com.netsdk.lib.enumeration.ENUMERROR; import com.sun.jna.Memory; import com.sun.jna.Native; 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.Calendar; import java.util.Date; import java.util.Scanner; import static com.netsdk.lib.Utils.getOsPrefix; /** * @author 291189 * @version 1.0 * @description ERR231201077 * @date 2023/12/6 14:29 */ public class GetDownloadPosDemo { // SDk对象初始化 public static final NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE; public static final NetSDKLib configsdk = NetSDKLib.CONFIG_INSTANCE; // 判断是否初始化 private static boolean bInit = false; // 判断log是否打开 private static boolean bLogOpen = false; // 设备信息 private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex(); // 登录句柄 private NetSDKLib.LLong m_hLoginHandle = new NetSDKLib.LLong(0); // 回调函数需要是静态的，防止被系统回收 // 断线回调 private static NetSDKLib.fDisConnect disConnectCB = DefaultDisconnectCallback.getINSTANCE(); // 重连回调 private static NetSDKLib.fHaveReConnect haveReConnectCB = DefaultHaveReconnectCallBack.getINSTANCE(); private NetSDKLib.LLong hygrothermographHandle = new NetSDKLib.LLong(0); private NetSDKLib.LLong attachHandle=new NetSDKLib.LLong(0); // 编码格式 public static String encode; static { String osPrefix = getOsPrefix(); if (osPrefix.toLowerCase().startsWith("win32-amd64")) { encode = "GBK"; } else if (osPrefix.toLowerCase().startsWith("linux-amd64")) { encode = "UTF-8"; } } /** * 获取当前时间 */ public static String GetDate() { SimpleDateFormat simpleDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); return simpleDate.format(new java.util.Date()).replaceAll("[^0-9]", "-"); } /** * 初始化SDK库 */ public static boolean Init() { bInit = netsdk.CLIENT_Init(disConnectCB, null);// 进程启动时，初始化一次 if (!bInit) { System.out.println("Initialize SDK failed"); return false; } // 配置日志 GetDownloadPosDemo.enableLog(); // 设置断线重连回调接口, 此操作为可选操作，但建议用户进行设置 netsdk.CLIENT_SetAutoReconnect(haveReConnectCB, null); // 设置登录超时时间和尝试次数，可选 // 登录请求响应超时时间设置为3S int waitTime = 3000; // 登录时尝试建立链接 1 次 int tryTimes = 1; netsdk.CLIENT_SetConnectTime(waitTime, tryTimes); // 设置更多网络参数， NET_PARAM 的nWaittime ， nConnectTryNum 成员与 CLIENT_SetConnectTime // 接口设置的登录设备超时时间和尝试次数意义相同,可选 NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM(); // 登录时尝试建立链接的超时时间 netParam.nConnectTime = 10000; // 设置子连接的超时时间 netParam.nGetConnInfoTime = 3000; netsdk.CLIENT_SetNetworkParam(netParam); return true; } /** * 打开 sdk log */ private static void enableLog() { NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO(); File path = new File("sdklog/"); if (!path.exists()) path.mkdir(); // 这里的log保存地址依据实际情况自己调整 String logPath = path.getAbsoluteFile().getParent() + "\\sdklog\\" + "sdklog" + GetDate() + ".log"; setLog.nPrintStrategy = 0; setLog.bSetFilePath = 1; System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length); System.out.println(logPath); setLog.bSetPrintStrategy = 1; bLogOpen = netsdk.CLIENT_LogOpen(setLog); if (!bLogOpen) System.err.println("Failed to open NetSDK log"); } /** * 高安全登录 */ public void loginWithHighLevel() { // 输入结构体参数 NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() { { szIP = m_strIpAddr.getBytes(); nPort = m_nPort; szUserName = m_strUser.getBytes(); szPassword = m_strPassword.getBytes(); } }; // 输出结构体参数 NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY(); // 写入sdk m_hLoginHandle = netsdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam); if (m_hLoginHandle.longValue() == 0) { System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", m_strIpAddr, m_nPort, ToolKits.getLastError()); } else { deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息 System.out.println("Login Success"); System.out.println("Device Address：" + m_strIpAddr); System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道"); } } /** * 退出 */ public void logOut() { if (m_hLoginHandle.longValue() != 0) { netsdk.CLIENT_Logout(m_hLoginHandle); System.out.println("LogOut Success"); } } /** * 清理sdk环境并退出 */ public static void cleanAndExit() { if (bLogOpen) { netsdk.CLIENT_LogClose(); // 关闭sdk日志打印 } netsdk.CLIENT_Cleanup(); // 进程关闭时，调用一次 System.exit(0); } public static Pointer GetStringToPointer(String src, String charset) { Pointer pointer = null; try { byte[] b = src.getBytes(charset); pointer = new Memory(b.length + 1); pointer.clear(b.length + 1); pointer.write(0, b, 0, b.length); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } return pointer; } /** * 开始下载录像 */ NetSDKLib.LLong n_hDownLoadHandle =new NetSDKLib.LLong(); static Scanner sc = new Scanner(System.in); private static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 回调建议写成单例模式, 回调里处理数据，需要另开线程 // 下载进度回调 public static class DownloadPosCallBack implements NetSDKLib.fTimeDownLoadPosCallBack { private DownloadPosCallBack() {} private static class DownloadPosCallBackHolder { private static final DownloadPosCallBack posCB = new DownloadPosCallBack(); } public static final DownloadPosCallBack getInstance() { return DownloadPosCallBackHolder.posCB; } @Override public void invoke(NetSDKLib.LLong lPlayHandle, int dwTotalSize, int dwDownLoadSize, int index, NetSDKLib.NET_RECORDFILE_INFO.ByValue recordfileinfo, Pointer dwUser) { //System.out.println("DownloadPosCallBack dwTotalSize： " + dwTotalSize + " dwDownLoadSize： " + dwDownLoadSize); } } 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)); } 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; } } /** * 下载录像 */ 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()); } } 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(m_hLoginHandle, 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 class IntStructure extends NetSDKLib.SdkStructure{ public int size; } public void getDownloadPos(){ IntStructure nTotalSize=new IntStructure(); Pointer nTotalSizePointer=new Memory(nTotalSize.size()); nTotalSizePointer.clear(nTotalSize.size()); ToolKits.SetStructDataToPointer(nTotalSize,nTotalSizePointer,0); IntStructure nDownLoadSize=new IntStructure(); Pointer nDownLoadSizePointer=new Memory(nDownLoadSize.size()); nDownLoadSizePointer.clear(nDownLoadSize.size()); ToolKits.SetStructDataToPointer(nDownLoadSize,nDownLoadSizePointer,0); boolean b = netsdk.CLIENT_GetDownloadPos(n_hDownLoadHandle, nTotalSizePointer, nDownLoadSizePointer); if(b ) { System.out.println("CLIENT_GetDownloadPos success"); ToolKits.GetPointerDataToStruct(nTotalSizePointer,0,nTotalSize); ToolKits.GetPointerDataToStruct(nDownLoadSizePointer,0,nDownLoadSize); Native.free(Pointer.nativeValue(nTotalSizePointer));//清理内存 Pointer.nativeValue(nTotalSizePointer, 0); Native.free(Pointer.nativeValue(nDownLoadSizePointer));//清理内存 Pointer.nativeValue(nDownLoadSizePointer, 0); //总文件大小 System.out.println(" nTotalSize:"+nTotalSize.size); //已下载文件大小 System.out.println(" nDownLoadSize:"+nDownLoadSize.size); } else { System.err.println("CLIENT_GetDownloadPos Failed!" + ToolKits.getLastError() ); } } /** * 设置回放时的码流类型 * @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(m_hLoginHandle, emType, steamType.getPointer()); } 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, "查询录像下载进度", "getDownloadPos")); menu.run(); } // 配置登陆地址，端口，用户名，密码 private String m_strIpAddr = "172.10.2.251"; private int m_nPort = 37777; private String m_strUser = "admin"; private String m_strPassword = "admin123"; public static void main(String[] args) { GetDownloadPosDemo demo=new GetDownloadPosDemo(); demo.InitTest(); demo.RunTest(); demo.EndTest(); } /** * 初始化测试 */ public void InitTest() { Init(); this.loginWithHighLevel(); } /** * 结束测试 */ public void EndTest() { System.out.println("End Test"); this.logOut(); // 登出设备 System.out.println("See You..."); cleanAndExit(); // 清理资源并退出 } }