优化sql框架使用mybatis-plus代替mybatis

‘liusuyi’

2023-09-25 e71d3d823093bafe0283a57aa640928709d09434

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

@@ -6,17 +6,17 @@
import com.ard.alarm.camera.service.IArdCamerasService;
import com.ard.alarm.external.domain.ArdEquipExternal;
import com.ard.alarm.external.service.IArdEquipExternalService;
import com.ard.config.MinioClientSingleton;
import com.ard.utils.minio.MinioUtil;
import com.ard.utils.other.ByteUtils;
import com.ard.utils.hiksdk.common.GlobalVariable;
import com.ard.utils.hiksdk.domain.AccessControlHostEventInfo;
import com.ard.utils.hiksdk.domain.CameraEventInfo;
import com.ard.utils.hiksdk.domain.ExternalAlarmEventInfo;
import com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK;
import com.ard.utils.hiksdk.util.minio.MinioUtils;
import com.ard.utils.other.DateUtils;
import com.ard.utils.other.SpringTool;
import com.ard.utils.mqtt.MqttConsumer;
import com.ard.utils.spring.SpringUtils;
import com.ard.utils.uuid.IdUtils;
import com.sun.jna.Pointer;
import lombok.extern.slf4j.Slf4j;

@@ -24,6 +24,7 @@
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

/**
 * @ClassName: FMSGCallBack
@@ -32,7 +33,7 @@
 * @Date: 2023年02月15日 12:16
 * @Version: 1.0
 **/
@Slf4j(topic = "hiksdk")
@Slf4j(topic = "hikSdk")
public class FMSGCallBack implements HCNetSDK.FMSGCallBack_V31 {

    /**
@@ -46,360 +47,360 @@
     */
    @Override
    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {

        String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);
        Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);

        SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);//设备IP地址
        Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口
        CameraEventInfo info;
        String sTime;//事件时间
        String url = "";//事件图片
        //lCommand是传的报警类型
        switch (lCommand) {
            case HCNetSDK.COMM_ALARM_RULE:
                //region 行为分析信息
                ArdCameras ardCameras = new ArdCameras();
                ardCameras.setIp(sDeviceIP);
                ardCameras.setPort(wLinkPort);
                IArdCamerasService ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class);
                ArdCameras ardcamere = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
                log.info("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
                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);//通道
                CameraEventInfo info = new CameraEventInfo();
                info.setAlarmName("人员行为分析");
                info.setAlarmTime(sTime);
                info.setCameraName(ardcamere.getName());
                info.setCameraId(ardcamere.getId());
                info.setCameraIp(ipaddr);
                info.setCameraType(ardcamere.getGdtype());
                info.setCameraChannel(channel);
                info.setLongitude(ardcamere.getLongitude());
                info.setLatitude(ardcamere.getLatitude());
                info.setAlarmType(ardcamere.getGdtype());
                info.setRuleId(ruleID);
                switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
                    case 1: //region穿越警戒面 (越界侦测)
                        info.setAlarmType("越界侦测报警");
                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_TRAVERSE_PLANE.class);
                        //endregion
                        break;
                    case 2: //region 目标进入区域
                        info.setAlarmType("目标进入区域报警");
                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
                        //endregion
                        break;
                    case 3: //region 目标离开区域
                        info.setAlarmType("目标离开区域报警");
                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
                        //endregion
                        break;
                    case 4: //region 周界入侵
                        info.setAlarmType("周界入侵报警");
                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class);
                        //endregion
                        break;
                    case 5: //region 徘徊
                        info.setAlarmType("徘徊事件报警");
                        //endregion
                        break;
                    case 8: //region 快速移动(奔跑)
                        info.setAlarmType("快速移动(奔跑)事件报警");
                        //endregion
                        break;
                    case 13: //region 物品遗留事件
                        info.setAlarmType("物品遗留事件报警");
                        //endregion
                        break;
                    case 14: //region 物品拿取事件
                        info.setAlarmType("物品拿取事件事件报警");
                        //endregion
                        break;
                    case 20: //region 倒地检测
                        info.setAlarmType("倒地事件触发");
                        //endregion
                        break;
                    case 44: //region 玩手机
                        info.setAlarmType("玩手机报警事件");
                        //endregion
                        break;
                    default:
                        log.info("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
                        printLog(info);
                        break;
                }
                //endregion
                //图片存入minio
                url = savePicture(info);
                info.setPicUrl(url);
                publishMqtt(info);
                break;
            case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
                log.info("人脸检测事件上报");
                break;
            case HCNetSDK.COMM_GISINFO_UPLOAD:
                log.info("GPS报警信息上报");
                break;
            case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
                log.info("报警主机 CID 报告报警上传");
                //region 报警主机报警处理
                ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
                ardEquipExternal.setIp(sDeviceIP);
                ardEquipExternal.setPort(wLinkPort);
                IArdEquipExternalService ardEquipExternalService = SpringTool.getApplicationContext().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 = SpringTool.getApplicationContext().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) {
                    //只获取事件
                    break;
                }
                int dwMinor = strACSInfo.dwMinor;
                if (dwMinor != 80 && dwMinor != 104) {
                    //只解析真人检测失败和人脸抓拍失败的次类型事件
                    break;
                }
