优化ResultAppender

This commit is contained in:
tanghc
2019-06-06 18:10:09 +08:00
parent 3be7610ae6
commit c244f84ba3
2 changed files with 6 additions and 3 deletions

View File

@@ -181,7 +181,7 @@ public abstract class BaseExecutorAdapter<T, R> implements ResultExecutor<T, R>
public String merge(T exchange, JSONObject jsonObjectService) { public String merge(T exchange, JSONObject jsonObjectService) {
JSONObject ret = new JSONObject(); JSONObject ret = new JSONObject();
String name = "error"; String name = "error";
Map<String, ?> params = this.getApiParam(exchange); Map<String, Object> params = this.getApiParam(exchange);
if (params != null) { if (params != null) {
Object method = params.get(ParamNames.API_NAME); Object method = params.get(ParamNames.API_NAME);
if (method != null) { if (method != null) {
@@ -196,7 +196,7 @@ public abstract class BaseExecutorAdapter<T, R> implements ResultExecutor<T, R>
this.appendReturnSign(apiConfig, params, ret); this.appendReturnSign(apiConfig, params, ret);
ResultAppender resultAppender = apiConfig.getResultAppender(); ResultAppender resultAppender = apiConfig.getResultAppender();
if (resultAppender != null) { if (resultAppender != null) {
resultAppender.append(ret, params); resultAppender.append(ret, params, exchange);
} }
return ret.toJSONString(); return ret.toJSONString();
} }

View File

@@ -6,13 +6,16 @@ import java.util.Map;
/** /**
* 对结果进行追加 * 对结果进行追加
*
* @author tanghc * @author tanghc
*/ */
public interface ResultAppender { public interface ResultAppender {
/** /**
* 追加最终结果 * 追加最终结果
*
* @param result 最终结果 * @param result 最终结果
* @param params 请求参数 * @param params 请求参数
* @param ctx 请求上下文zuul对应的是RequestContextGateway对应的是exchange
*/ */
void append(JSONObject result, Map<String, ?> params); void append(JSONObject result, Map<String, Object> params, Object ctx);
} }