fix(driver): set collect time when missing in mqtt demo receive service

This commit is contained in:
xwh201314
2023-04-17 15:50:51 +08:00
parent 5e6bad7856
commit f3db2bbdb8
@@ -25,6 +25,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@@ -44,6 +45,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
// do something to process your mqtt messages
log.info(JsonUtil.toPrettyJsonString(mqttMessage));
PointValue pointValue = JsonUtil.parseObject(mqttMessage.getPayload(), PointValue.class);
pointValue.setOriginTime(new Date());
driverSenderService.pointValueSender(pointValue);
}