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

1

Browse Source
This commit is contained in:
cxh 2025-11-14 18:00:20 +08:00
parent 98f84845be
commit 5cefbe6cf4
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/mqtt_client_wrapper.cpp
View File

@ -226,11 +226,14 @@ static void handle_record_play_request(const nlohmann::json& req)
data["endTime"] = seg.end_ms; data["endTime"] = seg.end_ms;
data["duration"] = duration; data["duration"] = duration;
int index = 1;
// 6. 单文件列表 // 6. 单文件列表
nlohmann::json files = nlohmann::json::array(); nlohmann::json files = nlohmann::json::array();
for (auto& f : seg.files) for (auto& f : seg.files)
{ {
nlohmann::json item; nlohmann::json item;
item["index"] = index++;
item["url"] = "http://" + ip + ":" + std::to_string(http_port) + f.path; item["url"] = "http://" + ip + ":" + std::to_string(http_port) + f.path;
item["startTime"] = f.start_ms; item["startTime"] = f.start_ms;
item["endTime"] = f.end_ms; item["endTime"] = f.end_ms;
@ -252,7 +255,6 @@ static void on_mqtt_message_received(const std::string& topic, const std::string
// 必须是 request // 必须是 request
if (!j.contains("type") || j["type"] != "request") if (!j.contains("type") || j["type"] != "request")
{ {
LOG_INFO("[MQTT] Ignored non-request message");
return; return;
} }