From 0f1aebc2666683642a6b3fdf1a5e4530a0f12a0a Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Mon, 30 Jan 2023 11:36:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java | 3 ++- .../RootCloudIotDataReceiptedEventDeserializationSchema.java | 3 +++ 2 files changed, 5 insertions(+), 1 deletion(-) 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 05ed043..400f26e 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 @@ -165,7 +165,8 @@ public class RootCloudIotDataReceiptedEvent implements Serializable { private Online __online__; - private String __thingName__; + @JsonProperty(value = "__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 6dd0725..58484b4 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,5 +1,7 @@ package com.qniao.iot.rc.event; +import cn.hutool.core.util.ByteUtil; +import cn.hutool.json.JSONUtil; import com.fasterxml.jackson.databind.ObjectMapper; import com.qniao.iot.rc.RootCloudIotDataReceiptedEvent; import org.apache.flink.api.common.serialization.DeserializationSchema; @@ -18,6 +20,7 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese @Override public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException { + return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class); }