cxh/kunlang_video
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
cxh 2025-09-09 10:20:04 +08:00
parent 0165a8893f
commit e9b4fbb3d8
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/mqtt_client_wrapper.cpp
View File

@ -30,6 +30,24 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
{ {
if (topic == g_app_config.mqtt.topics.video_down) if (topic == g_app_config.mqtt.topics.video_down)
{ {
LOG_INFO("[MQTT] Step 1: parsing json");
auto j = nlohmann::json::parse(message);
LOG_INFO("[MQTT] Step 2: checking data field");
if (!j.contains("data"))
{
LOG_WARN("[MQTT] missing data");
return;
}
if (!j["data"].contains("status"))
{
LOG_WARN("[MQTT] missing status");
return;
}
int status = j["data"]["status"].get<int>();
LOG_INFO("[MQTT] Step 3: got status=" + std::to_string(status));
// 处理 video_down // 处理 video_down
auto j = nlohmann::json::parse(message); auto j = nlohmann::json::parse(message);