From 0436e5443295395025f89f0d091aab1e9551d1a4 Mon Sep 17 00:00:00 2001
From: pansen <pansen626@sina.com>
Date: 星期四, 10 一月 2019 20:26:31 +0800
Subject: [PATCH] Merge branch 'ywv1.2' of ssh://192.168.1.226:29418/development/c++ into ywv1.2

---
 QiaoJiaSystem/VideoAnalysFromHC/BaiscSDKAnalysVideo.h |   54 +++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 37 insertions(+), 17 deletions(-)

diff --git a/QiaoJiaSystem/VideoAnalysFromHC/BaiscSDKAnalysVideo.h b/QiaoJiaSystem/VideoAnalysFromHC/BaiscSDKAnalysVideo.h
index a742fb6..622bc1e 100644
--- a/QiaoJiaSystem/VideoAnalysFromHC/BaiscSDKAnalysVideo.h
+++ b/QiaoJiaSystem/VideoAnalysFromHC/BaiscSDKAnalysVideo.h
@@ -16,7 +16,7 @@
 #include <basic/util/app/AppPreference.hpp>
 #include <basic/http_server/HttpSrvRetRecieve.hpp>
 #include <basic/util/net_config/net_config.h>
-
+#include "DBStruct.h"
 #define SETSCORE(VEC, POS, IDENT) appPref.setFloatData(IDENT, POS >= VEC.size() ? 80 : VEC[POS]);
 
 class BaiscSDKAnalysVideo : public mythread<getsdkHdlManage> {
@@ -60,7 +60,7 @@
     virtual void doFunc(std::shared_ptr<getsdkHdlManage> spPacket) {
 
 //        DBG("do func sdk");
-        Json::Value json;
+  //      Json::Value json;
 
         //split sdks enable
         //#todo other sdk
@@ -70,42 +70,62 @@
 //            std::string s_c = str_cmp_thr;
         vector<int> sdkDetCoVec = chnString2Vec(spPacket->str_det_thr);
         vector<int> sdkComCoVec = chnString2Vec(spPacket->str_cmp_thr);
-
+        SdkRuleMap ruleMap;
         int t_size = sdkVec.size();
         std::string str_pre(spPacket->strDevID);
         str_pre.append(to_string(spPacket->nChannelID));
         for (int i = 0; i < t_size; i++) {
             switch (sdkVec[i]) {
-                case 1: {
-                    json["face.enable"] = "1";
+                case FaceSdk: {
+//                    json["face.enable"] = "1";
+
                     DBG("" << str_pre);
+
                     DBG(" TESTCODE setValue" << str_pre << "  " << sdkDetCoVec[i] << "  " << sdkComCoVec[i]);
-                    SETSCORE(sdkDetCoVec, i, str_pre + "face.det");
-                    SETSCORE(sdkComCoVec, i, str_pre + "face.cmp");
+//                    SETSCORE(sdkDetCoVec, i, str_pre + "face.det");
+//                    SETSCORE(sdkComCoVec, i, str_pre + "face.cmp");
+                    SdkRule rule;
+                    rule.nIsRun=1;
+                    rule.nQuality=sdkDetCoVec[i];
+                    rule.nThreshold=sdkComCoVec[i];
+                    rule.strAddr=spPacket->str_addr.c_str();
+                    ruleMap[FaceSdk]=rule;
                     break;
                 }
-                case 2: {
-                    DBG("XX.enable    " << "1");
+                case CarSdk: {
+//                    DBG("XX.enable    " << "1");
                     DBG(" TESTCODE setValue" << str_pre << "  " << sdkDetCoVec[i] << "  " << sdkComCoVec[i]);
-                    SETSCORE(sdkDetCoVec, i, str_pre + "XX.det");
-                    SETSCORE(sdkComCoVec, i, str_pre + "XX.cmp");
+//                    SETSCORE(sdkDetCoVec, i, str_pre + "XX.det");
+//                    SETSCORE(sdkComCoVec, i, str_pre + "XX.cmp");
+                    SdkRule rule;
+                    rule.nIsRun=1;
+                    rule.nQuality=sdkDetCoVec[i];
+                    rule.nThreshold=sdkComCoVec[i];
+                    rule.strAddr=spPacket->str_addr.c_str();
+                    ruleMap[CarSdk]=rule;
                     break;
                 }
-                case 3: {
-                    json["yolo.enable"] = "1";
+                case YoloSdk: {
+//                    json["yolo.enable"] = "1";
                     DBG(" TESTCODE setValue" << str_pre << "  " << sdkDetCoVec[i] << "  " << sdkComCoVec[i]);
-                    SETSCORE(sdkDetCoVec, i, str_pre + "yolo.det");
-                    SETSCORE(sdkComCoVec, i, str_pre + "yolo.cmp");
+//                    SETSCORE(sdkDetCoVec, i, str_pre + "yolo.det");
+//                    SETSCORE(sdkComCoVec, i, str_pre + "yolo.cmp");
+                    SdkRule rule;
+                    rule.nIsRun=1;
+                    rule.nQuality=sdkDetCoVec[i];
+                    rule.nThreshold=sdkComCoVec[i];
+                    rule.strAddr=spPacket->str_addr.c_str();
+                    ruleMap[YoloSdk]=rule;
                     break;
                 }
             }
         }
-        json["addr"] = spPacket->str_addr;
+     //   json["addr"] = spPacket->str_addr;
         INFO("cam add is " << spPacket->str_addr);
 
         //#todo get address
 
-        AppPipeController _AppPipeController(spPacket->src_path, json);
+        AppPipeController _AppPipeController(spPacket->src_path, ruleMap);
         _AppPipeController.setfdfsClient(&fdfsClient);
         //#todo from path get file list
         file_filter_type filter = [](const char *dirName, const char *dirent) {

--
Gitblit v1.8.0