整合代码

chenshijun

2019-03-15 684b55231257011c11caacc5ae72b0f0977c6114

 QiaoJiaSystem/DataManagerServer/vss/dao/VssLocalSettingTblSqliteDao.h

@@ -3,30 +3,19 @@
#define VSSLOCALSETTINGTBL_Sqlite_MANAGER_H



#include "../model/VssLocalSettingTbl.h"

#include "BaseDao.h"

#include "BaseSqliteDao.h"



#define VSSLocalSettingTbl_Sqlite_TABLE_NAME "VSSLocalSettingTbl"



#include <qsqlfield.h>

/**

 * 本地国标配置管理类

 */

class VssLocalSettingTblSqliteDao : public BaseDao {

class VssLocalSettingTblSqliteDao : public BaseSqliteDao {

private:

   /** 本地国标配置构造函数 */

   VssLocalSettingTblSqliteDao() {}

private:

    LDBTool* lDBTool;



    QSqlDatabase* m_db;

    QSqlTableModel *m_pModel;

    QMutex* m_mutexVisit;

public:

    void setLDBTool(LDBTool* lDBTool) {

       this->lDBTool = lDBTool;

       this->m_db = lDBTool->get_m_db();

       this->m_pModel = lDBTool->get_m_pModel();

       this->m_mutexVisit = lDBTool->get_m_mutexVisit();

   }

public:

   /** 本地国标配置单例模式 */

