deviceManage/ruoyi-admin/src/main/java/com/ruoyi/web/controller/hk/BjsbController.java

package com.ruoyi.web.controller.hk;

import com.ruoyi.common.core.domain.AjaxResult;
import com.sun.jna.Native;
import com.sun.jna.Pointer;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.UnsupportedEncodingException;

/**
 * @Author: tjf
 * @Date: 2025/6/6 星期五 16:03
 * @Describe:
 */
@RestController
@RequestMapping("/system/user")
public class BjsbController {
    static HCNetSDK hCNetSDK = null;
    static int lUserID = -1;//用户句柄
    static int lAlarmHandle = -1;

    /**
     * 根据不同操作系统选择不同的库文件和库路径
     *
     * @return
     */
    private static boolean createSDKInstance() {
        if (hCNetSDK == null) {
            synchronized (HCNetSDK.class) {
                String strDllPath = "";
                try {
                    //System.setProperty("jna.debug_load", "true");
                    if (osSelect.isWindows())
                        //win系统加载库路径
                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
                    else if (osSelect.isLinux())
                        //Linux系统加载库路径
                        strDllPath = System.getProperty("user.dir") + "/libOne/libhcnetsdk.so";
                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
                } catch (Exception ex) {
                    System.out.println("loadLibrary: " + strDllPath + " Error: " + ex.getMessage());
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * 获取表计数据
     */
    @GetMapping("/getBj")
    public AjaxResult getBj() {
        if (hCNetSDK == null) {
            if (!createSDKInstance()) {
                System.out.println("Load SDK fail");
                return AjaxResult.error("Load SDK fail");
            }
        }
        //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(HCNetSDK.NET_SDK_INIT_CFG_LIBEAY_PATH, ptrByteArray1.getPointer());
            System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
            ptrByteArray2.write();
            hCNetSDK.NET_DVR_SetSDKInitCfg(HCNetSDK.NET_SDK_INIT_CFG_SSLEAY_PATH, 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(HCNetSDK.NET_SDK_INIT_CFG_SDK_PATH, struComPath.getPointer());
        }
        /*初始化*/
        hCNetSDK.NET_DVR_Init();

        /*加载日志*/
        //hCNetSDK.NET_DVR_SetLogToFile(3, "./sdklog", false);

        //分离模式（建议）：对应报警信息类型COMM_ISAPI_ALARM，pAlarmInfo对应结构体NET_DVR_ALARM_ISAPI_INFO，将报警事件信息数据（XML或者JSON格式的字符串）和二进制图片数据分离，分别在结构体的pAlarmData、pPicPackData指针指向的内存里面返回。设备上传的报警信息包含图片数据，图片数据有二进制传输方式和URL传输方式两种，如果URL方式则对应pPicPackData为空，报警事件信息数据（XML或者JSON格式的字符串）里面包含HTTP协议的URL字段。
        HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG struNET_DVR_LOCAL_GENERAL_CFG = new HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG();
        //控制JSON透传报警数据和图片是否分离，0-不分离，1-分离（分离后走COMM_ISAPI_ALARM回调返回）
        struNET_DVR_LOCAL_GENERAL_CFG.byAlarmJsonPictureSeparate = 1;
        struNET_DVR_LOCAL_GENERAL_CFG.write();
        Pointer pStrNET_DVR_LOCAL_GENERAL_CFG = struNET_DVR_LOCAL_GENERAL_CFG.getPointer();
        if (!hCNetSDK.NET_DVR_SetSDKLocalCfg(17, pStrNET_DVR_LOCAL_GENERAL_CFG)) {
            AjaxResult.error("报警主机NET_DVR_SetSDKLocalCfg失败");
        }
        //设置连接时间与重连时间
        hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
        hCNetSDK.NET_DVR_SetReconnect(10000, true);

        //设备登录
        lUserID = loginDevice("10.9.137.190", (short) 8000, "admin", "hik12345"); //登录设备
        if (lUserID == -1) {
            return AjaxResult.error("请先注册报警主机");
        }
        //设置报警回调函数
        HCNetSDK.FMSGCallBack_V31 fMSFCallBack_v31 = new FMSGCallBack_V31();
        boolean flag = hCNetSDK.NET_DVR_SetDVRMessageCallBack_V50(0, fMSFCallBack_v31, null);
        if (!flag) {
            AjaxResult.error("报警主机设置回调函数失败!");
        }
        //启用布防
        HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50 struAlarmParam = new HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50();
        struAlarmParam.byAlarmTypeURL = 1;
        struAlarmParam.write();
        lAlarmHandle = hCNetSDK.NET_DVR_SetupAlarmChan_V50(lUserID, struAlarmParam, null, 0);
        if (lAlarmHandle == -1) {
            return AjaxResult.error("报警主机布防失败，错误号:" + hCNetSDK.NET_DVR_GetLastError());
        } else {
            return AjaxResult.success("报警主机布防成功");
        }
    }

    /**
     * @description: 报警信息回调函数
     **/
    public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {

        /**
         * @param lCommand   上传消息类型
         * @param pAlarmer   报警设备信息
         * @param pAlarmInfo 报警信息
         * @param dwBufLen   报警信息缓存大小
         * @param pUser      用户数据
         * @return
         */
        @Override
        public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) throws UnsupportedEncodingException {
            alarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
            return true;
        }

        //报警信息回调函数
        public void alarmDataHandle(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) throws UnsupportedEncodingException {
            //报警时间
            String sAlarmType = "lCommand=0x" + Integer.toHexString(lCommand);
            System.out.println(pAlarmInfo);
            //退出程序时调用NET_DVR_Logout注销设备
            Logout();
            //lCommand是传的报警类型
/*            switch (lCommand) {
                case HCNetSDK.COMM_ISAPI_ALARM:
                    HCNetSDK.NET_DVR_ALARM_ISAPI_INFO struISAPIAlarm = new HCNetSDK.NET_DVR_ALARM_ISAPI_INFO();
                    //解析JSON数据
                    if (struISAPIAlarm.dwAlarmDataLen > 0)
                    {
                        printf("COMM_ISAPI_ALARM报警事件信息数据: \n%s\n", UTF8ToAnsi(struISAPIAlarm.pAlarmData));
                    }
                    break;
                default:
                    break;
            }*/
        }
    }


    /**
     * 登录设备，支持 V40 和 V30 版本，功能一致。
     *
     * @param ip   设备IP地址
     * @param port SDK端口，默认为设备的8000端口
     * @param user 设备用户名
     * @param psw  设备密码
     * @return 登录成功返回用户ID，失败返回-1
     */
    public static int loginDevice(String ip, short port, String user, String psw) {
        // 创建设备登录信息和设备信息对象
        HCNetSDK.NET_DVR_USER_LOGIN_INFO loginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();
        HCNetSDK.NET_DVR_DEVICEINFO_V40 deviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();

        // 设置设备IP地址
        byte[] deviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
        byte[] ipBytes = ip.getBytes();
        System.arraycopy(ipBytes, 0, deviceAddress, 0, Math.min(ipBytes.length, deviceAddress.length));
        loginInfo.sDeviceAddress = deviceAddress;

        // 设置用户名和密码
        byte[] userName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
        byte[] password = psw.getBytes();
        System.arraycopy(user.getBytes(), 0, userName, 0, Math.min(user.length(), userName.length));
        System.arraycopy(password, 0, loginInfo.sPassword, 0, Math.min(password.length, loginInfo.sPassword.length));
        loginInfo.sUserName = userName;

        // 设置端口和登录模式
        loginInfo.wPort = port;
        loginInfo.bUseAsynLogin = false; // 同步登录
        loginInfo.byLoginMode = 0; // 使用SDK私有协议

        // 执行登录操作
        int userID = hCNetSDK.NET_DVR_Login_V40(loginInfo, deviceInfo);
        if (userID == -1) {
            System.err.println("登录失败，错误码为: " + hCNetSDK.NET_DVR_GetLastError());
        } else {
            System.out.println(ip + " 设备登录成功！");
            // 处理通道号逻辑
            int startDChan = deviceInfo.struDeviceV30.byStartDChan;
            System.out.println("预览起始通道号: " + startDChan);
        }
        return userID; // 返回登录结果
    }

    /**
     * 报警主机注销用户，释放资源
     */
    public static AjaxResult Logout() {
        //报警撤防
        if (lAlarmHandle > -1) {
            if (hCNetSDK.NET_DVR_CloseAlarmChan_V30(lAlarmHandle)) {
                lAlarmHandle = -1;
                //注销
                if (lUserID > -1) {
                    if (hCNetSDK.NET_DVR_Logout(lUserID)) {
                        hCNetSDK.NET_DVR_Cleanup();
                        lUserID = -1;
                        return AjaxResult.success("报警主机注销用户,撤防成功");
                    } else {
                        System.out.println("报警主机注销失败，错误号:" + hCNetSDK.NET_DVR_GetLastError());
                    }
                }
            } else {
                System.out.println("报警主机撤防失败，错误号:" + hCNetSDK.NET_DVR_GetLastError());
            }
        }
        return AjaxResult.error("报警主机注销用户失败，错误号:" + hCNetSDK.NET_DVR_GetLastError());
    }

}