1、报警记录的获取由原来的直接从摄像头获取改为从超脑获取

2、报警记录中增加图片信息

pom.xml

@@ -3,20 +3,27 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <parent>
-        <groupId>com.unitssoft</groupId>
-        <artifactId>smart-grp-nof-pom</artifactId>
-        <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../smart-grp-nof-pom/pom.xml</relativePath>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.3.12.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
     </parent>
 
     <artifactId>smart-grp-nof-devices</artifactId>
     <groupId>com.unissoft</groupId>
-    <version>0.0.1-SNAPSHOT</version>
+    <version>1.0</version>
     <name>smart-grp-nof-devices</name>
-    <description>Demo project for Spring Boot</description>
     <packaging>jar</packaging>
     <properties>
         <java.version>1.8</java.version>
+        <springboot.version>2.3.12.RELEASE</springboot.version>
+        <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
+        <logstash.version>7.0.1</logstash.version>
+        <fastjson.version>1.2.83</fastjson.version>
+        <lombok.version>1.18.20</lombok.version>
+        <jna.version>1.0</jna.version>
+        <dom4j.version>2.1.4</dom4j.version>
+        <spring-web.version>5.2.15.RELEASE</spring-web.version>
     </properties>
     <dependencies>
         <!-- cloud -->
@@ -33,6 +40,7 @@
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>
             <version>${fastjson.version}</version>
+
         </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>
@@ -42,7 +50,6 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-integration</artifactId>
         </dependency>
-        <!-- 引入本地依赖 start -->
         <dependency>
             <groupId>com.sun.jna</groupId>
             <artifactId>jna</artifactId>
@@ -58,7 +65,33 @@
             <artifactId>dom4j</artifactId>
             <version>${dom4j.version}</version>
         </dependency>