    static VssLocalSettingTblSqliteDao* instance() {

@@ -84,8 +73,9 @@
        QMutexLocker mutexLocker(m_mutexVisit);//TODO

        QSqlTableModel pModel(NULL, *m_db);

        pModel.setTable(VSSLocalSettingTbl_Sqlite_TABLE_NAME);

        for (auto whereKeyValue : whereKeyValues ) {

            pModel.setFilter(QObject::tr((string(whereKeyValue.first)+" = '%1'").c_str()).arg(QString::fromUtf8(whereKeyValue.second.c_str())));

        if (whereKeyValues.size() > 0) {

            auto filter = QObject::tr((string(" 1=1 ")+getWhereColumnNameValuePair(whereKeyValues)).c_str());

            pModel.setFilter(filter);

        }

        pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange

        pModel.select();

@@ -118,13 +108,14 @@
    Json::Value updateVssLocalSettingTbl(std::map<std::string, std::string>& keyValuesToUpdate,

                           std::map<std::string, std::string>& whereKeyValues) {

        Json::Value responseJsonValue;

        responseJsonValue["message"] = "删除失败！";

        responseJsonValue["message"] = "更新失败！";

        responseJsonValue["success"] = "false";

        QMutexLocker mutexLocker(m_mutexVisit);//TODO

        QSqlTableModel pModel(NULL, *m_db);

        pModel.setTable(VSSLocalSettingTbl_Sqlite_TABLE_NAME);

        for (auto whereKeyValue : whereKeyValues) {

            pModel.setFilter(QObject::tr((whereKeyValue.first + " = '%1'").c_str()).arg(QString::fromStdString(whereKeyValue.second)));

        if (whereKeyValues.size() > 0) {

            auto filter = QObject::tr((string(" 1=1 ")+getWhereColumnNameValuePair(whereKeyValues)).c_str());

            pModel.setFilter(filter);

        }

        pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange

        pModel.select();

@@ -156,7 +147,7 @@
        if (pModel.submitAll()) {

            m_db->commit();//提交

            responseJsonValue["success"] = "true";

            responseJsonValue["message"] = "删除成功！";

            responseJsonValue["message"] = "更新成功！";

        } else {

            m_db->rollback();//回滚

            ERR("updateLDeviceTable ,pModel_load Error: " << pModel.lastError().text().toStdString());

@@ -165,121 +156,60 @@
   }



    /** 更新创建二级设备表 keyValuesToUpdate 需要更新的列名和列值对； whereKeyValues 列名和列值条件 */

    bool updateVssLocalSettingTbl(std::map<std::string, std::string>& keyValuesToUpdate,

    Json::Value updateVssLocalSettingTbl(std::map<std::string, std::string>& keyValuesToUpdate,

                             string whereKey,

                             string whereValue) {

        std::map<std::string, std::string> whereKeyValues;

        whereKeyValues[whereKey] = whereValue;

        return update(keyValuesToUpdate, VSSLocalSettingTbl_TABLE_NAME, whereKeyValues);

        return updateVssLocalSettingTbl(keyValuesToUpdate, whereKeyValues);

    }



   /** 查询本地国标配置列表  querySql 要查询的sql语句 */

    Json::Value findVssLocalSettingTblList(string querySql) {

    Json::Value findVssLocalSettingTblList(std::map<std::string, std::string>& whereKeyValues) {



        Json::Value responseJsonValue;

        responseJsonValue["message"] = "删除失败！";

        responseJsonValue["message"] = "查询失败！";

        responseJsonValue["success"] = "false";

        responseJsonValue["data"] = "[]";

        responseJsonValue["data"] = Json::arrayValue;



        QMutexLocker mutexLocker(m_mutexVisit);//TODO

        std::list<Record_Cut_Video_info> lst;

        QSqlTableModel pModel(NULL, *m_db);

        pModel.setTable(VSSLocalSettingTbl_Sqlite_TABLE_NAME);

        pModel.setTable(VSSLocalSettingTbl_Sqlite_TABLE_NAME);;

        if (whereKeyValues.size() > 0) {

            auto filter = QObject::tr((string(" 1=1 ")+getWhereColumnNameValuePair(whereKeyValues)).c_str());

            pModel.setFilter(filter);

        }

        pModel.setEditStrategy(QSqlTableModel::OnManualSubmit);//OnManualSubmit OnFieldChange

        pModel.select();



        int rowCount = pModel.rowCount();

        if (rowCount > 0) {

            Json::Value rowDataList;

            Json::Value rowDataList = Json::arrayValue;

            for (int i = 0; i < rowCount; ++i) {

                Json::Value rowData;

                Json::Value rowData = Json::objectValue;

                Record_Cut_Video_info lRec;

                QSqlRecord rec = pModel.record(i);

//                if (!rec.value("finish_flag").toBool()) {

//                    lRec.n_id = rec.value("id").toInt();

//                    lRec.str_storage_dev_id = rec.value("storage_dev_id").toString();

//                    lRec.n_chn = rec.value("chn").toInt();

//                    lRec.str_src_path = rec.value("src_path").toString();

//                    lRec.str_dst_path = rec.value("dst_path").toString();

//                    lRec.n_total = rec.value("total").toInt();

//                    lRec.b_finish_flag = rec.value("finish_flag").toBool();

//                    lRec.tim_update_time = QDateTime::fromString(rec.value("update_time").toString(),

//                                                                 "yyyy-MM-dd hh:mm:ss");

//                    lRec.str_reserved = rec.value("reserved").toString();

//                    lst.push_back(lRec);

//                }

                for (int i = 0; i < rec.count(); i++) {

                    QSqlField field = rec.field(i);

                    rowData[field.name().toStdString()] = field.value().toString().toStdString();

                }

                rowDataList.append(rowData);

            }

            responseJsonValue["data"] = rowDataList;

        }



        responseJsonValue["message"] = "查询成功！";

        responseJsonValue["success"] = "true";

        return responseJsonValue;









//        vector<VssLocalSettingTbl> vssLocalSettingTblVec;

//        vector<map<string, string>> rowDatList = findList(querySql);

//        vssLocalSettingTblVec.reserve(rowDatList.size());

//        for (auto rowData : rowDatList) {

//            vssLocalSettingTblVec.emplace_back(mapToModel(rowData));

//        }

//        return vssLocalSettingTblVec;

   }



    /**查询本地国标配置列表 whereKeyValues 列名和列值对条件 */

    Json::Value findVssLocalSettingTblList(std::map<std::string, std::string>& whereKeyValues) {

        return findVssLocalSettingTblList(string("select * from ") + VSSLocalSettingTbl_TABLE_NAME + " where 1=1 " + getWhereColumnNameValuePair(whereKeyValues));

    }



    /**查询所有本地国标配置列表 */

    Json::Value findAllVssLocalSettingTblList() {

        return findVssLocalSettingTblList(string("select * from ") + VSSLocalSettingTbl_TABLE_NAME + " where 1=1 ");

        std::map<std::string, std::string> whereKeyValues;

        return findVssLocalSettingTblList(whereKeyValues);

    }



   /** 查询map列表 querySql 要查询的sql语句 */

   vector<map<string, string>> findMapList(string querySql) {

      return findList(querySql);

   }



    /** 执行sql语句 */

    bool execute(string sql) {

        return exec(move(sql));

    }



    /** map转model类 */

    VssLocalSettingTbl mapToModel(map<string, string>& rowData) {

        VssLocalSettingTbl vssLocalSettingTbl;

        string IDValue = rowData[VssLocalSettingTbl_ID];

        if (IDValue.length() != 0 && IDValue != "NULL") {

            vssLocalSettingTbl.ID = std::stoi(IDValue);

        }

        string ServerIpValue = rowData[VssLocalSettingTbl_ServerIp];

        if (ServerIpValue.length() != 0 && ServerIpValue != "NULL") {

            vssLocalSettingTbl.ServerIp = ServerIpValue;

        }

        string ServerPortValue = rowData[VssLocalSettingTbl_ServerPort];

        if (ServerPortValue.length() != 0 && ServerPortValue != "NULL") {

            vssLocalSettingTbl.ServerPort = ServerPortValue;

        }

        string ServerIdValue = rowData[VssLocalSettingTbl_ServerId];

        if (ServerIdValue.length() != 0 && ServerIdValue != "NULL") {

            vssLocalSettingTbl.ServerId = ServerIdValue;

        }

        string UserAuthIdValue = rowData[VssLocalSettingTbl_UserAuthId];

        if (UserAuthIdValue.length() != 0 && UserAuthIdValue != "NULL") {

            vssLocalSettingTbl.UserAuthId = UserAuthIdValue;

        }

        string PasswordValue = rowData[VssLocalSettingTbl_Password];

        if (PasswordValue.length() != 0 && PasswordValue != "NULL") {

            vssLocalSettingTbl.Password = PasswordValue;

        }

        string UpdateTimeValue = rowData[VssLocalSettingTbl_UpdateTime];

        if (UpdateTimeValue.length() != 0 && UpdateTimeValue != "NULL") {

            vssLocalSettingTbl.UpdateTime = UpdateTimeValue;

        }

        return vssLocalSettingTbl;

    }



};