1.修改
This commit is contained in:
parent
18c6de38ca
commit
434726a9af
|
|
@ -50,8 +50,7 @@ public class DJIBaseServiceImpl implements DJIBaseService {
|
||||||
mqttPushService.pushMessageByClient1(topic, payload.toString());
|
mqttPushService.pushMessageByClient1(topic, payload.toString());
|
||||||
String bid = payload.getStr("bid");
|
String bid = payload.getStr("bid");
|
||||||
String tid = payload.getStr("tid");
|
String tid = payload.getStr("tid");
|
||||||
// 设备回复只回传相同的 bid(tid 会重新生成),因此以 bid 作为关联回复的缓存键
|
String cacheKey = bid + "_" + tid;
|
||||||
String cacheKey = bid;
|
|
||||||
|
|
||||||
// 记录当前等待回复的命令,供前端模拟回复使用
|
// 记录当前等待回复的命令,供前端模拟回复使用
|
||||||
String deviceSn = extractDeviceSn(topic);
|
String deviceSn = extractDeviceSn(topic);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue