From 603b7d82eb15256f484ac65896c1260ae30fe00c Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Mon, 30 Jan 2023 17:04:22 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8F=8D=E5=BA=8F=E5=88=97?=
 =?UTF-8?q?=E5=8C=96=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java | 2 +-
 .../RootCloudIotDataReceiptedEventDeserializationSchema.java  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
index af0e315..504e0b1 100644
--- a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
+++ b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
@@ -167,7 +167,7 @@ public class RootCloudIotDataReceiptedEvent implements Serializable {
     private Online __online__;
 
     @JsonProperty("__thingName__")
-    private Object thingName;
+    private String thingName;
 
     @Data
     public static class Online {
diff --git a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
index c8df0ee..00a52ee 100644
--- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
+++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
@@ -26,8 +26,8 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese
     @Override
     public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException {
 
-        log.info("接受的信息：{}", StrUtil.str(message, CharsetUtil.UTF_8));
-        return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
+        return JSONUtil.toBean(StrUtil.str(message, CharsetUtil.UTF_8), RootCloudIotDataReceiptedEvent.class);
+        //return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
     }
 
     @Override