pansen
2019-01-28 b10d8e00b83032d802adab3222def7e6d280d928
QiaoJiaSystem/StructureApp/PerimeterElement.cpp
@@ -13,14 +13,16 @@
#include <uuid/uuid.h>
#include <jsoncpp/json/json.h>
#define ALARM_PERCENT (10)  //10%
PerimeterElement::PerimeterElement(const SdkRule &rule) :
    m_sdkRule(rule),
    PipeElement(true),
    trackingTrigger(nullptr),
    mRealNum(0),
    m_triggerElement(rule.nTriggerDelay*8,0),
    m_triggerElement(rule.nTriggerDelay * 8, 0),
    pManagerEsDB(nullptr),
    npts(0) {
    m_bIsMask(true) {
    pManagerEsDB = new EsDBTool(appPref.getStringData("ipAdd"), appPref.getIntData("ipPort"));
}
@@ -40,7 +42,7 @@
void PerimeterElement::threadFunc() {
   // ClockTimer ct("PerimeterElement::threadFunc");
    //ClockTimer ct("PerimeterElement::threadFunc");
    if (!isInWeek(m_sdkRule.weekRuleVec))
        return;
    int num = 0;
@@ -56,17 +58,42 @@
        QRect rect(obj.rect.x, obj.rect.y, obj.rect.width, obj.rect.height);
        QPoint center = rect.center();
        if (mPolygon.containsPoint(center, Qt::OddEvenFill)) {
            m_recVec.push_back(obj.rect);
            if (picDate.empty()) {
                picDate = obj.properties["time"];
                // DBG("picDate="<<picDate);
        if (picDate.empty()) {
            picDate = obj.properties["time"];
            // DBG("picDate="<<picDate);
        }
        if (m_sdkRule.nSdkType == PerimeterSdk) {
            if (m_bIsMask) {
                std::vector<Point> poly2;
                std::vector<Point> interPoly;
                poly2.push_back(Point(rect.x(), rect.y()));
                poly2.push_back(Point(rect.x() + rect.width(), rect.y()));
                poly2.push_back(Point(rect.x() + rect.width(), rect.y() + rect.height()));
                poly2.push_back(Point(rect.x(), rect.y() + rect.height()));
                IntAreaCalcUtil::PolygonClip(poly1, poly2, interPoly);
                float inter = IntAreaCalcUtil::intAreaCalc(interPoly);
                float total1 = IntAreaCalcUtil::intAreaCalc(poly1);
                float total2 = IntAreaCalcUtil::intAreaCalc(poly2);
                int per1 = (int) (inter / total1 * 100);
                int per2 = (int) (inter / total2 * 100);
                int per = std::max(per1, per2);
                if (ALARM_PERCENT <= per) {
                    //DBG("per 1="<<per1<<" per2="<<per2<<" per="<<per);
                    m_recVec.push_back(obj.rect);
                    num++;
                }
            }
        } else if (mPolygon.containsPoint(center, Qt::OddEvenFill) || !m_bIsMask) {
            m_recVec.push_back(obj.rect);
            num++;
        }
@@ -74,19 +101,23 @@
    switch (m_sdkRule.nSdkType) {
        case PerimeterSdk:
            state = num > 0 ;
            //state = num > 0 ;
            state = (num != mRealNum);
            //  DBG("num="<<num<< "time="<< picDate);
            break;
        case CrowdSdk:
            state = num > m_sdkRule.nAlarmNumLowerLimit  ;
            state = num > m_sdkRule.nAlarmNumLowerLimit && num != mRealNum;
            break;
        case PerHubSdk:
            state = num > m_sdkRule.nAlarmNumLowerLimit && num < m_sdkRule.nAlarmNumUpperLimit ;
//         if(m_sdkRule.nAlarmNumLowerLimit>0)
            state = num > m_sdkRule.nAlarmNumLowerLimit && num < m_sdkRule.nAlarmNumUpperLimit && num != mRealNum;
//         if(m_sdkRule.nAlarmNumLowerLimit>=0)
//         {
//             if( m_sdkRule.nAlarmNumUpperLimit>m_sdkRule.nAlarmNumLowerLimit+1)
//             if( m_sdkRule.nAlarmNumUp2019-01-16 09:49:57perLimit>m_sdkRule.nAlarmNumLowerLimit+1)
//             {
//                  m_triggerElement.setState(num>m_sdkRule.nAlarmNumLowerLimit && num<m_sdkRule.nAlarmNumUpperLimit);
@@ -117,20 +148,41 @@
    m_triggerElement.setState(state);
    m_triggerElement.triggerOnce();
    //  DBG("imgUrl="<<imgUrl);
    if (m_triggerElement.getTriggerState() && num!=mRealNum)
    {
        auto t_image = image(CutMask()).clone();
        std::string imgUrl = uploadImgToFdfs(t_image);
        saveInfoToEs(imgUrl, picDate);
    if (m_triggerElement.getTriggerState()) {
        if (num > 0) {
            cv::Mat t_image = image(CutMask()).clone();
            if (t_image.empty()) {
                DBG("t_image empty");
                return;
            }
            std::string imgUrl = uploadImgToFdfs(t_image);
            saveInfoToEs(imgUrl, picDate);
        }
        DBG("num=" << num << " lastnum=" << mRealNum);
        mRealNum = num;
    }
    //if(state)
   // DBG("num=" << num <<"m_triggerElement.getTriggerState()="<<m_triggerElement.getTriggerState());
//    if (m_triggerElement.getTriggerState() && num!=mRealNum)
//    {
//        cv::Mat t_image = image(CutMask()).clone();
//        if(t_image.empty())
//        {
//            DBG("t_image empty");
//            return;
//        }
//        std::string imgUrl = uploadImgToFdfs(t_image);
//        saveInfoToEs(imgUrl, picDate);
//        DBG("num=" << num << " lastnum=" << mRealNum);
//        mRealNum = num;
//    }
   mRealNum = num;
//    if(!state)
//    {
//        mRealNum = num;
//    }
    // DBG("m_sdkRule.nSdkType="<<m_sdkRule.nSdkType<<" num="<<num);
@@ -169,7 +221,8 @@
void PerimeterElement::setMask(std::string mask) {
    QJsonArray arrayAreas = getJsonArrayFromQString(QString::fromStdString(mask));
    if (arrayAreas.isEmpty()) {
    if (arrayAreas.isEmpty() && m_sdkRule.nSdkType != PerimeterSdk) {
        m_bIsMask = false;
        return;//do not detect
    }
    int size = arrayAreas.size();
@@ -180,8 +233,12 @@
        QJsonObject obj = jsonValue.toObject();
        int x = obj.value("x").toDouble() * 4;
        int y = obj.value("y").toDouble() * 4;
        if (m_sdkRule.nSdkType == PerimeterSdk) {
            poly1.push_back(Point(x, y));
        } else {
            mPolygon << (QPoint(x, y));
        }
        mPolygon << (QPoint(x, y));
    }
}
@@ -215,7 +272,7 @@
        CvUtil::cvMat2Buffer(image, buffer);
        std::string strImgUrlTmp = "";
        fdfsClient->fastFds->uploadFile(buffer, strImgUrlTmp, "jpg");
      //  strImgUrl.append(fdfsClient->fastFds->getIp() + "/" + strImgUrlTmp);
        //  strImgUrl.append(fdfsClient->fastFds->getIp() + "/" + strImgUrlTmp);
        strImgUrl.clear();
        strImgUrl = strImgUrlTmp;
//                    strImgUrl.append("/").append(strImgUrlTmp);
@@ -249,13 +306,13 @@
    t_json["ChannlId"] = getProperty("ch_id"); // 通道id
    t_json["likeDate"] = AppUtil::getTimeSecString(); // 比对时间
    t_json["picAddress"] = m_sdkRule.strAddr.toStdString();// 抓拍地址
    DBG("picAddress="<<m_sdkRule.strAddr.toStdString());
    DBG("picAddress=" << m_sdkRule.strAddr.toStdString());
    t_json["picMaxUrl"] = "wait todo"; // 大图路径
    //   t_json["Age"] ="wait todo";
    t_json["picDate"] = time; // 抓拍时间,必须有
     DBG("picDate="<<time);
    DBG("picDate=" << time);
    t_json["picLocalUrl"] = "wait todo";  // 本地路径
    t_json["isDelete"] = "1";//默认1 ,0无效 1有效
@@ -347,3 +404,7 @@
//   DBG("RECT x="<<rect.x<<"y"<<rect.y<<"w"<<rect.width<<"h"<<rect.height);
    return rect;
}
bool PerimeterElement::isAnd() {
}