chenshijun
2019-03-27 e15c4888f720b8781260b901ac82d058f8f7c3b5
QiaoJiaSystem/DataManagerServer/http_configserver.cpp
@@ -33,7 +33,7 @@
using namespace std;
devHttpServer_c::devHttpServer_c()
    : _HttpSrvRetRecieve("0.0.0.0", 8083, 1), erlangDbTool(nullptr), m_SqliteFaceEncap("LocalDataDB") {
    : _HttpSrvRetRecieve("0.0.0.0", 8083, 1), erlangDbTool(nullptr), m_SqliteFaceEncap("LocalDataDB"){
    init();
}
@@ -73,6 +73,10 @@
void devHttpServer_c::init(void) {
    std::string strDevId = appConfig.getStringProperty("DEV_ID");
    //nsq
    nsqMsgProducer = new BasicMsg::Nsq::NsqMsgProducer("127.0.0.1", "4150");
    nsqMsgProducer->init();
//    DSVAD010120181119
    m_batch = strDevId.substr(5, 2);
@@ -1529,9 +1533,13 @@
    }
    if (ret) {
        killVideoAnalysFromHCApp();
        sleep(1);
        runAllApp();
        //todo
        {
            std::string topic = "cut_dura_edit";
            std::string msg = content;
            DBG("msg:" << msg);
            nsqMsgProducer->Publish(topic, (void *) (&msg));
        }
        return "{\"ret_status\": \"ok_ack\"}";
    } else {
        return "{\"ret_status\": \"内容有误,请检查!\"}";