server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java
@@ -59,7 +59,7 @@ } MqttLog mqttLog = new MqttLog(); mqttLog.setMsgId(msgId); int msgCount =mqttLogMapper.selectCount(new QueryWrapper<MqttLog>().lambda().eq(MqttLog::getMsgId, msgId)); int msgCount =mqttLogMapper.selectCount(new QueryWrapper<MqttLog>().lambda().eq(MqttLog::getMsg, param).eq(MqttLog::getType, Constants.ZERO)); if(msgCount>0){ log.error("mqtt消息订阅==============已消费数据====="+param); return;
