图片下载

src/main/java/com/unis/alarm/Alarm.java

@@ -0,0 +1,388 @@
+package com.unis.alarm;
+
+import com.sun.jna.Native;
+import com.sun.jna.Pointer;
+import com.unis.common.osSelect;
+import com.unis.config.AddressModel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Scanner;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-08-01 14:24
+ */
+@Slf4j
+@Component
+@SuppressWarnings("all")
+public class Alarm implements ApplicationRunner {
+
+    static HCNetSDK hCNetSDK = null;
+    static int[] lUserID = new int[]{0, 0, 0, 0, 0};//用户句柄 实现对设备登录
+    static int[] lAlarmHandle = new int[]{-1, -1, -1, -1, -1};//报警布防句柄
+    static int[] lAlarmHandle_V50 = new int[]{-1, -1, -1, -1, -1}; //v50报警布防句柄
+    static int lListenHandle = -1;//报警监听句柄
+    static FMSGCallBack_V31 fMSFCallBack_V31 = null;
+    static FMSGCallBack fMSFCallBack = null;
+    // 设备连接信息
+    @Resource
+    private AddressModel addressModel;
+
+    private void mainMethod() {
+        if (hCNetSDK == null) {
+            if (!CreateSDKInstance()) {
+                log.info("Load SDK fail");
+                return;
+            }
+        }
+        //linux系统建议调用以下接口加载组件库
+        if (osSelect.isLinux()) {
+            HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
+            HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
+            //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
+            String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
+            String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
+
+            System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
+            ptrByteArray1.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
+
+            System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
+            ptrByteArray2.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
+
+            String strPathCom = System.getProperty("user.dir") + "/lib";
+            HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
+            System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
+            struComPath.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
+        }
+
+        /**初始化*/
+        hCNetSDK.NET_DVR_Init();
+        /**加载日志*/
+        hCNetSDK.NET_DVR_SetLogToFile(3, "../sdklog", false);
+        //设置报警回调函数
+        if (fMSFCallBack_V31 == null) {
+            fMSFCallBack_V31 = new FMSGCallBack_V31();
+            Pointer pUser = null;
+            if (!hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(fMSFCallBack_V31, pUser)) {
+                log.error("设置回调函数失败!");
+                return;
+            } else {
+                log.info("设置回调函数成功!");
+            }
+        }
+        /** 设备上传的报警信息是COMM_VCA_ALARM(0x4993)类型，
+         在SDK初始化之后增加调用NET_DVR_SetSDKLocalCfg(enumType为NET_DVR_LOCAL_CFG_TYPE_GENERAL)设置通用参数NET_DVR_LOCAL_GENERAL_CFG的byAlarmJsonPictureSeparate为1，
+         将Json数据和图片数据分离上传，这样设置之后，报警布防回调函数里面接收到的报警信息类型为COMM_ISAPI_ALARM(0x6009)，
+         报警信息结构体为NET_DVR_ALARM_ISAPI_INFO（与设备无关，SDK封装的数据结构），更便于解析。*/
+        HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG struNET_DVR_LOCAL_GENERAL_CFG = new HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG();
+        struNET_DVR_LOCAL_GENERAL_CFG.byAlarmJsonPictureSeparate = 1;   //设置JSON透传报警数据和图片分离
+        struNET_DVR_LOCAL_GENERAL_CFG.write();
+        Pointer pStrNET_DVR_LOCAL_GENERAL_CFG = struNET_DVR_LOCAL_GENERAL_CFG.getPointer();
+        hCNetSDK.NET_DVR_SetSDKLocalCfg(17, pStrNET_DVR_LOCAL_GENERAL_CFG);
+
+        String m_sDeviceIP = addressModel.getDeviceIP();//设备ip地址
+        short m_wPort = addressModel.getPort();//设备ip地址
+        String m_sUsername = addressModel.getUserName();//设备用户名
+        String m_sPassword = addressModel.getPassword();//设备密码
+        Alarm.Login_V40(0, m_sDeviceIP, (short) m_wPort, m_sUsername, m_sPassword);  //登录设备
+
+        Alarm.SetAlarm(0);//报警布防，和报警监听二选一即可
+
+        //  Alarm.StartListen("10.17.34.18",(short)8000);//报警监听，不需要登陆设备
+        while (true) {
+            //这里加入控制台输入控制，是为了保持连接状态，当输入Y表示布防结束
+            log.info("请选择是否撤出布防(Y/N): ");
+            Scanner input = new Scanner(System.in);
+            String str = input.next();
+            if (str.equals("Y")) {
+                break;
+            }
+        }
+        Alarm.Logout(0);
+        //释放SDK
+        hCNetSDK.NET_DVR_Cleanup();
+        return;
+    }
+
+    /**
+     * 设备登录V40 与V30功能一致
+     *
+     * @param i    登录设备编号
+     * @param ip   设备IP
+     * @param port SDK端口，默认设备的8000端口
+     * @param user 设备用户名
+     * @param psw  设备密码
+     */
+    public static void Login_V40(int i, String ip, short port, String user, String psw) {
+        //注册
+        HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
+        HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
+
+        String m_sDeviceIP = ip;//设备ip地址
+        m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
+        System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
+
+        String m_sUsername = user;//设备用户名
+        m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
+        System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
+
+        String m_sPassword = psw;//设备密码
+        m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
+        System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
+
+        m_strLoginInfo.wPort = port;
+        m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
+//        m_strLoginInfo.byLoginMode=1;  //ISAPI登录
+        m_strLoginInfo.write();
+
+        lUserID[i] = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
+        if (lUserID[i] == -1) {
+            log.error("登录失败，错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
+            return;
+        } else {
+            log.info("设备登录成功IP: {}", ip);
+            return;
+        }
+    }
+
+    /**
+     * 设备登录V30
+     *
+     * @param i    登录设备编号
+     * @param ip   设备IP
+     * @param port SDK端口，默认设备的8000端口
+     * @param user 设备用户名
+     * @param psw  设备密码
+     */
+    public static void Login_V30(int i, String ip, short port, String user, String psw) {
+        HCNetSDK.NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
+        lUserID[i] = hCNetSDK.NET_DVR_Login_V30(ip, port, user, psw, m_strDeviceInfo);
+        log.info("UsID: {}", lUserID[i]);
+        if ((lUserID[i] == -1) || (lUserID[i] == 0xFFFFFFFF)) {
+            log.error("登录失败，错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
+            return;
+        } else {
+            log.info("设备登录成功IP: {}", ip);
+            return;
+        }
+    }
+
+    /**
+     * 报警布防接口
+     *
+     * @param i
+     */
+    public static void SetAlarm(int i) {
+        if (lAlarmHandle[i] < 0) { //尚未布防,需要布防
+            //报警布防参数设置
+            HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();
+            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
+            m_strAlarmInfo.byLevel = 0;  //布防等级
+            m_strAlarmInfo.byAlarmInfoType = 1;   // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
+            m_strAlarmInfo.byDeployType = 0;   //布防类型：0-客户端布防，1-实时布防
+            m_strAlarmInfo.write();
+            lAlarmHandle[i] = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID[i], m_strAlarmInfo);
+            System.out.println("lAlarmHandle: " + lAlarmHandle[i]);
+            if (lAlarmHandle[i] == -1) {
+                log.error("布防失败，错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
+                return;
+            } else {
+                log.info("布防成功");
+            }
+        } else {
+            log.info("设备已经布防，请先撤防！");
+        }
+        return;
+    }
+
+    /**
+     * 报警布防V50接口，功能和V41一致
+     *
+     * @param i
+     */
+    public static void setAlarm_V50(int i) {
+        if (lAlarmHandle_V50[i] < 0) {//尚未布防,需要布防
+            //报警布防参数设置
+            HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50 m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50();
+            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
+            m_strAlarmInfo.byLevel = 1;  //布防等级
+            m_strAlarmInfo.byAlarmInfoType = 1;   // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
+            m_strAlarmInfo.byDeployType = 1;   //布防类型 0：客户端布防 1：实时布防
+            m_strAlarmInfo.write();
+            lAlarmHandle[i] = hCNetSDK.NET_DVR_SetupAlarmChan_V50(lUserID[i], m_strAlarmInfo, Pointer.NULL, 0);
+            log.info("lAlarmHandle: {}", lAlarmHandle[i]);
+            if (lAlarmHandle[i] == -1) {
+                log.error("布防失败，错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
+                return;
+            } else {
+                log.info("布防成功");
+            }
+        } else {
+            log.info("设备已经布防，请先撤防！");
+        }
+        return;
+
+    }
+
+    /**
+     * 开启监听
+     *
+     * @param ip   监听IP
+     * @param port 监听端口
+     */
+    public static void StartListen(String ip, short port) {
+        if (fMSFCallBack == null) {
+            fMSFCallBack = new FMSGCallBack();
+        }
+        lListenHandle = hCNetSDK.NET_DVR_StartListen_V30(ip, port, fMSFCallBack_V31, null);
+        if (lListenHandle == -1) {
+            log.error("监听失败: {}", hCNetSDK.NET_DVR_GetLastError());
+            return;
+        } else {
+            log.info("监听成功");
+        }
+    }
+
+    /**
+     * 设备注销
+     *
+     * @param i
+     */
+    public static void Logout(int i) {
+        if (lAlarmHandle[i] > -1) {
+            if (!hCNetSDK.NET_DVR_CloseAlarmChan(lAlarmHandle[i])) {
+                log.info("撤防成功");
+            }
+        }
+        if (lListenHandle > -1) {
+            if (!hCNetSDK.NET_DVR_StopListen_V30(lListenHandle)) {
+                log.info("停止监听成功");
+            }
+        }
+        if (hCNetSDK.NET_DVR_Logout(lUserID[i])) {
+            log.info("注销成功");
+        }
+        return;
+    }
+
+    /**
+     * 动态库加载
+     *
+     * @return
+     */
+    private static boolean CreateSDKInstance() {
+        if (hCNetSDK == null) {
+            synchronized (HCNetSDK.class) {
+                String strDllPath = "";
+                try {
+                    if (osSelect.isWindows())
+                        //win系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
+                    else if (osSelect.isLinux())
+                        //Linux系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "/lib/libhcnetsdk.so";
+                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
+                } catch (Exception ex) {
+                    log.error("loadLibrary: {}", strDllPath);
+                    log.error("Error: {}", ex.getMessage());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        // after behind for application run,because implements ApplicationRunner
+        this.mainMethod();
+    }
+
+    // ------------------------------------------------------
+
+    /**
+     * @param args
+     */
+    /*public static void main(String[] args) throws InterruptedException {
+
+        if (hCNetSDK == null) {
+            if (!CreateSDKInstance()) {
+                System.out.println("Load SDK fail");
+                return;
+            }
+        }
+        //linux系统建议调用以下接口加载组件库
+        if (osSelect.isLinux()) {
+            HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
+            HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
+            //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
+            String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
+            String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
+
+            System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
+            ptrByteArray1.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
+
+            System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
+            ptrByteArray2.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
+
+            String strPathCom = System.getProperty("user.dir") + "/lib";
+            HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
+            System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
+            struComPath.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
+        }
+
+        *//**初始化*//*
+        hCNetSDK.NET_DVR_Init();
+        *//**加载日志*//*
+        hCNetSDK.NET_DVR_SetLogToFile(3, "../sdklog", false);
+        //设置报警回调函数
+        if (fMSFCallBack_V31 == null) {
+            fMSFCallBack_V31 = new FMSGCallBack_V31();
+            Pointer pUser = null;
+            if (!hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(fMSFCallBack_V31, pUser)) {
+                System.out.println("设置回调函数失败!");
+                return;
+            } else {
+                System.out.println("设置回调函数成功!");
+            }
+        }
+        *//** 设备上传的报警信息是COMM_VCA_ALARM(0x4993)类型，
+     在SDK初始化之后增加调用NET_DVR_SetSDKLocalCfg(enumType为NET_DVR_LOCAL_CFG_TYPE_GENERAL)设置通用参数NET_DVR_LOCAL_GENERAL_CFG的byAlarmJsonPictureSeparate为1，
+     将Json数据和图片数据分离上传，这样设置之后，报警布防回调函数里面接收到的报警信息类型为COMM_ISAPI_ALARM(0x6009)，
+     报警信息结构体为NET_DVR_ALARM_ISAPI_INFO（与设备无关，SDK封装的数据结构），更便于解析。*//*
+        HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG struNET_DVR_LOCAL_GENERAL_CFG = new HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG();
+        struNET_DVR_LOCAL_GENERAL_CFG.byAlarmJsonPictureSeparate = 1;   //设置JSON透传报警数据和图片分离
+        struNET_DVR_LOCAL_GENERAL_CFG.write();
+        Pointer pStrNET_DVR_LOCAL_GENERAL_CFG = struNET_DVR_LOCAL_GENERAL_CFG.getPointer();
+        hCNetSDK.NET_DVR_SetSDKLocalCfg(17, pStrNET_DVR_LOCAL_GENERAL_CFG);
+        Alarm.Login_V40(0, "10.7.11.161", (short) 8000, "admin", "Aa870618");  //登录设备
+
+        Alarm.SetAlarm(0);//报警布防，和报警监听二选一即可
+
+        //  Alarm.StartListen("10.17.34.18",(short)8000);//报警监听，不需要登陆设备
+        while (true) {
+            //这里加入控制台输入控制，是为了保持连接状态，当输入Y表示布防结束
+            System.out.print("请选择是否撤出布防(Y/N)：");
+            Scanner input = new Scanner(System.in);
+            String str = input.next();
+            if (str.equals("Y")) {
+                break;
+            }
+        }
+        Alarm.Logout(0);
+        //释放SDK
+        hCNetSDK.NET_DVR_Cleanup();
+        return;
+    }*/
+}

src/main/java/com/unis/alarm/AlarmDataParse.java

@@ -0,0 +1,498 @@
+package com.unis.alarm;
+
+import com.sun.jna.Pointer;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.nio.ByteBuffer;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * @author qingsong.han
+ * @create 2024-08-01 9:24
+ */
+@Slf4j
+@SuppressWarnings("all")
+public class AlarmDataParse {
+
+    public static void alarmDataHandle(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        log.info("报警事件类型lCommand int: {}", lCommand);
+        log.info("报警事件类型lCommand int: {}", "0x" + lCommand);
+
+        /*String hexString = Integer.toHexString(lCommand);
+        log.info("报警事件类型lCommand Hex: {}", hexString);*/
+
+        String sTime;
+        String MonitoringSiteID;
+        String pic = System.getProperty("user.dir") + "/pic/";
+        log.info("pic: {}", pic);
+        //lCommand是传的报警类型
+        switch (lCommand) {
+            //行为分析信息
+            case HCNetSDK.COMM_ALARM_RULE:
+                HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
+                strVcaAlarm.write();
+                Pointer pVCAInfo = strVcaAlarm.getPointer();
+                pVCAInfo.write(0, pAlarmInfo.getByteArray(0, strVcaAlarm.size()), 0, strVcaAlarm.size());
+                strVcaAlarm.read();
+
+                switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
+                    case 1: //穿越警戒面 (越界侦测)
+                        System.out.println("越界侦测报警发生");
+                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_TRAVERSE_PLANE.class);
+                        System.out.println("检测目标：" + strVcaAlarm.struRuleInfo.uEventParam.struTraversePlane.byDetectionTarget); //检测目标，0表示所有目标（表示不锁定检测目标，所有目标都将进行检测），其他取值按位表示不同的检测目标：0x01-人，0x02-车
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = pic + newName + "VCA_TRAVERSE_PLANE" + ".jpg";
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                        break;
+                    case 2: //目标进入区域
+                        System.out.println("目标进入区域报警发生");
+                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
+                        System.out.println("检测目标：" + strVcaAlarm.struRuleInfo.uEventParam.struArea.byDetectionTarget);
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = "../pic/" + newName + "_TargetEnter" + ".jpg";
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                        break;
+                    case 3: //目标离开区域
+                        System.out.println("目标离开区域报警触发");
+                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
+                        System.out.println("检测目标：" + strVcaAlarm.struRuleInfo.uEventParam.struArea.byDetectionTarget);
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = "../pic/" + newName + "_TargetLeave" + ".jpg";
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                        break;
+                    case 4: //周界入侵
+                        System.out.println("周界入侵报警发生");
+                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class);
+                        System.out.println("检测目标：" + strVcaAlarm.struRuleInfo.uEventParam.struIntrusion.byDetectionTarget);
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = pic + newName + "VCA_INTRUSION" + ".jpg";
+                                log.info("filename: {}", filename);
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                        break;
+                    case 15: //离岗
+                        System.out.println("离岗事件触发");
+                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_LEAVE_POSITION.class);
+                        System.out.println(strVcaAlarm.struRuleInfo.uEventParam.struLeavePos.byOnPosition);
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = "../pic/" + newName + "VCA_LEAVE_POSITION_" + ".jpg";
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                    case 20: //倒地检测
+                        System.out.println("倒地事件触发");
+                        break;
+                    case 44: //玩手机
+
+                        System.out.println("玩手机报警发生");
+                        //图片保存
+                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
+                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                            String newName = sf.format(new Date());
+                            FileOutputStream fout;
+                            try {
+                                String filename = "../pic/" + newName + "PLAY_CELLPHONE_" + ".jpg";
+                                fout = new FileOutputStream(filename);
+                                //将字节写入文件
+                                long offset = 0;
+                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
+                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
+                                buffers.rewind();
+                                buffers.get(bytes);
+                                fout.write(bytes);
+                                fout.close();
+                            } catch (FileNotFoundException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                            }
+                        }
+                        break;
+                    case 45: //持续检测
+                        System.out.println("持续检测事件触发");
+                    default:
+                        System.out.println("行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
+                        break;
+                }
+                break;
+            case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT: //实时人脸抓拍上传
+                System.out.println("UPLOAD_FACESNAP_Alarm");
+                HCNetSDK.NET_VCA_FACESNAP_RESULT strFaceSnapInfo = new HCNetSDK.NET_VCA_FACESNAP_RESULT();
+                strFaceSnapInfo.write();
+                Pointer pFaceSnapInfo = strFaceSnapInfo.getPointer();
+                pFaceSnapInfo.write(0, pAlarmInfo.getByteArray(0, strFaceSnapInfo.size()), 0, strFaceSnapInfo.size());
+                strFaceSnapInfo.read();
+
+                //事件时间
+                int dwYear = (strFaceSnapInfo.dwAbsTime >> 26) + 2000;
+                int dwMonth = (strFaceSnapInfo.dwAbsTime >> 22) & 15;
+                int dwDay = (strFaceSnapInfo.dwAbsTime >> 17) & 31;
+                int dwHour = (strFaceSnapInfo.dwAbsTime >> 12) & 31;
+                int dwMinute = (strFaceSnapInfo.dwAbsTime >> 6) & 63;
+                int dwSecond = (strFaceSnapInfo.dwAbsTime >> 0) & 63;
+
+                String strAbsTime = "" + String.format("%04d", dwYear) +
+                        String.format("%02d", dwMonth) +
+                        String.format("%02d", dwDay) +
+                        String.format("%02d", dwHour) +
+                        String.format("%02d", dwMinute) +
+                        String.format("%02d", dwSecond);
+
+                //人脸属性信息
+                String sFaceAlarmInfo = "Abs时间:" + strAbsTime + ",年龄:" + strFaceSnapInfo.struFeature.byAge +
+                        ",性别：" + strFaceSnapInfo.struFeature.bySex + ",是否戴口罩：" +
+                        strFaceSnapInfo.struFeature.byMask + ",是否微笑：" + strFaceSnapInfo.struFeature.bySmile;
+                System.out.println("人脸信息：" + sFaceAlarmInfo);
+
+                //人脸测温信息
+                if (strFaceSnapInfo.byAddInfo == 1) {
+                    HCNetSDK.NET_VCA_FACESNAP_ADDINFO strAddInfo = new HCNetSDK.NET_VCA_FACESNAP_ADDINFO();
+                    strAddInfo.write();
+                    Pointer pAddInfo = strAddInfo.getPointer();
+                    pAddInfo.write(0, strFaceSnapInfo.pAddInfoBuffer.getByteArray(0, strAddInfo.size()), 0, strAddInfo.size());
+                    strAddInfo.read();
+
+                    String sTemperatureInfo = "测温是否开启：" + strAddInfo.byFaceSnapThermometryEnabled + "人脸温度：" + strAddInfo.fFaceTemperature + "温度是否异常"
+                            + strAddInfo.byIsAbnomalTemperature + "报警温度阈值：" + strAddInfo.fAlarmTemperature;
+                    System.out.println("人脸温度信息:" + sTemperatureInfo);
+
+                }
+
+                try {
+                    SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss");//设置日期格式
+                    String time = df.format(new Date());// new Date()为获取当前系统时间
+
+                    //人脸图片写文件
+                    FileOutputStream small = new FileOutputStream("../pic/" + time + "small.jpg");
+                    FileOutputStream big = new FileOutputStream("../pic/" + time + "big.jpg");
+                    try {
+                        small.write(strFaceSnapInfo.pBuffer1.getByteArray(0, strFaceSnapInfo.dwFacePicLen), 0, strFaceSnapInfo.dwFacePicLen);
+                        small.close();
+                    } catch (IOException ex) {
+                        ex.printStackTrace();
+                    }
+                    try {
+                        big.write(strFaceSnapInfo.pBuffer2.getByteArray(0, strFaceSnapInfo.dwBackgroundPicLen), 0, strFaceSnapInfo.dwBackgroundPicLen);
+                        big.close();
+                    } catch (IOException ex) {
+                        ex.printStackTrace();
+                    }
+
+                } catch (FileNotFoundException ex) {
+                    ex.printStackTrace();
+                }
+                break;
+            case HCNetSDK.COMM_ALARM_V30:  //移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
+                HCNetSDK.NET_DVR_ALARMINFO_V30 struAlarmInfo = new HCNetSDK.NET_DVR_ALARMINFO_V30();
+                struAlarmInfo.write();
+                Pointer pAlarmInfo_V30 = struAlarmInfo.getPointer();
+                pAlarmInfo_V30.write(0, pAlarmInfo.getByteArray(0, struAlarmInfo.size()), 0, struAlarmInfo.size());
+                struAlarmInfo.read();
+                System.out.println("报警类型：" + struAlarmInfo.dwAlarmType);  // 3-移动侦测
+                break;
+            case HCNetSDK.COMM_ALARM_V40: //移动侦测、视频丢失、遮挡、IO信号量等报警信息，报警数据为可变长
+                HCNetSDK.NET_DVR_ALARMINFO_V40 struAlarmInfoV40 = new HCNetSDK.NET_DVR_ALARMINFO_V40();
+                struAlarmInfoV40.write();
+                Pointer pAlarmInfoV40 = struAlarmInfoV40.getPointer();
+                pAlarmInfoV40.write(0, pAlarmInfo.getByteArray(0, struAlarmInfoV40.size()), 0, struAlarmInfoV40.size());
+                struAlarmInfoV40.read();
+                System.out.println("报警类型:" + struAlarmInfoV40.struAlarmFixedHeader.dwAlarmType); //3-移动侦测
+                break;
+            case HCNetSDK.COMM_THERMOMETRY_ALARM:  //温度报警信息
+                HCNetSDK.NET_DVR_THERMOMETRY_ALARM struTemInfo = new HCNetSDK.NET_DVR_THERMOMETRY_ALARM();
+                struTemInfo.write();
+                Pointer pTemInfo = struTemInfo.getPointer();
+                pTemInfo.write(0, pAlarmInfo.getByteArray(0, struTemInfo.size()), 0, struTemInfo.size());
+                struTemInfo.read();
+                String sThermAlarmInfo = "规则ID:" + struTemInfo.byRuleID + "预置点号：" + struTemInfo.wPresetNo + "报警等级：" + struTemInfo.byAlarmLevel + "报警类型：" +
+                        struTemInfo.byAlarmType + "当前温度：" + struTemInfo.fCurrTemperature;
+                System.out.println(sThermAlarmInfo);
+                //可见光图片保存
+                if ((struTemInfo.dwPicLen > 0) && (struTemInfo.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_" + struTemInfo.fCurrTemperature + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = struTemInfo.pPicBuff.getByteBuffer(offset, struTemInfo.dwPicLen);
+                        byte[] bytes = new byte[struTemInfo.dwPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+
+                if ((struTemInfo.dwThermalPicLen > 0) && (struTemInfo.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_" + "_ThermalPiC" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = struTemInfo.pThermalPicBuff.getByteBuffer(offset, struTemInfo.dwThermalPicLen);
+                        byte[] bytes = new byte[struTemInfo.dwThermalPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+
+                }
+                break;
+            case HCNetSDK.COMM_THERMOMETRY_DIFF_ALARM: //温差检测报警
+                HCNetSDK.NET_DVR_THERMOMETRY_DIFF_ALARM strThermDiffAlarm = new HCNetSDK.NET_DVR_THERMOMETRY_DIFF_ALARM();
+                strThermDiffAlarm.write();
+                Pointer pTemDiffInfo = strThermDiffAlarm.getPointer();
+                pTemDiffInfo.write(0, pAlarmInfo.getByteArray(0, strThermDiffAlarm.size()), 0, strThermDiffAlarm.size());
+                strThermDiffAlarm.read();
+                String sThremDiffInfo = "通道号：" + strThermDiffAlarm.dwChannel + ",报警规则：" + strThermDiffAlarm.byAlarmRule + "，当前温差：" + strThermDiffAlarm.fCurTemperatureDiff;
+                System.out.println(sThremDiffInfo);
+                //可见光图片保存
+                if ((strThermDiffAlarm.dwPicLen > 0) && (strThermDiffAlarm.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_" + strThermDiffAlarm.fCurTemperatureDiff + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strThermDiffAlarm.pPicBuff.getByteBuffer(offset, strThermDiffAlarm.dwPicLen);
+                        byte[] bytes = new byte[strThermDiffAlarm.dwPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                //热成像图片保存
+                if ((strThermDiffAlarm.dwThermalPicLen > 0) && (strThermDiffAlarm.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_" + "_ThermalDiffPiC" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strThermDiffAlarm.pThermalPicBuff.getByteBuffer(offset, strThermDiffAlarm.dwThermalPicLen);
+                        byte[] bytes = new byte[strThermDiffAlarm.dwThermalPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+
+                }
+                break;
+
+            case HCNetSDK.COMM_FIREDETECTION_ALARM://烟火检测
+                HCNetSDK.NET_DVR_FIREDETECTION_ALARM struFireDecAlarm = new HCNetSDK.NET_DVR_FIREDETECTION_ALARM();
+                struFireDecAlarm.write();
+                Pointer pFireDecAlarm = struFireDecAlarm.getPointer();
+                pFireDecAlarm.write(0, pAlarmInfo.getByteArray(0, struFireDecAlarm.size()), 0, struFireDecAlarm.size());
+                struFireDecAlarm.read();
+                String sFireDecAlarmInfo = "绝对时间：" + struFireDecAlarm.dwAbsTime + ",报警子类型：" + struFireDecAlarm.byAlarmSubType + ",火点最高温度 :" +
+                        struFireDecAlarm.wFireMaxTemperature + ",火点目标距离：" + struFireDecAlarm.wTargetDistance;
+                System.out.println(sFireDecAlarmInfo);
+                //可见光图片保存
+                if ((struFireDecAlarm.dwVisiblePicLen > 0) && (struFireDecAlarm.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_FireDecAlarm" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = struFireDecAlarm.pVisiblePicBuf.getByteBuffer(offset, struFireDecAlarm.dwVisiblePicLen);
+                        byte[] bytes = new byte[struFireDecAlarm.dwVisiblePicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                //热成像图片保存
+                if ((struFireDecAlarm.dwPicDataLen > 0) && (struFireDecAlarm.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+
+                    try {
+                        String filename = "../pic/" + newName + "_" + "_ThermalFireAlarm" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = struFireDecAlarm.pBuffer.getByteBuffer(offset, struFireDecAlarm.dwPicDataLen);
+                        byte[] bytes = new byte[struFireDecAlarm.dwPicDataLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+
+                }
+                break;
+            default:
+                log.info("default报警类型: {}", Integer.toHexString(lCommand));
+                break;
+        }
+    }
+}

src/main/java/com/unis/alarm/CommonUtil.java

@@ -0,0 +1,24 @@
+
+
+package com.unis.alarm;
+
+/**
+ * @author
+ * @create 2022-03-22-11:13
+ */
+public class CommonUtil {
+
+    //SDK时间解析
+    public static String parseTime(int time)
+    {
+        int year=(time>>26)+2000;
+        int month=(time>>22)&15;
+        int day=(time>>17)&31;
+        int hour=(time>>12)&31;
+        int min=(time>>6)&63;
+        int second=(time>>0)&63;
+        String sTime=year+"-"+month+"-"+day+"-"+hour+":"+min+":"+second;
+//        System.out.println(sTime);
+        return sTime;
+    }
+}

src/main/java/com/unis/alarm/FMSGCallBack.java

@@ -0,0 +1,16 @@
+package com.unis.alarm;
+
+import com.sun.jna.Pointer;
+
+
+/**
+ * @author jiangxin
+ * @create 2022-08-15-17:26
+ */
+public class FMSGCallBack implements HCNetSDK.FMSGCallBack {
+    //报警信息回调函数
+    public void invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        AlarmDataParse.alarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
+        return;
+    }
+}

src/main/java/com/unis/alarm/FMSGCallBack_V31.java

@@ -0,0 +1,20 @@
+
+package com.unis.alarm;
+
+import com.sun.jna.Pointer;
+
+
+public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
+    //报警信息回调函数
+    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        AlarmDataParse.alarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
+        return true;
+    }
+}
+
+
+
+
+
+
+

src/main/java/com/unis/common/NetDVRAlarmerConvert.java

@@ -24,7 +24,7 @@ public class NetDVRAlarmerConvert {
     private Byte byUserIDValid;
     private Byte byVersionValid;
     private Byte dwDeviceVersion;
-    private String lUserID;
+    private Integer lUserID;
     private Object pointer;
     private String sDeviceIP;
     private String sDeviceName;

src/main/java/com/unis/config/AddressModel.java

@@ -29,4 +29,8 @@ public class AddressModel {
     @Value("${exceptionAlarm.password}")
     private String password;
 
+    // 设备登录密码
+    @Value("${exceptionAlarm.port}")
+    private short port;
+
 }

src/main/java/com/unis/face/FMSGCallBack_V31.java

@@ -7,6 +7,7 @@ import com.unis.common.HCNetSDK;
 import com.unissoft.pushMsg.AlarmDSServiceImpl;*/
 import com.unis.common.NetDVRAlarmerConvert;
 import com.unis.utils.BinaryConversionUtil;
+import com.unis.video.VideoMok;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 
@@ -23,6 +24,8 @@ import java.util.Date;
 public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
     // this class call jna native callback,so is not spring manage class
     /*private AlarmDSService alarmDSService = new AlarmDSServiceImpl();*/
+    //相机一般只有一个通道号，热成像相机有2个通道号，通道号为1或1,2
+    static int iChannelNo = 1;
 
     //报警信息回调函数
     public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
@@ -59,6 +62,9 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
         convert.setSSocketIP(new String(pAlarmer.getSSocketIP()));
         log.info("convert: {}", convert);
 
+        // 抓图
+        VideoMok.RealPlay(convert.getLUserID(), iChannelNo);
+        VideoMok.getPicbyPlayCtrl();
 
         /*String hexString = Integer.toHexString(lCommand);
         log.info("报警类型 hexString {}", hexString);*/
@@ -69,7 +75,7 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
                 Pointer ruleAlarmPointer = ruleAlarm.getPointer();
                 ruleAlarmPointer.write(0, pAlarmInfo.getByteArray(0, ruleAlarm.size()), 0, ruleAlarm.size());
                 ruleAlarm.read();
-                log.info("alarm type in the NET_VCA_RULE_ALARM ---------->: {}", JSON.toJSONString(ruleAlarm));
+                log.info("Alarm type in the NET_VCA_RULE_ALARM ---------->: {}", JSON.toJSONString(ruleAlarm));
 //                alarmDSService.pushLCommand(lCommand);
                 break;
             case HCNetSDK.COMM_SNAP_MATCH_ALARM:
@@ -199,8 +205,8 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
                 break;
             default:
                 // TODO 单报警设备 目前不需要 sAlarmType alarmNow
-                log.info("alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
-                log.info("alarm type in the FMSGCallBack_V31 ->HEX: {}", BinaryConversionUtil.toHex(lCommand));
+                log.info("Alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
+                log.info("Alarm type in the FMSGCallBack_V31 ->HEX: {}", BinaryConversionUtil.toHex(lCommand));
 //                alarmDSService.pushLCommand(lCommand);
                 break;
         }

src/main/java/com/unis/face/FaceMain.java

@@ -21,7 +21,8 @@ import java.io.InputStreamReader;
  * @create 2024-07-31 9:29
  */
 @Slf4j
-@Component
+// 启动加载注解
+//@Component
 @Order(1)
 public class FaceMain implements ApplicationRunner {
 

src/main/java/com/unis/video/Clinet.java

@@ -0,0 +1,213 @@
+package com.unis.video;
+
+import com.sun.jna.Native;
+import com.sun.jna.Pointer;
+import com.unis.common.HCNetSDK;
+import com.unis.common.osSelect;
+
+import java.util.Timer;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-08-01 10:35
+ */
+public class Clinet {
+    int iErr = 0;
+    static HCNetSDK hCNetSDK = null;
+    static PlayCtrl playControl = null;
+    static int lUserID = 0;//用户句柄
+    static int lAlarmHandle = -1;//报警布防句柄
+    static int lListenHandle = -1;//报警监听句柄
+
+    static boolean bSaveHandle = false;
+    Timer Playbacktimer;//回放用定时器
+
+    static FExceptionCallBack_Imp fExceptionCallBack;
+    static int FlowHandle;
+
+    static class FExceptionCallBack_Imp implements HCNetSDK.FExceptionCallBack {
+        public void invoke(int dwType, int lUserID, int lHandle, Pointer pUser) {
+            System.out.println("异常事件类型:" + dwType);
+            return;
+        }
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+
+        if (hCNetSDK == null && playControl == null) {
+            if (!CreateSDKInstance()) {
+                System.out.println("Load SDK fail");
+                return;
+            }
+            if (!CreatePlayInstance()) {
+                System.out.println("Load PlayCtrl fail");
+                return;
+            }
+        }
+        //linux系统建议调用以下接口加载组件库
+        if (osSelect.isLinux()) {
+            HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
+            HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
+            //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
+            /*String strPath1 = "/home/hik/LinuxSDK/libcrypto.so.1.1";
+            String strPath2 = "/home/hik/LinuxSDK/libssl.so.1.1";*/
+            String strPath1 = System.getProperty("user.dir") + "\\lib\\libcrypto.so.1.1";
+            String strPath2 = System.getProperty("user.dir") + "\\lib\\libssl.so.1.1";
+
+            System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
+            ptrByteArray1.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
+
+            System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
+            ptrByteArray2.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
+
+            String strPathCom = System.getProperty("user.dir") + "\\lib\\";
+            HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
+            System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
+            struComPath.write();
+            hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
+        }
+
+        //SDK初始化，一个程序只需要调用一次
+        boolean initSuc = hCNetSDK.NET_DVR_Init();
+
+        if (initSuc != true) {
+            System.out.println("初始化失败");
+        }
+
+        //异常消息回调
+        if (fExceptionCallBack == null) {
+            fExceptionCallBack = new FExceptionCallBack_Imp();
+        }
+
+        Pointer pUser = null;
+        if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, pUser)) {
+            return;
+        }
+        System.out.println("设置异常消息回调成功");
+
+        //启动SDK写日志
+        hCNetSDK.NET_DVR_SetLogToFile(3, "..\\sdkLog\\", false);
+
+        //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
+        HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
+        HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
+
+        String m_sDeviceIP = "10.7.11.161";//设备ip地址
+        m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
+        System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
+
+        String m_sUsername = "admin";//设备用户名
+        m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
+        System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
+
+        String m_sPassword = "Aa870618";//设备密码
+        m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
+        System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
+
+        m_strLoginInfo.wPort = 8000; //SDK端口
+        m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
+        m_strLoginInfo.write();
+
+        lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
+        if (lUserID == -1) {
+            System.out.println("登录失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+        } else {
+            System.out.println(m_sDeviceIP + ":设备登录成功! " + "设备序列号:" + new String(m_strDeviceInfo.struDeviceV30.sSerialNumber).trim());
+            m_strDeviceInfo.read();
+        }
+        //相机一般只有一个通道号，热成像相机有2个通道号，通道号为1或1,2
+        int lDChannel = 1;
+        //byStartDChan为IP通道起始通道号, 预览回放NVR的IP通道时需要根据起始通道号进行取值
+        if ((int) m_strDeviceInfo.struDeviceV30.byStartDChan == 1 && (int) m_strDeviceInfo.struDeviceV30.byStartDChan == 33) {
+            //byStartDChan为IP通道起始通道号, 预览回放NVR的IP通道时需要根据起始通道号进行取值,NVR起始通道号一般是33或者1开始
+            lDChannel = (int) m_strDeviceInfo.struDeviceV30.byStartDChan;
+        }
+        System.out.println("预览通道号: " + lDChannel);
+
+        //注释掉的代码也可以参考，去掉注释可以运行
+        //VideoDemo.getIPChannelInfo(lUserID); //获取IP通道
+
+//        VideoDemo.RealPlay(lUserID,lDChannel);
+
+        //按时间回放和下载
+        new VideoMok().PlayBackBytime(lUserID);
+//        new VideoDemo().DowmloadRecordByTime(lUserID); //按时间下载录像
+        //按时间回放和下载录像，需要等待回放和下载完成后调用注销和释放接口
+/*        while (true)
+        {
+
+        }*/
+
+        //按录像文件回放和下载
+//        VideoDemo.DownloadRecordByFile(lUserID, 1);//录像文件查找下载
+//        VideoDemo.playBackByfile(lUserID);
+        Thread.sleep(3000);
+
+        //退出程序时调用，每一台设备分别注销
+        if (hCNetSDK.NET_DVR_Logout(lUserID)) {
+            System.out.println("注销成功");
+        }
+
+        //SDK反初始化，释放资源，只需要退出时调用一次
+        hCNetSDK.NET_DVR_Cleanup();
+        return;
+
+    }
+
+    /**
+     * 动态库加载
+     *
+     * @return
+     */
+    private static boolean CreateSDKInstance() {
+        if (hCNetSDK == null) {
+            synchronized (HCNetSDK.class) {
+                String strDllPath = "";
+                try {
+                    if (osSelect.isWindows())
+                        //win系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
+
+                    else if (osSelect.isLinux())
+                        //Linux系统加载库路径
+                        strDllPath = "/home/hik/LinuxSDK/libhcnetsdk.so";
+                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
+                } catch (Exception ex) {
+                    System.out.println("loadLibrary: " + strDllPath + " Error: " + ex.getMessage());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 播放库加载
+     *
+     * @return
+     */
+    private static boolean CreatePlayInstance() {
+        if (playControl == null) {
+            synchronized (PlayCtrl.class) {
+                String strPlayPath = "";
+                try {
+                    if (osSelect.isWindows())
+                        //win系统加载库路径
+                        strPlayPath = System.getProperty("user.dir") + "\\lib\\PlayCtrl.dll";
+                    else if (osSelect.isLinux())
+                        //Linux系统加载库路径
+                        strPlayPath = "/home/hik/LinuxSDK/libPlayCtrl.so";
+                    playControl = (PlayCtrl) Native.loadLibrary(strPlayPath, PlayCtrl.class);
+
+                } catch (Exception ex) {
+                    System.out.println("loadLibrary: " + strPlayPath + " Error: " + ex.getMessage());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+}

src/main/java/com/unis/video/PlayCtrl.java

@@ -0,0 +1,59 @@
+package com.unis.video;
+
+import com.sun.jna.Callback;
+import com.sun.jna.Library;
+import com.sun.jna.Pointer;
+import com.sun.jna.Structure;
+import com.sun.jna.examples.win32.W32API;
+import com.sun.jna.ptr.ByteByReference;
+import com.sun.jna.ptr.IntByReference;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-08-01 10:44
+ */
+//播放库函数声明,PlayCtrl.dll
+public interface PlayCtrl extends Library {
+
+    public static final int STREAME_REALTIME = 0;
+    public static final int STREAME_FILE = 1;
+
+    boolean PlayM4_GetPort(IntByReference nPort);
+
+    boolean PlayM4_OpenStream(int nPort, ByteByReference pFileHeadBuf, int nSize, int nBufPoolSize);
+
+    boolean PlayM4_InputData(int nPort, ByteByReference pBuf, int nSize);
+
+    boolean PlayM4_CloseStream(int nPort);
+
+    boolean PlayM4_SetStreamOpenMode(int nPort, int nMode);
+
+    boolean PlayM4_Play(int nPort, W32API.HWND hWnd);
+
+    boolean PlayM4_Stop(int nPort);
+
+    boolean PlayM4_SetSecretKey(int nPort, int lKeyType, String pSecretKey, int lKeyLen);
+
+    boolean PlayM4_GetPictureSize(int nPort, IntByReference pWidth, IntByReference pHeight);
+
+    boolean PlayM4_GetJPEG(int nPort, Pointer pBitmap, int nBufSize, IntByReference pBmpSize);
+
+    int PlayM4_GetLastError(int nPort);
+
+    boolean PlayM4_SetDecCallBackExMend(int nPort, DecCallBack decCBFun, Pointer pDest, int nDestSize, int nUser);
+
+    public static interface DecCallBack extends Callback {
+        void invoke(int nPort, Pointer pBuf, int nSize, FRAME_INFO pFrameInfo, int nReserved1, int nReserved2);
+    }
+
+    public class FRAME_INFO extends Structure {
+        public int nWidth;                   /* 画面宽，单位像素。如果是音频数据，则为音频声道数 */
+        public int nHeight;                     /* 画面高，单位像素。如果是音频数据，则为样位率 */
+        public int nStamp;                           /* 时标信息，单位毫秒 */
+        public int nType;                            /* 数据类型，T_AUDIO16, T_RGB32, T_YV12 */
+        public int nFrameRate;                /* 编码时产生的图像帧率，如果是音频数据则为采样率 */
+        public int dwFrameNum;                      /* 帧号 */
+    }
+
+}

src/main/java/com/unis/video/VideoMok.java

@@ -0,0 +1,716 @@
+package com.unis.video;
+
+import com.sun.jna.Pointer;
+import com.sun.jna.ptr.ByteByReference;
+import com.sun.jna.ptr.IntByReference;
+import com.unis.common.HCNetSDK;
+
+import java.io.*;
+import java.nio.ByteBuffer;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Timer;
+
+import static com.unis.video.Clinet.hCNetSDK;
+import static com.unis.video.Clinet.playControl;
+
+/**
+ * @author qingsong.han
+ * @description: 视频取流预览，下载，抓图mok
+ * @create 2024-08-01 10:30
+ */
+public class VideoMok {
+    Timer Downloadtimer;//下载用定时器
+    Timer Playbacktimer;//回放用定时器
+    static FRealDataCallBack fRealDataCallBack;//预览回调函数实现
+    static fPlayEScallback fPlayescallback; //裸码流回调函数
+    static playDataCallBack playBackCallBack; //回放码流回调
+    static int lPlay = -1;  //预览句柄
+    int m_lLoadHandle;
+    int iPlayBack; //回放句柄
+    static File file;
+    static FileOutputStream outputStream;
+    static IntByReference m_lPort = new IntByReference(-1);
+    static String resultFileName = "..\\Download" + new String("returnFile" + ".h264");
+    static FileOutputStream fileOutputStream = null;
+    static int fileLenth = 0;
+
+    public static void RealPlay(int userID, int iChannelNo) {
+        if (userID == -1) {
+            System.out.println("请先注册");
+            return;
+        }
+        HCNetSDK.NET_DVR_PREVIEWINFO strClientInfo = new HCNetSDK.NET_DVR_PREVIEWINFO();
+        strClientInfo.read();
+        strClientInfo.hPlayWnd = 0;  //窗口句柄，从回调取流不显示一般设置为空
+        strClientInfo.lChannel = iChannelNo;  //通道号
+        strClientInfo.dwStreamType = 0; //0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
+        strClientInfo.dwLinkMode = 0; //连接方式：0- TCP方式，1- UDP方式，2- 多播方式，3- RTP方式，4- RTP/RTSP，5- RTP/HTTP，6- HRUDP（可靠传输） ，7- RTSP/HTTPS，8- NPQ
+        strClientInfo.bBlocked = 1;
+        strClientInfo.write();
+
+        //回调函数定义必须是全局的
+        if (fRealDataCallBack == null) {
+            fRealDataCallBack = new FRealDataCallBack();
+        }
+
+        //开启预览
+        lPlay = hCNetSDK.NET_DVR_RealPlay_V40(userID, strClientInfo, fRealDataCallBack, null);
+        if (lPlay == -1) {
+            int iErr = hCNetSDK.NET_DVR_GetLastError();
+            System.out.println("取流失败" + iErr);
+            return;
+        }
+        System.out.println("取流成功");
+
+        //设置裸码流回调函数
+//        if (fPlayescallback==null)
+//        {
+//            fPlayescallback=new fPlayEScallback();
+//        }
+//        boolean setcallback=hCNetSDK.NET_DVR_SetESRealPlayCallBack(lPlay,fPlayescallback,null);
+//        if (setcallback==false)
+//        {
+//            System.out.println("设置裸码流回调失败，错误码："+hCNetSDK.NET_DVR_GetLastError());
+//        }
+
+//        try {
+//            Thread.sleep(3000);
+//        } catch (InterruptedException e) {
+//            e.printStackTrace();
+//        }
+
+        //取流解码过程中播放库从解码码流中抓图
+//        getPicbyPlayCtrl();
+
+        /**
+         * 预览一段时间；如果要一直取流预览，需要保证程序一直运行
+         */
+        try {
+            Thread.sleep(30000);
+        } catch (InterruptedException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+
+        if (lPlay >= 0) {
+            if (hCNetSDK.NET_DVR_StopRealPlay(lPlay)) {
+                System.out.println("停止预览成功");
+                return;
+            }
+        }
+    }
+
+    //播放库抓图
+    public static void getPicbyPlayCtrl() {
+
+        IntByReference pWidth = new IntByReference(0);
+        IntByReference pHieght = new IntByReference(0);
+        boolean bFlag = playControl.PlayM4_GetPictureSize(m_lPort.getValue(), pWidth, pHieght);
+        if (!bFlag) {
+            System.out.println("获取失败：" + playControl.PlayM4_GetLastError(m_lPort.getValue()));
+        }
+        System.out.println(pWidth.getValue());
+        System.out.println(pHieght.getValue());
+        IntByReference RealPicSize = new IntByReference(0);
+        int picsize = pWidth.getValue() * pHieght.getValue() * 5;
+        HCNetSDK.BYTE_ARRAY picByte = new HCNetSDK.BYTE_ARRAY(picsize);
+        picByte.write();
+        Pointer pByte = picByte.getPointer();
+        boolean b_GetPic = playControl.PlayM4_GetJPEG(m_lPort.getValue(), pByte, picsize, RealPicSize);
+        if (!b_GetPic) {
+            System.out.println("抓图失败：" + playControl.PlayM4_GetLastError(m_lPort.getValue()));
+        }
+        picByte.read();
+        SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+        String newName = sf.format(new Date());
+        FileOutputStream fout = null;
+        try {
+
+            fout = new FileOutputStream(System.getProperty("user.dir") + "//pic//" + newName + ".jpg");
+            //将字节写入文件
+            long offset = 0;
+            ByteBuffer buffers = pByte.getByteBuffer(offset, RealPicSize.getValue());
+            byte[] bytes = new byte[RealPicSize.getValue()];
+            buffers.rewind();
+            buffers.get(bytes);
+            fout.write(bytes);
+            fout.close();
+        } catch (FileNotFoundException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        } catch (IOException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        System.out.println("抓图成功!");
+
+    }
+
+
+    /**
+     * 按时间回放获取码流数据
+     *
+     * @param userID
+     */
+
+    public void PlayBackBytime(int userID) {
+        file = new File(System.getProperty("user.dir") + "\\Download\\Videodatabytime.mp4");  //保存回调函数的音频数据
+
+        if (!file.exists()) {
+            try {
+                file.createNewFile();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        try {
+            outputStream = new FileOutputStream(file);
+        } catch (FileNotFoundException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        HCNetSDK.NET_DVR_VOD_PARA net_dvr_vod_para = new HCNetSDK.NET_DVR_VOD_PARA();
+        net_dvr_vod_para.dwSize = net_dvr_vod_para.size();
+        net_dvr_vod_para.struIDInfo.dwChannel = 1; //通道号
+        net_dvr_vod_para.struBeginTime.dwYear = 2024;
+        net_dvr_vod_para.struBeginTime.dwMonth = 8;
+        net_dvr_vod_para.struBeginTime.dwDay = 1;
+        net_dvr_vod_para.struBeginTime.dwHour = 14;
+        net_dvr_vod_para.struBeginTime.dwMinute = 00;
+        net_dvr_vod_para.struBeginTime.dwSecond = 00;
+        //停止时间
+        net_dvr_vod_para.struEndTime.dwYear = 2024;
+        net_dvr_vod_para.struEndTime.dwMonth = 8;
+        net_dvr_vod_para.struEndTime.dwDay = 1;
+        net_dvr_vod_para.struEndTime.dwHour = 14;
+        net_dvr_vod_para.struEndTime.dwMinute = 05;
+        net_dvr_vod_para.struEndTime.dwSecond = 00;
+        net_dvr_vod_para.hWnd = null; // 回放的窗口句柄，若置为空，SDK仍能收到码流数据，但不解码显示
+        net_dvr_vod_para.write();
+
+        int iPlayBack = hCNetSDK.NET_DVR_PlayBackByTime_V40(userID, net_dvr_vod_para);
+        if (iPlayBack <= -1) {
+            System.out.println("按时间回放失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+
+        //开启取流
+        boolean bCrtl = hCNetSDK.NET_DVR_PlayBackControl(iPlayBack, HCNetSDK.NET_DVR_PLAYSTART, 0, null);
+        if (playBackCallBack == null) {
+            playBackCallBack = new playDataCallBack();
+        }
+        boolean bRet = hCNetSDK.NET_DVR_SetPlayDataCallBack_V40(iPlayBack, playBackCallBack, Pointer.NULL);
+        //开始计时器
+        Playbacktimer = new Timer();//新建定时器
+        Playbacktimer.schedule(new PlaybackTask(), 0, 5000);//0秒后开始响应函数
+        return;
+    }
+
+
+    public static void playBackByfile(int userID) {
+        file = new File(System.getProperty("user.dir") + "\\Download\\Videodatabyfile.mp4");  //保存回调函数的音频数据
+
+        if (!file.exists()) {
+            try {
+                file.createNewFile();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        try {
+            outputStream = new FileOutputStream(file);
+        } catch (FileNotFoundException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        String strFileName = "";
+        HCNetSDK.NET_DVR_FILECOND_V40 struFileCond = new HCNetSDK.NET_DVR_FILECOND_V40();
+        struFileCond.read();
+        struFileCond.lChannel = 1; //通道号 NVR设备路数小于32路的起始通道号从33开始，依次增加
+        struFileCond.byFindType = 0;  //录象文件类型 0=定时录像
+        //起始时间
+        struFileCond.struStartTime.dwYear = 2022;
+        struFileCond.struStartTime.dwMonth = 4;
+        struFileCond.struStartTime.dwDay = 17;
+        struFileCond.struStartTime.dwHour = 10;
+        struFileCond.struStartTime.dwMinute = 00;
+        struFileCond.struStartTime.dwSecond = 00;
+        //停止时间
+        struFileCond.struStopTime.dwYear = 2022;
+        struFileCond.struStopTime.dwMonth = 4;
+        struFileCond.struStopTime.dwDay = 17;
+        struFileCond.struStopTime.dwHour = 10;
+        struFileCond.struStopTime.dwMinute = 10;
+        struFileCond.struStopTime.dwSecond = 0;
+        struFileCond.write();
+        int FindFileHandle = hCNetSDK.NET_DVR_FindFile_V40(userID, struFileCond);
+        if (FindFileHandle <= -1) {
+            System.out.println("查找建立失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+        }
+
+        while (true) {
+            HCNetSDK.NET_DVR_FINDDATA_V40 struFindData = new HCNetSDK.NET_DVR_FINDDATA_V40();
+
+            long State = hCNetSDK.NET_DVR_FindNextFile_V40(FindFileHandle, struFindData);
+            if (State <= -1) {
+
+                System.out.println("查找失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+                return;
+
+            } else if (State == 1000)  //获取文件信息成功
+            {
+                struFindData.read();
+                try {
+                    strFileName = new String(struFindData.sFileName, "UTF-8").trim();
+                    System.out.println("文件名称：" + strFileName);
+                    System.out.println("文件大小:" + struFindData.dwFileSize);
+                } catch (UnsupportedEncodingException e) {
+                    e.printStackTrace();
+                }
+                System.out.println("获取文件成功");
+                break;
+
+            } else if (State == 1001) //未查找到文件
+            {
+                System.out.println("未查找到文件");
+                break;
+
+            } else if (State == 1002) //正在查找请等待
+            {
+                System.out.println("正在查找，请等待");
+                continue;
+
+            } else if (State == 1003) //没有更多的文件，查找结束
+            {
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            } else if (State == 1004) //查找文件时异常
+            {
+
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            } else if (State == 1005) //查找文件超时
+            {
+
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            }
+
+        }
+        boolean b_CloseHandle = hCNetSDK.NET_DVR_FindClose_V30(FindFileHandle);
+        if (!b_CloseHandle) {
+            System.out.println("关闭失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+
+        int lPlayByFileHandle = hCNetSDK.NET_DVR_PlayBackByName(userID, strFileName, null);
+        if (lPlayByFileHandle <= -1) {
+            System.out.println("按文件回放失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+        IntByReference intP1 = new IntByReference(0);
+        IntByReference intInlen = new IntByReference(0);
+        boolean b_PlayBackStart = hCNetSDK.NET_DVR_PlayBackControl_V40(lPlayByFileHandle, HCNetSDK.NET_DVR_PLAYSTART, intP1.getPointer(), 4, Pointer.NULL, intInlen);
+        if (!b_PlayBackStart) {
+            System.out.println("开始播放失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+        if (playBackCallBack == null) {
+            playBackCallBack = new playDataCallBack();
+        }
+        boolean bRet = hCNetSDK.NET_DVR_SetPlayDataCallBack_V40(lPlayByFileHandle, playBackCallBack, Pointer.NULL);
+        while (true) {
+            int Pos = hCNetSDK.NET_DVR_GetDownloadPos(lPlayByFileHandle);
+            if (Pos != 100) {
+                System.out.println("回放进度:" + Pos);
+
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                continue;
+            } else {
+                break;
+            }
+        }
+        boolean b_Stop = hCNetSDK.NET_DVR_StopPlayBack(lPlayByFileHandle);
+        if (!b_Stop) {
+            System.out.println("停止回放失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+        System.out.println("回放成功");
+        return;
+
+
+    }
+
+
+    //按文件下载录像(设置转成3GP格式)
+    public static void DownloadRecordByFile(int userID, int iChannelNo) {
+        String strFileName = "";
+        HCNetSDK.NET_DVR_FILECOND_V40 struFileCond = new HCNetSDK.NET_DVR_FILECOND_V40();
+        struFileCond.read();
+        struFileCond.lChannel = 1; //通道号 NVR设备路数小于32路的起始通道号从33开始，依次增加
+        struFileCond.dwFileType = 0Xff;
+        struFileCond.byFindType = 0;
+        //起始时间
+        struFileCond.struStartTime.dwYear = 2022;
+        struFileCond.struStartTime.dwMonth = 7;
+        struFileCond.struStartTime.dwDay = 5;
+        struFileCond.struStartTime.dwHour = 12;
+        struFileCond.struStartTime.dwMinute = 00;
+        struFileCond.struStartTime.dwSecond = 00;
+        //停止时间
+        struFileCond.struStopTime.dwYear = 2022;
+        struFileCond.struStopTime.dwMonth = 7;
+        struFileCond.struStopTime.dwDay = 5;
+        struFileCond.struStopTime.dwHour = 12;
+        struFileCond.struStopTime.dwMinute = 10;
+        struFileCond.struStopTime.dwSecond = 00;
+        struFileCond.write();
+        int FindFileHandle = hCNetSDK.NET_DVR_FindFile_V40(userID, struFileCond);
+        if (FindFileHandle <= -1) {
+            System.out.println("查找建立失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+        }
+
+        while (true) {
+            HCNetSDK.NET_DVR_FINDDATA_V40 struFindData = new HCNetSDK.NET_DVR_FINDDATA_V40();
+
+            long State = hCNetSDK.NET_DVR_FindNextFile_V40(FindFileHandle, struFindData);
+            if (State <= -1) {
+
+                System.out.println("查找失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+                return;
+
+            } else if (State == 1000)  //获取文件信息成功
+            {
+                struFindData.read();
+                try {
+                    strFileName = new String(struFindData.sFileName, "UTF-8").trim();
+                    System.out.println("文件名称：" + strFileName);
+                    System.out.println("文件大小:" + struFindData.dwFileSize);
+                } catch (UnsupportedEncodingException e) {
+                    e.printStackTrace();
+                }
+                System.out.println("获取文件成功");
+                break;
+
+            } else if (State == 1001) //未查找到文件
+            {
+                System.out.println("未查找到文件");
+                break;
+
+            } else if (State == 1002) //正在查找请等待
+            {
+                System.out.println("正在查找，请等待");
+                continue;
+
+            } else if (State == 1003) //没有更多的文件，查找结束
+            {
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            } else if (State == 1004) //查找文件时异常
+            {
+
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            } else if (State == 1005) //查找文件超时
+            {
+
+                System.out.println("没有更多的文件，查找结束");
+                break;
+
+            }
+
+        }
+        boolean b_CloseHandle = hCNetSDK.NET_DVR_FindClose_V30(FindFileHandle);
+        if (!b_CloseHandle) {
+            System.out.println("关闭失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+
+        //按文件下载录像
+        String SaveDir = ".\\Download\\test.mp4";
+
+        int FileName = hCNetSDK.NET_DVR_GetFileByName(userID, strFileName, SaveDir.getBytes());
+        if (FileName <= -1) {
+            System.out.println("下载录像失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+        //转码3GP命令
+        IntByReference intP = new IntByReference(5);
+        IntByReference intInlen1 = new IntByReference(0);
+        boolean b_PlayBack = hCNetSDK.NET_DVR_PlayBackControl_V40(FileName, 32, intP.getPointer(), 4, Pointer.NULL, intInlen1);
+        if (!b_PlayBack) {
+            System.out.println("转封装失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+
+        IntByReference intP1 = new IntByReference(0);
+        IntByReference intInlen = new IntByReference(0);
+        boolean b_PlayBackStart = hCNetSDK.NET_DVR_PlayBackControl_V40(FileName, HCNetSDK.NET_DVR_PLAYSTART, intP1.getPointer(), 4, Pointer.NULL, intInlen);
+        if (!b_PlayBackStart) {
+            System.out.println("开始播放失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+
+/*        IntByReference intP=new IntByReference(30*1024);
+        IntByReference intInlen1=new IntByReference(0);
+        boolean b_PlayBack=hCNetSDK.NET_DVR_PlayBackControl_V40(FileName,24,intP.getPointer(),4, Pointer.NULL,intInlen1);
+        if (!b_PlayBack) {
+            System.out.println("设置下载速度失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }*/
+        while (true) {
+            int Pos = hCNetSDK.NET_DVR_GetDownloadPos(FileName);
+            if (Pos != 100) {
+                System.out.println("下载进度:" + Pos);
+
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                continue;
+            } else {
+                break;
+            }
+        }
+        boolean b_Stop = hCNetSDK.NET_DVR_StopGetFile(FileName);
+        if (!b_Stop) {
+            System.out.println("停止下载失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+        System.out.println("下载成功");
+        return;
+    }
+
+    //按时间下载录像(不支持转码3GP格式)
+    public void DowmloadRecordByTime(int userID) {
+        HCNetSDK.NET_DVR_PLAYCOND net_dvr_playcond = new HCNetSDK.NET_DVR_PLAYCOND();
+        net_dvr_playcond.read();
+        net_dvr_playcond.dwChannel = 1; //通道号 NVR设备路数小于32路的起始通道号从33开始，依次增加
+        //开始时间
+        net_dvr_playcond.struStartTime.dwYear = 2022;
+        net_dvr_playcond.struStartTime.dwMonth = 4;
+        net_dvr_playcond.struStartTime.dwDay = 17;
+        net_dvr_playcond.struStartTime.dwHour = 10;
+        net_dvr_playcond.struStartTime.dwMinute = 00;
+        net_dvr_playcond.struStartTime.dwSecond = 00;
+        //停止时间
+        net_dvr_playcond.struStopTime.dwYear = 2022;
+        net_dvr_playcond.struStopTime.dwMonth = 4;
+        net_dvr_playcond.struStopTime.dwDay = 17;
+        net_dvr_playcond.struStopTime.dwHour = 10;
+        net_dvr_playcond.struStopTime.dwMinute = 10;
+        net_dvr_playcond.struStopTime.dwSecond = 00;
+        net_dvr_playcond.write();
+        String sFileName = ".\\Download\\" + System.currentTimeMillis() + ".mp4";
+        System.out.println(sFileName);
+        m_lLoadHandle = hCNetSDK.NET_DVR_GetFileByTime_V40(userID, sFileName, net_dvr_playcond);
+        if (m_lLoadHandle >= 0) {
+            hCNetSDK.NET_DVR_PlayBackControl(m_lLoadHandle, HCNetSDK.NET_DVR_PLAYSTART, 0, null);
+/*            IntByReference intP=new IntByReference(5*8*1024);
+            IntByReference intInlen=new IntByReference(0);
+            boolean b_PlayBack=ClientDemo.hCNetSDK.NET_DVR_PlayBackControl_V40(m_lLoadHandle,24,intP.getPointer(),4,Pointer.NULL,intInlen);
+            if (!b_PlayBack) {
+                System.out.println("设置下载速度失败，错误码为" + ClientDemo.hCNetSDK.NET_DVR_GetLastError());
+                return;
+            }*/
+            Date nowTime = new Date(System.currentTimeMillis());
+            SimpleDateFormat sdFormatter = new SimpleDateFormat("yyyy-MM-dd-hh-mm-ss");
+            System.out.println("开始下载时间：" + sdFormatter.format(nowTime));
+            Downloadtimer = new Timer();//新建定时器
+            Downloadtimer.schedule(new DownloadTask(), 0, 5000);//0秒后开始响应函数
+        } else {
+            System.out.println("按时间下载失败");
+            System.out.println("laste error " + hCNetSDK.NET_DVR_GetLastError());
+            return;
+        }
+    }
+
+    /*************************************************
+     类:      DownloadTask
+     类描述:  下载定时器响应函数
+     *************************************************/
+    class DownloadTask extends java.util.TimerTask {
+        //定时器函数
+        @Override
+        public void run() {
+            IntByReference nPos = new IntByReference(0);
+            hCNetSDK.NET_DVR_PlayBackControl(m_lLoadHandle, HCNetSDK.NET_DVR_PLAYGETPOS, 0, nPos);
+            if (nPos.getValue() > 100) {
+                m_lLoadHandle = -1;
+                Downloadtimer.cancel();
+                System.out.println("由于网络原因或DVR忙,下载异常终止!");
+            }
+            if (nPos.getValue() == 100) {
+                Date nowTime = new Date(System.currentTimeMillis());
+                SimpleDateFormat sdFormatter = new SimpleDateFormat("yyyy-MM-dd-hh-mm-ss");
+                System.out.println("结束下载时间：" + sdFormatter.format(nowTime));
+                m_lLoadHandle = -1;
+                Downloadtimer.cancel();
+                System.out.println("按时间下载结束!");
+            }
+        }
+    }
+
+
+    class PlaybackTask extends java.util.TimerTask {
+        //定时器函数
+        @Override
+        public void run() {
+            System.out.println("定时器触发");
+            IntByReference nPos = new IntByReference(0);
+            System.out.println("ceshi");
+
+            System.out.println("iPlayBack" + iPlayBack);
+            boolean bret = hCNetSDK.NET_DVR_PlayBackControl(iPlayBack, HCNetSDK.NET_DVR_PLAYGETPOS, 0, nPos);
+            if (bret) {
+                System.out.println("回放进度" + nPos.getValue());
+            } else {
+                System.out.println("获取回放进度失败");
+            }
+
+            if (nPos.getValue() > 100) {
+
+                hCNetSDK.NET_DVR_StopPlayBack(iPlayBack);
+                if (outputStream != null) {
+                    try {
+                        outputStream.close();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                System.out.println("由于网络原因或DVR忙,回放异常终止!");
+            }
+            if (nPos.getValue() == 100) {
+                hCNetSDK.NET_DVR_StopPlayBack(iPlayBack);
+                if (outputStream != null) {
+                    try {
+                        outputStream.close();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                System.out.println("按时间回放结束");
+            }
+        }
+
+
+    }
+
+
+    //获取IP通道
+    public static void getIPChannelInfo(int userID) {
+        IntByReference ibrBytesReturned = new IntByReference(0);//获取IP接入配置参数
+        HCNetSDK.NET_DVR_IPPARACFG_V40 m_strIpparaCfg = new HCNetSDK.NET_DVR_IPPARACFG_V40();
+        m_strIpparaCfg.write();
+        //lpIpParaConfig 接收数据的缓冲指针
+        Pointer lpIpParaConfig = m_strIpparaCfg.getPointer();
+        boolean bRet = hCNetSDK.NET_DVR_GetDVRConfig(userID, HCNetSDK.NET_DVR_GET_IPPARACFG_V40, 0, lpIpParaConfig, m_strIpparaCfg.size(), ibrBytesReturned);
+        m_strIpparaCfg.read();
+        System.out.println("起始数字通道号：" + m_strIpparaCfg.dwStartDChan);
+
+        for (int iChannum = 0; iChannum < m_strIpparaCfg.dwDChanNum; iChannum++) {
+            int channum = iChannum + m_strIpparaCfg.dwStartDChan;
+            m_strIpparaCfg.struStreamMode[iChannum].read();
+            if (m_strIpparaCfg.struStreamMode[iChannum].byGetStreamType == 0) {
+                m_strIpparaCfg.struStreamMode[iChannum].uGetStream.setType(HCNetSDK.NET_DVR_IPCHANINFO.class);
+                m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.read();
+                if (m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byEnable == 1) {
+                    System.out.println("IP通道" + channum + "在线");
+                } else {
+                    System.out.println("IP通道" + channum + "不在线");
+                }
+            }
+        }
+    }
+
+    static class fPlayEScallback implements HCNetSDK.FPlayESCallBack {
+        public void invoke(int lPreviewHandle, HCNetSDK.NET_DVR_PACKET_INFO_EX pstruPackInfo, Pointer pUser) {
+            System.out.println("进入码流回调");
+            System.out.println(pstruPackInfo.dwPacketSize);
+//            try {
+//                fileLenth += pstruPackInfo.dwPacketSize;
+//                fileOutputStream = new FileOutputStream(resultFileName,true);
+//                //将字节写入文件
+//                ByteBuffer buffers = pstruPackInfo.pPacketBuffer.getByteBuffer(0, pstruPackInfo.dwPacketSize);
+//                byte[] bytes = new byte[pstruPackInfo.dwPacketSize];
+//                buffers.rewind();
+//                buffers.get(bytes);
+//                fileOutputStream.write(bytes);
+//            } catch (FileNotFoundException e) {
+//                e.printStackTrace();
+//            } catch (IOException e) {
+//                e.printStackTrace();
+//            }
+        }
+    }
+
+    static class playDataCallBack implements HCNetSDK.FPlayDataCallBack {
+        public void invoke(int lPlayHandle, int dwDataType, Pointer pBuffer, int dwBufSize, int dwUser) {
+            System.out.println("回放码流回调...");
+            //将设备发送过来的回放码流数据写入文件
+            long offset = 0;
+            ByteBuffer buffers = pBuffer.getByteBuffer(offset, dwBufSize);
+            byte[] bytes = new byte[dwBufSize];
+            buffers.rewind();
+            buffers.get(bytes);
+            try {
+                outputStream.write(bytes);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    static class FRealDataCallBack implements HCNetSDK.FRealDataCallBack_V30 {
+        //预览回调
+        public void invoke(int lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
+            System.out.println("码流数据回调...dwBufSize=" + dwBufSize);
+            //播放库解码
+            switch (dwDataType) {
+                case HCNetSDK.NET_DVR_SYSHEAD: //系统头
+                    if (!playControl.PlayM4_GetPort(m_lPort)) //获取播放库未使用的通道号
+                    {
+                        break;
+                    }
+                    if (dwBufSize > 0) {
+                        if (!playControl.PlayM4_SetStreamOpenMode(m_lPort.getValue(), PlayCtrl.STREAME_REALTIME))  //设置实时流播放模式
+                        {
+                            break;
+                        }
+                        if (!playControl.PlayM4_OpenStream(m_lPort.getValue(), pBuffer, dwBufSize, 1024 * 1024)) //打开流接口
+                        {
+                            break;
+                        }
+                        if (!playControl.PlayM4_Play(m_lPort.getValue(), null)) //播放开始
+                        {
+                            break;
+                        }
+
+                    }
+                case HCNetSDK.NET_DVR_STREAMDATA:   //码流数据
+                    if ((dwBufSize > 0) && (m_lPort.getValue() != -1)) {
+                        if (!playControl.PlayM4_InputData(m_lPort.getValue(), pBuffer, dwBufSize))  //输入流数据
+                        {
+                            break;
+                        }
+                    }
+            }
+        }
+    }
+
+}

src/main/resources/application-dev.yml

@@ -3,6 +3,8 @@
 exceptionAlarm:
   # 设备ip地址 枪机: DS-2CD7T27DWD-IZS(16384)/球机: DS-7716NX-I4(4354)
   deviceIP: 10.7.11.161
+  # 端口
+  port: 8000
   # 设备用户名
   userName: admin
   # 设备密码

src/main/resources/application-prod.yml

@@ -2,13 +2,15 @@
 # 设备登录
 exceptionAlarm:
   # 设备ip地址 DS-2CD7T27DWD-IZS(16384)/DS-7716NX-I4(4354)-->4432
-  deviceIP: 192.168.143.10
-  # orgCode
-  org-code: SPB
+  deviceIP: 10.7.11.161
   # 设备用户名
   userName: admin
   # 设备密码
-  password: JLspb20220928
+  password: Aa870618
+  # 端口
+  port: 8000
+  # orgCode
+  org-code: SPB
 # 只支持post
 address:
   # 推送异常闯入/入侵信息地址