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); }