Commit b1f3f9e2 by huangfusuper

网关结果集封装

parent 879d465a
...@@ -163,10 +163,12 @@ public class ScriptExecutorServiceImpl implements ScriptExecutorService { ...@@ -163,10 +163,12 @@ public class ScriptExecutorServiceImpl implements ScriptExecutorService {
jobRunResultDto.setReturnResult(ReturnResult.FAIL); jobRunResultDto.setReturnResult(ReturnResult.FAIL);
} }
} catch (Exception e){ } catch (Exception e){
log.error("调度执行机出现异常:{}",e.getMessage());
ReturnResult<String> returnResult = new ReturnResult<>(); ReturnResult<String> returnResult = new ReturnResult<>();
returnResult.setCode(ReturnResult.FAIL.getCode()); returnResult.setCode(ReturnResult.FAIL.getCode());
returnResult.setMsg(e.getMessage()); returnResult.setMsg(e.getMessage());
jobRunResultDto.setReturnResult(returnResult); jobRunResultDto.setReturnResult(returnResult);
} }
//设置结束时间 //设置结束时间
jobRunResultDto.setEndTime(new Date()); jobRunResultDto.setEndTime(new Date());
......
package com.byit.gateway.filters;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* @author huangfu
*/
public class ResponseGlobalFilter extends ZuulFilter {
@Override
public String filterType() {
return FilterConstants.POST_TYPE;
}
@Override
public int filterOrder() {
return 900;
}
@Override
public boolean shouldFilter() {
return true;
}
@Override
public Object run() {
RequestContext ctx = RequestContext.getCurrentContext();
String responseBody = ctx.getResponseBody();
System.out.println(responseBody);
return null;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment