package com.netsdk.demo.event;
|
|
import java.awt.Dimension;
|
import java.awt.Toolkit;
|
import java.awt.image.BufferedImage;
|
import java.io.ByteArrayInputStream;
|
import java.io.ByteArrayOutputStream;
|
import java.io.File;
|
import java.io.FileNotFoundException;
|
import java.io.IOException;
|
import java.util.Scanner;
|
|
import javax.imageio.ImageIO;
|
import javax.imageio.stream.FileImageInputStream;
|
import javax.swing.JWindow;
|
|
import com.netsdk.demo.customize.CommonWithCallBack.RealDataCallBack;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.ALARM_ANATOMY_TEMP_DETECT_INFO;
|
import com.netsdk.lib.NetSDKLib.ALARM_REGULATOR_ABNORMAL_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_ANALYSERULES_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_ANATOMY_TEMP_DETECT_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_COMPOSE_CHANNEL;
|
import com.netsdk.lib.NetSDKLib.CFG_LIGHTING_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_PICINPIC_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_RULE_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_SMALLPIC_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_SPLIT_CHANNEL_INFO;
|
import com.netsdk.lib.NetSDKLib.CFG_SPLIT_INFO;
|
import com.netsdk.lib.NetSDKLib.DEV_EVENT_FACERECOGNITION_INFO;
|
import com.netsdk.lib.NetSDKLib.FACERECOGNITION_PERSON_INFOEX;
|
import com.netsdk.lib.NetSDKLib.NET_CFG_RADIO_REGULATOR;
|
import com.netsdk.lib.NetSDKLib.NET_IN_BATCH_APPEND_FACERECONGNITION;
|
import com.netsdk.lib.NetSDKLib.NET_IN_GET_HUMAN_RADIO_CAPS;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_BATCH_APPEND_FACERECONGNITION;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_GET_HUMAN_RADIO_CAPS;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.NET_DEVICEINFO_Ex;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Native;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
public class ThermalDemo {
|
public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
|
// 登陆句柄
|
private static LLong loginHandle = new LLong(0);
|
|
//智能报警句柄
|
private LLong lRealloadHandle = new LLong(0);
|
|
// 全景图
|
private static BufferedImage globalBufferedImage = null;
|
|
// 人脸图
|
private static BufferedImage personBufferedImage = null;
|
|
// 候选人图
|
private static BufferedImage candidateBufferedImage = null;
|
|
//智能报警句柄
|
private LLong m_hPlayHandle = new LLong(0);
|
|
private static int index = -1;
|
|
JWindow wnd;
|
public ThermalDemo(LLong loginHandle)
|
{
|
this.loginHandle = loginHandle;
|
createWindow();
|
}
|
// 设备信息扩展
|
private NET_DEVICEINFO_Ex deviceInfo = new NET_DEVICEINFO_Ex();
|
|
|
public void InitTest(){
|
// 初始化SDK库
|
netSdk.CLIENT_Init(DisConnectCallBack.getInstance(), null);
|
|
// 设置断线重连成功回调函数
|
netSdk.CLIENT_SetAutoReconnect(HaveReConnectCallBack.getInstance(), null);
|
|
System.out.printf("NetSDK Version [%d]\n", netSdk.CLIENT_GetSDKVersion());
|
//打开日志，可选
|
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!!!");
|
}
|
|
Login();
|
}
|
|
public void Login(){
|
|
// 登陆设备
|
int nSpecCap = NetSDKLib.EM_LOGIN_SPAC_CAP_TYPE.EM_LOGIN_SPEC_CAP_TCP; // TCP登入
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netSdk.CLIENT_LoginEx2(m_strIp, m_nPort, m_strUser,
|
m_strPassword ,nSpecCap, null, deviceInfo, nError);
|
if (loginHandle.longValue() != 0) {
|
System.out.printf("Login Device[%s] Success!\n", m_strIp);
|
}
|
else {
|
System.err.printf("Login Device[%s] Fail.Error[%s]\n", m_strIp, ToolKits.getErrorCode());
|
LoginOut();
|
}
|
}
|
|
|
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);
|
}
|
|
////////////////////////////////////////////////////////////////
|
private String m_strIp = "172.23.12.114"/*"172.32.100.188"*/;
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
////////////////////////////////////////////////////////////////
|
|
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 BatchAppendFaceRecognition(){
|
//入参
|
NET_IN_BATCH_APPEND_FACERECONGNITION pstInParam=new NET_IN_BATCH_APPEND_FACERECONGNITION();
|
pstInParam.nPersonNum=1;
|
pstInParam.nBufferLen=image("D://123.jpg").length;
|
pstInParam.nBufferLen=1024*1024;
|
pstInParam.pBuffer=new Memory(pstInParam.nBufferLen);
|
System.arraycopy(image("D://123.jpg"), 0,pstInParam.pBuffer.getByteArray(0, image("D://123.jpg").length), 0, image("D://123.jpg").length);
|
FACERECOGNITION_PERSON_INFOEX msg=new FACERECOGNITION_PERSON_INFOEX();
|
msg.byIDType=1;
|
msg.bySex=1;
|
byte[] GroupID="1".getBytes();
|
System.arraycopy(GroupID, 0, msg.szGroupID, 0, GroupID.length);
|
byte[] GroupName="111".getBytes();
|
System.arraycopy(GroupName, 0, msg.szGroupName, 0, GroupName.length);
|
byte[] szID="3308213468972432".getBytes();
|
System.arraycopy(szID, 0, msg.szID, 0, szID.length);
|
byte[] PersonName="xiaoming".getBytes();
|
System.arraycopy(PersonName, 0, msg.szPersonName, 0, PersonName.length);
|
pstInParam.pstPersonInfo=new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pstInParam.pstPersonInfo, 0);
|
//出参
|
NET_OUT_BATCH_APPEND_FACERECONGNITION pstOutParam=new NET_OUT_BATCH_APPEND_FACERECONGNITION();
|
boolean ret=netSdk.CLIENT_BatchAppendFaceRecognition(loginHandle, pstInParam, pstOutParam, 3000);
|
if(ret){
|
System.out.println("BatchAppendFaceRecognition success"+ pstOutParam.nResultNum);
|
}else{
|
System.out.println("BatchAppendFaceRecognition false");
|
}
|
}
|
|
|
public void createWindow() {
|
wnd = new JWindow();
|
Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
|
screenSize.height /= 2;
|
screenSize.width /= 2;
|
wnd.setSize(screenSize);
|
|
Dimension dim = Toolkit.getDefaultToolkit().getScreenSize();
|
int w = wnd.getSize().width;
|
int h = wnd.getSize().height;
|
int x = (dim.width - w) / 2;
|
int y = (dim.height - h) / 2;
|
wnd.setLocation(x, y);
|
}
|
|
public void Realplay(){
|
if (loginHandle.longValue() == 0) {
|
System.err.println("Please login first");
|
}
|
wnd.setVisible(true);
|
int channel = 0; // 预览通道号， 设备有多通道的情况，可手动更改
|
int playType = NetSDKLib.NET_RealPlayType.NET_RType_Realplay; // 实时预览
|
|
m_hPlayHandle = netSdk.CLIENT_RealPlayEx(loginHandle, channel, Native.getComponentPointer(wnd), playType);
|
if (m_hPlayHandle.longValue() == 0) {
|
int error = netSdk.CLIENT_GetLastError();
|
System.err.println("开始实时预览失败，错误码：" + String.format("[0x%x]", error));
|
}
|
else {
|
System.out.println("Success to start realplay");
|
netSdk.CLIENT_SetRealDataCallBackEx(m_hPlayHandle, RealDataCallBack.getInstance(), null, 0);
|
}
|
}
|
|
public void StopRealPlay(){
|
if(netSdk.CLIENT_StopRealPlayEx(m_hPlayHandle)){
|
System.out.println("StopRealPlay success");
|
}
|
}
|
|
public void GetHumanRadioCaps(){
|
//入参
|
NET_IN_GET_HUMAN_RADIO_CAPS pInParam=new NET_IN_GET_HUMAN_RADIO_CAPS();
|
//单目热成像
|
pInParam.nChannel=1;
|
/* //双目热成像
|
pInParam.nChannel=1;*/
|
|
//出参
|
NET_OUT_GET_HUMAN_RADIO_CAPS pOutParam=new NET_OUT_GET_HUMAN_RADIO_CAPS();
|
boolean bRet=netSdk.CLIENT_GetHumanRadioCaps(loginHandle, pInParam, pOutParam, 5000);
|
if(bRet) {
|
System.out.printf("CLIENT_GetHumanRadioCaps success.bSupportRegulatorAlarm:%d\n", pOutParam.bSupportRegulatorAlarm);
|
}else{
|
System.err.printf("CLIENT_GetHumanRadioCaps fail, error:%d\n", netSdk.CLIENT_GetLastError());
|
}
|
}
|
|
//人体温智能检测事件配置
|
/*public void TempConfig(){
|
int channel = 1; // 通道号
|
String command = NetSDKLib.CFG_CMD_ANALYSERULE;
|
|
int ruleCount = 30; // 事件规则个数
|
CFG_RULE_INFO[] ruleInfo = new CFG_RULE_INFO[ruleCount];
|
for(int i = 0; i < ruleCount; i++) {
|
ruleInfo[i] = new CFG_RULE_INFO();
|
}
|
|
CFG_ANALYSERULES_INFO analyse = new CFG_ANALYSERULES_INFO();
|
analyse.nRuleLen = 1024 * 1024 * 40;
|
analyse.pRuleBuf = new Memory(1024 * 1024 * 40); // 申请内存
|
analyse.pRuleBuf.clear(1024 * 1024 * 40);
|
|
// 获取
|
if(ToolKits.GetDevConfig(loginHandle, channel, command, analyse)) {
|
int offset = 0;
|
System.out.println("设备返回的事件规则个数:" + analyse.nRuleCount);
|
|
int count = analyse.nRuleCount < ruleCount? analyse.nRuleCount : ruleCount;
|
|
for(int i = 0; i < count; i++) {
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, ruleInfo[i]);
|
offset += ruleInfo[0].size(); // 智能规则偏移量
|
offset += ruleInfo[i].nRuleSize; // 智能事件偏移量
|
}
|
|
CFG_ANATOMY_TEMP_DETECT_INFO msg = new CFG_ANATOMY_TEMP_DETECT_INFO();
|
System.arraycopy("NetSdk001".getBytes(), 0, msg.szRuleName, 0, "NetSdk001".getBytes().length);
|
msg.bRuleEnable = 1;
|
msg.nDetectRegionPoint=4;
|
for(int j=0; j<msg.stuDetectRegion.length; j++){
|
msg.stuDetectRegion[j] =new CFG_POLYGON();
|
}
|
msg.stuDetectRegion[0].nX = 1570;
|
msg.stuDetectRegion[0].nY = 4467;
|
msg.stuDetectRegion[1].nX = 1276;
|
msg.stuDetectRegion[1].nY = 5241;
|
msg.stuDetectRegion[2].nX = 2577;
|
msg.stuDetectRegion[2].nY = 5279;
|
msg.stuDetectRegion[3].nX = 2615;
|
msg.stuDetectRegion[3].nY = 4573;
|
analyse.nRuleCount += 1; // 新增1个
|
|
System.out.println("analyse.nRuleCount " + analyse.nRuleCount);
|
if(offset <=analyse.nRuleLen-msg.size()-ruleInfo[0].size()){
|
ruleInfo[count].stuRuleCommInfo.emClassType = NetSDKLib.EM_SCENE_TYPE.EM_SCENE_ANATOMYTEMP_DETECT;
|
ruleInfo[count].dwRuleType = NetSDKLib.EVENT_IVS_ANATOMY_TEMP_DETECT;
|
ruleInfo[count].nRuleSize = msg.size();
|
ToolKits.SetStructDataToPointer(ruleInfo[count], analyse.pRuleBuf, offset);
|
ToolKits.SetStructDataToPointer(msg, analyse.pRuleBuf, offset + ruleInfo[count].size());
|
}
|
// 设置
|
if(ToolKits.SetDevConfig(loginHandle, channel, command, analyse)) {
|
System.out.println("设置使能成功!");
|
} else {
|
System.err.println("设置使能失败!" + ToolKits.getErrorCode());
|
}
|
} else {
|
System.err.println("获取使能失败!" + ToolKits.getErrorCode());
|
}
|
}*/
|
//人体温智能检测事件配置
|
public void SetTempEnable() {
|
int channel =1; // 通道号
|
String command = NetSDKLib.CFG_CMD_ANALYSERULE;
|
|
int ruleCount = 10; // 事件规则个数
|
CFG_RULE_INFO[] ruleInfo = new CFG_RULE_INFO[ruleCount];
|
for(int i = 0; i < ruleCount; i++) {
|
ruleInfo[i] = new CFG_RULE_INFO();
|
}
|
|
CFG_ANALYSERULES_INFO analyse = new CFG_ANALYSERULES_INFO();
|
analyse.nRuleLen = 1024 * 1024 * 40;
|
analyse.pRuleBuf = new Memory(1024 * 1024 * 40); // 申请内存
|
analyse.pRuleBuf.clear(1024 * 1024 * 40);
|
|
// 获取
|
if(ToolKits.GetDevConfig(loginHandle, channel, command, analyse)) {
|
int offset = 0;
|
System.out.println("设备返回的事件规则个数:" + analyse.nRuleCount);
|
|
int count = analyse.nRuleCount < ruleCount? analyse.nRuleCount : ruleCount;
|
|
for(int i = 0; i < count; i++) {
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, ruleInfo[i]);
|
|
offset += ruleInfo[0].size(); // 智能规则偏移量
|
|
switch (ruleInfo[i].dwRuleType) {
|
case NetSDKLib.EVENT_IVS_ANATOMY_TEMP_DETECT: // 人体温智能检测事件
|
{
|
CFG_ANATOMY_TEMP_DETECT_INFO msg = new CFG_ANATOMY_TEMP_DETECT_INFO();
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, msg);
|
System.out.println("规则名称：" + new String(msg.szRuleName).trim());
|
System.out.println("使能：" + msg.bRuleEnable);
|
ruleInfo[i].stuRuleCommInfo.emClassType = NetSDKLib.EM_SCENE_TYPE.EM_SCENE_ANATOMYTEMP_DETECT;
|
ToolKits.SetStructDataToPointer(ruleInfo[i], analyse.pRuleBuf, offset - ruleInfo[0].size());
|
// 设置使能开
|
System.arraycopy("TEMP".getBytes(), 0, msg.szRuleName, 0, "TEMP".getBytes().length);
|
msg.bRuleEnable = 1;
|
ToolKits.SetStructDataToPointer(msg, analyse.pRuleBuf, offset);
|
break;
|
}
|
default:
|
break;
|
}
|
|
offset += ruleInfo[i].nRuleSize; // 智能事件偏移量
|
}
|
// 设置
|
if(ToolKits.SetDevConfig(loginHandle, channel, command, analyse)) {
|
System.out.println("设置使能成功!");
|
} else {
|
System.err.println("设置使能失败!" + ToolKits.getErrorCode());
|
}
|
} else {
|
System.err.println("获取使能失败!" + ToolKits.getErrorCode());
|
}
|
}
|
|
//人体测温标准黑体配置
|
public void TempBlackConfig(){
|
// 获取
|
int nChannelID=1;
|
NET_CFG_RADIO_REGULATOR msg=new NET_CFG_RADIO_REGULATOR();
|
Pointer pstuConfigInfo=new Memory(msg.size());
|
boolean gRet = netSdk.CLIENT_GetConfig(loginHandle, NetSDKLib.NET_EM_CFG_RADIO_REGULATOR, nChannelID, pstuConfigInfo, msg.size(), 3000, null);
|
if (!gRet)
|
{
|
System.err.printf("CLIENT_GetConfig fail,error:%d\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
ToolKits.GetPointerData(pstuConfigInfo, msg);
|
System.out.println("使能"+msg.bEnable);
|
System.out.println("使能"+msg.stRegulatorInfo.nDiffTemperature);
|
NET_CFG_RADIO_REGULATOR msg1=new NET_CFG_RADIO_REGULATOR();
|
Pointer pstuConfigInfo1=new Memory(msg1.size());
|
msg1.bEnable=0;
|
msg1.stRegulatorInfo.nTemperature=6;
|
msg1.stRegulatorInfo.nDiffTemperature=7;
|
ToolKits.SetStructDataToPointer(msg1, pstuConfigInfo1, 0);
|
boolean sRet=netSdk.CLIENT_SetConfig(loginHandle, NetSDKLib.NET_EM_CFG_RADIO_REGULATOR, nChannelID, pstuConfigInfo1, msg1.size(), 3000, null, null);
|
if(!sRet){
|
System.err.printf("CLIENT_SetConfig fail,error:%d\n", netSdk.CLIENT_GetLastError());
|
return;
|
}else{
|
System.out.printf("CLIENT_SetConfig success\n");
|
}
|
}
|
|
|
//开启侦听智能事件
|
public void RealLoadPictureEx(){
|
int bNeedPicFile=1;
|
Scanner in = new Scanner(System.in);
|
System.out.println("请输入通道号：");
|
int nChannelID=in.nextInt();
|
lRealloadHandle=netSdk.CLIENT_RealLoadPictureEx(loginHandle, nChannelID, NetSDKLib.EVENT_IVS_ALL, bNeedPicFile, AnalyzerDataCB.getInstance(), null, null);
|
if(lRealloadHandle.longValue()!=0){
|
System.out.printf("CLIENT_RealLoadPictureEx success\n");
|
}else{
|
System.err.printf("CLIENT_RealLoadPictureEx fail, error:%d\n", netSdk.CLIENT_GetLastError());
|
}
|
}
|
|
//停止侦听智能事件
|
public void StopLoadPic(){
|
if(lRealloadHandle.longValue()!=0){
|
netSdk.CLIENT_StopLoadPic(lRealloadHandle);
|
}
|
}
|
|
/**
|
* 订阅报警信息
|
* @return
|
*/
|
public void startListen() {
|
// 设置报警回调函数
|
netSdk.CLIENT_SetDVRMessCallBack(fAlarmDataCB.getCallBack(), null);
|
|
// 订阅报警
|
boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle);
|
if (!bRet) {
|
System.err.printf("订阅报警失败! error:%d\n" , netSdk.CLIENT_GetLastError());
|
}
|
else {
|
System.out.println("订阅报警成功.");
|
}
|
}
|
|
/**
|
* 取消订阅报警信息
|
* @return
|
*/
|
public void stopListen() {
|
// 停止订阅报警
|
boolean bRet = netSdk.CLIENT_StopListen(loginHandle);
|
if (bRet) {
|
System.out.println("取消订阅报警信息.");
|
}
|
}
|
|
/**
|
* 保存目标识别事件图片
|
* @param pBuffer 抓拍图片信息
|
* @param dwBufSize 抓拍图片大小
|
* @param faceRecognitionInfo 目标识别事件信息
|
*/
|
public static void saveFaceRecognitionPic(Pointer pBuffer, int dwBufSize,
|
DEV_EVENT_FACERECOGNITION_INFO faceRecognitionInfo) throws FileNotFoundException {
|
index = -1;
|
globalBufferedImage = null;
|
personBufferedImage = null;
|
candidateBufferedImage = null;
|
|
File path = new File("./FaceRecognition/");
|
if (!path.exists()) {
|
path.mkdir();
|
}
|
|
if (pBuffer == null || dwBufSize <= 0) {
|
return;
|
}
|
|
/////////////// 保存全景图 ///////////////////
|
if(faceRecognitionInfo.bGlobalScenePic == 1) {
|
|
String strGlobalPicPathName = path + "\\" + faceRecognitionInfo.UTC.toStringTitle() + "_FaceRecognition_Global.jpg";
|
byte[] bufferGlobal = pBuffer.getByteArray(faceRecognitionInfo.stuGlobalScenePicInfo.dwOffSet,
|
faceRecognitionInfo.stuGlobalScenePicInfo.dwFileLenth);
|
ByteArrayInputStream byteArrInputGlobal = new ByteArrayInputStream(bufferGlobal);
|
|
try {
|
globalBufferedImage = ImageIO.read(byteArrInputGlobal);
|
if(globalBufferedImage != null) {
|
File globalFile = new File(strGlobalPicPathName);
|
if(globalFile != null) {
|
ImageIO.write(globalBufferedImage, "jpg", globalFile);
|
}
|
}
|
} catch (IOException e2) {
|
e2.printStackTrace();
|
}
|
}
|
|
/////////////// 保存人脸图 /////////////////////////
|
if(faceRecognitionInfo.stuObject.stPicInfo != null) {
|
String strPersonPicPathName = path + "\\" + faceRecognitionInfo.UTC.toStringTitle() + "_FaceRecognition_Person.jpg";
|
byte[] bufferPerson = pBuffer.getByteArray(faceRecognitionInfo.stuObject.stPicInfo.dwOffSet,
|
faceRecognitionInfo.stuObject.stPicInfo.dwFileLenth);
|
ByteArrayInputStream byteArrInputPerson = new ByteArrayInputStream(bufferPerson);
|
|
try {
|
personBufferedImage = ImageIO.read(byteArrInputPerson);
|
if(personBufferedImage != null) {
|
File personFile = new File(strPersonPicPathName);
|
if(personFile != null) {
|
ImageIO.write(personBufferedImage, "jpg", personFile);
|
}
|
}
|
} catch (IOException e2) {
|
e2.printStackTrace();
|
}
|
}
|
|
///////////// 保存对比图 //////////////////////
|
if(faceRecognitionInfo.nRetCandidatesExNum > 0
|
&& faceRecognitionInfo.stuCandidatesEx != null) {
|
/* int maxValue = -1;
|
|
// 设备可能返回多张图片，这里只显示相似度最高的
|
int[] nSimilary = new int[faceRecognitionInfo.nRetCandidatesExNum];
|
for(int i = 0; i < faceRecognitionInfo.nRetCandidatesExNum; i++) {
|
nSimilary[i] = faceRecognitionInfo.stuCandidatesEx[i].bySimilarity & 0xff;
|
}
|
|
|
for(int i = 0; i < nSimilary.length; i++) {
|
if(maxValue < nSimilary[i]) {
|
maxValue = nSimilary[i];
|
index = i;
|
}
|
}*/
|
|
String strCandidatePicPathName = path + "\\" + faceRecognitionInfo.UTC.toStringTitle() + "_FaceRecognition_Candidate.jpg";
|
|
// 每个候选人的图片个数：faceRecognitionInfo.stuCandidatesEx[index].stPersonInfo.wFacePicNum，
|
// 正常情况下只有1张。如果有多张，此demo只显示第一张
|
byte[] bufferCandidate = pBuffer.getByteArray(faceRecognitionInfo.stuCandidatesEx[0].stPersonInfo.szFacePicInfo[0].dwOffSet,
|
faceRecognitionInfo.stuCandidatesEx[0].stPersonInfo.szFacePicInfo[0].dwFileLenth);
|
ByteArrayInputStream byteArrInputCandidate = new ByteArrayInputStream(bufferCandidate);
|
|
try {
|
candidateBufferedImage = ImageIO.read(byteArrInputCandidate);
|
if(candidateBufferedImage != null) {
|
File candidateFile = new File(strCandidatePicPathName);
|
if(candidateFile != null) {
|
ImageIO.write(candidateBufferedImage, "jpg", candidateFile);
|
}
|
}
|
} catch (IOException e2) {
|
e2.printStackTrace();
|
}
|
|
}
|
}
|
|
|
/**
|
* 报警信息回调函数原形,建议写成单例模式
|
*/
|
private static class fAlarmDataCB implements NetSDKLib.fMessCallBack{
|
private fAlarmDataCB(){}
|
|
private static class fAlarmDataCBHolder {
|
private static fAlarmDataCB callback = new fAlarmDataCB();
|
}
|
|
public static fAlarmDataCB getCallBack() {
|
return fAlarmDataCBHolder.callback;
|
}
|
|
@Override
|
public boolean invoke(int lCommand, LLong lLoginID, Pointer pStuEvent,
|
int dwBufLen, String strDeviceIP, NativeLong nDevicePort,
|
Pointer dwUser) {
|
// TODO Auto-generated method stub
|
switch (lCommand)
|
{
|
case NetSDKLib.NET_ALARM_ANATOMY_TEMP_DETECT: { // 人体温智能检测事件
|
ALARM_ANATOMY_TEMP_DETECT_INFO msg = new ALARM_ANATOMY_TEMP_DETECT_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
System.out.printf("【人体温智能检测事件 】 时间(UTC):%s 通道号:%d nAction:%d szName:%s nPresetID:%d \n",
|
msg.UTC, msg.nChannelID, msg.nAction, new String(msg.szName).trim(), msg.nPresetID);
|
|
System.out.printf("【区域内人员体温信息】nObjectID"+msg.stManTempInfo.nObjectID+"dbHighTemp"+msg.stManTempInfo.dbHighTemp+" nTempUnit"+msg.stManTempInfo.nTempUnit+"bIsOverTemp"+msg.stManTempInfo.bIsOverTemp+"bIsUnderTemp"+msg.stManTempInfo.bIsUnderTemp+"\n");
|
break;
|
}
|
case NetSDKLib.NET_ALARM_REGULATOR_ABNORMAL: { // 标准黑体源异常报警事件
|
ALARM_REGULATOR_ABNORMAL_INFO msg = new ALARM_REGULATOR_ABNORMAL_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
System.out.printf("【标准黑体源异常报警事件】 时间(UTC):%s 通道号:%d nAction:%d szName:%s 异常类型:%s \n",
|
msg.UTC, msg.nChannelID, msg.nAction, new String(msg.szName).trim(), new String(msg.szTypes).trim());
|
break;
|
}
|
default:
|
break;
|
}
|
return false;
|
}
|
}
|
|
public void LightingControl() {
|
String commond =NetSDKLib.CFG_CMD_LIGHTING;
|
|
CFG_LIGHTING_INFO msg=new CFG_LIGHTING_INFO();
|
|
boolean ret =ToolKits.GetDevConfig(loginHandle, 0, commond, msg);
|
|
if(!ret) {
|
System.err.printf("getconfig failed, ErrCode=%x\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
System.out.println("灯光设置有效个数" + msg.nLightingDetailNum);
|
|
//赋值
|
msg.nLightingDetailNum=1;
|
msg.stuLightingDetail[0].nCorrection=50;
|
msg.stuLightingDetail[0].nSensitive=3;
|
msg.stuLightingDetail[0].emMode=1;
|
msg.stuLightingDetail[0].nNearLight=1;
|
msg.stuLightingDetail[0].stuNearLights[0].bEnable=1;
|
msg.stuLightingDetail[0].stuNearLights[0].dwAnglePercent=50;
|
msg.stuLightingDetail[0].stuNearLights[0].dwLightPercent=50;
|
msg.stuLightingDetail[0].nFarLight=1;
|
msg.stuLightingDetail[0].stuFarLights[0].bEnable=1;
|
msg.stuLightingDetail[0].stuFarLights[0].dwAnglePercent=50;
|
msg.stuLightingDetail[0].stuFarLights[0].dwLightPercent=50;
|
boolean result =ToolKits.SetDevConfig(loginHandle, 0, commond, msg);
|
if(result) {
|
System.out.println("CLIENT_SetConfig success");
|
}else {
|
System.err.println("CLIENT_SetConfig field");
|
}
|
}
|
|
public void LControl() {
|
String commond =NetSDKLib.CFG_CMD_COMPOSE_CHANNEL;
|
|
CFG_COMPOSE_CHANNEL msg=new CFG_COMPOSE_CHANNEL();
|
|
boolean ret =ToolKits.GetDevConfig(loginHandle, 0, commond, msg);
|
|
if(!ret) {
|
System.err.printf("getconfig failed, ErrCode=%x\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
System.out.println("分割模式" + msg.emSplitMode);
|
|
//赋值
|
msg.emSplitMode=NetSDKLib.CFG_SPLITMODE.SPLITMODE_PIP1;
|
msg.nChannelCount=1;
|
msg.nChannelCombination[0]=1;
|
boolean result =ToolKits.SetDevConfig(loginHandle, 0, commond, msg);
|
if(result) {
|
System.out.println("CLIENT_SetConfig success");
|
}else {
|
System.err.println("CLIENT_SetConfig field");
|
}
|
}
|
|
public void kControl() {
|
String commond =NetSDKLib.CFG_CMD_PICINPIC;
|
|
CFG_SMALLPIC_INFO sinfo = new CFG_SMALLPIC_INFO();
|
sinfo.nChannelID=4;
|
|
CFG_SPLIT_CHANNEL_INFO info = new CFG_SPLIT_CHANNEL_INFO();
|
info.bEnable=1;
|
info.nChannelID=8;
|
info.nReturnSmallChannels=1;
|
info.nMaxSmallChannels = 1;
|
info.pPicInfo=new Memory(sinfo.size());
|
ToolKits.SetStructDataToPointer(sinfo, info.pPicInfo, 0);
|
|
CFG_SPLIT_INFO k=new CFG_SPLIT_INFO();
|
k.pSplitChannels=new Memory(info.size());
|
k.emSplitMode=1;
|
k.nReturnChannels=1;
|
k.nMaxChannels = 1;
|
ToolKits.SetStructDataToPointer(info, k.pSplitChannels, 0);
|
|
CFG_PICINPIC_INFO msg=new CFG_PICINPIC_INFO();
|
msg.nReturnSplit=1;
|
msg.nMaxSplit = 1;
|
msg.pSplits=new Memory(k.size());
|
ToolKits.SetStructDataToPointer(k, msg.pSplits, 0);
|
/*
|
* ToolKits.SetStructDataToPointer(k, piont, 0);
|
* ToolKits.SetStructDataToPointer(info, pointer, 0);
|
* ToolKits.SetStructDataToPointer(sinfo, point, 0); boolean ret
|
* =ToolKits.GetDevConfig(loginHandle, 0, commond, msg);
|
*
|
* if(!ret) { System.err.printf("getconfig failed, ErrCode=%x\n",
|
* netSdk.CLIENT_GetLastError()); return; } System.out.println("解析得到实际使用" +
|
* msg.nReturnSplit);
|
*/
|
|
//赋值
|
boolean result
|
=ToolKits.SetDevConfig(loginHandle, 0, commond, msg); if(result) {
|
System.out.println("CLIENT_SetConfig success"); }else {
|
System.err.println("CLIENT_SetConfig field"); }
|
|
}
|
|
/**
|
* 智能报警事件回调
|
*/
|
public static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack{
|
|
private File picturePath;
|
|
private AnalyzerDataCB() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdir();
|
}
|
}
|
|
private static class CallBackHolder {
|
private static AnalyzerDataCB instance = new AnalyzerDataCB();
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
@Override
|
public int invoke(LLong lAnalyzerHandle, int dwAlarmType,
|
Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize, Pointer dwUser,
|
int nSequence, Pointer reserved) {
|
// TODO Auto-generated method stub
|
{
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
switch(dwAlarmType)
|
{
|
case NetSDKLib.EVENT_IVS_ANATOMY_TEMP_DETECT : // 人体温智能检测事件
|
{
|
NetSDKLib.DEV_EVENT_ANATOMY_TEMP_DETECT_INFO msg = new NetSDKLib.DEV_EVENT_ANATOMY_TEMP_DETECT_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
System.out.printf("【人体温智能检测事件 】 时间(UTC):%s 通道号:%d nAction:%d szName:%s nPresetID:%d \n",
|
msg.UTC, msg.nChannelID, msg.nAction, new String(msg.szName).trim(), msg.nPresetID);
|
|
System.out.printf("【区域内人员体温信息】nObjectID"+msg.stManTempInfo.nObjectID+",dbHighTemp"
|
+msg.stManTempInfo.dbHighTemp+",nTempUnit"+msg.stManTempInfo.nTempUnit
|
+",bIsOverTemp"+msg.stManTempInfo.bIsOverTemp+",bIsUnderTemp"
|
+msg.stManTempInfo.bIsUnderTemp+",emMaskDetectResult"+msg.stManTempInfo.emMaskDetectResult+
|
",nAge"+msg.stManTempInfo.nAge+",emSex"+msg.stManTempInfo.emSex
|
+",stThermalRect_top"+msg.stManTempInfo.stThermalRect.top
|
+",stThermalRect_left"+msg.stManTempInfo.stThermalRect.left
|
+",stThermalRect_right"+msg.stManTempInfo.stThermalRect.right
|
+",stThermalRect_bottom"+msg.stManTempInfo.stThermalRect.bottom+"\n");
|
//可见光全景图
|
if(msg.stVisSceneImage!=null && msg.stVisSceneImage.nLength> 0){
|
String bigPicture = picturePath + "\\" + System.currentTimeMillis() + ".jpg";
|
ToolKits.savePicture(pBuffer, msg.stVisSceneImage.nOffset, msg.stVisSceneImage.nLength, bigPicture);
|
}
|
//热成像全景图
|
if(msg.stThermalSceneImage!=null && msg.stThermalSceneImage.nLength> 0){
|
String smallPicture = picturePath + "\\" + System.currentTimeMillis() + "small.jpg";
|
ToolKits.savePicture(pBuffer, msg.stThermalSceneImage.nOffset, msg.stThermalSceneImage.nLength, smallPicture);
|
}
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_FACERECOGNITION : // 目标识别事件
|
{
|
DEV_EVENT_FACERECOGNITION_INFO msg=new DEV_EVENT_FACERECOGNITION_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
System.out.println( "眼睛"+msg.stuFaceData.emEye+ "嘴巴"+msg.stuFaceData.emMouth+ "胡子"+msg.stuFaceData.emBeard);
|
System.out.printf("【目标识别事件 】 时间(UTC):%s 通道号:%d emMask:%d dbTemperature:%f bAnatomyTempDetect:%s\n",
|
msg.UTC, msg.nChannelID, msg.stuFaceData.emMask, msg.stuFaceData.dbTemperature,msg.stuFaceData.bAnatomyTempDetect);
|
try {
|
saveFaceRecognitionPic(pBuffer, dwBufSize, msg);
|
} catch (FileNotFoundException e) {
|
e.printStackTrace();
|
}
|
}
|
break;
|
default:
|
break;
|
}
|
}
|
return 0;
|
}
|
}
|
|
/**
|
* 设备断线回调
|
*/
|
private static class DisConnectCallBack implements NetSDKLib.fDisConnect {
|
|
private DisConnectCallBack() {
|
}
|
|
private static class CallBackHolder {
|
private static DisConnectCallBack instance = new DisConnectCallBack();
|
}
|
|
public static DisConnectCallBack getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%s] Port[%d] DisConnect!\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
/**
|
* 设备重连回调
|
*/
|
private static class HaveReConnectCallBack implements NetSDKLib.fHaveReConnect {
|
private HaveReConnectCallBack() {
|
}
|
|
private static class CallBackHolder {
|
private static HaveReConnectCallBack instance = new HaveReConnectCallBack();
|
}
|
|
public static HaveReConnectCallBack getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
public void invoke(NetSDKLib.LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
|
|
}
|
}
|
public void RunTest(){
|
CaseMenu menu=new CaseMenu();
|
menu.addItem((new CaseMenu.Item(this , "BatchAppendFaceRecognition" , "BatchAppendFaceRecognition")));
|
menu.addItem((new CaseMenu.Item(this , "StopRealPlay" , "StopRealPlay")));
|
menu.addItem((new CaseMenu.Item(this , "TempBlackConfig" , "TempBlackConfig")));
|
menu.addItem((new CaseMenu.Item(this , "Realplay" , "Realplay")));
|
menu.addItem((new CaseMenu.Item(this , "RealLoadPictureEx" , "RealLoadPictureEx")));
|
menu.addItem((new CaseMenu.Item(this , "StopLoadPic" , "StopLoadPic")));
|
menu.addItem((new CaseMenu.Item(this , "startListen" , "startListen")));
|
menu.addItem((new CaseMenu.Item(this , "stopListen" , "stopListen")));
|
menu.addItem((new CaseMenu.Item(this , "LightingControl" , "LightingControl")));
|
menu.addItem((new CaseMenu.Item(this , "Control" , "Control")));
|
menu.addItem((new CaseMenu.Item(this , "LControl" , "LControl")));
|
menu.addItem((new CaseMenu.Item(this , "kControl" , "kControl")));
|
menu.run();
|
}
|
public static void main(String []args){
|
ThermalDemo XM=new ThermalDemo(loginHandle);
|
XM.InitTest();
|
XM.RunTest();
|
XM.LoginOut();
|
}
|
}
|
