find channel bug

xuxiuxi

2019-03-07 f2ac06cd25abc8d69ceeb0b19abdb5051d9fcf41

find channel bug

 QiaoJiaSystem/DataManagerServer/CMakeLists.txt

@@ -110,7 +110,7 @@
    ../LocalDBTool/SqliteFaceEncap.cpp
    ../../../BasicPlatForm/basic/db/sqlite/sqliteEncapsulation.cpp
    ../../../BasicPlatForm/basic/db/sqlite/sqliteEncapsulation.h
    )
        vss/dao/BaseDao.cpp)

target_link_libraries(DataWebServer
    glog

 QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.cpp

New file
@@ -0,0 +1,3 @@
#include "BaseDao.h"
mysqlpp::Connection* BaseDao::conn = nullptr;
QMutex BaseDao::m_mutexVisit;

 QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h

@@ -8,11 +8,15 @@
#include <iostream>
#include <mysql++.h>
#include <AppConfig.h>
#include <QtCore/QMutex>

using namespace std;

static mysqlpp::Connection* conn;
class BaseDao {
public:
    static QMutex m_mutexVisit;
private:
    static mysqlpp::Connection* conn;
public:
    static mysqlpp::SimpleResult add(std::map<std::string, std::string>& columns, string tableName) {
        initConnection();
@@ -135,7 +139,7 @@
//            )) {
        if (conn->connect(
                "EGEyesForVSS",
                "127.0.0.1",
                "192.168.1.148",
                "root",
                "123456",
                3306

 QiaoJiaSystem/DataManagerServer/vss/dao/BaseSqliteDao.cpp

New file
@@ -0,0 +1,7 @@
#include "BaseSqliteDao.h"

LDBTool* BaseSqliteDao::lDBTool = nullptr;
QSqlDatabase* BaseSqliteDao::m_db = nullptr;
QSqlTableModel *BaseSqliteDao::m_pModel = nullptr;
QMutex* BaseSqliteDao::m_mutexVisit = nullptr;
ErlangTool::ErlangDbTool *BaseSqliteDao::erlangDbTool = nullptr;

 QiaoJiaSystem/DataManagerServer/vss/dao/VssChannelTblDao.h

@@ -23,6 +23,7 @@
    

    /** 添加创建二级设备表 keyValuesToAdd 需要添加的列名和列值对map*/

    mysqlpp::SimpleResult addVssChannelTbl(std::map<std::string, std::string>& keyValuesToAdd) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return add(keyValuesToAdd, VSSChannelTbl_TABLE_NAME);

    }

    

@@ -35,12 +36,14 @@


    /** 删除创建二级设备表 whereColumnNameValues 列名和列值对条件 */

    bool deleteVssChannelTbl(std::map<std::string, std::string>& whereKeyValues) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return del(VSSChannelTbl_TABLE_NAME, whereKeyValues);

    }

    

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

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

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

        QMutexLocker mutexLocker(&m_mutexVisit);

        return update(keyValuesToUpdate, VSSChannelTbl_TABLE_NAME, whereKeyValues);

    }

    

@@ -55,6 +58,7 @@
    

    /** 查询创建二级设备表列表  querySql 要查询的sql语句 */

    vector<VssChannelTbl> findVssChannelTblList(string querySql) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        vector<VssChannelTbl> vssChannelTblVec;

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

        vssChannelTblVec.reserve(rowDatList.size());

@@ -81,6 +85,7 @@
    

    /** 执行sql语句 */

    bool execute(string sql) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return exec(move(sql));

    }

    


 QiaoJiaSystem/DataManagerServer/vss/dao/VssDevTblDao.h

@@ -23,6 +23,7 @@
    

    /** 添加创建一级设备表 keyValuesToAdd 需要添加的列名和列值对map*/

    mysqlpp::SimpleResult addVssDevTbl(std::map<std::string, std::string>& keyValuesToAdd) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return add(keyValuesToAdd, VSSDevTbl_TABLE_NAME);

    }

    

@@ -35,12 +36,14 @@


    /** 删除创建一级设备表 whereColumnNameValues 列名和列值对条件 */

    bool deleteVssDevTbl(std::map<std::string, std::string>& whereKeyValues) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return del(VSSDevTbl_TABLE_NAME, whereKeyValues);

    }

    

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

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

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

        QMutexLocker mutexLocker(&m_mutexVisit);

        return update(keyValuesToUpdate, VSSDevTbl_TABLE_NAME, whereKeyValues);

    }

    

@@ -55,6 +58,7 @@
    

    /** 查询创建一级设备表列表  querySql 要查询的sql语句 */

    vector<VssDevTbl> findVssDevTblList(string querySql) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        vector<VssDevTbl> vssDevTblVec;

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

        vssDevTblVec.reserve(rowDatList.size());

@@ -76,11 +80,13 @@
    

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

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

        QMutexLocker mutexLocker(&m_mutexVisit);

        return findList(querySql);

    }

    

    /** 执行sql语句 */

    bool execute(string sql) {

        QMutexLocker mutexLocker(&m_mutexVisit);

        return exec(move(sql));

    }