增加超脑业务

‘liusuyi’

2023-11-09 092d7c56bb8653075b8f4b27220e69e6bb8e5d37

增加超脑业务

 src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java

@@ -19,6 +19,8 @@
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;


/**
 * externalService业务层处理
@@ -35,12 +37,12 @@

    public static List<ArdEquipExternal> ardAlarmHostList = new ArrayList<>();
    public static List<ArdEquipExternal> ardAccessHostList = new ArrayList<>();

    @Autowired
    public static List<ArdEquipExternal> ardSuperBrainHostList = new ArrayList<>();
    @Resource
    private ArdEquipExternalMapper ardEquipExternalMapper;

    @Override
    public void run(ApplicationArguments args){
    public void run(ApplicationArguments args) {
        //获取全部海康报警主机尝试登录
        ArdEquipExternal alarmHost = new ArdEquipExternal();
        alarmHost.setFactory("1");
@@ -55,6 +57,13 @@
        ardAccessHostList = selectArdEquipExternalList(accessControlHost);
        HikClientUtil.loginAllAccessControlHost(ardAccessHostList);
        log.debug("门禁主机尝试登录");
        //获取全部超脑尝试登录
        ArdEquipExternal superBrainHost = new ArdEquipExternal();
        superBrainHost.setFactory("1");
        superBrainHost.setType("5");
        ardSuperBrainHostList = selectArdEquipExternalList(superBrainHost);
        HikClientUtil.loginAllSuperBrainHost(ardSuperBrainHostList);
        log.debug("超脑尝试登录");
        //同步任务
        syncTask();
    }
@@ -99,10 +108,10 @@

                //endregion
                //region 定时同步门禁主机
                alarmHost = new ArdEquipExternal();
                alarmHost.setFactory("1");
                alarmHost.setType("6");
                List<ArdEquipExternal> newAccessHostList = selectArdEquipExternalList(alarmHost);
                ArdEquipExternal accessHost = new ArdEquipExternal();
                accessHost.setFactory("1");
                accessHost.setType("6");
                List<ArdEquipExternal> newAccessHostList = selectArdEquipExternalList(accessHost);
                //需要更新的数据
                updateList = sameListWithDifferent(ardAccessHostList, newAccessHostList);
                if (updateList.size() > 0) {
@@ -128,6 +137,36 @@
                    }
                }
                //endregion
                //region 定时同步超脑
                ArdEquipExternal superBrainHost = new ArdEquipExternal();
                superBrainHost.setFactory("1");
                superBrainHost.setType("5");
                List<ArdEquipExternal> newSuperBrainList = selectArdEquipExternalList(superBrainHost);
                //需要更新的数据
                updateList = sameListWithDifferent(ardSuperBrainHostList, newSuperBrainList);
                if (updateList.size() > 0) {
                    HikClientUtil.logoutAllSuperBrainHost(updateList);
                    HikClientUtil.loginAllSuperBrainHost(updateList);
                    ardSuperBrainHostList.clear();
                    ardSuperBrainHostList.addAll(newSuperBrainList);
                }
                //需要删除的数据
                delList = diffList(ardSuperBrainHostList, newSuperBrainList);
                if (delList.size() > 0) {
                    HikClientUtil.logoutAllSuperBrainHost(delList);
                    for (ArdEquipExternal ardEquipExternal : delList) {
                        ardSuperBrainHostList.remove(ardEquipExternal);
                    }
                }
                //需要新增的数据
                inserList = diffList(newSuperBrainList, ardSuperBrainHostList);
                if (inserList.size() > 0) {
                    HikClientUtil.loginAllSuperBrainHost(inserList);
                    for (ArdEquipExternal ardEquipExternal : inserList) {
                        ardSuperBrainHostList.add(ardEquipExternal);
                    }
                }
                //endregion
            } catch (Exception e) {
                log.error("同步外联任务执行出错" + e.getMessage());
            }
@@ -148,7 +187,7 @@

    @Override
    public ArdEquipExternal selectArdEquipExternal(ArdEquipExternal ardEquipExternal) {
        QueryWrapper<ArdEquipExternal> queryWrapper=new QueryWrapper<>(ardEquipExternal);
        QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
        return ardEquipExternalMapper.selectOne(queryWrapper);
    }

@@ -160,7 +199,7 @@
     */
    @Override
    public List<ArdEquipExternal> selectArdEquipExternalList(ArdEquipExternal ardEquipExternal) {
        QueryWrapper<ArdEquipExternal> queryWrapper=new QueryWrapper<>(ardEquipExternal);
        QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
        return ardEquipExternalMapper.selectList(queryWrapper);
    }


 src/main/java/com/ard/alarm/radar/controller/RadarController.java

