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