From 4da1a259a916ae3d21ae165dfd53c7a68ca659b5 Mon Sep 17 00:00:00 2001 From: yechuan Date: Fri, 11 Aug 2023 11:57:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=B9=E4=BA=8Exml=E6=A0=BC=E5=BC=8F?= =?UTF-8?q?=E7=9A=84=E6=B6=88=E6=81=AF=20=E4=BD=BF=E7=94=A8toString?= =?UTF-8?q?=E4=BC=9A=E6=94=B6=E5=B0=BE=E6=8B=BC=E6=8E=A5=E2=80=9C=20?= =?UTF-8?q?=E5=AF=BC=E8=87=B4=E5=90=8E=E7=BB=AD=E8=BD=AC=E5=8C=96=E5=BC=82?= =?UTF-8?q?=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../transformer/JsonDataTransformer.java | 26 ++++++++++++++++++++++ .../transformer/ResDataTransformer.java | 2 +- 2 files changed, 27 insertions(+), 1 deletion(-) create mode 100644 transformer/src/main/java/work/xuye/transformer/transformer/JsonDataTransformer.java diff --git a/transformer/src/main/java/work/xuye/transformer/transformer/JsonDataTransformer.java b/transformer/src/main/java/work/xuye/transformer/transformer/JsonDataTransformer.java new file mode 100644 index 0000000..d5fb1b3 --- /dev/null +++ b/transformer/src/main/java/work/xuye/transformer/transformer/JsonDataTransformer.java @@ -0,0 +1,26 @@ +package work.xuye.transformer.transformer; + +import com.google.gson.JsonObject; +import com.google.gson.JsonParser; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * @author yechuan + * @since 2023/8/11 11:55 + **/ +@Slf4j +@Component("jsonData") +public class JsonDataTransformer implements MessageTransformer{ + @Override + public String transform(String message, String seedUrl) { + JsonObject res = JsonParser.parseString(message).getAsJsonObject(); + boolean hasData = res.has("data"); + if (hasData) { + return res.get("data").toString(); + } else { + log.warn("resData transform failed, res not has data, res: {}", res); + } + return null; + } +} diff --git a/transformer/src/main/java/work/xuye/transformer/transformer/ResDataTransformer.java b/transformer/src/main/java/work/xuye/transformer/transformer/ResDataTransformer.java index 69e04ac..4b342c5 100644 --- a/transformer/src/main/java/work/xuye/transformer/transformer/ResDataTransformer.java +++ b/transformer/src/main/java/work/xuye/transformer/transformer/ResDataTransformer.java @@ -20,7 +20,7 @@ public class ResDataTransformer implements MessageTransformer { JsonObject res = JsonParser.parseString(json).getAsJsonObject(); boolean hasData = res.has("data"); if (hasData) { - return res.get("data").toString(); + return res.get("data").getAsString(); } else { log.warn("resData transform failed, res not has data, res: {}", res); }