提交 884dab92 authored 作者: blu's avatar blu

cloud cmd api for platform client

上级 19d4d7d6
...@@ -472,6 +472,11 @@ private: ...@@ -472,6 +472,11 @@ private:
spdlog::error("evcloudsvc {} failed to send multiple: {}", devSn, zmq_strerror(zmq_errno())); spdlog::error("evcloudsvc {} failed to send multiple: {}", devSn, zmq_strerror(zmq_errno()));
} }
} }
}else{
json resp;
resp["metaType"] = EV_MSG_META_PONG;
resp["target"] = selfId;
sendEdgeMsg(resp);
} }
} }
} }
...@@ -558,12 +563,16 @@ private: ...@@ -558,12 +563,16 @@ private:
if(v.size() == 1 || v.size() == 3) { if(v.size() == 1 || v.size() == 3) {
json meta; json meta;
meta["type"] = body["metaType"]; meta["type"] = body["metaType"];
if(body.count("metaValue") == 0) {
// meta["value"] = "";
}else{
meta["value"] = body["metaValue"]; meta["value"] = body["metaValue"];
}
body["sender"] = devSn; body["sender"] = devSn;
if(peerData["status"].count(v[0]) == 0 || peerData["status"][v[0]] == 0){ if(peerData["status"].count(v[0]) == 0 || peerData["status"][v[0]] == 0){
spdlog::warn("evcloudsvc sent msg {} to {}, but it was offline", body.dump(), v[0]); spdlog::warn("evcloudsvc sent msg {} to {}, but it was offline", body.dump(), v[0]);
}else{ }else{
} }
int i= z_send(pRouter, v[0], devSn, meta, body.dump()); int i= z_send(pRouter, v[0], devSn, meta, body.dump());
if(i < 0) { if(i < 0) {
......
...@@ -565,7 +565,10 @@ private: ...@@ -565,7 +565,10 @@ private:
}else{ }else{
spdlog::info("done"); spdlog::info("done");
} }
}else{ }else if(meta == EV_MSG_META_PONG) {
spdlog::info("evdaemon {} received pong msg from evcloudsvc", devSn);
}
else{
spdlog::info("evdaemon {} received msg from cloud that having no handler implemented: {}", devSn, msg); spdlog::info("evdaemon {} received msg from cloud that having no handler implemented: {}", devSn, msg);
} }
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论