diff --git a/admin/src/main/java/com/multictrl/modules/business/service/impl/DJIBaseServiceImpl.java b/admin/src/main/java/com/multictrl/modules/business/service/impl/DJIBaseServiceImpl.java index da138c6..580d46e 100644 --- a/admin/src/main/java/com/multictrl/modules/business/service/impl/DJIBaseServiceImpl.java +++ b/admin/src/main/java/com/multictrl/modules/business/service/impl/DJIBaseServiceImpl.java @@ -50,8 +50,7 @@ public class DJIBaseServiceImpl implements DJIBaseService { mqttPushService.pushMessageByClient1(topic, payload.toString()); String bid = payload.getStr("bid"); String tid = payload.getStr("tid"); - // 设备回复只回传相同的 bid(tid 会重新生成),因此以 bid 作为关联回复的缓存键 - String cacheKey = bid; + String cacheKey = bid + "_" + tid; // 记录当前等待回复的命令,供前端模拟回复使用 String deviceSn = extractDeviceSn(topic);