From d3b7bbe7102cd089680a828f5d8f6402c8cf6342 Mon Sep 17 00:00:00 2001
From: pansen <pansen626@sina.com>
Date: 星期四, 07 三月 2019 14:43:28 +0800
Subject: [PATCH] GB28181集成完成,集成推流模块

---
 QiaoJiaSystem/StructureApp/PerimeterElement.cpp |   26 +++++++++++++++++++++++---
 1 files changed, 23 insertions(+), 3 deletions(-)

diff --git a/QiaoJiaSystem/StructureApp/PerimeterElement.cpp b/QiaoJiaSystem/StructureApp/PerimeterElement.cpp
index e33b86a..19f3a92 100644
--- a/QiaoJiaSystem/StructureApp/PerimeterElement.cpp
+++ b/QiaoJiaSystem/StructureApp/PerimeterElement.cpp
@@ -24,7 +24,8 @@
     pManagerEsDB(nullptr),
     m_bIsMask(true),
     m_bSetWH(false),
-    pointArray(nullptr)
+    pointArray(nullptr),
+    m_rpcClient("RtspAnalysServer", "127.0.0.1",appPref.getIntData("RpcServerPort"),"tcp")
 {
 
     pManagerEsDB = new EsDBTool(appPref.getStringData("ipAdd"), appPref.getIntData("ipPort"));
@@ -168,7 +169,7 @@
     INFO("State:"<<state<<" Num:"<<num<<" mRealNum:"<<mRealNum<<" LowerLimit :"<<m_sdkRule.nAlarmNumLowerLimit<<" HightLimit: "<<m_sdkRule.nAlarmNumUpperLimit);
     m_triggerElement.setState(state);
     m_triggerElement.triggerOnce();
-    if (m_triggerElement.getTriggerState() )
+    if (m_triggerElement.getTriggerState())
     {
         if(num > 0) {
             if(pointArray!=nullptr)
@@ -177,7 +178,7 @@
 
                 int npt[]={npts};
 
-                cv::polylines(image, ppt,npt, 1, true,cv::Scalar(255,255,0));
+                cv::polylines(image, ppt,npt, 1, true,cv::Scalar(255,255,0), 2);
             }
 
             for(auto rect:m_recVec)
@@ -195,6 +196,10 @@
         }
         DBG("num=" << num << " lastnum=" << mRealNum);
         mRealNum = num;
+
+        //todo 閲嶇疆鎶ヨtrigger
+        m_triggerElement.setState(false);
+        m_triggerElement.triggerOnce();
     }
 
 //    if (m_triggerElement.getTriggerState() && num!=mRealNum)
@@ -382,6 +387,21 @@
     t_json["ack_alarm"] = m_triggerElement.getTriggerState() ? "0" : "";  //  que ren shi fou bao jing
     t_json["cluster_id"] = appPref.getStringData("clusterID");; // ji qun id
     t_json["imgKey"] = imgKey;
+    try {
+        auto server = m_rpcClient.getServer();
+        if (!server)
+        {
+            ERR("server is null");
+            //return false;
+        }
+        INFO("Record Video "<<imgKey);
+        server->recordVideo(imgKey);
+    }
+    catch (std::exception &e)
+    {
+        ERR("Record Video Err: "<<imgKey <<"   Message: "<<e.what());
+        //return false;
+    }
     INFO("SaveImgKeyToES: "<<imgKey);
     bool retface = false;
     if (pManagerEsDB)

--
Gitblit v1.8.0