diff --git a/.gitignore b/.gitignore
index a1c2a23..e090081 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,23 +1,70 @@
-# Compiled class file
-*.class
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
-# Log file
-*.log
+**/*.iml
+**/.idea/**
-# BlueJ files
-*.ctxt
+# User-specific stuff
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/**/usage.statistics.xml
+.idea/**/dictionaries
+.idea/**/shelf
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
+# Generated files
+.idea
+.idea/**/contentModel.xml
-# Package Files #
-*.jar
-*.war
-*.nar
-*.ear
-*.zip
-*.tar.gz
-*.rar
+# Sensitive or high-churn files
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+.idea/**/dbnavigator.xml
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
+# Gradle
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# Gradle and Maven with auto-import
+# When using Gradle or Maven with auto-import, you should exclude module files,
+# since they will be recreated, and may cause churn. Uncomment if using
+# auto-import.
+# .idea/modules.xml
+# .idea/*.iml
+# .idea/modules
+
+# CMake
+cmake-build-*/
+
+# Mongo Explorer plugin
+.idea/**/mongoSettings.xml
+
+# File-based project format
+*.iws
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+# Editor-based Rest Client
+.idea/httpRequests
+
+target
+*.iml
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..f5621df
--- /dev/null
+++ b/README.md
@@ -0,0 +1,8 @@
+# FlyFish快速开发框架
+经过长期积累后实现的快速开发框架，可用于任何业务快速开发上线
+兼容各种场景和复杂的封装
+
+# 框架兼容性
+基于JDK1.8 +
+基于MongoDB（可动态切换Mysql）
+基于模块化CRUD
\ No newline at end of file
diff --git a/flyfish-common/pom.xml b/flyfish-common/pom.xml
new file mode 100644
index 0000000..ae28dd3
--- /dev/null
+++ b/flyfish-common/pom.xml
@@ -0,0 +1,64 @@
+
+
+
+ flyfish-framework
+ com.flyfish.framework
+ 0.0.1-SNAPSHOT
+
+ 4.0.0
+
+ flyfish-common
+
+
+
+
+
+ org.apache.commons
+ commons-lang3
+
+
+
+ org.apache.commons
+ commons-collections4
+
+
+
+ org.springframework.data
+ spring-data-commons
+
+
+
+
+ commons-io
+ commons-io
+
+
+
+ org.springframework
+ spring-context
+
+
+ com.fasterxml.jackson.core
+ jackson-annotations
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+
+
+ io.projectreactor
+ reactor-core
+
+
+ javax.validation
+ validation-api
+
+
+ org.slf4j
+ slf4j-api
+
+
+
+
\ No newline at end of file
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/BaseResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/BaseResponse.java
new file mode 100644
index 0000000..a3a803f
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/BaseResponse.java
@@ -0,0 +1,35 @@
+package com.flyfish.framework.bean;
+
+/**
+ * Created by wangyu 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;
+ }
+
+
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/ListRestResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/ListRestResponse.java
new file mode 100644
index 0000000..958b47b
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/ListRestResponse.java
@@ -0,0 +1,59 @@
+package com.flyfish.framework.bean;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-09 7:32
+ */
+public class ListRestResponse {
+ 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;
+ }
+
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/ObjectRestResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/ObjectRestResponse.java
new file mode 100644
index 0000000..7cb37f3
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/ObjectRestResponse.java
@@ -0,0 +1,40 @@
+package com.flyfish.framework.bean;
+
+/**
+ * Created by Wangyu on 2017/6/11.
+ */
+public class ObjectRestResponse 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;
+ }
+
+
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/PageBean.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/PageBean.java
new file mode 100644
index 0000000..5854713
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/PageBean.java
@@ -0,0 +1,60 @@
+package com.flyfish.framework.bean;
+
+import org.springframework.data.domain.Page;
+
+/**
+ * 分页实体的bean
+ *
+ * @param 泛型
+ */
+public class PageBean {
+
+ private Integer page;
+
+ private Long totalCount;
+
+ private Integer totalPages;
+
+ private Integer size;
+
+ public PageBean(Page page) {
+ // 页大小
+ this.size = page.getSize();
+ // 页码
+ this.page = page.getNumber() + 1;
+ this.totalCount = page.getTotalElements();
+ this.totalPages = page.getTotalPages();
+ }
+
+ public Integer getPage() {
+ return page;
+ }
+
+ public void setPage(Integer page) {
+ this.page = page;
+ }
+
+ public Long getTotalCount() {
+ return totalCount;
+ }
+
+ public void setTotalCount(Long totalCount) {
+ this.totalCount = totalCount;
+ }
+
+ public Integer getTotalPages() {
+ return totalPages;
+ }
+
+ public void setTotalPages(Integer totalPages) {
+ this.totalPages = totalPages;
+ }
+
+ public Integer getSize() {
+ return size;
+ }
+
+ public void setSize(Integer size) {
+ this.size = size;
+ }
+}
\ No newline at end of file
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/PageResult.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/PageResult.java
new file mode 100644
index 0000000..94fd00b
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/PageResult.java
@@ -0,0 +1,47 @@
+package com.flyfish.framework.bean;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+/**
+ * 用来描述分页数据的bean
+ *
+ * @author Mr.Wang
+ */
+public class PageResult extends Result> {
+
+ public static final Pageable DEFAULT_PAGE = PageRequest.of(0, 20);
+
+ private PageBean page;
+
+ private Integer count;
+
+ public PageResult(String errCode, String errMsg, Page data) {
+ super(errCode, errMsg, data.getContent());
+ this.page = new PageBean<>(data);
+ this.count = (int) data.getTotalElements();
+ }
+
+ public PageResult(String errCode, String errMsg) {
+ super(errCode, errMsg);
+ }
+
+ public PageBean getPage() {
+ return page;
+ }
+
+ public void setPage(PageBean page) {
+ this.page = page;
+ }
+
+ public Integer getCount() {
+ return count;
+ }
+
+ public void setCount(Integer count) {
+ this.count = count;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/Result.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/Result.java
new file mode 100644
index 0000000..6020615
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/Result.java
@@ -0,0 +1,170 @@
+package com.flyfish.framework.bean;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.Pageable;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+import java.util.function.Function;
+
+/**
+ * 请求结果
+ *
+ * @author Mr.Wang
+ */
+@SuppressWarnings("unchecked")
+public class Result {
+
+ public static final String SUCCESS = "0";
+
+ public static final String FAIL = "-1";
+
+ public static final String MSG_SUCCESS = "请求成功";
+
+ public static final String MSG_FAIL = "系统异常！";
+
+ public static final String MSG_NO_DATA = "未查询到任何数据！";
+
+ private T data;
+
+ private String code;
+
+ private String msg;
+
+ public Result(String code, String msg, T data) {
+ this.code = code;
+ this.msg = msg;
+ this.data = data;
+ }
+
+ public Result(String code, String msg) {
+ this.code = code;
+ this.msg = msg;
+ this.data = (T) Collections.emptyMap();
+ }
+
+ public static Result accept(T data) {
+ if (null == data) {
+ return new Result<>(FAIL, MSG_NO_DATA);
+ }
+ return new Result<>(SUCCESS, MSG_SUCCESS, data);
+ }
+
+ /**
+ * 单个元素，附带分页信息，分页数据写死
+ *
+ * @param data 数据
+ * @param 泛型
+ * @return 结果
+ */
+ public static Result> single(T data) {
+ Page page = new PageImpl<>(Collections.singletonList(data), PageResult.DEFAULT_PAGE, 1);
+ return accept(page);
+ }
+
+ public static Result> accept(List data, Pageable pageable, int total) {
+ Page page = new PageImpl<>(data, pageable, total);
+ return accept(page);
+ }
+
+ public static Result> accept(Page page) {
+ if (null == page) {
+ return new PageResult<>(FAIL, MSG_NO_DATA);
+ }
+ return new PageResult<>(SUCCESS, MSG_SUCCESS, page);
+ }
+
+ public static Result error() {
+ return new Result<>(FAIL, MSG_FAIL, null);
+ }
+
+ public static Result ok() {
+ return empty();
+ }
+
+ public static Result ok(T data) {
+ return new Result<>(SUCCESS, MSG_SUCCESS, data);
+ }
+
+ public static Result empty() {
+ return new Result<>(SUCCESS, MSG_SUCCESS, null);
+ }
+
+ public static Result> emptyList() {
+ return new Result<>(SUCCESS, MSG_SUCCESS, Collections.emptyList());
+ }
+
+ public static Result> emptyPage() {
+ return new PageResult<>(SUCCESS, MSG_SUCCESS, Page.empty());
+ }
+
+ public static Result notFound() {
+ return new Result<>(FAIL, MSG_NO_DATA, null);
+ }
+
+ public static Result error(String errMsg) {
+ return new Result<>(FAIL, errMsg, null);
+ }
+
+ public Result toVoid() {
+ return (Result) this;
+ }
+
+ public Optional optional() {
+ return isSuccess() ? Optional.ofNullable(data) : Optional.empty();
+ }
+
+ public Result map(Function function) {
+ if (this.data != null) {
+ this.data = (T) function.apply(this.data);
+ return (Result) this;
+ }
+ return (Result) this;
+ }
+
+ public Result orElse(Result other) {
+ if (null == this.data) {
+ return other;
+ }
+ return this;
+ }
+
+ public Result filter(Function function) {
+ if (!function.apply(this.data)) {
+ this.data = null;
+ }
+ return this;
+ }
+
+ @JsonIgnore
+ public boolean isSuccess() {
+ return SUCCESS.equals(this.code);
+ }
+
+ public T getData() {
+ return data;
+ }
+
+ public void setData(T data) {
+ this.data = data;
+ }
+
+ public String getCode() {
+ return code;
+ }
+
+ public void setCode(String code) {
+ this.code = code;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public void setMsg(String msg) {
+ this.msg = msg;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/TableResultResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/TableResultResponse.java
new file mode 100644
index 0000000..cb930f2
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/TableResultResponse.java
@@ -0,0 +1,69 @@
+package com.flyfish.framework.bean;
+
+import java.util.List;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-14 22:40
+ */
+public class TableResultResponse extends BaseResponse {
+
+ TableData data;
+
+ public TableResultResponse(long total, List rows) {
+ this.data = new TableData(total, rows);
+ }
+
+ public TableResultResponse() {
+ this.data = new TableData();
+ }
+
+ TableResultResponse total(int total) {
+ this.data.setTotal(total);
+ return this;
+ }
+
+ TableResultResponse total(List rows) {
+ this.data.setRows(rows);
+ return this;
+ }
+
+ public TableData getData() {
+ return data;
+ }
+
+ public void setData(TableData data) {
+ this.data = data;
+ }
+
+ class TableData {
+ long total;
+ List rows;
+
+ public TableData(long total, List rows) {
+ this.total = total;
+ this.rows = rows;
+ }
+
+ public TableData() {
+ }
+
+ public long getTotal() {
+ return total;
+ }
+
+ public void setTotal(long total) {
+ this.total = total;
+ }
+
+ public List getRows() {
+ return rows;
+ }
+
+ public void setRows(List rows) {
+ this.rows = rows;
+ }
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/TreeNode.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/TreeNode.java
new file mode 100644
index 0000000..a7ca24a
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/TreeNode.java
@@ -0,0 +1,41 @@
+package com.flyfish.framework.bean;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by Wangyu on 2017/6/12.
+ */
+public class TreeNode {
+ protected int id;
+ protected int parentId;
+ List children = new ArrayList();
+
+ public List getChildren() {
+ return children;
+ }
+
+ public void setChildren(List children) {
+ this.children = children;
+ }
+
+ 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);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenErrorResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenErrorResponse.java
new file mode 100644
index 0000000..a09f577
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenErrorResponse.java
@@ -0,0 +1,13 @@
+package com.flyfish.framework.bean.auth;
+
+import com.flyfish.framework.bean.BaseResponse;
+import com.flyfish.framework.constant.RestCodeConstants;
+
+/**
+ * Created by wangyu on 2017/8/23.
+ */
+public class TokenErrorResponse extends BaseResponse {
+ public TokenErrorResponse(String message) {
+ super(RestCodeConstants.TOKEN_ERROR_CODE, message);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenForbiddenResponse.java b/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenForbiddenResponse.java
new file mode 100644
index 0000000..a950239
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/bean/auth/TokenForbiddenResponse.java
@@ -0,0 +1,13 @@
+package com.flyfish.framework.bean.auth;
+
+import com.flyfish.framework.bean.BaseResponse;
+import com.flyfish.framework.constant.RestCodeConstants;
+
+/**
+ * Created by wangyu on 2017/8/25.
+ */
+public class TokenForbiddenResponse extends BaseResponse {
+ public TokenForbiddenResponse(String message) {
+ super(RestCodeConstants.TOKEN_FORBIDDEN_CODE, message);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/constant/CommonConstants.java b/flyfish-common/src/main/java/com/flyfish/framework/constant/CommonConstants.java
new file mode 100644
index 0000000..617d704
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/constant/CommonConstants.java
@@ -0,0 +1,22 @@
+package com.flyfish.framework.constant;
+
+/**
+ * Created by wangyu 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";
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/constant/ReactiveConstants.java b/flyfish-common/src/main/java/com/flyfish/framework/constant/ReactiveConstants.java
new file mode 100644
index 0000000..fefbc68
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/constant/ReactiveConstants.java
@@ -0,0 +1,11 @@
+package com.flyfish.framework.constant;
+
+/**
+ * 异步接口常量
+ *
+ * @author wangyu
+ */
+public interface ReactiveConstants {
+
+ String USE_REACTIVE = "Reactive=1";
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/constant/RestCodeConstants.java b/flyfish-common/src/main/java/com/flyfish/framework/constant/RestCodeConstants.java
new file mode 100644
index 0000000..0eefbcb
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/constant/RestCodeConstants.java
@@ -0,0 +1,10 @@
+package com.flyfish.framework.constant;
+
+/**
+ * Created by wangyu on 2017/8/23.
+ */
+public class RestCodeConstants {
+
+ public static final int TOKEN_ERROR_CODE = 40101;
+ public static final int TOKEN_FORBIDDEN_CODE = 40301;
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/constant/UserConstant.java b/flyfish-common/src/main/java/com/flyfish/framework/constant/UserConstant.java
new file mode 100644
index 0000000..2584898
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/constant/UserConstant.java
@@ -0,0 +1,11 @@
+package com.flyfish.framework.constant;
+
+/**
+ * ${DESCRIPTION}
+ *
+ * @author wanghaobin
+ * @create 2017-06-14 8:36
+ */
+public class UserConstant {
+ public static int PW_ENCORDER_SALT = 12;
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/context/DateContext.java b/flyfish-common/src/main/java/com/flyfish/framework/context/DateContext.java
new file mode 100644
index 0000000..aff4623
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/context/DateContext.java
@@ -0,0 +1,94 @@
+package com.flyfish.framework.context;
+
+import org.springframework.stereotype.Component;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 基于ThreadLocal的时间仓库，提高线程性能
+ *
+ * @author wybab
+ */
+@Component
+public class DateContext {
+
+ private static DateContext instance;
+ private ThreadLocal formatThreadLocal = new ThreadLocal<>();
+ private ThreadLocal> mapThreadLocal = new ThreadLocal<>();
+
+ public DateContext() {
+ instance = this;
+ }
+
+ public static DateContext getInstance() {
+ return instance;
+ }
+
+ public static DateFormat simpleFormat() {
+ DateFormat format = instance.formatThreadLocal.get();
+ if (format == null) {
+ format = new SimpleDateFormat("yyyy-MM-dd");
+ instance.formatThreadLocal.set(format);
+ }
+ return format;
+ }
+
+ /**
+ * 内置的解析，避免使用
+ *
+ * @param date 日期
+ * @return 结果
+ */
+ public static Date parse(Object date) {
+ if (date instanceof String) {
+ try {
+ return simpleFormat().parse((String) date);
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 内置解析
+ *
+ * @param date 日期
+ * @param pattern 格式
+ * @return 结果
+ */
+ public static Date parse(Object date, String pattern) {
+ if (date instanceof String) {
+ try {
+ return dateFormat(pattern).parse((String) date);
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ }
+ return null;
+ }
+
+ public static DateFormat dateFormat(String pattern) {
+ return instance.getDateFormat(pattern);
+ }
+
+ public static String formatDate(Date date, String pattern) {
+ return dateFormat(pattern).format(date);
+ }
+
+ public DateFormat getDateFormat(String pattern) {
+ Map formatMap = mapThreadLocal.get();
+ if (null == formatMap) {
+ formatMap = new HashMap<>();
+ mapThreadLocal.set(formatMap);
+ }
+ DateFormat format = formatMap.compute(pattern, (key, value) ->
+ value == null ? new SimpleDateFormat(key) : value);
+ return format;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/enums/CodeBasedEnum.java b/flyfish-common/src/main/java/com/flyfish/framework/enums/CodeBasedEnum.java
new file mode 100644
index 0000000..948f289
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/enums/CodeBasedEnum.java
@@ -0,0 +1,16 @@
+package com.flyfish.framework.enums;
+
+/**
+ * 基于标识码的枚举基类
+ *
+ * @author wangyu
+ */
+public interface CodeBasedEnum {
+
+ /**
+ * 获取枚举对象标识码
+ *
+ * @return 枚举标识
+ */
+ int getCode();
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/enums/RoleType.java b/flyfish-common/src/main/java/com/flyfish/framework/enums/RoleType.java
new file mode 100644
index 0000000..188b5e1
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/enums/RoleType.java
@@ -0,0 +1,13 @@
+package com.flyfish.framework.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum RoleType {
+
+ PC("PC端"), MOBILE("移动端");
+
+ private String name;
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/enums/UserStatus.java b/flyfish-common/src/main/java/com/flyfish/framework/enums/UserStatus.java
new file mode 100644
index 0000000..5b4e65c
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/enums/UserStatus.java
@@ -0,0 +1,19 @@
+package com.flyfish.framework.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 用户状态
+ *
+ * @author wangyu
+ * 根据用户状态标识用户
+ */
+@Getter
+@AllArgsConstructor
+public enum UserStatus {
+
+ NORMAL("正常状态"), LOCKED("已锁定"), DISABLED("已禁用"), EXPIRED("已过期");
+
+ private String name;
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/enums/UserType.java b/flyfish-common/src/main/java/com/flyfish/framework/enums/UserType.java
new file mode 100644
index 0000000..bb6d4ae
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/enums/UserType.java
@@ -0,0 +1,33 @@
+package com.flyfish.framework.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 用户类型枚举
+ *
+ * @author wangyu
+ */
+@AllArgsConstructor
+@Getter
+public enum UserType {
+
+ SUPER_ADMIN("超级管理员"), ADMIN("管理员"), VIP("会员"), USER("非会员");
+
+ private static final Map aliasMap;
+
+ static {
+ aliasMap = new HashMap<>();
+ aliasMap.put("vip", VIP);
+ aliasMap.put("user", USER);
+ }
+
+ private String name;
+
+ public static UserType getByAlias(String alias) {
+ return aliasMap.getOrDefault(alias, USER);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/BaseException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/BaseException.java
new file mode 100644
index 0000000..08436e0
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/BaseException.java
@@ -0,0 +1,41 @@
+package com.flyfish.framework.exception;
+
+/**
+ * Created by wangyu on 2017/9/8.
+ */
+public class BaseException extends RuntimeException {
+
+ private int status = 200;
+
+ 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);
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientForbiddenException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientForbiddenException.java
new file mode 100644
index 0000000..3e5623f
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientForbiddenException.java
@@ -0,0 +1,15 @@
+package com.flyfish.framework.exception.auth;
+
+
+import com.flyfish.framework.constant.CommonConstants;
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * Created by wangyu on 2017/9/12.
+ */
+public class ClientForbiddenException extends BaseException {
+ public ClientForbiddenException(String message) {
+ super(message, CommonConstants.EX_CLIENT_FORBIDDEN_CODE);
+ }
+
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientInvalidException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientInvalidException.java
new file mode 100644
index 0000000..79b7019
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientInvalidException.java
@@ -0,0 +1,14 @@
+package com.flyfish.framework.exception.auth;
+
+
+import com.flyfish.framework.constant.CommonConstants;
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * Created by wangyu on 2017/9/10.
+ */
+public class ClientInvalidException extends BaseException {
+ public ClientInvalidException(String message) {
+ super(message, CommonConstants.EX_CLIENT_INVALID_CODE);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientTokenException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientTokenException.java
new file mode 100644
index 0000000..778bb85
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/ClientTokenException.java
@@ -0,0 +1,14 @@
+package com.flyfish.framework.exception.auth;
+
+
+import com.flyfish.framework.constant.CommonConstants;
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * Created by wangyu on 2017/9/10.
+ */
+public class ClientTokenException extends BaseException {
+ public ClientTokenException(String message) {
+ super(message, CommonConstants.EX_CLIENT_INVALID_CODE);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserInvalidException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserInvalidException.java
new file mode 100644
index 0000000..2f542b1
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserInvalidException.java
@@ -0,0 +1,14 @@
+package com.flyfish.framework.exception.auth;
+
+
+import com.flyfish.framework.constant.CommonConstants;
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * Created by wangyu on 2017/9/8.
+ */
+public class UserInvalidException extends BaseException {
+ public UserInvalidException(String message) {
+ super(message, CommonConstants.EX_USER_PASS_INVALID_CODE);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserTokenException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserTokenException.java
new file mode 100644
index 0000000..1755f58
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/auth/UserTokenException.java
@@ -0,0 +1,14 @@
+package com.flyfish.framework.exception.auth;
+
+
+import com.flyfish.framework.constant.CommonConstants;
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * Created by wangyu on 2017/9/8.
+ */
+public class UserTokenException extends BaseException {
+ public UserTokenException(String message) {
+ super(message, CommonConstants.EX_USER_INVALID_CODE);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/DataLackException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/DataLackException.java
new file mode 100644
index 0000000..7d2f49c
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/DataLackException.java
@@ -0,0 +1,37 @@
+package com.flyfish.framework.exception.biz;
+
+import com.flyfish.framework.exception.BaseException;
+
+import java.util.function.Supplier;
+
+/**
+ * 数据缺失异常，会抛出404
+ *
+ * @author wangyu
+ */
+public class DataLackException extends BaseException {
+
+ private static final long serialVersionUID = -2048295927616443440L;
+
+ private int status = 404;
+
+ public DataLackException(String message) {
+ super(message);
+ }
+
+ public static DataLackException msg(String message) {
+ return new DataLackException(message);
+ }
+
+ public static Supplier supplier(String message) {
+ return () -> msg(message);
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/InvalidBusinessException.java b/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/InvalidBusinessException.java
new file mode 100644
index 0000000..af05606
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/exception/biz/InvalidBusinessException.java
@@ -0,0 +1,25 @@
+package com.flyfish.framework.exception.biz;
+
+import com.flyfish.framework.exception.BaseException;
+
+/**
+ * 业务限制异常
+ *
+ * @author wangyu
+ */
+public class InvalidBusinessException extends BaseException {
+
+ private int status = 400;
+
+ public InvalidBusinessException(String message) {
+ super(message);
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/utils/Assert.java b/flyfish-common/src/main/java/com/flyfish/framework/utils/Assert.java
new file mode 100644
index 0000000..1cf7fd3
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/utils/Assert.java
@@ -0,0 +1,430 @@
+package com.flyfish.framework.utils;
+
+import com.flyfish.framework.exception.biz.InvalidBusinessException;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+
+import java.util.Collection;
+import java.util.Map;
+import java.util.stream.Stream;
+
+import static org.apache.commons.lang3.StringUtils.join;
+
+/**
+ * 断言工具
+ *
+ * @author Mr.Wang
+ * 提供断言，快速抛出业务异常，降低代码重复
+ */
+public abstract class Assert {
+
+ /**
+ * Assert a boolean expression, throwing {@code QQWBusinessException}
+ * if the test result is {@code false}.
+ *
Assert.isTrue(i > 0, "The value must be greater than zero");
+ *
+ * @param expression a boolean expression
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if expression is {@code false}
+ */
+ public static void isTrue(boolean expression, String message) {
+ if (!expression) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert a boolean expression, throwing {@code QQWBusinessException}
+ * if the test result is {@code false}.
+ *
Assert.isTrue(i > 0);
+ *
+ * @param expression a boolean expression
+ * @throws InvalidBusinessException if expression is {@code false}
+ */
+ public static void isTrue(boolean expression) {
+ isTrue(expression, "[Assertion failed] - this expression must be true");
+ }
+
+ public static void isFalse(boolean expression) {
+ isTrue(!expression);
+ }
+
+ public static void isFalse(boolean expression, String message) {
+ isTrue(!expression, message);
+ }
+
+ /**
+ * Assert that an object is {@code null} .
+ *
Assert.isNull(value, "The value must be null");
+ *
+ * @param object the object to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the object is not {@code null}
+ */
+ public static void isNull(Object object, String message) {
+ if (object != null) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that an object is {@code null} .
+ *
Assert.isNull(value);
+ *
+ * @param object the object to check
+ * @throws InvalidBusinessException if the object is not {@code null}
+ */
+ public static void isNull(Object object) {
+ isNull(object, "[Assertion failed] - the object argument must be null");
+ }
+
+ /**
+ * Assert that an object is not {@code null} .
+ *
Assert.notNull(clazz, "The class must not be null");
+ *
+ * @param object the object to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the object is {@code null}
+ */
+ public static void notNull(Object object, String message) {
+ if (object == null) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that an object is not {@code null} .
+ *
Assert.notNull(clazz);
+ *
+ * @param object the object to check
+ * @throws InvalidBusinessException if the object is {@code null}
+ */
+ public static void notNull(Object object) {
+ notNull(object, "[Assertion failed] - this argument is required; it must not be null");
+ }
+
+ /**
+ * Assert that the given String is not empty; that is,
+ * it must not be {@code null} and not the empty String.
+ *
Assert.hasLength(name, "Name must not be empty");
+ *
+ * @param text the String to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the text is empty
+ * @see StringUtils#hasLength
+ */
+ public static void hasLength(String text, String message) {
+ if (!StringUtils.hasLength(text)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that the given String is not empty; that is,
+ * it must not be {@code null} and not the empty String.
+ *
Assert.hasLength(name);
+ *
+ * @param text the String to check
+ * @throws InvalidBusinessException if the text is empty
+ * @see StringUtils#hasLength
+ */
+ public static void hasLength(String text) {
+ hasLength(text,
+ "[Assertion failed] - this String argument must have length; it must not be null or empty");
+ }
+
+ /**
+ * Assert that the given String has valid text content; that is, it must not
+ * be {@code null} and must contain at least one non-whitespace character.
+ *
Assert.hasText(name, "'name' must not be empty");
+ *
+ * @param text the String to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the text does not contain valid text content
+ * @see StringUtils#hasText
+ */
+ public static void hasText(String text, String message) {
+ if (!StringUtils.hasText(text)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that the given String has valid text content; that is, it must not
+ * be {@code null} and must contain at least one non-whitespace character.
+ *
Assert.hasText(name, "'name' must not be empty");
+ *
+ * @param text the String to check
+ * @throws InvalidBusinessException if the text does not contain valid text content
+ * @see StringUtils#hasText
+ */
+ public static void hasText(String text) {
+ hasText(text,
+ "[Assertion failed] - this String argument must have text; it must not be null, empty, or blank");
+ }
+
+ /**
+ * Assert that the given text does not contain the given substring.
+ *
Assert.doesNotContain(name, "rod", "Name must not contain 'rod'");
+ *
+ * @param textToSearch the text to search
+ * @param substring the substring to find within the text
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the text contains the substring
+ */
+ public static void doesNotContain(String textToSearch, String substring, String message) {
+ if (StringUtils.hasLength(textToSearch) && StringUtils.hasLength(substring) &&
+ textToSearch.contains(substring)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that the given text does not contain the given substring.
+ *
Assert.doesNotContain(name, "rod");
+ *
+ * @param textToSearch the text to search
+ * @param substring the substring to find within the text
+ * @throws InvalidBusinessException if the text contains the substring
+ */
+ public static void doesNotContain(String textToSearch, String substring) {
+ doesNotContain(textToSearch, substring,
+ "[Assertion failed] - this String argument must not contain the substring [" + substring + "]");
+ }
+
+ /**
+ * Assert that an array has elements; that is, it must not be
+ * {@code null} and must have at least one element.
+ *
Assert.notEmpty(array, "The array must have elements");
+ *
+ * @param array the array to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the object array is {@code null} or has no elements
+ */
+ public static void notEmpty(Object[] array, String message) {
+ if (ObjectUtils.isEmpty(array)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that an array has elements; that is, it must not be
+ * {@code null} and must have at least one element.
+ *
Assert.notEmpty(array);
+ *
+ * @param array the array to check
+ * @throws InvalidBusinessException if the object array is {@code null} or has no elements
+ */
+ public static void notEmpty(Object[] array) {
+ notEmpty(array, "[Assertion failed] - this array must not be empty: it must contain at least 1 element");
+ }
+
+ /**
+ * Assert that an array has no null elements.
+ * Note: Does not complain if the array is empty!
+ *
Assert.noNullElements(array, "The array must have non-null elements");
+ *
+ * @param array the array to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the object array contains a {@code null} element
+ */
+ public static void noNullElements(Object[] array, String message) {
+ if (array != null) {
+ for (Object element : array) {
+ if (element == null) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+ }
+ }
+
+ /**
+ * Assert that an array has no null elements.
+ * Note: Does not complain if the array is empty!
+ *
Assert.noNullElements(array);
+ *
+ * @param array the array to check
+ * @throws InvalidBusinessException if the object array contains a {@code null} element
+ */
+ public static void noNullElements(Object[] array) {
+ noNullElements(array, "[Assertion failed] - this array must not contain any null elements");
+ }
+
+ /**
+ * Assert that a collection has elements; that is, it must not be
+ * {@code null} and must have at least one element.
+ *
Assert.notEmpty(collection, "Collection must have elements");
+ *
+ * @param collection the collection to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the collection is {@code null} or has no elements
+ */
+ public static void notEmpty(Collection collection, String message) {
+ if (CollectionUtils.isEmpty(collection)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that a collection has elements; that is, it must not be
+ * {@code null} and must have at least one element.
+ *
Assert.notEmpty(collection, "Collection must have elements");
+ *
+ * @param collection the collection to check
+ * @throws InvalidBusinessException if the collection is {@code null} or has no elements
+ */
+ public static void notEmpty(Collection collection) {
+ notEmpty(collection,
+ "[Assertion failed] - this collection must not be empty: it must contain at least 1 element");
+ }
+
+ /**
+ * Assert that a Map has entries; that is, it must not be {@code null}
+ * and must have at least one entry.
+ *
Assert.notEmpty(map, "Map must have entries");
+ *
+ * @param map the map to check
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if the map is {@code null} or has no entries
+ */
+ public static void notEmpty(Map map, String message) {
+ if (CollectionUtils.isEmpty(map)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert that a Map has entries; that is, it must not be {@code null}
+ * and must have at least one entry.
+ *
Assert.notEmpty(map);
+ *
+ * @param map the map to check
+ * @throws InvalidBusinessException if the map is {@code null} or has no entries
+ */
+ public static void notEmpty(Map map) {
+ notEmpty(map, "[Assertion failed] - this map must not be empty; it must contain at least one entry");
+ }
+
+ /**
+ * Assert that the provided object is an instance of the provided class.
+ *
Assert.instanceOf(Foo.class, foo);
+ *
+ * @param clazz the required class
+ * @param obj the object to check
+ * @throws InvalidBusinessException if the object is not an instance of clazz
+ * @see Class#isInstance
+ */
+ public static void isInstanceOf(Class clazz, Object obj) {
+ isInstanceOf(clazz, obj, "");
+ }
+
+ /**
+ * Assert that the provided object is an instance of the provided class.
+ *
Assert.instanceOf(Foo.class, foo);
+ *
+ * @param type the type to check against
+ * @param obj the object to check
+ * @param message a message which will be prepended to the message produced by
+ * the function itself, and which may be used to provide context. It should
+ * normally end in ":" or "." so that the generated message looks OK when
+ * appended to it.
+ * @throws InvalidBusinessException if the object is not an instance of clazz
+ * @see Class#isInstance
+ */
+ public static void isInstanceOf(Class type, Object obj, String message) {
+ notNull(type, "Type to check against must not be null");
+ if (!type.isInstance(obj)) {
+ throw new InvalidBusinessException(
+ (StringUtils.hasLength(message) ? message + " " : "") +
+ "Object of class [" + (obj != null ? obj.getClass().getName() : "null") +
+ "] must be an instance of " + type);
+ }
+ }
+
+ /**
+ * Assert that {@code superType.isAssignableFrom(subType)} is {@code true}.
+ *
Assert.isAssignable(Number.class, myClass);
+ *
+ * @param superType the super type to check
+ * @param subType the sub type to check
+ * @throws InvalidBusinessException if the classes are not assignable
+ */
+ public static void isAssignable(Class superType, Class subType) {
+ isAssignable(superType, subType, "");
+ }
+
+ /**
+ * Assert that {@code superType.isAssignableFrom(subType)} is {@code true}.
+ *
Assert.isAssignable(Number.class, myClass);
+ *
+ * @param superType the super type to check against
+ * @param subType the sub type to check
+ * @param message a message which will be prepended to the message produced by
+ * the function itself, and which may be used to provide context. It should
+ * normally end in ":" or "." so that the generated message looks OK when
+ * appended to it.
+ * @throws InvalidBusinessException if the classes are not assignable
+ */
+ public static void isAssignable(Class superType, Class subType, String message) {
+ notNull(superType, "Type to check against must not be null");
+ if (subType == null || !superType.isAssignableFrom(subType)) {
+ throw new InvalidBusinessException((StringUtils.hasLength(message) ? message + " " : "") +
+ subType + " is not assignable to " + superType);
+ }
+ }
+
+ /**
+ * Assert a boolean expression, throwing {@code QQWBusinessException}
+ * if the test result is {@code false}. Call isTrue if you wish to
+ * throw QQWBusinessException on an assertion failure.
+ *
Assert.state(id == null, "The id property must not already be initialized");
+ *
+ * @param expression a boolean expression
+ * @param message the exception message to use if the assertion fails
+ * @throws InvalidBusinessException if expression is {@code false}
+ */
+ public static void state(boolean expression, String message) {
+ if (!expression) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+
+ /**
+ * Assert a boolean expression, throwing {@link InvalidBusinessException}
+ * if the test result is {@code false}.
+ *
Call {@link #isTrue(boolean)} if you wish to
+ * throw {@link InvalidBusinessException} on an assertion failure.
+ *
Assert.state(id == null);
+ *
+ * @param expression a boolean expression
+ * @throws InvalidBusinessException if the supplied expression is {@code false}
+ */
+ public static void state(boolean expression) {
+ state(expression, "[Assertion failed] - this state invariant must be true");
+ }
+
+ /**
+ * 检查文件类型
+ *
+ * @param filename 文件
+ * @param filePatterns 文件类型
+ */
+ public static void isFilePatterns(String filename, String[] filePatterns) {
+ if (Stream.of(filePatterns).noneMatch(filename::endsWith)) {
+ throw new InvalidBusinessException("文件格式不正确，必须是" + join(filePatterns, ",") + "中的一种！");
+ }
+ }
+
+ /**
+ * 检查文件类型
+ *
+ * @param filename 文件
+ * @param filePatterns 文件类型
+ */
+ public static void isFilePatterns(String filename, String[] filePatterns, String message) {
+ if (Stream.of(filePatterns).noneMatch(filename::endsWith)) {
+ throw new InvalidBusinessException(message);
+ }
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/utils/EntityUtils.java b/flyfish-common/src/main/java/com/flyfish/framework/utils/EntityUtils.java
new file mode 100644
index 0000000..da6ef8e
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/utils/EntityUtils.java
@@ -0,0 +1,47 @@
+package com.flyfish.framework.utils;
+
+/**
+ * 实体类相关工具类
+ * 解决问题： 1、快速对实体的常驻字段，如：crtUser、crtHost、updUser等值快速注入
+ *
+ * @author Wangyu
+ * @version 1.0
+ * @date 2016年4月18日
+ * @since 1.7
+ */
+public class EntityUtils {
+
+ /**
+ * 依据对象的属性数组和值数组对对象的属性进行赋值
+ *
+ * @param entity 对象
+ * @param fields 属性数组
+ * @param value 值数组
+ * @author 王浩彬
+ */
+ private static void setDefaultValues(T entity, String[] fields, Object[] value) {
+ for (int i = 0; i < fields.length; i++) {
+ String field = fields[i];
+ if (ReflectionUtils.hasField(entity, field)) {
+ ReflectionUtils.invokeSetter(entity, field, value[i]);
+ }
+ }
+ }
+
+ /**
+ * 根据主键属性，判断主键是否值为空
+ *
+ * @param entity
+ * @param field
+ * @return 主键为空，则返回false；主键有值，返回true
+ * @author 王浩彬
+ * @date 2016年4月28日
+ */
+ public static boolean isPKNotNull(T entity, String field) {
+ if (!ReflectionUtils.hasField(entity, field)) {
+ return false;
+ }
+ Object value = ReflectionUtils.getFieldValue(entity, field);
+ return value != null && !"".equals(value);
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/utils/EnumUtils.java b/flyfish-common/src/main/java/com/flyfish/framework/utils/EnumUtils.java
new file mode 100644
index 0000000..eee1be2
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/utils/EnumUtils.java
@@ -0,0 +1,33 @@
+package com.flyfish.framework.utils;
+
+
+import com.flyfish.framework.enums.CodeBasedEnum;
+
+import java.util.NoSuchElementException;
+
+/**
+ * 枚举工具类
+ *
+ * @author Liu.xT
+ */
+public class EnumUtils {
+ /**
+ * 根据枚举标识码获取枚举对象
+ *
+ * @param code 枚举标识
+ * @param enumClass 枚举Class类型
+ * @param 枚举泛型
+ * @return 枚举对象
+ * @throws NoSuchElementException 找不到指定元素
+ */
+ public static & CodeBasedEnum> E getByCode(int code, Class enumClass) throws NoSuchElementException {
+ E[] enumConstants = enumClass.getEnumConstants();
+ for (E e : enumConstants) {
+ if (e.getCode() == code) {
+ return e;
+ }
+ }
+ throw new NoSuchElementException("找不到标识码[" + code + "]对应的枚举对象: [" + enumClass.getSimpleName() + "]");
+ }
+
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/utils/JacksonUtil.java b/flyfish-common/src/main/java/com/flyfish/framework/utils/JacksonUtil.java
new file mode 100644
index 0000000..711335f
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/utils/JacksonUtil.java
@@ -0,0 +1,133 @@
+package com.flyfish.framework.utils;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+/**
+ * Jackson序列化工具类
+ *
+ * @author Mr.Wang
+ */
+public final class JacksonUtil {
+
+ private static final ObjectMapper mapper = new ObjectMapper();
+
+ static {
+ // =========================================================================
+ // SerializationFeature for changing how JSON is written
+
+ // to enable standard indentation ("pretty-printing"):
+// mapper.enable(SerializationFeature.INDENT_OUTPUT);
+ // to allow serialization of "empty" POJOs (no properties to serialize)
+ // (without this setting, an exception is thrown in those cases)
+ mapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
+ // to write java.util.Date, Calendar as number (timestamp):
+ mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+
+ // DeserializationFeature for changing how JSON is read as POJOs:
+
+ // to prevent exception when encountering unknown property:
+ mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
+ // to allow coercion of JSON empty String ("") to null Object value:
+ mapper.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT);
+
+ // =========================================================================
+ // JsonParser.Feature for configuring parsing settings:
+
+ // to allow C/C++ style comments in JSON (non-standard, disabled by default)
+ mapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
+ // (note: with Jackson 2.5, there is also `mapper.enable(feature)` / `mapper.disable(feature)`)
+ mapper.configure(JsonParser.Feature.ALLOW_COMMENTS, true);
+ // to allow (non-standard) unquoted field names in JSON:
+ mapper.configure(JsonParser.Feature.ALLOW_UNQUOTED_FIELD_NAMES, true);
+ // to allow use of apostrophes (single quotes), non standard
+ mapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true);
+
+ mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+ // JsonGenerator.Feature for configuring low-level JSON generation:
+
+ // to force escaping of non-ASCII characters:
+ mapper.configure(JsonGenerator.Feature.ESCAPE_NON_ASCII, true);
+ }
+
+ public static T fromJson(final String json) {
+ return readValue(json, new TypeReference() {
+ });
+ }
+
+ public static T fromJson(final String json, TypeReference reference) {
+ return readValue(json, reference);
+ }
+
+ public static T fromJson(final String json, Class clazz) {
+ if (null == json || "".equals(json)) {
+ return null;
+ }
+ try {
+ return mapper.readValue(json, clazz);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+// public static Map json2Map(final String json) {
+// return fromJson(json, Map.class);
+// }
+
+ public static Map json2Map(String json) {
+ return readValue(json, new TypeReference>() {
+ });
+ }
+
+ public static List json2List(final String json) {
+ return readValue(json, new TypeReference>() {
+ });
+ }
+
+ public static List json2List(final String json, Class clazz) {
+ if (null == json || "".equals(json)) {
+ return null;
+ }
+ try {
+ return mapper.readValue(json, mapper.getTypeFactory().constructParametricType(List.class, clazz));
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ return Collections.emptyList();
+ }
+
+ public static Optional toJson(final Object obj) {
+ try {
+ return Optional.of(mapper.writeValueAsString(obj));
+ } catch (JsonProcessingException e) {
+ e.printStackTrace();
+ }
+ return Optional.empty();
+ }
+
+ private static T readValue(String json, TypeReference valueTypeRef) {
+ if (null == json || "".equals(json)) {
+ return null;
+ }
+ try {
+ return mapper.readValue(json, valueTypeRef);
+ } catch (IOException e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+}
diff --git a/flyfish-common/src/main/java/com/flyfish/framework/utils/ReflectionUtils.java b/flyfish-common/src/main/java/com/flyfish/framework/utils/ReflectionUtils.java
new file mode 100644
index 0000000..b86c398
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/utils/ReflectionUtils.java
@@ -0,0 +1,338 @@
+package com.flyfish.framework.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.Validate;
+import org.springframework.util.Assert;
+
+import java.lang.reflect.*;
+
+/**
+ * 反射工具类.
+ * 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数.
+ *
+ * @author calvin
+ * @version 2013-01-15
+ */
+@SuppressWarnings("rawtypes")
+@Slf4j
+public class ReflectionUtils {
+
+ private static final String SETTER_PREFIX = "set";
+
+ private static final String GETTER_PREFIX = "get";
+
+ private static final String CGLIB_CLASS_SEPARATOR = "$$";
+
+ /**
+ * 调用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) {
+ log.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) {
+ log.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) {
+ log.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, 并强制设置为可访问.
+ *