优化超脑报警事件

‘liusuyi’

2023-12-07 8aa86d038ed9152875196e9049e998ca7d620a22

优化超脑报警事件

 src/main/java/com/ard/alarm/camera/service/impl/ArdCamerasServiceImpl.java

@@ -9,6 +9,7 @@
import com.ard.alarm.camera.domain.ArdCameras;

import com.ard.alarm.camera.mapper.ArdCamerasMapper;

import com.ard.alarm.camera.service.IArdCamerasService;

import com.ard.utils.sdk.hiksdk.common.GlobalVariable;

import com.ard.utils.sdk.hiksdk.service.impl.HikClientUtil;

import com.baomidou.mybatisplus.core.conditions.Wrapper;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;

@@ -39,10 +40,9 @@
    //初始化执行

    @Override

    public void run(ApplicationArguments args) {

        //获取小光电尝试登录

        ardCameraList = selectArdCamerasList(new ArdCameras());

        HikClientUtil.loginAllCamera(ardCameraList);

        syncCameraListTask();

        syncCameraTask();

    }



    /**

@@ -51,10 +51,10 @@
     * åˆ˜è‹ä¹‰

     * 2023/8/11 9:09:27

     */

    private void syncCameraListTask() {

    private void syncCameraTask() {

        scheduler.scheduleAtFixedRate(() -> {

            try {

                //region å®šæ—¶åŒæ­¥å°å…‰ç”µ

                //region å®šæ—¶åŒæ­¥å…‰ç”µè®¾å¤‡

                List<ArdCameras> newArdCameraList = selectArdCamerasList(new ArdCameras());

                //需要更新的数据

                List<ArdCameras> updateList = sameListWithDifferent(ardCameraList, newArdCameraList);

@@ -95,8 +95,6 @@
     */

    @Override

    public List<ArdCameras> selectArdCamerasList(ArdCameras ardCamera) {

        ardCamera.setGdType("0");

        ardCamera.setFactory("1");

        Wrapper<ArdCameras> queryWrapper=new QueryWrapper<>(ardCamera);

        return ardCamerasMapper.selectList(queryWrapper);

    }


 src/main/java/com/ard/utils/minio/MinioUtil.java

@@ -442,7 +442,7 @@
                    .stream(stream, size, -1)
                    .contentType(contextType)
                    .build();
            ObjectWriteResponse objectWriteResponse = minioClient.putObject(putObjectArgs);
            minioClient.putObject(putObjectArgs);
            return true;
        } catch (Exception ex) {
            log.error("minio上传文件(通过stream)异常" + ex.getMessage());

 src/main/java/com/ard/utils/sdk/hiksdk/common/GlobalVariable.java

@@ -1,8 +1,10 @@
package com.ard.utils.sdk.hiksdk.common;

import com.ard.alarm.camera.domain.ArdCameras;
import com.ard.utils.sdk.hiksdk.domain.ChannelInfo;
import lombok.Data;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
@@ -14,6 +16,7 @@
 **/
@Data
public class GlobalVariable {

    //保存相机信息key:(ip:port) value:camera对象
    public static Map<String, ArdCameras> cameraMap = new HashMap<>();

@@ -22,4 +25,7 @@

    //保存设备的布防信息key:deviceId value:lAlarmHandle
    public static Map<String, Integer> alarmMap = new HashMap<>();
}

    //保存设备的通道信息key:deviceId value:ChannelInfoList
    public static Map<String, List<ChannelInfo>> deviceChanMap= new HashMap<>();
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/ChannelInfo.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package com.ard.utils.sdk.hiksdk.domain;

import lombok.Data;

/**
 * @Description:
 * @ClassName: ChannelInfo
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´12月07日8:21:36
 **/
@Data
public class ChannelInfo {
    String ip;
    Integer port;
    String name;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/SuperBrainEventInfo.java

@@ -44,6 +44,10 @@
     */
    Double latitude;
    /**
     * å…³è”超脑高层
     */
    Double altitude;
    /**
     * å¤§å›¾url
     */
    String picUrl;

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Age.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,12 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;
import lombok.Data;
/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class Age {
    private String ageGroup;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Extenddata.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;
import lombok.Data;
/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class Extenddata {

    private int extendID;
    private boolean enable;
    private String name;
    private String value;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/FaceCapture.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;
import java.util.List;
import lombok.Data;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class FaceCapture {

    private Targetattrs targetAttrs;
    private List<Faces> faces;
    private String recordDataIndex;
    private String targetId;
    private List<Faceinfo> FaceInfo;

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Faceappenddata.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

import lombok.Data;


/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn
 * @website http://www.jsons.cn/json2java/
 */
@Data
public class Faceappenddata {

    private String name;
    private String gender;
    private String bornTime;
    private String city;
    private String certificateType;
    private String certificateNumber;
    private String phoneNumber;
    private String cityName;
    private String provinceName;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Faceexpression.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
public class Faceexpression {

    private String value;
    public void setValue(String value) {
         this.value = value;
     }
     public String getValue() {
         return value;
     }

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Faceinfo.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

import java.util.List;

import lombok.Data;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn
 * @website http://www.jsons.cn/json2java/
 */
@Data
public class Faceinfo {

    private String FDID;
    private String faceLibType;
    private String PID;
    private String face_picurl;
    private Faceappenddata FaceAppendData;
    private double similarity;
    private List<Extenddata> extendData;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Facerect.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

import lombok.Data;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class Facerect {

    private double height;
    private double width;
    private double x;
    private double y;
}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Faces.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

import lombok.Data;


/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn
 * @website http://www.jsons.cn/json2java/
 */
@Data
public class Faces {


    private int faceId;
    private Facerect faceRect;
    private Age age;
    private Gender gender;
    private Glass glass;
    private Smile smile;
    private Mask mask;

    private String URL;
    private int occurrences;

    private Faceexpression faceExpression;


}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Gender.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
public class Gender {

    private String value;
    public void setValue(String value) {
         this.value = value;
     }
     public String getValue() {
         return value;
     }

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Glass.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
public class Glass {

    private String value;
    public void setValue(String value) {
         this.value = value;
     }
     public String getValue() {
         return value;
     }

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/IsapiAlarm.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,42 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;
import java.util.Date;
import java.util.List;
import lombok.Data;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class IsapiAlarm {

    private String ipAddress;

    private String ipv6Address;

    private int portNo;
    private String protocol;

    private String macAddress;

    private int channelID;

    private Date dateTime;

    private int activePostCount;

    private String eventType;

    private String eventState;

    private String eventDescription;

    private String channelName;

    private List<FaceCapture> faceCapture;

    private String URLCertificationType;

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Mask.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
public class Mask {

    private String value;
    public void setValue(String value) {
         this.value = value;
     }
     public String getValue() {
         return value;
     }

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Smile.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
public class Smile {

    private String value;
    public void setValue(String value) {
         this.value = value;
     }
     public String getValue() {
         return value;
     }

}

 src/main/java/com/ard/utils/sdk/hiksdk/domain/isapi/Targetattrs.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
package com.ard.utils.sdk.hiksdk.domain.isapi;
import java.util.Date;
import lombok.Data;

/**
 * Auto-generated: 2023-12-07 11:38:0
 *
 * @author www.jsons.cn 
 * @website http://www.jsons.cn/json2java/ 
 */
@Data
public class Targetattrs {


    private int deviceChannel;

    private String deviceName;

    private Date faceTime;

    private String bkgUrl;

}

 src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java

@@ -1,6 +1,7 @@
package com.ard.utils.sdk.hiksdk.service.impl;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ard.alarm.camera.domain.ArdCameras;
import com.ard.alarm.camera.domain.CameraCmd;
import com.ard.alarm.camera.service.impl.ArdCamerasServiceImpl;
@@ -8,6 +9,8 @@
import com.ard.alarm.external.service.impl.ArdEquipExternalServiceImpl;
import com.ard.utils.sdk.hiksdk.domain.*;
import com.ard.utils.minio.MinioUtil;
import com.ard.utils.sdk.hiksdk.domain.isapi.FaceCapture;
import com.ard.utils.sdk.hiksdk.domain.isapi.IsapiAlarm;
import com.ard.utils.util.ByteUtils;
import com.ard.utils.sdk.hiksdk.common.GlobalVariable;
import com.ard.utils.sdk.hiksdk.util.hikSdkUtil.HCNetSDK;
@@ -22,6 +25,7 @@
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Optional;

import static com.ard.utils.sdk.hiksdk.util.hikSdkUtil.HCNetSDK.*;
@@ -49,7 +53,7 @@
    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
        SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP).trim();//设备IP地址
        Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口
        int wLinkPort = pAlarmer.wLinkPort;//设备通讯端口
        //通过ip和端口查询设备
        Optional<ArdCameras> foundCamera = findArdCameraByIpAndPort(sDeviceIP, wLinkPort);
        Optional<ArdEquipExternal> foundExternal = findArdEquipExternalByIpAndPort(sDeviceIP, wLinkPort);
@@ -66,15 +70,13 @@
        if (camera == null && ardEquipExternal == null) {
            return false;
        }
        CameraEventInfo cameraEventInfo;
        SuperBrainEventInfo superBrainEventInfo;
        String alarmName = "";//报警名称
        String alarmTime;//事件时间
        String alarmType = "";//报警类型
        String picUrl = "";//事件图片
        String facePicUrl = "";//人脸抓拍图片
        String faceLibUrl = "";//人脸库图片
        int dwPicDataLen;//图片数据长度
        int chanNo = 0;//通道号
        //lCommand是传的报警类型
        log.debug("【" + sDeviceIP + ":" + wLinkPort + "】报警事件类型:lCommand:" + Integer.toHexString(lCommand));
        switch (lCommand) {
@@ -89,7 +91,16 @@
                switch (netDvrAlarminfoV30.dwAlarmType) {
                    case 3:
                        if (camera != null) {
                            cameraEventHandler(camera, "移动侦测", "移动侦测报警", fmt.format(new Date()), "");
                            for (byte b : netDvrAlarminfoV30.byChannel) {
                                if (b == 1) {
                                    chanNo = b;
                                    switch (camera.getGdType()) {
                                        case "0":
                                            cameraEventHandler(camera, chanNo, "移动侦测", "移动侦测报警", fmt.format(new Date()), picUrl, "");
                                            break;
                                    }
                                }
                            }
                        }
                        break;
                }
@@ -107,7 +118,7 @@
                strVcaAlarm.read();
                Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
                alarmTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
                Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
                chanNo = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
                switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
                    case 1: //region穿越警戒面 (越界侦测)
                        alarmType = "越界侦测报警";
@@ -184,37 +195,23 @@
                dwPicDataLen = strVcaAlarm.dwPicDataLen;
                int byPicTransType = strVcaAlarm.byPicTransType;
                if (dwPicDataLen > 0 && strVcaAlarm.pImage != null && byPicTransType == 0) {
                    //将字节写入文件
                    long offset = 0;
                    ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, dwPicDataLen);
                    byte[] bytes = new byte[dwPicDataLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    InputStream input = new ByteArrayInputStream(bytes);
                    try {
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + picUrl);
                        }
                    } catch (Exception e) {
                        log.error("异常行为识别信息报警信息上报图片保存失败" + e.getMessage());
                    }
                    picUrl = saveBinPicToMinio(strVcaAlarm.pImage, dwPicDataLen);
                }
                if (camera != null) {
                    camera.setChannel(channel);
                    cameraEventHandler(camera, alarmName, alarmType, alarmTime, picUrl);
                }
                if (ardEquipExternal != null) {
                    alarmName = "异常行为识别";
                    superBrainEventHandler(ardEquipExternal, channel, alarmName, alarmType, alarmTime, picUrl, "");
                    switch (camera.getGdType()) {
                        case "0":
                            cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, "");
                            break;
                        case "3":
                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, "");
                            break;
                    }
                }
                //endregion
                break;
            case COMM_UPLOAD_FACESNAP_RESULT:
                log.debug("人脸抓拍报警信息(暂不解析)");
                log.debug("人脸抓拍报警信息上报");
                //region äººè„¸æŠ“拍报警信息
                HCNetSDK.NET_VCA_FACESNAP_RESULT struFaceSnap = new HCNetSDK.NET_VCA_FACESNAP_RESULT();
                struFaceSnap.write();
@@ -223,6 +220,7 @@
                struFaceSnap.read();
                alarmTime = DateUtils.parseTime(struFaceSnap.dwAbsTime);
                String facePicTyp;
                chanNo = struFaceSnap.struDevInfo.byChannel;
                switch (struFaceSnap.byUploadEventDataType) {
                    case 0:
                        facePicTyp = "二进制数据";
@@ -235,63 +233,38 @@
                        break;
                }
                if (struFaceSnap.dwFacePicLen > 0 && struFaceSnap.pBuffer1 != null) {
                    //将字节写入文件
                    long offset = 0;
                    ByteBuffer buffers = struFaceSnap.pBuffer1.getByteBuffer(offset, struFaceSnap.dwBackgroundPicLen);
                    byte[] bytes = new byte[struFaceSnap.dwBackgroundPicLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    InputStream input = new ByteArrayInputStream(bytes);
                    try {
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            facePicUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + url);
                        }
                    } catch (Exception e) {
                        log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
                    }
                    facePicUrl = saveBinPicToMinio(struFaceSnap.pBuffer1, struFaceSnap.dwFacePicLen);
                }
                if (struFaceSnap.dwBackgroundPicLen > 0 && struFaceSnap.pBuffer2 != null) {
                    //将字节写入文件
                    long offset = 0;
                    ByteBuffer buffers = struFaceSnap.pBuffer2.getByteBuffer(offset, struFaceSnap.dwBackgroundPicLen);
                    byte[] bytes = new byte[struFaceSnap.dwBackgroundPicLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    InputStream input = new ByteArrayInputStream(bytes);
                    try {
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + url);
                        }
                    } catch (Exception e) {
                        log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
                    }
                    picUrl = saveBinPicToMinio(struFaceSnap.pBuffer2, struFaceSnap.dwBackgroundPicLen);
                }
                //log.debug("【人脸抓拍报警信息】: alarmTime:" + alarmTime + " picUrl:" + picUrl + " facePicType:" + facePicTyp + " facePicUrl:" + facePicUrl);
                FaceSnapEventInfo faceSnapEventInfo = new FaceSnapEventInfo();
                faceSnapEventInfo.setAlarmTime(alarmTime);
                faceSnapEventInfo.setPicUrl(picUrl);
                publishMqtt(faceSnapEventInfo, "superbrain");
                if (camera != null) {
                    alarmName = "人脸抓拍检测";
                    alarmType = "人脸抓拍报警";
                    switch (camera.getGdType()) {
                        case "0":
                            cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, "", "");
                            break;
                        case "3":
                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                            break;
                    }
                }
                //endregion
                break;
            case COMM_SNAP_MATCH_ALARM:
                log.debug("人脸比对报警信息");
                log.debug("人脸比对报警信息上报");
                //region äººè„¸æ¯”对报警信息
                HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM struFaceMatchAlarm = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
                struFaceMatchAlarm.byPicTransType = 0;
                struFaceMatchAlarm.write();
                Pointer fmaInfo = struFaceMatchAlarm.getPointer();
                fmaInfo.write(0, pAlarmInfo.getByteArray(0, struFaceMatchAlarm.size()), 0, struFaceMatchAlarm.size());
                struFaceMatchAlarm.read();
                alarmTime = DateUtils.parseTime(struFaceMatchAlarm.struSnapInfo.dwAbsTime);//报警时间
                chanNo = struFaceMatchAlarm.struSnapInfo.struDevInfo.byChannel;
                int byMatchPicNum = struFaceMatchAlarm.byMatchPicNum;//匹配图片数量
                int picTransType = struFaceMatchAlarm.byPicTransType;////图片数据传输方式: 0-二进制；1-url
                String contrastStatus = "";
                switch (struFaceMatchAlarm.byContrastStatus) {
                    case 1:
@@ -315,76 +288,6 @@
                    default:
                        BlockType = "未知";
                        break;
                }
                //人脸比对报警图片保存，图片格式二进制
                if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
                    String newName = sf.format(new Date());
                    FileOutputStream fout;
                    try {
                        String filename = "../pic/" + newName + "_pSnapPicBuffer" + ".jpg";
                        fout = new FileOutputStream(filename);
                        //将字节写入文件
                        long offset = 0;
                        ByteBuffer buffers = struFaceMatchAlarm.pSnapPicBuffer.getByteBuffer(offset, struFaceMatchAlarm.dwSnapPicLen);
                        byte[] bytes = new byte[struFaceMatchAlarm.dwSnapPicLen];
                        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 ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
                    String newName = sf.format(new Date());
                    FileOutputStream fout;
                    try {
                        String filename = "../pic/" + newName + "_struSnapInfo_pBuffer1" + ".jpg";
                        fout = new FileOutputStream(filename);
                        //将字节写入文件
                        long offset = 0;
                        ByteBuffer buffers = struFaceMatchAlarm.struSnapInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
                        byte[] bytes = new byte[struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen];
                        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 ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
                    String newName = sf.format(new Date());
                    FileOutputStream fout;
                    try {
                        String filename = "../pic/" + newName + "_fSimilarity_" + struFaceMatchAlarm.fSimilarity + "_struBlackListInfo_pBuffer1" + ".jpg";
                        fout = new FileOutputStream(filename);
                        //将字节写入文件
                        long offset = 0;
                        ByteBuffer buffers = struFaceMatchAlarm.struBlockListInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen);
                        byte[] bytes = new byte[struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen];
                        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();
                    }
                }
                //人脸比对报警图片保存，图片格式URL格式
                if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {
@@ -414,18 +317,35 @@
                    byte[] bytes = new byte[struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    faceLibUrl = new String(bytes);
                    String faceLibUrl = new String(bytes);
                    //System.out.println("人脸库人脸图的URL：" + SnapPicUrl);
                }
                if (ardEquipExternal != null) {
                //人脸比对报警图片保存，图片格式二进制
                //if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                //    picUrl = saveBinPicToMinio(struFaceMatchAlarm.pSnapPicBuffer, struFaceMatchAlarm.dwSnapPicLen);
                //}
                //if ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                //    facePicUrl = saveBinPicToMinio(struFaceMatchAlarm.struSnapInfo.pBuffer1, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
                //}
                //if ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
                //    //String faceBlockPicUrl = saveBinPicToMinio(struFaceMatchAlarm.struBlockListInfo.pBuffer1, struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen);
                //}
                if (camera != null) {
                    alarmName = "人脸比对检测";
                    alarmType = contrastStatus + "[" + BlockType + "]";
                    superBrainEventHandler(ardEquipExternal, 0, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                    alarmType = BlockType + "[" + contrastStatus + "]";
                    switch (camera.getGdType()) {
                        case "0":
                            cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, "", "");
                            break;
                        case "3":
                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                            break;
                    }
                }
                //endregion
                break;
            case COMM_UPLOAD_AIOP_VIDEO:
                log.debug("AI开放平台接入视频检测报警上传");
                log.debug("AI视频检测报警上传");
                //region AI开放平台接入视频检测
                HCNetSDK.NET_AIOP_VIDEO_HEAD struAIOPVideo = new HCNetSDK.NET_AIOP_VIDEO_HEAD();
                struAIOPVideo.write();
@@ -441,9 +361,9 @@
                        String.format("%02d", struAIOPVideo.struTime.wDay) + " " +
                        String.format("%02d", struAIOPVideo.struTime.wHour) + ":" +
                        String.format("%02d", struAIOPVideo.struTime.wMinute) + ":" +
                        String.format("%02d", struAIOPVideo.struTime.wSecond) + "." +
                        String.format("%03d", struAIOPVideo.struTime.wMilliSec);
                alarmName = "AI开放平台接入视频检测";
                        String.format("%02d", struAIOPVideo.struTime.wSecond);
                // + "." + String.format("%03d", struAIOPVideo.struTime.wMilliSec);
                chanNo = struAIOPVideo.dwChannel;
                switch (szMPID) {
                    case "H930_MODEL_SPD":
                        alarmType = "抽烟打电话";
@@ -451,80 +371,79 @@
                }
                //图片数据保存
                if (struAIOPVideo.dwPictureSize > 0) {
                    //将字节写入文件
                    long offset = 0;
                    ByteBuffer buffers = struAIOPVideo.pBufferPicture.getByteBuffer(offset, struAIOPVideo.dwPictureSize);
                    byte[] bytes = new byte[struAIOPVideo.dwPictureSize];
                    buffers.rewind();
                    buffers.get(bytes);
                    InputStream input = new ByteArrayInputStream(bytes);
                    try {
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + picUrl);
                        }
                    } catch (Exception e) {
                        log.error("AI开放平台接入视频检测报警上传上报图片保存失败" + e.getMessage());
                    }
                    picUrl = saveBinPicToMinio(struAIOPVideo.pBufferPicture, struAIOPVideo.dwPictureSize);
                }
                if (ardEquipExternal != null) {
                    superBrainEventHandler(ardEquipExternal, struAIOPVideo.dwChannel, alarmName, alarmType, alarmTime, picUrl, "");
                if (camera != null) {
                    alarmName = "AI视频检测";
                    switch (camera.getGdType()) {
                        case "3":
                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                            break;
                    }
                }
                //endregion
                break;
            case COMM_ISAPI_ALARM:
                log.debug("安全帽检测报警信息上报");
                //region å®‰å…¨å¸½æ£€æµ‹æŠ¥è­¦ä¿¡æ¯
            case COMM_ISAPI_ALARM://ISAPI协议报警信息
                log.debug("ISAPI协议报警信息上报");
                //region ISAPI协议报警信息
                HCNetSDK.NET_DVR_ALARM_ISAPI_INFO struEventISAPI = new HCNetSDK.NET_DVR_ALARM_ISAPI_INFO();
                struEventISAPI.write();
                Pointer pEventISAPI = struEventISAPI.getPointer();
                pEventISAPI.write(0, pAlarmInfo.getByteArray(0, struEventISAPI.size()), 0, struEventISAPI.size());
                struEventISAPI.read();
                int dwAlarmDataLen = struEventISAPI.dwAlarmDataLen;
                int byDataType = struEventISAPI.byDataType;
                int byPicturesNumber = struEventISAPI.byPicturesNumber;
                //处理安全帽检测上传的照片数据
                Pointer pPicPackData = struEventISAPI.pPicPackData;
                if (pPicPackData != null) {
                    HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA struPicData = new HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA();
                    struPicData.write();
                    if (struPicData.size() > 0) {
                        Pointer pPicData = struPicData.getPointer();
                        pPicData.write(0, pPicPackData.getByteArray(0, struPicData.size()), 0, struPicData.size());
                        struPicData.read();
                        int dwPicLen = struPicData.dwPicLen;
                        pPicData = struPicData.pPicData;
                        if (dwPicLen > 0 && pPicData != null) {
                            //将字节写入文件
                            long offset = 0;
                            ByteBuffer buffers = pPicData.getByteBuffer(offset, dwPicLen);
                            byte[] bytes = new byte[dwPicLen];
                            buffers.rewind();
                            buffers.get(bytes);
                            InputStream input = new ByteArrayInputStream(bytes);
                            try {
                                String bucketName = "pic";
                                String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                                boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                                if (uploadObject) {
                                    picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                                    //log.debug("上传文件成功!" + picUrl);
                int dwAlarmDataLen = struEventISAPI.dwAlarmDataLen;// æŠ¥è­¦æ•°æ®é•¿åº¦
                int byDataType = struEventISAPI.byDataType;// 0-invalid,1-xml,2-json
                int byPicturesNumber = struEventISAPI.byPicturesNumber;// å›¾ç‰‡æ•°é‡
                if (dwAlarmDataLen > 0) {//报警数据打印
                    HCNetSDK.BYTE_ARRAY m_strISAPIData = new HCNetSDK.BYTE_ARRAY(struEventISAPI.dwAlarmDataLen);
                    m_strISAPIData.write();
                    Pointer pPlateInfo = m_strISAPIData.getPointer();
                    pPlateInfo.write(0, struEventISAPI.pAlarmData.getByteArray(0, m_strISAPIData.size()), 0, m_strISAPIData.size());
                    m_strISAPIData.read();
                    String json = new String(m_strISAPIData.byValue).trim();
                    // log.debug(new String(m_strISAPIData.byValue).trim() + "\n");
                    //解析JSON数据
                    if (byDataType == 2) {
                        IsapiAlarm isapiAlarm = JSONObject.parseObject(json, IsapiAlarm.class);
                        alarmName = "ISAPI协议信息检测";
                        switch (isapiAlarm.getEventType()) {
                            //case "HFPD":
                            //chanNo = isapiAlarm.getChannelID();
                            //alarmType = "高频人员事件报警";
                            //picUrl = isapiAlarm.getFaceCapture().get(0).getTargetAttrs().getBkgUrl();
                            //facePicUrl = isapiAlarm.getFaceCapture().get(0).getFaces().get(0).getURL();
                            // break;
                            case "safetyHelmetDetection":
                                chanNo = isapiAlarm.getChannelID();
                                alarmType = "安全帽事件报警";
                                alarmTime = fmt.format(isapiAlarm.getDateTime());
                                //图片保存
                                for (int i = 0; i < struEventISAPI.byPicturesNumber; i++) {
                                    HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA struPicData = new HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA();
                                    struPicData.write();
                                    Pointer pPicData = struPicData.getPointer();
                                    pPicData.write(0, struEventISAPI.pPicPackData.getByteArray(i * struPicData.size(), struPicData.size()), 0, struPicData.size());
                                    struPicData.read();
                                    switch (i) {
                                        case 0:
                                            picUrl = saveBinPicToMinio(struPicData.pPicData, struPicData.dwPicLen);
                                            break;
                                        case 1:
                                            facePicUrl = saveBinPicToMinio(struPicData.pPicData, struPicData.dwPicLen);
                                            break;
                                    }
                                }
                            } catch (Exception e) {
                                log.error("异常行为识别信息报警信息上报图片保存失败" + e.getMessage());
                            }
                                if (camera != null) {
                                    switch (camera.getGdType()) {
                                        case "3":
                                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                                            break;
                                    }
                                }
                                break;
                        }

                    }
                }
                if (ardEquipExternal != null) {
                    alarmName = "安全帽检测";
                    alarmType = "安全帽事件报警";
                    alarmTime = fmt.format(new Date());
                    superBrainEventHandler(ardEquipExternal, 0, alarmName, alarmType, alarmTime, picUrl, "");
                }
                //endregion
                break;
@@ -643,24 +562,7 @@
                //事件图片处理
                dwPicDataLen = strACSInfo.dwPicDataLen;
                if (dwPicDataLen > 0) {
                    try {
                        //将字节写入文件
                        long offset = 0;
                        ByteBuffer buffers = strACSInfo.pPicData.getByteBuffer(offset, strACSInfo.dwPicDataLen);
                        byte[] bytes = new byte[strACSInfo.dwPicDataLen];
                        buffers.rewind();
                        buffers.get(bytes);
                        InputStream input = new ByteArrayInputStream(bytes);
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + url);
                        }
                    } catch (Exception e) {
                        log.error("图片保存失败");
                    }
                    picUrl = saveBinPicToMinio(strACSInfo.pPicData, strACSInfo.dwPicDataLen);
                }
                HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
                int byType = struAcsEventInfo.byType;
@@ -725,36 +627,23 @@
                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);
                //String sFireDecAlarmInfo = "绝对时间：" + struFireDecAlarm.dwAbsTime + ",报警子类型：" + struFireDecAlarm.byAlarmSubType + ",火点最高温度 :" +
                //        struFireDecAlarm.wFireMaxTemperature + ",火点目标距离：" + struFireDecAlarm.wTargetDistance;
                //System.out.println(sFireDecAlarmInfo);
                //图片保存
                if ((struFireDecAlarm.dwPicDataLen > 0) && (struFireDecAlarm.byPicTransType == 0)) {
                    long offset = 0;
                    ByteBuffer buffers = struFireDecAlarm.pBuffer.getByteBuffer(offset, struFireDecAlarm.dwPicDataLen);
                    byte[] bytes = new byte[struFireDecAlarm.dwPicDataLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    InputStream input = new ByteArrayInputStream(bytes);
                    try {
                        String bucketName = "pic";
                        String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
                        boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
                        if (uploadObject) {
                            picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + picUrl);
                        }
                    } catch (Exception e) {
                        log.error("火点检测事件报警上报热成像图片保存失败" + e.getMessage());
                    }

                    picUrl = saveBinPicToMinio(struFireDecAlarm.pBuffer, struFireDecAlarm.dwPicDataLen);
                }
                if (ardEquipExternal != null) {
                chanNo = struFireDecAlarm.dwVisibleChannel;
                alarmTime = DateUtils.parseTime(struFireDecAlarm.dwAbsTime);//报警时间
                if (camera != null) {
                    alarmName = "火焰检测信息上报";
                    alarmType = "火焰检测事件报警";
                    int dwVisibleChannel = struFireDecAlarm.dwVisibleChannel;
                    alarmTime = DateUtils.parseTime(struFireDecAlarm.dwAbsTime);//报警时间
                    superBrainEventHandler(ardEquipExternal, dwVisibleChannel, alarmName, alarmType, alarmTime, picUrl, "");
                    switch (camera.getGdType()) {
                        case "3":
                            superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
                            break;
                    }
                }
                //endregion
                break;
@@ -769,14 +658,12 @@
        return true;
    }


    /**
     * ç›¸æœºäº‹ä»¶å¤„理
     * åˆ˜è‹ä¹‰
     * 2023/12/5 12:56:47
     */
    public void cameraEventHandler(ArdCameras camera, String alarmName, String alarmType, String alarmTime, String picUrl) {

    public void cameraEventHandler(ArdCameras camera, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {
        CameraEventInfo cameraEventInfo = new CameraEventInfo();
        cameraEventInfo.setAlarmName(alarmName);
        cameraEventInfo.setAlarmTime(alarmTime);
@@ -785,7 +672,7 @@
        cameraEventInfo.setCameraIp(camera.getIp());
        cameraEventInfo.setCameraPort(camera.getPort());
        cameraEventInfo.setCameraType(camera.getGdType());
        cameraEventInfo.setCameraChannel(camera.getChannel());
        cameraEventInfo.setCameraChannel(chanNo);
        cameraEventInfo.setLongitude(camera.getLongitude());
        cameraEventInfo.setLatitude(camera.getLatitude());
        cameraEventInfo.setAlarmType(alarmType);
@@ -803,20 +690,33 @@
     * åˆ˜è‹ä¹‰
     * 2023/12/5 12:56:47
     */
    public void superBrainEventHandler(ArdEquipExternal superBrainDevice, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {
    public void superBrainEventHandler(ArdCameras camera, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {

        SuperBrainEventInfo superBrainEventInfo = new SuperBrainEventInfo();
        superBrainEventInfo.setAlarmName(alarmName);
        superBrainEventInfo.setAlarmType(alarmType);
        superBrainEventInfo.setAlarmTime(alarmTime);
        superBrainEventInfo.setDeviceId(superBrainDevice.getId());
        superBrainEventInfo.setDeviceName(superBrainDevice.getName());
        List<ChannelInfo> channelInfoList = GlobalVariable.deviceChanMap.get(camera.getId());//获取超脑的通道集合
        if (channelInfoList.size() > 0) {
            if (chanNo > 0) {
                ChannelInfo channelInfo = channelInfoList.get(chanNo - 1);//根据通道号获取通道信息
                if (channelInfo != null) {
                    Optional<ArdCameras> foundCamera = findArdCameraByIpAndPort(channelInfo.getIp(), channelInfo.getPort());
                    if (foundCamera.isPresent()) {
                        camera = foundCamera.get();
                        superBrainEventInfo.setDeviceId(camera.getId());
                        superBrainEventInfo.setDeviceName(camera.getName());
                        superBrainEventInfo.setLongitude(camera.getLongitude());
                        superBrainEventInfo.setLatitude(camera.getLatitude());
                        superBrainEventInfo.setAltitude(camera.getAltitude());
                    }
                }
            }
        }
        superBrainEventInfo.setChanNo(chanNo);
        superBrainEventInfo.setLongitude(superBrainDevice.getLongitude());
        superBrainEventInfo.setLatitude(superBrainDevice.getLatitude());
        superBrainEventInfo.setPicUrl(picUrl);
        superBrainEventInfo.setFaceUrl(faceUrl);
        log.debug("处理通超脑事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + superBrainDevice.getName() + "【Url】" + picUrl + "【faceUrl】" + faceUrl );
        log.debug("处理超脑事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + camera.getName() + "【Url】" + picUrl + "【faceUrl】" + faceUrl);
        publishMqtt(superBrainEventInfo, "superBrain");
    }

@@ -930,4 +830,28 @@
        return wYear + "-" + byMonth + "-" + byDay + " " + byHour + ":" + byMinute + ":" + bySecond;
    }

    //二进制图片接收写入minio返回url
    private String saveBinPicToMinio(Pointer picData, int picDataLen) {
        String picUrl = "";
        try {
            //将字节写入文件
            long offset = 0;
            ByteBuffer buffers = picData.getByteBuffer(offset, picDataLen);
            byte[] bytes = new byte[picDataLen];
            buffers.rewind();
            buffers.get(bytes);
            InputStream input = new ByteArrayInputStream(bytes);
            String bucketName = "pic";
            String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
            boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, picDataLen, "image/JPEG");
            if (uploadObject) {
                picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                //log.debug("上传文件成功!" + picUrl);
            }
        } catch (Exception e) {
            log.error("图片保存失败:" + e.getMessage());
        }
        return picUrl;
    }

}

 src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java

@@ -4,10 +4,12 @@
import com.ard.alarm.camera.domain.CameraCmd;
import com.ard.alarm.external.domain.ArdEquipExternal;
import com.ard.utils.minio.MinioUtil;
import com.ard.utils.sdk.hiksdk.domain.ChannelInfo;
import com.ard.utils.util.ByteUtils;
import com.ard.utils.sdk.hiksdk.common.GlobalVariable;
import com.ard.utils.sdk.hiksdk.domain.DeviceInfo;
import com.ard.utils.sdk.hiksdk.util.hikSdkUtil.HCNetSDK;
import com.sun.jna.NativeLong;
import com.sun.jna.Platform;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;
@@ -16,7 +18,6 @@
import java.io.*;
import java.nio.ByteBuffer;
import java.util.*;


/**
 * @ClassName: hikClientServiceImpl
@@ -32,58 +33,11 @@
    public static HCNetSDK.FMSGCallBack_V31 fMSFCallBack_V31;

    /**
     * @描述 æ³¨å†Œç™»å½• åªæ”¯æŒåŒæ­¥ç™»é™†ï¼Œä¸”官方不建议直接在此接口下写耗时操作
     * @参数 [dvrLogin]
     * @返回值 java.lang.Integer
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/17 16:12
     * @修改人和其它信息
     */
    public ArdCameras login1(ArdCameras camera) {
        // åˆå§‹åŒ–
        if (!hCNetSDK.NET_DVR_Init()) {
            log.error("SDK初始化失败");
        }

        //打印海康sdk日志
        if (Platform.isWindows()) {
            String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
            hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);
        } else {
            hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);
        }
        String m_sDeviceIP = camera.getIp();
        String m_sUsername = camera.getUsername();
        String m_sPassword = camera.getPassword();
        short m_sPort = camera.getPort().shortValue();
        //设置连接时间与重连时间
        hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
        hCNetSDK.NET_DVR_SetReconnect(100000, true);

        //设备信息, è¾“出参数
        HCNetSDK.NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
        int lUserID = hCNetSDK.NET_DVR_Login_V30(m_sDeviceIP, m_sPort, m_sUsername, m_sPassword, m_strDeviceInfo);
        if (lUserID < 0) {
            //释放SDK资源
            hCNetSDK.NET_DVR_Cleanup();
            camera.setLoginId(-1);
        }
        if (GlobalVariable.loginMap.containsKey(camera.getId())) {
            GlobalVariable.loginMap.remove(camera.getId());
        }
        GlobalVariable.loginMap.put(camera.getId(), lUserID);

        camera.setLoginId(lUserID);
        camera.setChannel((int) m_strDeviceInfo.byStartChan);
        return camera;
    }

    /**
     * @描述 æ³¨å†Œç™»å½• é›†æˆäºŽNET_DVR_Login_V30，支持同步和异步登录
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/17 16:12
     */
    public static void login(DeviceInfo deviceInfo) {
    public static int login(DeviceInfo deviceInfo) {
        // åˆå§‹åŒ–
        if (!hCNetSDK.NET_DVR_Init()) {
            log.error("SDK初始化失败");
@@ -94,6 +48,7 @@
        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);

        //打印海康sdk日志
        if (Platform.isWindows()) {
            String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
@@ -127,11 +82,12 @@
        //异步登录回调
        m_strLoginInfo.cbLoginResult = new LoginResultCallBack(deviceInfo);
        m_strLoginInfo.write();
        int i = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
        if (i < 0) {
        int loginId = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
        if (loginId < 0) {
            int errorCode = hCNetSDK.NET_DVR_GetLastError();
            log.error("登录异常：" + errorCode);
        }
        return loginId;
    }

    /**
@@ -174,12 +130,13 @@
                info.setPort(camera.getPort());
                info.setUsername(camera.getUsername());
                info.setPassword(camera.getPassword());
                info.setDeviceType(camera.getGdType());
                login(info);
                String key = camera.getIp() + ":" + camera.getPort();
                GlobalVariable.cameraMap.put(key, camera);
            }
        } catch (Exception ex) {
            log.error("初始化登录相机异常：" + ex.getMessage());
            log.error("登录相机异常：" + ex.getMessage());
        }
    }

@@ -203,147 +160,10 @@
                GlobalVariable.cameraMap.remove(key);
            }
        } catch (Exception ex) {
            log.error("初始化登录相机异常：" + ex.getMessage());
            log.error("注销相机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å½•æ‰€æœ‰æŠ¥è­¦ä¸»æœº
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void loginAllAlarmHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal alarmHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(alarmHost.getId());
                info.setIp(alarmHost.getIp());
                info.setPort(alarmHost.getPort());
                info.setUsername(alarmHost.getUsername());
                info.setPassword(alarmHost.getPassword());
                login(info);
//                String key=alarmHost.getIp()+":"+alarmHost.getPort();
//                GlobalVariable.alarmHostMap.put(key, alarmHost);
            }
        } catch (Exception ex) {
            log.error("登录所有报警主机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å‡ºæ‰€æœ‰æŠ¥è­¦ä¸»æœº
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void logoutAllAlarmHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal alarmHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(alarmHost.getId());
                info.setIp(alarmHost.getIp());
                info.setPort(alarmHost.getPort());
                info.setUsername(alarmHost.getUsername());
                info.setPassword(alarmHost.getPassword());
                logout(info);
//                String key=alarmHost.getIp()+":"+alarmHost.getPort();
//                GlobalVariable.alarmHostMap.remove(key);
            }
        } catch (Exception ex) {
            log.error("登出所有报警主机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å½•æ‰€æœ‰é—¨ç¦ä¸»æœº
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void loginAllAccessControlHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal accessControlHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(accessControlHost.getId());
                info.setIp(accessControlHost.getIp());
                info.setPort(accessControlHost.getPort());
                info.setUsername(accessControlHost.getUsername());
                info.setPassword(accessControlHost.getPassword());
                login(info);
            }
        } catch (Exception ex) {
            log.error("登录所有门禁主机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å‡ºæ‰€æœ‰é—¨ç¦ä¸»æœº
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void logoutAllAccessControlHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal accessControlHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(accessControlHost.getId());
                info.setIp(accessControlHost.getIp());
                info.setPort(accessControlHost.getPort());
                info.setUsername(accessControlHost.getUsername());
                info.setPassword(accessControlHost.getPassword());
                logout(info);
            }
        } catch (Exception ex) {
            log.error("登出所有门禁主机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å½•æ‰€æœ‰è¶…è„‘
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void loginAllSuperBrainHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal superBrainHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(superBrainHost.getId());
                info.setIp(superBrainHost.getIp());
                info.setPort(superBrainHost.getPort());
                info.setUsername(superBrainHost.getUsername());
                info.setPassword(superBrainHost.getPassword());
                login(info);
            }
        } catch (Exception ex) {
            log.error("登录所有超脑异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å‡ºæ‰€æœ‰è¶…è„‘
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/3 10:10
     */
    public static void logoutAllSuperBrainHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal superBrainHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(superBrainHost.getId());
                info.setIp(superBrainHost.getIp());
                info.setPort(superBrainHost.getPort());
                info.setUsername(superBrainHost.getUsername());
                info.setPassword(superBrainHost.getPassword());
                logout(info);
//                String key=accessControlHost.getIp()+":"+accessControlHost.getPort();
//                GlobalVariable.accessHostMap.remove(key);
            }
        } catch (Exception ex) {
            log.error("登出所有超脑异常：" + ex.getMessage());
        }
    }
    /**
     * @描述 ç™»å½•æ‰€æœ‰å¤–联设备
     * @创建人 åˆ˜è‹ä¹‰
@@ -365,6 +185,7 @@
            log.error("登录所有外联设备异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 ç™»å‡ºæ‰€æœ‰å¤–联设备
     * @创建人 åˆ˜è‹ä¹‰
@@ -383,10 +204,9 @@
                logout(info);
            }
        } catch (Exception ex) {
            log.error("登出所有超脑异常：" + ex.getMessage());
            log.error("登出所有外联设备异常：" + ex.getMessage());
        }
    }



    /**
@@ -420,6 +240,11 @@
            m_strAlarmInfo.byDeployType = 1;
            //人脸报警信息类型：1- äººè„¸ä¾¦æµ‹æŠ¥è­¦ 0- äººè„¸æŠ“拍报警
            m_strAlarmInfo.byFaceAlarmDetection = 0;
            //报警图片数据类型，按位表示：
            //bit0- äººè„¸æŠ“拍(报警类型为COMM_UPLOAD_FACESNAP_RESULT)中图片数据上传类型：0- äºŒè¿›åˆ¶ä¼ è¾“，1- URL传输
            //bit1- EVENT_JSON(报警类型为COMM_VCA_ALARM)中图片数据上传类型：0- äºŒè¿›åˆ¶ä¼ è¾“，1- URL传输
            //bit2- äººè„¸æ¯”对(报警类型为COMM_SNAP_MATCH_ALARM)中图片数据上传类型：0- äºŒè¿›åˆ¶ä¼ è¾“，1- URL传输
            m_strAlarmInfo.byAlarmTypeURL = 0;
            m_strAlarmInfo.write();
            // å¸ƒé˜²æˆåŠŸï¼Œè¿”回布防成功的数据传输通道号
            lAlarmHandle = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID, m_strAlarmInfo);
@@ -535,4 +360,67 @@
        return name;
    }

    //获取IP通道
    public static void getIPChannelInfo(String deviceId, int iUserID) {
        try {
            GlobalVariable.deviceChanMap.remove(deviceId);
            List<ChannelInfo> channelInfoList = new ArrayList<>();
            int chanNum = 64;
            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(iUserID, HCNetSDK.NET_DVR_GET_IPPARACFG_V40, 0, lpIpParaConfig, m_strIpparaCfg.size(), ibrBytesReturned);
            m_strIpparaCfg.read();
            //log.debug("起始数字通道号：" + m_strIpparaCfg.dwStartDChan);
            for (int iChannum = 0; iChannum < chanNum; iChannum++) {
                int channum = iChannum + m_strIpparaCfg.dwStartDChan;
                HCNetSDK.NET_DVR_PICCFG_V40 strPicCfg = new HCNetSDK.NET_DVR_PICCFG_V40();
                strPicCfg.dwSize = strPicCfg.size();
                strPicCfg.write();
                Pointer pStrPicCfg = strPicCfg.getPointer();
                NativeLong lChannel = new NativeLong(channum);
                IntByReference pInt = new IntByReference(0);
                boolean b_GetPicCfg = hCNetSDK.NET_DVR_GetDVRConfig(iUserID, HCNetSDK.NET_DVR_GET_PICCFG_V40, lChannel.intValue(),
                        pStrPicCfg, strPicCfg.size(), pInt);
//            if (b_GetPicCfg == false) {
//                System.out.println("获取图像参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());
//            }
                strPicCfg.read();
                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();

                    //log.debug("--------------第" + (iChannum + 1) + "个通道------------------");
                    int channel = m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPID + m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPIDHigh * 256;
                    //log.debug("channel:" + channel);
                    if (channel > 0) {
                        //log.debug("name： " + new String(strPicCfg.sChanName, "GBK").trim());
                        //log.debug("ip： " + new String(m_strIpparaCfg.struIPDevInfo[channel - 1].struIP.sIpV4).trim());
                        //log.debug("port： " + m_strIpparaCfg.struIPDevInfo[channel - 1].wDVRPort);
                        String name = new String(strPicCfg.sChanName, "GBK").trim();
                        String ip = new String(m_strIpparaCfg.struIPDevInfo[channel - 1].struIP.sIpV4).trim();
                        int port = m_strIpparaCfg.struIPDevInfo[channel - 1].wDVRPort;
                        ChannelInfo channelInfo = new ChannelInfo();
                        channelInfo.setIp(ip);
                        channelInfo.setPort(port);
                        channelInfo.setName(name);
                        channelInfoList.add(channelInfo);
                    }
                    if (m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byEnable == 1) {
                        //log.debug("IP通道" + channum + "在线");
                    } else {
                        //log.debug("IP通道" + channum + "不在线");
                    }
                }
            }
            if (channelInfoList.size() > 0) {
                GlobalVariable.deviceChanMap.put(deviceId, channelInfoList);
            }
        } catch (Exception ex) {
            log.error("获取IP通道异常：" + ex.getMessage());
        }
    }
}

 src/main/java/com/ard/utils/sdk/hiksdk/service/impl/LoginResultCallBack.java

@@ -28,6 +28,11 @@
        if (dwResult == 1) {
            GlobalVariable.loginMap.put(deviceInfo.getDeviceId(), lUserID);
            log.debug("设备【" + deviceIpPort + "】登录成功");
            //获取通道
            if(deviceInfo.getDeviceType().equals("3")) {
                //仅超脑设备获取通道
                HikClientUtil.getIPChannelInfo(deviceInfo.getDeviceId(), lUserID);
            }
            // è®¾ç½®æŠ¥è­¦å›žè°ƒå‡½æ•°ï¼Œå»ºç«‹æŠ¥è­¦ä¸Šä¼ é€šé“（启用布防）
            int lAlarmHandle = HikClientUtil.setupAlarmChan(deviceIpPort, lUserID, -1);
            if (lAlarmHandle != -1) {

 src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java

@@ -2257,7 +2257,7 @@
        public byte byChannel;                    /* é€šé“号 */
        public byte[] byres = new byte[33];                    /* ä¿ç•™ */


        public int byIPIDHigh;
    }

    public static class NET_DVR_IPPARACFG extends HIKSDKStructure {/* IP接入配置结构 */