|
|
@@ -18,6 +18,7 @@ import com.xy.entity.MqttCommand;
|
|
|
import com.xy.mapper.MqttCommandMapper;
|
|
|
import com.xy.producer.MqttProducer;
|
|
|
import com.xy.utils.*;
|
|
|
+import com.xy.utils.consts.CommConsts;
|
|
|
import com.xy.utils.enums.MqttCommandStatusEnum;
|
|
|
import io.swagger.annotations.Api;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
@@ -57,7 +58,7 @@ public class MqttServiceImpl implements MqttService {
|
|
|
.setDebug(mqttDto.getDebug());
|
|
|
//延迟发布处理
|
|
|
String delayTime = mqttDto.getDelayTime();
|
|
|
- String topic = mqttDto.getDeviceId().toString(); //+ CommConsts.DEVICE_MQTT_TOPIC_SUFFIX;
|
|
|
+ String topic = mqttDto.getDeviceId() + CommConsts.DEVICE_MQTT_TOPIC_SUFFIX;
|
|
|
if (!StringUtils.isEmpty(delayTime)) {
|
|
|
//消息消费时间 - 发布时间的差值 = 距今被消费的秒数
|
|
|
long m = DataTime.diff(DataTime.toLocal(pater.getTime()), DataTime.toLocal(delayTime), "s");
|