@@ -9,12 +9,15 @@
import com.ard.utils.tcp.ClientInitialize;
import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;

/**
 * @Description: 雷达接口
@@ -24,6 +27,7 @@
 **/
@RestController
@RequestMapping("/radar")
@Slf4j(topic = "netty")
public class RadarController {

    @Resource
@@ -55,14 +59,19 @@
        radarPosition[1] = latitude;
        double distance = GisUtils.getDistance(radarPosition, targetPosition);
        float angleInRadians = (float)Math.atan(distance / altitude);
        float t = 90-(float)Math.toDegrees(angleInRadians);

        float t = (90-(float)Math.toDegrees(angleInRadians))*-1;
        log.debug("distance："+distance);
        log.debug("p："+p);
        log.debug("t："+t);
        //发送告警前端的角度提示
        byte[] header = {0x01, 0x02, 0x01};//包头
        byte[] payloadHeader = {0x10, 0x03, 0x40, 0x00};//负载头
        byte[] payloadHeader = {0x10, 0x03, 0x20, 0x00};//负载头
        byte[] distanceBytes = ByteUtils.decimalToBytes((int)distance);
        distanceBytes=ByteUtils.toLittleEndian(distanceBytes);
        byte[] pBytes = ByteUtils.floatToBytes(p);
        pBytes=ByteUtils.toLittleEndian(pBytes);
        byte[] tBytes = ByteUtils.floatToBytes(t);
        tBytes=ByteUtils.toLittleEndian(tBytes);
        byte[] resBytes=new byte[20];
        byte[] payloadBody = ByteUtils.appendArrays(distanceBytes,pBytes,tBytes,resBytes);//负载


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

@@ -54,22 +54,23 @@
        String sTime;//事件时间
        String url = "";//事件图片
        //lCommand是传的报警类型
        //log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
        log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
        ArdCameras ardCameras = new ArdCameras();
        ardCameras.setIp(sDeviceIP);
        ardCameras.setPort(wLinkPort);
        IArdCamerasService ardCamerasService = SpringUtils.getBean(IArdCamerasService.class);
        List<ArdCameras> ardCamerasList = ardCamerasService.selectArdCamerasList(ardCameras);
        if (ardCamerasList.size() > 0) {
            ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
            switch (lCommand) {
                case HCNetSDK.COMM_ALARM_V30:
                    //log.debug("移动侦测");
                    HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
                    netDvrAlarminfoV30.write();
                    Pointer pNDAInfo = netDvrAlarminfoV30.getPointer();
                    pNDAInfo.write(0, pAlarmInfo.getByteArray(0, netDvrAlarminfoV30.size()), 0, netDvrAlarminfoV30.size());
                    netDvrAlarminfoV30.read();
        switch (lCommand) {
            //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
            case HCNetSDK.COMM_ALARM_V30:
                //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
                HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
                netDvrAlarminfoV30.write();
                Pointer pNDAInfo = netDvrAlarminfoV30.getPointer();
                pNDAInfo.write(0, pAlarmInfo.getByteArray(0, netDvrAlarminfoV30.size()), 0, netDvrAlarminfoV30.size());
                netDvrAlarminfoV30.read();
                if (ardCamerasList.size() > 0) {
                    ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
                    switch (netDvrAlarminfoV30.dwAlarmType) {
                        case 3:
                            info = new CameraEventInfo();
@@ -90,21 +91,26 @@
                            publishMqtt(info);
                            break;
                    }
                case HCNetSDK.COMM_ALARM_RULE:
                    //log.debug("行为分析信息报警信息上报");
                    //region 行为分析信息
                    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();
                    Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
                    sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
                    String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
                    Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
                    info = new CameraEventInfo();
                    info.setAlarmName("人员行为分析");
                    info.setAlarmTime(sTime);
                }
                //endregion
                break;
            case HCNetSDK.COMM_ALARM_RULE:
                //log.debug("行为分析信息报警信息上报");
                //region 异常行为识别信息
                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();
                Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
                sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
                String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
                Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
                info = new CameraEventInfo();
                info.setAlarmName("人员行为分析");
                info.setAlarmTime(sTime);
                if (ardCamerasList.size() > 0) {
                    ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
                    info.setCameraName(camera.getName());
                    info.setCameraId(camera.getId());
                    info.setCameraIp(camera.getIp());
@@ -171,217 +177,218 @@
                            // log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
                            break;
                    }
                    //endregion
                    break;
                case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
                    //log.debug("人脸检测事件上报(暂不解析)");
                    break;
                case HCNetSDK.COMM_GISINFO_UPLOAD:
                    //log.debug("GPS报警信息上报(暂不解析)");
                    break;
                case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
                    //log.debug("报警主机CID报告报警上报");
                    //region 报警主机报警处理
                    ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
                    ardEquipExternal.setIp(sDeviceIP);
                    ardEquipExternal.setPort(wLinkPort);
                    IArdEquipExternalService ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
                    ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal);
                }
                //endregion
                break;
            case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
                //log.debug("人脸检测事件上报(暂不解析)");
                break;
            case HCNetSDK.COMM_GISINFO_UPLOAD:
                //log.debug("GPS报警信息上报(暂不解析)");
                break;
            case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
                log.debug("报警主机CID报告报警上报");
                //region 报警主机报警处理
                ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
                ardEquipExternal.setIp(sDeviceIP);
                ardEquipExternal.setPort(wLinkPort);
                IArdEquipExternalService ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
                ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal);

