简单校验 不通过抛出异常

pom.xml

@@ -16,6 +16,7 @@
         <module>spring5-gateway</module>
         <module>spring5-admin</module>
         <module>spring5-order</module>
+        <module>spring5-common</module>
     </modules>
 
 	<properties>
@@ -84,12 +85,12 @@
         </dependency>
        
        <!--热加载-->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-devtools</artifactId>
-            <scope>runtime</scope>
-            <optional>true</optional>
-        </dependency>
+<!--         <dependency> -->
+<!--             <groupId>org.springframework.boot</groupId> -->
+<!--             <artifactId>spring-boot-devtools</artifactId> -->
+<!--             <scope>runtime</scope> -->
+<!--             <optional>true</optional> -->
+<!--         </dependency> -->
 
 			
 		<!-- Spring test 依赖 -->

spring5-auth/spring5-auth-client/pom.xml

@@ -44,5 +44,12 @@
             <groupId>io.github.openfeign</groupId>
             <artifactId>feign-okhttp</artifactId>
         </dependency>
+        
+        <!-- 二方包 -->
+        <dependency>
+            <groupId>com.yaozhitech</groupId>
+            <artifactId>spring5-common</artifactId>
+            <version>0.1.0</version>
+        </dependency>
 	</dependencies>
 </project>

spring5-auth/spring5-auth-client/src/main/java/com/yaozhitech/spring5/config/FeignOkHttpConfig.java

@@ -12,7 +12,6 @@ import org.springframework.context.annotation.Configuration;
 import com.yaozhitech.spring5.intercept.OkHttpTokenInterceptor;
 
 import feign.Feign;
-import okhttp3.ConnectionPool;
 
 @AutoConfigureBefore(FeignAutoConfiguration.class)
 @Configuration
@@ -25,16 +24,16 @@ public class FeignOkHttpConfig {
 	private int feignOkHttpReadTimeout = 60;
 	private int feignConnectTimeout = 60;
 	private int feignWriteTimeout = 120;
-
-//	@Bean
-//	public okhttp3.OkHttpClient okHttpClient() {
-//		return new okhttp3.OkHttpClient.Builder()
-//				.readTimeout(feignOkHttpReadTimeout, TimeUnit.SECONDS)
-//				.connectTimeout(feignConnectTimeout, TimeUnit.SECONDS)
-//				.writeTimeout(feignWriteTimeout, TimeUnit.SECONDS)
+	
+	@Bean
+	public okhttp3.OkHttpClient okHttpClient() {
+		return new okhttp3.OkHttpClient.Builder()
+				.readTimeout(feignOkHttpReadTimeout, TimeUnit.SECONDS)
+				.connectTimeout(feignConnectTimeout, TimeUnit.SECONDS)
+				.writeTimeout(feignWriteTimeout, TimeUnit.SECONDS)
 //				.connectionPool(new ConnectionPool())
-////				.addInterceptor(okHttpLoggingInterceptor)
+//				.addInterceptor(okHttpLoggingInterceptor)
 //				.addInterceptor(interceptor)
-//				.build();
-//	}
+				.build();
+	}
 }

spring5-auth/spring5-auth-client/src/main/java/com/yaozhitech/spring5/intercept/OkHttpTokenInterceptor.java

@@ -1,5 +1,6 @@
 package com.yaozhitech.spring5.intercept;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Configuration;
 
 import feign.RequestInterceptor;
@@ -8,9 +9,12 @@ import feign.RequestTemplate;
 @Configuration
 public class OkHttpTokenInterceptor implements RequestInterceptor{
 
+	@Value("${spring.application.name}")
+    private String applicationName;
+
 	@Override
 	public void apply(RequestTemplate template) {
-		template.header("X-Forwarded-For", "origin.host.com");
+		template.header("x-auth-client", applicationName);
 	}
 
 }

spring5-auth/spring5-auth-client/src/main/java/com/yaozhitech/spring5/intercept/ServiceAuthRestInterceptor.java

@@ -1,5 +1,6 @@
 package com.yaozhitech.spring5.intercept;
 
+import java.util.Arrays;
 import java.util.List;
 
 import javax.servlet.http.HttpServletRequest;
@@ -7,10 +8,12 @@ import javax.servlet.http.HttpServletResponse;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.method.HandlerMethod;
 import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
 
