package com.netsdk.demo.customize.securityCheck; import com.netsdk.demo.util.CaseMenu; import com.netsdk.lib.NativeString; import com.netsdk.lib.NetSDKLib; import com.netsdk.lib.ToolKits; import com.netsdk.lib.callback.securityCheck.PackageInformationCallBack; import com.netsdk.lib.structure.NET_IN_XRAY_ATTACH_PACKAGE_STATISTICS; import com.netsdk.lib.structure.NET_OUT_XRAY_ATTACH_PACKAGE_STATISTICS; import com.sun.jna.Memory; import com.sun.jna.Pointer; import java.io.File; import java.util.UUID; import static com.netsdk.lib.Utils.getOsPrefix; /** * @author 291189 * @version 1.0 * @description 安检机包裹检测 * @date 2021/7/1 */ public class SecurityMachinePackageDetectionDemo { /** 10.35.232.160 安检门环境 admin admin123 安检机 10.35.233.144 port 37777 admin admin123 */ private String m_strIpAddr = "10.35.232.75"; private int m_nPort = 37777; private String m_strUser = "admin"; private String m_strPassword = "admin123"; static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE; static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE; // public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE; // 登陆句柄 private static NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0); // 订阅句柄 private static NetSDKLib.LLong AttachHandle = new NetSDKLib.LLong(0); //X光机包裹信息句柄 private static NetSDKLib.LLong lFindID = new NetSDKLib.LLong(0); // 设备信息扩展 private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex(); /** * 设备断线回调 */ private static class DisconnectCallback implements NetSDKLib.fDisConnect { private static DisconnectCallback instance = new DisconnectCallback(); private DisconnectCallback() { } public static DisconnectCallback getInstance() { return instance; } public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) { System.out.printf("Device[%s:%d] Disconnect!\n", pchDVRIP, nDVRPort); } } /** * 设备重连回调 */ private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect { private static HaveReconnectCallback instance = new HaveReconnectCallback(); private HaveReconnectCallback() { } public static HaveReconnectCallback getInstance() { return instance; } public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) { System.out.printf("Device[%s:%d] HaveReconnected!\n", pchDVRIP, nDVRPort); } } public void InitTest(){ // 初始化SDK库 netSdk.CLIENT_Init(DisconnectCallback.getInstance(), null); // 设置断线重连成功回调函数 netSdk.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null); //打开日志，可选0 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!!!"); } loginWithHighLevel(); } /** * 高安全登录 */ public void loginWithHighLevel() { // 输入结构体参数 NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() { { szIP = m_strIpAddr.getBytes(); nPort = m_nPort; szUserName = m_strUser.getBytes(); szPassword = m_strPassword.getBytes(); } }; // 输出结构体参数 NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY(); // 写入sdk loginHandle = netSdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam); if (loginHandle.longValue() == 0) { System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", m_strIpAddr, m_nPort, netSdk.CLIENT_GetLastError()); } else { deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息 System.out.println("Login Success"); System.out.println("Device Address：" + m_strIpAddr); System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道"); } } /** * 退出清理环境 */ 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); } // 编码格式 public static String encode; static { String osPrefix = getOsPrefix(); if (osPrefix.toLowerCase().startsWith("win64-amd64")) { encode = "GBK"; } else if (osPrefix.toLowerCase().startsWith("linux-amd64")) { encode = "UTF-8"; } } /** * 订阅X光机包裹数量统计信息 */ public void attachPackageStatistics(){ //入参 NET_IN_XRAY_ATTACH_PACKAGE_STATISTICS inParam=new NET_IN_XRAY_ATTACH_PACKAGE_STATISTICS(); UUID uuid= UUID.randomUUID(); byte[] szUUID = inParam.szUUID; String numbers =uuid.toString(); //beda31a3-a7b5-4126-81b9-6e67402b7b0c? int i = numbers.lastIndexOf("-"); String[] split = numbers.split("-"); //UUID算法(8-4-4-16格式) numbers=split[0]+"-"+split[1]+""+split[2]+"-"+split[3]+split[4]; System.arraycopy(numbers.getBytes(), 0, szUUID, 0, numbers.getBytes().length); inParam.szUUID=szUUID; Pointer user=new Memory(1024); inParam.dwUser=user; inParam.cbNotify= PackageInformationCallBack.getInstance(); Pointer pInParam=new Memory(inParam.size()); ToolKits.SetStructDataToPointer(inParam, pInParam, 0); //出参 NET_OUT_XRAY_ATTACH_PACKAGE_STATISTICS outParm=new NET_OUT_XRAY_ATTACH_PACKAGE_STATISTICS(); Pointer pOutParam=new Memory(outParm.size()); ToolKits.SetStructDataToPointer(outParm, pOutParam, 0); AttachHandle= netSdk.CLIENT_XRayAttachPackageStatistics(loginHandle,pInParam,pOutParam,3000); if (AttachHandle.longValue() != 0) { System.out.println("CLIENT_XRayAttachPackageStatistics Success"); } else { System.out.println("CLIENT_XRayAttachPackageStatistics Failed!LastError = %s\n"+ToolKits.getErrorCode()); } } /** * 取消订阅X光机包裹数量统计信息 */ public void DetachPackageStatistics() { if (AttachHandle.longValue() != 0) { netSdk.CLIENT_XRayDetachPackageStatistics(AttachHandle); } } // 开始查找X光机包裹信息 public void StartFindXRayPkg(){ NetSDKLib.NET_IN_START_FIND_XRAY_PKG NSFXP=new NetSDKLib.NET_IN_START_FIND_XRAY_PKG(); NetSDKLib.NET_OUT_START_FIND_XRAY_PIC NOSFT=new NetSDKLib.NET_OUT_START_FIND_XRAY_PIC(); //查询结果按时间排序(1.按时间升序。2.按时间降序) NSFXP.emTimeOrder=1; //开始时间 NSFXP.stuStartTime.setTime(2021,7,1,00,00,00); /*NSFXP.stuStartTime.dwYear=2019; NSFXP.stuStartTime.dwMonth=10; NSFXP.stuStartTime.dwDay=23; NSFXP.stuStartTime.dwHour=12; NSFXP.stuStartTime.dwMinute=12; NSFXP.stuStartTime.dwSecond=12;*/ //结束时间 NSFXP.stuEndTime.setTime(2021,7,1,23,59,59); /*NSFXP.stuEndTime.dwYear=2019; NSFXP.stuEndTime.dwMonth=10; NSFXP.stuEndTime.dwDay=24; NSFXP.stuEndTime.dwHour=12; NSFXP.stuEndTime.dwMinute=12; NSFXP.stuEndTime.dwSecond=12;*/ int[] SimilarityArray={0,100}; int[] emObjTypeArray={1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26}; System.arraycopy(SimilarityArray,0,NSFXP.nSimilarityRange,0,SimilarityArray.length); NSFXP.nObjTypeNum=26; System.arraycopy(emObjTypeArray,0,NSFXP.emObjType,0,NSFXP.nObjTypeNum); lFindID=netSdk.CLIENT_StartFindXRayPkg(loginHandle, NSFXP, NOSFT, 1000); if(AttachHandle.longValue()!=0){ System.out.printf("Start FindXRayPkg Success!\n 包裹总数为"+NOSFT.nTotal); }else{ System.err.printf("Start FindXRayPkg Fail.Error[%s]\n", ToolKits.getErrorCode()); } } // 查询X光机包裹的信息 public void DoFindXRayPkg(){ if(lFindID.longValue() == 0) { System.out.println("请开始查找X光机包裹信息"); return; } File picturePath= new File("./ColorOverlay/"); if (!picturePath.exists()) { picturePath.mkdirs(); } NetSDKLib.NET_IN_DO_FIND_XRAY_PKG NIODFXP = new NetSDKLib.NET_IN_DO_FIND_XRAY_PKG(); NetSDKLib.NET_OUT_DO_FIND_XRAY_PKG NODFXPG = new NetSDKLib.NET_OUT_DO_FIND_XRAY_PKG(); NetSDKLib.NET_XRAY_PKG_INFO[] NXPI = new NetSDKLib.NET_XRAY_PKG_INFO[10]; for(int i=0;i<10;i++) { NXPI[i] = new NetSDKLib.NET_XRAY_PKG_INFO(); } NIODFXP.nCount=10; NIODFXP.nOffset=10; NODFXPG.nMaxCount=10; NODFXPG.pstuXRayPkgInfo = new Memory(NXPI[0].size()*10); NODFXPG.pstuXRayPkgInfo.clear(NXPI[0].size()*10); ToolKits.SetStructArrToPointerData(NXPI, NODFXPG.pstuXRayPkgInfo); // 将数组内存拷贝给Pointer Boolean DoFind=netSdk.CLIENT_DoFindXRayPkg(lFindID, NIODFXP, NODFXPG, 3000); if(!DoFind){ System.err.printf("Do Find XRay Pkg.Error[%s]\n", ToolKits.getErrorCode()); return; } ToolKits.GetPointerDataToStructArr(NODFXPG.pstuXRayPkgInfo, NXPI); for(int j = 0; j< NODFXPG.nRetCount; j++) { System.out.println("包裹产生时间"+NXPI[j].stuTime+"\n关联的进口IPC通道号"+NXPI[j].nChannelIn+"\n关联的出口IPC通道号"+NXPI[j].nChannelOut +"\n用户名"+new String(NXPI[j].szUser).trim()+"\n需要下载的文件名"+new String(NXPI[j].stuViewInfo[0].szColorOverlayImagePath).trim()); for(int k=0;k<2;k++){ byte[] EnergyPath=NXPI[j].stuViewInfo[k].szEnergyImagePath; byte[] ColorOverlayPath=NXPI[j].stuViewInfo[k].szColorOverlayImagePath; if(NXPI[j].stuViewInfo[k].nColorOverlayImageLength !=0){ // 入参 NetSDKLib.NET_IN_DOWNLOAD_REMOTE_FILE stIn = new NetSDKLib.NET_IN_DOWNLOAD_REMOTE_FILE(); stIn.pszFileName = new NativeString(new String(ColorOverlayPath).trim()).getPointer(); stIn.pszFileDst = new NativeString(picturePath + "\\"+System.currentTimeMillis()+"ColorOverlayPath"+".jpg").getPointer(); // 存放路径 // 出参 NetSDKLib.NET_OUT_DOWNLOAD_REMOTE_FILE stOut = new NetSDKLib.NET_OUT_DOWNLOAD_REMOTE_FILE(); if(netSdk.CLIENT_DownloadRemoteFile(loginHandle, stIn, stOut, 5000)) { System.out.println("下载图片成功!"); } else { System.err.println("下载图片失败!" + ToolKits.getErrorCode()); } } } } } // 结束查询X光机包裹的信息 public void StopFindXRayPkg(){ Boolean StopFind=netSdk.CLIENT_StopFindXRayPkg(lFindID); if(StopFind){ System.out.println("Stop Find XRayPkg suceess"); } } public void RunTest() { System.out.println("Run Test"); CaseMenu menu = new CaseMenu(); menu.addItem(new CaseMenu.Item(this , "attachPackageStatistics" , "attachPackageStatistics")); menu.addItem(new CaseMenu.Item(this , "DetachPackageStatistics" , "DetachPackageStatistics")); menu.addItem((new CaseMenu.Item(this , "StartFindXRayPkg" , "StartFindXRayPkg"))); menu.addItem((new CaseMenu.Item(this , "DoFindXRayPkg" , "DoFindXRayPkg"))); menu.addItem((new CaseMenu.Item(this , "StopFindXRayPkg" , "StopFindXRayPkg"))); menu.run(); } public static void main(String[] args){ SecurityMachinePackageDetectionDemo securityMachinePackageDetectionDemo=new SecurityMachinePackageDetectionDemo(); securityMachinePackageDetectionDemo.InitTest(); securityMachinePackageDetectionDemo.RunTest(); securityMachinePackageDetectionDemo.LoginOut(); } }