package com.netsdk.demo.intelligentTraffic.parkingDemo;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_PARKINGSPACE_STATE;
|
import com.netsdk.lib.structure.*;
|
import com.sun.jna.ptr.IntByReference;
|
|
import java.io.UnsupportedEncodingException;
|
import java.util.Scanner;
|
import java.util.UUID;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
/**
|
* @author 47040
|
* @update 2020/11/19
|
* 1）事件抓图(SnapByEvent)
|
* 2）设置停车位状态(setParkStatus)
|
* 3）修改停车记录(modifyParkingInfo)
|
* @since Created in 2020/7/20 16:28
|
*/
|
public class ParkingImageEventDemo {
|
|
// The constant net sdk
|
public static final NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;
|
|
// The constant config sdk.
|
public static NetSDKLib configsdk = NetSDKLib.CONFIG_INSTANCE;
|
|
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";
|
}
|
}
|
|
////////////////////////////////////// 登录相关 ///////////////////////////////
|
//////////////////////////////////////////////////////////////////////////////
|
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex(); // 设备信息
|
|
private NetSDKLib.LLong m_hLoginHandle = new NetSDKLib.LLong(0); // 登录句柄
|
|
/**
|
* login with high level 高安全级别登陆
|
*/
|
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,
|
netsdk.CLIENT_GetLastError());
|
} else {
|
deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息
|
System.out.println("Login Success");
|
System.out.println("Device Address：" + m_strIpAddr);
|
System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
|
}
|
}
|
|
/**
|
* logout 退出
|
*/
|
public void logOut() {
|
if (m_hLoginHandle.longValue() != 0) {
|
netsdk.CLIENT_Logout(m_hLoginHandle);
|
System.out.println("LogOut Success");
|
}
|
}
|
|
//////////////////////////////////////// 订阅事件/退订 ///////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////
|
|
private NetSDKLib.LLong m_hAttachHandle = new NetSDKLib.LLong(0); // 订阅相关
|
|
private NetSDKLib.fAnalyzerDataCallBack analyzerDataCB = ParkingAnalyzerDataCallBack.getSingleInstance();
|
|
private int channel = 0;
|
|
public void setChannelID() {
|
System.out.println("请输入订阅通道,-1 表示全部");
|
Scanner sc = new Scanner(System.in);
|
this.channel = sc.nextInt();
|
}
|
|
public void AttachEventRealLoadPic() {
|
|
this.DetachEventRealLoadPic(); // 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
|
int bNeedPicture = 1; // 需要图片
|
|
m_hAttachHandle = netsdk.CLIENT_RealLoadPictureEx(m_hLoginHandle, channel, NetSDKLib.EVENT_IVS_ALL, bNeedPicture, analyzerDataCB, null, null);
|
if (m_hAttachHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
|
} else {
|
System.out.printf("Ch[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel, ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (m_hAttachHandle.longValue() != 0) {
|
netsdk.CLIENT_StopLoadPic(m_hAttachHandle);
|
}
|
}
|
|
/////////////////////////////////////// RPC 接口 ////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////
|
|
/**
|
* 获取停车超时配置
|
*/
|
public void TestParkingTimeoutGetConfig() {
|
|
NetSDKLib.NET_CFG_PARKING_TIMEOUT_DETECT timeoutDetectConfig = new NetSDKLib.NET_CFG_PARKING_TIMEOUT_DETECT();
|
boolean ret = ParkingUtils.ParkingTimeoutGetConfig(m_hLoginHandle, timeoutDetectConfig);
|
if (!ret) return;
|
StringBuilder builder = new StringBuilder()
|
.append("<<-----Parking Timeout Config----->>").append("\n")
|
.append("bEnable: ").append(timeoutDetectConfig.bEnable).append("\n")
|
.append("nParkingTime: ").append(timeoutDetectConfig.nParkingTime);
|
System.out.println(builder.toString());
|
}
|
|
/**
|
* 设置停车超时配置
|
*/
|
public void TestParkingTimeoutSetConfig() {
|
|
NetSDKLib.NET_CFG_PARKING_TIMEOUT_DETECT timeoutDetectConfig = new NetSDKLib.NET_CFG_PARKING_TIMEOUT_DETECT();
|
timeoutDetectConfig.bEnable = 1;
|
timeoutDetectConfig.nParkingTime = 302400;
|
ParkingUtils.ParkingTimeoutSetConfig(m_hLoginHandle, timeoutDetectConfig);
|
}
|
|
|
/**
|
* 手动抓图 (ParkingSnapshot)
|
*/
|
public void TestParkingSnapshot() {
|
|
NetSDKLib.NET_IN_SNAP_MNG_SHOT stuInBuf = new NetSDKLib.NET_IN_SNAP_MNG_SHOT();
|
stuInBuf.nChannel = channel;
|
stuInBuf.nTime = 1; // 连拍次数, 0表示停止抓拍,正数表示连续抓拍的张数
|
|
ParkingUtils.ParkingSnapshot(m_hLoginHandle, stuInBuf);
|
}
|
|
/**
|
* 手动抓图 通用二代协议
|
*/
|
public void TestParkingSnapshotCommon() {
|
|
NetSDKLib.MANUAL_SNAP_PARAMETER snapParameter = new NetSDKLib.MANUAL_SNAP_PARAMETER();
|
snapParameter.nChannel = channel;
|
String sUuid = UUID.randomUUID().toString();
|
byte[] bUuid = sUuid.getBytes();
|
System.arraycopy(bUuid, 0, snapParameter.bySequence, 0, bUuid.length);
|
int emType = NetSDKLib.CtrlType.CTRLTYPE_MANUAL_SNAP;
|
snapParameter.write();
|
boolean ret = netsdk.CLIENT_ControlDevice(m_hLoginHandle, emType, snapParameter.getPointer(), 3000);
|
if (!ret) {
|
System.err.println("手动抓图失败! " + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("手动抓图命令下发成功!");
|
}
|
|
|
/**
|
* 下发车辆清理接口, 清除的车辆为 P1 的 “一位多车信息”中车辆（车位号，车牌号）
|
*/
|
public void TestRemoveParkingCarInfo() throws UnsupportedEncodingException {
|
NetSDKLib.NET_IN_REMOVE_PARKING_CAR_INFO stuInBuf = new NetSDKLib.NET_IN_REMOVE_PARKING_CAR_INFO();
|
NetSDKLib.DEV_OCCUPIED_WARNING_INFO stuParkingCarInfo = stuInBuf.stuParkingCarInfo;
|
|
byte[] szParkingNo = "P1".getBytes();
|
System.arraycopy(szParkingNo, 0, stuParkingCarInfo.szParkingNo, 0, szParkingNo.length);
|
|
// 设备会对以下的数据作严格校验，如果不存在会返回校验错误，另外务必注意编码格式 encode
|
|
stuParkingCarInfo.nPlateNumber = 3;
|
|
byte[] iSzPlatNumber1 = "皖SLV662".getBytes(encode);
|
System.arraycopy(iSzPlatNumber1, 0, stuParkingCarInfo.szPlateNumber[0].plateNumber, 0, iSzPlatNumber1.length);
|
byte[] iSzPlatNumber2 = "浙A826RW".getBytes(encode);
|
System.arraycopy(iSzPlatNumber2, 0, stuParkingCarInfo.szPlateNumber[1].plateNumber, 0, iSzPlatNumber2.length);
|
byte[] iSzPlatNumber3 = "沪C0M959".getBytes(encode);
|
System.arraycopy(iSzPlatNumber3, 0, stuParkingCarInfo.szPlateNumber[2].plateNumber, 0, iSzPlatNumber3.length);
|
|
ParkingUtils.RemoveParkingCarInfo(m_hLoginHandle, stuInBuf);
|
}
|
|
/**
|
* 指定事件抓图
|
*/
|
public void TestSnapPictureByEvent() {
|
|
NET_IN_SNAP_BY_EVENT stuParamIn = new NET_IN_SNAP_BY_EVENT();
|
stuParamIn.nChannel = channel; // Todo 通道号
|
stuParamIn.dwEventID = NetSDKLib.EVENT_IVS_TRAFFIC_PARKINGSPACE_MANUALSNAP; // 指定"路侧停车位手动抓图"事件
|
byte[] serialNo = UUID.randomUUID().toString().getBytes(); // Todo 自定义序列号，用于匹配事件
|
System.arraycopy(serialNo, 0, stuParamIn.szSerialNo, 0, serialNo.length);
|
|
NET_OUT_SNAP_BY_EVENT stuParamOut = new NET_OUT_SNAP_BY_EVENT();
|
|
stuParamIn.write();
|
stuParamOut.write();
|
boolean ret = netsdk.CLIENT_SnapPictureByEvent(m_hLoginHandle, stuParamIn.getPointer(), stuParamOut.getPointer(), 3000);
|
if (!ret) {
|
System.err.println("指定事件抓图指令下发失败: " + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("指定事件抓图指令下发成功。");
|
}
|
|
/**
|
* 设置停车位状态
|
*/
|
public void TestSetParkingStatus() throws UnsupportedEncodingException {
|
|
// 入参
|
NET_IN_SET_PARKINGSPACE_STATE_INFO stuParamIn = new NET_IN_SET_PARKINGSPACE_STATE_INFO();
|
stuParamIn.nChannel = channel; // Todo 通道号
|
byte[] plateNumber = "浙A826RW".getBytes(encode); // Todo 车牌号
|
System.arraycopy(plateNumber, 0, stuParamIn.szPlateNumber, 0, plateNumber.length);
|
byte[] parkingNo = "A0001".getBytes(); // Todo 车位号
|
System.arraycopy(parkingNo, 0, stuParamIn.szParkingNo, 0, parkingNo.length);
|
stuParamIn.emState = EM_PARKINGSPACE_STATE.EM_PARKINGSPACE_STATE_PARKING.getValue(); // Todo 车位状态(是否有车)
|
stuParamIn.bUnNeedPic = 1; // Todo 是否需要图片 0 不需要 1 需要
|
// 出参
|
NET_OUT_SET_PARKINGSPACE_STATE_INFO stuParamOut = new NET_OUT_SET_PARKINGSPACE_STATE_INFO();
|
|
stuParamIn.write();
|
stuParamOut.write();
|
boolean ret = netsdk.CLIENT_SetParkingSpaceState(m_hLoginHandle, stuParamIn.getPointer(), stuParamOut.getPointer(), 3000);
|
if (!ret) {
|
System.err.println("设置停车位失败: " + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("设置停车位成功。");
|
}
|
|
/**
|
* 修改停车记录
|
*/
|
public void TestModifyParkingRecord() throws UnsupportedEncodingException {
|
|
// 入参
|
NET_IN_MODIFY_PARKINGRECORD_INFO stuParamIn = new NET_IN_MODIFY_PARKINGRECORD_INFO();
|
//->旧的记录
|
stuParamIn.stuOld.nChannel = channel; // Todo 旧通道号
|
byte[] oldPlateNumber = "浙A826RW".getBytes(encode); // Todo 旧车牌号
|
System.arraycopy(oldPlateNumber, 0, stuParamIn.stuOld.szPlateNumber, 0, oldPlateNumber.length);
|
byte[] oldParkingNo = "A0001".getBytes(); // Todo 旧车位号
|
System.arraycopy(oldParkingNo, 0, stuParamIn.stuOld.szParkingNo, 0, oldParkingNo.length);
|
//->新的记录
|
stuParamIn.stuNew.nChannel = channel; // Todo 新通道号
|
byte[] newPlateNumber = "沪C0M959".getBytes(encode); // Todo 新车牌号
|
System.arraycopy(newPlateNumber, 0, stuParamIn.stuNew.szPlateNumber, 0, newPlateNumber.length);
|
byte[] newParkingNo = "A0002".getBytes(); // Todo 新车位号
|
System.arraycopy(newParkingNo, 0, stuParamIn.stuNew.szParkingNo, 0, newParkingNo.length);
|
|
// 出参
|
NET_OUT_MODIFY_PARKINGRECORD_INFO stuParamOut = new NET_OUT_MODIFY_PARKINGRECORD_INFO();
|
|
stuParamIn.write();
|
stuParamOut.write();
|
boolean ret = netsdk.CLIENT_ModifyParkingRecord(m_hLoginHandle, stuParamIn.getPointer(), stuParamOut.getPointer(), 3000);
|
if (!ret) {
|
System.err.println("修改停车记录失败: " + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("修改停车记录成功。");
|
}
|
|
// 相机状态侦听句柄
|
private NetSDKLib.LLong m_hCameraStateHandle = new NetSDKLib.LLong(0); // 订阅相关
|
|
// 订阅侦听相机状态
|
public void AttachCameraState() {
|
|
this.DetachCameraState(); // 先退订
|
|
NET_IN_CAMERASTATE stuIn = new NET_IN_CAMERASTATE();
|
stuIn.nChannels = 1;
|
stuIn.pChannels = new IntByReference(-1).getPointer(); // 查全部
|
stuIn.cbCamera = ParkingCameraStateCallBack.getSingleInstance(); // 注册回调
|
|
NET_OUT_CAMERASTATE stuOut = new NET_OUT_CAMERASTATE();
|
|
stuIn.write();
|
stuOut.write();
|
m_hCameraStateHandle = netsdk.CLIENT_AttachCameraState(m_hLoginHandle, stuIn.getPointer(), stuOut.getPointer(), 3000);
|
if (m_hCameraStateHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_AttachCameraState Success\n", -1);
|
} else {
|
System.out.printf("Ch[%d] CLIENT_AttachCameraState Failed!LastError = %s\n", -1, ToolKits.getErrorCode());
|
}
|
}
|
|
// 停止订阅侦听相机状态
|
public void DetachCameraState() {
|
if (m_hCameraStateHandle.longValue() != 0) {
|
netsdk.CLIENT_DetachCameraState(m_hCameraStateHandle);
|
}
|
}
|
|
|
|
/////////////////////////////////////// 简易控制台 ///////////////////////////////////////
|
/////////////////////////////////////////////////////////////////////////////////////////
|
/////////////////////////////////////////////////////////////////////////////////////////
|
|
// 初始化测试
|
public void InitTest() {
|
|
ParkingUtils.Init(); // 初始化SDK库
|
this.loginWithHighLevel(); // 高安全登录
|
}
|
|
// 加载测试内容
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "订阅任务", "AttachEventRealLoadPic"));
|
menu.addItem(new CaseMenu.Item(this, "退订任务", "DetachEventRealLoadPic"));
|
menu.addItem(new CaseMenu.Item(this, "选择通道", "setChannelID"));
|
menu.addItem(new CaseMenu.Item(this, "手动抓图(TrafficManualSnap)", "TestParkingSnapshot"));
|
menu.addItem(new CaseMenu.Item(this, "手动抓图(通用 Snapshot 二代协议)", "TestParkingSnapshotCommon"));
|
menu.addItem(new CaseMenu.Item(this, "获取停车超时配置", "TestParkingTimeoutGetConfig"));
|
menu.addItem(new CaseMenu.Item(this, "设置停车超时配置", "TestParkingTimeoutSetConfig"));
|
menu.addItem(new CaseMenu.Item(this, "下发车辆清理接口", "TestRemoveParkingCarInfo"));
|
|
//////////////////////////////////////////// 舟曲新增 ///////////////////////////////////////////////
|
|
menu.addItem(new CaseMenu.Item(this, "事件抓图(SnapByEvent)", "TestSnapPictureByEvent"));
|
menu.addItem(new CaseMenu.Item(this, "设置停车位状态(setParkStatus)", "TestSetParkingStatus"));
|
menu.addItem(new CaseMenu.Item(this, "修改停车记录(modifyParkingInfo)", "TestModifyParkingRecord"));
|
|
//////////////////////////////////////////// 摄像头状态主动回调 //////////////////////////////////////
|
|
menu.addItem(new CaseMenu.Item(this, "摄像头状态订阅(AttachCameraState)", "AttachCameraState"));
|
menu.addItem(new CaseMenu.Item(this, "摄像头状态退订(DetachCameraState)", "DetachCameraState"));
|
|
|
menu.run();
|
}
|
|
// 结束测试
|
public void EndTest() {
|
System.out.println("End Test");
|
this.logOut(); // 退出
|
System.out.println("See You...");
|
|
ParkingUtils.cleanAndExit(); // 清理资源并退出
|
}
|
|
/////////////// 配置登陆地址，端口，用户名，密码 ////////////////////////
|
// private String m_strIpAddr = "172.24.9.9"; // 盒子
|
// private String m_strIpAddr = "172.24.3.56"; // 盒子
|
private String m_strIpAddr = "10.80.9.45"; // 盒子
|
// private String m_strIpAddr = "10.80.9.162"; // 相机
|
// private String m_strIpAddr = "172.27.1.102"; // 相机
|
// private String m_strIpAddr = "10.34.3.63"; // 模拟器
|
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
// private String m_strPassword = "admin123";
|
// private String m_strPassword = "admin123B";
|
private String m_strPassword = "2020";
|
// private String m_strPassword = "admin";
|
//////////////////////////////////////////////////////////////////////
|
|
public static void main(String[] args) {
|
ParkingImageEventDemo demo = new ParkingImageEventDemo();
|
|
if (args.length == 4) {
|
demo.m_strIpAddr = args[0];
|
demo.m_nPort = Integer.parseInt(args[1]);
|
demo.m_strUser = args[2];
|
demo.m_strPassword = args[3];
|
}
|
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
|
}
|