+import com.alibaba.nacos.client.utils.IPUtil;
+import com.yaozhitech.spring5.common.exception.auth.ClientForbiddenException;
+import com.yaozhitech.spring5.common.util.ClientUtil;
 import com.yaozhitech.spring5.config.ServiceAuthConfig;
 
 /**
@@ -27,11 +30,16 @@ public class ServiceAuthRestInterceptor extends HandlerInterceptorAdapter {
 //  @Autowired
   private ServiceAuthConfig serviceAuthConfig;
 
-  private List<String> allowedClient;
+  private List<String> allowedClient = Arrays.asList("admin", "order", "gateway");
 
   @Override
   public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
-      HandlerMethod handlerMethod = (HandlerMethod) handler;
+		HandlerMethod handlerMethod = (HandlerMethod) handler;
+		// ip
+//		if (ClientUtil.isLocalhost(request)) {
+//			return super.preHandle(request, response, handler);
+//		}
+		
 //      // 配置该注解，说明不进行服务拦截
 //      IgnoreClientToken annotation = handlerMethod.getBeanType().getAnnotation(IgnoreClientToken.class);
 //      if (annotation == null) {
@@ -41,18 +49,16 @@ public class ServiceAuthRestInterceptor extends HandlerInterceptorAdapter {
 //          return super.preHandle(request, response, handler);
 //      }
 
-      String token = request.getHeader("X-Forwarded-For");
+      String token = request.getHeader("x-auth-client");
       logger.info(token);
       
 //      IJWTInfo infoFromToken = serviceAuthUtil.getInfoFromToken(token);
-//      String uniqueName = infoFromToken.getUniqueName();
-//      for(String client:serviceAuthUtil.getAllowedClient()){
-//          if(client.equals(uniqueName)){
-//              return super.preHandle(request, response, handler);
-//          }
-//      }
-//      throw new ClientForbiddenException("Client is Forbidden!");
-      
-      return super.preHandle(request, response, handler);
+      String uniqueName = token;
+      for(String client:allowedClient){
+          if(client.equals(uniqueName)){
+              return super.preHandle(request, response, handler);
+          }
+      }
+      throw new ClientForbiddenException("Client is Forbidden!");
   }
 }

spring5-auth/spring5-auth-client/src/main/java/com/yaozhitech/spring5/utils/JwtUtils.java

@@ -14,7 +14,7 @@ import com.auth0.jwt.interfaces.DecodedJWT;
 public class JwtUtils {
 
 	/**
-          * 获得token中的信息无需secret解密也能获得
+     * 获得token中的信息无需secret解密也能获得
      * @return token中包含的签发时间
      */
     public static Date getIssuedAt(String token) {

spring5-common/.gitignore

@@ -0,0 +1 @@
+/target/

spring5-common/pom.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	
+	<artifactId>spring5-common</artifactId>
+	<packaging>jar</packaging>
+	<name>${project.artifactId}</name>
+    <description>spring5 demo</description>
+	
+	<parent>
+        <groupId>com.yaozhitech</groupId>
+        <artifactId>spring5</artifactId>
+        <version>0.1.0</version>
+    </parent>
+    
+	<dependencies>
+
+		
+	</dependencies>
+</project>

spring5-common/src/main/java/com/yaozhitech/spring5/common/constant/CommonConstants.java

@@ -0,0 +1,22 @@
+package com.yaozhitech.spring5.common.constant;
+
+/**
+ * Created by ace on 2017/8/29.
+ */
+public class CommonConstants {
+    public final static String RESOURCE_TYPE_MENU = "menu";
+    public final static String RESOURCE_TYPE_BTN = "button";
+    // 用户token异常
+    public static final Integer EX_USER_INVALID_CODE = 40101;
+    public static final Integer EX_USER_PASS_INVALID_CODE = 40001;
+    // 客户端token异常
+    public static final Integer EX_CLIENT_INVALID_CODE = 40301;
+    public static final Integer EX_CLIENT_FORBIDDEN_CODE = 40331;
+    public static final Integer EX_OTHER_CODE = 500;
+    public static final String CONTEXT_KEY_USER_ID = "currentUserId";
+    public static final String CONTEXT_KEY_USERNAME = "currentUserName";
+    public static final String CONTEXT_KEY_USER_NAME = "currentUser";
+    public static final String CONTEXT_KEY_USER_TOKEN = "currentUserToken";
+    public static final String JWT_KEY_USER_ID = "userId";
+    public static final String JWT_KEY_NAME = "name";
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/constant/RestCodeConstants.java

@@ -0,0 +1,10 @@
+package com.yaozhitech.spring5.common.constant;
+
+/**
+ * Created by ace on 2017/8/23.
+ */
+public class RestCodeConstants {
+
+    public static final int TOKEN_ERROR_CODE = 40101;
+    public static final int TOKEN_FORBIDDEN_CODE = 40301;
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/constant/UserConstant.java

@@ -0,0 +1,11 @@
+package com.yaozhitech.spring5.common.constant;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-14 8:36
+ */
+public class UserConstant {
+    public static int PW_ENCORDER_SALT = 12;
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/BaseException.java

@@ -0,0 +1,40 @@
+package com.yaozhitech.spring5.common.exception;
+
+/**
+ * Created by ace on 2017/9/8.
+ */
+public class BaseException extends RuntimeException {
+    private int status = 200;
+
+    public int getStatus() {
+        return status;
+    }
+
+    public void setStatus(int status) {
+        this.status = status;
+    }
+
+    public BaseException() {
+    }
+
+    public BaseException(String message,int status) {
+        super(message);
+        this.status = status;
+    }
+
+    public BaseException(String message) {
+        super(message);
+    }
+
+    public BaseException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public BaseException(Throwable cause) {
+        super(cause);
+    }
+
+    public BaseException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+        super(message, cause, enableSuppression, writableStackTrace);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/auth/ClientForbiddenException.java

@@ -0,0 +1,15 @@
+package com.yaozhitech.spring5.common.exception.auth;
+
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+
+/**
+ * Created by ace on 2017/9/12.
+ */
+public class ClientForbiddenException extends BaseException {
+    public ClientForbiddenException(String message) {
+        super(message, CommonConstants.EX_CLIENT_FORBIDDEN_CODE);
+    }
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/auth/ClientInvalidException.java

@@ -0,0 +1,14 @@
+package com.yaozhitech.spring5.common.exception.auth;
+
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+
+/**
+ * Created by ace on 2017/9/10.
+ */
+public class ClientInvalidException extends BaseException {
+    public ClientInvalidException(String message) {
+        super(message, CommonConstants.EX_CLIENT_INVALID_CODE);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/auth/ClientTokenException.java

@@ -0,0 +1,14 @@
+package com.yaozhitech.spring5.common.exception.auth;
+
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+
+/**
+ * Created by ace on 2017/9/10.
+ */
+public class ClientTokenException extends BaseException {
+    public ClientTokenException(String message) {
+        super(message, CommonConstants.EX_CLIENT_INVALID_CODE);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/auth/UserInvalidException.java

@@ -0,0 +1,14 @@
+package com.yaozhitech.spring5.common.exception.auth;
+
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+
+/**
+ * Created by ace on 2017/9/8.
+ */
+public class UserInvalidException extends BaseException {
+    public UserInvalidException(String message) {
+        super(message, CommonConstants.EX_USER_PASS_INVALID_CODE);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/exception/auth/UserTokenException.java

@@ -0,0 +1,14 @@
+package com.yaozhitech.spring5.common.exception.auth;
+
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+
+/**
+ * Created by ace on 2017/9/8.
+ */
+public class UserTokenException extends BaseException {
+    public UserTokenException(String message) {
+        super(message, CommonConstants.EX_USER_INVALID_CODE);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/handler/GlobalExceptionHandler.java

@@ -0,0 +1,61 @@
+package com.yaozhitech.spring5.common.handler;
+
+import javax.servlet.http.HttpServletResponse;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import com.yaozhitech.spring5.common.constant.CommonConstants;
+import com.yaozhitech.spring5.common.exception.BaseException;
+import com.yaozhitech.spring5.common.exception.auth.ClientTokenException;
+import com.yaozhitech.spring5.common.exception.auth.UserInvalidException;
+import com.yaozhitech.spring5.common.exception.auth.UserTokenException;
+import com.yaozhitech.spring5.common.msg.BaseResponse;
+
+/**
+ * Created by ace on 2017/9/8.
+ */
+@ControllerAdvice("com.yaozhitech")
+@ResponseBody
+public class GlobalExceptionHandler {
+    private Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class);
+
+    @ExceptionHandler(ClientTokenException.class)
+    public BaseResponse clientTokenExceptionHandler(HttpServletResponse response, ClientTokenException ex) {
+        response.setStatus(403);
+        logger.error(ex.getMessage(),ex);
+        return new BaseResponse(ex.getStatus(), ex.getMessage());
+    }
+
+    @ExceptionHandler(UserTokenException.class)
+    public BaseResponse userTokenExceptionHandler(HttpServletResponse response, UserTokenException ex) {
+        response.setStatus(200);
+        logger.error(ex.getMessage(),ex);
+        return new BaseResponse(ex.getStatus(), ex.getMessage());
+    }
+
+    @ExceptionHandler(UserInvalidException.class)
+    public BaseResponse userInvalidExceptionHandler(HttpServletResponse response, UserInvalidException ex) {
+        response.setStatus(200);
+        logger.error(ex.getMessage(),ex);
+        return new BaseResponse(ex.getStatus(), ex.getMessage());
+    }
+
+    @ExceptionHandler(BaseException.class)
+    public BaseResponse baseExceptionHandler(HttpServletResponse response, BaseException ex) {
+        logger.error(ex.getMessage(),ex);
+        response.setStatus(500);
+        return new BaseResponse(ex.getStatus(), ex.getMessage());
+    }
+
+    @ExceptionHandler(Exception.class)
+    public BaseResponse otherExceptionHandler(HttpServletResponse response, Exception ex) {
+        response.setStatus(500);
+        logger.error(ex.getMessage(),ex);
+        return new BaseResponse(CommonConstants.EX_OTHER_CODE, ex.getMessage());
+    }
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/BaseResponse.java

@@ -0,0 +1,35 @@
+package com.yaozhitech.spring5.common.msg;
+
+/**
+ * Created by ace on 2017/8/23.
+ */
+public class BaseResponse {
+    private int status = 200;
+    private String message;
+
+    public BaseResponse(int status, String message) {
+        this.status = status;
+        this.message = message;
+    }
+
+    public BaseResponse() {
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public int getStatus() {
+        return status;
+    }
+
+    public void setStatus(int status) {
+        this.status = status;
+    }
+
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/ListRestResponse.java

@@ -0,0 +1,60 @@
+package com.yaozhitech.spring5.common.msg;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-09 7:32
+ */
+public class ListRestResponse<T> {
+    String msg;
+    T result;
+    int count;
+
+
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public T getResult() {
+        return result;
+    }
+
+    public void setResult(T result) {
+        this.result = result;
+    }
+
+    public int getCount() {
+        return count;
+    }
+
+    public void setCount(int count) {
+        this.count = count;
+    }
+
+    public ListRestResponse count(int count) {
+        this.setCount(count);
+        return this;
+    }
+
+    public ListRestResponse count(Long count) {
+        this.setCount(count.intValue());
+        return this;
+    }
+
+    public ListRestResponse msg(String msg) {
+        this.setMsg(msg);
+        return this;
+    }
+
+    public ListRestResponse result(T result) {
+        this.setResult(result);
+        return this;
+    }
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/ObjectRestResponse.java

@@ -0,0 +1,39 @@
+package com.yaozhitech.spring5.common.msg;
+
+/**
+ * Created by Ace on 2017/6/11.
+ */
+public class ObjectRestResponse<T> extends BaseResponse {
+
+    T data;
+    boolean rel;
+
+    public boolean isRel() {
+        return rel;
+    }
+
+    public void setRel(boolean rel) {
+        this.rel = rel;
+    }
+
+
+    public ObjectRestResponse rel(boolean rel) {
+        this.setRel(rel);
+        return this;
+    }
+
+
+    public ObjectRestResponse data(T data) {
+        this.setData(data);
+        return this;
+    }
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/TableResultResponse.java

@@ -0,0 +1,69 @@
+package com.yaozhitech.spring5.common.msg;
+
+import java.util.List;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-14 22:40
+ */
+public class TableResultResponse<T> extends BaseResponse {
+
+    TableData<T> data;
+
+    public TableResultResponse(long total, List<T> rows) {
+        this.data = new TableData<T>(total, rows);
+    }
+
+    public TableResultResponse() {
+        this.data = new TableData<T>();
+    }
+
+    TableResultResponse<T> total(int total) {
+        this.data.setTotal(total);
+        return this;
+    }
+
+    TableResultResponse<T> total(List<T> rows) {
+        this.data.setRows(rows);
+        return this;
+    }
+
+    public TableData<T> getData() {
+        return data;
+    }
+
+    public void setData(TableData<T> data) {
+        this.data = data;
+    }
+
+    class TableData<T> {
+        long total;
+        List<T> rows;
+
+        public TableData(long total, List<T> rows) {
+            this.total = total;
+            this.rows = rows;
+        }
+
+        public TableData() {
+        }
+
+        public long getTotal() {
+            return total;
+        }
+
+        public void setTotal(long total) {
+            this.total = total;
+        }
+
+        public List<T> getRows() {
+            return rows;
+        }
+
+        public void setRows(List<T> rows) {
+            this.rows = rows;
+        }
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/auth/TokenErrorResponse.java

@@ -0,0 +1,13 @@
+package com.yaozhitech.spring5.common.msg.auth;
+
+import com.yaozhitech.spring5.common.constant.RestCodeConstants;
+import com.yaozhitech.spring5.common.msg.BaseResponse;
+
+/**
+ * Created by ace on 2017/8/23.
+ */
+public class TokenErrorResponse extends BaseResponse {
+    public TokenErrorResponse(String message) {
+        super(RestCodeConstants.TOKEN_ERROR_CODE, message);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/msg/auth/TokenForbiddenResponse.java

@@ -0,0 +1,13 @@
+package com.yaozhitech.spring5.common.msg.auth;
+
+import com.yaozhitech.spring5.common.constant.RestCodeConstants;
+import com.yaozhitech.spring5.common.msg.BaseResponse;
+
+/**
+ * Created by ace on 2017/8/25.
+ */
+public class TokenForbiddenResponse  extends BaseResponse {
+    public TokenForbiddenResponse(String message) {
+        super(RestCodeConstants.TOKEN_FORBIDDEN_CODE, message);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/util/ClientUtil.java

@@ -0,0 +1,29 @@
+package com.yaozhitech.spring5.common.util;
+
+import javax.servlet.http.HttpServletRequest;
+
+public class ClientUtil {
+	/**
+	 * 获取客户端真实ip
+	 * @param request
+	 * @return
+	 */
+	public static String getClientIp(HttpServletRequest request){
+		String ip = request.getHeader("x-forwarded-for");
+		if (ip==null||ip.length()==0||"unknown".equalsIgnoreCase(ip)) {
+			ip = request.getHeader("Proxy-Client-IP");
+		}
+		if (ip==null||ip.length()==0||"unknown".equalsIgnoreCase(ip)) {
+			ip = request.getHeader("WL-Proxy-Client-IP");
+		}
+		if (ip==null||ip.length()==0||"unknown".equalsIgnoreCase(ip)) {
+			ip = request.getRemoteAddr();
+		}
+		return ip;
+	}
+	
+	public static boolean isLocalhost(HttpServletRequest request) {
+		String ip = getClientIp(request);
+		return "127.0.0.1".equals(ip);
+	}
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/util/ReflectionUtils.java

@@ -0,0 +1,346 @@
+package com.yaozhitech.spring5.common.util;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.Validate;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.Assert;
+
+/**
+ * 反射工具类.
+ * 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数.
+ * @author calvin
+ * @version 2013-01-15
+ */
+@SuppressWarnings("rawtypes")
+public class ReflectionUtils {
+	
+	private static final String SETTER_PREFIX = "set";
+
+	private static final String GETTER_PREFIX = "get";
+
+	private static final String CGLIB_CLASS_SEPARATOR = "$$";
+	
+	private static Logger logger = LoggerFactory.getLogger(ReflectionUtils.class);
+
+	/**
+	 * 调用Getter方法.
+	 * 支持多级，如：对象名.对象名.方法
+	 */
+	public static Object invokeGetter(Object obj, String propertyName) {
+		Object object = obj;
+		for (String name : StringUtils.split(propertyName, ".")){
+			String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(name);
+			object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {});
+		}
+		return object;
+	}
+
+	/**
+	 * 调用Setter方法, 仅匹配方法名。
+	 * 支持多级，如：对象名.对象名.方法
+	 */
+	public static void invokeSetter(Object obj, String propertyName, Object value) {
+		Object object = obj;
+		String[] names = StringUtils.split(propertyName, ".");
+		for (int i=0; i<names.length; i++){
+			if(i<names.length-1){
+				String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(names[i]);
+				object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {});
+			}else{
+				String setterMethodName = SETTER_PREFIX + StringUtils.capitalize(names[i]);
+				invokeMethodByName(object, setterMethodName, new Object[] { value });
+			}
+		}
+	}
+
+	/**
+	 * 直接读取对象属性值, 无视private/protected修饰符, 不经过getter函数.
+	 */
+	public static Object getFieldValue(final Object obj, final String fieldName) {
+		Field field = getAccessibleField(obj, fieldName);
+
+		if (field == null) {
+			throw new IllegalArgumentException("Could not find field [" + fieldName + "] on target [" + obj + "]");
+		}
+
+		Object result = null;
+		try {
+			result = field.get(obj);
+		} catch (IllegalAccessException e) {
+			logger.error("不可能抛出的异常{}", e.getMessage());
+		}
+		return result;
+	}
+
+	/**
+	 * 直接设置对象属性值, 无视private/protected修饰符, 不经过setter函数.
+	 */
+	public static void setFieldValue(final Object obj, final String fieldName, final Object value) {
+		Field field = getAccessibleField(obj, fieldName);
+
+		if (field == null) {
+			logger.error("Could not find field [" + fieldName + "] on target [" + obj + "]");
+			return;
+			//throw new IllegalArgumentException("Could not find field [" + fieldName + "] on target [" + obj + "]");
+		}
+		try {
+			field.set(obj, convert(value, field.getType()));
+		} catch (IllegalAccessException e) {
+			logger.error("不可能抛出的异常:{}", e.getMessage());
+		}
+	}
+	
+	public static Object convert(Object object, Class<?> type) {
+	    if (object instanceof Number) {
+	        Number number = (Number) object;
+	        if (type.equals(byte.class) || type.equals(Byte.class)) {
+	            return number.byteValue();
+	        }
+	        if (type.equals(short.class) || type.equals(Short.class)) {
+	            return number.shortValue();
+	        }
+	        if (type.equals(int.class) || type.equals(Integer.class)) {
+	            return number.intValue();
+	        }
+	        if (type.equals(long.class) || type.equals(Long.class)) {
+	            return number.longValue();
+	        }
+	        if (type.equals(float.class) || type.equals(Float.class)) {
+	            return number.floatValue();
+	        }
+	        if (type.equals(double.class) || type.equals(Double.class)) {
+	            return number.doubleValue();
+	        }
+	    }
+	    if(type.equals(String.class)){
+	    	return object==null?"":object.toString();
+	    }
+	    return object;
+	}
+
+	/**
+	 * 直接调用对象方法, 无视private/protected修饰符.
+	 * 用于一次性调用的情况，否则应使用getAccessibleMethod()函数获得Method后反复调用.
+	 * 同时匹配方法名+参数类型，
+	 */
+	public static Object invokeMethod(final Object obj, final String methodName, final Class<?>[] parameterTypes,
+			final Object[] args) {
+		Method method = getAccessibleMethod(obj, methodName, parameterTypes);
+		if (method == null) {
+			throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]");
+		}
+
+		try {
+			return method.invoke(obj, args);
+		} catch (Exception e) {
+			throw convertReflectionExceptionToUnchecked(e);
+		}
+	}
+
+	/**
+	 * 直接调用对象方法, 无视private/protected修饰符，
+	 * 用于一次性调用的情况，否则应使用getAccessibleMethodByName()函数获得Method后反复调用.
+	 * 只匹配函数名，如果有多个同名函数调用第一个。
+	 */
+	public static Object invokeMethodByName(final Object obj, final String methodName, final Object[] args) {
+		Method method = getAccessibleMethodByName(obj, methodName);
+		if (method == null) {
+			throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]");
+		}
+
+		try {
+			return method.invoke(obj, args);
+		} catch (Exception e) {
+			throw convertReflectionExceptionToUnchecked(e);
+		}
+	}
+
+	/**
+	 * 循环向上转型, 获取对象的DeclaredField, 并强制设置为可访问.
+	 * 
+	 * 如向上转型到Object仍无法找到, 返回null.
+	 */
+	public static Field getAccessibleField(final Object obj, final String fieldName) {
+		Validate.notNull(obj, "object can't be null");
+		Validate.notBlank(fieldName, "fieldName can't be blank");
+		for (Class<?> superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) {
+			try {
+				Field field = superClass.getDeclaredField(fieldName);
+				makeAccessible(field);
+				return field;
+			} catch (NoSuchFieldException e) {//NOSONAR
+				// Field不在当前类定义,继续向上转型
+				continue;// new add
+			}
+		}
+		return null;
+	}
+
+	/**
+	 * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问.
+	 * 如向上转型到Object仍无法找到, 返回null.
+	 * 匹配函数名+参数类型。
+	 * 
+	 * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args)
+	 */
+	public static Method getAccessibleMethod(final Object obj, final String methodName,
+			final Class<?>... parameterTypes) {
+		Validate.notNull(obj, "object can't be null");
+		Validate.notBlank(methodName, "methodName can't be blank");
+
+		for (Class<?> searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
+			try {
+				Method method = searchType.getDeclaredMethod(methodName, parameterTypes);
+				makeAccessible(method);
+				return method;
+			} catch (NoSuchMethodException e) {
+				// Method不在当前类定义,继续向上转型
+				continue;// new add
+			}
+		}
+		return null;
+	}
+
+	/**
+	 * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问.
+	 * 如向上转型到Object仍无法找到, 返回null.
+	 * 只匹配函数名。
+	 * 
+	 * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args)
+	 */
+	public static Method getAccessibleMethodByName(final Object obj, final String methodName) {
+		Validate.notNull(obj, "object can't be null");
+		Validate.notBlank(methodName, "methodName can't be blank");
+
+		for (Class<?> searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
+			Method[] methods = searchType.getDeclaredMethods();
+			for (Method method : methods) {
+				if (method.getName().equals(methodName)) {
+					makeAccessible(method);
+					return method;
+				}
+			}
+		}
+		return null;
+	}
+
+	/**
+	 * 改变private/protected的方法为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。
+	 */
+	public static void makeAccessible(Method method) {
+		if ((!Modifier.isPublic(method.getModifiers()) || !Modifier.isPublic(method.getDeclaringClass().getModifiers()))
+				&& !method.isAccessible()) {
+			method.setAccessible(true);
+		}
+	}
+
+	/**
+	 * 改变private/protected的成员变量为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。
+	 */
+	public static void makeAccessible(Field field) {
+		if ((!Modifier.isPublic(field.getModifiers()) || !Modifier.isPublic(field.getDeclaringClass().getModifiers()) || Modifier
+				.isFinal(field.getModifiers())) && !field.isAccessible()) {
+			field.setAccessible(true);
+		}
+	}
+
+	/**
+	 * 通过反射, 获得Class定义中声明的泛型参数的类型, 注意泛型必须定义在父类处
+	 * 如无法找到, 返回Object.class.
+	 * eg.
+	 * public UserDao extends HibernateDao<User>
+	 *
+	 * @param clazz The class to introspect
+	 * @return the first generic declaration, or Object.class if cannot be determined
+	 */
+	@SuppressWarnings("unchecked")
+	public static <T> Class<T> getClassGenricType(final Class clazz) {
+		return getClassGenricType(clazz, 0);
+	}
+
+	/**
+	 * 通过反射, 获得Class定义中声明的父类的泛型参数的类型.
+	 * 如无法找到, 返回Object.class.
+	 * 
+	 * 如public UserDao extends HibernateDao<User,Long>
+	 *
+	 * @param clazz clazz The class to introspect
+	 * @param index the Index of the generic ddeclaration,start from 0.
+	 * @return the index generic declaration, or Object.class if cannot be determined
+	 */
+	public static Class getClassGenricType(final Class clazz, final int index) {
+
+		Type genType = clazz.getGenericSuperclass();
+
+		if (!(genType instanceof ParameterizedType)) {
+			logger.warn(clazz.getSimpleName() + "'s superclass not ParameterizedType");
+			return Object.class;
+		}
+
+		Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
+
+		if (index >= params.length || index < 0) {
+			logger.warn("Index: " + index + ", Size of " + clazz.getSimpleName() + "'s Parameterized Type: "
+					+ params.length);
+			return Object.class;
+		}
+		if (!(params[index] instanceof Class)) {
+			logger.warn(clazz.getSimpleName() + " not set the actual class on superclass generic parameter");
+			return Object.class;
+		}
+
+		return (Class) params[index];
+	}
+	
+	public static Class<?> getUserClass(Object instance) {
+		Assert.notNull(instance, "Instance must not be null");
+		Class clazz = instance.getClass();
+		if (clazz != null && clazz.getName().contains(CGLIB_CLASS_SEPARATOR)) {
+			Class<?> superClass = clazz.getSuperclass();
+			if (superClass != null && !Object.class.equals(superClass)) {
+				return superClass;
+			}
+		}
+		return clazz;
+
+	}
+	
+	/**
+	 * 将反射时的checked exception转换为unchecked exception.
+	 */
+	public static RuntimeException convertReflectionExceptionToUnchecked(Exception e) {
+		if (e instanceof IllegalAccessException || e instanceof IllegalArgumentException
+				|| e instanceof NoSuchMethodException) {
+			return new IllegalArgumentException(e);
+		} else if (e instanceof InvocationTargetException) {
+			return new RuntimeException(((InvocationTargetException) e).getTargetException());
+		} else if (e instanceof RuntimeException) {
+			return (RuntimeException) e;
+		}
+		return new RuntimeException("Unexpected Checked Exception.", e);
+	}
+	/**
+	 * 判断某个对象是否拥有某个属性
+	 * 
+	 * @param obj 对象
+	 * @param fieldName 属性名
+	 * @return 有属性返回true
+	 * 		        无属性返回false
+	 */
+	public static boolean hasField(final Object obj, final String fieldName){
+		Field field = getAccessibleField(obj, fieldName);
+		if (field == null) {
+			return false;
+		}
+		return true;
+
+	}
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/util/StringHelper.java

@@ -0,0 +1,10 @@
+package com.yaozhitech.spring5.common.util;
+
+/**
+ * Created by ace on 2017/9/10.
+ */
+public class StringHelper {
+    public static String getObjectValue(Object obj){
+        return obj==null?"":obj.toString();
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/util/TreeUtil.java

@@ -0,0 +1,74 @@
+package com.yaozhitech.spring5.common.util;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.yaozhitech.spring5.common.vo.TreeNode;
+
+/**
+ * Created by Ace on 2017/6/12.
+ */
+public class TreeUtil{
+  /**
+   * 两层循环实现建树
+   * 
+   * @param treeNodes 传入的树节点列表
+   * @return
+   */
+  public static <T extends TreeNode> List<T> bulid(List<T> treeNodes,Object root) {
+
+    List<T> trees = new ArrayList<T>();
+
+    for (T treeNode : treeNodes) {
+
+      if (root.equals(treeNode.getParentId())) {
+        trees.add(treeNode);
+      }
+
+      for (T it : treeNodes) {
+        if (it.getParentId() == treeNode.getId()) {
+          if (treeNode.getChildren() == null) {
+            treeNode.setChildren(new ArrayList<TreeNode>());
+          }
+          treeNode.add(it);
+        }
+      }
+    }
+    return trees;
+  }
+
+  /**
+   * 使用递归方法建树
+   * 
+   * @param treeNodes
+   * @return
+   */
+  public static <T extends TreeNode> List<T> buildByRecursive(List<T> treeNodes,Object root) {
+    List<T> trees = new ArrayList<T>();
+    for (T treeNode : treeNodes) {
+      if (root.equals(treeNode.getParentId())) {
+        trees.add(findChildren(treeNode, treeNodes));
+      }
+    }
+    return trees;
+  }
+
+  /**
+   * 递归查找子节点
+   * 
+   * @param treeNodes
+   * @return
+   */
+  public static <T extends TreeNode> T findChildren(T treeNode, List<T> treeNodes) {
+    for (T it : treeNodes) {
+      if (treeNode.getId() == it.getParentId()) {
+        if (treeNode.getChildren() == null) {
+          treeNode.setChildren(new ArrayList<TreeNode>());
+        }
+        treeNode.add(findChildren(it, treeNodes));
+      }
+    }
+    return treeNode;
+  }
+
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/util/UUIDUtils.java

@@ -0,0 +1,28 @@
+package com.yaozhitech.spring5.common.util;
+
+import java.util.UUID;
+
+/**
+ * Created by ace on 2017/9/27.
+ */
+public class UUIDUtils {
+    public static String[] chars = new String[] { "a", "b", "c", "d", "e", "f",
+            "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s",
+            "t", "u", "v", "w", "x", "y", "z", "0", "1", "2", "3", "4", "5",
+            "6", "7", "8", "9", "A", "B", "C", "D", "E", "F", "G", "H", "I",
+            "J", "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T", "U", "V",
+            "W", "X", "Y", "Z" };
+
+
+    public static String generateShortUuid() {
+        StringBuffer shortBuffer = new StringBuffer();
+        String uuid = UUID.randomUUID().toString().replace("-", "");
+        for (int i = 0; i < 8; i++) {
+            String str = uuid.substring(i * 4, i * 4 + 4);
+            int x = Integer.parseInt(str, 16);
+            shortBuffer.append(chars[x % 0x3E]);
+        }
+        return shortBuffer.toString();
+
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/vo/TreeNode.java

@@ -0,0 +1,42 @@
+package com.yaozhitech.spring5.common.vo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by Ace on 2017/6/12.
+ */
+public class TreeNode {
+    protected int id;
+    protected int parentId;
+
+    public List<TreeNode> getChildren() {
+        return children;
+    }
+
+    public void setChildren(List<TreeNode> children) {
+        this.children = children;
+    }
+
+    List<TreeNode> children = new ArrayList<TreeNode>();
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public int getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(int parentId) {
+        this.parentId = parentId;
+    }
+
+    public void add(TreeNode node){
+        children.add(node);
+    }
+}

spring5-common/src/main/java/com/yaozhitech/spring5/common/web/ParameterRequestWrapper.java

@@ -0,0 +1,69 @@
+package com.yaozhitech.spring5.common.web;
+
+
+import java.util.Enumeration;
+import java.util.Map;
+import java.util.Vector;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletRequestWrapper;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-07-01 17:04
+ */
+public class ParameterRequestWrapper extends HttpServletRequestWrapper {
+
+    private Map params;
+
+    public ParameterRequestWrapper(HttpServletRequest request, Map newParams) {
+        super(request);
+        this.params = newParams;
+    }
+
+    @Override
+    public Map getParameterMap() {
+        return params;
+    }
+
+    @Override
+    public Enumeration getParameterNames() {
+        Vector l = new Vector(params.keySet());
+        return l.elements();
+    }
+
+    @Override
+    public String[] getParameterValues(String name) {
+        Object v = params.get(name);
+        if (v == null) {
+            return null;
+        } else if (v instanceof String[]) {
+            return (String[]) v;
+        } else if (v instanceof String) {
+            return new String[] { (String) v };
+        } else {
+            return new String[] { v.toString() };
+        }
+    }
+
+    @Override
+    public String getParameter(String name) {
+        Object v = params.get(name);
+        if (v == null) {
+            return null;
+        } else if (v instanceof String[]) {
+            String[] strArr = (String[]) v;
+            if (strArr.length > 0) {
+                return strArr[0];
+            } else {
+                return null;
+            }
+        } else if (v instanceof String) {
+            return (String) v;
+        } else {
+            return v.toString();
+        }
+    }
+}