cxh/sweeper_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 14:04:59 +08:00
parent cdd3961550
commit 6be2795468
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/mqtt_client_wrapper.cpp
View File

@ -33,14 +33,14 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
// 处理 video_down // 处理 video_down
auto j = nlohmann::json::parse(message); auto j = nlohmann::json::parse(message);
if (!j.contains("data") || !j["data"].contains("status")) if (!j.contains("data") || !j["data"].contains("status") || !j["data"].contains("seqNo"))
{ {
LOG_WARN("[MQTT] video_down JSON missing data.status"); LOG_WARN("[MQTT] video_down JSON missing required fields");
return; return;
} }
int status = j["data"]["status"].get<int>(); int status = j["data"]["status"].get<int>();
std::string seqNo = j["seqNo"].get<std::string>(); std::string seqNo = j["data"]["seqNo"].get<std::string>();
bool success = true; // 标记是否操作成功 bool success = true; // 标记是否操作成功
if (status == 0) if (status == 0)