package com.netsdk.demo.example.trafficParking;
|
|
|
import com.netsdk.demo.util.EventTaskHandler;
|
import com.netsdk.demo.util.QueueGeneration;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.EVENT_COMM_INFO;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.NET_MSG_OBJECT;
|
import com.netsdk.lib.NetSDKLib.NET_TIME_EX;
|
import com.netsdk.lib.NetSDKLib.NET_PIC_INFO;
|
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 java.awt.*;
|
import java.awt.event.ActionEvent;
|
import java.awt.event.ActionListener;
|
import java.awt.event.WindowAdapter;
|
import java.awt.event.WindowEvent;
|
import java.io.*;
|
import java.util.Vector;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
|
class ITSParkingEventMsg {
|
|
static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
|
private SDKEnvironment sdkEnv;
|
|
// 登录参数
|
private String address = "172.24.1.162";
|
private Integer port = new Integer("37777");
|
private String username = "admin";
|
private String password = "admin123";
|
|
// 设备信息
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
// 句柄信息
|
private LLong loginHandle = new LLong(0); // 登录句柄
|
private LLong playHandle = new LLong(0); // 预览句柄
|
private LLong attachHandle = new LLong(0); // 智能事件订阅句柄
|
// 事件回调
|
private fAnalyzerDataCB m_AnalyzerDataCB = new fAnalyzerDataCB(); // 智能事件回调
|
// Flags
|
private boolean bTriggerBtnClick = false;
|
private boolean bAttachFlag = false;
|
private boolean bRealplayFlags = false;
|
|
// 通道
|
private Vector<String> chnlist = new Vector<String>();
|
|
public ITSParkingEventMsg() {
|
sdkEnv = new SDKEnvironment();
|
sdkEnv.init(); // 初始化
|
|
// 启动回调的消息队列
|
eventCBQueueService.init();
|
|
SwingUtilities.invokeLater(new Runnable() {
|
public void run() {
|
mainFrame = new JFrame("有车无车事件处理Demo");
|
mainFrame.setSize(900, 600);
|
mainFrame.setLayout(new BorderLayout());
|
mainFrame.setLocationRelativeTo(null);
|
mainFrame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
|
mainFrame.setVisible(true);
|
|
loginJPanel = new LoginPanel(); // 登录面板
|
messagePanel = new MessagePanel(); // 事件信息提示
|
realPlayPanel = new RealPlayPanel(); // 实时预览
|
|
mainFrame.add(loginJPanel, BorderLayout.NORTH);
|
mainFrame.add(realPlayPanel, BorderLayout.WEST);
|
mainFrame.add(messagePanel, BorderLayout.CENTER);
|
|
WindowAdapter closeWindowAdapter = new WindowAdapter() {
|
public void windowClosing(WindowEvent e) {
|
System.out.println("Window Closing");
|
logoutBtnPerformed(null); // 登出
|
sdkEnv.cleanup();
|
mainFrame.dispose();
|
}
|
};
|
mainFrame.addWindowListener(closeWindowAdapter);
|
}
|
});
|
}
|
|
/**
|
* 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 = netsdkApi.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\\ITSParkingEventMsg_" + System.currentTimeMillis() + ".log";
|
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
bLogopen = netsdkApi.CLIENT_LogOpen(setLog);
|
if (!bLogopen) {
|
System.err.println("Failed to open NetSDK log !!!");
|
}
|
|
// 获取版本, 可选操作
|
System.out.printf("NetSDK Version [%d]\n", netsdkApi.CLIENT_GetSDKVersion());
|
|
// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK内部会自动进行重连操作
|
// 此操作为可选操作，但建议用户进行设置
|
netsdkApi.CLIENT_SetAutoReconnect(haveReConnect, null);
|
|
// 设置登录超时时间和尝试次数 , 此操作为可选操作
|
int waitTime = 5000; // 登录请求响应超时时间设置为 5s
|
int tryTimes = 1; // 登录时尝试建立链接3次
|
netsdkApi.CLIENT_SetConnectTime(waitTime, tryTimes);
|
|
// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime
|
// 接口设置的登录设备超时时间和尝试次数意义相同
|
// 此操作为可选操作
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
netParam.nConnectTime = 10000; // 登录时尝试建立链接的超时时间
|
netParam.nGetConnInfoTime = 3000; // 设置子连接的超时时间
|
netParam.nPicBufSize = 8 * 1024 * 1024;
|
netsdkApi.CLIENT_SetNetworkParam(netParam);
|
|
return true;
|
}
|
|
// 清除环境
|
public void cleanup() {
|
if (bLogopen) {
|
netsdkApi.CLIENT_LogClose();
|
}
|
|
if (bInit) {
|
netsdkApi.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);
|
messageTextArea.append(String.format("Device[%s] Port[%d] Disconnect!\n", pchDVRIP, nDVRPort));
|
|
// 取消订阅
|
detachIVSEvent();
|
}
|
}
|
|
// 网络连接恢复，设备重连成功回调
|
// 通过 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);
|
messageTextArea.append(String.format("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort));
|
|
// 重新订阅
|
attachIVSEvent();
|
}
|
}
|
}
|
|
///////////////// 事件动作相关接口 ///////////////////////////
|
|
/**
|
* 登录按钮
|
*/
|
private void loginBtnPerformed(ActionEvent e) {
|
address = ipTextArea.getText();
|
port = Integer.parseInt(portTextArea.getText());
|
username = nameTextArea.getText();
|
password = new String(passwordTextArea.getPassword());
|
|
System.out.println("设备地址：" + address
|
+ "\n端口号：" + port
|
+ "\n用户名：" + username
|
+ "\n密码：" + password);
|
messageTextArea.append("设备地址：" + address
|
+ "\n端口号：" + port
|
+ "\n用户名：" + username
|
+ "\n密码：" + password + "\n");
|
|
// 登录设备
|
IntByReference nError = new IntByReference(0);
|
|
NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam =
|
new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {{
|
szIP = address.getBytes();
|
nPort = port;
|
szUserName = username.getBytes();
|
szPassword = password.getBytes();
|
}}; // 输入结构体参数
|
NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam =
|
new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY(); // 输结构体参数
|
pstOutParam.stuDeviceInfo = deviceInfo;
|
|
// 高安全登陆
|
loginHandle = netsdkApi.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
// loginHandle = netsdkApi.CLIENT_LoginEx2(address, port, username, password, 0, null, deviceInfo, nError);
|
if (loginHandle.longValue() == 0) {
|
System.err.printf("Login Device[%s] Port[%d]Failed. Last Error[%x]\n", address, port, netsdkApi.CLIENT_GetLastError());
|
JOptionPane.showMessageDialog(mainFrame, "登录失败");
|
} else {
|
System.out.println("Login Success [ " + address + " ]");
|
messageTextArea.append(String.format("Login Success [ %s ]\n", address));
|
|
JOptionPane.showMessageDialog(mainFrame, "登录成功");
|
loginJPanel.enableCompents(true);
|
|
for (int i = 0; i < deviceInfo.byChanNum; i++) {
|
chnlist.add("通道 " + i);
|
}
|
// 预选 0 通道
|
if (deviceInfo.byChanNum > 0) {
|
chnComboBox.setSelectedIndex(0);
|
}
|
}
|
}
|
|
/**
|
* 登出按钮
|
*/
|
private void logoutBtnPerformed(ActionEvent e) {
|
if (loginHandle.longValue() != 0) {
|
System.out.println("LogOut Button Action");
|
messageTextArea.append(String.format("LogOut Button Action\n"));
|
|
// 确保关闭预览
|
stopRealPlay();
|
realplayButton.setText("预览");
|
bRealplayFlags = false;
|
|
// 停止订阅事件
|
detachIVSEvent();
|
attachButton.setText("订阅");
|
bAttachFlag = false;
|
|
if (netsdkApi.CLIENT_Logout(loginHandle)) {
|
System.out.println("Logout Success [ " + address + " ]");
|
messageTextArea.append(String.format("Logout Success [%s]\n", address));
|
loginHandle.setValue(0);
|
loginJPanel.enableCompents(true);
|
bTriggerBtnClick = false;
|
chnlist.clear();
|
chnComboBox.setModel(new DefaultComboBoxModel(chnlist));
|
}
|
}
|
}
|
|
/**
|
* 开始实时预览按钮事件
|
*/
|
private void startRealPlay() {
|
if (loginHandle.longValue() == 0) {
|
System.err.println("Please login first");
|
JOptionPane.showMessageDialog(mainFrame, "请先登录");
|
return;
|
}
|
|
int channel = chnComboBox.getSelectedIndex(); // 预览通道号
|
int playType = NetSDKLib.NET_RealPlayType.NET_RType_Realplay; // 实时预览
|
|
playHandle = netsdkApi.CLIENT_RealPlayEx(loginHandle, channel, Native.getComponentPointer(realplayWindow), playType);
|
if (playHandle.longValue() == 0) {
|
int error = netsdkApi.CLIENT_GetLastError();
|
JOptionPane.showMessageDialog(mainFrame, "开始实时预览失败，错误码：" + String.format("[0x%x]", error));
|
} else {
|
System.out.println("[通道" + channel + "] 拉流成功！");
|
messageTextArea.append(String.format("[通道 %2d ] 拉流成功！\n", channel));
|
}
|
}
|
|
/**
|
* 结束实时预览按钮事件
|
*/
|
private void stopRealPlay() {
|
|
if (playHandle.longValue() == 0) {
|
System.out.println("Make sure the realplay Handle is valid");
|
messageTextArea.append("Make sure the realplay Handle is valid\n");
|
return;
|
}
|
|
if (netsdkApi.CLIENT_StopRealPlayEx(playHandle)) {
|
System.out.println("Success to stop realplay");
|
messageTextArea.append("Success to stop realplay\n");
|
|
playHandle.setValue(0);
|
realplayWindow.repaint();
|
}
|
}
|
|
// 订阅实时上传智能分析数据
|
private void attachIVSEvent() {
|
|
/**
|
* 说明：
|
* 通道数可以在有登录是返回的信息 m_stDeviceInfo.byChanNum 获取
|
* 下列仅订阅了 0 通道的智能事件.
|
*/
|
int bNeedPicture = 1; // 是否需要图片
|
int ChannelId = chnComboBox.getSelectedIndex(); // 通道
|
|
attachHandle = netsdkApi.CLIENT_RealLoadPictureEx(loginHandle, ChannelId, NetSDKLib.EVENT_IVS_ALL, bNeedPicture, m_AnalyzerDataCB, null, null);
|
if (attachHandle.longValue() != 0) {
|
System.out.println("[通道" + ChannelId + "] 订阅成功！");
|
messageTextArea.append(String.format("[通道 %2d ] 订阅成功！\n", ChannelId));
|
|
} else {
|
System.out.printf("CLIENT_RealLoadPictureEx Failed!LastError = %x\n", netsdkApi.CLIENT_GetLastError());
|
messageTextArea.append(String.format("CLIENT_RealLoadPictureEx Failed!LastError = %x\n", netsdkApi.CLIENT_GetLastError()));
|
}
|
|
eventCBQueueService.activeService(); // 启动队列
|
}
|
|
// 停止上传智能分析数据－图片
|
private void detachIVSEvent() {
|
if (0 != attachHandle.longValue()) {
|
netsdkApi.CLIENT_StopLoadPic(attachHandle);
|
System.out.println("Stop detach IVS event");
|
messageTextArea.append("Stop detach IVS even\n");
|
|
attachHandle.setValue(0);
|
}
|
|
eventCBQueueService.destroy(); // 关闭队列
|
}
|
|
/* 智能报警事件回调 */
|
public class fAnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack/*, StdCallCallback*/ {
|
private final String m_imagePath = "./PlateNumber/";
|
NetSDKLib.NET_MSG_OBJECT plateObject; // 车牌信息
|
NetSDKLib.NET_MSG_OBJECT vehicleObject; // 车辆信息
|
NetSDKLib.NET_TIME_EX utc; // 事件时间
|
|
int lane = 0; // 车道号
|
String EventMsg; // 事件信息
|
int nConfide = 0; // 置信度, 只有特定设备才支持，一般设备默认都是0不填充
|
|
private String encode;
|
|
public fAnalyzerDataCB() {
|
File path = new File(m_imagePath);
|
if (!path.exists()) {
|
path.mkdir();
|
}
|
initRecord();
|
|
initEncodeType();
|
|
}
|
|
// 解码格式
|
private void initEncodeType() {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
}
|
|
// 初始化
|
private void initRecord() {
|
plateObject = new NET_MSG_OBJECT(); // 车牌信息
|
vehicleObject = new NET_MSG_OBJECT(); // 车辆信息
|
utc = new NET_TIME_EX(); // 事件时间
|
lane = -1; // 车道号
|
EventMsg = ""; // 事件信息
|
nConfide = 0; // 置信度, 只有特定设备才支持，一般设备默认都是0不填充
|
}
|
|
// 回调
|
public int invoke(LLong lAnalyzerHandle, int dwAlarmType,
|
Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
initRecord(); // init record
|
if (lAnalyzerHandle.longValue() == 0) return -1;
|
if (pAlarmInfo == null) return 0;
|
|
System.out.println("--------dwAlarmType-------------" + dwAlarmType);
|
messageTextArea.append("--------------Event Received----------------\n");
|
// 获取事件信息
|
NetSDKLib.NET_EVENT_FILE_INFO fileInfo = new NetSDKLib.NET_EVENT_FILE_INFO();
|
|
switch (dwAlarmType) {
|
case NetSDKLib.EVENT_IVS_TRAFFIC_PARKINGSPACEPARKING: /// 车位有车事件
|
{
|
messageTextArea.append("<Event> TRAFFIC PARKING SPACE [ PARKING ]\n");
|
|
NetSDKLib.DEV_EVENT_TRAFFIC_PARKINGSPACEPARKING_INFO msg = new NetSDKLib.DEV_EVENT_TRAFFIC_PARKINGSPACEPARKING_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
plateObject = msg.stuObject;
|
vehicleObject = msg.stuVehicle;
|
utc = msg.UTC;
|
lane = msg.nLane;
|
fileInfo = msg.stuFileInfo;
|
|
// 抓拍到物体的数据
|
NET_MSG_OBJECT msgObject = msg.stuObject;
|
NET_PIC_INFO msgObjPicInfo = msgObject.stPicInfo;
|
if (msgObjPicInfo != null) {
|
int msgPicOffset = msgObjPicInfo.dwOffSet;
|
int msgPicLength = msgObjPicInfo.dwFileLenth;
|
String msgPicName = String.format("%s_%s_%s.jpg", "Parking", utc.toStringTime().replaceAll("[^0-9]", "-"), "plate");
|
String msgPicPath = m_imagePath + msgPicName;
|
eventCBQueueService.addEvent(new SaveTrafficPicHandler(pBuffer, msgPicOffset, msgPicLength, msgPicPath));
|
}
|
|
// 公共信息图片
|
EVENT_COMM_INFO commInfo = msg.stCommInfo;
|
int nPictureNum = commInfo.nPictureNum; // 原始图片张数
|
|
for (int i = 0; i < nPictureNum; i++) {
|
int length = commInfo.stuPicInfos[i].nLength;
|
int offSet = commInfo.stuPicInfos[i].nOffset;
|
String fileName = String.format("%s_%s_%02d.jpg", "Parking", utc.toStringTime().replaceAll("[^0-9]", "-"), i);
|
String savePath = m_imagePath + fileName;
|
// ToolKits.savePicture(pBuffer, offSet, length, savePath);
|
|
eventCBQueueService.addEvent(new SaveTrafficPicHandler(pBuffer, offSet, length, savePath));
|
}
|
|
printInfo(fileInfo, msg.stTrafficCar);
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_TRAFFIC_PARKINGSPACENOPARKING: /// 车位无车事件
|
{
|
messageTextArea.append("<Event> TRAFFIC PARKING SPACE [ NO PARKING ]\n");
|
|
NetSDKLib.DEV_EVENT_TRAFFIC_PARKINGSPACENOPARKING_INFO msg = new NetSDKLib.DEV_EVENT_TRAFFIC_PARKINGSPACENOPARKING_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
plateObject = msg.stuObject;
|
vehicleObject = msg.stuVehicle;
|
utc = msg.UTC;
|
lane = msg.nLane;
|
fileInfo = msg.stuFileInfo;
|
EventMsg = "[ " + utc.toStringTime() + " ] " + "车位无车事件";
|
|
// 抓拍到物体的图片
|
NET_MSG_OBJECT msgObject = msg.stuObject;
|
NET_PIC_INFO msgObjPicInfo = msgObject.stPicInfo;
|
if (msgObjPicInfo != null) {
|
int msgPicOffset = msgObjPicInfo.dwOffSet;
|
int msgPicLength = msgObjPicInfo.dwFileLenth;
|
String msgPicName = String.format("%s_%s_%s.jpg", "NoParking", utc.toStringTime().replaceAll("[^0-9]", "-"), "plate");
|
String msgPicPath = m_imagePath + msgPicName;
|
eventCBQueueService.addEvent(new SaveTrafficPicHandler(pBuffer, msgPicOffset, msgPicLength, msgPicPath));
|
}
|
// 公共图片
|
EVENT_COMM_INFO commInfo = msg.stCommInfo;
|
int nPictureNum = commInfo.nPictureNum;
|
|
for (int i = 0; i < nPictureNum; i++) {
|
int length = commInfo.stuPicInfos[i].nLength;
|
int offSet = commInfo.stuPicInfos[i].nOffset;
|
String fileName = String.format("%s_%s_%02d.jpg", "NoParking", utc.toStringTime().replaceAll("[^0-9]", "-"), i);
|
String savePath = m_imagePath + fileName;
|
// ToolKits.savePicture(pBuffer, offSet, length, savePath);
|
|
eventCBQueueService.addEvent(new SaveTrafficPicHandler(pBuffer, offSet, length, savePath));
|
}
|
|
printInfo(fileInfo, msg.stTrafficCar);
|
|
break;
|
}
|
default:
|
System.out.printf("Get Event 0x%x\n", dwAlarmType);
|
EventMsg = "未处理事件 dwAlarmType = " + String.format("0x%x", dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
|
private void printInfo(NetSDKLib.NET_EVENT_FILE_INFO fileInfo, NetSDKLib.DEV_EVENT_TRAFFIC_TRAFFICCAR_INFO stTrafficCar) {
|
// Todo 展示 EVENT_FILE_INFO 的内容
|
|
String message = null;
|
try {
|
message = "SnapShotTime: " + stTrafficCar.stSnapTime.toStringTime()
|
+ "\nParkingPlaceNo：" + new String(stTrafficCar.szCustomParkNo, encode).trim()
|
+ "\nVehicleDirection: " + stTrafficCar.byDirection
|
+ "\nVehicleSize: " + stTrafficCar.nVehicleSize
|
+ "\nszPlateColor: " + new String(stTrafficCar.szPlateColor).trim()
|
+ "\nszVehicleColor: " + new String(stTrafficCar.szVehicleColor).trim();
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
System.out.println(message);
|
messageTextArea.append(message + "\n");
|
}
|
}
|
|
///////////////////////////////////// 异步图片存储队列 ////////////////////////////////////
|
|
private QueueGeneration eventCBQueueService = new QueueGeneration();
|
|
private class SaveTrafficPicHandler implements EventTaskHandler {
|
private static final long serialVersionUID = 1L;
|
|
private final byte[] imgBuffer;
|
private final int length;
|
private final String savePath;
|
|
public SaveTrafficPicHandler(Pointer pBuf, int dwBufOffset, int dwBufSize, String sDstFile) {
|
|
this.imgBuffer = pBuf.getByteArray(dwBufOffset, dwBufSize);
|
this.length = dwBufSize;
|
this.savePath = sDstFile;
|
}
|
|
@Override
|
public void eventCallBackProcess() {
|
|
System.out.println("保存图片中...路径：" + savePath);
|
messageTextArea.append("保存图片中...路径：" + savePath + "\n");
|
|
try {
|
DataOutputStream out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(savePath)));
|
out.write(imgBuffer, 0, length);
|
out.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/////////////////////////////////界面组件/////////////////////////////////////////////////
|
///////////////////////////// 界面组件相关成员变量 ////////////////////////////////////////
|
|
/**
|
* 设置边框
|
*/
|
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));
|
}
|
|
/**
|
* 登录面板
|
*/
|
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(username, 8);
|
passwordTextArea = new JPasswordField(password, 8);
|
ipLabel = new JLabel("设备地址");
|
portLabel = new JLabel("端口号");
|
ipTextArea = new JTextField(address, 15);
|
portTextArea = new JTextField("37777", 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);
|
|
enableCompents(false);
|
|
// 登录按钮. 监听事件
|
loginBtn.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
loginBtnPerformed(e);
|
}
|
});
|
|
// 登出按钮. 监听事件
|
logoutBtn.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
logoutBtnPerformed(e);
|
enableCompents(false);
|
}
|
});
|
}
|
|
public void enableCompents(boolean enable) {
|
loginBtn.setEnabled(!enable);
|
logoutBtn.setEnabled(enable);
|
}
|
|
private JButton loginBtn;
|
private JButton logoutBtn;
|
private JLabel nameLabel;
|
private JLabel passwordLabel;
|
private JLabel ipLabel;
|
private JLabel portLabel;
|
}
|
|
/**
|
* 事件信息显示面板
|
*/
|
private class MessagePanel extends JPanel {
|
|
private static final long serialVersionUID = 1L;
|
|
public MessagePanel() {
|
setBorderEx(this, "事件信息提示", 2);
|
|
Dimension dim = getPreferredSize();
|
dim.height = 226;
|
setPreferredSize(dim);
|
setLayout(new BorderLayout());
|
|
messageTextArea = new JTextArea();
|
|
add(new JScrollPane(messageTextArea), BorderLayout.CENTER);
|
}
|
}
|
|
/**
|
* 预览面板
|
*/
|
private class RealPlayPanel extends JPanel {
|
|
private static final long serialVersionUID = 1L;
|
|
public RealPlayPanel() {
|
setBorderEx(this, "实时预览", 2);
|
setLayout(new BorderLayout());
|
Dimension dim = getPreferredSize();
|
dim.height = 367;
|
dim.width = 480;
|
setPreferredSize(dim);
|
|
realplayWindow = new Panel();
|
chnComboBox = new JComboBox(chnlist);
|
attachButton = new JButton("订阅");
|
realplayButton = new JButton("预览");
|
|
realplayWindow.setBackground(new java.awt.Color(153, 240, 255));
|
realplayWindow.setForeground(new java.awt.Color(0, 0, 0));
|
realplayWindow.setBounds(5, 5, 350, 290);
|
realplayWindow.setSize(358, 294);
|
|
JPanel btnPanel = new JPanel();
|
btnPanel.setBorder(new EmptyBorder(5, 5, 5, 5));
|
btnPanel.setLayout(new GridLayout(1, 3, 5, 5));
|
btnPanel.add(chnComboBox);
|
btnPanel.add(attachButton);
|
btnPanel.add(realplayButton);
|
|
add(realplayWindow, BorderLayout.CENTER);
|
add(btnPanel, BorderLayout.SOUTH);
|
|
// 订阅按钮动作监听
|
attachButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
if (!bAttachFlag) {
|
attachIVSEvent();
|
attachButton.setText("停止订阅");
|
bAttachFlag = true;
|
} else {
|
detachIVSEvent();
|
attachButton.setText("订阅");
|
bAttachFlag = false;
|
}
|
}
|
});
|
|
// 预览按钮监听
|
realplayButton.addActionListener(new ActionListener() {
|
public void actionPerformed(ActionEvent e) {
|
if (!bRealplayFlags) {
|
startRealPlay();
|
realplayButton.setText("停止预览");
|
bRealplayFlags = true;
|
} else {
|
stopRealPlay();
|
realplayButton.setText("预览");
|
bRealplayFlags = false;
|
}
|
}
|
});
|
}
|
}
|
|
/**
|
* 主界面组件
|
*/
|
private JFrame mainFrame;
|
|
/**
|
* 登录条组件
|
*/
|
private JTextField nameTextArea;
|
private JPasswordField passwordTextArea;
|
|
private JTextField ipTextArea;
|
private JTextField portTextArea;
|
|
private LoginPanel loginJPanel;
|
|
/**
|
* 事件信息显示组件
|
*/
|
private MessagePanel messagePanel;
|
private JTextArea messageTextArea;
|
|
/**
|
* 实时预览组件
|
*/
|
private RealPlayPanel realPlayPanel;
|
private java.awt.Panel realplayWindow;
|
private JButton attachButton;
|
private JButton realplayButton;
|
private JComboBox chnComboBox;
|
}
|
|
public class TrafficParkingEvent {
|
|
public static void main(String[] args) throws SecurityException, IllegalArgumentException {
|
|
ITSParkingEventMsg demo = new ITSParkingEventMsg();
|
}
|
}
|
