GB28181集成完成,集成推流模块

pansen

2019-03-07 d3b7bbe7102cd089680a828f5d8f6402c8cf6342

 QiaoJiaSystem/DataManagerServer/vss/controller/VssLocalSettingTblController.h

@@ -17,47 +17,52 @@
 */

class VssLocalSettingTblController : public VssBaseController {

private:

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

   VssLocalSettingTblController() {}

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

    VssLocalSettingTblController() {}



public:

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

    static VssLocalSettingTblController* instance() {

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

    static VssLocalSettingTblController *instance() {

        static VssLocalSettingTblController instance;

        return &instance;

    }

public:

   /** 注册{label}http服务 */

    void registerHttpServices(HttpSrvRetRecieve& _HttpSrvRetRecieve) {



       _HttpSrvRetRecieve.setInfo("^/addVssLocalSettingTbl$", "POST",

                                  std::bind(&VssLocalSettingTblController::addVssLocalSettingTbl, this,

                                            std::placeholders::_1, std::placeholders::_2,

                                            std::placeholders::_3, std::placeholders::_4));

	
       _HttpSrvRetRecieve.setInfo("^/delVssLocalSettingTbl$", "POST",

                                  std::bind(&VssLocalSettingTblController::delVssLocalSettingTbl, this,

                                            std::placeholders::_1, std::placeholders::_2,

                                            std::placeholders::_3, std::placeholders::_4));

	
       _HttpSrvRetRecieve.setInfo("^/updateVssLocalSettingTbl$", "POST",

                                  std::bind(&VssLocalSettingTblController::updateVssLocalSettingTbl, this,

                                            std::placeholders::_1, std::placeholders::_2,

                                            std::placeholders::_3, std::placeholders::_4));

	
       _HttpSrvRetRecieve.setInfo("^/findVssLocalSettingTbl$", "POST",

                                  std::bind(&VssLocalSettingTblController::findVssLocalSettingTbl, this,

                                            std::placeholders::_1, std::placeholders::_2,

                                            std::placeholders::_3, std::placeholders::_4));

	
       _HttpSrvRetRecieve.setInfo("^/findVssLocalSettingTblList$", "POST",

                                  std::bind(&VssLocalSettingTblController::findVssLocalSettingTblList, this,

                                            std::placeholders::_1, std::placeholders::_2,

                                            std::placeholders::_3, std::placeholders::_4));

public:

    /** 注册{label}http服务 */

    void registerHttpServices(HttpSrvRetRecieve &_HttpSrvRetRecieve) {



        _HttpSrvRetRecieve.setInfo("^/addVssLocalSettingTbl$", "POST",

                                   std::bind(&VssLocalSettingTblController::addVssLocalSettingTbl, this,

                                             std::placeholders::_1, std::placeholders::_2,

                                             std::placeholders::_3, std::placeholders::_4));



        _HttpSrvRetRecieve.setInfo("^/delVssLocalSettingTbl$", "POST",

                                   std::bind(&VssLocalSettingTblController::delVssLocalSettingTbl, this,

                                             std::placeholders::_1, std::placeholders::_2,

                                             std::placeholders::_3, std::placeholders::_4));



        _HttpSrvRetRecieve.setInfo("^/updateVssLocalSettingTbl$", "POST",

                                   std::bind(&VssLocalSettingTblController::updateVssLocalSettingTbl, this,

                                             std::placeholders::_1, std::placeholders::_2,

                                             std::placeholders::_3, std::placeholders::_4));



        _HttpSrvRetRecieve.setInfo("^/findVssLocalSettingTbl$", "POST",

                                   std::bind(&VssLocalSettingTblController::findVssLocalSettingTbl, this,

                                             std::placeholders::_1, std::placeholders::_2,

                                             std::placeholders::_3, std::placeholders::_4));



        _HttpSrvRetRecieve.setInfo("^/findVssLocalSettingTblList$", "POST",

                                   std::bind(&VssLocalSettingTblController::findVssLocalSettingTblList, this,

                                             std::placeholders::_1, std::placeholders::_2,

                                             std::placeholders::_3, std::placeholders::_4));



    }



public:

   /** 添加本地国标配置 */

    /** 添加本地国标配置 */

    std::string addVssLocalSettingTbl(std::string ip, unsigned int port, std::string content, PResponse &response) {

        DBG("ip:" << ip << "; port:" << port);

        DBG("content: " << content);

        Json::Reader requestJsonReader;

        Json::Value requestJsonValue;

        Json::Value responseJsonValue;

@@ -65,43 +70,43 @@
        responseJsonValue["success"] = "false";

        if (requestJsonReader.parse(content, requestJsonValue)) {

            VssLocalSettingTblBuilder vssLocalSettingTblBuilder;

	    
          Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];



            Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addID(std::stoi(iDJsonValue.asString()));

            }



          Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            if (serverIpJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerIp(serverIpJsonValue.asString());

            }



          Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            if (serverPortJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerPort(serverPortJsonValue.asString());

            }



          Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            if (serverIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerId(serverIdJsonValue.asString());

            }



          Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            if (userAuthIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUserAuthId(userAuthIdJsonValue.asString());

            }



          Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            if (passwordJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addPassword(passwordJsonValue.asString());

            }



          Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            if (updateTimeJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUpdateTime(updateTimeJsonValue.asString());

            }

          auto keyValuesToAdd = vssLocalSettingTblBuilder.buildVssLocalSettingTblMap();

          if (keyValuesToAdd.size() > 0) {

            auto keyValuesToAdd = vssLocalSettingTblBuilder.buildVssLocalSettingTblMap();

            if (keyValuesToAdd.size() > 0) {

                responseJsonValue = VssLocalSettingTblSqliteDao::instance()->addVssLocalSettingTbl(keyValuesToAdd);

            }

        }

@@ -110,16 +115,18 @@


    /** 删除本地国标配置 */

    std::string delVssLocalSettingTbl(std::string ip, unsigned int port, std::string content, PResponse &response) {

        DBG("ip:" << ip << "; port:" << port);

        DBG("content: " << content);

        Json::Reader requestJsonReader;

        Json::Value requestJsonValue;

        Json::Value responseJsonValue;

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

        responseJsonValue["success"] = "false";

        if (requestJsonReader.parse(content, requestJsonValue)) {

           Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

           if (iDJsonValue.type() != Json::ValueType::nullValue) {

              string iDValue = iDJsonValue.asString();

              responseJsonValue = VssLocalSettingTblSqliteDao::instance()->deleteByColumn("ID", iDValue);

            Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                string iDValue = iDJsonValue.asString();

                responseJsonValue = VssLocalSettingTblSqliteDao::instance()->deleteByColumn("ID", iDValue);

            }



        }

@@ -128,6 +135,8 @@


    /** 更新本地国标配置 */

    std::string updateVssLocalSettingTbl(std::string ip, unsigned int port, std::string content, PResponse &response) {

        DBG("ip:" << ip << "; port:" << port);

        DBG("content: " << content);

        Json::Reader requestJsonReader;

        Json::Value requestJsonValue;

        Json::Value responseJsonValue;

@@ -136,43 +145,44 @@
        if (requestJsonReader.parse(content, requestJsonValue)) {

            VssLocalSettingTblBuilder vssLocalSettingTblBuilder;



          Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addID(std::stoi(iDJsonValue.asString()));

            }



          Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            if (serverIpJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerIp(serverIpJsonValue.asString());

            }



          Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            if (serverPortJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerPort(serverPortJsonValue.asString());

            }



          Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            if (serverIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerId(serverIdJsonValue.asString());

            }



          Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            if (userAuthIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUserAuthId(userAuthIdJsonValue.asString());

            }



          Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            if (passwordJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addPassword(passwordJsonValue.asString());

            }



          Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            if (updateTimeJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUpdateTime(updateTimeJsonValue.asString());

            }

           if (iDJsonValue.type() != Json::ValueType::nullValue) {

              string iDValue = iDJsonValue.asString();

                responseJsonValue = VssLocalSettingTblSqliteDao::instance()->updateVssLocalSettingTbl(vssLocalSettingTblBuilder.buildVssLocalSettingTblMap(), "ID", iDValue);

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                string iDValue = iDJsonValue.asString();

                responseJsonValue = VssLocalSettingTblSqliteDao::instance()->updateVssLocalSettingTbl(

                    vssLocalSettingTblBuilder.buildVssLocalSettingTblMap(), "ID", iDValue);

            }

        }

        return responseJsonValue.toStyledString();

@@ -180,6 +190,8 @@


    /** 查找单个本地国标配置 */

    std::string findVssLocalSettingTbl(std::string ip, unsigned int port, std::string content, PResponse &response) {

        DBG("ip:" << ip << "; port:" << port);

        DBG("content: " << content);

        Json::Reader requestJsonReader;

        Json::Value requestJsonValue;

        Json::Value responseJsonValue;

@@ -188,49 +200,53 @@
        if (requestJsonReader.parse(content, requestJsonValue)) {

            VssLocalSettingTblBuilder vssLocalSettingTblBuilder;



          Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addID(std::stoi(iDJsonValue.asString()));

            }



          Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            if (serverIpJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerIp(serverIpJsonValue.asString());

            }



          Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            if (serverPortJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerPort(serverPortJsonValue.asString());

            }



          Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            if (serverIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerId(serverIdJsonValue.asString());

            }



          Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            if (userAuthIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUserAuthId(userAuthIdJsonValue.asString());

            }



          Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            if (passwordJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addPassword(passwordJsonValue.asString());

            }



          Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            if (updateTimeJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUpdateTime(updateTimeJsonValue.asString());

            }

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

           responseJsonValue["success"] = "true";

            responseJsonValue = VssLocalSettingTblSqliteDao::instance()->findVssLocalSettingTblList(vssLocalSettingTblBuilder.buildVssLocalSettingTblMap());

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

            responseJsonValue["success"] = "true";

            responseJsonValue = VssLocalSettingTblSqliteDao::instance()->findVssLocalSettingTblList(

                vssLocalSettingTblBuilder.buildVssLocalSettingTblMap());

        }

        return responseJsonValue.toStyledString();

    }



    /** 查找本地国标配置列表 */

    std::string findVssLocalSettingTblList(std::string ip, unsigned int port, std::string content, PResponse &response) {

    std::string

    findVssLocalSettingTblList(std::string ip, unsigned int port, std::string content, PResponse &response) {

        DBG("ip:" << ip << "; port:" << port);

        DBG("content: " << content);

        Json::Reader requestJsonReader;

        Json::Value requestJsonValue;

        Json::Value responseJsonValue;

@@ -239,52 +255,49 @@
        if (content == "" || requestJsonReader.parse(content, requestJsonValue)) {

            VssLocalSettingTblBuilder vssLocalSettingTblBuilder;



          Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            Json::Value iDJsonValue = requestJsonValue[VssLocalSettingTbl_ID];

            if (iDJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addID(std::stoi(iDJsonValue.asString()));

            }

	    
          Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];



            Json::Value serverIpJsonValue = requestJsonValue[VssLocalSettingTbl_ServerIp];

            if (serverIpJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerIp(serverIpJsonValue.asString());

            }

	    
          Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];



            Json::Value serverPortJsonValue = requestJsonValue[VssLocalSettingTbl_ServerPort];

            if (serverPortJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerPort(serverPortJsonValue.asString());

            }

	    
          Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];



            Json::Value serverIdJsonValue = requestJsonValue[VssLocalSettingTbl_ServerId];

            if (serverIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addServerId(serverIdJsonValue.asString());

            }

	    
          Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];



            Json::Value userAuthIdJsonValue = requestJsonValue[VssLocalSettingTbl_UserAuthId];

            if (userAuthIdJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUserAuthId(userAuthIdJsonValue.asString());

            }

	    
          Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];



            Json::Value passwordJsonValue = requestJsonValue[VssLocalSettingTbl_Password];

            if (passwordJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addPassword(passwordJsonValue.asString());

            }

	    
          Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];



            Json::Value updateTimeJsonValue = requestJsonValue[VssLocalSettingTbl_UpdateTime];

            if (updateTimeJsonValue.type() != Json::ValueType::nullValue) {

                vssLocalSettingTblBuilder.addUpdateTime(updateTimeJsonValue.asString());

            }

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

           responseJsonValue["success"] = "true";

          responseJsonValue = VssLocalSettingTblSqliteDao::instance()->findVssLocalSettingTblList(vssLocalSettingTblBuilder.buildVssLocalSettingTblMap());

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

            responseJsonValue["success"] = "true";

            responseJsonValue = VssLocalSettingTblSqliteDao::instance()->findVssLocalSettingTblList(

                vssLocalSettingTblBuilder.buildVssLocalSettingTblMap());



        }

        return responseJsonValue.toStyledString();

    }

};













#endif //VSSLOCALSETTINGTBL_CONTROLLER_H