cam_dev add type code

xuxiuxi

2019-03-08 118d5304c8744a3cb533164af6fbdc91229d6f3d

 QiaoJiaSystem/VideoServer/QiaoJia/DB/LDBTool.cpp

@@ -356,11 +356,23 @@
    pModel_cam.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel_cam.select();

//    QSqlTableModel pModel_sdk(NULL, m_db);
//    pModel_sdk.setTable("cam_sdk");
//    pModel_sdk.setFilter(QObject::tr("cam_dev_id = '%1'").arg(strCamId));
//    pModel_sdk.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
//    pModel_sdk.select();

    QSqlTableModel pModel_sdk(NULL, m_db);
    pModel_sdk.setTable("cam_sdk");
    pModel_sdk.setFilter(QObject::tr("cam_dev_id = '%1'").arg(strCamId));
    pModel_sdk.setTable("sdk_rule");
    pModel_sdk.setFilter(QObject::tr("cam_id = '%1'").arg(strCamId));
    pModel_sdk.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel_sdk.select();

    QSqlTableModel pModel_week(NULL, m_db);
    pModel_week.setTable("rule_week");
    pModel_week.setFilter(QObject::tr("camera_id = '%1'").arg(strCamId));
    pModel_week.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel_week.select();

    int rowCount_cam = pModel_cam.rowCount();
    if (rowCount_cam >= 1) {
@@ -376,17 +388,25 @@
        }
    }

    int rowCount_week = pModel_week.rowCount();
    if (rowCount_week >= 1) {
        for (int i = 0; i < rowCount_week; i++) {
            pModel_week.removeRow(i);//TODO
        }
    }

    m_db.transaction();//开始事务操作

    if (pModel_cam.submitAll() && \
        pModel_sdk.submitAll()) {
        pModel_sdk.submitAll() && pModel_week.submitAll()) {
        m_db.commit();//提交
        return true;
    } else {
        m_db.rollback();//回滚
        ERR("deleteLDeviceTable err ,Database Error: " \
 << pModel_cam.lastError().text().toStdString() \
 << pModel_sdk.lastError().text().toStdString());
 << pModel_sdk.lastError().text().toStdString() \
 << pModel_week.lastError().text().toStdString());
        //        QMessageBox::warning(NULL,QObject::tr("deleteLDeviceTable"),QObject::tr("Database Error: %1").arg(pModel.lastError().text()));
        return false;
    }
@@ -434,6 +454,35 @@
    }
}

bool LDBTool::updateCamDevSnapshot(const QString &strIp, const QString &imgUrl) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("cam_dev");
    pModel.setFilter(
        QObject::tr("ip = '%1'").arg(strIp));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

    QSqlRecord rec = pModel.record(0);
    rec.setValue("reserved", imgUrl);

    int rowCount = pModel.rowCount();
    if (rowCount > 0) {
        pModel.setRecord(0, rec);//TODO
    }

    m_db.transaction();//开始事务操作

    if (pModel.submitAll()) {
        m_db.commit();//提交
        return true;
    } else {
        m_db.rollback();//回滚
        ERR("updateCamDevSnapshot err ,Database Error: " << pModel.lastError().text().toStdString());
        return false;
    }
}

int LDBTool::searchCamDevNumber(void) {
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("cam_dev");
@@ -451,7 +500,7 @@
    std::list<Record_Cam_Dev> lst;
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("cam_dev");
    pModel.setFilter(QObject::tr("cam_dev_id != '' and cam_dev_id is not null"));
    pModel.setFilter(QObject::tr("cam_dev_id != '' and cam_dev_id is not null and type='0'"));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

@@ -479,6 +528,19 @@
    return lst;
}

bool LDBTool::searchCamDevByCamId(QString strCamId) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    std::list<Record_Cam_Dev> lst;
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("cam_dev");
    pModel.setFilter(QObject::tr("cam_dev_id ='%1' and cam_dev_id != '' and cam_dev_id is not null").arg(strCamId));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

    int rowCount = pModel.rowCount();

    return rowCount > 0;
}

