package com.netsdk.demo.intelligentTraffic;
|
|
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.SdkStructure;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
/**
|
* 智能交通违法代码配置
|
* @author 29779
|
*
|
*/
|
public class TrafficViolationCode {
|
|
static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
private static LLong loginHandle = new LLong(0);
|
|
String address = "172.32.4.229";
|
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);
|
}
|
}
|
|
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);
|
}
|
}
|
|
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 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);
|
}
|
|
private static boolean SetDevConfig(String strCmd , SdkStructure cmdObject , LLong hHandle , int nChn ) {
|
boolean result = false;
|
int nBufferLen = 100*1024;
|
byte szBuffer[] = new byte[nBufferLen];
|
for(int i=0; i<nBufferLen; i++)szBuffer[i]=0;
|
IntByReference error = new IntByReference();
|
IntByReference restart = new IntByReference();
|
|
cmdObject.write();
|
result = configApi.CLIENT_PacketData(strCmd, cmdObject.getPointer(), cmdObject.size(),szBuffer, nBufferLen);
|
cmdObject.read();
|
if (!result) {
|
System.out.println("Packet " + strCmd + " Config Failed!");
|
return result;
|
}
|
result = netsdkApi.CLIENT_SetNewDevConfig(hHandle, strCmd, nChn, szBuffer, nBufferLen, error, restart, 3000);
|
if (!result) {
|
System.out.printf("Set %s Config Failed! Last Error = %x\n" , strCmd , netsdkApi.CLIENT_GetLastError());
|
}
|
|
return result;
|
}
|
|
private static boolean GetDevConfig(String strCmd , SdkStructure cmdObject , LLong hHandle , int nChn) {
|
boolean result = false;
|
IntByReference error = new IntByReference();
|
int nBufferLen = 100*1024;
|
byte[] strBuffer = new byte[nBufferLen];
|
|
result = netsdkApi.CLIENT_GetNewDevConfig( hHandle, strCmd , nChn, strBuffer, nBufferLen,error,3000,null);
|
if (!result) {
|
System.out.printf("Get %s Config Failed!Last Error = %x\n" , strCmd , netsdkApi.CLIENT_GetLastError());
|
return result;
|
}
|
|
cmdObject.write();
|
result = configApi.CLIENT_ParseData(strCmd, strBuffer, cmdObject.getPointer(), cmdObject.size(), null);
|
cmdObject.read();
|
|
return result;
|
}
|
|
public void RunTest() {
|
System.out.println("Run Test");
|
|
String cmd = NetSDKLib.CFG_CMD_TRAFFICGLOBAL;
|
NetSDKLib.CFG_TRAFFICGLOBAL_INFO cmdObject = new NetSDKLib.CFG_TRAFFICGLOBAL_INFO();
|
|
if (GetDevConfig(cmd, cmdObject, loginHandle, -1)) {
|
System.out.println("Get traffic global");
|
|
NetSDKLib.VIOLATIONCODE_INFO code = new NetSDKLib.VIOLATIONCODE_INFO();
|
code = cmdObject.stViolationCode;
|
|
System.out.println("逆行：" + new String(code.szRetrograde).trim());
|
System.out.println("逆行：" + new String(code.szRetrogradeDesc).trim());
|
System.out.println("逆行：" + new String(code.szRetrogradeShowName).trim());
|
|
/// 修改逆行码, 需要用 System.arraycopy 不能直接 赋值
|
String retrogade = "1301";
|
System.arraycopy(retrogade.getBytes(), 0, code.szRetrograde, 0, retrogade.length());
|
}
|
|
if (SetDevConfig(cmd, cmdObject, loginHandle, -1)) {
|
System.out.println("Set traffic global");
|
}
|
}
|
|
public static void main(String[]args)
|
{
|
TrafficViolationCode demo = new TrafficViolationCode();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
