增加各个车厢显示合并显示，优化管道传输逻辑

.vscode/settings.json

@@ -70,7 +70,8 @@
         "hash_map": "cpp",
         "hash_set": "cpp",
         "codecvt": "cpp",
-        "future": "cpp"
+        "future": "cpp",
+        "queue": "cpp"
     },
     "C_Cpp.errorSquiggles": "Disabled",
     "commentTranslate.targetLanguage": "en"

modules/dataType/include/DataSource.h

@@ -2,7 +2,9 @@
 #include <iostream>
 #include <gst/gst.h>
 #include <vector>
+#include <memory>
 
+using namespace std;
 
 class DataSource
 {
@@ -15,13 +17,17 @@ public:
     std::string uri;
     std::string range;
     GstElement *source_bin = NULL;
+    std::string Pid;
     bool Play = false;
+    int AddrNum = 0;
 };
 
 class InferInfo{
 public:
     InferInfo(){};
     ~InferInfo(){};
+    static std::shared_ptr<InferInfo> CreateNew();
+
     bool Play = true;
     std::vector<DataSource> DataSources;
 };

modules/dataType/include/Notices.h

@@ -10,3 +10,4 @@
 #define NOTICE_RELEASE    "NOTICE_RELEASE"
 #define NOTICE_REPORT     "NOTICE_REPORT"
 #define NOTICE_INFEREPER  "NOTICE_INFEREPER"
+#define NOTICE_END        "NOTICE_END"

modules/dataType/src/DataSource.cpp

@@ -0,0 +1,9 @@
+#include "DataSource.h"
+
+std::shared_ptr<InferInfo> m_InferInfo = nullptr;
+
+std::shared_ptr<InferInfo> InferInfo::CreateNew()
+{
+    if(m_InferInfo == nullptr) m_InferInfo = std::make_shared<InferInfo>();
+    return m_InferInfo;
+}

modules/inference/include/inference.h

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:37:51
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-12-28 09:03:34
+ * @LastEditTime: 2021-12-29 17:14:59
  */
 #pragma once
 #include <iostream>
@@ -40,6 +40,10 @@
 #include "recorder.h"
 #include <mutex>
 #include <cuda_runtime.h>
+#include <map>
+#include <queue>
+#include <vector>
+
 
 // opencv
 #include <opencv2/core.hpp>
@@ -70,7 +74,7 @@ namespace MIVA{
 
         guint tiler_rows, tiler_columns;
         guint pgie_batch_size;
-
+        
     public:
         std::shared_ptr<std::vector<DataSource>> m_DataList = NULL;
         std::shared_ptr<InferInfo> m_InferInfo = nullptr;
@@ -93,7 +97,7 @@ namespace MIVA{
          * @return {*}
          * @author: lishengyin
          */        
-        int32_t Init(std::shared_ptr<InferInfo> InferInfo);
+        int32_t Init();
 
         /**
          * @description: 释放数据
@@ -244,7 +248,6 @@ namespace MIVA{
          */        
         void AddSources(int sourceId);
 
-
     };
 }
 

modules/inference/src/inference.cpp

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:35:37
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-12-28 09:01:07
+ * @LastEditTime: 2021-12-29 17:22:41
  */
 #include "inference.h"
 