                    HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
                    netDvrCidAlarm.write();
                    Pointer pCIDInfo = netDvrCidAlarm.getPointer();
                    pCIDInfo.write(0, pAlarmInfo.getByteArray(0, netDvrCidAlarm.size()), 0, netDvrCidAlarm.size());
                    netDvrCidAlarm.read();
                    //CID事件名
                    String sCIDCode = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDCode);//CID事件名
                    //CID事件名
                    //String sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);//CID事件名
                    int position = ByteUtils.findIndexOfDoubleZero(netDvrCidAlarm.sCIDDescribe);
                    String sCIDDescribe;
                    if (position != -1) {
                        byte[] result = new byte[position];
                        System.arraycopy(netDvrCidAlarm.sCIDDescribe, 0, result, 0, position);
                        sCIDDescribe = ByteUtils.bytesToStringZh(result);
                    } else {
                        sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);
                    }
                    //触发报警的时间点
                    String struTriggerTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struTriggerTime), "yyyy-M-d H:m:s");
                    //上传报警的时间点
                    String struUploadTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struUploadTime), "yyyy-M-d H:m:s");
                    //报告类型
                    String byReportType = "";
                    switch (netDvrCidAlarm.byReportType) {
                        case 1:
                            byReportType = "防区报警";
                            break;
                        case 2:
                            byReportType = "视频报警";
                            break;
                        case 3:
                            byReportType = "软防区报警";
                            break;
                        case 4:
                            byReportType = "挟持报警";
                            break;
                        case 5:
                            byReportType = "防拆报警 ";
                            break;
                        case 6:
                            byReportType = "操作报告 ";
                            break;
                        case 7:
                            byReportType = "异常报告 ";
                            break;
                    }
                    //子系统号
                    Integer bySubSysNo = Integer.valueOf(netDvrCidAlarm.bySubSysNo);
                    //防区号 起始0
                    Integer wDefenceNo = Integer.valueOf(netDvrCidAlarm.wDefenceNo);
                    //防区名称
                    String wDefenceName = "";
                    if (!bySubSysNo.equals(-1)) {
                        CameraCmd cmd = new CameraCmd();
                        cmd.setCameraId(ardEquipExternal.getId());
                        cmd.setWZoneIndex(wDefenceNo);
                        wDefenceName = HikClientUtil.getDefenseZoneName(cmd);
                    }
                    if (sCIDDescribe.contains("恢复")) {
                        return true;
                    }

                    ExternalAlarmEventInfo externalAlarmEventInfo = new ExternalAlarmEventInfo();
                    externalAlarmEventInfo.setAlarmId(sCIDCode);
                    externalAlarmEventInfo.setAlarmName(sCIDDescribe);
                    externalAlarmEventInfo.setDefenseId((wDefenceNo + 1));
                    externalAlarmEventInfo.setDefenseName(wDefenceName);
                    externalAlarmEventInfo.setSubSysNo(bySubSysNo);
                    externalAlarmEventInfo.setAlarmType(byReportType);
                    externalAlarmEventInfo.setAlarmTime(struTriggerTime);
                    externalAlarmEventInfo.setAlarmHostId(ardEquipExternal.getId());
                    publishMqtt(externalAlarmEventInfo);
                    //endregion
                    break;
                case HCNetSDK.COMM_ALARM_ACS:
                    //region 门禁主机报警处理
                    ArdEquipExternal accessControlHost = new ArdEquipExternal();
                    accessControlHost.setIp(sDeviceIP);
                    accessControlHost.setPort(wLinkPort);
                    ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
                    accessControlHost = ardEquipExternalService.selectArdEquipExternal(accessControlHost);
                    HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
                    strACSInfo.write();
                    Pointer acsInfo = strACSInfo.getPointer();
                    acsInfo.write(0, pAlarmInfo.getByteArray(0, strACSInfo.size()), 0, strACSInfo.size());
                    strACSInfo.read();
                    int dwMajor = strACSInfo.dwMajor;

                    if (dwMajor != 5) {
                        //只获取事件
                        // log.debug("非事件报警数据上报(暂不解析)");
                HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
                netDvrCidAlarm.write();
                Pointer pCIDInfo = netDvrCidAlarm.getPointer();
                pCIDInfo.write(0, pAlarmInfo.getByteArray(0, netDvrCidAlarm.size()), 0, netDvrCidAlarm.size());
                netDvrCidAlarm.read();
                //CID事件名
                String sCIDCode = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDCode);//CID事件名
                //CID事件名
                //String sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);//CID事件名
                int position = ByteUtils.findIndexOfDoubleZero(netDvrCidAlarm.sCIDDescribe);
                String sCIDDescribe;
                if (position != -1) {
                    byte[] result = new byte[position];
                    System.arraycopy(netDvrCidAlarm.sCIDDescribe, 0, result, 0, position);
                    sCIDDescribe = ByteUtils.bytesToStringZh(result);
                } else {
                    sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);
                }
                //触发报警的时间点
                String struTriggerTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struTriggerTime), "yyyy-M-d H:m:s");
                //上传报警的时间点
                String struUploadTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struUploadTime), "yyyy-M-d H:m:s");
                //报告类型
                String byReportType = "";
                switch (netDvrCidAlarm.byReportType) {
                    case 1:
                        byReportType = "防区报警";
                        break;
                    }

                    int dwMinor = strACSInfo.dwMinor;
                    if (dwMinor != 80 && dwMinor != 104) {
                        //只解析真人检测失败和人脸抓拍失败的次类型事件
                    case 2:
                        byReportType = "视频报警";
                        break;
                    }
                    String alarmType = "";
                    switch (dwMinor) {
                        case 104:
                            alarmType = "真人检测失败";
                            break;
                        case 80:
                            alarmType = "人脸抓拍失败";
                            break;
                    }
                    log.debug("门禁主机报警上传:" + alarmType);
                    String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
                    case 3:
                        byReportType = "软防区报警";
                        break;
                    case 4:
                        byReportType = "挟持报警";
                        break;
                    case 5:
                        byReportType = "防拆报警 ";
                        break;
                    case 6:
                        byReportType = "操作报告 ";
                        break;
                    case 7:
                        byReportType = "异常报告 ";
                        break;
                }
                //子系统号
                Integer bySubSysNo = Integer.valueOf(netDvrCidAlarm.bySubSysNo);
                //防区号 起始0
                Integer wDefenceNo = Integer.valueOf(netDvrCidAlarm.wDefenceNo);
                //防区名称
                String wDefenceName = "";
                if (!bySubSysNo.equals(-1)) {
                    CameraCmd cmd = new CameraCmd();
                    cmd.setCameraId(ardEquipExternal.getId());
                    cmd.setWZoneIndex(wDefenceNo);
                    wDefenceName = HikClientUtil.getDefenseZoneName(cmd);
                }
                if (sCIDDescribe.contains("恢复")) {
                    return true;
                }

                    //事件图片处理
                    int 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) {
                                url = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                                //log.debug("上传文件成功!" + url);
                            }
                        } catch (Exception e) {
                            log.error("图片保存失败");
                ExternalAlarmEventInfo externalAlarmEventInfo = new ExternalAlarmEventInfo();
                externalAlarmEventInfo.setAlarmId(sCIDCode);
                externalAlarmEventInfo.setAlarmName(sCIDDescribe);
                externalAlarmEventInfo.setDefenseId((wDefenceNo + 1));
                externalAlarmEventInfo.setDefenseName(wDefenceName);
                externalAlarmEventInfo.setSubSysNo(bySubSysNo);
                externalAlarmEventInfo.setAlarmType(byReportType);
                externalAlarmEventInfo.setAlarmTime(struTriggerTime);
                externalAlarmEventInfo.setAlarmHostId(ardEquipExternal.getId());
                publishMqtt(externalAlarmEventInfo);
                //endregion
                break;
            case HCNetSDK.COMM_ALARM_ACS:
                log.debug("门禁主机报警上报");
                //region 门禁主机报警处理
                ArdEquipExternal accessControlHost = new ArdEquipExternal();
                accessControlHost.setIp(sDeviceIP);
                accessControlHost.setPort(wLinkPort);
                ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
                accessControlHost = ardEquipExternalService.selectArdEquipExternal(accessControlHost);
                HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
                strACSInfo.write();
                Pointer acsInfo = strACSInfo.getPointer();
                acsInfo.write(0, pAlarmInfo.getByteArray(0, strACSInfo.size()), 0, strACSInfo.size());
                strACSInfo.read();
                int dwMajor = strACSInfo.dwMajor;

                if (dwMajor != 5) {
                    //只获取事件
                    // log.debug("非事件报警数据上报(暂不解析)");
                    break;
                }

                int dwMinor = strACSInfo.dwMinor;
                if (dwMinor != 80 && dwMinor != 104) {
                    //只解析真人检测失败和人脸抓拍失败的次类型事件
                    break;
                }
                String alarmType = "";
                switch (dwMinor) {
                    case 104:
                        alarmType = "真人检测失败";
                        break;
                    case 80:
                        alarmType = "人脸抓拍失败";
                        break;
                }
                log.debug("门禁主机报警上传:" + alarmType);
                String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");

                //事件图片处理
                int 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) {
                            url = MinioUtil.getBucketObjectUrl(bucketName, objectName);
                            //log.debug("上传文件成功!" + url);
                        }
                    } catch (Exception e) {
                        log.error("图片保存失败");
                    }
                    HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
                    int byType = struAcsEventInfo.byType;
                    String defenseType = "";
                    switch (byType) {
                        case 0:
                            defenseType = "即时防区";
                            break;
                        case 1:
                            defenseType = "24小时防区";
                            break;
                        case 2:
                            defenseType = "延时防区";
                            break;
                        case 3:
                            defenseType = "内部防区";
                            break;
                        case 4:
                            defenseType = "钥匙防区";
                            break;
                        case 5:
                            defenseType = "火警防区";
                            break;
                        case 6:
                            defenseType = "周界防区";
                            break;
                        case 7:
                            defenseType = "24小时无声防区";
                            break;
                        case 8:
                            defenseType = "24小时辅助防区";
                            break;
                        case 9:
                            defenseType = "24小时震动防区";
                            break;
                        case 10:
                            defenseType = "门禁紧急开门防区";
                            break;
                        case 11:
                            defenseType = "门禁紧急关门防区";
                            break;
                        default:
                            defenseType = "无";
                            break;
                    }
                    AccessControlHostEventInfo accessControlHostEventInfo = new AccessControlHostEventInfo();
                    accessControlHostEventInfo.setSerialNo(struAcsEventInfo.dwSerialNo);
                    accessControlHostEventInfo.setAlarmType(alarmType);
                    accessControlHostEventInfo.setDoorNo(struAcsEventInfo.dwDoorNo);
                    accessControlHostEventInfo.setDefenseType(defenseType);
                    accessControlHostEventInfo.setAlarmTime(alarmTime);
                    accessControlHostEventInfo.setPicUrl(url);
                    accessControlHostEventInfo.setAcsId(accessControlHost.getId());
                    publishMqtt(accessControlHostEventInfo);
                    //endregion
                    break;
                default:
                    // log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
                    break;
                }
                HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
                int byType = struAcsEventInfo.byType;
                String defenseType = "";
                switch (byType) {
                    case 0:
                        defenseType = "即时防区";
                        break;
                    case 1:
                        defenseType = "24小时防区";
                        break;
                    case 2:
                        defenseType = "延时防区";
                        break;
                    case 3:
                        defenseType = "内部防区";
                        break;
                    case 4:
                        defenseType = "钥匙防区";
                        break;
                    case 5:
                        defenseType = "火警防区";
                        break;
                    case 6:
                        defenseType = "周界防区";
                        break;
                    case 7:
                        defenseType = "24小时无声防区";
                        break;
                    case 8:
                        defenseType = "24小时辅助防区";
                        break;
                    case 9:
                        defenseType = "24小时震动防区";
                        break;
                    case 10:
                        defenseType = "门禁紧急开门防区";
                        break;
                    case 11:
                        defenseType = "门禁紧急关门防区";
                        break;
                    default:
                        defenseType = "无";
                        break;
                }
                AccessControlHostEventInfo accessControlHostEventInfo = new AccessControlHostEventInfo();
                accessControlHostEventInfo.setSerialNo(struAcsEventInfo.dwSerialNo);
                accessControlHostEventInfo.setAlarmType(alarmType);
                accessControlHostEventInfo.setDoorNo(struAcsEventInfo.dwDoorNo);
                accessControlHostEventInfo.setDefenseType(defenseType);
                accessControlHostEventInfo.setAlarmTime(alarmTime);
                accessControlHostEventInfo.setPicUrl(url);
                accessControlHostEventInfo.setAcsId(accessControlHost.getId());
                publishMqtt(accessControlHostEventInfo);
                //endregion
                break;
            default:
                log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
                break;

            }
        }
        return true;
    }

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

