package com.netsdk.demo.customize.securityCheck;
|
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_EVENT_IVS_TYPE;
|
import com.netsdk.lib.structure.DEV_EVENT_SECURITYGATE_PERSONALARM_INFO;
|
import com.netsdk.lib.structure.NET_SECURITYGATE_ALARM_FACE_INFO;
|
import com.netsdk.lib.structure.NET_TIME_EX;
|
import com.sun.jna.Pointer;
|
|
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.util.Objects;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description 安检门温度检测 安检门事件
|
* @date 2021/6/30
|
*/
|
public class TemperatureDetectionDemo {
|
|
/**
|
* 安检门
|
*/
|
private String m_strIpAddr = "10.35.232.160";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
|
|
static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
|
|
// public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
// 登陆句柄
|
private static NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);
|
|
// 订阅句柄
|
private static NetSDKLib.LLong AttachHandle = new NetSDKLib.LLong(0);
|
|
// 设备信息扩展
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
/**
|
* 设备断线回调
|
*/
|
private static class DisconnectCallback implements NetSDKLib.fDisConnect {
|
private static TemperatureDetectionDemo.DisconnectCallback instance = new TemperatureDetectionDemo.DisconnectCallback();
|
|
private DisconnectCallback() {
|
}
|
|
public static DisconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(NetSDKLib.LLong lLoginID, 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 TemperatureDetectionDemo.HaveReconnectCallback instance = new TemperatureDetectionDemo.HaveReconnectCallback();
|
|
private HaveReconnectCallback() {
|
}
|
|
public static HaveReconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%s:%d] HaveReconnected!\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
|
public void InitTest(){
|
// 初始化SDK库
|
netSdk.CLIENT_Init(TemperatureDetectionDemo.DisconnectCallback.getInstance(), null);
|
|
// 设置断线重连成功回调函数
|
netSdk.CLIENT_SetAutoReconnect(TemperatureDetectionDemo.HaveReconnectCallback.getInstance(), null);
|
|
//打开日志，可选0
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator + "sdk.log";
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
if (!netSdk.CLIENT_LogOpen(setLog)){
|
System.err.println("Open SDK Log Failed!!!");
|
}
|
|
loginWithHighLevel();
|
}
|
/**
|
* 高安全登录
|
*/
|
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
|
loginHandle = netSdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
if (loginHandle.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 + "个通道");
|
}
|
}
|
|
/**
|
* 退出清理环境
|
*/
|
public void LoginOut(){
|
System.out.println("End Test");
|
if( loginHandle.longValue() != 0)
|
{
|
netSdk.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netSdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
|
// 编码格式
|
public static String encode;
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win64-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
}
|
|
|
/**
|
* 选择通道
|
*/
|
private int channel = 0;
|
|
|
/**
|
* 订阅智能任务
|
*/
|
public void attachIVSEvent() {
|
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
this.DetachEventRealLoadPic();
|
// 需要图片
|
int bNeedPicture = 1;
|
//订阅所有事件
|
AttachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_ALL, bNeedPicture,
|
AnalyzerDataCB.getInstance(), null, null);
|
if (AttachHandle.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());
|
}
|
|
}
|
|
|
/**
|
* 报警事件（智能）回调
|
*/
|
private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
private final File picturePath;
|
private static AnalyzerDataCB instance;
|
|
private AnalyzerDataCB() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdirs();
|
}
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
if (instance == null) {
|
synchronized (AnalyzerDataCB.class) {
|
if (instance == null) {
|
instance = new AnalyzerDataCB();
|
}
|
}
|
}
|
return instance;
|
}
|
|
public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
switch (Objects.requireNonNull(EM_EVENT_IVS_TYPE.getEventType(dwAlarmType))) {
|
case EVENT_IVS_ANATOMY_TEMP_DETECT: {// 人体温智能检测事件(对应 DEV_EVENT_ANATOMY_TEMP_DETECT_INFO)
|
|
NetSDKLib.DEV_EVENT_ANATOMY_TEMP_DETECT_INFO msg = new NetSDKLib.DEV_EVENT_ANATOMY_TEMP_DETECT_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
System.out.println("人体温智能检测事件");
|
|
// 通道号
|
int nChannelID = msg.nChannelID;
|
|
System.out.println("nChannelID:"+nChannelID);
|
|
// 1:开始 2:停止
|
int nAction = msg.nAction;
|
|
System.out.println("nAction:"+nAction);
|
|
// 事件名称
|
byte[] szName = msg.szName;
|
try {
|
String name = new String(szName, "gbk");
|
System.out.println("szName:"+name);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
|
|
// 时间戳(单位是毫秒)
|
double pts = msg.PTS;
|
|
System.out.println("pts:"+pts);
|
|
// 事件发生的时间
|
NetSDKLib.NET_TIME_EX utc = msg.UTC;
|
|
System.out.println("utc:"+utc);
|
|
// 事件ID
|
int nEventID = msg.nEventID;
|
|
System.out.println("nEventID:"+nEventID);
|
|
|
//智能事件所属大类(对应枚举类型EM_CLASS_TYPE)
|
int emClassType = msg.emClassType;
|
|
System.out.println("emClassType:"+emClassType);
|
|
// 事件触发的预置点号, 从1开始, 没有该字段,表示预置点未知
|
int nPresetID = msg.nPresetID;
|
System.out.println("nPresetID:"+nPresetID);
|
|
|
NetSDKLib.NET_MAN_TEMP_INFO stManTempInfo = msg.stManTempInfo;
|
|
System.out.printf("【区域内人员体温信息】:nObjectID="+stManTempInfo.nObjectID+",dbHighTemp="
|
+stManTempInfo.dbHighTemp+",nTempUnit="+stManTempInfo.nTempUnit
|
+",bIsOverTemp="+stManTempInfo.bIsOverTemp+",bIsUnderTemp="
|
+stManTempInfo.bIsUnderTemp+",emMaskDetectResult="+stManTempInfo.emMaskDetectResult+
|
",nAge="+stManTempInfo.nAge+",emSex="+stManTempInfo.emSex
|
+",stThermalRect_top="+stManTempInfo.stThermalRect.top
|
+",stThermalRect_left="+stManTempInfo.stThermalRect.left
|
+",stThermalRect_right="+stManTempInfo.stThermalRect.right
|
+",stThermalRect_bottom="+stManTempInfo.stThermalRect.bottom+"\n");
|
|
//可见光全景图
|
if(msg.stVisSceneImage!=null && msg.stVisSceneImage.nLength> 0){
|
String visibleLightPicture = picturePath + "\\" + System.currentTimeMillis() + "visibleLight.jpg";
|
ToolKits.savePicture(pBuffer, msg.stVisSceneImage.nOffset, msg.stVisSceneImage.nLength, visibleLightPicture);
|
}
|
//热成像全景图
|
if(msg.stThermalSceneImage!=null && msg.stThermalSceneImage.nLength> 0){
|
String thermographyPicture = picturePath + "\\" + System.currentTimeMillis() + "thermography.jpg";
|
ToolKits.savePicture(pBuffer, msg.stThermalSceneImage.nOffset, msg.stThermalSceneImage.nLength, thermographyPicture);
|
}
|
|
break;
|
}
|
case EVENT_IVS_SECURITYGATE_PERSONALARM: { //安检门人员报警事件
|
|
System.out.println("安检门人员报警事件");
|
|
DEV_EVENT_SECURITYGATE_PERSONALARM_INFO msg = new DEV_EVENT_SECURITYGATE_PERSONALARM_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
// 通道号
|
int nChannelID = msg.nChannelID;
|
|
System.out.println("nChannelID:" + nChannelID);
|
|
// 0:脉冲 1:开始 2:停止
|
int nAction = msg.nAction;
|
|
System.out.println("nAction:" + nAction);
|
|
// 事件名称
|
byte[] szName = msg.szName;
|
try {
|
String name = new String(szName, "gbk");
|
System.out.println("szName:" + name);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
// 时间戳(单位是毫秒)
|
double pts = msg.PTS;
|
|
System.out.println("pts:" + pts);
|
|
// 事件发生的时间
|
NET_TIME_EX utc = msg.UTC;
|
|
System.out.println("utc:" + utc);
|
|
|
// 事件ID
|
int nEventID = msg.nEventID;
|
|
System.out.println("nEventID:" + nEventID);
|
|
/**
|
* 人员通过方向枚举,参考枚举{@link com.netsdk.lib.enumeration.EM_SECURITYGATE_PERSON_PASS_DIRECTION }
|
*/
|
int emDirection = msg.emDirection;
|
|
System.out.println("emDirection:" + emDirection);
|
|
/**
|
* 报警级别,参考枚举{@link com.netsdk.lib.enumeration.EM_SECURITYGATE_ALARM_LEVEL }
|
*/
|
int emAlarmLevel = msg.emAlarmLevel;
|
|
System.out.println("emAlarmLevel:" + emAlarmLevel);
|
|
// 关联进入通道
|
int nChannelIn = msg.nChannelIn;
|
System.out.println("nChannelIn:" + nChannelIn);
|
|
// 关联离开通道
|
int channelOut = msg.ChannelOut;
|
System.out.println("ChannelOut:" + channelOut);
|
|
// 报警位置个数
|
int nAlarmPositionNum = msg.nAlarmPositionNum;
|
System.out.println("nAlarmPositionNum:" + nAlarmPositionNum);
|
|
|
// 人脸信息
|
NET_SECURITYGATE_ALARM_FACE_INFO faceInfo = msg.stuSecurityGateFaceInfo;
|
System.out.println("【人脸信息】:emSex=" + faceInfo.emSex + ",nAge=" + faceInfo.nAge + ",emEmotion="
|
+ faceInfo.emEmotion + ",emGlasses=" + faceInfo.emGlasses + ",emMask=" + faceInfo.emMask + ",emBeard=" +
|
faceInfo.emBeard + ",nAttractive=" + faceInfo.nAttractive
|
+ ",emMouth=" + faceInfo.emMouth + ",emEye=" + faceInfo.emEye + ",fTemperature=" + faceInfo.fTemperature + ",emTempUnit="
|
+ faceInfo.emTempUnit + ",emTempType=" + faceInfo.emTempType);
|
|
|
/**
|
* 报警位置,参考枚举{@link com.netsdk.lib.enumeration.EM_SECURITYGATE_ALARM_POSITION }
|
*/
|
// 报警位置
|
int[] emAlarmPosition = msg.emAlarmPosition;
|
|
for (int i = 0; i < emAlarmPosition.length; i++) {
|
System.out.println("报警位置:" + i + "[" + emAlarmPosition[i] + "]");
|
}
|
|
//人脸图片信息
|
if (msg.stuImageInfo != null && msg.stuImageInfo.nLength > 0) {
|
String facePicture = picturePath + "\\" + System.currentTimeMillis() + "face.jpg";
|
ToolKits.savePicture(pBuffer, msg.stuImageInfo.nOffSet, msg.stuImageInfo.nLength, facePicture);
|
}
|
|
//人脸小图
|
if (msg.stuFaceImageInfo != null && msg.stuFaceImageInfo.nLength > 0) {
|
String faceSmallPicture = picturePath + "\\" + System.currentTimeMillis() + "faceSmall.jpg";
|
ToolKits.savePicture(pBuffer, msg.stuFaceImageInfo.nOffSet, msg.stuFaceImageInfo.nLength, faceSmallPicture);
|
}
|
|
|
break;
|
}
|
default:
|
System.out.println("其他事件--------------------" + dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
|
}
|
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (AttachHandle.longValue() != 0) {
|
netSdk.CLIENT_StopLoadPic(AttachHandle);
|
}
|
}
|
|
public void RunTest(){
|
CaseMenu menu=new CaseMenu();
|
menu.addItem((new CaseMenu.Item(this , "attachIVSEvent" , "attachIVSEvent")));
|
menu.addItem((new CaseMenu.Item(this , "DetachEventRealLoadPic" , "DetachEventRealLoadPic")));
|
menu.run();
|
}
|
|
public static void main(String []args){
|
TemperatureDetectionDemo TD=new TemperatureDetectionDemo();
|
TD.InitTest();
|
TD.RunTest();
|
TD.LoginOut();
|
}
|
}
|
