Commit 18dbe672 authored by 黎博's avatar 黎博

新增日志及易宝接口去掉/mock

parent 2a639020
...@@ -25,7 +25,7 @@ public class InterceptorConfig implements WebMvcConfigurer { ...@@ -25,7 +25,7 @@ public class InterceptorConfig implements WebMvcConfigurer {
@Override @Override
public void addInterceptors(InterceptorRegistry registry) { public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(yeebaoInterceptor()).addPathPatterns("/mock/tzt-api/**", "/mock/balance-board/**"); registry.addInterceptor(yeebaoInterceptor()).addPathPatterns("/tzt-api/**", "/balance-board/**");
registry.addInterceptor(ruleEngineInterceptor()).addPathPatterns("/rule_engine/**"); registry.addInterceptor(ruleEngineInterceptor()).addPathPatterns("/rule_engine/**");
} }
} }
...@@ -56,12 +56,15 @@ public class RuleEngineInterceptor implements HandlerInterceptor { ...@@ -56,12 +56,15 @@ public class RuleEngineInterceptor implements HandlerInterceptor {
if (mock.getFlag() == 1) { if (mock.getFlag() == 1) {
mockData = mock.getSuccess(); mockData = mock.getSuccess();
} }
log.info("收到风控接口 {} 请求,请求参数:{}", uri, requestMap);
if (uri.equals("/rule_engine/middle_office/audit")) { if (uri.equals("/rule_engine/middle_office/audit")) {
Map<String, Object> auditMap = JSON.parseObject(mockData, Map.class); Map<String, Object> auditMap = JSON.parseObject(mockData, Map.class);
Map<String, Object> responseMap = handleRiskAudit(requestMap, auditMap); Map<String, Object> responseMap = handleRiskAudit(requestMap, auditMap);
log.info("/rule_engine/middle_office/audit的mock响应为:{}", responseMap);
InterceptorUtils.constructResponse(response, JSON.toJSONString(responseMap), "application/json; charset=utf-8"); InterceptorUtils.constructResponse(response, JSON.toJSONString(responseMap), "application/json; charset=utf-8");
return false; return false;
} }
log.info("{}的mock响应为:{}", uri, mockData);
InterceptorUtils.constructResponse(response, mockData, "application/json; charset=utf-8"); InterceptorUtils.constructResponse(response, mockData, "application/json; charset=utf-8");
return false; return false;
} }
...@@ -156,13 +159,12 @@ public class RuleEngineInterceptor implements HandlerInterceptor { ...@@ -156,13 +159,12 @@ public class RuleEngineInterceptor implements HandlerInterceptor {
@Override @Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
@Nullable ModelAndView modelAndView) throws Exception { @Nullable ModelAndView modelAndView) {
log.info("本次请求返回响应:{}", response);
} }
@Override @Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler,
@Nullable Exception ex) throws Exception { @Nullable Exception ex) {
} }
/** /**
......
...@@ -39,7 +39,7 @@ public class YeebaoInterceptor implements HandlerInterceptor { ...@@ -39,7 +39,7 @@ public class YeebaoInterceptor implements HandlerInterceptor {
@Override @Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
throws Exception { throws Exception {
String uri = request.getRequestURI().substring(5); String uri = request.getRequestURI();
Map<String, String[]> parameterMap = request.getParameterMap(); Map<String, String[]> parameterMap = request.getParameterMap();
QueryWrapper<Mock> queryWrapper = new QueryWrapper<>(); QueryWrapper<Mock> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("url", uri); queryWrapper.eq("url", uri);
...@@ -63,6 +63,7 @@ public class YeebaoInterceptor implements HandlerInterceptor { ...@@ -63,6 +63,7 @@ public class YeebaoInterceptor implements HandlerInterceptor {
if (mock.getEncrypt() == 1) { if (mock.getEncrypt() == 1) {
EncryptConvertor encryptConvertor = EncryptFactory.produce("yeebao"); EncryptConvertor encryptConvertor = EncryptFactory.produce("yeebao");
requestMap = JSON.parseObject(encryptConvertor.decrypt(JSON.toJSONString(convertParameterMap(parameterMap))), Map.class); requestMap = JSON.parseObject(encryptConvertor.decrypt(JSON.toJSONString(convertParameterMap(parameterMap))), Map.class);
log.info("收到{}接口请求,解密后的请求参数为:{}", request.getRequestURI(), requestMap);
// 判断返回是字符串还是json,1-json,2-字符串 // 判断返回是字符串还是json,1-json,2-字符串
if (mock.getType() == 1) { if (mock.getType() == 1) {
responseMap = disposeResponseMap(requestMap, responseMap); responseMap = disposeResponseMap(requestMap, responseMap);
...@@ -76,37 +77,42 @@ public class YeebaoInterceptor implements HandlerInterceptor { ...@@ -76,37 +77,42 @@ public class YeebaoInterceptor implements HandlerInterceptor {
if (uri.equals("/tzt-api/api/bindcard/confirm") && mock.getFlag() == 1) { if (uri.equals("/tzt-api/api/bindcard/confirm") && mock.getFlag() == 1) {
responseMap = handleBindCardConfirm(requestMap, responseMap); responseMap = handleBindCardConfirm(requestMap, responseMap);
} }
log.info("{}接口返回的响应为:{}", request.getRequestURI(), responseMap);
constructResponse(response, encryptConvertor.encrypt(JSON.toJSONString(responseMap)), "application/json; charset=utf-8"); constructResponse(response, encryptConvertor.encrypt(JSON.toJSONString(responseMap)), "application/json; charset=utf-8");
} else if (mock.getType() == 2) { } else if (mock.getType() == 2) {
log.info("{}接口返回的响应为:{}", request.getRequestURI(), responseStr);
constructResponse(response, encryptConvertor.encrypt(responseStr)); constructResponse(response, encryptConvertor.encrypt(responseStr));
} }
} else if (mock.getEncrypt() == 0) { } else if (mock.getEncrypt() == 0) {
requestMap = convertParameterMap(parameterMap); requestMap = convertParameterMap(parameterMap);
log.info("收到{}接口请求,请求参数为:{}", request.getRequestURI(), requestMap);
if (mock.getType() == 1) { if (mock.getType() == 1) {
responseMap = disposeResponseMap(requestMap, responseMap); responseMap = disposeResponseMap(requestMap, responseMap);
log.info("{}接口返回的响应为:{}", request.getRequestURI(), responseMap);
constructResponse(response, JSON.toJSONString(responseMap), "application/json; charset=utf-8"); constructResponse(response, JSON.toJSONString(responseMap), "application/json; charset=utf-8");
} else if (mock.getType() == 2) { } else if (mock.getType() == 2) {
// 针对 /balance-board/transfer 接口特殊处理 // 针对 /balance-board/transfer 接口特殊处理
if (uri.equals("/balance-board/transfer")) { if (uri.equals("/balance-board/transfer")) {
responseStr = handleBalanceBoardTransfer(request); responseStr = handleBalanceBoardTransfer(request);
log.info("{}接口返回的响应为:{}", request.getRequestURI(), responseStr);
constructResponse(response, responseStr); constructResponse(response, responseStr);
return false; return false;
} }
log.info("{}接口返回的响应为:{}", request.getRequestURI(), responseStr);
constructResponse(response, responseStr); constructResponse(response, responseStr);
} }
} }
return true; return false;
} }
@Override @Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
@Nullable ModelAndView modelAndView) throws Exception { @Nullable ModelAndView modelAndView) {
log.info("本次请求返回响应:{}", response);
} }
@Override @Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler,
@Nullable Exception ex) throws Exception { @Nullable Exception ex) {
} }
/** /**
......
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