@@ -124,7 +124,7 @@
        int i = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);

        if (i < 0) {

            int errorCode = hCNetSDK.NET_DVR_GetLastError();

            log.info("登录异常：" + errorCode);

            log.error("登录异常：" + errorCode);

        }

    }



@@ -221,7 +221,7 @@
//                GlobalVariable.alarmHostMap.put(key, alarmHost);

            }

        } catch (Exception ex) {

            log.error("初始化报警主机异常：" + ex.getMessage());

            log.error("登录所有报警主机异常：" + ex.getMessage());

        }

    }



@@ -245,7 +245,7 @@
//                GlobalVariable.alarmHostMap.remove(key);

            }

        } catch (Exception ex) {

            log.error("初始化登录相机异常：" + ex.getMessage());

            log.error("登出所有报警主机异常：" + ex.getMessage());

        }

    }



@@ -270,7 +270,7 @@
//                GlobalVariable.accessHostMap.put(key, accessControlHost);

            }

        } catch (Exception ex) {

            log.error("初始化报警主机异常：" + ex.getMessage());

            log.error("登录所有门禁主机异常：" + ex.getMessage());

        }

    }



@@ -294,10 +294,57 @@
//                GlobalVariable.accessHostMap.remove(key);

            }

        } catch (Exception ex) {

            log.error("初始化报警主机异常：" + ex.getMessage());

            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);