//chn==========================
///
@@ -2370,7 +2432,7 @@


//config 修改裁剪视频时长
bool LDBTool::updateConfigTableByCutDuration(int n_cut_max_duration) {
bool LDBTool::updateConfigTableByCutDuration(int n_cut_max_duration, int n_cut_min_duration) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("config");
@@ -2379,7 +2441,7 @@

    QSqlRecord rec = pModel.record(0);
    rec.setValue("cut_max_duration", n_cut_max_duration);

    rec.setValue("cut_min_duration", n_cut_min_duration);
    while (pModel.canFetchMore()) {
        pModel.fetchMore();
    }
@@ -2423,32 +2485,19 @@
        lRec.str_es_pic_ip = rec.value("es_pic_ip").toString();
        lRec.n_es_pic_port = rec.value("es_pic_port").toInt();
        lRec.n_cut_max_duration = rec.value("cut_max_duration").toInt();
        lRec.dev_id = QString::fromStdString(appConfig.getStringProperty("DEV_ID"));
        lRec.n_cut_min_duration = rec.value("cut_min_duration").toInt();
        lRec.dev_name = rec.value("dev_name").toString();
    }

    lRec.dev_id = QString::fromStdString(appConfig.getStringProperty("DEV_ID"));
    if (lRec.n_cut_max_duration == 0) {
        lRec.n_cut_max_duration = 20;
    }
    if (lRec.n_cut_min_duration == 0) {
        lRec.n_cut_min_duration = 4;
    }
    return lRec;
}

//config 查询裁剪视频时长
int LDBTool::searchConfigTableWithinCutDuration(void) {
    int cut_max_duration = 5;//默认5分钟
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("config");
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

    int rowCount = pModel.rowCount();
    if (rowCount > 0) {
        QSqlRecord rec = pModel.record(0);
        if (cut_max_duration != 0) {
            cut_max_duration = rec.value("cut_max_duration").toInt();
        }
    }

    return cut_max_duration;
}

bool LDBTool::insertRecordVedioPath(QString pathKey, QString filePath) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
@@ -2523,187 +2572,181 @@
        return false;
    }
}
 bool LDBTool::insertPerimeterRule(ActRule actRule)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_perimeter");
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange

     QSqlRecord rec = pModel.record();
     rec.setGenerated("rule_id", false);
     rec.setValue("camera_id", actRule.nCamId);
     rec.setValue("sensitivity", actRule.fSensitivity);
     rec.setValue("delay",actRule.nTriggerDelay);
     rec.setValue("tolerance",actRule.nTriggertolerance);
     rec.setValue("show_pepole_num",actRule.nAlarmPeopleNum);

     pModel.insertRecord(-1, rec);//TODO

     m_db.transaction();//开始事务操作

     if (pModel.submitAll()) {
         m_db.commit();//提交
         return true;
     } else {
         m_db.rollback();//回滚
         ERR("insertCameraRule ,pModel_load Error: " << pModel.lastError().text().toStdString());

         return false;
     }
 }
 bool LDBTool::updatePerimeterRuleByCamId(ActRule actRule)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_perimeter");
     pModel.setFilter(QObject::tr("camera_id = '%1' ").arg(actRule.nCamId));
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange


     QSqlRecord rec = pModel.record(0);
     rec.setValue("camera_id", actRule.nCamId);
     rec.setValue("sensitivity", actRule.fSensitivity);
     rec.setValue("delay",actRule.nTriggerDelay);
     rec.setValue("tolerance",actRule.nTriggertolerance);
     rec.setValue("show_pepole_num",actRule.nAlarmPeopleNum);