@@ -89,7 +89,7 @@ namespace MIVA{
      * @return {*} 是否初始化成功
      * @author: lishengyin
      */   
-    int32_t Inference::Init(std::shared_ptr<InferInfo> InferInfo)
+    int32_t Inference::Init()
     {
         m_recorder = recorder::CreateNew();
         // init
@@ -107,8 +107,8 @@ namespace MIVA{
             return ERR;
         }
         gst_bin_add (GST_BIN (this->pipeline), streammux);
-        this->m_InferInfo = InferInfo;
-        g_InferInfo = InferInfo;
+        this->m_InferInfo = InferInfo::CreateNew();
+        g_InferInfo = this->m_InferInfo;
 
         // 创建数据源
         std::vector<DataSource>::iterator iter;
@@ -314,24 +314,26 @@ namespace MIVA{
             sourceId++;
         }
         
-        state_return = gst_element_set_state(this->queue1, GST_STATE_NULL);
-        switch (state_return) {
-            case GST_STATE_CHANGE_SUCCESS:
-                InfoL << "queue1 STATE CHANGE SUCCESS";
-                break;
-            case GST_STATE_CHANGE_FAILURE:
-                ErrorL << "queue1 STATE CHANGE FAILURE";
-                break;
-            case GST_STATE_CHANGE_ASYNC:
-                InfoL << "queue1 STATE CHANGE ASYNC";
-                break;
-            case GST_STATE_CHANGE_NO_PREROLL:
-                InfoL << "queue1 STATE CHANGE NO PREROLL";
-                break;
-            default:
-                break;
-        }
-
+        // state_return = gst_element_set_state(this->queue1, GST_STATE_NULL);
+        // switch (state_return) {
+        //     case GST_STATE_CHANGE_SUCCESS:
+        //         InfoL << "queue1 STATE CHANGE SUCCESS";
+        //         break;
+        //     case GST_STATE_CHANGE_FAILURE:
+        //         ErrorL << "queue1 STATE CHANGE FAILURE";
+        //         break;
+        //     case GST_STATE_CHANGE_ASYNC:
+        //         InfoL << "queue1 STATE CHANGE ASYNC";
+        //         break;
+        //     case GST_STATE_CHANGE_NO_PREROLL:
+        //         InfoL << "queue1 STATE CHANGE NO PREROLL";
+        //         break;
+        //     default:
+        //         break;
+        // }
+
+        // 16:49:40  16:58:33 16:58:33 16:55:15
+        
         if(m_recorder != nullptr){
             m_recorder->Finish();
         }
@@ -470,14 +472,17 @@ namespace MIVA{
             // 推理广播
             NoticeCenter::Instance().emitEvent(NOTICE_INFER,frame_meta->source_id, num);
         }
-        // ErrorL << "size:" << i;
-        int interNum = 0;
-        for(auto &data: g_InferInfo->DataSources){
-            if(data.Play == true && data.source_bin != NULL){
-                interNum++;
-            }
-        }
-        if(i == interNum) NoticeCenter::Instance().emitEvent(NOTICE_INFEREPER);
+        gst_buffer_unmap (buf, &in_map_info);
+        // int interNum = 0;
+        // for(auto &data: g_InferInfo->DataSources){
+        //     if(data.Play == true && data.source_bin != NULL){
+        //         interNum++;  
+        //     }
+        // }
+        // if(i == interNum) {
+        //     NoticeCenter::Instance().emitEvent(NOTICE_INFEREPER);
+        // }
+
         return GST_PAD_PROBE_OK;
     }
 
@@ -507,6 +512,9 @@ namespace MIVA{
         NvDsBatchMeta *batch_meta = gst_buffer_get_nvds_batch_meta (buf);
         l_frame = batch_meta->frame_meta_list; 
 
+        map<string, vector<cv::Mat>> frames;
+        frames.clear();
+        int i = 0;
         for (l_frame = batch_meta->frame_meta_list; l_frame != NULL;l_frame = l_frame->next) //从批量中获取某一帧图
         {
             NvDsFrameMeta *frame_meta = (NvDsFrameMeta *) (l_frame->data);
@@ -548,31 +556,78 @@ namespace MIVA{
             cv::Mat out_mat = cv::Mat (cv::Size(frame_width, frame_height), CV_8UC3);
             cv::cvtColor(frame, out_mat, CV_RGBA2BGR);
             
-            //WarnL << "buf_pts" << frame_meta->source_id << ":" << frame_meta->buf_pts << endl;
-            //WarnL << "ntp_timestamp" << frame_meta->source_id << ":" << frame_meta->ntp_timestamp << endl;
-
-            // time_t t;
-            // struct tm *p;
-            // t=frame_meta->buf_pts;
-            // p=gmtime(&t);
-            // char s[80];
-            // strftime(s, 80, "%Y-%m-%d %H:%M:%S", p);
-            // // printf("%d: %s\n", (int)t, s);
-            // WarnL << "time:" << s << endl;
-
-            std::shared_ptr<recorder> m_recorder = recorder::CreateNew();
-            if(m_recorder != nullptr){
-                m_recorder->ConsumerData(frame_meta->source_id, out_mat);
-            }
+            frames[g_InferInfo->DataSources[frame_meta->source_id].Pid].push_back(out_mat);
+            i++;
             if(src_data != NULL) {
                 free(src_data);
                 src_data = NULL;
             }
         }
+        if(frames.size() == 0) {
+            gst_buffer_unmap (buf, &in_map_info);
+            return GST_PAD_PROBE_OK;
+        }
+        std::shared_ptr<recorder> m_recorder = recorder::CreateNew();
+        if(m_recorder != nullptr){
+            for(auto iter = frames.begin(); iter != frames.end(); iter++){
+                int frame_size = iter->second.size();
+                int num = 0;
+                for(auto& source : g_InferInfo->DataSources){
+                    if(source.Pid == iter->first){
+                        num = source.AddrNum;
+                    }
+                }
+                if(frame_size != num) continue;
+                if(frame_size == 1){
+                    m_recorder->ConsumerData(iter->first, iter->second[0]);
+                }else{
+                    cv::Mat outImg;
+                    
+                    int rows = (int) sqrt (frame_size);
+                    int columns = (int) ceil (1.0 * frame_size / rows);
+
+                    int a = 0;
+                    for(int i = 1; i <= rows; i++){
+                        cv::Mat img;
+                        for(; a < columns * i ; a++){
+                            if(a + 1 > frame_size){
+                                cv::Mat M(cv::Size(1920, 1080), CV_8UC3);
+                                hconcat(iter->second[a],iter->second[0],img);
+                            }else if(a == 0){
+                                hconcat(iter->second[a],iter->second[a + 1],img);
+                                a++;
+                            }
+                            else{
+                                if(a >= columns  && a % columns == 0){
+                                    hconcat(iter->second[a],iter->second[a + 1],img);
+                                    a++;
+                                }else 
+                                hconcat(img,iter->second[a],img);
+                            }
+                        }
+                        if(i == 1) outImg = img;
+                        else{
+                            vconcat(outImg,img,outImg);
+                        } 
+                    }
+                    cv::resize(outImg, outImg, cv::Size(1920, 1080));
+                    m_recorder->ConsumerData(iter->first, outImg);
+                }
+            }
+        }
+
+        int interNum = 0;
+        for(auto &data: g_InferInfo->DataSources){
+            if(data.Play == true && data.source_bin != NULL){
+                interNum++;  
+            }
+        }
+        if(i == interNum) {
+            NoticeCenter::Instance().emitEvent(NOTICE_INFEREPER);
+        }
+
         gst_buffer_unmap (buf, &in_map_info);
-      
         return GST_PAD_PROBE_OK;
-        
     }
 
     /**
@@ -658,12 +713,12 @@ namespace MIVA{
         #ifndef PLATFORM_TEGRA
             case GST_MESSAGE_ELEMENT:
             {
-            if (gst_nvmessage_is_stream_eos (msg)) {
-                guint stream_id;
-                if (gst_nvmessage_parse_stream_eos (msg, &stream_id)) {
-                    InfoL << "Got EOS from stream " << stream_id;
+                if (gst_nvmessage_is_stream_eos (msg)) {
+                    guint stream_id;
+                    if (gst_nvmessage_parse_stream_eos (msg, &stream_id)) {
+                        InfoL << "Got EOS from stream " << stream_id;
+                    }
                 }
-            }
             break;
             }
         #endif

modules/recorder/include/recorder.h

@@ -16,6 +16,7 @@
 #include <opencv2/imgproc.hpp>
 #include <opencv2/imgproc/types_c.h>
 #include "Util/logger.h"
+#include "DataSource.h"
 
 using namespace toolkit;
 using namespace std;
@@ -36,11 +37,11 @@ namespace MIVA
 
         void Finish();
 
-        void ConsumerData(int sourceId,cv::Mat& frame);
+        void ConsumerData(std::string Pid,cv::Mat& frame);
 
-        std::string GetFileName(int sourceId);
+        std::string GetFileName(std::string Pid);
 
-        std::shared_ptr<cv::VideoWriter> GetVideoWriter(int sourceId);
+        std::shared_ptr<cv::VideoWriter> GetVideoWriter(std::string Pid);
 
 
     private:
@@ -48,7 +49,7 @@ namespace MIVA
             std::string fileName = "";
             std::shared_ptr<cv::VideoWriter> videoWriter = nullptr;
         };
-        map<int, Writer> videoWriters;
+        map<std::string, Writer> videoWriters;
 
     public:
         bool enable = true;

modules/recorder/src/recorder.cpp

@@ -14,17 +14,17 @@ namespace MIVA
         if(m_recorder == nullptr) m_recorder = std::make_shared<recorder>();
         return m_recorder;
     }
-
+    
     /**
      * @description: 消费数据
      * @param {int} sourceId
      * @param {Mat} frame
      * @return {*}
      */    
-    void recorder::ConsumerData(int sourceId,cv::Mat& frame)
+    void recorder::ConsumerData(std::string Pid,cv::Mat& frame)
     {
         if(!enable) return;
-        auto iter = this->videoWriters.find(sourceId);
+        auto iter = this->videoWriters.find(Pid);
         if(iter != this->videoWriters.end()){
             if(iter->second.videoWriter == nullptr || iter->second.fileName == ""){
                 time_t rawtime;
@@ -35,8 +35,9 @@ namespace MIVA
                 strftime(ctime, 80, "%Y-%m-%d_%H:%M:%S", info);
                 string fileName = this->outDir;
                 string time1 = ctime;
-                fileName += time1 + "_" + std::to_string(sourceId) + ".mp4";
-                iter->second.videoWriter = std::make_shared<cv::VideoWriter>("appsrc ! autovideoconvert ! omxh264enc  ! matroskamux ! filesink location=" + fileName + " sync=false", 0, (double)30, cv::Size(1920, 1080), true);
+                fileName += time1 + "_" + Pid + ".mp4";
+                // ErrorL << fileName << endl;
+                iter->second.videoWriter = std::make_shared<cv::VideoWriter>("appsrc ! autovideoconvert ! omxh264enc  ! matroskamux ! filesink location=" + fileName + " sync=false", 0, (double)2, cv::Size(1920, 1080), true);
                 iter->second.fileName = fileName;
             }
         }
@@ -51,12 +52,13 @@ namespace MIVA
             strftime(ctime, 80, "%Y-%m-%d_%H:%M:%S", info);
             string fileName = this->outDir;
             string time1 = ctime;
-            fileName += time1 + "_" + std::to_string(sourceId) + ".mp4";
+            fileName += time1 + "_" + Pid + ".mp4";
+            // ErrorL << fileName << endl;
             writer.fileName = fileName;
-            writer.videoWriter = std::make_shared<cv::VideoWriter>("appsrc ! autovideoconvert ! omxh264enc  ! matroskamux ! filesink location=" + fileName + " sync=false", 0, (double)30, cv::Size(1920, 1080), true);
-            this->videoWriters[sourceId] = writer;
+            writer.videoWriter = std::make_shared<cv::VideoWriter>("appsrc ! autovideoconvert ! omxh264enc  ! matroskamux ! filesink location=" + fileName + " sync=false", 0, (double)2, cv::Size(1920, 1080), true);
+            this->videoWriters[Pid] = writer;
         }
-        this->videoWriters[sourceId].videoWriter->write(frame);
+        this->videoWriters[Pid].videoWriter->write(frame);
     }
 
     /**
@@ -108,10 +110,10 @@ namespace MIVA
      * @param {int} sourceId
      * @return {*}
      */    
-    std::string recorder::GetFileName(int sourceId)
+    std::string recorder::GetFileName(std::string Pid)
     {
         std::string fileName = "";
-        auto iter = this->videoWriters.find(sourceId);
+        auto iter = this->videoWriters.find(Pid);
         if(iter != this->videoWriters.end()){
             fileName = iter->second.fileName;
         }
@@ -123,10 +125,10 @@ namespace MIVA
      * @param {int} sourceId
      * @return {*}
      */    
-    std::shared_ptr<cv::VideoWriter> recorder::GetVideoWriter(int sourceId)
+    std::shared_ptr<cv::VideoWriter> recorder::GetVideoWriter(std::string Pid)
     {
         std::shared_ptr<cv::VideoWriter> videoWriter = nullptr;
-        auto iter = this->videoWriters.find(sourceId);
+        auto iter = this->videoWriters.find(Pid);
         if(iter != this->videoWriters.end()){
             videoWriter = iter->second.videoWriter;
         }

modules/userApp/include/user_app.h

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:41:50
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-12-27 13:55:40
+ * @LastEditTime: 2021-12-29 15:57:08
  */
 #pragma once
 
@@ -133,6 +133,8 @@ namespace MIVA
          * @author: lishengyin
          */        
         static uint8_t GradeDetermination(int num);
+        
+        static int GetAddrNum(std::string Pid);
     private:
         IniFile m_ini;
         std::string m_appName;
@@ -165,6 +167,7 @@ namespace MIVA
         int device_id;
         bool play = false;
         bool start = true;
+        bool enable = true;
     private:
         std::shared_ptr<TCPClient> m_tcpClient = NULL;
         std::shared_ptr<Inference> m_Infer = NULL;
@@ -181,6 +184,8 @@ namespace MIVA
         Timer::Ptr m_timer3;
         Timer::Ptr m_timer4;
         Timer::Ptr m_timer5;
+        Timer::Ptr m_timer6;
+        
 
     private:
 

modules/userApp/src/user_app.cpp

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:35:42
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-12-27 13:53:09
+ * @LastEditTime: 2021-12-29 17:09:54
  */
 #include "user_app.h"
 
@@ -109,10 +109,11 @@ namespace MIVA
 
         sqlUpdata << sqlRet;
         // 查询需要播放的流
-        SqlWriter sqlSelect("SELECT Id,Uri,RecognitionRange FROM MIVA_DB.`DataSources` WHERE Play = 1 and Del = 0");
+        SqlWriter sqlSelect("SELECT Id,Uri,RecognitionRange,PId FROM MIVA_DB.`DataSources` WHERE Play = 1 and Del = 0");
         sqlSelect << sqlRet;
 
-        this->m_InferInfo = std::make_shared<InferInfo>();
+        this->m_InferInfo = InferInfo::CreateNew();
+
         if(!sqlRet.empty()){
             int sourceId = 0;
             for(auto &line : sqlRet){
@@ -120,8 +121,10 @@ namespace MIVA
                 data.Id = std::atoi(line[0].c_str());
                 data.uri = line[1];
                 data.range = line[2];
+                data.Pid = line[3];
                 data.Play = true;
                 data.sourceId = sourceId;
+                data.AddrNum = GetAddrNum(data.Pid);
                 this->m_InferInfo->DataSources.push_back(data);
                 sourceId++;
             }
@@ -131,7 +134,7 @@ namespace MIVA
                 ErrorL << "Inference module creation failed!";
                 return ERR;
             }
-            if(m_Infer->Init(this->m_InferInfo) != OK){
+            if(m_Infer->Init() != OK){
                 ErrorL << "Inference module initialization failed";
                 return ERR;
             }
@@ -243,7 +246,7 @@ namespace MIVA
         // 定时监控数据变化
         this->m_timer4 = std::make_shared<Timer>(3.0f,[&](){
             // 监听数据
-            if(this->play == false) this->MonitorData();
+            // if(this->play == false) this->MonitorData();
             return true;
         },nullptr);
 
@@ -283,6 +286,18 @@ namespace MIVA
             NoticeCenter::Instance().emitEvent(NOTICE_INFERDATA);
             this->start = false;
         }
+        // if(!this->enable) return;
+        // this->enable = false;
+        // this->m_timer6 = std::make_shared<Timer>(3.0f,[&](){
+        //     if(this->start == true){
+        //         this->m_Infer->StopTask();
+        //         // 推理结束发布InferData事件
+        //         NoticeCenter::Instance().emitEvent(NOTICE_INFERDATA);
+        //         this->start = false;
+        //         this->enable = true;
+        //     }
+        //     return false;
+        // },nullptr);
     }    
 
     /**
@@ -530,7 +545,7 @@ namespace MIVA
         vector<DataSource>::iterator iter;
         
         if(this->m_Infer == NULL || this->m_InferInfo->DataSources.empty()){
-            SqlWriter sqlSelect("SELECT Id,Uri,RecognitionRange FROM MIVA_DB.`DataSources` WHERE Play = 1 and Del = 0");
+            SqlWriter sqlSelect("SELECT Id,Uri,RecognitionRange,PId FROM MIVA_DB.`DataSources` WHERE Play = 1 and Del = 0");
             sqlSelect << sqlRet;
             if(sqlRet.empty()) return;
             int sourceId = 0;
@@ -539,6 +554,8 @@ namespace MIVA
                 data.Id = std::atoi(line[0].c_str());
                 data.uri = line[1];
                 data.range = line[2];
+                data.Pid = line[3];
+                data.AddrNum = GetAddrNum(data.Pid);
                 data.Play = true;
                 data.sourceId = sourceId;
                 this->m_InferInfo->DataSources.push_back(data);
@@ -552,7 +569,7 @@ namespace MIVA
                     ErrorL << "Inference module creation failed!";
                     return;
                 }
-                if(this->m_Infer->Init(this->m_InferInfo) != OK){
+                if(this->m_Infer->Init() != OK){
                     ErrorL << "Inference module initialization failed";
                 }
             }
@@ -560,7 +577,7 @@ namespace MIVA
         }
         if(this->m_InferInfo->DataSources.empty()) return;
         // 查询
-        std::string sql = "SELECT Id,Uri,RecognitionRange,Play FROM MIVA_DB.`DataSources` WHERE Del = 0";
+        std::string sql = "SELECT Id,Uri,RecognitionRange,Play,PId FROM MIVA_DB.`DataSources` WHERE Del = 0";
         SqlWriter sqlSelect(sql.c_str());
         sqlSelect << sqlRet;
         if(!sqlRet.empty()){
@@ -588,6 +605,8 @@ namespace MIVA
                     this->m_InferInfo->DataSources[i].uri = line[1];
                     this->m_InferInfo->DataSources[i].range = line[2];
                     this->m_InferInfo->DataSources[i].Play = atoi(line[3].c_str()) ? true:false;
+                    this->m_InferInfo->DataSources[i].Pid = line[4];
+                    this->m_InferInfo->DataSources[i].AddrNum = GetAddrNum(line[4]);
                     i++;
                 }
                 if(size > (int)sqlRet.size()){
@@ -614,6 +633,7 @@ namespace MIVA
                                 this->m_Infer->add_sources(i,sqlRet[i][1]);
                             }
                         }else{
+                            ErrorL;
                             this->m_Infer->stop_release_source(i);
                         }   
                     }
@@ -621,6 +641,8 @@ namespace MIVA
                     this->m_InferInfo->DataSources[i].uri = sqlRet[i][1];
                     this->m_InferInfo->DataSources[i].range = sqlRet[i][2];
                     this->m_InferInfo->DataSources[i].Play = atoi(sqlRet[i][3].c_str()) ? true:false;
+                    this->m_InferInfo->DataSources[i].Pid = sqlRet[i][4];
+                    this->m_InferInfo->DataSources[i].AddrNum = GetAddrNum(sqlRet[i][4]);
                 }
                 for(i = size; i < (int)sqlRet.size(); i++)
                 {
@@ -630,9 +652,11 @@ namespace MIVA
                     data.range = sqlRet[i][2];
                     data.Play = atoi(sqlRet[i][3].c_str()) ? true:false;
                     data.sourceId = i;
+                    data.Pid = sqlRet[i][4];
+                    data.AddrNum = GetAddrNum(data.Pid);
                     this->m_InferInfo->DataSources.push_back(data);
                     if(data.Play){
-                        DebugL << "Id" << i << ",Url:" << data.uri << endl;
+                        DebugL << "Id:" << i << ",Url:" << data.uri << endl;
                         this->m_Infer->add_sources(i, data.uri);
                     }
                 }
@@ -778,6 +802,13 @@ namespace MIVA
         return num;
     }
 
+    int UserApp::GetAddrNum(std::string Pid){
+        vector<vector<string>> sqlRet;
+        SqlWriter sqlSelect("SELECT * FROM MIVA_DB.`DataSources` WHERE Play = 1 and Del=0 and Pid='?'");
+        sqlSelect << Pid << sqlRet;
+        return (int)sqlRet.size();
+    }
+
     /**
      * @description: 拥挤程度判定
      * @param {int} num 最终结果