//                log.info("门禁主机报警上传");
//                log.info("【主类型】事件");
                String alarmType = "";
                switch (dwMinor) {
                    case 104:
                        alarmType = "真人检测失败";
                        break;
                    case 80:
                        alarmType = "人脸抓拍失败";
                        break;
                }
                String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");

                //事件图片处理
                int dwPicDataLen = strACSInfo.dwPicDataLen;
                if (dwPicDataLen > 0) {
                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
                    String newName = sf.format(new Date());
                    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_" + newName + ".jpeg";
                        boolean uploadObject = MinioUtils.uploadObject(bucketName, objectName, input, "image/JPEG");
                        if (uploadObject) {
                            url = MinioClientSingleton.domainUrl + "/" + bucketName + "/" + objectName;
                            //log.debug("上传文件成功!" + url);
                        }
                    } catch (Exception e) {
                        log.error("图片保存失败");
        //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 (netDvrAlarminfoV30.dwAlarmType) {
                        case 3:
                            info = new CameraEventInfo();
                            info.setAlarmName("移动侦测");
                            info.setAlarmTime(fmt.format(new Date()));
                            info.setCameraName(camera.getName());
                            info.setCameraId(camera.getId());
                            info.setCameraIp(camera.getIp());
                            info.setCameraPort(camera.getPort());
                            info.setCameraType(camera.getGdType());
                            info.setCameraChannel(Integer.valueOf(netDvrAlarminfoV30.byChannel[0]));
                            info.setLongitude(camera.getLongitude());
                            info.setLatitude(camera.getLatitude());
                            info.setAlarmType("移动侦测");
                            //图片存入minio
                            url = savePicture(info);
                            info.setPicUrl(url);
                            publishMqtt(info);
                            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.info("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
                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);
                    info.setCameraName(camera.getName());
                    info.setCameraId(camera.getId());
                    info.setCameraIp(camera.getIp());
                    info.setCameraPort(camera.getPort());
                    info.setCameraType(camera.getGdType());
                    info.setCameraChannel(channel);
                    info.setLongitude(camera.getLongitude());
                    info.setLatitude(camera.getLatitude());
                    info.setRuleId(ruleID);
                    switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
                        case 1: //region穿越警戒面 (越界侦测)
                            info.setAlarmType("越界侦测报警");
                            strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_TRAVERSE_PLANE.class);
                            //图片存入minio
                            url = savePicture(info);
                            info.setPicUrl(url);
                            publishMqtt(info);
                            //endregion
                            break;
//                    case 2: //region 目标进入区域
//                        info.setAlarmType("目标进入区域报警");
//                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
//                        //endregion
//                        break;
//                    case 3: //region 目标离开区域
//                        info.setAlarmType("目标离开区域报警");
//                        strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
//                        //endregion
//                        break;
                        case 4: //region 周界入侵
                            info.setAlarmType("周界入侵报警");
                            strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class);
                            //图片存入minio
                            url = savePicture(info);
                            info.setPicUrl(url);
                            publishMqtt(info);
                            //endregion
                            break;