bool LDBTool::updateCameraWeekRule(const LActRuleWeekRecord &weekRule) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("rule_week");
    pModel.setFilter(QObject::tr("camera_id = '%1' and type='%2' and sdk_type='%3'").arg(weekRule.m_strCamId).arg(
        weekRule.m_nType).arg(weekRule.m_nSdkType));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();
    QSqlRecord rec = pModel.record(0);
    //rec.setGenerated("id", false);
    rec.setValue("camera_id", weekRule.m_strCamId);
    rec.setValue("sdk_type", weekRule.m_nSdkType);
    rec.setValue("type", weekRule.m_nType);
    rec.setValue("begin_time", weekRule.m_strBegin);
    rec.setValue("end_time", weekRule.m_strEnd);

     int rowCount = pModel.rowCount();
     if (rowCount == 0) {
         pModel.insertRecord(-1, rec);
     } else if (rowCount > 0) {
         pModel.setRecord(0, rec);//TODO
     }
    int rowCount = pModel.rowCount();
    if (rowCount == 0) {
        pModel.insertRecord(-1, rec);
    } else if (rowCount > 0) {
        pModel.setRecord(0, rec);//TODO
    }

     m_db.transaction();//开始事务操作
    m_db.transaction();//开始事务操作

     if (pModel.submitAll()) {
         m_db.commit();//提交
         return true;
     } else {
         m_db.rollback();//回滚
         ERR("updateCameraRuleByCamId ,pModel_load Error: " << pModel.lastError().text().toStdString());
         return false;
     }
    if (pModel.submitAll()) {
        m_db.commit();//提交
        return true;
    } else {
        m_db.rollback();//回滚
        ERR("updateCameraWeekRule ,pModel_load Error: " << pModel.lastError().text().toStdString());

 }
 ActRule LDBTool::searchPerimeterRuleByCamId(int camId)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_perimeter");
     pModel.setFilter(QObject::tr("camera_id = '%1' ").arg(camId));
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
     pModel.select();
        return false;
    }
}

     ActRule rule;
     int rowCount = pModel.rowCount();
     if (rowCount > 0) {
         QSqlRecord rec = pModel.record(0);
         rule.nTriggerDelay=rec.value("delay").toInt();
         rule.nTriggertolerance=rec.value("tolerance").toInt();
         rule.strAreas=rec.value("area_points").toString();
         rule.nAlarmPeopleNum=rec.value("show_people_sum").toInt();
         rule.fSensitivity=rec.value("sensitivity").toFloat();
     }
std::vector<LActRuleWeekRecord> LDBTool::searchCameraWeekRuleByCamId(const QString &camId, const int &sdkType) {
    std::vector<LActRuleWeekRecord> vecWeek;
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("rule_week");
    pModel.setFilter(QObject::tr("camera_id = '%1' and sdk_type='%2'").arg(camId).arg(sdkType));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

     return rule;
 }
    int rowCount = pModel.rowCount();
    for (int i = 0; i < rowCount; ++i) {
        LActRuleWeekRecord lActRuleWeekRec;
        QSqlRecord rec = pModel.record(i);
        lActRuleWeekRec.m_nSdkType = rec.value("sdk_type").toInt();
        lActRuleWeekRec.m_nType = rec.value("type").toInt();
        lActRuleWeekRec.m_strBegin = rec.value("begin_time").toString();
        lActRuleWeekRec.m_strEnd = rec.value("end_time").toString();
        lActRuleWeekRec.m_strCamId = rec.value("camera_id").toString();
        vecWeek.push_back(lActRuleWeekRec);
    }

 bool LDBTool::insertCameraWeekRule(LActRuleWeekRecord weekRule)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_week");
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    return vecWeek;
}

     QSqlRecord rec = pModel.record();
     rec.setGenerated("id", false);
     rec.setValue("camera_id",weekRule.m_nCamId);
     rec.setValue("type", weekRule.m_nType);
     rec.setValue("start_time", weekRule.m_strBegin);
     rec.setValue("end_time",weekRule.m_strEnd);

     pModel.insertRecord(-1, rec);//TODO
