package com.netsdk.demo.customize.healthCodeEx;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.Scanner;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.TimeUnit;
|
|
import com.netsdk.demo.customize.healthCodeEx.callback.RegisterServiceCallBack;
|
import com.netsdk.demo.customize.healthCodeEx.entity.DeviceInfo;
|
import com.netsdk.demo.customize.healthCodeEx.entity.ListenInfo;
|
import com.netsdk.demo.customize.healthCodeEx.module.AutoRegisterModule;
|
import com.netsdk.demo.customize.healthCodeEx.module.LoginModule;
|
import com.netsdk.demo.customize.healthCodeEx.module.SdkUtilModule;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.enumeration.EM_EVENT_IVS_TYPE;
|
import com.netsdk.lib.enumeration.EM_HEALTH_CODE_STATUS;
|
import com.netsdk.lib.enumeration.ENUMERROR;
|
import com.netsdk.lib.structure.NET_HEALTH_CODE_INFO;
|
import com.netsdk.lib.structure.NET_HSJC_INFO;
|
import com.netsdk.lib.structure.NET_TEST_RESULT;
|
import com.netsdk.lib.structure.NET_TRAVEL_INFO;
|
import com.netsdk.lib.structure.NET_VACCINE_INFO;
|
import com.netsdk.lib.structure.PassingCityByteArr;
|
import com.netsdk.lib.structure.VaccinateDateByteArr;
|
import com.sun.jna.Memory;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
|
/**
|
* @author 251823
|
* @version 1.0
|
* @description 门禁健康码功能
|
*/
|
public class HealthCodeOpenDoorDemo {
|
|
static NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;
|
// 登录句柄
|
private static NetSDKLib.LLong m_hLoginHandle = new NetSDKLib.LLong(0);
|
// 设备信息
|
private static NetSDKLib.NET_DEVICEINFO_Ex m_hDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
// 主动注册监听句柄
|
private NetSDKLib.LLong m_hListenHandle = new NetSDKLib.LLong(0);
|
|
// 用户存储注册上来的设备信息的缓存 Map 项目中请替换成其他中间件
|
private final Map<String, DeviceInfo> deviceInfoMap = new ConcurrentHashMap<>();
|
|
// 智能订阅句柄
|
private LLong attachHandle = new NetSDKLib.LLong(0);
|
|
// 编码格式
|
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";
|
}
|
}
|
/**
|
* 初始化测试
|
*/
|
public void InitTest() {
|
// 初始化SDK库
|
SdkUtilModule.Init();
|
// 登录设备
|
deviceLogin();
|
}
|
|
/**
|
* 登录设备 两种登录方式 TCP登录 主动注册
|
*/
|
public void deviceLogin() {
|
Scanner sc = new Scanner(System.in);
|
System.out.println("请输入登录方式 1 TCP登录 2 主动注册:");
|
String key = sc.nextLine().trim();
|
if ("1".equals(key)) {
|
tcpLogin();
|
} else if ("2".equals(key)) {
|
autoRegisterLogin();
|
} else {
|
System.out.println("输入信息错误...");
|
}
|
}
|
|
/**
|
* TCP登录
|
*/
|
public void tcpLogin() {
|
NetSDKLib.LLong loginHandle = LoginModule.TcpLoginWithHighSecurity(m_ipAddr, m_nPort, m_username, m_password,
|
m_hDeviceInfo); // 高安全登录
|
if (loginHandle.intValue() == 0) {
|
System.err.println("TCP登录失败:" + ENUMERROR.getErrorMessage());
|
return;
|
}
|
m_hLoginHandle.setValue(loginHandle.longValue());
|
}
|
|
/**
|
* 主动注册
|
*/
|
public void autoRegisterLogin() {
|
// 开启监听
|
serverStartListen();
|
// 登录设备
|
Scanner sc = new Scanner(System.in);
|
System.out.println("请输入设备的注册 Serial：");
|
String key = sc.nextLine().trim();
|
|
DeviceInfo deviceInfo = deviceInfoMap.get(key);
|
if (deviceInfo == null) {
|
System.out.println("注册上报的设备中没有该 Serial");
|
return;
|
}
|
|
// 注册设备的IP
|
String ipAddr = deviceInfo.ipAddress;
|
// 注册设备的端口
|
int port = deviceInfo.port;
|
// 账号
|
String username = this.username;
|
// 密码
|
String password = this.password;
|
|
NetSDKLib.LLong loginHandle = LoginModule.AutoRegisterLoginWithHighSecurity(key, ipAddr, port, username,
|
password, deviceInfo.m_stDeviceInfo);
|
if (loginHandle.longValue() == 0) {
|
System.err.println("主动注册登录失败:" + ENUMERROR.getErrorMessage());
|
return;
|
}
|
m_hLoginHandle.setValue(loginHandle.longValue());
|
// 清除此注册信息 请等待重新上报后再重新登录
|
deviceInfoMap.remove(key);
|
}
|
|
private volatile Boolean taskIsOpen = false;
|
|
/**
|
* 开启监听
|
*/
|
public void serverStartListen() {
|
m_hListenHandle = AutoRegisterModule.ServerStartListen(serverIpAddr, serverPort,
|
RegisterServiceCallBack.getInstance());
|
if (m_hListenHandle.longValue() == 0)
|
return;
|
taskIsOpen = true;
|
new Thread(this::eventListTask).start();
|
}
|
|
// 获取监听回调数据并放入缓存
|
public void eventListTask() {
|
while (taskIsOpen) {
|
try {
|
// 稍微延迟一下，避免循环的太快
|
Thread.sleep(10);
|
// 阻塞获取
|
ListenInfo listenInfo = RegisterServiceCallBack.ServerInfoQueue.poll(50, TimeUnit.MILLISECONDS);
|
if (listenInfo == null)
|
continue;
|
// 结果放入缓存
|
if (!deviceInfoMap.containsKey(listenInfo.devSerial)) {
|
deviceInfoMap.put(listenInfo.devSerial,
|
new DeviceInfo(listenInfo.devIpAddress, listenInfo.devPort));
|
System.out.println("...有新设备上报注册信息... Serial:" + listenInfo.devSerial);
|
}
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 结束监听
|
*/
|
public void serverStopListen() {
|
AutoRegisterModule.ServerStopListen(m_hListenHandle);
|
// 清空队列
|
taskIsOpen = false;
|
deviceInfoMap.clear();
|
RegisterServiceCallBack.ServerInfoQueue.clear();
|
}
|
|
/**
|
* 门禁健康码:
|
* 1.NetSDK开启门禁智能事件订阅，监听是否完成健康码开门功能；
|
* 2.NetSDK开启门禁报警事件订阅，获取人员身份信息或者健康码二维码信息；
|
* 3.三方平台解析门禁报警事件数据，通过不同方式获取健康码状态信息方式：
|
* 第一种：利用门禁报警事件获取的证件号码；
|
* 第二种：利用门禁报警事件获取的二维码数据；
|
* 4.NetSDK将健康码状态信息 和 用户校验数据（第一种证件 /第二种是UserId）下发给设备，实现人脸开门
|
* 5.NetSDK查看智能监听事件是否有智能门禁事件上报
|
*/
|
public void healthCodeOpenDoor() {
|
// 智能事件订阅,会有回调事件上报
|
AttachEventRealLoadPic();
|
// 报警事件订阅,会有回调事件上报
|
startListen();
|
}
|
|
/**
|
* 下发健康码信息
|
*/
|
public static void openDoorByHealthCode(String szCitizenIDNo, String szUserID, String szQRCode) throws UnsupportedEncodingException {
|
// 入参
|
NetSDKLib.NET_IN_FACE_OPEN_DOOR pInParam = new NetSDKLib.NET_IN_FACE_OPEN_DOOR();
|
// 门通道号
|
pInParam.nChannel = 0;
|
// 比对结果,EM_COMPARE_RESULT 默认为1
|
pInParam.emCompareResult = 1;
|
|
//判断下发到设备的参数
|
NET_HEALTH_CODE_INFO health_code_info = new NET_HEALTH_CODE_INFO();//健康码信息结构体
|
if("".equals(szCitizenIDNo)) {//是否有证件号码
|
// 传递 szUserID 和 健康码状态
|
byte[] UserID = szUserID.getBytes();
|
System.arraycopy(UserID, 0, pInParam.stuMatchInfo.szUserID, 0, UserID.length);
|
//byte[] UserName = "施超".getBytes();
|
//System.arraycopy(UserName, 0, pInParam.stuMatchInfo.szUserName, 0, UserName.length);
|
}else {
|
// 传递 szCitizenIDNo 和 健康码状态
|
byte[] CitizenIDNo = szCitizenIDNo.getBytes();
|
System.arraycopy(CitizenIDNo, 0, health_code_info.szCitizenID, 0, CitizenIDNo.length);
|
}
|
/** 以下健康码相关所有信息，都通过szQRCode或者szCitizenIDNo作为参数去三方平台获取，本demo为静态参数模拟*/
|
//健康码信息
|
health_code_info.emHealthCodeStatus = EM_HEALTH_CODE_STATUS.EM_HEALTH_CODE_STATUS_GREEN.ordinal();
|
pInParam.stuMatchInfo.pstuHealthCodeInfo = new Memory(health_code_info.size());
|
ToolKits.SetStructDataToPointer(health_code_info, pInParam.stuMatchInfo.pstuHealthCodeInfo, 0);
|
|
//核酸检测信息
|
NET_HSJC_INFO pstuHSJCInfo = new NET_HSJC_INFO();
|
System.arraycopy("2021-06-21".getBytes(), 0,
|
pstuHSJCInfo.szHSJCReportDate, 0, "2021-06-21".getBytes().length);//核酸检测报告日期 (yyyy-MM-dd)
|
pstuHSJCInfo.nHSJCExpiresIn = 14; //核酸检测报告有效期(天)
|
pstuHSJCInfo.nHSJCResult = 1; //核酸检测报告结果
|
pInParam.stuMatchInfo.pstuHSJCInfo = new Memory(pstuHSJCInfo.size());
|
ToolKits.SetStructDataToPointer(pstuHSJCInfo, pInParam.stuMatchInfo.pstuHSJCInfo, 0);
|
|
//新冠疫苗接种信息
|
NET_VACCINE_INFO pstuVaccineInfo = new NET_VACCINE_INFO();
|
pstuVaccineInfo.nVaccinateFlag = 1;//是否已接种新冠疫苗, 0: 否, 1: 是
|
System.arraycopy("新型冠状病毒灭活疫苗(Vero 细胞)".getBytes(encode), 0,
|
pstuVaccineInfo.szVaccineName, 0, "新型冠状病毒灭活疫苗(Vero 细胞)".getBytes(encode).length);//新冠疫苗名称 // 中文字符串编码根据设备实际编码设置
|
pstuVaccineInfo.nDateCount= 2;//历史接种日期有效个数
|
|
VaccinateDateByteArr[] szVaccinateDate = (VaccinateDateByteArr[])new VaccinateDateByteArr().toArray(8);
|
VaccinateDateByteArr arr1 = new VaccinateDateByteArr();
|
System.arraycopy("2021-06-21".getBytes(), 0,
|
arr1.vaccinateDateByteArr, 0, "2021-06-21".getBytes().length);
|
VaccinateDateByteArr arr2 = new VaccinateDateByteArr();
|
System.arraycopy("2021-07-21".getBytes(), 0,
|
arr2.vaccinateDateByteArr, 0, "2021-07-21".getBytes().length);
|
szVaccinateDate[0] = arr1;
|
szVaccinateDate[1] = arr2;
|
pstuVaccineInfo.szVaccinateDate = szVaccinateDate;//历史接种日期 (yyyy-MM-dd). 如提供不了时间, 则填"0000-00-00", 表示已接种
|
pInParam.stuMatchInfo.pstuVaccineInfo = new Memory(pstuVaccineInfo.size());
|
ToolKits.SetStructDataToPointer(pstuVaccineInfo, pInParam.stuMatchInfo.pstuVaccineInfo, 0);
|
|
//行程码信息
|
NET_TRAVEL_INFO pstuTravelInfo = new NET_TRAVEL_INFO();
|
pstuTravelInfo.emTravelCodeColor = 2;//行程码状态,查考枚举EM_TRAVEL_CODE_COLOR
|
pstuTravelInfo.nCityCount = 2;//最近14天经过的城市个数
|
// 城市名称写为中文
|
PassingCityByteArr[] szPassingCity = (PassingCityByteArr[])new PassingCityByteArr().toArray(16);
|
PassingCityByteArr city1 = new PassingCityByteArr();
|
|
|
System.arraycopy("上海*".getBytes(encode), 0,
|
city1.passingCityByteArr, 0, "上海*".getBytes(encode).length); // 中文字符串编码根据设备实际编码设置
|
PassingCityByteArr city2 = new PassingCityByteArr();
|
System.arraycopy("杭州".getBytes(encode), 0,
|
city2.passingCityByteArr, 0, "杭州".getBytes(encode).length);
|
szPassingCity[0] = city1;
|
szPassingCity[1] = city2;
|
pstuTravelInfo.szPassingCity =szPassingCity;// 最近14天经过的城市名. 按时间顺序排列, 最早经过的城市放第一个
|
pInParam.stuMatchInfo.pstuTravelInfo = new Memory(pstuTravelInfo.size());
|
ToolKits.SetStructDataToPointer(pstuTravelInfo, pInParam.stuMatchInfo.pstuTravelInfo, 0);
|
|
//出参
|
NetSDKLib.NET_OUT_FACE_OPEN_DOOR pOutParam = new NetSDKLib.NET_OUT_FACE_OPEN_DOOR();
|
|
boolean bRet = netsdk.CLIENT_FaceOpenDoor(m_hLoginHandle, pInParam, pOutParam, 3000);
|
if (!bRet) {
|
System.out.println("face open door failed." + ENUMERROR.getErrorMessage());
|
return;
|
} else {
|
System.out.println("同步健康码成功 CLIENT_FaceOpenDoor Success\\n");
|
}
|
}
|
|
/**
|
* 关闭业务
|
*/
|
public void exitBusiness() {
|
// 停止侦听智能事件
|
DetachEventRealLoadPic();
|
// 取消订阅报警
|
stopListen();
|
// 停止主动注册监听
|
if (m_hListenHandle.longValue() != 0) {
|
serverStopListen();
|
};
|
}
|
|
/**
|
* 订阅智能任务
|
*/
|
public void AttachEventRealLoadPic() {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
this.DetachEventRealLoadPic();
|
// 通道号 -1代表全通道
|
int channel = 0;
|
// 需要图片
|
int bNeedPicture = 1;
|
attachHandle = netsdk.CLIENT_RealLoadPictureEx(m_hLoginHandle, 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(LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) throws UnsupportedEncodingException {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
switch (Objects.requireNonNull(EM_EVENT_IVS_TYPE.getEventType(dwAlarmType))) {
|
case EVENT_IVS_ACCESS_CTL: /// < 门禁事件（带图）
|
{
|
System.out.println("智能门禁事件--------------------------");
|
|
NetSDKLib.DEV_EVENT_ACCESS_CTL_INFO msg = new NetSDKLib.DEV_EVENT_ACCESS_CTL_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
int emFaceCheck = msg.emFaceCheck; // 刷卡开门时，门禁后台校验人脸是否是同一个人
|
System.out.println("emFaceCheck:" + emFaceCheck);
|
System.out.println("nErrorCode:" + msg.nErrorCode);
|
// 二维码是否过期。默认值0
|
int emQRCodeIsExpired = msg.emQRCodeIsExpired;
|
System.out.println("emQRCodeIsExpired:" + emQRCodeIsExpired);
|
// 二维码状态
|
int emQRCodeState = msg.emQRCodeState;
|
System.out.println("emQRCodeState:" + emQRCodeState);
|
|
// 二维码截止日期
|
NetSDKLib.NET_TIME stuQRCodeValidTo = msg.stuQRCodeValidTo;
|
System.out.println("stuQRCodeValidTo:" + stuQRCodeValidTo);
|
// 上报事件数据序列号从1开始自增
|
int nBlockId = msg.nBlockId;
|
System.out.println("nBlockId:" + nBlockId);
|
// 部门名称
|
byte[] szSection = msg.szSection;
|
System.out.println("szSection:" + new String(szSection));
|
// 工作班级
|
byte[] szWorkClass = msg.szWorkClass;
|
System.out.println("szWorkClass:" + new String(szWorkClass));
|
// 测试项目
|
int emTestItems = msg.emTestItems;
|
System.out.println("emTestItems:" + emTestItems);
|
// ESD阻值测试结果
|
NET_TEST_RESULT stuTestResult = msg.stuTestResult;
|
System.out.println("emEsdResult:" + stuTestResult.emEsdResult);
|
// 门禁设备编号
|
byte[] szDeviceID = msg.szDeviceID;
|
System.out.println("szDeviceID:" + new String(szDeviceID));
|
// 用户唯一表示ID
|
byte[] szUserUniqueID = msg.szUserUniqueID;
|
System.out.println("szUserUniqueID:" + new String(szUserUniqueID));
|
// 是否使用卡命名扩展
|
int bUseCardNameEx = msg.bUseCardNameEx;
|
System.out.println("bUseCardNameEx:" + bUseCardNameEx);
|
// 卡命名扩展
|
byte[] szCardNameEx = msg.szCardNameEx;
|
System.out.println("szCardNameEx:" + new String(szCardNameEx));
|
// 核酸检测报告结果
|
int nHSJCResult = msg.nHSJCResult;
|
System.out.println("nHSJCResult:" + nHSJCResult);
|
|
// 新冠疫苗接种信息
|
NET_VACCINE_INFO stuVaccineInfo = msg.stuVaccineInfo;
|
|
int nVaccinateFlag = stuVaccineInfo.nVaccinateFlag;
|
// 是否接种疫苗
|
System.out.println("nVaccinateFlag:" + nVaccinateFlag);
|
|
byte[] szVaccineName = stuVaccineInfo.szVaccineName;
|
// 疫苗名称
|
System.out.println("szVaccineName:" + new String(szVaccineName, encode));
|
|
// 历史接种日期有效个数
|
int nDateCount = stuVaccineInfo.nDateCount;
|
System.out.println("nDateCount:" + nDateCount);
|
// 历史接种日期 (yyyy-MM-dd). 如提供不了时间, 则填"0000-00-00", 表示已接种
|
VaccinateDateByteArr[] szVaccinateDate = stuVaccineInfo.szVaccinateDate;
|
|
for (int i = 0; i < nDateCount; i++) {
|
System.out.println("date:" + new String(szVaccinateDate[i].vaccinateDateByteArr));
|
}
|
|
// 行程码信息
|
NET_TRAVEL_INFO stuTravelInfo = msg.stuTravelInfo;
|
|
// 行程码状态
|
int emTravelCodeColor = stuTravelInfo.emTravelCodeColor;
|
|
System.out.println("emTravelCodeColor:" + emTravelCodeColor);
|
|
// 最近14天经过的城市个数
|
int nCityCount = stuTravelInfo.nCityCount;
|
System.out.println("nCityCount:" + nCityCount);
|
|
// 最近14天经过的城市名. 按时间顺序排列, 最早经过的城市放第一个
|
PassingCityByteArr[] szPassingCity = stuTravelInfo.szPassingCity;
|
for (int i = 0; i < nCityCount; i++) {
|
System.out.println("city:" + new String(szPassingCity[i].passingCityByteArr,encode));
|
}
|
String Picture = picturePath + "\\" +"EVENT_IVS_ACCESS_CTL"+ System.currentTimeMillis() + ".jpg";
|
ToolKits.savePicture(pBuffer, 0, dwBufSize, Picture);
|
break;
|
}
|
default:
|
System.out.println("其他事件--------------------" + dwAlarmType);
|
break;
|
}
|
|
return 0;
|
}
|
}
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (attachHandle.longValue() != 0) {
|
boolean flg = netsdk.CLIENT_StopLoadPic(attachHandle);
|
if(flg) {
|
System.out.println("CLIENT_StopLoadPic success");
|
}
|
}
|
}
|
|
/**
|
* 订阅报警信息
|
*
|
*/
|
public void startListen() {
|
// 设置报警回调函数，设置一次就可以
|
netsdk.CLIENT_SetDVRMessCallBack(fAlarmAccessDataCB.getInstance(), null);
|
|
// 订阅报警
|
boolean bRet = netsdk.CLIENT_StartListenEx(m_hLoginHandle);
|
if (!bRet) {
|
System.err.println("CLIENT_StartListenEx error ! LastError = 0x%x\n" + netsdk.CLIENT_GetLastError());
|
} else {
|
System.out.println("CLIENT_StartListenEx Success");
|
}
|
}
|
|
/**
|
* 报警事件回调
|
*/
|
private static class fAlarmAccessDataCB implements NetSDKLib.fMessCallBack {
|
private static fAlarmAccessDataCB instance = new fAlarmAccessDataCB();
|
|
private fAlarmAccessDataCB() {
|
}
|
|
public static fAlarmAccessDataCB getInstance() {
|
return instance;
|
}
|
|
public boolean invoke(int lCommand, LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP,
|
NativeLong nDevicePort, Pointer dwUser) {
|
switch (lCommand) {
|
case NetSDKLib.NET_ALARM_ACCESS_CTL_EVENT: { // 门禁事件（不带图）
|
NetSDKLib.ALARM_ACCESS_CTL_EVENT_INFO msg = new NetSDKLib.ALARM_ACCESS_CTL_EVENT_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("普通门禁事件--------------------------");
|
int nErrorCode = msg.nErrorCode; //健康码模式
|
if(nErrorCode == 112) {
|
// 获取参数
|
// 证件号 szCitizenIDNo
|
String szCitizenIDNo = new String(msg.szCitizenIDNo).trim();
|
// 开门用户 szUserID
|
String szUserID = new String(msg.szUserID).trim();
|
// 二维码 szQRCode
|
String szQRCode = new String(msg.szQRCode).trim();
|
System.out.println("证件号:"+szCitizenIDNo);
|
System.out.println("开门用户:"+szUserID);
|
System.out.println("二维码:"+szQRCode);
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
openDoorByHealthCode(szCitizenIDNo,szUserID,szQRCode);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
}).start();
|
}else {
|
System.out.println("nErrorCode："+msg.nErrorCode);
|
}
|
break;
|
}
|
}
|
return true;
|
}
|
}
|
|
|
/**
|
* 取消订阅报警信息
|
*/
|
public void stopListen() {
|
// 停止订阅报警
|
boolean bRet = netsdk.CLIENT_StopListen(m_hLoginHandle);
|
if (bRet) {
|
System.out.println("CLIENT_StopListen Success");
|
}
|
}
|
|
/**
|
* 业务操作
|
*/
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "门禁健康码开门", "healthCodeOpenDoor"));
|
menu.addItem(new CaseMenu.Item(this, "关闭业务", "exitBusiness"));
|
menu.run();
|
}
|
|
/**
|
* 结束测试
|
*/
|
public void EndTest() {
|
System.out.println("End Test");
|
// 退出登录
|
if (m_hLoginHandle.longValue() != 0) {
|
LoginModule.logout(m_hLoginHandle);
|
}
|
System.out.println("See You...");
|
// 工程关闭时，释放SDK资源
|
SdkUtilModule.cleanup();
|
System.exit(0);
|
}
|
|
/////////////// 配置TCP登陆地址，端口，用户名，密码 ////////////////////////
|
private String m_ipAddr = "172.10.5.164";
|
private int m_nPort = 37777;
|
private String m_username = "admin";
|
private String m_password = "admin123";
|
//////////////////////////////////////////////////////////////////////
|
|
/////////////// 注册地址(服务器 这里是运行此Demo的电脑IP) 监听端口 //////////////////////
|
private final String serverIpAddr = "10.34.3.83";
|
private final int serverPort = 9500; // 注意不要和其他程序发生冲突
|
private String username = "admin";
|
private String password = "admin123";
|
/////////////////////////////////////////////////////////////////////////////////////
|
|
public static void main(String[] args) {
|
HealthCodeOpenDoorDemo demo = new HealthCodeOpenDoorDemo();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
