package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.*;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_VEHICLE_DRIVING_DIRECTION;
|
import com.netsdk.lib.enumeration.EM_VEHICLE_HEAD_DIRECTION;
|
import com.netsdk.lib.enumeration.EM_VEHICLE_POSITION;
|
import com.netsdk.lib.structure.ALARM_TRAFFIC_VEHICLE_POSITION;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
import java.io.UnsupportedEncodingException;
|
|
public class AlarmEvent {
|
|
static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
private LLong loginHandle = new LLong(0);
|
|
String address = "10.11.17.20";
|
int port = 37777;
|
String username = "admin";
|
String password = "admin123";
|
|
private static class DisconnectCallback implements NetSDKLib.fDisConnect {
|
private static DisconnectCallback instance = new DisconnectCallback();
|
private DisconnectCallback() {}
|
public static DisconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong loginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s:%d] Disconnect!\n" , pchDVRIP , nDVRPort);
|
|
// 设备断线, 退订
|
netsdkApi.CLIENT_StopListen(loginHandle);
|
}
|
}
|
|
private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect {
|
private static HaveReconnectCallback instance = new HaveReconnectCallback();
|
private HaveReconnectCallback() {}
|
public static HaveReconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong loginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s:%d] HaveReconnected!\n" , pchDVRIP , nDVRPort);
|
|
// 内部登录成功, 重新订阅
|
netsdkApi.CLIENT_StartListenEx(loginHandle);
|
}
|
}
|
|
/**
|
* 报警事件回调
|
* @author 29779, 260611
|
*
|
*/
|
public static class AlarmEventCallback implements NetSDKLib.fMessCallBack {
|
private static AlarmEventCallback instance = new AlarmEventCallback();
|
private AlarmEventCallback() {}
|
public static AlarmEventCallback getInstance() {
|
return instance;
|
}
|
|
@Override
|
public boolean invoke(int lCommand, LLong loginHandle,
|
Pointer pStuEvent, int dwBufLen, String strDeviceIP,
|
NativeLong nDevicePort, Pointer dwUser) {
|
switch( lCommand ) {
|
case NetSDKLib.NET_ALARM_HUMAM_NUMBER_STATISTIC: { // 人数量/客流量统计事件
|
System.out.printf("NET_ALARM_HUMAM_NUMBER_STATISTIC\n");
|
NetSDKLib.ALARM_HUMAN_NUMBER_STATISTIC_INFO humanNumberStat = new NetSDKLib.ALARM_HUMAN_NUMBER_STATISTIC_INFO();
|
ToolKits.GetPointerData(pStuEvent, humanNumberStat);
|
|
System.out.println("Action[" + humanNumberStat.nEventAction +"] " +
|
" Time " + humanNumberStat.UTC.toStringTime() +
|
" Number " + humanNumberStat.nNumber +
|
" Enter Number " + humanNumberStat.nEnteredNumber +
|
" Exit Number " + humanNumberStat.nExitedNumber);
|
break;
|
}
|
case NetSDKLib.NET_ALARM_LABELINFO: {//电动车标签信息
|
System.out.printf("NET_ALARM_LABELINFO\n");
|
NetSDKLib.ALARM_LABELINFO labelInfo = new NetSDKLib.ALARM_LABELINFO();
|
ToolKits.GetPointerData(pStuEvent, labelInfo);
|
|
System.out.println("nChannelID[" + labelInfo.nChannelID +"] " +
|
" Time:" + labelInfo.stuDateTime.toStringTime() +
|
" IndexIs:" + new String(labelInfo.szIndexIs) +
|
" nVideoIndex:" + labelInfo.nVideoIndex +
|
" nACK:" + labelInfo.nACK +
|
" szReceiverID:" + new String(labelInfo.szReceiverID) +
|
" szLabelID:" + new String(labelInfo.szLabelID) +
|
" emLabelDataState:" + labelInfo.emLabelDataState);
|
break;
|
}
|
case NetSDKLib.NET_ALARM_TRAFFIC_VEHICLE_POSITION: {//车辆位置事件
|
System.out.printf("NET_ALARM_TRAFFIC_VEHICLE_POSITION\n");
|
ALARM_TRAFFIC_VEHICLE_POSITION positionInfo = new ALARM_TRAFFIC_VEHICLE_POSITION();
|
ToolKits.GetPointerData(pStuEvent, positionInfo);
|
|
try {
|
System.out.println("nAction:" + positionInfo.nAction +
|
" szEventName:" + new String(positionInfo.szEventName).trim() +
|
" nObjectID:" + positionInfo.nObjectID +
|
" GBK szPlateNumber:" + new String(positionInfo.szPlateNumber, "GBK").trim() +
|
" UTF-8 szPlateNumber:" + new String(positionInfo.szPlateNumber, "UTF-8").trim() +
|
" nPosition:" + positionInfo.nPosition +
|
" byOpenStrobeState:" + positionInfo.byOpenStrobeState +
|
" nPlateConfidence:" + positionInfo.nPlateConfidence +
|
" szPlateColor:" + new String(positionInfo.szPlateColor).trim() +
|
" nVehicleConfidence:" + positionInfo.nVehicleConfidence +
|
" szPlateType:" + new String(positionInfo.szPlateType).trim()+
|
" emVehicleHeadDirection:" + EM_VEHICLE_HEAD_DIRECTION.getNoteByValue(positionInfo.emVehicleHeadDirection) +
|
" emVehiclePosition:" + EM_VEHICLE_POSITION.getNoteByValue(positionInfo.emVehiclePosition) +
|
" emDrivingDirection:" + EM_VEHICLE_DRIVING_DIRECTION.getNoteByValue(positionInfo.emDrivingDirection));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
default:
|
System.out.printf("Command[%x]\n" , lCommand);
|
break;
|
}
|
return true;
|
}
|
}
|
|
|
public void InitTest() {
|
//初始化SDK库
|
netsdkApi.CLIENT_Init(DisconnectCallback.getInstance(), null);
|
|
//设置断线自动重练功能
|
netsdkApi.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null);
|
|
// 向设备登入
|
final int nSpecCap = 0; /// login device by TCP
|
final IntByReference error = new IntByReference();
|
|
loginHandle = netsdkApi.CLIENT_LoginEx2(address, (short)port, username,
|
password, nSpecCap, null, deviceInfo, error);
|
|
if(loginHandle.longValue() == 0) {
|
System.err.printf("Login Device [%s:%d] Failed ! Last Error[%x]\n", address, port, netsdkApi.CLIENT_GetLastError());
|
return;
|
}
|
|
System.out.printf("Login Device [%s:%d] Success. \n", address, port);
|
}
|
|
/**
|
* 订阅报警事件
|
*/
|
public void attachAlarmEvent() {
|
if (loginHandle.longValue() == 0) {
|
return;
|
}
|
|
netsdkApi.CLIENT_SetDVRMessCallBack(AlarmEventCallback.getInstance() , null);
|
|
if (!netsdkApi.CLIENT_StartListenEx(loginHandle)) {
|
System.err.printf("CLIENT_StartListenEx. Last Error[%x]\n", netsdkApi.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
/**
|
* 退订报警事件
|
*/
|
public void detachAlarmEvent() {
|
if (loginHandle.longValue() != 0) {
|
netsdkApi.CLIENT_StopListen(loginHandle);
|
}
|
}
|
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
|
menu.addItem(new CaseMenu.Item(this, "订阅报警事件", "attachAlarmEvent"));
|
menu.addItem(new CaseMenu.Item(this, "退订报警事件", "detachAlarmEvent"));
|
|
menu.run();
|
}
|
|
public void EndTest() {
|
System.out.println("End Test");
|
if( loginHandle.longValue() != 0) {
|
netsdkApi.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netsdkApi.CLIENT_Cleanup();
|
}
|
|
|
public static void main(String[]args) {
|
AlarmEvent demo = new AlarmEvent();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
