package com.netsdk.demo.customize;
|
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.util.Scanner;
|
|
import static com.netsdk.lib.NetSDKLib.EVENT_IVS_ALL;
|
import static com.netsdk.lib.NetSDKLib.EVENT_IVS_CONSUMPTION_EVENT;
|
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description ERR220302055 & GIP240125006
|
* @date 2022/3/7 10:37
|
*/
|
public class RecordAccessDemo extends Initialization {
|
|
NetSDKLib.LLong attachHandle=new NetSDKLib.LLong(0);
|
|
|
static int consumptionAmount;
|
|
static byte[] szUserIDA;
|
|
static byte[] transactionSerialNumber;
|
|
//1、获取和设置消费相关策略
|
int channel= 0;
|
public void getAndSetConsumption(){
|
|
NET_CFG_CONSUMPTION_STRATEGY_INFO msg=new NET_CFG_CONSUMPTION_STRATEGY_INFO();
|
|
Pointer getInfo=new Memory(msg.size());
|
getInfo.clear(msg.size());
|
ToolKits.SetStructDataToPointer(msg, getInfo, 0);
|
|
|
boolean b
|
= netSdk.CLIENT_GetConfig(loginHandle, NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_CONSUMPTION_STRATEGY, channel, getInfo, msg.size(), 3000, null);
|
|
if(!b) {
|
System.out.println("getconfig failed, ErrCode="+ ToolKits.getErrorCode());
|
return;
|
}else {
|
System.out.println("getconfig success");
|
}
|
|
ToolKits.GetPointerData(getInfo, msg);
|
|
System.out.println("getInfo:"+msg.toString());
|
|
/** 消费模式 {@link com.netsdk.lib.enumeration.EM_NET_CONSUMPTION_MODE} */
|
msg.emMode=1;
|
/** 同一个人消费间隔, 单位：秒，取值范围[1,600]
|
*/
|
msg.nConsumptionInterval=10;
|
/**
|
* 离线消费使能, TRUE:支持离线消费 FALSE:不支持离线消费
|
*/
|
msg.bOfflineEnable=true;
|
|
Pointer setInfo=new Memory(msg.size());
|
setInfo.clear(msg.size());
|
ToolKits.SetStructDataToPointer(msg, setInfo, 0);
|
|
b = netSdk.CLIENT_SetConfig(loginHandle, NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_CONSUMPTION_STRATEGY, channel, setInfo, msg.size(), 3000, new IntByReference(0), null);
|
|
if(!b) {
|
System.out.println("CLIENT_SetConfig failed, ErrCode="+ ToolKits.getErrorCode());
|
return;
|
}else {
|
System.out.println("setconfig success");
|
}
|
ToolKits.GetPointerData(setInfo, msg);
|
|
System.out.println("setInfo:"+msg.toString());
|
|
}
|
//设置消费结果
|
public static void SetConsumeResult(){
|
/**
|
* consumptionAmount
|
*/
|
NET_IN_SET_CONSUME_RESULT input=new NET_IN_SET_CONSUME_RESULT();
|
|
// 用户ID
|
input.szUserID=szUserIDA;
|
|
|
// ToolKits.StringToByteArray(uid,szUserID);
|
//消费后余额，如果消费失败则是消费前余额，单位分。
|
input.nRemainAmount=consumptionAmount;
|
// 平台固定消费金额，单位(分)
|
input.nConsumptionAmount =consumptionAmount;
|
// 消费流水号
|
input.szTransactionSerialNumber=transactionSerialNumber;
|
|
//消费成功与否
|
input.bConsumeResult=1;
|
|
|
String platDisplayText="总次数：200；剩余次数：5";
|
|
StringToByteArr(platDisplayText,input.szPlatDisplayText,encode);
|
|
Pointer inputMemory = new Memory(input.size());
|
|
inputMemory.clear(input.size());
|
|
ToolKits.SetStructDataToPointer(input,inputMemory,0);
|
|
NET_OUT_SET_CONSUME_RESULT out=new NET_OUT_SET_CONSUME_RESULT();
|
|
Pointer outMemory = new Memory(out.size());
|
|
outMemory.clear(out.size());
|
|
ToolKits.SetStructDataToPointer(out,outMemory,0);
|
|
boolean b
|
= netSdk.CLIENT_SetConsumeResult(loginHandle, inputMemory, outMemory, 3000);
|
|
if(!b) {
|
System.out.println("CLIENT_SetConsumeResult failed, ErrCode="+ ToolKits.getErrorCode());
|
return;
|
}else {
|
System.out.println("CLIENT_SetConsumeResult success");
|
}
|
|
}
|
|
public static void StringToByteArr(String src, byte[] dst,String encode) {
|
try {
|
byte[] bytes = src.getBytes(encode);
|
for (int i = 0; i < bytes.length; i++) {
|
dst[i] = (byte) bytes[i];
|
}
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
|
/**
|
* 韦根配置
|
*/
|
public void getSetWIEGAND(){
|
|
NET_CFG_WIEGAND_INFO msg=new NET_CFG_WIEGAND_INFO();
|
|
Pointer getInfo=new Memory(msg.size());
|
getInfo.clear(msg.size());
|
ToolKits.SetStructDataToPointer(msg, getInfo, 0);
|
|
|
boolean b
|
= netSdk.CLIENT_GetConfig(loginHandle, NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_WIEGAND, channel, getInfo, msg.size(), 3000, null);
|
|
if(!b) {
|
System.out.println("getconfig failed, ErrCode="+ToolKits.getErrorCode());
|
return;
|
}else {
|
System.out.println("getconfig success");
|
}
|
|
ToolKits.GetPointerData(getInfo, msg);
|
|
//stuWiegandInfos的有效元素
|
int nCount = msg.nCount;
|
|
NET_WIEGAND_INFO[] stuWiegandInfos
|
= msg.stuWiegandInfos;
|
|
for(int i=0;i<nCount;i++){
|
NET_WIEGAND_INFO stuWiegandInfo
|
= stuWiegandInfos[i];
|
stuWiegandInfo.emMode= 0;
|
stuWiegandInfo.emOutType=1;
|
|
}
|
|
Pointer setInfo=new Memory(msg.size());
|
setInfo.clear(msg.size());
|
ToolKits.SetStructDataToPointer(msg, setInfo, 0);
|
|
b = netSdk.CLIENT_SetConfig(loginHandle, NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_WIEGAND, channel, setInfo, msg.size(), 3000, new IntByReference(0), null);
|
|
if(!b) {
|
System.out.println("CLIENT_SetConfig NET_EM_CFG_WIEGAND failed, ErrCode="+ToolKits.getErrorCode());
|
return;
|
}else {
|
System.out.println("setconfig NET_EM_CFG_WIEGAND success");
|
}
|
|
|
}
|
|
|
/**
|
* 插入密码成功后返回的编号, 用于后续的更新、删除等操作
|
*/
|
private int passwordRecordNo = 0;
|
|
/**
|
* 插入密码
|
*/
|
public void insertPassword() {
|
|
// 密码的编号, 支持500个, 不重复
|
final String userId = "1";
|
|
// 开门密码
|
final String openDoorPassword = "888887";
|
|
NetSDKLib.NET_RECORDSET_ACCESS_CTL_PWD accessInsert = new NetSDKLib.NET_RECORDSET_ACCESS_CTL_PWD();
|
|
System.arraycopy(userId.getBytes(), 0, accessInsert.szUserID,
|
0, userId.getBytes().length);
|
System.arraycopy(openDoorPassword.getBytes(), 0, accessInsert.szDoorOpenPwd,
|
0, openDoorPassword.getBytes().length);
|
|
/// 以下字段可以固定, 目前设备做了限制必须要带
|
accessInsert.nDoorNum = 2; // 门个数 表示双门控制器
|
accessInsert.sznDoors[0] = 0; // 表示第一个门有权限
|
accessInsert.sznDoors[1] = 1; // 表示第二个门有权限
|
accessInsert.nTimeSectionNum = 2; // 与门数对应
|
accessInsert.nTimeSectionIndex[0] = 255; // 表示第一个门全天有效
|
accessInsert.nTimeSectionIndex[1] = 255; // 表示第二个门全天有效
|
|
NetSDKLib.NET_CTRL_RECORDSET_INSERT_PARAM insert = new NetSDKLib.NET_CTRL_RECORDSET_INSERT_PARAM();
|
insert.stuCtrlRecordSetInfo.emType = NetSDKLib.EM_NET_RECORD_TYPE.NET_RECORD_ACCESSCTLPWD; // 记录集信息类型
|
insert.stuCtrlRecordSetInfo.pBuf = accessInsert.getPointer();
|
|
accessInsert.write();
|
insert.write();
|
boolean success = netSdk.CLIENT_ControlDevice(loginHandle,
|
NetSDKLib.CtrlType.CTRLTYPE_CTRL_RECORDSET_INSERT, insert.getPointer(), 5000);
|
insert.read();
|
accessInsert.read();
|
|
if(!success) {
|
System.err.println("insert password failed. 0x" + Long.toHexString(netSdk.CLIENT_GetLastError()));
|
return;
|
}
|
|
System.out.println("Password nRecNo : " + insert.stuCtrlRecordSetResult.nRecNo);
|
passwordRecordNo = insert.stuCtrlRecordSetResult.nRecNo;
|
}
|
|
/**
|
* 更新密码
|
*/
|
public void updatePassword() {
|
|
NetSDKLib.NET_RECORDSET_ACCESS_CTL_PWD accessUpdate = new NetSDKLib.NET_RECORDSET_ACCESS_CTL_PWD();
|
accessUpdate.nRecNo = passwordRecordNo; // 需要修改的记录集编号,由插入获得
|
|
/// 密码编号, 必填否则更新密码不起作用
|
final String userId = String.valueOf(accessUpdate.nRecNo);
|
System.arraycopy(userId.getBytes(), 0, accessUpdate.szUserID,
|
0, userId.getBytes().length);
|
|
// 新的开门密码
|
final String newPassord = "333333";
|
System.arraycopy(newPassord.getBytes(), 0,
|
accessUpdate.szDoorOpenPwd, 0, newPassord.getBytes().length);
|
|
/// 以下字段可以固定, 目前设备做了限制必须要带
|
accessUpdate.nDoorNum = 2; // 门个数 表示双门控制器
|
accessUpdate.sznDoors[0] = 0; // 表示第一个门有权限
|
accessUpdate.sznDoors[1] = 1; // 表示第二个门有权限
|
accessUpdate.nTimeSectionNum = 2; // 与门数对应
|
accessUpdate.nTimeSectionIndex[0] = 255; // 表示第一个门全天有效
|
accessUpdate.nTimeSectionIndex[1] = 255; // 表示第二个门全天有效
|
|
NetSDKLib.NET_CTRL_RECORDSET_PARAM update = new NetSDKLib.NET_CTRL_RECORDSET_PARAM();
|
update.emType = NetSDKLib.EM_NET_RECORD_TYPE.NET_RECORD_ACCESSCTLPWD; // 记录集信息类型
|
update.pBuf = accessUpdate.getPointer();
|
|
accessUpdate.write();
|
update.write();
|
boolean result = netSdk.CLIENT_ControlDevice(loginHandle,
|
NetSDKLib.CtrlType.CTRLTYPE_CTRL_RECORDSET_UPDATE, update.getPointer(), 5000);
|
update.read();
|
accessUpdate.read();
|
if (!result) {
|
System.err.println("update password failed. 0x" + Long.toHexString(netSdk.CLIENT_GetLastError()));
|
}else {
|
System.out.println("update password success");
|
}
|
}
|
|
|
/**
|
* 删除密码
|
*/
|
public void deletePassword() {
|
NetSDKLib.NET_CTRL_RECORDSET_PARAM remove = new NetSDKLib.NET_CTRL_RECORDSET_PARAM();
|
remove.emType = NetSDKLib.EM_NET_RECORD_TYPE.NET_RECORD_ACCESSCTLPWD;
|
remove.pBuf = new IntByReference(passwordRecordNo).getPointer();
|
|
remove.write();
|
boolean result = netSdk.CLIENT_ControlDevice(loginHandle,
|
NetSDKLib.CtrlType.CTRLTYPE_CTRL_RECORDSET_REMOVE, remove.getPointer(), 5000);
|
remove.read();
|
|
if(!result){
|
System.err.println(" remove pawssword failed. 0x" + Long.toHexString(netSdk.CLIENT_GetLastError()));
|
}else {
|
System.out.println("remove password success");
|
}
|
}
|
|
/**
|
* 订阅智能任务
|
*/
|
|
public NetSDKLib.LLong AttachEventRealLoadPic() {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
if(attachHandle.longValue()!=0){
|
this.DetachEventRealLoadPic();
|
}
|
|
// 需要图片
|
int bNeedPicture = 1;
|
IntParam intParam=new IntParam();
|
|
Pointer reserved = new Memory(intParam.size());
|
|
reserved.clear(intParam.size());
|
|
ToolKits.SetStructDataToPointer(intParam,reserved,0);
|
System.out.println("reserved:"+intParam.intParam);
|
attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, EVENT_IVS_ALL, bNeedPicture,
|
AnalyzerDataCB.getInstance(), null, reserved);
|
if (attachHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
|
} else {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
}
|
|
return attachHandle;
|
}
|
public static class IntParam extends NetSDKLib.SdkStructure {
|
public int intParam ;
|
}
|
|
/**
|
* 根据用户ID获取用户信息
|
*/
|
public void operateAccessUserService(){
|
|
String[] userIDs = {"3"};
|
|
// 获取的用户个数
|
int nMaxNum = userIDs.length;
|
|
// /////////////////////////// 以下固定写法
|
// /////////////////////////////////////
|
// 用户操作类型
|
// 获取用户
|
int emtype = NetSDKLib.NET_EM_ACCESS_CTL_USER_SERVICE.NET_EM_ACCESS_CTL_USER_SERVICE_GET;
|
|
/**
|
* 用户信息数组
|
*/
|
// 先初始化用户信息数组
|
NetSDKLib.NET_ACCESS_USER_INFO[] users = new NetSDKLib.NET_ACCESS_USER_INFO[nMaxNum];
|
|
|
// 初始化返回的失败信息数组
|
NetSDKLib.FAIL_CODE[] failCodes = new NetSDKLib.FAIL_CODE[nMaxNum];
|
|
for (int i = 0; i < nMaxNum; i++) {
|
NetSDKLib.NET_ACCESS_USER_INFO info = new NetSDKLib.NET_ACCESS_USER_INFO();
|
int size
|
= new NET_FLOORS_INFO().size();
|
|
Pointer floors =new Memory(size);
|
|
floors.clear(size);
|
|
info.pstuFloorsEx2=floors;
|
|
NET_ACCESS_USER_INFO_EX pstuUserInfoEx=
|
new NET_ACCESS_USER_INFO_EX();
|
|
Pointer pstuUserInfo
|
= new Memory(pstuUserInfoEx.size());
|
|
pstuUserInfo.clear(pstuUserInfoEx.size());
|
|
info.pstuUserInfoEx=pstuUserInfo;
|
|
users[i]=info;
|
|
failCodes[i] = new NetSDKLib.FAIL_CODE();
|
}
|
|
/**
|
* 入参 NET_IN_ACCESS_USER_SERVICE_GET
|
*/
|
NetSDKLib.NET_IN_ACCESS_USER_SERVICE_GET stIn = new NetSDKLib.NET_IN_ACCESS_USER_SERVICE_GET();
|
// 用户ID个数
|
stIn.nUserNum = userIDs.length;
|
|
// 用户ID
|
for (int i = 0; i < userIDs.length; i++) {
|
System.arraycopy(userIDs[i].getBytes(), 0,
|
stIn.szUserIDs[i].szUserID, 0, userIDs[i].getBytes().length);
|
}
|
|
/**
|
* 出参 NET_OUT_ACCESS_USER_SERVICE_GET
|
*/
|
NetSDKLib.NET_OUT_ACCESS_USER_SERVICE_GET stOut = new NetSDKLib.NET_OUT_ACCESS_USER_SERVICE_GET();
|
|
stOut.nMaxRetNum = nMaxNum;
|
|
stOut.pUserInfo = new Memory(users[0].size() * nMaxNum); // 申请内存
|
stOut.pUserInfo.clear(users[0].size() * nMaxNum);
|
|
stOut.pFailCode = new Memory(failCodes[0].size() * nMaxNum); // 申请内存
|
stOut.pFailCode.clear(failCodes[0].size() * nMaxNum);
|
|
ToolKits.SetStructArrToPointerData(users, stOut.pUserInfo);
|
|
|
ToolKits.SetStructArrToPointerData(failCodes, stOut.pFailCode);
|
|
|
stIn.write();
|
stOut.write();
|
|
|
if (netSdk.CLIENT_OperateAccessUserService(loginHandle, emtype,
|
stIn.getPointer(), stOut.getPointer(), 3000)) {
|
// 将指针转为具体的信息
|
ToolKits.GetPointerDataToStructArr(stOut.pUserInfo, users);
|
ToolKits.GetPointerDataToStructArr(stOut.pFailCode, failCodes);
|
|
/**
|
* 打印具体的信息
|
*/
|
for (int i = 0; i < nMaxNum; i++) {
|
try {
|
System.out.println("[" + i + "]用户名："
|
+ new String(users[i].szName, "GBK").trim());
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
System.out.println("[" + i + "]密码："
|
+ new String(users[i].szPsw).trim());
|
System.out.println("[" + i + "]查询用户结果："
|
+ failCodes[i].nFailCode);
|
}
|
} else {
|
System.err.println("查询用户失败, " + ToolKits.getErrorCode());
|
}
|
|
}
|
|
|
/**
|
* 设置消费时间
|
|
*/
|
public void getAccessTimeSchedule() {
|
NetSDKLib.CFG_ACCESS_TIMESCHEDULE_INFO cfg = new NetSDKLib.CFG_ACCESS_TIMESCHEDULE_INFO();
|
|
String strCmd = NetSDKLib.CFG_CMD_ACCESSTIMESCHEDULE;
|
cfg.bEnable=1;
|
Scanner scanner=new Scanner(System.in);
|
// 获取
|
if (!ToolKits.GetDevConfig(loginHandle, channel, strCmd, cfg)) {
|
System.err.println("Get Access Time Schedule Failed!");
|
|
}else {
|
System.out.println("Get Access Time Schedule success");
|
}
|
int nConsumptionStrategyNums = cfg.nConsumptionStrategyNums;
|
|
System.out.println("nConsumptionStrategyNums:"+ nConsumptionStrategyNums);
|
|
|
NetSDKLib.DayTimeStrategy[] szConsumptionStrategy
|
= cfg.szConsumptionStrategy;
|
|
|
for(int i=0;i<nConsumptionStrategyNums;i++){
|
|
System.out.println("dayTime:"+ new String(szConsumptionStrategy[i].dayTime));
|
}
|
|
cfg.nConsumptionStrategyNums=42;
|
|
// 星期 时:分:秒-时:分:秒 消费类型 可消费次数 可消费金额
|
String next0 ="";
|
String next1="";
|
String next2="";
|
String next3="";
|
String next4="";
|
String next5="";
|
|
for(int i=0;i<cfg.nConsumptionStrategyNums;i++){
|
int m=i/6;
|
int n=i%6;
|
|
|
if(m==0){
|
|
if(n==0){
|
next0 = "00:00:00-23:59:59 0 200 999900";
|
}
|
|
if(n==1){
|
next1 = "00:00:00-23:59:59 0 201 999900";
|
}
|
|
if(n==2){
|
next2 = "00:00:00-23:59:59 0 202 999900";
|
}
|
|
if(n==3){
|
next3 = "00:00:00-23:59:59 0 203 999900";
|
}
|
|
if(n==4){
|
next4 = "00:00:00-23:59:59 0 204 999900";
|
}
|
|
if(n==5){
|
next5 = "00:00:00-23:59:59 0 205 999900";
|
}
|
}
|
String data="";
|
if(n==0){
|
|
data =m+" "+next0 ;
|
}
|
|
if(n==1){
|
data=m+" "+next1 ;
|
}
|
|
if(n==2){
|
data=m+" "+next2 ;
|
}
|
|
if(n==3){
|
data=m+" "+next3 ;
|
}
|
|
if(n==4){
|
data=m+" "+next4 ;
|
}
|
|
if(n==5){
|
data=m+" "+next5 ;
|
}
|
|
|
byte[] dataB=new byte[34];
|
|
ToolKits.StringToByteArray(data,dataB);
|
|
NetSDKLib.DayTimeStrategy dayTimeStrategy=new NetSDKLib.DayTimeStrategy();
|
dayTimeStrategy.dayTime=dataB;
|
|
cfg.szConsumptionStrategy[i]=dayTimeStrategy;
|
|
}
|
|
if (!ToolKits.SetDevConfig(loginHandle, channel, strCmd, cfg)) {
|
System.err.println("Set Access Time Schedule Failed!");
|
|
}else {
|
System.out.println("set Access Time Schedule success");
|
}
|
|
}
|
|
/*
|
* 7、
|
* CLIENT_FindRecord：emType消费记录：NET_RECORD_ACCESS_CONSUMPTION
|
* CLIENT_FindNextRecord/CLIENT_FindRecordClose
|
*/
|
|
/**
|
* 消费记录
|
*/
|
public void findAllAccessCard() {
|
String userId="1";
|
/**
|
* 查询条件
|
*/
|
FIND_RECORD_ACCESS_CTL_CONSUMPTION_INFO_CONDITION findRecordAccessCtlConsumptionInfoCondition = new FIND_RECORD_ACCESS_CTL_CONSUMPTION_INFO_CONDITION();
|
findRecordAccessCtlConsumptionInfoCondition.bUserIDEnable = 1; // 用户ID查询条件是否有效， 1-true; 0-false
|
|
// 用户ID
|
System.arraycopy(userId.getBytes(), 0, findRecordAccessCtlConsumptionInfoCondition.szUserID, 0, userId.getBytes().length);
|
|
/**
|
* CLIENT_FindRecord 接口入参
|
*/
|
NetSDKLib.NET_IN_FIND_RECORD_PARAM stuFindInParam = new NetSDKLib.NET_IN_FIND_RECORD_PARAM();
|
stuFindInParam.emType = NetSDKLib.EM_NET_RECORD_TYPE.NET_RECORD_ACCESS_CONSUMPTION;
|
stuFindInParam.pQueryCondition = findRecordAccessCtlConsumptionInfoCondition.getPointer();
|
|
/**
|
* CLIENT_FindRecord 接口出参
|
*/
|
NetSDKLib.NET_OUT_FIND_RECORD_PARAM stuFindOutParam = new NetSDKLib.NET_OUT_FIND_RECORD_PARAM();
|
|
findRecordAccessCtlConsumptionInfoCondition.write();
|
if(netSdk.CLIENT_FindRecord(loginHandle, stuFindInParam, stuFindOutParam, 5000)) {
|
findRecordAccessCtlConsumptionInfoCondition.read();
|
|
System.out.println("FindRecord Succeed" + "\n" + "FindHandle :" + stuFindOutParam.lFindeHandle);
|
|
|
/**
|
* CLIENT_FindNextRecord 接口入参
|
*/
|
int nRecordCount = 10;
|
NetSDKLib.NET_IN_FIND_NEXT_RECORD_PARAM stuFindNextInParam = new NetSDKLib.NET_IN_FIND_NEXT_RECORD_PARAM();
|
stuFindNextInParam.lFindeHandle = stuFindOutParam.lFindeHandle;
|
stuFindNextInParam.nFileCount = nRecordCount; //想查询的记录条数
|
|
// 门禁卡记录集信息
|
NET_RECORD_ACCESS_CTL_CONSUMPTION_INFO[] pstRecord = new NET_RECORD_ACCESS_CTL_CONSUMPTION_INFO[nRecordCount];
|
for (int i = 0; i < pstRecord.length; i++) {
|
pstRecord[i] = new NET_RECORD_ACCESS_CTL_CONSUMPTION_INFO();
|
}
|
|
/**
|
* CLIENT_FindNextRecord 接口出参
|
*/
|
NetSDKLib.NET_OUT_FIND_NEXT_RECORD_PARAM stuFindNextOutParam = new NetSDKLib.NET_OUT_FIND_NEXT_RECORD_PARAM();
|
stuFindNextOutParam.nMaxRecordNum = nRecordCount;
|
stuFindNextOutParam.pRecordList = new Memory(pstRecord[0].dwSize * nRecordCount);
|
stuFindNextOutParam.pRecordList.clear(pstRecord[0].dwSize * nRecordCount);
|
ToolKits.SetStructArrToPointerData(pstRecord, stuFindNextOutParam.pRecordList);
|
|
boolean zRet = netSdk.CLIENT_FindNextRecord(stuFindNextInParam, stuFindNextOutParam, 5000);
|
ToolKits.GetPointerDataToStructArr(stuFindNextOutParam.pRecordList, pstRecord);
|
|
if(zRet) {
|
for (int i = 0; i < pstRecord.length; i++) {
|
System.out.println("记录集编号:" + pstRecord[i].nRecNo);
|
System.out.println("用户ID:" + new String(pstRecord[i].szUserID).trim());
|
System.out.println("卡命名:" + new String(pstRecord[i].szCardName).trim());
|
System.out.println("消费金额:" + pstRecord[i].nConsumptionAmount);
|
|
System.out.println("交易流水号:" + new String(pstRecord[i].szTransactionSerialNumber).trim());
|
}
|
|
|
} else {
|
System.err.println("FindNextRecord Failed" + ToolKits.getErrorCode());
|
}
|
|
netSdk.CLIENT_FindRecordClose(stuFindOutParam.lFindeHandle);
|
} else {
|
System.err.println("Can Not Find This Record" + ToolKits.getErrorCode());
|
}
|
}
|
|
|
|
/**
|
* 报警事件（智能）回调
|
*/
|
private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
private final File picturePath;
|
private static AnalyzerDataCB instance;
|
private int count;
|
|
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;
|
}
|
|
@Override
|
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;
|
}
|
|
/* IntParam intParam=new IntParam();
|
ToolKits.GetPointerData(reserved,intParam);
|
System.out.println("reserved:"+intParam.intParam);*/
|
|
|
switch (dwAlarmType) {
|
case EVENT_IVS_CONSUMPTION_EVENT : {
|
count++;
|
System.out.println("消费事件");
|
|
DEV_EVENT_CONSUMPTION_EVENT_INFO msg=new DEV_EVENT_CONSUMPTION_EVENT_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
NET_TIME_EX stuUTC = msg.stuUTC;
|
System.out.println("stuUTC:"+stuUTC);
|
|
int emType = msg.emType;
|
System.out.println("事件类型:"+emType);
|
|
int emStatus = msg.emStatus;
|
System.out.println("消费结果:"+emStatus);
|
|
int emCardType = msg.emCardType;
|
System.out.println("卡类型:"+emCardType);
|
|
int emUserType = msg.emUserType;
|
System.out.println("用户类型:"+emUserType);
|
|
int emCardStatus = msg.emCardStatus;
|
System.out.println("卡状态:"+emCardStatus);
|
|
int emMethod = msg.emMethod;
|
System.out.println("开门方式:"+emMethod);
|
|
|
byte[] szUserID = msg.szUserID;
|
System.out.println("用户ID :"+new String(szUserID));
|
|
int nImageCount = msg.nImageCount;
|
DEV_ACCESS_CTL_IMAGE_INFO[] stuImageInfos = msg.stuImageInfos;
|
|
int nConsumptionAmount
|
= msg.nConsumptionAmount;
|
|
System.out.println("消费金额:"+nConsumptionAmount);
|
|
int nRechargeAmount
|
= msg.nRechargeAmount;
|
|
System.out.println("充值金额:"+nRechargeAmount);
|
|
byte[] szTransactionSerialNumber
|
= msg.szTransactionSerialNumber;
|
|
|
System.out.println("交易流水号:"+new String(szTransactionSerialNumber));
|
|
for(int i=0;i<nImageCount;i++){
|
|
DEV_ACCESS_CTL_IMAGE_INFO stuImageInfo = stuImageInfos[i];
|
int emType1 = stuImageInfo.emType;
|
String path=picturePath+"/"+emType1+"_"+System.currentTimeMillis()+".jpg";
|
ToolKits.savePicture(pBuffer,stuImageInfo.nOffSet,stuImageInfo.nLength,path);
|
}
|
|
|
consumptionAmount=msg.nConsumptionAmount;
|
|
szUserIDA=msg.szUserID;
|
|
transactionSerialNumber=msg.szTransactionSerialNumber;
|
|
|
SetConsumeResult();
|
|
break;
|
}
|
default:
|
System.out.println("其他事件--------------------"+ dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
}
|
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (this.attachHandle.longValue() != 0) {
|
netSdk.CLIENT_StopLoadPic(this.attachHandle);
|
}
|
}
|
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();
|
|
menu.addItem(new CaseMenu.Item(this , "获取和设置消费相关策略" , "getAndSetConsumption"));
|
|
menu.addItem(new CaseMenu.Item(this , "订阅智能任务" , "AttachEventRealLoadPic"));
|
|
menu.addItem(new CaseMenu.Item(this , "取消智能订阅" , "DetachEventRealLoadPic"));
|
|
menu.addItem(new CaseMenu.Item(this , "设置消费结果" , "SetConsumeResult"));
|
|
menu.addItem(new CaseMenu.Item(this , "设置消费时间" , "getAccessTimeSchedule"));
|
|
menu.addItem(new CaseMenu.Item(this , "韦根配置" , "getSetWIEGAND"));
|
|
menu.addItem(new CaseMenu.Item(this , "根据用户ID获取用户信息" , "operateAccessUserService"));
|
|
menu.addItem(new CaseMenu.Item(this , "插入密码" , "insertPassword"));
|
|
menu.addItem(new CaseMenu.Item(this , "修改密码" , "updatePassword"));
|
|
menu.addItem(new CaseMenu.Item(this , "删除密码" , "deletePassword"));
|
|
menu.addItem(new CaseMenu.Item(this , "消费记录查询" , "findAllAccessCard"));
|
|
|
menu.run();
|
}
|
|
|
private static String ipAddr = "172.5.3.165";
|
private static int port = 37777;
|
private static String user = "admin";
|
private static String password = "admin123";
|
|
public static void main(String[] args){
|
InitTest(ipAddr, port, user, password);
|
RecordAccessDemo recordAccessDemo=new RecordAccessDemo();
|
recordAccessDemo.RunTest();
|
LoginOut();
|
}
|
|
}
|
