package cn.lihu.jh.module.ecg.config;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.dataformat.xml.XmlMapper;
|
import feign.RequestTemplate;
|
import feign.Response;
|
import feign.codec.DecodeException;
|
import feign.codec.Decoder;
|
import feign.codec.EncodeException;
|
import feign.codec.Encoder;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
import javax.xml.bind.JAXBException;
|
import javax.xml.bind.Marshaller;
|
import java.io.IOException;
|
import java.io.StringWriter;
|
import java.lang.reflect.Type;
|
import java.nio.charset.StandardCharsets;
|
|
@Slf4j
|
public class FeignXmlConfiguration {
|
|
@Bean
|
public Encoder feignEncoder() {
|
return new Encoder.Default() {
|
@Override
|
public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
|
try {
|
XmlMapper xmlMapper = new XmlMapper();
|
String xml = xmlMapper.writeValueAsString(object);
|
template.body(xml.getBytes(StandardCharsets.UTF_8), StandardCharsets.UTF_8);
|
} catch (JsonProcessingException e) {
|
throw new EncodeException(e.getMessage(), e);
|
}
|
}
|
};
|
}
|
|
@Bean
|
public Decoder feignDecoder() {
|
return new Decoder.Default() {
|
@Override
|
public Object decode(Response response, Type type) throws IOException {
|
try {
|
XmlMapper xmlMapper = new XmlMapper();
|
return xmlMapper.readValue(response.body().asInputStream(), xmlMapper.constructType(type));
|
} catch (IllegalArgumentException e) {
|
throw new DecodeException(response.status(), e.getMessage(), response.request());
|
}
|
}
|
};
|
}
|
}
|