//

//                String key=accessControlHost.getIp()+":"+accessControlHost.getPort();

//                GlobalVariable.accessHostMap.put(key, accessControlHost);

            }

        } 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());

        }

    }



    /**

     * 建立布防上传通道，用于传输数据

@@ -323,7 +370,7 @@
            HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();

            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();

            // 智能交通布防优先级：0 - 一等级（高），1 - 二等级（中），2 - 三等级（低）

            m_strAlarmInfo.byLevel = 2;

            m_strAlarmInfo.byLevel = 0;

            // 智能交通报警信息上传类型：0 - 老报警信息（NET_DVR_PLATE_RESULT）, 1 - 新报警信息(NET_ITS_PLATE_RESULT)

            m_strAlarmInfo.byAlarmInfoType = 1;

            // 布防类型(仅针对门禁主机、人证设备)：0 - 客户端布防(会断网续传)，1 - 实时布防(只上传实时数据)


 src/main/java/com/ard/utils/other/ByteUtils.java

@@ -30,13 +30,27 @@
     * byte数组转中文字符串
     */
    public static String bytesToStringZh(byte[] bytes) {
        ByteBuffer buffer = ByteBuffer.wrap(bytes); // byteArray 是包含字节数组的变量
        //ByteBuffer buffer = ByteBuffer.wrap(bytes); // byteArray 是包含字节数组的变量
        //try {
        //    return new String(buffer.array(), "GBK");
        //} catch (UnsupportedEncodingException e) {
        //    e.printStackTrace();
        //}
        //return "";
        String zhStr = "";
        try {
            return new String(buffer.array(), "GBK");
            int position = ByteUtils.findIndexOfDoubleZero(bytes);
            if (position != -1) {
                byte[] result = new byte[position];
                System.arraycopy(bytes, 0, result, 0, position);
                zhStr = new String(result, "GBK");
            } else {
                zhStr = new String(bytes, "GBK");
            }
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return "";
        return zhStr;
    }

    /**
@@ -67,8 +81,13 @@
     * byte数组转整型
     */
    public static int bytesToDecimal(byte[] byteArray) {
        ByteBuffer buffer = ByteBuffer.wrap(byteArray); // byteArray 是包含字节数组的变量
        return buffer.getInt();
        //ByteBuffer buffer = ByteBuffer.wrap(byteArray); // byteArray 是包含字节数组的变量
        //return buffer.getInt();
        int decimalValue = 0;
        for (int i = 0; i < byteArray.length; i++) {
            decimalValue = (decimalValue << 8) | (byteArray[i] & 0xFF);
        }
        return decimalValue;
    }



 src/main/java/com/ard/utils/tcp/ClientHandler.java

@@ -175,7 +175,7 @@
            if (!crc32Check) {
                log.debug("CRC32校验不通过");
            } else {
                log.debug("CRC32校验通过");
                //log.debug("CRC32校验通过");
            }
            //endregion
            //log.info("原始数据:" + DatatypeConverter.printHexBinary(data));
@@ -188,6 +188,7 @@
            //  log.info("命令ID:" + DatatypeConverter.printHexBinary(cmdId));
            byte[] payloadSize = Arrays.copyOfRange(data, 2, 4);//有效负载大小
            payloadSize = ByteUtils.toLittleEndian(payloadSize);
            //log.info("payloadSize:" + DatatypeConverter.printHexBinary(payloadSize));
            int payloadSizeToDecimal = ByteUtils.bytesToDecimal(payloadSize);
            // log.info("有效负载大小(转整型):" + payloadSizeToDecimal);
            //endregion
@@ -461,13 +462,17 @@
                log.debug("方位:" + tx);
                byte[] fTy = Arrays.copyOfRange(data, 12, 16);
                fTy = ByteUtils.toLittleEndian(fTy);
                float ty= ByteUtils.bytesToFloat(fTy);
                float ty = ByteUtils.bytesToFloat(fTy);
                if (ty < 0) {
                    ty += 360;
                }
                log.debug("俯仰:" + ty);
                Map<String,Object>forceGuideMap=new HashMap<>();
                forceGuideMap.put("p",tx);
                forceGuideMap.put("t",ty);
                forceGuideMap.put("z",1);
                forceGuideMap.put("radarId",radarId);
                Map<String, Object> forceGuideMap = new HashMap<>();
                forceGuideMap.put("distance", distance);
                forceGuideMap.put("p", tx);
                forceGuideMap.put("t", ty);
                forceGuideMap.put("radarId", radarId);
                log.debug("强制引导信息" + forceGuideMap);
                //endregion
                MqttProducer.publish(2, false, "radarForceGuide", JSON.toJSONString(forceGuideMap));
            }
@@ -475,5 +480,4 @@
            log.error("雷达报文解析异常:" + ex.getMessage());
        }
    }

}
}