lywsvip/easy
1
0
Fork 0
mirror of https://github.com/yin5980280/easy.git synced 2026-09-03 07:26:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

【U】修复报错

Browse Source
This commit is contained in:
殷林
2020-08-10 18:13:37 +08:00
parent 7b907517df
commit 31cd2db31b
2 changed files with 51 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
easy-spring-cloud-feign/src/main/java/cn/org/easysite/spring/cloud/feign/configuration/FeignConfiguration.java
View File

@@ -1,11 +1,7 @@
package cn.org.easysite.spring.cloud.feign.configuration;
import cn.org.easysite.spring.cloud.feign.interceptor.FeignResponseInterceptor;
import org.springframework.context.annotation.Configuration;
import feign.codec.Decoder;
/**
* @author : yinlin
* @version : 1.0
@@ -18,8 +14,8 @@ import feign.codec.Decoder;
@Configuration
public class FeignConfiguration {
//@Bean
public Decoder getFeignResponseInterceptor() {
return new FeignResponseInterceptor();
}
//public Decoder getFeignResponseInterceptor() {
// return new FeignResponseInterceptor();
//}
}

96
easy-spring-cloud-feign/src/main/java/cn/org/easysite/spring/cloud/feign/interceptor/FeignResponseInterceptor.java
View File

@@ -1,48 +1,48 @@
package cn.org.easysite.spring.cloud.feign.interceptor;
import com.alibaba.fastjson.JSON;
import org.springframework.beans.factory.ObjectFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.cloud.openfeign.support.ResponseEntityDecoder;
import org.springframework.cloud.openfeign.support.SpringDecoder;
import org.springframework.http.HttpStatus;
import java.io.IOException;
import java.lang.reflect.Type;
import cn.org.easysite.framework.exception.BaseException;
import feign.FeignException;
import feign.Response;
import feign.Util;
import feign.codec.Decoder;
/**
* Created by panda @version 1.0
*/
public class FeignResponseInterceptor extends Decoder.Default implements Decoder {
@Autowired
private ObjectFactory<HttpMessageConverters> messageConverters;
@Override
public Object decode(Response response, Type type) throws IOException, FeignException {
if (response.status() == HttpStatus.NOT_FOUND.value()) {
return Util.emptyValueOf(type);
}
if (response.body() == null) {
return null;
}
if (byte[].class.equals(type)) {
return Util.toByteArray(response.body().asInputStream());
}
String json = Util.toString(response.body().asReader());
cn.org.easysite.spring.boot.model.Response res = JSON.parseObject(json, cn.org.easysite.spring.boot.model.Response.class);
if (!res.isSuccess()) {
throw new BaseException(1015, res.getMsg());
}
return new ResponseEntityDecoder(new SpringDecoder(this.messageConverters)).decode(response, type);
}
}
//package cn.org.easysite.spring.cloud.feign.interceptor;
//
//import com.alibaba.fastjson.JSON;
//
//import org.springframework.beans.factory.ObjectFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
//import org.springframework.cloud.openfeign.support.ResponseEntityDecoder;
//import org.springframework.cloud.openfeign.support.SpringDecoder;
//import org.springframework.http.HttpStatus;
//
//import java.io.IOException;
//import java.lang.reflect.Type;
//
//import cn.org.easysite.framework.exception.BaseException;
//import feign.FeignException;
//import feign.Response;
//import feign.Util;
//import feign.codec.Decoder;
//
//
///**
// * Created by panda @version 1.0
// */
//public class FeignResponseInterceptor extends Decoder.Default implements Decoder {
//
// @Autowired
// private ObjectFactory<HttpMessageConverters> messageConverters;
//
// @Override
// public Object decode(Response response, Type type) throws IOException, FeignException {
// if (response.status() == HttpStatus.NOT_FOUND.value()) {
// return Util.emptyValueOf(type);
// }
// if (response.body() == null) {
// return null;
// }
// if (byte[].class.equals(type)) {
// return Util.toByteArray(response.body().asInputStream());
// }
// String json = Util.toString(response.body().asReader());
// cn.org.easysite.spring.boot.model.Response res = JSON.parseObject(json, cn.org.easysite.spring.boot.model.Response.class);
// if (!res.isSuccess()) {
// throw new BaseException(1015, res.getMsg());
// }
// return new ResponseEntityDecoder(new SpringDecoder(this.messageConverters)).decode(response, type);
// }
//}