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 cbb00b6..af0e315 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 @@ -166,11 +166,11 @@ public class RootCloudIotDataReceiptedEvent implements Serializable { private Online __online__; - @JsonIgnoreProperties(ignoreUnknown = true) - private String __thingName__; + @JsonProperty("__thingName__") + private Object thingName; @Data - public static class Online{ + public static class Online { private boolean connected; private boolean directlyLinked; 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 7c6bd88..c8df0ee 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 @@ -1,6 +1,9 @@ package com.qniao.iot.rc.event; +import cn.hutool.core.text.CharSequenceUtil; import cn.hutool.core.util.ByteUtil; +import cn.hutool.core.util.CharsetUtil; +import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.fasterxml.jackson.databind.ObjectMapper; import com.qniao.iot.rc.RootCloudIotDataReceiptedEvent; @@ -23,6 +26,7 @@ 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); }