package com.netsdk.demo.customize; import com.netsdk.lib.NetSDKLib; import com.netsdk.lib.ToolKits; import com.netsdk.lib.enumeration.ENUMERROR; import com.netsdk.lib.structure.MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_INFO; import com.netsdk.lib.structure.MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_PARAM; import com.netsdk.lib.structure.NET_SMART_KITCHEN_CLOTHES_CHEF_MASK; 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.util.Date; import java.util.Scanner; /** * @author 291189 * @version 1.0 * @description * @date 2021/7/26 9:39 智慧厨房穿着检测事件 */ public class SmartKitchenClothesDetectionDemo extends Initialization { public static NetSDKLib.LLong AttachHandle=new NetSDKLib.LLong(0); /** * 订阅智能事件 * @return */ public static NetSDKLib.LLong realLoadPic(int ChannelId ) { /** * 说明： * 通道数可以在有登录是返回的信息 m_stDeviceInfo.byChanNum 获取 */ //先关闭，再开启 if(AttachHandle.intValue()!=0){ DetachEventRealLoadPic(AttachHandle); } int bNeedPicture = 1; // 是否需要图片 NetSDKLib.LLong m_hAttachHandle =netSdk.CLIENT_RealLoadPictureEx(loginHandle, ChannelId, netSdk.EVENT_IVS_SMART_KITCHEN_CLOTHES_DETECTION, bNeedPicture , AnalyzerDataCB.getInstance() , null , null); if( m_hAttachHandle.longValue() != 0 ) { System.out.println("CLIENT_RealLoadPictureEx Success ChannelId : \n" + ChannelId); } else { throw new RuntimeException("CLIENT_RealLoadPictureEx Failed!" + ToolKits.getErrorCode()); } return m_hAttachHandle; } //智慧厨房查询 public static void findSmartKitchenClothesDetectionFile() { // 选择查询类型->智慧厨房查询 int type = NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_SMART_KITCHEN_CLOTHES_DETECTION; MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_PARAM msgIn = new MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_PARAM(); msgIn.nChannelID = 0; //通道号从0开始,-1表示查询所有通道 NET_SMART_KITCHEN_CLOTHES_CHEF_MASK stuChefMask=new NET_SMART_KITCHEN_CLOTHES_CHEF_MASK(); stuChefMask.bChefMask=1; //查询条件，至少要填写一个 msgIn.stuChefMask=stuChefMask; msgIn.stuBeginTime = new NetSDKLib.NET_TIME() { { setTime(2021, 7, 20, 0, 0, 0); }}; // 历史库结束时间->"EndTime" msgIn.stuEndTime =new NetSDKLib.NET_TIME() { { setTime(2021, 8, 5, 23, 59, 59); } }; msgIn.write(); // 调用 SDK FindFile(FaceRecognition) 接口，成功了会获取检索结果集的句柄 lFindHandle NetSDKLib.LLong lFindHandle = netSdk.CLIENT_FindFileEx(loginHandle, type, msgIn.getPointer(), null, 2000); if(lFindHandle.intValue()==0){ throw new RuntimeException("find file fail"); } msgIn.read(); /////////////////////////////////////// GetTotalFileCount///////////////////////////////////////////////////////////////////////// /////////////////////////////////////// 查看共有多少数据///////////////////////////////////////////////////////////////////////// IntByReference pCount = new IntByReference(); boolean rt = netSdk.CLIENT_GetTotalFileCount(lFindHandle, pCount, null, 2000); if (!rt) { System.err.println("获取搜索句柄：" + lFindHandle + " 的搜索内容量失败。"); return; } System.out.println("搜索句柄：" + lFindHandle + " 共获取到：" + pCount.getValue() + " 条数据。"); /////////////////////////////////////// FindNextFile/////////////////////////////////////// //////////////////////////////////////////// ///////////////////////////////////// 循环获取查询数据/////////////////////////////////////// //////////////////////////////////////////// int nMaxCount = 10; // 一次最多获取条数，不一定会有这么多，数值不宜太大 MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_INFO[] info =new MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_INFO[nMaxCount]; for (int i = 0; i < info.length; ++i) { info[i] = new MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_INFO(); } int MemorySize = info[0].size() * nMaxCount; Pointer pInfo = new Memory(MemorySize); pInfo.clear(MemorySize); ToolKits.SetStructArrToPointerData(info, pInfo); // 循环查询 int nCurCount = 0; int nFindCount = 0; while (true) { int nRet = netSdk.CLIENT_FindNextFileEx(lFindHandle, nMaxCount, pInfo, MemorySize, null, 3000); // 从指针中把数据复制出来 ToolKits.GetPointerDataToStructArr(pInfo, info); System.out.println("获取到记录数 : " + nRet); if (nRet < 0) { System.err.println("FindNextFileEx failed!" + ENUMERROR.getErrorMessage()); break; } else if (nRet == 0) { break; } // 展示数据 for (int i = 0; i < nRet; i++) { nFindCount = 1 + nCurCount; MEDIAFILE_SMART_KITCHEN_CLOTHES_DETECTION_INFO smartInfo = info[i]; int nChannelID = smartInfo.nChannelID; // 通道号从0开始,-1表示查询所有通道 System.out.println("通道号:"+nChannelID); NetSDKLib.NET_TIME stuStartTime = smartInfo.stuStartTime; // 开始时间 System.out.println("开始时间:"+stuStartTime); NetSDKLib.NET_TIME stuEndTime = smartInfo.stuEndTime; // 结束时间 System.out.println("结束时间:"+stuEndTime); int emHasMask = smartInfo.emHasMask; //厨师口罩状态 System.out.println("厨师口罩状态:"+emHasMask); int emHasChefHat = smartInfo.emHasChefHat;//厨师帽状态 System.out.println("厨师帽状态:"+emHasChefHat); int emHasChefClothes = smartInfo.emHasChefClothes;//厨师服状态 System.out.println("厨师服状态:"+emHasChefClothes); int emChefClothesColor = smartInfo.emChefClothesColor;//厨师服颜色 System.out.println("厨师服颜色:"+emChefClothesColor); byte[] szFaceImagePath = smartInfo.szFaceImagePath; // 人脸小图路径 System.out.println("人脸小图路径:"+new String(szFaceImagePath)); int nFaceImageLength = smartInfo.nFaceImageLength;// 人脸小图图片大小，单位字节 System.out.println("人脸小图图片大小:"+nFaceImageLength); byte[] szHumanImagePath = smartInfo.szHumanImagePath;// 人体小图路径 System.out.println("人体小图路径:"+new String(szHumanImagePath)); int nHumanImageLength = smartInfo.nHumanImageLength;// 人体小图图片大小，单位字节 System.out.println("人体小图图片大小:"+nHumanImageLength); byte[] szSceneImagePath = smartInfo.szSceneImagePath; // 人体小图对应的全景图路径 System.out.println("人体小图对应的全景图路径:"+new String(szSceneImagePath)); int nSceneImageLength = smartInfo.nSceneImageLength; // 人体小图对应的全景图图片大小，单位字节 System.out.println("人体小图对应的全景图图片大小:"+nSceneImageLength); nCurCount++; } if(nRet < nMaxCount) { break; } } netSdk.CLIENT_FindCloseEx(lFindHandle); //结束录像文件查找 } /** * 停止侦听智能事件 */ public static void DetachEventRealLoadPic(NetSDKLib.LLong AttachHandle) { if (AttachHandle.longValue() != 0) { netSdk.CLIENT_StopLoadPic(AttachHandle); } } /** 写成静态主要是防止被回收 */ private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack { static File picturePath=null; private AnalyzerDataCB() { } private static class AnalyzerDataCBHolder { private static final AnalyzerDataCB instance = new AnalyzerDataCB(); } public static AnalyzerDataCB getInstance() { picturePath= new File("./HumanImage/"); if (!picturePath.exists()) { picturePath.mkdirs(); } return AnalyzerDataCBHolder.instance; } public int invoke( NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize, Pointer dwUser, int nSequence, Pointer reserved) { if (lAnalyzerHandle.longValue() == 0 || pAlarmInfo == null) { return -1; } switch (dwAlarmType) { case NetSDKLib.EVENT_IVS_SMART_KITCHEN_CLOTHES_DETECTION: // 智慧厨房穿着检测事件 { NetSDKLib.DEV_EVENT_SMART_KITCHEN_CLOTHES_DETECTION_INFO msg = new NetSDKLib.DEV_EVENT_SMART_KITCHEN_CLOTHES_DETECTION_INFO(); ToolKits.GetPointerData(pAlarmInfo, msg); double pts = msg.PTS;//时间戳 System.out.println("time:"+new Date((long)pts)); NetSDKLib.NET_TIME_EX utc = msg.UTC; //事件发生的时间 System.out.println("事件发生的时间:"+utc); NetSDKLib.HUMAN_IMAGE_INFO stuHumanImage = msg.stuHumanImage; //人体图片信息 if(stuHumanImage!=null && stuHumanImage.nLength> 0){ String humanPicture = picturePath + "\\" + System.currentTimeMillis() + "human.jpg"; ToolKits.savePicture(pBuffer, stuHumanImage.nOffSet, stuHumanImage.nLength, humanPicture); } NetSDKLib.SCENE_IMAGE_INFO stuSceneImage = msg.stuSceneImage; //全景广角图 if(stuSceneImage!=null && stuSceneImage.nLength> 0){ String scenePicture = picturePath + "\\" + System.currentTimeMillis() + "scene.jpg"; try { ToolKits.savePicture(pBuffer, stuSceneImage.nOffSet, stuSceneImage.nLength, scenePicture); } catch (Exception e) { e.printStackTrace(); } } NetSDKLib.FACE_IMAGE_INFO stuFaceImage = msg.stuFaceImage; // 人脸图片信息 if(stuFaceImage!=null && stuFaceImage.nLength> 0){ String facePicture = picturePath + "\\" + System.currentTimeMillis() + "face.jpg"; try { ToolKits.savePicture(pBuffer, stuFaceImage.nOffSet, stuFaceImage.nLength, facePicture); } catch (Exception e) { e.printStackTrace(); } } int nObjectID = msg.nObjectID; System.out.println("目标ID:"+nObjectID); int emHasMask= msg.emHasMask; // 检测是否有戴口罩（对应枚举值EM_NONMOTOR_OBJECT_STATUS） System.out.println("检测是否有戴口罩:"+emHasMask); int emHasChefHat =msg.emHasChefHat; // 检测是否有戴厨师帽（对应枚举值EM_NONMOTOR_OBJECT_STATUS） System.out.println("检测是否有戴厨师帽:"+emHasChefHat); int emHasChefClothes= msg.emHasChefClothes; // 检测是否有穿厨师服（对应枚举值EM_NONMOTOR_OBJECT_STATUS） System.out.println("检测是否有穿厨师服:"+emHasChefClothes); int emChefClothesColor=msg.emChefClothesColor; // 厨师服颜色（对应枚举值EM_OBJECT_COLOR_TYPE） System.out.println("厨师服颜色:"+emChefClothesColor); break; } default: System.out.println("其他事件：" + dwAlarmType); break; } return 0; } } /* public void RunTest() { CaseMenu menu = new CaseMenu(); menu.addItem((new CaseMenu.Item(this, "realLoadPic", "realLoadPic"))); menu.addItem((new CaseMenu.Item(this, "DetachEventRealLoadPic", "DetachEventRealLoadPic"))); menu.run(); }*/ public static void main(String[] args) { Initialization.InitTest("20.2.35.84", 37777, "admin", "admin123"); Scanner scanner=new Scanner(System.in); while (true){ System.out.println("0 ,退出"); System.out.println("1 ,订阅智能事件"); System.out.println("2 ,结束订阅事件"); System.out.println("3 ,智慧厨房查询"); int step = scanner.nextInt(); if(step==0){ break; }else if(step==1){ AttachHandle= realLoadPic(0); }else if(step==2) { DetachEventRealLoadPic(AttachHandle); }else if(step==3){ findSmartKitchenClothesDetectionFile(); } else{ break; } } Initialization.LoginOut(); } }