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.ENUMERROR;
|
import com.netsdk.lib.structure.NET_IN_DELIVER_USER_PICTURE;
|
import com.netsdk.lib.structure.NET_IN_GETFACEEIGEN_INFO;
|
import com.netsdk.lib.structure.NET_OUT_DELIVER_USER_PICTURE;
|
import com.netsdk.lib.structure.NET_OUT_GETFACEEIGEN_INFO;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
import javax.imageio.stream.FileImageInputStream;
|
import java.io.*;
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
/**
|
*
|
* @author 251589
|
* @version V1.0
|
* @Description:
|
* @date 2020/12/9 19:27
|
*
|
*/
|
|
public class UploadFaceFeatureDemo {
|
|
static NetSDKLib netSDK = NetSDKLib.NETSDK_INSTANCE;
|
|
private NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0); // 登陆句柄
|
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
public UploadFaceFeatureDemo(NetSDKLib.LLong loginHandle) {
|
|
this.loginHandle = loginHandle;
|
|
}
|
|
public UploadFaceFeatureDemo() {
|
|
}
|
|
// 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
|
|
public class fDisConnectCB implements NetSDKLib.fDisConnect {
|
|
public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
|
System.out.printf("Device[%s] Port[%d] Disconnect!\n", pchDVRIP, nDVRPort);
|
|
}
|
|
}
|
|
// 网络连接恢复，设备重连成功回调
|
|
// 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK会调用该函数
|
|
public class HaveReConnect implements NetSDKLib.fHaveReConnect {
|
|
public void invoke(NetSDKLib.LLong loginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
|
System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
|
|
}
|
|
}
|
|
private UploadFaceFeatureDemo.fDisConnectCB m_DisConnectCB = new UploadFaceFeatureDemo.fDisConnectCB();
|
|
private UploadFaceFeatureDemo.HaveReConnect haveReConnect = new UploadFaceFeatureDemo.HaveReConnect();
|
|
public void EndTest() {
|
|
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 void InitTest() {
|
|
// 初始化SDK库
|
|
netSDK.CLIENT_Init(m_DisConnectCB, null);
|
|
// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK内部会自动进行重连操作
|
|
// 此操作为可选操作，但建议用户进行设置
|
|
netSDK.CLIENT_SetAutoReconnect(haveReConnect, null);
|
|
// 设置登录超时时间和尝试次数，可选
|
|
int waitTime = 3000; // 登录请求响应超时时间设置为3S
|
|
int tryTimes = 3; // 登录时尝试建立链接3次
|
|
netSDK.CLIENT_SetConnectTime(waitTime, tryTimes);
|
|
// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime
|
|
// 接口设置的登录设备超时时间和尝试次数意义相同,可选
|
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
|
netParam.nConnectTime = 10000; // 登录时尝试建立链接的超时时间
|
|
netSDK.CLIENT_SetNetworkParam(netParam);
|
|
// 打开日志，可选
|
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
|
File path = new File(".");
|
|
String logPath = path.getAbsoluteFile().getParent() + "\\sdk_log\\" + System.currentTimeMillis() + ".log";
|
|
setLog.bSetFilePath = 1;
|
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
|
setLog.bSetPrintStrategy = 1;
|
|
setLog.nPrintStrategy = 0;
|
|
boolean logOpen = netSDK.CLIENT_LogOpen(setLog);
|
|
if (!logOpen) {
|
|
System.err.println("Failed to open NetSDK log !!!");
|
|
}
|
|
// 设备登入
|
|
int nSpecCap = 0;
|
|
Pointer pCapParam = null;
|
|
IntByReference nError = new IntByReference(0);
|
|
loginHandle = netSDK.CLIENT_LoginEx2(m_strIp, m_nPort, m_strUser,
|
|
m_strPassword, nSpecCap, pCapParam, deviceInfo, nError);
|
|
if (loginHandle.longValue() != 0) {
|
|
System.out.printf("Login Device[%s] Port[%d]Success!\n", m_strIp, m_nPort);
|
|
} else {
|
|
System.out.printf("Login Device[%s] Port[%d]Fail.Last Error[%s]\n", m_strIp, m_nPort,
|
ToolKits.getErrorCode() + "errorMsg: " + ENUMERROR.getErrorMessage());
|
|
EndTest();
|
|
}
|
|
}
|
|
public void getFaceInfo() {
|
|
// 获取
|
|
String userId = "123"; // 用户ID
|
|
int emType = NetSDKLib.EM_FACEINFO_OPREATE_TYPE.EM_FACEINFO_OPREATE_GET;
|
|
NetSDKLib.NET_IN_GET_FACE_INFO inGet = new NetSDKLib.NET_IN_GET_FACE_INFO();
|
|
System.arraycopy(userId.getBytes(), 0, inGet.szUserID, 0, userId.getBytes().length); // 用户ID
|
|
NetSDKLib.NET_OUT_GET_FACE_INFO outGet = new NetSDKLib.NET_OUT_GET_FACE_INFO();
|
|
outGet.nPhotoData = 1; // 白光人脸照片数据个数 1
|
|
outGet.nInPhotoDataLen[0] = 200 * 1024; // 用户申请的每张白光人脸照片大小 200KB
|
|
int size = outGet.nInPhotoDataLen[0] * outGet.nPhotoData;
|
|
outGet.pPhotoData[0] = new Memory(size);
|
|
outGet.pPhotoData[0].clear(size);
|
|
inGet.write();
|
|
outGet.write();
|
|
boolean bRet = netSDK.CLIENT_FaceInfoOpreate(loginHandle, emType, inGet.getPointer(), outGet.getPointer(),
|
5000);
|
|
inGet.read();
|
|
outGet.read();
|
|
if (bRet) {
|
|
System.out.println("FaceInfoOperate Get Succeed!");
|
|
System.out.println("图片个数 : " + outGet.nPhotoData);
|
|
for (int i = 0; i < outGet.nPhotoData; i++) {
|
|
ToolKits.savePicture(outGet.pPhotoData[i], outGet.nOutPhotoDataLen[i], "photo_data_" + i + ".jpg");
|
|
}
|
|
} else {
|
|
System.err.println("FaceInfoOperate Get Failed!" + netSDK.CLIENT_GetLastError() + "MSG:"
|
+ ENUMERROR.getErrorMessage());
|
|
}
|
|
}
|
|
/**
|
*
|
* 获取人脸特征值
|
*
|
*/
|
|
public void getFaceFeature() {
|
|
// 获取人脸特征值
|
|
int emType = NetSDKLib.EM_FACEINFO_OPREATE_TYPE.EM_FACEINFO_OPREATE_GETFACEEIGEN;
|
|
// 入参
|
|
NET_IN_GETFACEEIGEN_INFO inParam = new NET_IN_GETFACEEIGEN_INFO();
|
|
byte[] bytes = image("C:\\Users\\260611\\Downloads\\666.jpg");
|
|
inParam.pszPhotoData.write(0, bytes, 0, bytes.length);
|
|
inParam.nPhotoDataLen = bytes.length;
|
|
// 出参
|
|
NET_OUT_GETFACEEIGEN_INFO outParam = new NET_OUT_GETFACEEIGEN_INFO();
|
|
outParam.nInFaceEigenLen = 8 * 1024;
|
|
inParam.write();
|
|
outParam.write();
|
|
boolean bRet = netSDK.CLIENT_FaceInfoOpreate(loginHandle, emType, inParam.getPointer(), outParam.getPointer(),
|
3000);
|
|
inParam.read();
|
|
outParam.read();
|
|
if (bRet) {
|
|
byte[] outFeature = new byte[outParam.nOutFaceEigenLen];
|
|
outParam.pszFaceEigen.read(0, outFeature, 0, outFeature.length);
|
|
System.out.print("获取到的特征值为：[" + outFeature[0]);
|
|
for (int i = 1; i < outParam.nOutFaceEigenLen; i++) {
|
|
System.out.print("," + outFeature[i]);
|
|
}
|
|
System.out.println("]");
|
|
System.out.println("FaceInfoOpreate Succeed!" + outParam);
|
|
} else {
|
|
System.err
|
.println("FaceInfoOpreate Failed!" + ToolKits.getErrorCode() + " " + ENUMERROR.getErrorMessage());
|
|
}
|
|
}
|
|
// 下发人脸数据
|
|
public void setFaceFeature() {
|
|
// 入参
|
|
NET_IN_DELIVER_USER_PICTURE inParam = new NET_IN_DELIVER_USER_PICTURE();
|
|
String userId = "251500";
|
|
String citizenId = "123";
|
|
inParam.szUserID = userId.getBytes();
|
|
inParam.szCitizenID = citizenId.getBytes();
|
|
// 出参
|
|
NET_OUT_DELIVER_USER_PICTURE outParam = new NET_OUT_DELIVER_USER_PICTURE();
|
|
boolean ret = netSDK.CLIENT_DeliverUserFacePicture(loginHandle, inParam, outParam, 3000);
|
|
if (ret) {
|
|
System.out.println("下发人脸数据成功！");
|
|
ToolKits.GetPointerData(outParam.getPointer(), outParam);
|
|
System.out.println(outParam);
|
|
} else {
|
|
System.err.println("下发人脸数据失败！" + netSDK.CLIENT_GetLastError() + " msg: " + ENUMERROR.getErrorMessage());
|
|
}
|
|
}
|
|
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 byte[] image(String path) {
|
|
byte[] data = null;
|
|
FileImageInputStream input = null;
|
|
try {
|
|
input = new FileImageInputStream(new File(path));
|
|
ByteArrayOutputStream output = new ByteArrayOutputStream();
|
|
byte[] buf = new byte[1024];
|
|
int numBytesRead = 0;
|
|
while ((numBytesRead = input.read(buf)) != -1) {
|
|
output.write(buf, 0, numBytesRead);
|
|
}
|
|
data = output.toByteArray();
|
|
output.close();
|
|
input.close();
|
|
} catch (FileNotFoundException ex1) {
|
|
ex1.printStackTrace();
|
|
} catch (IOException ex1) {
|
|
ex1.printStackTrace();
|
|
}
|
|
return data;
|
|
}
|
|
public void RunTest() {
|
|
CaseMenu menu = new CaseMenu();
|
|
menu.addItem(new CaseMenu.Item(this, "获取人脸特征值", "getFaceFeature"));
|
|
menu.addItem(new CaseMenu.Item(this, "下发人脸特征值", "setFaceFeature"));
|
|
menu.run();
|
|
}
|
|
////////////////////////////////////////////////////////////////
|
|
String m_strIp = "172.5.54.223";
|
|
int m_nPort = 37777;
|
|
String m_strUser = "admin";
|
|
String m_strPassword = "admin123";
|
|
////////////////////////////////////////////////////////////////
|
|
public static void main(String[] args) {
|
|
UploadFaceFeatureDemo demo = new UploadFaceFeatureDemo();
|
|
demo.InitTest();
|
|
demo.RunTest();
|
|
demo.EndTest();
|
|
}
|
|
}
|
