集成minio

pom.xml

@@ -25,6 +25,7 @@
         <lombok.versin>1.18.22</lombok.versin>
         <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
         <jna.version>3.0.9</jna.version>
+        <minio.version>8.5.2</minio.version>
     </properties>
     <dependencies>
         <!-- lombok -->
@@ -51,6 +52,27 @@
             <version>${jna.version}</version>
         </dependency>
         <dependency>
+            <groupId>io.minio</groupId>
+            <artifactId>minio</artifactId>
+            <version>${minio.version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>okhttp</artifactId>
+                    <groupId>com.squareup.okhttp3</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.10.0</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.8.12</version>
+        </dependency>
+        <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>

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

@@ -2,6 +2,9 @@ package com.unis.alarm;
 
 import com.sun.jna.Native;
 import com.sun.jna.Pointer;
+import com.unis.common.FMSGCallBack;
+import com.unis.common.FMSGCallBack_V31;
+import com.unis.common.HCNetSDK;
 import com.unis.common.osSelect;
 import com.unis.config.AddressModel;
 import lombok.extern.slf4j.Slf4j;

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

@@ -1,12 +1,15 @@
 package com.unis.alarm;
 
+import com.alibaba.fastjson.JSON;
 import com.sun.jna.Pointer;
+import com.unis.common.HCNetSDK;
+import com.unis.common.NetDVRAlarmerConvert;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 
 import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
-import java.io.UnsupportedEncodingException;
 import java.nio.ByteBuffer;
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -20,18 +23,119 @@ import java.util.Date;
 public class AlarmDataParse {
 
     public static void alarmDataHandle(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
-        log.info("报警事件类型lCommand int: {}", lCommand);
-        log.info("报警事件类型lCommand int: {}", "0x" + lCommand);
+//        log.info("报警事件类型lCommand int: {}", lCommand);
 
-        /*String hexString = Integer.toHexString(lCommand);
-        log.info("报警事件类型lCommand Hex: {}", hexString);*/
+        String hexString = Integer.toHexString(lCommand);
+        log.info("报警事件类型lCommand Hex: {}", hexString);
 
         String sTime;
         String MonitoringSiteID;
         String pic = System.getProperty("user.dir") + "/pic/";
-        log.info("pic: {}", pic);
+//        log.info("pic: {}", pic);
+//        log.info("int---> {}", HCNetSDK.COMM_UPLOAD_AIOP_POLLING_SNAP);
+
+        // bye封装对象转换
+        NetDVRAlarmerConvert convert = new NetDVRAlarmerConvert();
+        BeanUtils.copyProperties(pAlarmer, convert);
+
+        // byMacAddr
+        convert.setByMacAddr(new String(pAlarmer.getByMacAddr()).trim());
+        // byRes2
+        convert.setByRes2(new String(pAlarmer.getByRes2()).trim());
+        // sDeviceIP
+        convert.setSDeviceIP(new String(pAlarmer.getSDeviceIP()).trim());
+        // sDeviceName
+        convert.setSDeviceName(new String(pAlarmer.getSDeviceName()).trim());
+        // sSerialNumber
+        convert.setSSerialNumber(new String(pAlarmer.getSSerialNumber()).trim());
+        // sSocketIP
+        convert.setSSocketIP(new String(pAlarmer.getSSocketIP()).trim());
+        log.info("convert: {}", JSON.toJSONString(convert));
+
         //lCommand是传的报警类型
         switch (lCommand) {
+            //AI开放平台接入轮询抓图检测报警信息(抽烟打电话)
+            case HCNetSDK.COMM_UPLOAD_AIOP_POLLING_SNAP:
+                log.info("抽烟打电话");
+                HCNetSDK.NET_AIOP_POLLING_SNAP_HEAD strAiopPollingPic = new HCNetSDK.NET_AIOP_POLLING_SNAP_HEAD();
+                strAiopPollingPic.write();
+                Pointer pAiopPollingPic = strAiopPollingPic.getPointer();
+                pAiopPollingPic.write(0, pAlarmInfo.getByteArray(0, strAiopPollingPic.size()), 0, strAiopPollingPic.size());
+                strAiopPollingPic.read();
+                log.info("通道号: {}", strAiopPollingPic.dwChannel);
+                log.info("轮询抓图任务ID: {}", new String(strAiopPollingPic.szTaskID));
+                String strPollingPicTime = "" + String.format("%04d", strAiopPollingPic.struTime.wYear) +
+                        String.format("%02d", strAiopPollingPic.struTime.wMonth) +
+                        String.format("%02d", strAiopPollingPic.struTime.wDay) +
+                        String.format("%02d", strAiopPollingPic.struTime.wHour) +
+                        String.format("%02d", strAiopPollingPic.struTime.wMinute) +
+                        String.format("%02d", strAiopPollingPic.struTime.wSecond) +
+                        String.format("%03d", strAiopPollingPic.struTime.wMilliSec);
+                //AIOPData数据保存
+                if (strAiopPollingPic.dwAIOPDataSize > 0) {
+                    FileOutputStream fout;
+                    try {
+                        String filename = pic + new String(pAlarmer.sDeviceIP).trim() +
+                                "_" + strPollingPicTime + "_PollingPicData.json";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strAiopPollingPic.pBufferAIOPData.getByteBuffer(offset, strAiopPollingPic.dwAIOPDataSize);
+                        byte[] bytes = new byte[strAiopPollingPic.dwAIOPDataSize];
+                        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 (strAiopPollingPic.dwPictureSize > 0) {
+                    FileOutputStream fout;
+                    try {
+                        String filename = pic + new String(pAlarmer.sDeviceIP).trim() +
+                                "_" + strPollingPicTime + "_PollingPic.jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strAiopPollingPic.pBufferPicture.getByteBuffer(offset, strAiopPollingPic.dwPictureSize);
+                        byte[] bytes = new byte[strAiopPollingPic.dwPictureSize];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                break;
+            case HCNetSDK.COMM_ALARM_V30:  //移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
+                HCNetSDK.NET_DVR_ALARMINFO_V30 struAlarmInfo = new HCNetSDK.NET_DVR_ALARMINFO_V30();
+                struAlarmInfo.write();
+                Pointer pAlarmInfo_V30 = struAlarmInfo.getPointer();
+                pAlarmInfo_V30.write(0, pAlarmInfo.getByteArray(0, struAlarmInfo.size()), 0, struAlarmInfo.size());
+                struAlarmInfo.read();
+                log.info("报警类型V30: {}", struAlarmInfo.dwAlarmType); // 3-移动侦测
+                break;
+            case HCNetSDK.COMM_ALARM_V40: //移动侦测、视频丢失、遮挡、IO信号量等报警信息，报警数据为可变长
+                HCNetSDK.NET_DVR_ALARMINFO_V40 struAlarmInfoV40 = new HCNetSDK.NET_DVR_ALARMINFO_V40();
+                struAlarmInfoV40.write();
+                Pointer pAlarmInfoV40 = struAlarmInfoV40.getPointer();
+                pAlarmInfoV40.write(0, pAlarmInfo.getByteArray(0, struAlarmInfoV40.size()), 0, struAlarmInfoV40.size());
+                struAlarmInfoV40.read();
+                log.info("报警类型V40: {}", struAlarmInfoV40.struAlarmFixedHeader.dwAlarmType); // 3-移动侦测
+                break;
+
+            // -------------------------------------------------------------------------
             //行为分析信息
             case HCNetSDK.COMM_ALARM_RULE:
                 HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
@@ -39,7 +143,7 @@ public class AlarmDataParse {
                 Pointer pVCAInfo = strVcaAlarm.getPointer();
                 pVCAInfo.write(0, pAlarmInfo.getByteArray(0, strVcaAlarm.size()), 0, strVcaAlarm.size());
                 strVcaAlarm.read();
-
+                log.info("行为分析信息case: {}", strVcaAlarm.struRuleInfo.wEventTypeEx);
                 switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
                     case 1: //穿越警戒面 (越界侦测)
                         System.out.println("越界侦测报警发生");
@@ -80,7 +184,7 @@ public class AlarmDataParse {
                             String newName = sf.format(new Date());
                             FileOutputStream fout;
                             try {
-                                String filename = "../pic/" + newName + "_TargetEnter" + ".jpg";
+                                String filename = pic + newName + "_TargetEnter" + ".jpg";
                                 fout = new FileOutputStream(filename);
                                 //将字节写入文件
                                 long offset = 0;
@@ -168,7 +272,7 @@ public class AlarmDataParse {
                             String newName = sf.format(new Date());
                             FileOutputStream fout;
                             try {
-                                String filename = "../pic/" + newName + "VCA_LEAVE_POSITION_" + ".jpg";
+                                String filename = pic + newName + "VCA_LEAVE_POSITION_" + ".jpg";
                                 fout = new FileOutputStream(filename);
                                 //将字节写入文件
                                 long offset = 0;
@@ -189,34 +293,6 @@ public class AlarmDataParse {
                     case 20: //倒地检测
                         System.out.println("倒地事件触发");
                         break;
-                    case 44: //玩手机
-
-                        System.out.println("玩手机报警发生");
-                        //图片保存
-                        if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
-                            SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                            String newName = sf.format(new Date());
-                            FileOutputStream fout;
-                            try {
-                                String filename = "../pic/" + newName + "PLAY_CELLPHONE_" + ".jpg";
-                                fout = new FileOutputStream(filename);
-                                //将字节写入文件
-                                long offset = 0;
-                                ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
-                                byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
-                                buffers.rewind();
-                                buffers.get(bytes);
-                                fout.write(bytes);
-                                fout.close();
-                            } catch (FileNotFoundException e) {
-                                // TODO Auto-generated catch block
-                                e.printStackTrace();
-                            } catch (IOException e) {
-                                // TODO Auto-generated catch block
-                                e.printStackTrace();
-                            }
-                        }
-                        break;
                     case 45: //持续检测
                         System.out.println("持续检测事件触发");
                     default:
@@ -224,210 +300,6 @@ public class AlarmDataParse {
                         break;
                 }
                 break;
-            case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT: //实时人脸抓拍上传
-                System.out.println("UPLOAD_FACESNAP_Alarm");
-                HCNetSDK.NET_VCA_FACESNAP_RESULT strFaceSnapInfo = new HCNetSDK.NET_VCA_FACESNAP_RESULT();
-                strFaceSnapInfo.write();
-                Pointer pFaceSnapInfo = strFaceSnapInfo.getPointer();
-                pFaceSnapInfo.write(0, pAlarmInfo.getByteArray(0, strFaceSnapInfo.size()), 0, strFaceSnapInfo.size());
-                strFaceSnapInfo.read();
-
-                //事件时间
-                int dwYear = (strFaceSnapInfo.dwAbsTime >> 26) + 2000;
-                int dwMonth = (strFaceSnapInfo.dwAbsTime >> 22) & 15;
-                int dwDay = (strFaceSnapInfo.dwAbsTime >> 17) & 31;
-                int dwHour = (strFaceSnapInfo.dwAbsTime >> 12) & 31;
-                int dwMinute = (strFaceSnapInfo.dwAbsTime >> 6) & 63;
-                int dwSecond = (strFaceSnapInfo.dwAbsTime >> 0) & 63;
-
-                String strAbsTime = "" + String.format("%04d", dwYear) +
-                        String.format("%02d", dwMonth) +
-                        String.format("%02d", dwDay) +
-                        String.format("%02d", dwHour) +
-                        String.format("%02d", dwMinute) +
-                        String.format("%02d", dwSecond);
-
-                //人脸属性信息
-                String sFaceAlarmInfo = "Abs时间:" + strAbsTime + ",年龄:" + strFaceSnapInfo.struFeature.byAge +
-                        ",性别：" + strFaceSnapInfo.struFeature.bySex + ",是否戴口罩：" +
-                        strFaceSnapInfo.struFeature.byMask + ",是否微笑：" + strFaceSnapInfo.struFeature.bySmile;
-                System.out.println("人脸信息：" + sFaceAlarmInfo);
-
-                //人脸测温信息
-                if (strFaceSnapInfo.byAddInfo == 1) {
-                    HCNetSDK.NET_VCA_FACESNAP_ADDINFO strAddInfo = new HCNetSDK.NET_VCA_FACESNAP_ADDINFO();
-                    strAddInfo.write();
-                    Pointer pAddInfo = strAddInfo.getPointer();
-                    pAddInfo.write(0, strFaceSnapInfo.pAddInfoBuffer.getByteArray(0, strAddInfo.size()), 0, strAddInfo.size());
-                    strAddInfo.read();
-
-                    String sTemperatureInfo = "测温是否开启：" + strAddInfo.byFaceSnapThermometryEnabled + "人脸温度：" + strAddInfo.fFaceTemperature + "温度是否异常"
-                            + strAddInfo.byIsAbnomalTemperature + "报警温度阈值：" + strAddInfo.fAlarmTemperature;
-                    System.out.println("人脸温度信息:" + sTemperatureInfo);
-
-                }
-
-                try {
-                    SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss");//设置日期格式
-                    String time = df.format(new Date());// new Date()为获取当前系统时间
-
-                    //人脸图片写文件
-                    FileOutputStream small = new FileOutputStream("../pic/" + time + "small.jpg");
-                    FileOutputStream big = new FileOutputStream("../pic/" + time + "big.jpg");
-                    try {
-                        small.write(strFaceSnapInfo.pBuffer1.getByteArray(0, strFaceSnapInfo.dwFacePicLen), 0, strFaceSnapInfo.dwFacePicLen);
-                        small.close();
-                    } catch (IOException ex) {
-                        ex.printStackTrace();
-                    }
-                    try {
-                        big.write(strFaceSnapInfo.pBuffer2.getByteArray(0, strFaceSnapInfo.dwBackgroundPicLen), 0, strFaceSnapInfo.dwBackgroundPicLen);
-                        big.close();
-                    } catch (IOException ex) {
-                        ex.printStackTrace();
-                    }
-
-                } catch (FileNotFoundException ex) {
-                    ex.printStackTrace();
-                }
-                break;
-            case HCNetSDK.COMM_ALARM_V30:  //移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
-                HCNetSDK.NET_DVR_ALARMINFO_V30 struAlarmInfo = new HCNetSDK.NET_DVR_ALARMINFO_V30();
-                struAlarmInfo.write();
-                Pointer pAlarmInfo_V30 = struAlarmInfo.getPointer();
-                pAlarmInfo_V30.write(0, pAlarmInfo.getByteArray(0, struAlarmInfo.size()), 0, struAlarmInfo.size());
-                struAlarmInfo.read();
-                System.out.println("报警类型：" + struAlarmInfo.dwAlarmType);  // 3-移动侦测
-                break;
-            case HCNetSDK.COMM_ALARM_V40: //移动侦测、视频丢失、遮挡、IO信号量等报警信息，报警数据为可变长
-                HCNetSDK.NET_DVR_ALARMINFO_V40 struAlarmInfoV40 = new HCNetSDK.NET_DVR_ALARMINFO_V40();
-                struAlarmInfoV40.write();
-                Pointer pAlarmInfoV40 = struAlarmInfoV40.getPointer();
-                pAlarmInfoV40.write(0, pAlarmInfo.getByteArray(0, struAlarmInfoV40.size()), 0, struAlarmInfoV40.size());
-                struAlarmInfoV40.read();
-                System.out.println("报警类型:" + struAlarmInfoV40.struAlarmFixedHeader.dwAlarmType); //3-移动侦测
-                break;
-            case HCNetSDK.COMM_THERMOMETRY_ALARM:  //温度报警信息
-                HCNetSDK.NET_DVR_THERMOMETRY_ALARM struTemInfo = new HCNetSDK.NET_DVR_THERMOMETRY_ALARM();
-                struTemInfo.write();
-                Pointer pTemInfo = struTemInfo.getPointer();
-                pTemInfo.write(0, pAlarmInfo.getByteArray(0, struTemInfo.size()), 0, struTemInfo.size());
-                struTemInfo.read();
-                String sThermAlarmInfo = "规则ID:" + struTemInfo.byRuleID + "预置点号：" + struTemInfo.wPresetNo + "报警等级：" + struTemInfo.byAlarmLevel + "报警类型：" +
-                        struTemInfo.byAlarmType + "当前温度：" + struTemInfo.fCurrTemperature;
-                System.out.println(sThermAlarmInfo);
-                //可见光图片保存
-                if ((struTemInfo.dwPicLen > 0) && (struTemInfo.byPicTransType == 0)) {
-                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                    String newName = sf.format(new Date());
-                    FileOutputStream fout;
-
-                    try {
-                        String filename = "../pic/" + newName + "_" + struTemInfo.fCurrTemperature + ".jpg";
-                        fout = new FileOutputStream(filename);
-                        //将字节写入文件
-                        long offset = 0;
-                        ByteBuffer buffers = struTemInfo.pPicBuff.getByteBuffer(offset, struTemInfo.dwPicLen);
-                        byte[] bytes = new byte[struTemInfo.dwPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (FileNotFoundException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-
-                if ((struTemInfo.dwThermalPicLen > 0) && (struTemInfo.byPicTransType == 0)) {
-                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                    String newName = sf.format(new Date());
-                    FileOutputStream fout;
-
-                    try {
-                        String filename = "../pic/" + newName + "_" + "_ThermalPiC" + ".jpg";
-                        fout = new FileOutputStream(filename);
-                        //将字节写入文件
-                        long offset = 0;
-                        ByteBuffer buffers = struTemInfo.pThermalPicBuff.getByteBuffer(offset, struTemInfo.dwThermalPicLen);
-                        byte[] bytes = new byte[struTemInfo.dwThermalPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (FileNotFoundException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-
-                }
-                break;
-            case HCNetSDK.COMM_THERMOMETRY_DIFF_ALARM: //温差检测报警
-                HCNetSDK.NET_DVR_THERMOMETRY_DIFF_ALARM strThermDiffAlarm = new HCNetSDK.NET_DVR_THERMOMETRY_DIFF_ALARM();
-                strThermDiffAlarm.write();
-                Pointer pTemDiffInfo = strThermDiffAlarm.getPointer();
-                pTemDiffInfo.write(0, pAlarmInfo.getByteArray(0, strThermDiffAlarm.size()), 0, strThermDiffAlarm.size());
-                strThermDiffAlarm.read();
-                String sThremDiffInfo = "通道号：" + strThermDiffAlarm.dwChannel + ",报警规则：" + strThermDiffAlarm.byAlarmRule + "，当前温差：" + strThermDiffAlarm.fCurTemperatureDiff;
-                System.out.println(sThremDiffInfo);
-                //可见光图片保存
-                if ((strThermDiffAlarm.dwPicLen > 0) && (strThermDiffAlarm.byPicTransType == 0)) {
-                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                    String newName = sf.format(new Date());
-                    FileOutputStream fout;
-
-                    try {
-                        String filename = "../pic/" + newName + "_" + strThermDiffAlarm.fCurTemperatureDiff + ".jpg";
-                        fout = new FileOutputStream(filename);
-                        //将字节写入文件
-                        long offset = 0;
-                        ByteBuffer buffers = strThermDiffAlarm.pPicBuff.getByteBuffer(offset, strThermDiffAlarm.dwPicLen);
-                        byte[] bytes = new byte[strThermDiffAlarm.dwPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (FileNotFoundException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-                //热成像图片保存
-                if ((strThermDiffAlarm.dwThermalPicLen > 0) && (strThermDiffAlarm.byPicTransType == 0)) {
-                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                    String newName = sf.format(new Date());
-                    FileOutputStream fout;
-
-                    try {
-                        String filename = "../pic/" + newName + "_" + "_ThermalDiffPiC" + ".jpg";
-                        fout = new FileOutputStream(filename);
-                        //将字节写入文件
-                        long offset = 0;
-                        ByteBuffer buffers = strThermDiffAlarm.pThermalPicBuff.getByteBuffer(offset, strThermDiffAlarm.dwThermalPicLen);
-                        byte[] bytes = new byte[strThermDiffAlarm.dwThermalPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (FileNotFoundException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-
-                }
-                break;
 
             case HCNetSDK.COMM_FIREDETECTION_ALARM://烟火检测
                 HCNetSDK.NET_DVR_FIREDETECTION_ALARM struFireDecAlarm = new HCNetSDK.NET_DVR_FIREDETECTION_ALARM();
@@ -445,7 +317,7 @@ public class AlarmDataParse {
                     FileOutputStream fout;
 
                     try {
-                        String filename = "../pic/" + newName + "_FireDecAlarm" + ".jpg";
+                        String filename = pic + newName + "_FireDecAlarm" + ".jpg";
                         fout = new FileOutputStream(filename);
                         //将字节写入文件
                         long offset = 0;
@@ -470,7 +342,7 @@ public class AlarmDataParse {
                     FileOutputStream fout;
 
                     try {
-                        String filename = "../pic/" + newName + "_" + "_ThermalFireAlarm" + ".jpg";
+                        String filename = pic + newName + "_" + "_ThermalFireAlarm" + ".jpg";
                         fout = new FileOutputStream(filename);
                         //将字节写入文件
                         long offset = 0;
@@ -487,7 +359,6 @@ public class AlarmDataParse {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                     }
-
                 }
                 break;
             default:

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

@@ -1,6 +1,6 @@
 
 
-package com.unis.alarm;
+package com.unis.common;
 
 /**
  * @author

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

@@ -1,6 +1,8 @@
-package com.unis.alarm;
+package com.unis.common;
 
 import com.sun.jna.Pointer;
+import com.unis.alarm.AlarmDataParse;
+import com.unis.common.HCNetSDK;
 
 
 /**

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

@@ -1,7 +1,9 @@
 
-package com.unis.alarm;
+package com.unis.common;
 
 import com.sun.jna.Pointer;
+import com.unis.alarm.AlarmDataParse;
+import com.unis.common.HCNetSDK;
 
 
 public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {

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

@@ -1,5 +1,6 @@
 package com.unis.common;
 
+import com.alibaba.fastjson.JSONObject;
 import lombok.Data;
 
 /**
@@ -25,7 +26,7 @@ public class NetDVRAlarmerConvert {
     private Byte byVersionValid;
     private Byte dwDeviceVersion;
     private Integer lUserID;
-    private Object pointer;
+    private JSONObject pointer;
     private String sDeviceIP;
     private String sDeviceName;
     private String sSerialNumber;

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

@@ -0,0 +1,197 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.config;
+
+import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.unis.enums.DevFileBucketAuthEnum;
+import io.minio.MinioClient;
+import io.minio.PutObjectArgs;
+import io.minio.SetBucketPolicyArgs;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.activation.MimetypesFileTypeMap;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * MINIO文件工具类
+ * 参考文档：http://docs.minio.org.cn/docs/master/java-client-quickstart-guide
+ *
+ * @author xuyuxiang
+ * @date 2022/1/2 18:13
+ */
+@Slf4j
+@Component
+public class DevFileMinIoUtil {
+    private static MinioClient client;
+    private static MinIoProperties minIoProperties;
+
+    @Autowired
+    public DevFileMinIoUtil(MinIoProperties minIoProperties) {
+        this.minIoProperties = minIoProperties;
+    }
+
+    /**
+     * 初始化操作的客户端
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    private static void initClient() {
+        String endpoint = minIoProperties.getEndpoint();
+        String accessKey = minIoProperties.getAccessKey();
+        String secretKey = minIoProperties.getSecretKey();
+        client = MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();
+    }
+
+    /**
+     * 获取默认存储桶名称
+     *
+     * @author xuyuxiang
+     * @date 2022/6/22 18:05
+     **/
+    public static String getDefaultBucketName() {
+        initClient();
+        return minIoProperties.getBucketName();
+
+    }
+
+
+    /**
+     * 存储文件，返回外网地址
+     *
+     * @param bucketName    桶名称
+     * @param key           唯一标示id，例如a.txt, doc/a.txt
+     * @param multipartFile 文件
+     * @author xuyuxiang
+     * @date 2022/1/5 23:45
+     */
+    public static String storageFileWithReturnUrl(String bucketName, String key, MultipartFile multipartFile) {
+        storageFile(bucketName, key, multipartFile);
+        setFileAcl(bucketName, key, DevFileBucketAuthEnum.PUBLIC_READ);
+        return getFileAuthUrl(bucketName, key);
+    }
+
+
+    /**
+     * 获取文件的下载地址（永久的，文件必须为公有读），生成外网地址
+     *
+     * @param bucketName 文件桶
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String getFileAuthUrl(String bucketName, String key) {
+        initClient();
+        return minIoProperties.getEndpoint() + StrUtil.SLASH + bucketName + StrUtil.SLASH + key;
+
+    }
+
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName    桶名称
+     * @param key           唯一标示id，例如a.txt, doc/a.txt
+     * @param multipartFile 文件
+     * @author xuyuxiang
+     * @date 2022/1/5 23:45
+     */
+    public static void storageFile(String bucketName, String key, MultipartFile multipartFile) {
+        InputStream inputStream = null;
+        try {
+            inputStream = multipartFile.getInputStream();
+        } catch (IOException e) {
+
+        }
+        storageFile(bucketName, key, inputStream);
+    }
+
+    /**
+     * 设置文件访问权限管理
+     *
+     * @param bucketName            桶名称
+     * @param key                   唯一标示id，例如a.txt, doc/a.txt
+     * @param devFileBucketAuthEnum 文件权限
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void setFileAcl(String bucketName, String key, DevFileBucketAuthEnum devFileBucketAuthEnum) {
+        try {
+            JSONObject configObject = JSONUtil.createObj().set("Version", "2012-10-17");
+            JSONArray statementArray = JSONUtil.createArray();
+            JSONArray actionArray = JSONUtil.createArray();
+            if (devFileBucketAuthEnum.equals(DevFileBucketAuthEnum.PUBLIC_READ)) {
+                actionArray.put("s3:GetObject");
+            }
+            if (devFileBucketAuthEnum.equals(DevFileBucketAuthEnum.PUBLIC_READ_WRITE)) {
+                actionArray.put("s3:GetObject");
+                actionArray.put("s3:PutObject");
+            }
+            JSONObject statementObject = JSONUtil.createObj();
+            statementObject.set("Effect", "Allow").set("Principal", JSONUtil.createObj().set("AWS", JSONUtil.createArray().put("*")))
+                    .set("Action", actionArray).set("Resource", JSONUtil.createArray().put("arn:aws:s3:::" + bucketName + "/*"));
+            statementArray.put(statementObject);
+            configObject.set("Statement", statementArray);
+            String config = JSONUtil.toJsonStr(configObject);
+            SetBucketPolicyArgs setBucketPolicyArgs = SetBucketPolicyArgs.builder().bucket(bucketName).config(config).build();
+            client.setBucketPolicy(setBucketPolicyArgs);
+        } catch (Exception e) {
+
+        }
+    }
+
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName  桶名称
+     * @param key         唯一标示id，例如a.txt, doc/a.txt
+     * @param inputStream 文件流
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void storageFile(String bucketName, String key, InputStream inputStream) {
+        try {
+            initClient();
+            PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(bucketName).object(key)
+                    .contentType(getFileContentType(key)).stream(inputStream, inputStream.available(), -1).build();
+            client.putObject(putObjectArgs);
+        } catch (Exception e) {
+
+        } finally {
+            IoUtil.close(inputStream);
+        }
+    }
+
+    /**
+     * 根据文件名获取ContentType
+     *
+     * @author xuyuxiang
+     * @date 2022/1/6 11:27
+     **/
+    private static String getFileContentType(String key) {
+        // 根据文件名获取contentType
+        String contentType = "application/octet-stream";
+        if (key.contains(".")) {
+            contentType = MimetypesFileTypeMap.getDefaultFileTypeMap().getContentType(key);
+        }
+        return contentType;
+    }
+
+}

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

@@ -0,0 +1,35 @@
+package com.unis.config;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.unis.enums.DevFileBucketAuthEnum;
+import io.minio.MinioClient;
+import io.minio.SetBucketPolicyArgs;
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author qingsong.han
+ * @description: minio 基础信息配置
+ * @create 2024-08-02 15:30
+ */
+@Data
+@Configuration
+public class MinIoProperties {
+
+    @Value("${minio.endpoint}")
+    private String endpoint;
+
+    @Value("${minio.access-key}")
+    private String accessKey;
+
+    @Value("${minio.secret-key}")
+    private String secretKey;
+
+    @Value("${minio.bucket-name}")
+    private String bucketName;
+
+}

src/main/java/com/unis/enums/DevFileBucketAuthEnum.java

@@ -0,0 +1,38 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.enums;
+
+/**
+ * 文件存储桶的权限策略枚举
+ *
+ * @author xuyuxiang
+ * @date 2022/1/5 23:29
+ */
+public enum DevFileBucketAuthEnum {
+
+    /**
+     * 私有的（仅有 owner 可以读写）
+     */
+    PRIVATE,
+
+    /**
+     * 公有读，私有写（ owner 可以读写， 其他客户可以读）
+     */
+    PUBLIC_READ,
+
+    /**
+     * 公共读写（即所有人都可以读写，慎用）
+     */
+    PUBLIC_READ_WRITE
+
+}

src/main/java/com/unis/enums/DevFileEngineTypeEnum.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.enums;
+
+import lombok.Getter;
+
+/**
+ * 文件存储引擎类型枚举
+ *
+ * @author xuyuxiang
+ * @date 2022/6/16 16:14
+ **/
+@Getter
+public enum DevFileEngineTypeEnum {
+
+    /** 本地 */
+    LOCAL("LOCAL"),
+
+    /** 阿里云 */
+    ALIYUN("ALIYUN"),
+
+    /** 腾讯云 */
+    TENCENT("TENCENT"),
+
+    /** MINIO */
+    MINIO("MINIO");
+
+    private final String value;
+
+    DevFileEngineTypeEnum(String value) {
+        this.value = value;
+    }
+}

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

@@ -1,75 +0,0 @@
-package com.unis.face;
-
-import com.sun.jna.Pointer;
-import com.unis.common.HCNetSDK;
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * 报警布防/监听功能模块：功能：报警布防/监听实时接受设备的人脸比对报警事件，回调函数中获取的报警类型(lCommand)为COMM_SNAP_MATCH_ALARM，报警信息(pAlarmInfo)对应结构体：NET_VCA_FACESNAP_MATCH_ALARM。
- * fSimilarity相似度大于0表示人脸比对成功，可以获取人脸库相关数据；fSimilarity相似度为0，需要通过NET_VCA_BLACKLIST_INFO结构体里面的byType类型判断，值为1表示陌生人模式，值为2表示人脸比对失败。
- */
-@Slf4j
-public class Alarm {
-
-    public static HCNetSDK.FMSGCallBack_V31 fMSFCallBack_V31 = null;
-
-    /**
-     * 报警布防 （布防和监听选其一）
-     *
-     * @param lUserID 用户登录句柄
-     */
-    public static void SetAlarm(int lUserID) {
-        //尚未布防,需要布防
-        if (FaceMain.lAlarmHandle < 0) {
-
-            //设置报警回调函数，一个程序进程只需要而且只能调用一次，对接多台设备，可以SDK初始化之后就调用该接口设置报警回调函数
-            if (fMSFCallBack_V31 == null) {
-                fMSFCallBack_V31 = new FMSGCallBack_V31();
-                Pointer pUser = null;
-                if (!FaceMain.hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(fMSFCallBack_V31, pUser)) {
-                    log.error("设置回调函数失败!");
-                } else {
-                    log.info("设置回调函数成功!");
-                }
-            }
-
-            //报警布防参数设置
-            HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();
-            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
-            m_strAlarmInfo.byLevel = 1;  //布防等级
-            m_strAlarmInfo.byAlarmInfoType = 1;   // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
-            m_strAlarmInfo.byDeployType = 1;   //布防类型 0：客户端布防 1：实时布防
-            m_strAlarmInfo.write();
-            FaceMain.lAlarmHandle = FaceMain.hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID, m_strAlarmInfo);
-            log.info("lAlarmHandle: {}", FaceMain.lAlarmHandle);
-            if (FaceMain.lAlarmHandle == -1) {
-                log.error("布防失败，错误码为: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
-            } else {
-                log.info("布防成功");
-            }
-        }
-    }
-
-    /**
-     * 报警监听
-     * <p>
-     * 注意: 设置监听前需要现在本机pc配置端口
-     * 具体步骤：库文件ClientDemo->登录设备->配置->网络参数配置->配置告警管理主机地址、告警管理主机端口（需要与NET_DVR_StartListen_V30接口中对应）
-     */
-    public void StartListen() {
-        if (fMSFCallBack_V31 == null) {
-            fMSFCallBack_V31 = new FMSGCallBack_V31();
-        }
-        /**
-         * 这里NET_DVR_StartListen_V30接口中的ip和端口需要和配置的ip和端口对应
-         * NET_DVR_StartListen_V30中传入的IP和端口是服务器或者测试PC的IP地址和端口，不是设备的IP和端口！！！
-         */
-        FaceMain.lListenHandle = FaceMain.hCNetSDK.NET_DVR_StartListen_V30("10.17.36.14", (short) 7201, fMSFCallBack_V31, null);
-        if (FaceMain.lListenHandle == -1) {
-            log.error("监听失败: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
-        } else {
-            log.info("监听成功");
-        }
-    }
-
-}

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

@@ -1,215 +0,0 @@
-package com.unis.face;
-
-import com.alibaba.fastjson.JSON;
-import com.sun.jna.Pointer;
-import com.unis.common.HCNetSDK;
-/*import com.unissoft.pushMsg.AlarmDSService;
-import com.unissoft.pushMsg.AlarmDSServiceImpl;*/
-import com.unis.common.NetDVRAlarmerConvert;
-import com.unis.utils.BinaryConversionUtil;
-import com.unis.video.VideoMok;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.BeanUtils;
-
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-/**
- * 人脸比对报警接收回调函数
- */
-@Slf4j
-public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
-    // this class call jna native callback,so is not spring manage class
-    /*private AlarmDSService alarmDSService = new AlarmDSServiceImpl();*/
-    //相机一般只有一个通道号，热成像相机有2个通道号，通道号为1或1,2
-    static int iChannelNo = 1;
-
-    //报警信息回调函数
-    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
-        AlarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
-        return true;
-    }
-
-    public void AlarmDataHandle(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
-        log.info("报警事件发生,进入回调");
-        log.info("lCommand: {}", lCommand);
-        log.info("pAlarmer: {}", JSON.toJSONString(pAlarmer));
-        log.info("pAlarmInfo: {}", JSON.toJSONString(pAlarmInfo));
-        log.info("dwBufLen: {}", dwBufLen);
-        log.info("pUser: {}", JSON.toJSONString(pUser));
-        /*log.info(
-                "lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
-                lCommand, JSON.toJSONString(pAlarmer), JSON.toJSONString(pAlarmInfo),dwBufLen,JSON.toJSONString(pUser)
-        );*/
-        // bye封装对象转换
-        NetDVRAlarmerConvert convert = new NetDVRAlarmerConvert();
-        BeanUtils.copyProperties(pAlarmer, convert);
-
-        // byMacAddr
-        convert.setByMacAddr(new String(pAlarmer.getByMacAddr()));
-        // byRes2
-        convert.setByRes2(new String(pAlarmer.getByRes2()));
-        // sDeviceIP
-        convert.setSDeviceIP(new String(pAlarmer.getSDeviceIP()));
-        // sDeviceName
-        convert.setSDeviceName(new String(pAlarmer.getSDeviceName()));
-        // sSerialNumber
-        convert.setSSerialNumber(new String(pAlarmer.getSSerialNumber()));
-        // sSocketIP
-        convert.setSSocketIP(new String(pAlarmer.getSSocketIP()));
-        log.info("convert: {}", convert);
-
-        // 抓图
-        VideoMok.RealPlay(convert.getLUserID(), iChannelNo);
-        VideoMok.getPicbyPlayCtrl();
-
-        /*String hexString = Integer.toHexString(lCommand);
-        log.info("报警类型 hexString {}", hexString);*/
-        switch (lCommand) {
-            case HCNetSDK.COMM_ALARM_RULE://行为分析信息上传
-                HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
-                ruleAlarm.write();
-                Pointer ruleAlarmPointer = ruleAlarm.getPointer();
-                ruleAlarmPointer.write(0, pAlarmInfo.getByteArray(0, ruleAlarm.size()), 0, ruleAlarm.size());
-                ruleAlarm.read();
-                log.info("Alarm type in the NET_VCA_RULE_ALARM ---------->: {}", JSON.toJSONString(ruleAlarm));
-//                alarmDSService.pushLCommand(lCommand);
-                break;
-            case HCNetSDK.COMM_SNAP_MATCH_ALARM:
-                //人脸黑名单比对报警
-                log.info("SNAP_MATCH_ALARM");
-                HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM strFaceSnapMatch = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
-                strFaceSnapMatch.write();
-                Pointer pFaceSnapMatch = strFaceSnapMatch.getPointer();
-                pFaceSnapMatch.write(0, pAlarmInfo.getByteArray(0, strFaceSnapMatch.size()), 0, strFaceSnapMatch.size());
-                strFaceSnapMatch.read();
-                //比对结果
-                log.info("比对结果: {}", strFaceSnapMatch.byContrastStatus == 1 ? "比对成功" : "比对失败");
-                //人脸库ID
-                if (strFaceSnapMatch.struBlockListInfo.dwFDIDLen > 0) {
-                    long offset1 = 0;
-                    ByteBuffer buffers1 = strFaceSnapMatch.struBlockListInfo.pFDID.getByteBuffer(offset1, strFaceSnapMatch.struBlockListInfo.dwFDIDLen);
-                    byte[] bytes1 = new byte[strFaceSnapMatch.struBlockListInfo.dwFDIDLen];
-                    buffers1.get(bytes1);
-                    log.info("人脸库ID: {}", new String(bytes1));
-                }
-                //人脸库图片ID
-                if (strFaceSnapMatch.struBlockListInfo.dwPIDLen > 0) {
-                    long offset2 = 0;
-                    ByteBuffer buffers2 = strFaceSnapMatch.struBlockListInfo.pPID.getByteBuffer(offset2, strFaceSnapMatch.struBlockListInfo.dwPIDLen);
-                    byte[] bytes2 = new byte[strFaceSnapMatch.struBlockListInfo.dwPIDLen];
-                    buffers2.get(bytes2);
-                    log.info("图片ID: {}", new String(bytes2));
-                }
-                //保存抓拍人脸图，图片数据传输方式: 0- 二进制
-                if ((strFaceSnapMatch.dwSnapPicLen > 0) && (strFaceSnapMatch.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 = strFaceSnapMatch.pSnapPicBuffer.getByteBuffer(offset, strFaceSnapMatch.dwSnapPicLen);
-                        byte[] bytes = new byte[strFaceSnapMatch.dwSnapPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-                //保存抓拍人脸图URL，图片数据传输方式: 1- URL 注：超脑设备人脸比对报警图片一般按照URL上传，根据URL去下载设备中存储的图片，认证方式选择：摘要认证
-                if ((strFaceSnapMatch.dwSnapPicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
-                    long offset = 0;
-                    ByteBuffer buffers = strFaceSnapMatch.pSnapPicBuffer.getByteBuffer(offset, strFaceSnapMatch.dwSnapPicLen);
-                    byte[] bytes = new byte[strFaceSnapMatch.dwSnapPicLen];
-                    buffers.rewind();
-                    buffers.get(bytes);
-                    log.info("人脸抓拍图片 URL: {}", new String(bytes));
-                }
-                if ((strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen > 0) && (strFaceSnapMatch.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 = strFaceSnapMatch.struSnapInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen);
-                        byte[] bytes = new byte[strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-                if ((strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
-                    long offset = 0;
-                    ByteBuffer buffers = strFaceSnapMatch.struSnapInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen);
-                    byte[] bytes = new byte[strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen];
-                    buffers.rewind();
-                    buffers.get(bytes);
-                    log.info("人脸抓拍图片1 URL: {}", new String(bytes));
-                }
-                //保存人脸库图片，图片数据传输方式: 0- 二进制
-                if ((strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen > 0) && (strFaceSnapMatch.byPicTransType == 0)) {
-                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
-                    String newName = sf.format(new Date());
-                    FileOutputStream fout;
-                    try {
-                        String filename = ".//pic//" + newName + "_fSimilarity_" + strFaceSnapMatch.fSimilarity + "_struBlackListInfo_pBuffer1" + ".jpg";
-                        fout = new FileOutputStream(filename);
-                        //将字节写入文件
-                        long offset = 0;
-                        ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen);
-                        byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen];
-                        buffers.rewind();
-                        buffers.get(bytes);
-                        fout.write(bytes);
-                        fout.close();
-                    } catch (IOException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-                //保存人脸库图片，图片数据传输方式: 1-URL
-                if ((strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
-                    long offset = 0;
-                    ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen);
-                    byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen];
-                    buffers.rewind();
-                    buffers.get(bytes);
-                    log.info("人脸库图片 URL: {}", new String(bytes));
-                }
-                //抓拍库附加信息数据指针，附加信息的XML文本中包含人脸温度数据
-                if (strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen > 0) {
-                    long offset = 0;
-                    ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.struBlockListInfo.pFCAdditionInfoBuffer.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen);
-                    byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen];
-                    buffers.rewind();
-                    buffers.get(bytes);
-                    log.info("抓拍库附加信息: {}", new String(bytes));
-                }
-//                alarmDSService.pushLCommand(lCommand);
-                break;
-            default:
-                // TODO 单报警设备 目前不需要 sAlarmType alarmNow
-                log.info("Alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
-                log.info("Alarm type in the FMSGCallBack_V31 ->HEX: {}", BinaryConversionUtil.toHex(lCommand));
-//                alarmDSService.pushLCommand(lCommand);
-                break;
-        }
-    }
-
-}

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

@@ -1,187 +0,0 @@
-package com.unis.face;
-
-import com.sun.jna.Native;
-import com.unis.common.HCNetSDK;
-import com.unis.common.osSelect;
-import com.unis.config.AddressModel;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.core.annotation.Order;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-
-/**
- * @author qingsong.han
- * @description:
- * @create 2024-07-31 9:29
- */
-@Slf4j
-// 启动加载注解
-//@Component
-@Order(1)
-public class FaceMain implements ApplicationRunner {
-
-    static HCNetSDK hCNetSDK = null;
-    static int lUserID = -1;//用户句柄
-    static int lAlarmHandle = -1; //布防句柄
-    static int lListenHandle = -1; //监听句柄
-
-    // 设备连接信息
-    @Resource
-    private AddressModel addressModel;
-
-    /*
-     * 获取配置
-     */
-    private void mainMethod() {
-        log.info("FaceMain mainMethod===========================================================init thread");
-        try {
-            if (hCNetSDK == null) {
-                if (!CreateSDKInstance()) {
-                    log.error("Load SDK fail");
-                    return;
-                }
-            }
-            //linux系统建议调用以下接口加载组件库
-            if (osSelect.isLinux()) {
-                HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
-                HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
-                //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
-                String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
-                String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
-
-                System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
-                ptrByteArray1.write();
-                hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
-
-                System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
-                ptrByteArray2.write();
-                hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
-
-                String strPathCom = System.getProperty("user.dir") + "/lib";
-                HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
-                System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
-                struComPath.write();
-                hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
-            }
-
-            //初始化
-            hCNetSDK.NET_DVR_Init();
-
-            //加载日志
-            hCNetSDK.NET_DVR_SetLogToFile(3, "..//sdklog", false);
-
-            //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
-            HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
-            HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
-
-            String m_sDeviceIP = addressModel.getDeviceIP();//设备ip地址
-            m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
-            System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
-
-            String m_sUsername = addressModel.getUserName();//设备用户名
-            m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
-            System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
-
-            String m_sPassword = addressModel.getPassword();//设备密码
-            m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
-            System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
-
-            m_strLoginInfo.wPort = 8000;
-            m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
-            m_strLoginInfo.byLoginMode = 0;  //登录模式：0- SDK私有协议，1- ISAPI协议
-            m_strLoginInfo.write();
-
-            lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
-            if (lUserID == -1) {
-                log.error("登录失败,错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
-            } else {
-                log.info("{} 设备登录成功!设备序列号: {}", m_sDeviceIP, new String(m_strDeviceInfo.struDeviceV30.sSerialNumber).trim());
-                m_strDeviceInfo.read();
-            }
-
-            //报警布防实时接收人脸比对的结果信息，也可以单独参考“2-报警布防监听”这个Demo示例
-            Alarm.SetAlarm(lUserID);
-
-            // TODO 暂停状态 需要测试改造
-            while (true) {
-                //这里加入控制台输入控制，是为了保持连接状态，当输入Y表示布防结束
-                log.info("请选择是否撤出布防(Y/N):");
-                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
-                String str = bufferedReader.readLine();
-                if (str.toUpperCase().equals("Y")) {
-                    break;
-                }
-            }
-            Thread.sleep(3000);
-
-            //退出之前判断布防监听状态，并做撤防和停止监听操作
-            if (lAlarmHandle >= 0) {
-                if (!hCNetSDK.NET_DVR_CloseAlarmChan_V30(lAlarmHandle)) {
-                    log.error("撤防失败，错误码: {}", hCNetSDK.NET_DVR_GetLastError());
-                } else {
-                    log.info("撤防成功！！！");
-                }
-            }
-            if (lListenHandle >= 0) {
-                if (!hCNetSDK.NET_DVR_StopListen_V30(lListenHandle)) {
-                    log.error("取消监听失败，错误码：{}", hCNetSDK.NET_DVR_GetLastError());
-                } else {
-                    log.info("停止监听成功！！！");
-                }
-            }
-
-            //注销登录，程序退出时调用；程序同时对接多台设备时，每一台设备分别调用一次接口，传入不同的登录句柄
-            if (lUserID >= 0) {
-                hCNetSDK.NET_DVR_Logout(lUserID);
-            }
-
-            //SDK反初始化，释放资源，程序退出时调用
-            boolean b = hCNetSDK.NET_DVR_Cleanup();
-            if (b)
-                log.info("释放资源,程序退出!");
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-    }
-
-    /**
-     * 根据不同操作系统选择不同的库文件和库路径
-     *
-     * @return
-     */
-    private boolean CreateSDKInstance() {
-        if (hCNetSDK == null) {
-            synchronized (HCNetSDK.class) {
-                String strDllPath = "";
-                try {
-//                    System.setProperty("jna.debug_load", "true");
-                    if (osSelect.isWindows())
-                        //win系统加载库路径
-                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
-                    else if (osSelect.isLinux())
-                        //Linux系统加载库路径
-                        strDllPath = System.getProperty("user.dir") + "/lib/libhcnetsdk.so";
-                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
-                } catch (Exception ex) {
-                    log.error("loadLibrary: {} Error: {}", strDllPath, ex.getMessage());
-                    return false;
-                }
-            }
-        }
-        return true;
-    }
-
-    @Override
-    public void run(ApplicationArguments args) throws Exception {
-        // after behind for application run,because implements ApplicationRunner
-        this.mainMethod();
-    }
-}

src/main/java/com/unis/fileUpload/DevFileService.java

@@ -0,0 +1,90 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.fileUpload;
+
+import cn.hutool.core.convert.Convert;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.img.ImgUtil;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.util.NumberUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.unis.config.DevFileMinIoUtil;
+import com.unis.enums.DevFileEngineTypeEnum;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.math.BigDecimal;
+import java.util.UUID;
+
+
+/**
+ * 文件Service接口
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:27
+ **/
+public interface DevFileService {
+
+    /**
+     * MultipartFile文件上传，返回文件Url
+     *
+     * @author xuyuxiang
+     * @date 2022/4/22 15:53
+     **/
+    String uploadReturnUrl(MultipartFile file);
+
+    @Service
+    class DevFileServiceImpl implements DevFileService {
+
+        @Override
+        public String uploadReturnUrl(MultipartFile file) {
+            return this.storageFile(file);
+        }
+
+        /**
+         * 存储文件
+         *
+         * @author xuyuxiang
+         * @date 2022/6/16 16:24
+         **/
+        private String storageFile(MultipartFile file) {
+            // 生成id
+            String fileId = UUID.randomUUID().toString();
+            return DevFileMinIoUtil.storageFileWithReturnUrl(DevFileMinIoUtil.getDefaultBucketName(), genFileKey(fileId, file), file);
+        }
+
+        @SuppressWarnings("all")
+        public String genFileKey(String fileId, MultipartFile file) {
+
+            // 获取文件原始名称
+            String originalFileName = file.getOriginalFilename();
+
+            // 获取文件后缀
+            String fileSuffix = FileUtil.getSuffix(originalFileName);
+
+            // 生成文件的对象名称，格式如:1377109572375810050.docx
+            String fileObjectName = fileId + StrUtil.DOT + fileSuffix;
+
+            // 获取日期文件夹，格式如，2021/10/11/
+            String dateFolderPath = DateUtil.thisYear() + StrUtil.SLASH +
+                    (DateUtil.thisMonth() + 1) + StrUtil.SLASH +
+                    DateUtil.thisDayOfMonth() + StrUtil.SLASH;
+
+            // 返回
+            return dateFolderPath + fileObjectName;
+        }
+
+    }
+
+}

src/main/java/com/unis/test/DevFileController.java

@@ -0,0 +1,54 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.test;
+
+import com.unis.enums.DevFileEngineTypeEnum;
+import com.unis.fileUpload.DevFileService;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestPart;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+
+/**
+ * 文件控制器
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:26
+ **/
+@RestController
+@RequestMapping("/file")
+public class DevFileController {
+
+    @Resource
+    private DevFileService devFileService;
+
+
+    /**
+     * MINIO文件上传，返回文件Url
+     *
+     * @author xuyuxiang
+     * @date 2021/10/13 14:01
+     **/
+    // 上传MINIO文件返回url
+    @PostMapping("/uploadMinIoReturnUrl")
+    public String uploadMinIoReturnUrl(@RequestPart("file") MultipartFile file) {
+        return devFileService.uploadReturnUrl(file);
+    }
+
+
+
+}

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

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

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

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

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

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

src/main/resources/application-dev.yml

@@ -14,4 +14,9 @@ exceptionAlarm:
 # 只支持post
 address:
   # 推送异常闯入/入侵信息地址
-  pushToIntrusion: http://localhost:8077/pushIntrusion
+  pushToIntrusion: http://localhost:8077/pushIntrusion
+minio:
+  endpoint: http://172.16.0.36:15772
+  access-key: 4vFQhyfxcwcqAXHPOV57
+  secret-key: 3kB9RIsEqXuHMG6FDDp4f299LACEwztgybwYTAmg
+  bucket-name: province-qinghai

src/main/resources/application-prod.yml

@@ -14,4 +14,9 @@ exceptionAlarm:
 # 只支持post
 address:
   # 推送异常闯入/入侵信息地址
-  pushToIntrusion: http://23.99.21.201:59882/pushIntrusion
+  pushToIntrusion: http://23.99.21.201:59882/pushIntrusion
+minio:
+  endpoint: http://172.18.93.234:15772
+  access-key: ubj8S4OuD5hPNq7tzHeD
+  secret-key: TwyyMuHgYlZFFW5q20BVPeowfwgOrCipdyEwi52u
+  bucket-name: province-qinghai

src/main/resources/application.yml

@@ -5,9 +5,13 @@ server:
 spring:
   application:
     name: video-super-brain
+  # dev: 开发环境,prod: 生产环境（线上）
+  profiles:
+    active: dev
   jackson:
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
-  # dev: 开发环境,prod: 生产环境（线上）
-  profiles:
-    active: dev
+  servlet:
+    multipart:
+      max-file-size: 100MB
+      max-request-size: 100MB