| | |
| | | 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(); |
| | | } |
| | | |
| | |
| | | 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); |
| | |
| | | } |
| | | |
| | | 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\": \"内容有误,请检查!\"}"; |