Commit a3c601f4 authored by data爬虫-冯 军凯's avatar data爬虫-冯 军凯

删除不需要引入的jar包

parent a9068184
......@@ -224,13 +224,6 @@
<version>${retrofit.version}</version>
</dependency>
<!-- kafka -->
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>1.2.1.RELEASE</version>
</dependency>
<dependency>
<groupId>net.logstash.logback</groupId>
<artifactId>logstash-logback-encoder</artifactId>
......@@ -299,14 +292,6 @@
<artifactId>enoch-agent-spring-boot-starter</artifactId>
</dependency>
<!-- add by 2019.09.09 -->
<!--<dependency>
<groupId>jxl</groupId>
<artifactId>jxl</artifactId>
<version>2.6.12.1</version>
</dependency>-->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
......
package cn.quantgroup.report.config.web;
import cn.quantgroup.report.interceptor.AuthHandlerInterceptorAdapter;
import cn.quantgroup.report.interceptor.HBaseHandlerInterceptorAdapter;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
import java.util.Arrays;
@Configuration
public class WebMvcConfigure extends WebMvcConfigurerAdapter {
@Autowired
private Environment environment;
/**
* 添加拦截器
*/
@Override
public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(new HBaseHandlerInterceptorAdapter()).addPathPatterns("/**").excludePathPatterns("/");
registry.addInterceptor(new AuthHandlerInterceptorAdapter(Arrays.stream(environment.getActiveProfiles()).anyMatch(o -> StringUtils.equalsAnyIgnoreCase(o, "dev", "test", "pre"))))
.addPathPatterns("/**")
.excludePathPatterns("/");
// .excludePathPatterns("/ex/91zhengxin/call");
}
}
package cn.quantgroup.report.interceptor;
import cn.quantgroup.report.error.QGException;
import cn.quantgroup.report.error.QGExceptionType;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@Slf4j
public class AuthHandlerInterceptorAdapter extends HandlerInterceptorAdapter {
public static final String KEY = "key";
protected boolean ignore;
public AuthHandlerInterceptorAdapter(boolean ignore) {
super();
this.ignore = ignore;
}
public boolean preHandle(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2) throws Exception {
// log.info("ip:{},path:{}", arg0.getRemoteAddr(), arg0.getRequestURI());
// if (ignore || StringUtils.equalsIgnoreCase("b5140fb2-2c85-4b5a-abcf-3e97528014db", getKey(arg0)) || StringUtils.equals("/ex/91zhengxin/call", arg0.getRequestURI()) || StringUtils.equals("/ex/dianhuabang/callBack", arg0.getRequestURI())) {
// return true;
// }
// throw new QGException(QGExceptionType.COMMON_AUTH_ERROR);
return true;
}
private String getKey(HttpServletRequest arg0) {
String key = arg0.getParameter(KEY);
if (StringUtils.isNoneBlank(key)) {
return key;
}
key = arg0.getHeader(KEY);
if (StringUtils.isNoneBlank(key)) {
return key;
}
Cookie[] cookies = arg0.getCookies();
if (cookies != null && cookies.length > 0) {
for (Cookie cookie : cookies) {
if (StringUtils.equalsIgnoreCase(cookie.getName(), KEY)) {
return cookie.getValue();
}
}
}
return null;
}
/**
* 在controller执行之后的DispatcherServlet之后执行
*/
public void postHandle(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2, ModelAndView arg3)
throws Exception {
}
/**
* 在页面渲染完成返回给客户端之前执行
*/
public void afterCompletion(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2, Exception arg3)
throws Exception {
}
}
package cn.quantgroup.report.interceptor;
import cn.quantgroup.report.service.thirdpartymonitor.HBaseConfig;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class HBaseHandlerInterceptorAdapter extends HandlerInterceptorAdapter {
public static final String READ_FROM_HBASE_FIRST = "readFromHBaseFirst";
public boolean preHandle(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2) throws Exception {
String readFromHBaseFirst = arg0.getParameter(READ_FROM_HBASE_FIRST);
if (readFromHBaseFirst != null && StringUtils.equalsIgnoreCase("false", readFromHBaseFirst)) {
HBaseConfig.disableReadHBaseFirst();
}
return true;
}
/**
* 在controller执行之后的DispatcherServlet之后执行
*/
public void postHandle(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2, ModelAndView arg3)
throws Exception {
}
/**
* 在页面渲染完成返回给客户端之前执行
*/
public void afterCompletion(HttpServletRequest arg0, HttpServletResponse arg1, Object arg2, Exception arg3)
throws Exception {
HBaseConfig.enableReadHBaseFirst();
}
}
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