bool LDBTool::updateSdkRule(const SdkRule &sdkRule) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("sdk_rule");
    pModel.setFilter(QObject::tr("cam_id = '%1' and sdk_type = '%2' ").arg(sdkRule.strCamId).arg(sdkRule.nSdkType));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();
    QSqlRecord rec = pModel.record(0);
    rec.setValue("cam_id", sdkRule.strCamId);
    rec.setValue("sdk_type", sdkRule.nSdkType);
    rec.setValue("area", sdkRule.strAreas);
    rec.setValue("ex_area", sdkRule.strExAreas);
    rec.setValue("line", sdkRule.strLine);
    rec.setValue("ex_line", sdkRule.strExLine);
    rec.setValue("alarm_delay", sdkRule.nTriggerDelay);
    rec.setValue("tolerance", sdkRule.nTriggerTolerance);
    rec.setValue("alarm_num_upper", sdkRule.nAlarmNumUpperLimit);
    rec.setValue("alarm_num_lower", sdkRule.nAlarmNumLowerLimit);
    rec.setValue("broadcast_area", sdkRule.strBroadcast);
    rec.setValue("is_run", sdkRule.nIsRun);
    rec.setValue("img_threshold", sdkRule.nThreshold);
    rec.setValue("img_quality", sdkRule.nQuality);

     m_db.transaction();//开始事务操作
    int rowCount = pModel.rowCount();
    if (rowCount == 0) {
        pModel.insertRecord(-1, rec);
    } else if (rowCount > 0) {
        pModel.setRecord(0, rec);//TODO
    }

     if (pModel.submitAll()) {
         m_db.commit();//提交
         return true;
     } else {
         m_db.rollback();//回滚
         ERR("insertCameraWeekRule ,pModel_load Error: " << pModel.lastError().text().toStdString());
    m_db.transaction();//开始事务操作

         return false;
     }
 }
 QVector<LActRuleWeekRecord> LDBTool::searchCameraWeekRuleByCamId(int camId)
 {
     QVector<LActRuleWeekRecord> vecWeek;
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_week");
     pModel.setFilter(QObject::tr("camera_id = '%1' ").arg(camId));
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
     pModel.select();
    if (pModel.submitAll()) {
        m_db.commit();//提交
        return true;
    } else {
        m_db.rollback();//回滚
        ERR("updateSdkRule ,pModel_load Error: " << pModel.lastError().text().toStdString());
        return false;
    }
}

     int rowCount = pModel.rowCount();
     for(int i = 0;i < rowCount;++i)
     {
         LActRuleWeekRecord lActRuleWeekRec;
         QSqlRecord rec = pModel.record(i);
         lActRuleWeekRec.m_nType = rec.value("type").toInt();
         lActRuleWeekRec.m_strBegin = rec.value("begin").toString();
         lActRuleWeekRec.m_strEnd = rec.value("end").toString();
         vecWeek.push_back(lActRuleWeekRec);
     }
