轮询

zhangmeng

2019-06-08 dad25d2735da7a04ccf111d1ae14da4d4bc4955b

轮询

 QiaoJiaSystem/VideoToImageMulth/CMakeLists.txt

@@ -85,6 +85,10 @@
    #nsq
    ../../../BasicPlatForm/libs/EvnsqTool/include
    ../../../BasicPlatForm/libs/libevent/include

    #mysql
    ../../../BasicPlatForm/basic/util/app/

)

link_directories(
@@ -128,6 +132,9 @@
    ./RtspImageRedis.h
    ./RtspImageRedis.cpp
    main.cpp

    #mysql
    ../DataManagerServer/vss/dao/BaseDao.cpp
    )
target_link_libraries(${PROJECT_NAME}
    ${LIBS}

 QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.cpp

@@ -4,7 +4,7 @@

#include "RtspAnalysManager.h"
#include <basic/pipe_element/ffmpeg/basic_struct_for_video_image.h>

#include <DataManagerServer/vss/dao/VssChannelTblDao.h>

using std::string;
void *gRtspAnalysManagerCamera = nullptr;
@@ -192,6 +192,13 @@
                itor++;
            }

            auto mysql = VssChannelTblDao::instance();
            bool flag = mysql->exec("update VSSChannelTbl set Longitude=\"0\"");
            if (flag){
                INFO("update all longtitue 0");
            }else{
                INFO("update all longtitude error");
            }
            for (int i = 0; i < CamCount; i++) {
                if (itor == lst.end()) {
                    ERR("itor == lst.end()");
@@ -203,6 +210,14 @@
                INFO("cam add is " << itor->str_addr.toStdString());

                addCamera(t_camIdex, rtsp_url);
                std::string sql("update VSSChannelTbl set Longitude=\"1\" where ChanPubID=");
                sql = sql + "\"" + t_camIdex + "\";";
                flag = mysql->exec(sql.c_str());
                if (flag){
                    INFO("update:"<< t_camIdex <<" longtitue 0");
                }else{
                    INFO("update:"<< t_camIdex <<" longtitue error");
                }
                sleep(1);
                itor++;
            }