//                    case 5: //region 徘徊
//                        info.setAlarmType("徘徊事件报警");
//                        //endregion
//                        break;
//                    case 8: //region 快速移动(奔跑)
//                        info.setAlarmType("快速移动(奔跑)事件报警");
//                        //endregion
//                        break;
//                    case 13: //region 物品遗留事件
//                        info.setAlarmType("物品遗留事件报警");
//                        //endregion
//                        break;
//                    case 14: //region 物品拿取事件
//                        info.setAlarmType("物品拿取事件事件报警");
//                        //endregion
//                        break;
//                    case 20: //region 倒地检测
//                        info.setAlarmType("倒地事件触发");
//                        //endregion
//                        break;
//                    case 44: //region 玩手机
//                        info.setAlarmType("玩手机报警事件");
//                        //endregion
//                        break;
                        default:
                            // 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);

                    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("非事件报警数据上报(暂不解析)");
                        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;

            }
        }
        return true;
    }

    /**
     * @描述 保存图片封装方法
     * @参数 [strVcaAlarm, eventName, eventNameEng]
     * @返回值 java.lang.String
     * @创建人 刘苏义
     * @创建时间 2023/2/17 15:05
     * @修改人和其它信息
     */
    private String savePicture(HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm, String eventName, String eventNameEng) {
        String url = "";
        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
            String currentTime = new SimpleDateFormat("yyyyMMdd").format(new Date());
            try {
                //存入minio
                long offset = 0;
                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
                buffers.rewind();
                buffers.get(bytes);
                InputStream inputStream = new ByteArrayInputStream(bytes);
                String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
                String UUID = java.util.UUID.randomUUID().toString().replace("-", "");
                String filename = ipaddr + "/" + currentTime + "/" + eventNameEng + "/" + UUID + ".jpg";
                boolean uploadRes = MinioUtils.uploadObject("pic", filename, inputStream, "image/jpeg");
                if (uploadRes) {
                    url = MinioClientSingleton.domainUrl + filename;
                    log.info("写入minio图片地址：" + url);
                }
            } catch (Exception ex) {
                log.error(eventName + "处理图片异常：" + ex.getMessage());
            }
        }
        return url;
    }

    /**
     * 相机截图
     */
    private String savePicture(CameraEventInfo info) {
        CameraCmd cmd = new CameraCmd();
        ArdCameras Cameras = GlobalVariable.cameraMap.get(info.getCameraIp());
        String key = info.getCameraIp() + ":" + info.getCameraPort();
        ArdCameras Cameras = GlobalVariable.cameraMap.get(key);
        if (Cameras == null) {
            return "";
        }
        cmd.setCameraId(Cameras.getId());
        cmd.setChannelNum(info.getCameraChannel());
        cmd.setBucketName("pic");
        String UUID = java.util.UUID.randomUUID().toString().replace("-", "");
        String filename = info.getCameraName() + "/" + info.getAlarmType() + "/" + UUID + ".jpg";
        String filename = "alarm" + "/" + IdUtils.simpleUUID() + ".jpg";
        cmd.setObjectName(filename);
        String url = HikClientUtil.picCutCate(cmd);
        return url;
@@ -409,7 +410,7 @@
     * 打印通用光电日志
     */
    private void printLog(CameraEventInfo info) {
        log.info("【规则】" + info.getAlarmName() + "【规则id】" + info.getRuleId() + "【类型】" + info.getAlarmType() +
        log.debug("【规则】" + info.getAlarmName() + "【规则id】" + info.getRuleId() + "【类型】" + info.getAlarmType() +
                "【时间】" + info.getAlarmTime() + "【相机id】" + info.getCameraId() + "【相机】" + info.getCameraName() +
                "【IP】" + info.getCameraIp() + "【通道】" + info.getCameraChannel() + "【型号】" + info.getCameraType() +
                "【图片】" + info.getPicUrl() + "【坐标】" + info.getLongitude() + "," + info.getLatitude());
@@ -419,7 +420,7 @@
     * 打印报警主机事件日志
     */
    private void printLog(ExternalAlarmEventInfo info) {
        log.info("【报警ID】" + info.getAlarmId() + "【报警名称】" + info.getAlarmName() +
        log.debug("【报警ID】" + info.getAlarmId() + "【报警名称】" + info.getAlarmName() +
                "【防区ID】" + info.getDefenseId() + "【防区名称】" + info.getDefenseName() + "【类型】" + info.getAlarmType() +
                "【时间】" + info.getAlarmTime() + "【报警主机ID】" + info.getAlarmHostId());
    }
@@ -428,9 +429,9 @@
     * 打印门禁事件日志
     */
    private void printLog(AccessControlHostEventInfo info) {
        log.info("【报警ID】" + info.getSerialNo() + "【设备编号】"+
        log.debug("【报警ID】" + info.getSerialNo() + "【设备编号】" +
                "【门编号】" + info.getDoorNo() + "【事件类型】" + info.getAlarmType() +
                "【防区类型】" + info.getDefenseType()+"【时间】" + info.getAlarmTime() +
                "【防区类型】" + info.getDefenseType() + "【时间】" + info.getAlarmTime() +
                "【门禁主机ID】" + info.getAcsId());
    }

@@ -438,7 +439,7 @@
     * 通用光电报警推送mqtt
     */
    private void publishMqtt(CameraEventInfo info) {
        // printLog(info);
        printLog(info);
        MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info));
    }