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.structure.CFG_REGULATOR_DETECT_INFO; import com.netsdk.lib.structure.NET_CFG_ENVIRONMENT_THERM_INFO; import com.netsdk.lib.structure.NET_TIME; import com.netsdk.lib.utils.Initialization; import com.sun.jna.Memory; import com.sun.jna.Native; import com.sun.jna.NativeLong; import com.sun.jna.Pointer; import java.io.UnsupportedEncodingException; import static com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_ENVIRONMENT_THERM_INFO; /** * @author 291189 * @version 1.0 * @description GIP220708004 GIP220722037 * @date 2022/7/23 10:14 */ public class RegulatorAbnormalDemo extends Initialization { /** * 订阅 * @return */ public void startListen() { // 设置报警回调函数 netSdk.CLIENT_SetDVRMessCallBack(fAlarmDataCB.getCallBack(), null); // 订阅报警 boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle); if (!bRet) { System.err.println("订阅报警失败! LastError = 0x%x\n" + netSdk.CLIENT_GetLastError()); } else { System.out.println("订阅报警成功."); } } /** * 取消订阅 * @return */ public void stopListen() { // 停止订阅报警 boolean bRet = netSdk.CLIENT_StopListen(loginHandle); if (bRet) { System.out.println("取消订阅报警信息."); } } /** * 报警信息回调函数原形,建议写成单例模式 */ private static class fAlarmDataCB implements NetSDKLib.fMessCallBack{ private fAlarmDataCB(){} private static class fAlarmDataCBHolder { private static fAlarmDataCB callback = new fAlarmDataCB(); } public static fAlarmDataCB getCallBack() { return fAlarmDataCB.fAlarmDataCBHolder.callback; } public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP, NativeLong nDevicePort, Pointer dwUser){ // System.out.printf("command = %x\n", lCommand); switch (lCommand) { case NetSDKLib.NET_ALARM_REGULATOR_ABNORMAL: { // // 标准黑体源异常报警事件(对应结构体 ALARM_REGULATOR_ABNORMAL_INFO) System.out.println(" 标准黑体源异常报警事件"); NetSDKLib.ALARM_REGULATOR_ABNORMAL_INFO msg = new NetSDKLib.ALARM_REGULATOR_ABNORMAL_INFO(); ToolKits.GetPointerData(pStuEvent, msg); System.out.println(" nAction:"+ msg.nAction); System.out.println(" nChannelID:"+ msg.nChannelID); System.out.println(" szName:"+ new String(msg.szName)); System.out.println(" UTC:"+ msg.UTC.toStringTime()); System.out.println(" nEventID:"+ msg.nEventID); System.out.println(" szTypes:"+ new String(msg.szTypes)); break; } default: break; } return true; } } // CLIENT_GetNewDevConfig和CLIENT_SetNewDevConfig + EVENT_IVS_ANATOMY_TEMP_DETECT + CFG_ANATOMY_TEMP_DETECT_INFO //人体温智能检测事件配置 public void SetTempEnable() { int channel =1; // 通道号 String command = NetSDKLib.CFG_CMD_ANALYSERULE; //视频分析规则配置(对应 CFG_ANALYSERULES_INFO) int ruleCount = 10; // 事件规则个数 NetSDKLib.CFG_RULE_INFO[] ruleInfo = new NetSDKLib.CFG_RULE_INFO[ruleCount]; for(int i = 0; i < ruleCount; i++) { ruleInfo[i] = new NetSDKLib.CFG_RULE_INFO(); } NetSDKLib.CFG_ANALYSERULES_INFO analyse = new NetSDKLib.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: // 人体温智能检测事件 { System.out.println(" 人体温智能检测事件"); NetSDKLib.CFG_ANATOMY_TEMP_DETECT_INFO msg = new NetSDKLib.CFG_ANATOMY_TEMP_DETECT_INFO(); ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, msg); try { System.out.println("规则名称 gbk：" + new String(msg.szRuleName,"GBK").trim()); System.out.println("规则名称 utf-8：" + new String(msg.szRuleName,"UTF-8").trim()); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } 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()); ToolKits.ByteArrZero(msg.szRuleName);//重新赋值前先将之前的数据清空 // 设置使能开 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()); } } //标准黑体源异常报警配置，对应结构体 CFG_REGULATOR_DETECT_INFO. 热成像通道有效 public void regulator(){ int chanl=1; CFG_REGULATOR_DETECT_INFO stuPTZ = new CFG_REGULATOR_DETECT_INFO(); if (!ToolKits.GetDevConfig(loginHandle, chanl, NetSDKLib.CFG_CMD_REGULATOR_DETECT, stuPTZ)) { System.err.println("Get CFG_REGULATOR_DETECT_INFO Failed!" + ToolKits.getErrorCode()); return; } System.out.println("bEnable:"+stuPTZ.bEnable); //灵敏度, 1-100 System.out.println("nSensitivity:"+stuPTZ.nSensitivity); stuPTZ.bEnable = 1; // 使能 /** 灵敏度, 1-100 */ stuPTZ.nSensitivity = 80; // if (!ToolKits.SetDevConfig(loginHandle, chanl, NetSDKLib.CFG_CMD_REGULATOR_DETECT, stuPTZ)) { System.err.println("Set PTZ Failed!" + ToolKits.getErrorCode()); } else { System.out.println("Set PTZ Success!"); } } // 环境温度信息(热成像内部配置,只可读,不可设),通道号需要填热成像通道号 对应结构体 NET_CFG_ENVIRONMENT_THERM_INFO public void therm(){ int nChannelID=1; NET_CFG_ENVIRONMENT_THERM_INFO msg=new NET_CFG_ENVIRONMENT_THERM_INFO(); Pointer pstuConfigInfo=new Memory(msg.size()); pstuConfigInfo.clear(msg.size()); ToolKits.SetStructDataToPointer(msg, pstuConfigInfo, 0); boolean gRet = netSdk.CLIENT_GetConfig(loginHandle, NET_EM_CFG_ENVIRONMENT_THERM_INFO, nChannelID, pstuConfigInfo, msg.size(), 3000, null); if (!gRet) { Native.free(Pointer.nativeValue(pstuConfigInfo)); //清理内存 Pointer.nativeValue(pstuConfigInfo, 0); System.err.println("CLIENT_GetConfig fail"+ToolKits.getErrorCode()); return; } ToolKits.GetPointerDataToStruct(pstuConfigInfo,0,msg); Native.free(Pointer.nativeValue(pstuConfigInfo)); //清理内存 Pointer.nativeValue(pstuConfigInfo, 0); int nEnvironmentTemp = msg.nEnvironmentTemp; System.out.println("nEnvironmentTemp:"+nEnvironmentTemp); NET_TIME stuLastEnvSaveTime = msg.stuLastEnvSaveTime; System.out.println("stuLastEnvSaveTime:"+stuLastEnvSaveTime); int nEnvSaveCnt = msg.nEnvSaveCnt; System.out.println("nEnvSaveCnt:"+nEnvSaveCnt); } public void RunTest() { System.out.println("Run Test"); CaseMenu menu = new CaseMenu(); menu.addItem((new CaseMenu.Item(this , "therm" , "therm"))); menu.addItem((new CaseMenu.Item(this , "SetTempEnable" , "SetTempEnable"))); menu.addItem((new CaseMenu.Item(this , "regulator" , "regulator"))); menu.addItem((new CaseMenu.Item(this , "startListen" , "startListen"))); menu.addItem((new CaseMenu.Item(this , "stopListen" , "stopListen"))); menu.run(); } public static void main(String[] args) { RegulatorAbnormalDemo regulatorAbnormalDemo=new RegulatorAbnormalDemo(); InitTest("10.35.232.184",40066,"admin","admin123"); regulatorAbnormalDemo.RunTest(); LoginOut(); } }