SdkRuleMap LDBTool::searchSdkRuleByCamId(const QString &camId) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("sdk_rule");
    pModel.setFilter(QObject::tr("cam_id = '%1' ").arg(camId));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();
    std::map<int, SdkRule> ruleMap;

     return vecWeek;
 }
 ActRule LDBTool::searchActRuleByCamId(int camId)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_act");
     pModel.setFilter(QObject::tr("cam_id = '%1' ").arg(camId));
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
     pModel.select();
    //std::vector<SdkRule> ruleVec;
    int rowCount = pModel.rowCount();
    for (int i = 0; i < rowCount; ++i) {
        SdkRule rule;
        QSqlRecord rec = pModel.record(i);
        rule.strCamId = rec.value("cam_id").toString();
        rule.strAreas = rec.value("area").toString();
        rule.strExAreas = rec.value("ex_area").toString();
        rule.strLine = rec.value("line").toString();
        rule.strExLine = rec.value("ex_line").toString();
        rule.nTriggerDelay = rec.value("alarm_delay").toInt();
        rule.nTriggerTolerance = rec.value("tolerance").toInt();
        rule.nQuality = rec.value("img_quality").toInt();
        rule.nThreshold = rec.value("img_threshold").toInt();
        rule.nAlarmNumUpperLimit = rec.value("alarm_num_upper").toInt();
        rule.nAlarmNumLowerLimit = rec.value("alarm_num_lower").toInt();
        rule.strBroadcast = rec.value("broadcast_area").toString();
        rule.nIsRun = rec.value("is_run").toInt();
        rule.nSdkType = rec.value("sdk_type").toInt();
        ruleMap[rule.nSdkType] = rule;
        //ruleVec.push_back(rule);
    }

     ActRule rule;
     int rowCount = pModel.rowCount();
     if (rowCount > 0) {
         QSqlRecord rec = pModel.record(0);
         rule.nTriggertolerance=rec.value("tolerance").toInt();
         rule.nTriggerDelay=rec.value("delay").toInt();
         rule.strAreas=rec.value("act_left_area").toString();
         rule.strLine=rec.value("act_left_line").toString();
         rule.strExAreas=rec.value("act_right_area").toString();
         rule.strExLine=rec.value("act_right_line").toString();
         rule.fSensitivity=rec.value("sensitivity").toFloat();
     }
    return ruleMap;
}

     return rule;
 }

 ActRule LDBTool::searchCrowdRuleByCamId(int camId)
 {
     QMutexLocker mutexLocker(&m_mutexVisit);//TODO
     QSqlTableModel pModel(NULL, m_db);
     pModel.setTable("rule_crowd");
     pModel.setFilter(QObject::tr("camera_id = '%1' ").arg(camId));
     pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
     pModel.select();
/**
 * type 0 rtsp, 1 gb28181
 */
std::list<Record_Cam_Dev> LDBTool::searchCamDevTableByType(int type) {
    QMutexLocker mutexLocker(&m_mutexVisit);//TODO
    std::list<Record_Cam_Dev> lst;
    QSqlTableModel pModel(NULL, m_db);
    pModel.setTable("cam_dev");
    pModel.setFilter(QObject::tr(
        (string("cam_dev_id != '' and cam_dev_id is not null and type='") + to_string(type) + "'").c_str()));
    pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange
    pModel.select();

     ActRule rule;
     int rowCount = pModel.rowCount();
     if (rowCount > 0) {
         QSqlRecord rec = pModel.record(0);
         rule.nTriggertolerance=rec.value("tolerance").toInt();
         rule.nTriggerDelay=rec.value("delay").toInt();
         rule.strAreas=rec.value("area_points").toString();
         rule.nAlarmPeopleNum=rec.value("alarm_people_num").toInt();
     }
    int rowCount = pModel.rowCount();
    if (rowCount > 0) {
        for (int i = 0; i < rowCount; ++i) {
            Record_Cam_Dev lChannelRec;
            QSqlRecord rec = pModel.record(i);
            lChannelRec.n_id = rec.value("id").toInt();
            lChannelRec.str_cam_dev_id = rec.value("cam_dev_id").toString();
            lChannelRec.str_name = rec.value("name").toString();
            lChannelRec.str_addr = rec.value("addr").toString();
            lChannelRec.str_longitude = rec.value("longitude").toString();
            lChannelRec.str_latitude = rec.value("latitude").toString();
            lChannelRec.str_ip = rec.value("ip").toString();
            lChannelRec.n_port = rec.value("port").toInt();
            lChannelRec.str_username = rec.value("username").toString();
            lChannelRec.str_password = rec.value("password").toString();
            lChannelRec.str_brand = rec.value("brand").toString();
            lChannelRec.str_reserved = rec.value("reserved").toString();
            lChannelRec.n_type = rec.value("type").toInt();
            lst.push_back(lChannelRec);
        }
    }

     return rule;
 }
    return lst;
}