-        <!-- 引入外部依赖 end -->
+        <!-- SpringWeb模块-->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+            <version>${spring-web.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.code.findbugs</groupId>
+            <artifactId>annotations</artifactId>
+            <version>3.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+            <version>1.14</version>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-test</artifactId>
+            <version>${springboot.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <!-- springCloud version -->
@@ -80,6 +113,14 @@
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>
             </plugin>
+            <!--打包时跳过测试-->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <configuration>
+                    <skipTests>true</skipTests>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

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

@@ -57,19 +57,25 @@ public class Alarm {
      * 注意: 设置监听前需要现在本机pc配置端口
      * 具体步骤：库文件ClientDemo->登录设备->配置->网络参数配置->配置告警管理主机地址、告警管理主机端口（需要与NET_DVR_StartListen_V30接口中对应）
      */
-    public void StartListen() {
+    public static void StartListen() {
         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("设置回调函数成功!");
+            }
         }
         /**
          * 这里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);
+        FaceMain.lListenHandle = FaceMain.hCNetSDK.NET_DVR_StartListen_V30(null, (short) 17201, fMSFCallBack_V31, null);
         if (FaceMain.lListenHandle == -1) {
-            log.error("监听失败: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
+            log.error("在端口17201启动报警监听失败: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
         } else {
-            log.info("监听成功");
+            log.info("在端口17201启动报警监听成功");
         }
     }
 

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

@@ -1,10 +1,12 @@
 package com.unissoft.face;
 
 import com.sun.jna.Native;
+import com.sun.jna.Pointer;
 import com.unissoft.common.osSelect;
 import com.unissoft.netSDKDemo.HCNetSDK;
 import com.unissoft.pushMsg.AddressModel;
 import lombok.extern.slf4j.Slf4j;
+import org.dom4j.util.StringUtils;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.core.annotation.Order;
@@ -14,6 +16,9 @@ import javax.annotation.Resource;
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
+import java.time.LocalDate;
+import java.util.Calendar;
+import java.util.Date;
 import java.util.Scanner;
 
 @Slf4j
@@ -35,6 +40,7 @@ public class FaceMain implements ApplicationRunner {
      */
     private void mainMethod() {
         log.info("FaceMain mainMethod===========================================================init thread");
+
         try {
             if (hCNetSDK == null) {
                 if (!CreateSDKInstance()) {
@@ -42,13 +48,16 @@ public class FaceMain implements ApplicationRunner {
                     return;
                 }
             }
+
             //linux系统建议调用以下接口加载组件库
             if (osSelect.isLinux()) {
+                System.out.println("linux system come in here");
                 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.out.println("strPath1:" + strPath1);
 
                 System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
                 ptrByteArray1.write();
@@ -64,7 +73,6 @@ public class FaceMain implements ApplicationRunner {
                 struComPath.write();
                 hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
             }
-
             //初始化
             hCNetSDK.NET_DVR_Init();
 
@@ -74,7 +82,7 @@ public class FaceMain implements ApplicationRunner {
             //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
             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();//设备信息
-
+            //m_strDeviceInfo.struDeviceV30.
             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());
@@ -92,6 +100,7 @@ public class FaceMain implements ApplicationRunner {
             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());
@@ -100,49 +109,74 @@ public class FaceMain implements ApplicationRunner {
                 m_strDeviceInfo.read();
             }
 
+            try {
+                log.info("進行撤防");
+                hCNetSDK.NET_DVR_CloseAlarmChan_V30(lAlarmHandle);
+            } catch (Exception e) {
+                log.info("不需要撤防");
+            }
+            try {
+                log.info("停止监听");
+                hCNetSDK.NET_DVR_StopListen_V30(lListenHandle);
+            } catch (Exception e) {
+                log.info("不需要停止监听");
+            }
+
             //报警布防实时接收人脸比对的结果信息，也可以单独参考“2-报警布防监听”这个Demo示例
             Alarm.SetAlarm(lUserID);
 
             // TODO 暂停状态 需要测试改造
+            Date satart = new Date();
+            Calendar c1 = Calendar.getInstance();
+            c1.setTime(satart);
             while (true) {
                 //这里加入控制台输入控制，是为了保持连接状态，当输入Y表示布防结束
-                log.info("请选择是否撤出布防(Y/N):");
+                log.info("监听进行中，输入字母Q可退出监听");
                 BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
                 String str = bufferedReader.readLine();
-                if (str.toUpperCase().equals("Y")) {
+                if (str.toUpperCase().equals("Q")) {
+                    break;
+                 /*
+                Thread.sleep(60000);
+                Date end = new Date();
+                Calendar c2 = Calendar.getInstance();
+                c2.setTime(end);
+                long millis = c2.getTimeInMillis() - c1.getTimeInMillis();
+                long hours = millis/(1000*60*60);
+                if(hours > 10) {
+                    log.info("时间过去10小时，退出程序");
                     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 (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);
-            }
+                //注销登录，程序退出时调用；程序同时对接多台设备时，每一台设备分别调用一次接口，传入不同的登录句柄
+                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) {
+                //SDK反初始化，释放资源，程序退出时调用
+                boolean b = hCNetSDK.NET_DVR_Cleanup();
+                if (b)
+                    log.info("释放资源,程序退出!");
+            }
+        } catch (Exception e) {
             e.printStackTrace();
         }
     }
@@ -174,9 +208,72 @@ public class FaceMain implements ApplicationRunner {
         return true;
     }
 
+    private void alarmListenMethod() {
+
+        if (hCNetSDK == null) {
+            if (!CreateSDKInstance()) {
+                log.error("Load SDK fail");
+                return;
+            }
+        }
+
+        //linux系统建议调用以下接口加载组件库
+        if (osSelect.isLinux()) {
+            System.out.println("linux system come in here");
+            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.out.println("strPath1:" + strPath1);
+
+            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();
+        Alarm.StartListen();
+        try {
+            while (true) {
+                Thread.sleep(60000);
+                log.info("监听进行中，如需退出监听请输入字母Q");
+                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
+                String str = bufferedReader.readLine();
+                if (str.toUpperCase().equals("Q")) {
+                    break;
+                }
+            }
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } catch (IOException ioe) {
+            ioe.printStackTrace();
+        }
+
+        //停止监听
+        if (lListenHandle >= 0) {
+            if (!hCNetSDK.NET_DVR_StopListen_V30(lListenHandle)) {
+                log.error("取消监听失败，错误码：{}", hCNetSDK.NET_DVR_GetLastError());
+            } else {
+                log.info("停止监听成功！！！");
+            }
+        }
+        hCNetSDK.NET_DVR_Cleanup();
+    }
     @Override
     public void run(ApplicationArguments args) throws Exception {
-        // after behind for application run,because implements ApplicationRunner
+        //after behind for application run,because implements ApplicationRunner
         this.mainMethod();
+        //this.alarmListenMethod();
     }
 }

src/main/java/com/unissoft/netSDKDemo/FMSGCallBack_V31.java

@@ -6,6 +6,8 @@ import com.unissoft.pushMsg.AlarmDSService;
 import com.unissoft.pushMsg.AlarmDSServiceImpl;
 import lombok.extern.slf4j.Slf4j;
 
+import java.io.File;
+import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -30,20 +32,47 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
         log.info("报警事件发生,进入回调");
         /*String hexString = Integer.toHexString(lCommand);
         log.info("报警类型 hexString {}", hexString);*/
+        HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm;
+        Pointer ruleAlarmPointer;
         switch (lCommand) {
             case HCNetSDK.COMM_ALARM_RULE://行为分析信息上传
+
+                ruleAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
+                ruleAlarm.write();
+                ruleAlarmPointer = ruleAlarm.getPointer();
+                ruleAlarmPointer.write(0, pAlarmInfo.getByteArray(0, ruleAlarm.size()), 0, ruleAlarm.size());
+                ruleAlarm.read();
+                //log.info("alarm type in the COMM_ALARM_RULE ---------->: {}", JSON.toJSONString(ruleAlarm));
+                System.out.println("行为类型：" + ruleAlarm.struRuleInfo.wEventTypeEx);
+                System.out.println("报警通道对应设备的通道号：" + ruleAlarm.struDevInfo.byChannel);
+                System.out.println("SDK接入设备的通道号：" + ruleAlarm.struDevInfo.byIvmsChannel);
+                System.out.println("报警通道对应设备的IP地址：" + ruleAlarm.struDevInfo.struDevIP.toString());
+                System.out.println("报警通道对应设备的端口号：" + ruleAlarm.struDevInfo.wPort);
+
+                
+                alarmDSService.pushLCommandEx(lCommand, ruleAlarm);
                 log.info(
-                        "lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
+                        "行为分析事件，lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
                         lCommand, JSON.toJSONString(pAlarmer), JSON.toJSONString(pAlarmInfo),dwBufLen,JSON.toJSONString(pUser)
                 );
-                HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
+                break;
+
+            case HCNetSDK.COMM_VEHICLE_CONTROL_ALARM://车辆报警上传
+                log.info(
+                        "车辆报警事件，lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
+                        lCommand, JSON.toJSONString(pAlarmer), JSON.toJSONString(pAlarmInfo),dwBufLen,JSON.toJSONString(pUser)
+                );
+                ruleAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
                 ruleAlarm.write();
-                Pointer ruleAlarmPointer = ruleAlarm.getPointer();
+                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));
+                //log.info("alarm type in the COMM_VEHICLE_CONTROL_ALARM ---------->: {}", JSON.toJSONString(ruleAlarm));
                 alarmDSService.pushLCommand(lCommand);
                 break;
+            case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
+                log.info("报警主机防区报警");
+                break;
             case HCNetSDK.COMM_SNAP_MATCH_ALARM:
                 //人脸黑名单比对报警
                 log.info("SNAP_MATCH_ALARM");
@@ -144,6 +173,7 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
                         buffers.get(bytes);
                         fout.write(bytes);
                         fout.close();
+
                     } catch (IOException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
@@ -171,7 +201,11 @@ public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
                 break;
             default:
                 // TODO 单报警设备 目前不需要 sAlarmType alarmNow
-                log.info("alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
+                //log.info("alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
+                log.info(
+                        "不分类事件，不返回报警具体数据，lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
+                        lCommand, JSON.toJSONString(pAlarmer), JSON.toJSONString(pAlarmInfo),dwBufLen,JSON.toJSONString(pUser)
+                );
                 alarmDSService.pushLCommand(lCommand);
                 break;
         }

src/main/java/com/unissoft/netSDKDemo/HCNetSDK.java

@@ -8647,6 +8647,7 @@ public class NET_DVR_PIC_PARAM extends Structure {
         public byte[] byRes = new byte[128];
     }
 
+
     public static class BYTE_ARRAY extends Structure {
         public byte[] byValue;
 

src/main/java/com/unissoft/pushMsg/AddressModel.java

@@ -14,8 +14,11 @@ import org.springframework.stereotype.Component;
 public class AddressModel {
 
     // 推送地址
-    @Value("${address.pushToIntrusion}")
-    private String pushToIntrusion;
+    //@Value("${address.pushToIntrusion}")
+    //private String pushToIntrusion;
+    @Value("${address.push}")
+    private String push;
+
     // 设备ip
     @Value("${exceptionAlarm.deviceIP}")
     private String deviceIP;

src/main/java/com/unissoft/pushMsg/AlarmDSService.java

@@ -1,6 +1,7 @@
 package com.unissoft.pushMsg;
 
 import com.sun.jna.Callback;
+import com.unissoft.netSDKDemo.HCNetSDK;
 
 /**
  * @author qingsong.han
@@ -11,4 +12,5 @@ public interface AlarmDSService extends Callback {
 
     void pushLCommand(Integer lCommand);
 
+    void pushLCommandEx(Integer lCommand, HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm);
 }

src/main/java/com/unissoft/pushMsg/AlarmDSServiceImpl.java

@@ -1,14 +1,25 @@
 package com.unissoft.pushMsg;
 
+import com.unissoft.netSDKDemo.HCNetSDK;
 import com.unissoft.utils.GetBeanUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.binary.Base64;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.client.RestTemplate;
 
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
 import java.net.URL;
+import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
+import java.text.SimpleDateFormat;
 import java.util.Date;
 
 /**
@@ -38,7 +49,74 @@ public class AlarmDSServiceImpl implements AlarmDSService {
         requestEntity.add("orgCode", addressModel.getOrgCode());
         log.info("报警类型 int: {}", requestEntity);
         // push of post for object
-        Object object = restTemplate.postForObject(addressModel.getPushToIntrusion(), requestEntity, Object.class);
+        Object object = restTemplate.postForObject(addressModel.getPush(), requestEntity, Object.class);
         log.info("AlarmDSServiceImpl push alarm result: {}", object);
     }
+
+    @Override
+    public void pushLCommandEx(Integer lCommand, HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm) {
+        // 获取spring RestTemple bean
+        RestTemplate restTemplate = (RestTemplate) GetBeanUtil.getBean("restTemplate");
+        // get push class AddressModel bean
+        AddressModel addressModel = (AddressModel) GetBeanUtil.getBean("addressModel");
+        // MultiValueMap requestEntity
+        MultiValueMap<String, Object> requestEntity = new LinkedMultiValueMap<>();
+        // 报警类型(异常闯入/入侵) int 4354
+        requestEntity.add("sAlarmType", lCommand);
+        // 报警时间
+        requestEntity.add("alarmNow", new Date());
+        // 设备ip
+        requestEntity.add("deviceIP", addressModel.getDeviceIP());
+        // 机构编码
+        requestEntity.add("orgCode", addressModel.getOrgCode());
+
+        requestEntity.add("cameraIP", ruleAlarm.struDevInfo.struDevIP.toString());
+        //将字节写入文件
+        SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+        String newName = sf.format(new Date());
+        FileOutputStream fout;
+        String filename = ".//pic//" + newName + "_pSnapPicBuffer" + ".jpg";
+        try {
+            long offset = 0;
+            fout = new FileOutputStream(filename);
+            ByteBuffer buffers = ruleAlarm.pImage.getByteBuffer(offset, ruleAlarm.dwPicDataLen);
+            byte[] bytes = new byte[ruleAlarm.dwPicDataLen];
+            buffers.rewind();
+            buffers.get(bytes);
+            fout.write(bytes);
+            fout.close();
+        } catch (FileNotFoundException e) {
+            throw new RuntimeException(e);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+
+        long offset = 0;
+        ByteBuffer buffers = ruleAlarm.pImage.getByteBuffer(offset, ruleAlarm.dwPicDataLen);
+        byte[] bytes = new byte[ruleAlarm.dwPicDataLen];
+        buffers.rewind();
+        buffers.get(bytes);
+        buffers.flip();
+        String picStr = StandardCharsets.UTF_8.decode(buffers).toString();
+        log.info("pic-string length:"+picStr.length());
+        requestEntity.add("pic", picStr);
+        requestEntity.add("picSize", ruleAlarm.dwPicDataLen);
+        log.info("报警类型: %d", requestEntity.get("sAlarmType") + "超脑IP："+requestEntity.get("deviceIP")+"\t摄像头IP："+requestEntity.get("cameraIP"));
+        // push of post for object
+        //Object object = restTemplate.postForObject(addressModel.getPush(), requestEntity, Object.class);
+        //log.info("AlarmDSServiceImpl push alarm result: {}", object);
+
+        RestTemplate rest = new RestTemplate();
+        MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
+        headers.add("content-type", MediaType.APPLICATION_FORM_URLENCODED_VALUE);
+        // headers.add("Accept", MediaType.APPLICATION_FORM_URLENCODED_VALUE);
+        // 请求体
+        MultiValueMap<String, String> body = new LinkedMultiValueMap<>();
+        body.add("file", "picture");
+        body.add("base64", Base64.encodeBase64String(bytes));
+        body.add("key", "123456");
+
+        HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(body, headers);
+        ResponseEntity<String> response = rest.postForEntity(addressModel.getPush(), httpEntity, String.class);
+    }
 }

src/main/resources/bootstrap.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8072
+  port: 18071
   tomcat:
     uri-encoding: UTF-8
 spring:
@@ -10,7 +10,7 @@ spring:
     time-zone: GMT+8
   # dev: 开发环境,test: 测试环境,prod: 生产环境（线上）
   profiles:
-    active: prop
+    active: prod
 ---
 spring:
   profiles: dev
@@ -28,22 +28,23 @@ exceptionAlarm:
 # 只支持post
 address:
   # 推送异常闯入/入侵信息地址
-  pushToIntrusion: http://localhost:8077/pushIntrusion
+  pushToIntrusion1: http://localhost:8077/pushIntrusion
 ---
 spring:
-  profiles: prop
+  profiles: prod
 # 异常闯入异常,入侵分析
 # 设备登录
 exceptionAlarm:
   # 设备ip地址 DS-2CD7T27DWD-IZS(16384)/DS-7716NX-I4(4354)-->4432
-  deviceIP: 192.168.173.162
+  deviceIP: 192.168.193.1
   # orgCode
-  org-code: WZZ
+  org-code: SJG
   # 设备用户名
   userName: admin
   # 设备密码
-  password: JL@123456
+  password: Relax123
 # 只支持post
 address:
   # 推送异常闯入/入侵信息地址
-  pushToIntrusion: http://23.99.21.201:59882/pushIntrusion
+  #push: http://23.99.21.201:59882/pushIntrusion
+  push: http://10.105.101.60:8072/pushIntrusion