package com.netsdk.demo.customize;
|
|
import com.netsdk.lib.LastError;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.NET_TIME;
|
import com.netsdk.lib.ToolKits;
|
import com.sun.jna.Native;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
import javax.swing.*;
|
import javax.swing.border.Border;
|
import javax.swing.border.EmptyBorder;
|
import javax.swing.border.TitledBorder;
|
import java.awt.*;
|
import java.awt.event.*;
|
import java.io.File;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
|
/**
|
* 回放Demo
|
*/
|
class PlayBackFrame {
|
static NetSDKLib NetSdk = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib ConfigSdk = NetSDKLib.CONFIG_INSTANCE;
|
|
private SDKEnvironment sdkEnv;
|
|
// 登录参数
|
private String m_strIp = "172.13.138.12";
|
private Integer m_nPort = new Integer("37777");
|
private String m_strUser = "admin";
|
private String m_strPassword = "hzci202210";
|
// 设备信息
|
private NetSDKLib.NET_DEVICEINFO m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO();
|
|
private boolean m_playFlag = false; // 播放标志位
|
private boolean m_pauseFlag = true; // 暂停标志位
|
|
private boolean m_dingweiFlag = false; // 定位志位 播放
|
|
|
private LLong m_hLoginHandle = new LLong(0); // 登录句柄
|
private LLong m_hPlayHandle = new LLong(0); // 回放句柄
|
private LLong m_hDownLoadHandle = new LLong(0); // 下载录像句柄
|
|
private int m_streamType; // 码流类型
|
private int m_recordType; // 录像类型
|
private Integer m_channel = new Integer(0); // 通道号
|
private NetSDKLib.NET_TIME m_startTime = new NetSDKLib.NET_TIME(); // 开始时间
|
private NetSDKLib.NET_TIME m_stopTime = new NetSDKLib.NET_TIME(); // 结束时间
|
|
private DownLoadPosCallBack m_PlayBackDownLoadPos = new DownLoadPosCallBack(); // 回放数据下载进度
|
private DataCallBack m_dataCallBack = new DataCallBack(); // 回放数据回调
|
private TimeDownLoadPosCallBack m_DownLoadPos = new TimeDownLoadPosCallBack(); // 录像下载进度
|
private TimeDownLoadDataCallBack m_DownLoadData = new TimeDownLoadDataCallBack(); // 录像下载数据回调
|
|
/**
|
* PlayDemo 构造
|
*/
|
public PlayBackFrame() {
|
sdkEnv = new SDKEnvironment();
|
sdkEnv.init();
|
|
SwingUtilities.invokeLater(new Runnable() {
|
public void run() {
|
InitPlayBackFrame("PlayBackByTime");
|
}
|
});
|
}
|
|
public void InitPlayBackFrame(String title) {
|
playFrame = new JFrame(title);
|
playFrame.setSize(800, 650);
|
playFrame.setLayout(new BorderLayout());
|
playFrame.setLocationRelativeTo(null);
|
playFrame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
|
playFrame.setVisible(true);
|
|
loginJPanel = new LoginPanel(); // 登录面板
|
controlPanel = new ControlPanel(); // 主控制面板
|
playWindow = new PlayWindow(); // 播放面板
|
|
playFrame.add(controlPanel, BorderLayout.EAST);
|
playFrame.add(loginJPanel, BorderLayout.NORTH);
|
playFrame.add(playWindow, BorderLayout.CENTER);
|
|
WindowAdapter closeWindowAdapter = new WindowAdapter() {
|
public void windowClosing(WindowEvent e) {
|
System.out.println("PlayBack Window Closing");
|
LoginOutButtonPerformed(null);
|
sdkEnv.cleanup();
|
playFrame.dispose();
|
}
|
};
|
playFrame.addWindowListener(closeWindowAdapter);
|
}
|
|
/**
|
* 登录面板
|
*/
|
private class LoginPanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public LoginPanel() {
|
loginBtn = new JButton("登入");
|
logoutBtn = new JButton("登出");
|
nameLabel = new JLabel("用户名");
|
passwordLabel = new JLabel("密码");
|
nameTextArea = new JTextField(m_strUser, 8);
|
passwordTextArea = new JPasswordField(m_strPassword, 8);
|
ipLabel = new JLabel("设备地址");
|
portLabel = new JLabel("端口号");
|
ipTextArea = new JTextField(m_strIp, 15);
|
portTextArea = new JTextField(String.valueOf(m_nPort.intValue()), 6);
|
|
setLayout(new FlowLayout());
|
setBorderEx(this, "登录", 2);
|
|
add(ipLabel);
|
add(ipTextArea);
|
add(portLabel);
|
add(portTextArea);
|
add(nameLabel);
|
add(nameTextArea);
|
add(passwordLabel);
|
add(passwordTextArea);
|
add(loginBtn);
|
add(logoutBtn);
|
|
logoutBtn.setEnabled(false);
|
// 登录按钮. 监听事件
|
loginBtn.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
LoginButtonPerformed(e);
|
}
|
});
|
|
// 登出按钮. 监听事件
|
logoutBtn.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
LoginOutButtonPerformed(e);
|
}
|
});
|
}
|
}
|
|
/**
|
* 主控制面板
|
*/
|
private class ControlPanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public ControlPanel() {
|
setBorderEx(this, "控制面板", 2);
|
Dimension dim = getPreferredSize();
|
dim.width = 250;
|
setPreferredSize(dim);
|
|
// 设置时间
|
ctrlTimeBarPanel = new TimePanel();
|
|
// 录像信息配置
|
recordInfoPanel = new RecordInfoPanel();
|
|
// 回放操作
|
ctrlPanel = new PlayBackCtrlPanel();
|
|
// 下载操作
|
downLoadRecordPanel = new DownLoadRecordPanel();
|
|
osdButton = new JButton("OSD Time");
|
|
JTabbedPane ctrlJTabbedPane = new JTabbedPane();
|
ctrlJTabbedPane.addTab("回放", ctrlPanel);
|
ctrlJTabbedPane.addTab("下载", downLoadRecordPanel);
|
|
add(ctrlTimeBarPanel, BorderLayout.NORTH);
|
add(recordInfoPanel, BorderLayout.CENTER);
|
add(ctrlJTabbedPane, BorderLayout.CENTER);
|
add(osdButton, BorderLayout.SOUTH);
|
|
osdButton.addActionListener(new ActionListener() {
|
@Override
|
public void actionPerformed(ActionEvent e) {
|
NET_TIME OsdTime = new NET_TIME();
|
NET_TIME StartTime = new NET_TIME();
|
NET_TIME EndTime = new NET_TIME();
|
boolean ret = NetSdk.CLIENT_GetPlayBackOsdTime(m_hPlayHandle, OsdTime, StartTime, EndTime);
|
if (!ret) {
|
System.err.println("Get OSD Time Failed! "+ ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("OSD Time: " + OsdTime.toStringTime());
|
}
|
});
|
}
|
}
|
|
/**
|
* 控制面板 - 回放操作
|
*/
|
private class PlayBackCtrlPanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public PlayBackCtrlPanel() {
|
setLayout(new BorderLayout());
|
|
// 播放按钮
|
JPanel ctlPanel = new JPanel();
|
ctlPanel.setBorder(new EmptyBorder(6, 5, 5, 5));
|
ctlPanel.setLayout(new GridLayout(0, 1));
|
ctlPanel.add(playButton);
|
ctlPanel.add(pauseButton);
|
ctlPanel.add(normalButton);
|
ctlPanel.add(fastButton);
|
ctlPanel.add(slowButton);
|
ctlPanel.add(playStartButton);
|
/// 按钮操作事件
|
playButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
// 播放
|
if (!m_playFlag) {
|
StartPlayBack();
|
} else {
|
StopPlayBack();
|
}
|
}
|
});
|
pauseButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
PausePlayBack(m_pauseFlag);
|
m_pauseFlag = !m_pauseFlag;
|
}
|
});
|
normalButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
NormalPlayBack();
|
}
|
});
|
fastButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
FastPlayBack();
|
}
|
});
|
slowButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
SlowPlayBack();
|
}
|
});
|
playStartButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
// PausePlayBack(m_pauseFlag);
|
PlayStartBack();
|
}
|
});
|
add(ctlPanel, BorderLayout.CENTER);
|
}
|
}
|
|
/**
|
* 控制面板 - 录像下载操作
|
* 按时间下载录像
|
*/
|
private class DownLoadRecordPanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public DownLoadRecordPanel() {
|
setBorder(new EmptyBorder(5, 5, 5, 5));
|
setLayout(new BorderLayout());
|
|
downRecordButton = new JButton("下载录像");
|
stopDonwloadButton = new JButton("停止下载");
|
downLoadProgressLabel = new JLabel("进度:");
|
downLoadProgressBar = new JProgressBar();
|
|
JPanel progressPanel = new JPanel();
|
progressPanel.setLayout(new FlowLayout());
|
progressPanel.add(downLoadProgressLabel);
|
progressPanel.add(downLoadProgressBar);
|
|
JPanel bottonPanel = new JPanel();
|
bottonPanel.setLayout(new GridLayout(0, 1));
|
bottonPanel.add(downRecordButton);
|
bottonPanel.add(stopDonwloadButton);
|
|
add(bottonPanel, BorderLayout.SOUTH);
|
add(progressPanel, BorderLayout.NORTH);
|
|
// 下载按钮事件
|
downRecordButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
DownLoadRecordFile();
|
// DownLoadRecordFileEx();
|
}
|
});
|
|
// 停止下载事件
|
stopDonwloadButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
StopDownLoadRecord();
|
}
|
});
|
}
|
}
|
|
/**
|
* 控制面板 - 时间配置
|
*/
|
private class TimePanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public TimePanel() {
|
setBorderEx(this, "时间设置", 2);
|
GridBagLayout layout = new GridBagLayout();
|
GridBagConstraints gc = new GridBagConstraints();
|
setLayout(layout);
|
|
String[] timeStrings = {"年", "月", "日", "时", "分", "秒"};
|
String[] strStartTime = {"2023", "5", "16", "10", "0", "0"};
|
String[] strStopTime = {"2023", "5", "16", "15", "10", "0"};
|
for (int i = 0; i < timeStrings.length; ++i) {
|
startTimeJLabels[i] = new JLabel(timeStrings[i]);
|
stopTimeJLabels[i] = new JLabel(timeStrings[i]);
|
startTextFields[i] = new JTextField(strStartTime[i], 4);
|
stopTextFields[i] = new JTextField(strStopTime[i], 4);
|
}
|
//// first row ////
|
gc.gridy = 0;
|
gc.gridx = 0;
|
gc.fill = GridBagConstraints.NONE;
|
Insets lastInsets = new Insets(2, 2, 2, 2);
|
gc.insets = lastInsets;
|
layout.setConstraints(startLabel, gc);
|
add(startLabel);
|
|
//// second row ////
|
gc.gridy = 1;
|
for (int j = 0; j < 3; j++) {
|
gc.gridx = j * 2;
|
gc.fill = GridBagConstraints.NONE;
|
layout.setConstraints(startTextFields[j], gc);
|
add(startTextFields[j]);
|
|
gc.gridx = 2 * j + 1;
|
layout.setConstraints(startTimeJLabels[j], gc);
|
add(startTimeJLabels[j]);
|
}
|
|
//// third row ////
|
gc.gridy = 2;
|
for (int j = 3; j < 6; j++) {
|
gc.gridx = j * 2 - 6;
|
layout.setConstraints(startTextFields[j], gc);
|
add(startTextFields[j]);
|
|
gc.gridx = 2 * j + 1 - 6;
|
layout.setConstraints(startTimeJLabels[j], gc);
|
add(startTimeJLabels[j]);
|
}
|
|
//// fourth row ///
|
gc.gridy = 3;
|
gc.gridx = 0;
|
layout.setConstraints(stopLabel, gc);
|
add(stopLabel);
|
|
gc.gridy = 4;
|
for (int j = 0; j < 3; j++) {
|
gc.gridx = j * 2;
|
layout.setConstraints(stopTextFields[j], gc);
|
add(stopTextFields[j]);
|
|
gc.gridx = 2 * j + 1;
|
layout.setConstraints(stopTimeJLabels[j], gc);
|
add(stopTimeJLabels[j]);
|
}
|
|
//// third row ////
|
gc.gridy = 5;
|
for (int j = 3; j < 6; j++) {
|
gc.gridx = j * 2 - 6;
|
layout.setConstraints(stopTextFields[j], gc);
|
add(stopTextFields[j]);
|
|
gc.gridx = 2 * j + 1 - 6;
|
layout.setConstraints(stopTimeJLabels[j], gc);
|
add(stopTimeJLabels[j]);
|
}
|
}
|
}
|
|
/**
|
* 控制面板 - 录像信息配置
|
*/
|
private class RecordInfoPanel extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
public RecordInfoPanel() {
|
System.out.println("Record Info : " + getPreferredSize());
|
setBorder(new TitledBorder("录像配置"));
|
// 参数
|
String[] strStreamType = {"0-主辅码流", "1-主码流", "2-辅码流"};
|
String[] strRecordType = {"0-所有录像", "1-普通录像", "2-外部报警", "3-动检报警"};
|
|
JPanel paramJPanel = new JPanel();
|
paramJPanel.setLayout(new GridLayout(0, 2));
|
paramJPanel.setBorder(new EmptyBorder(10, 10, 10, 10));
|
|
channelLabel = new JLabel("通道号:");
|
chanelTextArea = new JTextField("0", 2);
|
streamTypeLabel = new JLabel("码流类型:");
|
streamTypeComboBox = new JComboBox(strStreamType);
|
recordTypeLabel = new JLabel("录像类型:");
|
recordTypeComboBox = new JComboBox(strRecordType);
|
|
streamTypeComboBox.addItemListener(new ItemListener() {
|
public void itemStateChanged(ItemEvent e) {
|
m_streamType = streamTypeComboBox.getSelectedIndex();
|
System.out.println("Steam ItemEvent: " + m_streamType);
|
}
|
});
|
|
recordTypeComboBox.addItemListener(new ItemListener() {
|
public void itemStateChanged(ItemEvent e) {
|
m_recordType = recordTypeComboBox.getSelectedIndex();
|
System.out.println("Record ItemEvent: " + m_recordType);
|
}
|
});
|
|
paramJPanel.add(channelLabel);
|
paramJPanel.add(chanelTextArea);
|
paramJPanel.add(streamTypeLabel);
|
paramJPanel.add(streamTypeComboBox);
|
paramJPanel.add(recordTypeLabel);
|
paramJPanel.add(recordTypeComboBox);
|
|
add(paramJPanel, BorderLayout.CENTER);
|
}
|
}
|
|
/**
|
* 播放面板
|
*/
|
private class PlayWindow extends JPanel {
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
private Pointer m_win32;
|
|
public PlayWindow() {
|
setLayout(new BorderLayout());
|
setBorderEx(this, "播放窗口", 2);
|
|
panelPlayBack = new java.awt.Panel();
|
playSlider = new JSlider(0, 100, 0);
|
|
// 播放容器设置
|
panelPlayBack.setBackground(new java.awt.Color(153, 240, 255));
|
panelPlayBack.setForeground(new java.awt.Color(0, 0, 0));
|
panelPlayBack.setBounds(10, 20, 390, 300);
|
panelPlayBack.setSize(500, 500);
|
|
// 进度条
|
playSlider.setPaintLabels(true);
|
playSlider.setPaintTicks(true);
|
playSlider.setMajorTickSpacing(10);
|
playSlider.setMinorTickSpacing(1);
|
playSlider.setSnapToTicks(true); // 让滑块滑动刻度的整数处
|
|
JPanel sliderJPanel = new JPanel();
|
setBorderEx(sliderJPanel, "播放进度", 2);
|
sliderJPanel.setLayout(new BoxLayout(sliderJPanel, BoxLayout.Y_AXIS));
|
sliderJPanel.add(playSlider);
|
|
add(sliderJPanel, BorderLayout.SOUTH);
|
add(panelPlayBack, BorderLayout.CENTER);
|
|
}
|
|
// 返回 windows 句柄
|
public Pointer getHWNDofFrame() {
|
m_win32 = Native.getComponentPointer(panelPlayBack);
|
return m_win32;
|
}
|
}
|
|
/**
|
* NetSDK 库初始化
|
*/
|
private class SDKEnvironment {
|
|
private boolean bInit = false;
|
private boolean bLogopen = false;
|
|
private DisConnect disConnect = new DisConnect(); // 设备断线通知回调
|
private HaveReConnect haveReConnect = new HaveReConnect(); // 网络连接恢复
|
|
// 初始化
|
public boolean init() {
|
|
// SDK 库初始化, 并设置断线回调
|
bInit = NetSdk.CLIENT_Init(disConnect, null);
|
if (!bInit) {
|
System.err.println("Initialize SDK failed");
|
return false;
|
}
|
|
// 打开日志，可选
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
|
File path = new File(".");
|
String logPath = path.getAbsoluteFile().getParent() + "\\sdk_log\\PlayBackByTime_" + System.currentTimeMillis() + ".log";
|
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
bLogopen = NetSdk.CLIENT_LogOpen(setLog);
|
if (!bLogopen) {
|
System.err.println("Failed to open NetSDK log !!!");
|
}
|
|
// 获取版本, 可选操作
|
System.out.printf("NetSDK Version [%d]\n", NetSdk.CLIENT_GetSDKVersion());
|
|
// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK内部会自动进行重连操作
|
// 此操作为可选操作，但建议用户进行设置
|
NetSdk.CLIENT_SetAutoReconnect(haveReConnect, null);
|
|
// 设置登录超时时间和尝试次数 , 此操作为可选操作
|
int waitTime = 5000; // 登录请求响应超时时间设置为 5s
|
int tryTimes = 3; // 登录时尝试建立链接3次
|
NetSdk.CLIENT_SetConnectTime(waitTime, tryTimes);
|
|
// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime
|
// 接口设置的登录设备超时时间和尝试次数意义相同
|
// 此操作为可选操作
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
netParam.nConnectTime = 10000; // 登录时尝试建立链接的超时时间
|
NetSdk.CLIENT_SetNetworkParam(netParam);
|
|
return true;
|
}
|
|
// 清除环境
|
public void cleanup() {
|
if (bLogopen) {
|
NetSdk.CLIENT_LogClose();
|
}
|
|
if (bInit) {
|
NetSdk.CLIENT_Cleanup();
|
}
|
}
|
|
// 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
|
public class DisConnect implements NetSDKLib.fDisConnect {
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%s] Port[%d] Disconnect!\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
// 网络连接恢复，设备重连成功回调
|
// 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK会调用该函数
|
public class HaveReConnect implements NetSDKLib.fHaveReConnect {
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
|
}
|
}
|
}
|
|
// 回放进度回调
|
public class DownLoadPosCallBack implements NetSDKLib.fDownLoadPosCallBack {
|
public void invoke(LLong lPlayHandle, int dwTotalSize, int dwDownLoadSize, Pointer dwUser) {
|
// System.out.println("PlayBack DownLoadCallback: [ " + dwTotalSize + " ]" + " [ " + dwDownLoadSize +" ]");
|
if (playPos != dwDownLoadSize) {
|
playPos = dwDownLoadSize;
|
playTotal=dwTotalSize;
|
// System.out.println("PlayBack DownLoadCallback: [ " + dwTotalSize + " ]" + " [ " + dwDownLoadSize +" ]");
|
System.out.println("Pos " + dwDownLoadSize*100/dwTotalSize);
|
System.out.println("playPos:"+playPos);
|
System.out.println("dwDownLoadSize:"+dwDownLoadSize);
|
System.out.println("dwTotalSize:"+dwTotalSize);
|
playSlider.setValue(dwDownLoadSize*100/dwTotalSize);
|
if (-1 == dwDownLoadSize) {
|
JOptionPane.showMessageDialog(playFrame, "回放结束");
|
playSlider.setValue(100);
|
}
|
}
|
}
|
}
|
|
// 回放数据回调
|
public class DataCallBack implements NetSDKLib.fDataCallBack {
|
public int invoke(LLong lRealHandle, int dwDataType, Pointer pBuffer, int dwBufSize, Pointer dwUser) {
|
// System.out.println("PlayBack DataCallBack [ " + dwUser +" ]");
|
return 1;
|
}
|
}
|
|
// 按时间下载进度回调
|
public class TimeDownLoadPosCallBack implements NetSDKLib.fTimeDownLoadPosCallBack {
|
public void invoke(LLong lLoginID, int dwTotalSize, int dwDownLoadSize, int index, NetSDKLib.NET_RECORDFILE_INFO.ByValue recordfileinfo, Pointer dwUser) {
|
if (downloadPos != dwDownLoadSize) {
|
downloadPos = dwDownLoadSize;
|
System.out.println("Download Pos: [ " + dwTotalSize + " ]" + " [ " + dwDownLoadSize + " ]");
|
int pos = dwDownLoadSize * 100 / dwTotalSize;
|
System.out.println("Current Pos: " + pos);
|
downLoadProgressBar.setValue(pos);
|
if (-1 == dwDownLoadSize) {
|
StopDownLoadRecord();
|
downLoadProgressBar.setValue(100);
|
System.out.println("Download finished");
|
JOptionPane.showMessageDialog(playFrame, "下载完成");
|
}
|
}
|
}
|
}
|
|
// 按时间下载数据回调
|
public class TimeDownLoadDataCallBack implements NetSDKLib.fDataCallBack {
|
public int invoke(LLong lRealHandle, int dwDataType, Pointer pBuffer, int dwBufSize, Pointer dwUser) {
|
// System.out.println("TimeDownLoadDataCallBack [ " + dwUser +" ]");
|
return 0;
|
}
|
}
|
|
//////////////////////// Border Extends //////////////////////
|
|
/**
|
* 设置边框
|
*/
|
private void setBorderEx(JComponent object, String title, int width) {
|
Border innerBorder = BorderFactory.createTitledBorder(title);
|
Border outerBorder = BorderFactory.createEmptyBorder(width, width, width, width);
|
object.setBorder(BorderFactory.createCompoundBorder(outerBorder, innerBorder));
|
}
|
|
//////////////////////// Operations of PlayBackFrame ////////////////
|
|
/**
|
* 更新回放参数
|
*/
|
private void updatePlayBackParams() {
|
// 通道号 、码流 、录像类型
|
m_channel = Integer.parseInt(chanelTextArea.getText());
|
|
m_streamType = streamTypeComboBox.getSelectedIndex();
|
m_recordType = recordTypeComboBox.getSelectedIndex();
|
|
// 开始时间
|
m_startTime.dwYear = Integer.parseInt(startTextFields[0].getText());
|
m_startTime.dwMonth = Integer.parseInt(startTextFields[1].getText());
|
m_startTime.dwDay = Integer.parseInt(startTextFields[2].getText());
|
m_startTime.dwHour = Integer.parseInt(startTextFields[3].getText());
|
m_startTime.dwMinute = Integer.parseInt(startTextFields[4].getText());
|
m_startTime.dwSecond = Integer.parseInt(startTextFields[5].getText());
|
// 结束时间
|
m_stopTime.dwYear = Integer.parseInt(stopTextFields[0].getText());
|
m_stopTime.dwMonth = Integer.parseInt(stopTextFields[1].getText());
|
m_stopTime.dwDay = Integer.parseInt(stopTextFields[2].getText());
|
m_stopTime.dwHour = Integer.parseInt(stopTextFields[3].getText());
|
m_stopTime.dwMinute = Integer.parseInt(stopTextFields[4].getText());
|
m_stopTime.dwSecond = Integer.parseInt(stopTextFields[5].getText());
|
|
System.out.println("Param m_channel: " + m_channel);
|
System.out.println("Param SteamType: " + m_streamType);
|
System.out.println("Param RecordType: " + m_recordType);
|
System.out.println("Param StartTime: " + m_startTime);
|
System.out.println("Param StopTime: " + m_stopTime);
|
}
|
|
/**
|
* 登录按钮
|
*/
|
private void LoginButtonPerformed(ActionEvent e) {
|
m_strIp = ipTextArea.getText();
|
m_nPort = Integer.parseInt(portTextArea.getText());
|
m_strUser = nameTextArea.getText();
|
m_strPassword = new String(passwordTextArea.getPassword());
|
|
System.out.println("设备地址：" + m_strIp
|
+ "\n端口号：" + m_nPort
|
+ "\n用户名：" + m_strUser
|
+ "\n密码：" + m_strPassword);
|
|
// 登录设备
|
IntByReference nError = new IntByReference(0);
|
m_hLoginHandle = NetSdk.CLIENT_LoginEx(m_strIp, m_nPort.intValue(), m_strUser, m_strPassword, 0, null, m_stDeviceInfo, nError);
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Login Device[%s] Port[%d]Failed. Last Error[%x]\n", m_strIp, m_nPort, NetSdk.CLIENT_GetLastError());
|
JOptionPane.showMessageDialog(playWindow, "登录失败");
|
} else {
|
System.out.println("Login Success [ " + m_strIp + " ]");
|
JOptionPane.showMessageDialog(playWindow, "登录成功");
|
logoutBtn.setEnabled(true);
|
loginBtn.setEnabled(false);
|
}
|
}
|
|
/**
|
* 登出按钮
|
*/
|
private void LoginOutButtonPerformed(ActionEvent e) {
|
if (m_hLoginHandle.longValue() != 0) {
|
System.out.println("LogOut Button Action");
|
// 确保关闭播放
|
StopPlayBack();
|
|
// 确保关闭下载
|
StopDownLoadRecord();
|
|
if (NetSdk.CLIENT_Logout(m_hLoginHandle)) {
|
System.out.println("Logout Success [ " + m_strIp + " ]");
|
m_hLoginHandle.setValue(0);
|
logoutBtn.setEnabled(false);
|
loginBtn.setEnabled(true);
|
}
|
}
|
}
|
|
/**
|
* 开启回放
|
*/
|
private void StartPlayBack() {
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Please Login First");
|
JOptionPane.showMessageDialog(playFrame, "请先登录");
|
return;
|
}
|
|
// 同一个登录句柄，回放和下载不能同时进行
|
if (m_hDownLoadHandle.longValue() != 0) {
|
JOptionPane.showMessageDialog(playFrame, "请先停止下载");
|
return;
|
}
|
|
updatePlayBackParams(); // 更新参数
|
|
// 设置回放时的码流类型
|
IntByReference steamType = new IntByReference(m_streamType);// 0-主辅码流,1-主码流,2-辅码流
|
int emType = NetSDKLib.EM_USEDEV_MODE.NET_RECORD_STREAM_TYPE;
|
|
boolean bret = NetSdk.CLIENT_SetDeviceMode(m_hLoginHandle, emType, steamType.getPointer());
|
if (!bret) {
|
System.err.printf("Set Stream Type Failed, Get last error [0x%x]\n", NetSdk.CLIENT_GetLastError());
|
}
|
|
// 设置回放时的录像文件类型
|
IntByReference emFileType = new IntByReference(m_recordType); // 所有录像 NET_RECORD_TYPE
|
emType = NetSDKLib.EM_USEDEV_MODE.NET_RECORD_TYPE;
|
bret = NetSdk.CLIENT_SetDeviceMode(m_hLoginHandle, emType, emFileType.getPointer());
|
if (!bret) {
|
System.err.printf("Set Record Type Failed, Get last error [0x%x]\n", NetSdk.CLIENT_GetLastError());
|
}
|
|
m_hPlayHandle = NetSdk.CLIENT_PlayBackByTimeEx(m_hLoginHandle, m_channel.intValue(), m_startTime, m_stopTime,
|
playWindow.getHWNDofFrame(), m_PlayBackDownLoadPos, null, m_dataCallBack, null);
|
if (m_hPlayHandle.longValue() == 0) {
|
int error = NetSdk.CLIENT_GetLastError();
|
System.err.printf("PlayBackByTimeEx Failed, Get last error [0x%x]\n", error);
|
switch (error) {
|
case LastError.NET_NO_RECORD_FOUND:
|
JOptionPane.showMessageDialog(playFrame, "查找不到录像");
|
break;
|
default:
|
JOptionPane.showMessageDialog(playFrame, "开启失败, 错误码：" + String.format("0x%x", error));
|
break;
|
}
|
} else {
|
// NetSdk.CLIENT_PausePlayBack(m_hPlayHandle, pauseFlag ? 0: 1); // 1 - 暂停 0 - 恢复
|
// pauseButton.setText(pauseFlag ? "暂停" : "播放");
|
// m_pauseFlag = !m_pauseFlag;
|
|
System.out.println("PlayBackByTimeEx Successed");
|
m_playFlag = true; // 打开播放标志位
|
playButton.setText("停止回放");
|
panelPlayBack.repaint();
|
panelPlayBack.setVisible(true);
|
}
|
}
|
|
/**
|
* 停止回放
|
*/
|
private void StopPlayBack() {
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
if (!NetSdk.CLIENT_StopPlayBack(m_hPlayHandle)) {
|
System.err.println("StopPlayBack Failed");
|
return;
|
}
|
|
m_hPlayHandle.setValue(0);
|
m_playFlag = false;
|
m_pauseFlag = true;
|
playPos = 0;
|
playButton.setText("开启回放");
|
pauseButton.setText("暂停");
|
panelPlayBack.repaint();
|
}
|
|
/**
|
* 回放暂停、播放
|
*
|
* @param pause true - 暂停; false - 播放
|
*/
|
private void PausePlayBack(boolean pause) {
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
NetSdk.CLIENT_PausePlayBack(m_hPlayHandle, pause ? 1 : 0); // 1 - 暂停 0 - 恢复
|
pauseButton.setText(pause ? "播放" : "暂停");
|
}
|
|
/**
|
* 正常速度播放
|
*/
|
private void NormalPlayBack() {
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
NetSdk.CLIENT_NormalPlayBack(m_hPlayHandle);
|
}
|
|
/**
|
* 快放
|
*/
|
private void FastPlayBack() {
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
NetSdk.CLIENT_FastPlayBack(m_hPlayHandle);
|
}
|
|
/**
|
* 慢放
|
*/
|
private void SlowPlayBack() {
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
NetSdk.CLIENT_SlowPlayBack(m_hPlayHandle);
|
}
|
// 定位回放起点
|
private void PlayStartBack( ){
|
/* if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}*/
|
int value
|
= playSlider.getValue();
|
|
long l = queryRecordFile();
|
|
|
int time=(int)l;
|
|
|
int l1
|
= value * time / 100;
|
int toatl=0;
|
|
int index=0;
|
|
int dingweiTime=0;
|
for(int i=0;i<fileTime.size();i++){
|
Integer integer = fileTime.get(i);
|
System.out.println("["+i+"]"+integer);
|
toatl+=integer;
|
Integer integer1
|
= fileStartTime.get(i);
|
System.out.println("file["+i+"]"+integer1);
|
dingweiTime+=integer1;
|
if(toatl>l1){
|
index=i;
|
|
break;
|
}
|
}
|
l1=l1+dingweiTime;
|
|
System.out.println("value:"+value);
|
System.out.println("l1:"+l1);
|
|
boolean b
|
= NetSdk.CLIENT_SeekPlayBack(m_hPlayHandle,l1 , 0xffffffff );
|
if(b){
|
System.out.println("success seek play back:");
|
|
|
// NetSdk.CLIENT_PausePlayBack(m_hPlayHandle, pauseFlag ? 0: 1); // 1 - 暂停 0 - 恢复
|
|
// pauseButton.setText(pauseFlag ? "暂停" : "播放");
|
// m_pauseFlag = !m_pauseFlag;
|
if (m_hPlayHandle.longValue() == 0) {
|
System.err.println("Please make sure the PlayBack Handle is valid");
|
return;
|
}
|
|
} else {
|
System.out.println("err:"+ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 开始下载录像
|
*/
|
private void DownLoadRecordFile() {
|
if (m_hLoginHandle.longValue() == 0) {
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Please Login First");
|
JOptionPane.showMessageDialog(playFrame, "请先登录");
|
return;
|
}
|
}
|
|
// 同一个登录句柄，回放和下载不能同时进行
|
if (m_hPlayHandle.longValue() != 0) {
|
JOptionPane.showMessageDialog(playFrame, "请先停止回放");
|
return;
|
}
|
|
updatePlayBackParams();
|
|
// 进度清0
|
downloadPos = 0;
|
downLoadProgressBar.setValue(0);
|
|
// 通道
|
int nChannelId = m_channel.intValue();
|
int nRecordFileType = 0; // 全部录像
|
|
File currentPath = new File(".");
|
String SavedFileName = currentPath.getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".dav"; // 默认保存路径
|
|
m_hDownLoadHandle = NetSdk.CLIENT_DownloadByTimeEx(m_hLoginHandle, nChannelId, nRecordFileType,
|
m_startTime, m_stopTime, SavedFileName,
|
m_DownLoadPos, null, m_DownLoadData, null, null);
|
if (0 == m_hDownLoadHandle.longValue()) {
|
int error = NetSdk.CLIENT_GetLastError();
|
System.err.printf("DownloadByTimeEx Failed, Get last error [0x%x]\n", error);
|
switch (error) {
|
case LastError.NET_NO_RECORD_FOUND:
|
JOptionPane.showMessageDialog(playFrame, "查找不到录像");
|
break;
|
default:
|
JOptionPane.showMessageDialog(playFrame, "下载失败, 错误码：" + String.format("0x%x", error));
|
break;
|
}
|
} else {
|
System.out.println("DownloadByTimeEx Successed");
|
}
|
}
|
|
/**
|
* 开始下载录像(可以设置保存的录像码流类型)
|
*/
|
private void DownLoadRecordFileEx() {
|
if (m_hLoginHandle.longValue() == 0) {
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Please Login First");
|
JOptionPane.showMessageDialog(playFrame, "请先登录");
|
return;
|
}
|
}
|
|
// 同一个登录句柄，回放和下载不能同时进行
|
if (m_hPlayHandle.longValue() != 0) {
|
JOptionPane.showMessageDialog(playFrame, "请先停止回放");
|
return;
|
}
|
|
updatePlayBackParams();
|
|
// 进度清0
|
downloadPos = 0;
|
downLoadProgressBar.setValue(0);
|
|
// 通道
|
int nChannelId = m_channel.intValue();
|
int nRecordFileType = 0; // 全部录像
|
int scType = 3; // scType: 码流转换类型,0-DAV码流(默认); 1-PS流,3-MP4
|
|
File currentPath = new File(".");
|
String SavedFileName = currentPath.getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".MP4"; // 默认保存路径
|
|
System.out.println("SavedFileName:" + SavedFileName);
|
|
m_hDownLoadHandle = NetSdk.CLIENT_DownloadByTimeEx2(m_hLoginHandle, nChannelId, nRecordFileType,
|
m_startTime, m_stopTime, SavedFileName,
|
m_DownLoadPos, null, m_DownLoadData, null, scType, null);
|
if (0 == m_hDownLoadHandle.longValue()) {
|
int error = NetSdk.CLIENT_GetLastError();
|
System.err.printf("DownloadByTimeEx Failed, Get last error [0x%x]\n", error);
|
switch (error) {
|
case LastError.NET_NO_RECORD_FOUND:
|
JOptionPane.showMessageDialog(playFrame, "查找不到录像");
|
break;
|
default:
|
JOptionPane.showMessageDialog(playFrame, "下载失败, 错误码：" + String.format("0x%x", error));
|
break;
|
}
|
} else {
|
System.out.println("DownloadByTimeEx Successed");
|
downRecordButton.setEnabled(false);
|
}
|
}
|
|
/**
|
* 结束下载录像
|
*/
|
private void StopDownLoadRecord() {
|
if (m_hDownLoadHandle.longValue() == 0) {
|
System.err.println("Please make sure the download handle is valid");
|
return;
|
}
|
downloadPos = 0;
|
NetSdk.CLIENT_StopDownload(m_hDownLoadHandle);
|
m_hDownLoadHandle.setValue(0);
|
downRecordButton.setEnabled(true);
|
}
|
|
ArrayList<Integer> fileTime=new ArrayList<>();
|
|
ArrayList<Integer> fileStartTime=new ArrayList<>();
|
|
// 查询录像视频
|
public long queryRecordFile() {
|
NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
|
fileTime=new ArrayList<>();
|
fileStartTime=new ArrayList<>();
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
stTimeStart.dwYear = Integer.valueOf( startTextFields[0].getText()) ;
|
|
stTimeStart.dwMonth = Integer.valueOf(startTextFields[1].getText()) ;
|
stTimeStart.dwDay = Integer.valueOf(startTextFields[2].getText()) ;
|
stTimeStart.dwHour = Integer.valueOf(startTextFields[3].getText()) ;
|
stTimeStart.dwMinute = Integer.valueOf(startTextFields[4].getText()) ;
|
stTimeStart.dwSecond =Integer.valueOf(startTextFields[5].getText()) ;
|
|
|
NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
|
stTimeEnd.dwYear = Integer.valueOf(stopTextFields[0].getText());
|
stTimeEnd.dwMonth = Integer.valueOf(stopTextFields[1].getText());
|
stTimeEnd.dwDay = Integer.valueOf(stopTextFields[2].getText());
|
stTimeEnd.dwHour = Integer.valueOf(stopTextFields[3].getText());
|
stTimeEnd.dwMinute = Integer.valueOf(stopTextFields[4].getText());
|
stTimeEnd.dwSecond = Integer.valueOf(stopTextFields[5].getText());
|
|
Date startTimeOff=null;
|
Date endTimeOff=null;
|
try {
|
startTimeOff = simpleDateFormat.parse(stTimeStart.dwYear+"-"+stTimeStart.dwMonth+"-"+stTimeStart.dwDay+" "+stTimeStart.dwHour+":"+stTimeStart.dwMinute+":"+stTimeStart.dwSecond);
|
|
endTimeOff = simpleDateFormat.parse(stTimeEnd.dwYear+"-"+stTimeEnd.dwMonth+"-"+stTimeEnd.dwDay+" "+stTimeEnd.dwHour+":"+stTimeEnd.dwMinute+":"+stTimeEnd.dwSecond);
|
|
} 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(m_hLoginHandle, 0, 0, stTimeStart, stTimeEnd, null, numberFile, maxlen, outFileCoutReference, 5000, false);
|
|
int value = outFileCoutReference.getValue();
|
|
int timeAll=0;
|
|
if (cRet) {
|
System.out.println("QueryRecordFile Succeed! \n" + "查询到的视频个数：" + outFileCoutReference.getValue()
|
+ "\n" + "码流类型：" + numberFile[0].bRecType);
|
// System.out.printf("%s", numberFile[0].filename);
|
|
for(int i=0;i<value;i++){
|
NetSDKLib.NET_RECORDFILE_INFO recordfileInfo
|
= numberFile[i];
|
NET_TIME startTime
|
= recordfileInfo.starttime;
|
|
NET_TIME endTime
|
= recordfileInfo.endtime;
|
|
|
|
|
try {
|
Date start = simpleDateFormat.parse(startTime.dwYear+"-"+startTime.dwMonth+"-"+startTime.dwDay+" "+startTime.dwHour+":"+startTime.dwMinute+":"+startTime.dwSecond);
|
|
Date end = simpleDateFormat.parse(endTime.dwYear+"-"+endTime.dwMonth+"-"+endTime.dwDay+" "+endTime.dwHour+":"+endTime.dwMinute+":"+endTime.dwSecond);
|
|
long l = (end.getTime() - start.getTime())/1000;
|
|
fileTime.add((int)l);
|
|
if(i==0){
|
long l1 = (start.getTime() - startTimeOff.getTime())/1000;
|
|
fileStartTime.add((int)l1);
|
}else {
|
|
NetSDKLib.NET_RECORDFILE_INFO recordfileInfoBefore
|
= numberFile[i-1];
|
|
NET_TIME endTimeBefore
|
= recordfileInfoBefore.endtime;
|
|
|
Date endBefore = simpleDateFormat.parse(endTimeBefore.dwYear+"-"+endTimeBefore.dwMonth+"-"
|
+endTimeBefore.dwDay+" "+endTimeBefore.dwHour+":"+endTimeBefore.dwMinute+":"+endTimeBefore.dwSecond);
|
|
|
long l1 = (start.getTime() - endBefore.getTime())/1000;
|
|
fileStartTime.add((int)l1);
|
}
|
|
|
timeAll+=l;
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
|
|
}
|
|
} else {
|
System.err.println("QueryRecordFile Failed!" + NetSdk.CLIENT_GetLastError());
|
}
|
System.out.println("timeAll:"+timeAll);
|
return timeAll;
|
// *********查询时间段内是否有视频*************
|
/*IntByReference bResult = new IntByReference(0);
|
boolean cRet = NetSdk.CLIENT_QueryRecordTime(loginHandle, 0, 0, stTimeStart, stTimeEnd, null, bResult, 5000);
|
if(cRet) {
|
System.out.printf("QueryRecordFile Succeed!\n bResult = %b", bResult.getValue());
|
} else {
|
System.err.println("QueryRecordFile Failed!" + NetSdk.CLIENT_GetLastError());
|
}*/
|
}
|
|
//////////////////////// Components of PlayBackFrame ///////////////
|
/**
|
* 主界面
|
*/
|
private JFrame playFrame;
|
|
/**
|
* 登录条
|
*/
|
private JButton loginBtn;
|
private JButton logoutBtn;
|
|
private JLabel nameLabel;
|
private JLabel passwordLabel;
|
private JTextField nameTextArea;
|
private JPasswordField passwordTextArea;
|
|
private JLabel ipLabel;
|
private JLabel portLabel;
|
private JTextField ipTextArea;
|
private JTextField portTextArea;
|
|
private LoginPanel loginJPanel;
|
|
/**
|
* 控制面板
|
*/
|
private JButton playButton = new JButton("开启回放");
|
private JButton pauseButton = new JButton("暂停");
|
private JButton normalButton = new JButton("正常速度");
|
private JButton fastButton = new JButton("快放");
|
private JButton slowButton = new JButton("慢放");
|
private JButton playStartButton = new JButton("定位回放起点");
|
|
private JButton osdButton = new JButton("OSD Time");
|
|
private JLabel channelLabel;// 通道
|
private JTextField chanelTextArea;
|
private JLabel streamTypeLabel;// 码流类型
|
private JComboBox streamTypeComboBox;
|
private JLabel recordTypeLabel;// 录像文件
|
private JComboBox recordTypeComboBox;
|
|
private JLabel startLabel = new JLabel("开始时间");
|
private JLabel stopLabel = new JLabel("结束时间");
|
private JLabel[] startTimeJLabels = new JLabel[6];
|
private JTextField[] startTextFields = new JTextField[6];
|
private JLabel[] stopTimeJLabels = new JLabel[6];
|
private JTextField[] stopTextFields = new JTextField[6];
|
|
// 下载操作相关组件
|
private JButton downRecordButton;
|
private JButton stopDonwloadButton;
|
private JLabel downLoadProgressLabel;
|
private JProgressBar downLoadProgressBar;
|
|
private RecordInfoPanel recordInfoPanel;
|
private TimePanel ctrlTimeBarPanel;
|
private ControlPanel controlPanel;
|
private PlayBackCtrlPanel ctrlPanel;
|
private DownLoadRecordPanel downLoadRecordPanel;
|
private int downloadPos = 0;
|
|
/**
|
* 播放界面
|
*/
|
private java.awt.Panel panelPlayBack;
|
private JSlider playSlider; // 播放进度条
|
private int playPos = 0;
|
private int playTotal=0;
|
private PlayWindow playWindow;
|
}
|
|
public class PlayBackByTime {
|
|
public static void main(String[] args) {
|
|
|
new PlayBackFrame();
|
}
|
}
|
