From f15b4feb486a85dcc3b9b5c68a8526957a6ad0bd Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期六, 18 十一月 2023 16:53:24 +0800
Subject: [PATCH] 调整车牌识别配置3
---
src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java b/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
index d71a7c5..7ba5fdc 100644
--- a/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
+++ b/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
@@ -14,6 +14,7 @@
import com.fzzy.gateway.hx2023.kafka.KafkaDeviceReportService;
import com.fzzy.mqtt.MqttGatewayService;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -97,7 +98,7 @@
GatewayDevice device = reqData.getDevice();
- if (null == reqData.getData()) {
+ if (StringUtils.isEmpty(reqData.getData())) {
WebSocketPacket packet = new WebSocketPacket();
WebSocketPacketHeader header = new WebSocketPacketHeader();
header.setDeviceName(reqData.getDeviceName());
@@ -116,6 +117,8 @@
jsonObject.put("position", device.getPosition());
packet.setProperties(jsonObject);
packet.setTimestamp(System.currentTimeMillis());
+
+ reqData.setData(JSONObject.toJSONString(packet));
}
publishService.publishMqttWithTopic(reqData.getData(), topic);
--
Gitblit v1.9.3