keys, boolean fragment) {
+ UriComponentsBuilder template = UriComponentsBuilder.newInstance();
+ UriComponentsBuilder builder = UriComponentsBuilder.fromUriString(base);
+ URI redirectUri;
+ try {
+ // assume it's encoded to start with (if it came in over the wire)
+ redirectUri = builder.build(true).toUri();
+ } catch (Exception e) {
+ // ... but allow client registrations to contain hard-coded non-encoded values
+ redirectUri = builder.build().toUri();
+ builder = UriComponentsBuilder.fromUri(redirectUri);
+ }
+ template.scheme(redirectUri.getScheme()).port(redirectUri.getPort()).host(redirectUri.getHost())
+ .userInfo(redirectUri.getUserInfo()).path(redirectUri.getPath());
+
+ if (fragment) {
+ StringBuilder values = new StringBuilder();
+ if (redirectUri.getFragment() != null) {
+ String append = redirectUri.getFragment();
+ values.append(append);
+ }
+ for (String key : query.keySet()) {
+ if (values.length() > 0) {
+ values.append("&");
+ }
+ String name = key;
+ if (keys != null && keys.containsKey(key)) {
+ name = keys.get(key);
+ }
+ values.append(name).append("={").append(key).append("}");
+ }
+ if (values.length() > 0) {
+ template.fragment(values.toString());
+ }
+ UriComponents encoded = template.build().expand(query).encode();
+ builder.fragment(encoded.getFragment());
+ } else {
+ for (String key : query.keySet()) {
+ String name = key;
+ if (keys != null && keys.containsKey(key)) {
+ name = keys.get(key);
+ }
+ template.queryParam(name, "{" + key + "}");
+ }
+ template.fragment(redirectUri.getFragment());
+ UriComponents encoded = template.build().expand(query).encode();
+ builder.query(encoded.getQuery());
+ }
+ return builder.build().toUriString();
+ }
+
+ public static String[] obtainBasicAuthorization(HttpServletRequest request) {
+ String clientId;
+ String clientSecret;
+ // 先从 Header 中获取
+ String authorization = request.getHeader("Authorization");
+ authorization = StrUtil.subAfter(authorization, "Basic ", true);
+ if (StringUtils.hasText(authorization)) {
+ authorization = Base64.decodeStr(authorization);
+ clientId = StrUtil.subBefore(authorization, ":", false);
+ clientSecret = StrUtil.subAfter(authorization, ":", false);
+ // 再从 Param 中获取
+ } else {
+ clientId = request.getParameter("client_id");
+ clientSecret = request.getParameter("client_secret");
+ }
+
+ // 如果两者非空，则返回
+ if (StrUtil.isNotEmpty(clientId) && StrUtil.isNotEmpty(clientSecret)) {
+ return new String[]{clientId, clientSecret};
+ }
+ return null;
+ }
+
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/http/SoapUtil.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/http/SoapUtil.java
new file mode 100644
index 0000000..09b7aae
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/http/SoapUtil.java
@@ -0,0 +1,67 @@
+package com.jojubanking.boot.framework.common.util.http;
+
+import com.jojubanking.boot.framework.common.exception.enums.GlobalErrorCodeConstants;
+import com.jojubanking.boot.framework.common.exception.util.ServiceExceptionUtil;
+import org.apache.commons.httpclient.HttpClient;
+import org.apache.commons.httpclient.methods.PostMethod;
+
+
+/**
+ * 访问远程SOAP Web Service 协议接口
+ */
+public class SoapUtil {
+ //外网测试地址
+// private static String url = "http://222.128.90.115:8010/BtGhYytWebService.asmx";
+ //测试库地址
+// private static String url = "http://192.168.150.17:8002/BtGhYytWebService.asmx";
+
+ //生成库地址
+// private static String url = "http://192.168.150.15:8001/BtGhYytWebService.asmx";
+ private static String url = "http://101.132.179.117/webservice/WebService.asmx";
+
+ /**
+ * @param xml
+ * @return
+ * @throws Exception
+ */
+ public static String soapMethod(String xml) throws Exception {
+ HttpClient client = new HttpClient();
+ PostMethod method = new PostMethod(url);
+ // 设置请求头头
+ method.setRequestHeader("Content-Type", "text/xml; charset=utf-8");
+ // 设置请求体
+ method.setRequestBody(xml);
+ // 获取响应状态码
+ int code = client.executeMethod(method);
+ if (code == 200) {
+ return method.getResponseBodyAsString();
+ } else {
+ throw ServiceExceptionUtil.exception(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR);
+// throw new LogicException("异常，请联系管理员。");
+ }
+ }
+
+ /**
+ * 定时任务发送请求
+ *
+ * @param xml
+ * @return
+ * @throws Exception
+ */
+ public static String taskSoapMethod(String xml) throws Exception {
+ HttpClient client = new HttpClient();
+ PostMethod method = new PostMethod(url);
+ // 设置请求头头
+ method.setRequestHeader("Content-Type", "text/xml; charset=utf-8");
+ // 设置请求体
+ method.setRequestBody(xml);
+ // 获取响应状态码
+ int code = client.executeMethod(method);
+ if (code == 200) {
+ return method.getResponseBodyAsString();
+ } else {
+ return "";
+ }
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/FileUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/FileUtils.java
new file mode 100644
index 0000000..b6ccf4f
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/FileUtils.java
@@ -0,0 +1,84 @@
+package com.jojubanking.boot.framework.common.util.io;
+
+import cn.hutool.core.io.FileTypeUtil;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.io.file.FileNameUtil;
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.crypto.digest.DigestUtil;
+import lombok.SneakyThrows;
+
+import java.io.ByteArrayInputStream;
+import java.io.File;
+
+/**
+ * 文件工具类
+ *
+ * @author TW
+ */
+public class FileUtils {
+
+ /**
+ * 创建临时文件
+ * 该文件会在 JVM 退出时，进行删除
+ *
+ * @param data 文件内容
+ * @return 文件
+ */
+ @SneakyThrows
+ public static File createTempFile(String data) {
+ File file = createTempFile();
+ // 写入内容
+ FileUtil.writeUtf8String(data, file);
+ return file;
+ }
+
+ /**
+ * 创建临时文件
+ * 该文件会在 JVM 退出时，进行删除
+ *
+ * @param data 文件内容
+ * @return 文件
+ */
+ @SneakyThrows
+ public static File createTempFile(byte[] data) {
+ File file = createTempFile();
+ // 写入内容
+ FileUtil.writeBytes(data, file);
+ return file;
+ }
+
+ /**
+ * 创建临时文件，无内容
+ * 该文件会在 JVM 退出时，进行删除
+ *
+ * @return 文件
+ */
+ @SneakyThrows
+ public static File createTempFile() {
+ // 创建文件，通过 UUID 保证唯一
+ File file = File.createTempFile(IdUtil.simpleUUID(), null);
+ // 标记 JVM 退出时，自动删除
+ file.deleteOnExit();
+ return file;
+ }
+
+ /**
+ * 生成文件路径
+ *
+ * @param content 文件内容
+ * @param originalName 原始文件名
+ * @return path，唯一不可重复
+ */
+ public static String generatePath(byte[] content, String originalName) {
+ String sha256Hex = DigestUtil.sha256Hex(content);
+ // 情况一：如果存在 name，则优先使用 name 的后缀
+ if (StrUtil.isNotBlank(originalName)) {
+ String extName = FileNameUtil.extName(originalName);
+ return StrUtil.isBlank(extName) ? sha256Hex : sha256Hex + "." + extName;
+ }
+ // 情况二：基于 content 计算
+ return sha256Hex + '.' + FileTypeUtil.getType(new ByteArrayInputStream(content));
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/IoUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/IoUtils.java
new file mode 100644
index 0000000..25db556
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/io/IoUtils.java
@@ -0,0 +1,28 @@
+package com.jojubanking.boot.framework.common.util.io;
+
+import cn.hutool.core.io.IORuntimeException;
+import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.util.StrUtil;
+
+import java.io.InputStream;
+
+/**
+ * IO 工具类，用于 {@link cn.hutool.core.io.IoUtil} 缺失的方法
+ *
+ * @author TW
+ */
+public class IoUtils {
+
+ /**
+ * 从流中读取 UTF8 编码的内容
+ *
+ * @param in 输入流
+ * @param isClose 是否关闭
+ * @return 内容
+ * @throws IORuntimeException IO 异常
+ */
+ public static String readUtf8(InputStream in, boolean isClose) throws IORuntimeException {
+ return StrUtil.utf8Str(IoUtil.read(in, isClose));
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/json/JsonUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/json/JsonUtils.java
new file mode 100644
index 0000000..5187277
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/json/JsonUtils.java
@@ -0,0 +1,142 @@
+package com.jojubanking.boot.framework.common.util.json;
+
+import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import lombok.SneakyThrows;
+import lombok.experimental.UtilityClass;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * JSON 工具类
+ *
+ * @author TW
+ */
+@UtilityClass
+@Slf4j
+public class JsonUtils {
+
+ private static ObjectMapper objectMapper = new ObjectMapper();
+
+ static {
+ objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
+ }
+
+ /**
+ * 初始化 objectMapper 属性
+ *
+ * 通过这样的方式，使用 Spring 创建的 ObjectMapper Bean
+ *
+ * @param objectMapper ObjectMapper 对象
+ */
+ public static void init(ObjectMapper objectMapper) {
+ JsonUtils.objectMapper = objectMapper;
+ }
+
+ @SneakyThrows
+ public static String toJsonString(Object object) {
+ return objectMapper.writeValueAsString(object);
+ }
+
+ @SneakyThrows
+ public static byte[] toJsonByte(Object object) {
+ return objectMapper.writeValueAsBytes(object);
+ }
+
+ @SneakyThrows
+ public static String toJsonPrettyString(Object object) {
+ return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(object);
+ }
+
+ public static T parseObject(String text, Class clazz) {
+ if (StrUtil.isEmpty(text)) {
+ return null;
+ }
+ try {
+ return objectMapper.readValue(text, clazz);
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", text, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 将字符串解析成指定类型的对象
+ * 使用 {@link #parseObject(String, Class)} 时，在@JsonTypeInfo(use = JsonTypeInfo.Id.CLASS) 的场景下，
+ * 如果 text 没有 class 属性，则会报错。此时，使用这个方法，可以解决。
+ *
+ * @param text 字符串
+ * @param clazz 类型
+ * @return 对象
+ */
+ public static T parseObject2(String text, Class clazz) {
+ if (StrUtil.isEmpty(text)) {
+ return null;
+ }
+ return JSONUtil.toBean(text, clazz);
+ }
+
+ public static T parseObject(byte[] bytes, Class clazz) {
+ if (ArrayUtil.isEmpty(bytes)) {
+ return null;
+ }
+ try {
+ return objectMapper.readValue(bytes, clazz);
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", bytes, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ public static T parseObject(String text, TypeReference typeReference) {
+ try {
+ return objectMapper.readValue(text, typeReference);
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", text, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ public static List parseArray(String text, Class clazz) {
+ if (StrUtil.isEmpty(text)) {
+ return new ArrayList<>();
+ }
+ try {
+ return objectMapper.readValue(text, objectMapper.getTypeFactory().constructCollectionType(List.class, clazz));
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", text, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ public static JsonNode parseTree(String text) {
+ try {
+ return objectMapper.readTree(text);
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", text, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ public static JsonNode parseTree(byte[] text) {
+ try {
+ return objectMapper.readTree(text);
+ } catch (IOException e) {
+ log.error("json parse err,json:{}", text, e);
+ throw new RuntimeException(e);
+ }
+ }
+
+ public static boolean isJson(String text) {
+ return JSONUtil.isTypeJSON(text);
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.java
new file mode 100644
index 0000000..32eda4a
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.java
@@ -0,0 +1,30 @@
+package com.jojubanking.boot.framework.common.util.monitor;
+
+import org.apache.skywalking.apm.toolkit.trace.TraceContext;
+
+/**
+ * 链路追踪工具类
+ *
+ * 考虑到每个 starter 都需要用到该工具类，所以放到 common 模块下的 util 包下
+ *
+ * @author TW
+ */
+public class TracerUtils {
+
+ /**
+ * 私有化构造方法
+ */
+ private TracerUtils() {
+ }
+
+ /**
+ * 获得链路追踪编号，直接返回 SkyWalking 的 TraceId。
+ * 如果不存在的话为空字符串！！！
+ *
+ * @return 链路追踪编号
+ */
+ public static String getTraceId() {
+ return TraceContext.traceId();
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/number/NumberUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/number/NumberUtils.java
new file mode 100644
index 0000000..0b4f318
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/number/NumberUtils.java
@@ -0,0 +1,16 @@
+package com.jojubanking.boot.framework.common.util.number;
+
+import cn.hutool.core.util.StrUtil;
+
+/**
+ * 数字的工具类，补全 {@link cn.hutool.core.util.NumberUtil} 的功能
+ *
+ * @author TW
+ */
+public class NumberUtils {
+
+ public static Long parseLong(String str) {
+ return StrUtil.isNotEmpty(str) ? Long.valueOf(str) : null;
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/ObjectUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/ObjectUtils.java
new file mode 100644
index 0000000..f1af84a
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/ObjectUtils.java
@@ -0,0 +1,63 @@
+package com.jojubanking.boot.framework.common.util.object;
+
+import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.ReflectUtil;
+
+import java.lang.reflect.Field;
+import java.util.Arrays;
+import java.util.Objects;
+import java.util.function.Consumer;
+
+/**
+ * Object 工具类
+ *
+ * @author TW
+ */
+public class ObjectUtils {
+
+ /**
+ * 复制对象，并忽略 Id 编号
+ *
+ * @param object 被复制对象
+ * @param consumer 消费者，可以二次编辑被复制对象
+ * @return 复制后的对象
+ */
+ public static T cloneIgnoreId(T object, Consumer consumer) {
+ T result = ObjectUtil.clone(object);
+ // 忽略 id 编号
+ Field field = ReflectUtil.getField(object.getClass(), "id");
+ if (field != null) {
+ ReflectUtil.setFieldValue(result, field, null);
+ }
+ // 二次编辑
+ if (result != null) {
+ consumer.accept(result);
+ }
+ return result;
+ }
+
+ public static > T max(T obj1, T obj2) {
+ if (obj1 == null) {
+ return obj2;
+ }
+ if (obj2 == null) {
+ return obj1;
+ }
+ return obj1.compareTo(obj2) > 0 ? obj1 : obj2;
+ }
+
+ public static T defaultIfNull(T... array) {
+ for (T item : array) {
+ if (item != null) {
+ return item;
+ }
+ }
+ return null;
+ }
+
+ public static boolean equalsAny(T obj, T... array) {
+ return Arrays.asList(array).contains(obj);
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/PageUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/PageUtils.java
new file mode 100644
index 0000000..b48278d
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/object/PageUtils.java
@@ -0,0 +1,16 @@
+package com.jojubanking.boot.framework.common.util.object;
+
+import com.jojubanking.boot.framework.common.pojo.PageParam;
+
+/**
+ * {@link PageParam} 工具类
+ *
+ * @author TW
+ */
+public class PageUtils {
+
+ public static int getStart(PageParam pageParam) {
+ return (pageParam.getPageNo() - 1) * pageParam.getPageSize();
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/package-info.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/package-info.java
new file mode 100644
index 0000000..1d1ec7c
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/package-info.java
@@ -0,0 +1,7 @@
+/**
+ * 对于工具类的选择，优先查找 Hutool 中有没对应的方法
+ * 如果没有，则自己封装对应的工具类，以 Utils 结尾，用于区分
+ *
+ * ps：如果担心 Hutool 存在坑的问题，可以阅读 Hutool 的实现源码，以确保可靠性。并且，可以补充相关的单元测试。
+ */
+package com.jojubanking.boot.framework.common.util;
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.java
new file mode 100644
index 0000000..2317d1e
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.java
@@ -0,0 +1,95 @@
+package com.jojubanking.boot.framework.common.util.servlet;
+
+import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.extra.servlet.ServletUtil;
+import com.jojubanking.boot.framework.common.util.json.JsonUtils;
+import org.springframework.http.MediaType;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.ServletRequest;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+
+/**
+ * 客户端工具类
+ *
+ * @author TW
+ */
+public class ServletUtils {
+
+ /**
+ * 返回 JSON 字符串
+ *
+ * @param response 响应
+ * @param object 对象，会序列化成 JSON 字符串
+ */
+ @SuppressWarnings("deprecation") // 必须使用 APPLICATION_JSON_UTF8_VALUE，否则会乱码
+ public static void writeJSON(HttpServletResponse response, Object object) {
+ String content = JsonUtils.toJsonString(object);
+ ServletUtil.write(response, content, MediaType.APPLICATION_JSON_UTF8_VALUE);
+ }
+
+ /**
+ * 返回附件
+ *
+ * @param response 响应
+ * @param filename 文件名
+ * @param content 附件内容
+ * @throws IOException
+ */
+ public static void writeAttachment(HttpServletResponse response, String filename, byte[] content) throws IOException {
+ // 设置 header 和 contentType
+ response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(filename, "UTF-8"));
+ response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
+ // 输出附件
+ IoUtil.write(response.getOutputStream(), false, content);
+ }
+
+ /**
+ * @param request 请求
+ * @return ua
+ */
+ public static String getUserAgent(HttpServletRequest request) {
+ String ua = request.getHeader("User-Agent");
+ return ua != null ? ua : "";
+ }
+
+ /**
+ * 获得请求
+ *
+ * @return HttpServletRequest
+ */
+ public static HttpServletRequest getRequest() {
+ RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
+ if (!(requestAttributes instanceof ServletRequestAttributes)) {
+ return null;
+ }
+ return ((ServletRequestAttributes) requestAttributes).getRequest();
+ }
+
+ public static String getUserAgent() {
+ HttpServletRequest request = getRequest();
+ if (request == null) {
+ return null;
+ }
+ return getUserAgent(request);
+ }
+
+ public static String getClientIP() {
+ HttpServletRequest request = getRequest();
+ if (request == null) {
+ return null;
+ }
+ return ServletUtil.getClientIP(request);
+ }
+
+ public static boolean isJsonRequest(ServletRequest request) {
+ return StrUtil.startWithIgnoreCase(request.getContentType(), MediaType.APPLICATION_JSON_VALUE);
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.java
new file mode 100644
index 0000000..a164593
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.java
@@ -0,0 +1,46 @@
+package com.jojubanking.boot.framework.common.util.spring;
+
+import cn.hutool.core.bean.BeanUtil;
+import org.springframework.aop.framework.AdvisedSupport;
+import org.springframework.aop.framework.AopProxy;
+import org.springframework.aop.support.AopUtils;
+
+/**
+ * Spring AOP 工具类
+ *
+ * 参考波克尔 http://www.bubuko.com/infodetail-3471885.html 实现
+ */
+public class SpringAopUtils {
+
+ /**
+ * 获取代理的目标对象
+ *
+ * @param proxy 代理对象
+ * @return 目标对象
+ */
+ public static Object getTarget(Object proxy) throws Exception {
+ // 不是代理对象
+ if (!AopUtils.isAopProxy(proxy)) {
+ return proxy;
+ }
+ // Jdk 代理
+ if (AopUtils.isJdkDynamicProxy(proxy)) {
+ return getJdkDynamicProxyTargetObject(proxy);
+ }
+ // Cglib 代理
+ return getCglibProxyTargetObject(proxy);
+ }
+
+ private static Object getCglibProxyTargetObject(Object proxy) throws Exception {
+ Object dynamicAdvisedInterceptor = BeanUtil.getFieldValue(proxy, "CGLIB$CALLBACK_0");
+ AdvisedSupport advisedSupport = (AdvisedSupport) BeanUtil.getFieldValue(dynamicAdvisedInterceptor, "advised");
+ return advisedSupport.getTargetSource().getTarget();
+ }
+
+ private static Object getJdkDynamicProxyTargetObject(Object proxy) throws Exception {
+ AopProxy aopProxy = (AopProxy) BeanUtil.getFieldValue(proxy, "h");
+ AdvisedSupport advisedSupport = (AdvisedSupport) BeanUtil.getFieldValue(aopProxy, "advised");
+ return advisedSupport.getTargetSource().getTarget();
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.java
new file mode 100644
index 0000000..5a8cf4f
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.java
@@ -0,0 +1,82 @@
+package com.jojubanking.boot.framework.common.util.spring;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.ArrayUtil;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.core.DefaultParameterNameDiscoverer;
+import org.springframework.core.ParameterNameDiscoverer;
+import org.springframework.expression.EvaluationContext;
+import org.springframework.expression.ExpressionParser;
+import org.springframework.expression.spel.standard.SpelExpressionParser;
+import org.springframework.expression.spel.support.StandardEvaluationContext;
+
+import java.lang.reflect.Method;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Spring EL 表达式的工具类
+ *
+ * @author mashu
+ */
+public class SpringExpressionUtils {
+
+ private static final ExpressionParser EXPRESSION_PARSER = new SpelExpressionParser();
+ private static final ParameterNameDiscoverer PARAMETER_NAME_DISCOVERER = new DefaultParameterNameDiscoverer();
+
+ private SpringExpressionUtils() {
+ }
+
+ /**
+ * 从切面中，单个解析 EL 表达式的结果
+ *
+ * @param joinPoint 切面点
+ * @param expressionString EL 表达式数组
+ * @return 执行界面
+ */
+ public static Object parseExpression(ProceedingJoinPoint joinPoint, String expressionString) {
+ Map result = parseExpressions(joinPoint, Collections.singletonList(expressionString));
+ return result.get(expressionString);
+ }
+
+ /**
+ * 从切面中，批量解析 EL 表达式的结果
+ *
+ * @param joinPoint 切面点
+ * @param expressionStrings EL 表达式数组
+ * @return 结果，key 为表达式，value 为对应值
+ */
+ public static Map parseExpressions(ProceedingJoinPoint joinPoint, List expressionStrings) {
+ // 如果为空，则不进行解析
+ if (CollUtil.isEmpty(expressionStrings)) {
+ return MapUtil.newHashMap();
+ }
+
+ // 第一步，构建解析的上下文 EvaluationContext
+ // 通过 joinPoint 获取被注解方法
+ MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
+ Method method = methodSignature.getMethod();
+ // 使用 spring 的 ParameterNameDiscoverer 获取方法形参名数组
+ String[] paramNames = PARAMETER_NAME_DISCOVERER.getParameterNames(method);
+ // Spring 的表达式上下文对象
+ EvaluationContext context = new StandardEvaluationContext();
+ // 给上下文赋值
+ if (ArrayUtil.isNotEmpty(paramNames)) {
+ Object[] args = joinPoint.getArgs();
+ for (int i = 0; i < paramNames.length; i++) {
+ context.setVariable(paramNames[i], args[i]);
+ }
+ }
+
+ // 第二步，逐个参数解析
+ Map result = MapUtil.newHashMap(expressionStrings.size(), true);
+ expressionStrings.forEach(key -> {
+ Object value = EXPRESSION_PARSER.parseExpression(key).getValue(context);
+ result.put(key, value);
+ });
+ return result;
+ }
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/string/StrUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/string/StrUtils.java
new file mode 100644
index 0000000..8a4a8e2
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/string/StrUtils.java
@@ -0,0 +1,40 @@
+package com.jojubanking.boot.framework.common.util.string;
+
+import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.StrUtil;
+
+import java.util.Collection;
+
+/**
+ * 字符串工具类
+ *
+ * @author TW
+ */
+public class StrUtils {
+
+ public static String maxLength(CharSequence str, int maxLength) {
+ return StrUtil.maxLength(str, maxLength - 3); // -3 的原因，是该方法会补充 ... 恰好
+ }
+
+ /**
+ * 给定字符串是否以任何一个字符串开始
+ * 给定字符串和数组为空都返回 false
+ *
+ * @param str 给定字符串
+ * @param prefixes 需要检测的开始字符串
+ * @since 3.0.6
+ */
+ public static boolean startWithAny(String str, Collection prefixes) {
+ if (StrUtil.isEmpty(str) || ArrayUtil.isEmpty(prefixes)) {
+ return false;
+ }
+
+ for (CharSequence suffix : prefixes) {
+ if (StrUtil.startWith(str, suffix, false)) {
+ return true;
+ }
+ }
+ return false;
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.java
new file mode 100644
index 0000000..930b1e3
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.java
@@ -0,0 +1,49 @@
+package com.jojubanking.boot.framework.common.util.validation;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import org.springframework.util.StringUtils;
+
+import javax.validation.ConstraintViolation;
+import javax.validation.ConstraintViolationException;
+import javax.validation.Validator;
+import java.util.Set;
+import java.util.regex.Pattern;
+
+/**
+ * 校验工具类
+ *
+ * @author TW
+ */
+public class ValidationUtils {
+
+ private static final Pattern PATTERN_URL = Pattern.compile("^(https?|ftp|file)://[-a-zA-Z0-9+&@#/%?=~_|!:,.;]*[-a-zA-Z0-9+&@#/%=~_|]");
+
+ private static final Pattern PATTERN_XML_NCNAME = Pattern.compile("[a-zA-Z_][\\-_.0-9_a-zA-Z$]*");
+
+ public static boolean isMobile(String mobile) {
+ if (StrUtil.length(mobile) != 11) {
+ return false;
+ }
+ // TODO TW，后面完善手机校验
+ return true;
+ }
+
+ public static boolean isURL(String url) {
+ return StringUtils.hasText(url)
+ && PATTERN_URL.matcher(url).matches();
+ }
+
+ public static boolean isXmlNCName(String str) {
+ return StringUtils.hasText(str)
+ && PATTERN_XML_NCNAME.matcher(str).matches();
+ }
+
+ public static void validate(Validator validator, Object object, Class... groups) {
+ Set> constraintViolations = validator.validate(object, groups);
+ if (CollUtil.isNotEmpty(constraintViolations)) {
+ throw new ConstraintViolationException(constraintViolations);
+ }
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/xml/XmlUtil.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/xml/XmlUtil.java
new file mode 100644
index 0000000..78703e2
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/util/xml/XmlUtil.java
@@ -0,0 +1,283 @@
+package com.jojubanking.boot.framework.common.util.xml;
+
+import org.apache.commons.lang3.StringEscapeUtils;
+import org.dom4j.Document;
+import org.dom4j.DocumentException;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Element;
+
+import javax.imageio.ImageIO;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.IOException;
+import java.util.List;
+import java.util.*;
+
+public class XmlUtil {
+// public static void main(String[] args) {
+// Reserve8Vo vo = new Reserve8Vo();
+// System.out.println(getOpAppAppoint(vo));
+// }
+
+ /**
+ * 省份证的正则表达式^(\d{15}|\d{17}[\dx])$
+ *
+ * @param id 省份证号
+ * @return 生日（yyyy-MM-dd）
+ */
+ public static String extractYearMonthDayOfIdCard(String id) {
+ String year = null;
+ String month = null;
+ String day = null;
+ //正则匹配身份证号是否是正确的，15位或者17位数字+数字/x/X
+ if (id.matches("^\\d{15}|\\d{17}[\\dxX]$")) {
+ year = id.substring(6, 10);
+ month = id.substring(10, 12);
+ day = id.substring(12, 14);
+ } else {
+ System.out.println("身份证号码不匹配！");
+ return null;
+ }
+ return year + "-" + month + "-" + day;
+ }
+
+ // 获取返回的报文统一处理
+// public static Map map = new HashMap();
+
+ public static Map parse(String soap) throws DocumentException {
+ //map.clear();
+ String soapWeb = StringEscapeUtils.unescapeXml(soap);
+ soapWeb = soapWeb.replace("", "");
+ Document doc = DocumentHelper.parseText(soapWeb);// 报文 转成 xml
+ Element root = doc.getRootElement();//获取根元素，准备递归解析这个XML树
+
+ Map map = getCodeNC(root);
+ return map;
+ }
+
+ // 非递归遍历所有的 节点 和 数据
+ public static Map getCodeNC(Element root) {
+ Map map = new HashMap();
+
+ Stack a = null;
+ a = new Stack<>();
+ a.push(root);
+
+ if (root.elements().size() == 0 || root.elements() == null) {
+ return map;
+ }
+ //top 是栈顶元素
+ Element top = null;
+ while (!a.empty()) {
+ top = (Element) a.peek();
+ a.pop();
+
+ //如果当前跟节点有子节点，找到子节点
+ List list = top.elements();
+ int size = top.elements().size();
+
+ for (Element e : list) {
+ //遍历每个节点
+ if (e.elements().size() > 0) {
+ //对栈顶元素进行反向遍历，入栈
+ a.push((Element) e);
+ }
+ if (e.elements().size() == 0) {
+ map.put(e.getName(), e.getTextTrim());
+ }//如果为叶子节点，那么直接把名称和值放入map
+ }
+ }
+
+ return map;
+ }
+
+// // 递归遍历所有的 节点 和 数据
+// public static Map getCode(Element root) {
+// // Map map = new HashMap();
+//
+// if (root.elements() != null) {
+// List list = root.elements();//如果当前跟节点有子节点，找到子节点
+// for (Element e : list) {//遍历每个节点
+// if (e.elements().size() > 0) {
+// getCode(e);//当前节点不为空的话，递归遍历子节点；
+// }
+// if (e.elements().size() == 0) {
+// map.put(e.getName(), e.getTextTrim());
+// }//如果为叶子节点，那么直接把名称和值放入map
+// }
+// }
+// return map;
+// }
+//
+ public static List> getPacsRes(String soap, String name) throws DocumentException {
+ String res1 = name + "Response";
+ String res2 = name + "Result";
+ String soapWeb = org.apache.commons.lang.StringEscapeUtils.unescapeXml(soap);
+ soapWeb = soapWeb.replace("", "");
+ // 字符串转xml
+ Document doc = DocumentHelper.parseText(soapWeb);
+
+ //获取根节点
+ Element root = doc.getRootElement();
+ Element body = root.element("Body").element(res1).element(res2).element("response");
+
+ Element elresult = body.element("returnresult");
+ Element eldata = body.element("data");
+
+ System.out.println("根节点 为 ： " + elresult.element("returncode").getText());
+
+ List> list = new ArrayList>();
+ //判断返回值
+ String soapcode = elresult.element("returncode").getText();
+ if (soapcode.equals("1")) {
+ // 获取Body下的所有子节点
+
+ List bodyChild = eldata.elements();
+ for (Iterator it = bodyChild.iterator(); it.hasNext(); ) {
+ Map soapMap = new HashMap();
+ soapMap.put("returncode", soapcode);
+
+ Element elm1 = (Element) it.next();
+ List responseChild = elm1.elements();
+ for (Iterator it1 = responseChild.iterator(); it1.hasNext(); ) {
+ Element elm2 = (Element) it1.next();
+ soapMap.put(elm2.getName(), elm2.getTextTrim());
+ }
+
+ list.add(soapMap);
+ }
+ } else {
+ Map soapMap = new HashMap();
+ soapMap.put("returncode", soapcode);
+ soapMap.put("errormsg", elresult.element("errormsg").getText());
+ list.add(soapMap);
+ }
+ return list;
+ }
+
+ /**
+ * 定时任务解析 xml
+ */
+ public static List> getTasks(String soap) throws DocumentException {
+ String soapWeb = StringEscapeUtils.unescapeXml(soap);
+ soapWeb = soapWeb.replace("", "");
+ Document doc = DocumentHelper.parseText(soapWeb); // 字符串转xml
+ Element root = doc.getRootElement();//获取根节点
+ Element body = root.element("Body"); // 获取所需节点
+ Element response = body.element("queryAppRegistRecordsNewResponse");
+ Element result = response.element("queryAppRegistRecordsNewResult");
+ Element Response = result.element("Response");
+
+ String Result_Code = Response.elementTextTrim("Result_Code");
+
+ List> list = new ArrayList>();
+ if (Result_Code.equals("0000")) {
+ Element resultData = Response.element("Result_Data");
+ Element recordList = resultData.element("Record_List");
+ List elements = recordList.elements();
+ Iterator iterator = elements.iterator();
+ while (iterator.hasNext()) {
+ Element element = iterator.next();
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", "0000");
+ soapMap.put("HIS_ORDER_NO", element.elementTextTrim("HIS_ORDER_NO")); // 交易流水号
+ soapMap.put("REGIST_TYPE", element.elementTextTrim("REGIST_TYPE")); // 预约单状态 1 已退费 0 正常
+ soapMap.put("ALLOWREFUNDFLAG", element.elementTextTrim("ALLOWREFUNDFLAG")); // 允许退号标志 N 不允许 Y 允许
+ list.add(soapMap);
+ }
+ } else {
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", Result_Code);
+ soapMap.put("Error_Msg", Response.elementTextTrim("Error_Msg"));
+ list.add(soapMap);
+ }
+ return list;
+ }
+
+ /**
+ * 查询解析xml
+ */
+
+ public static List> getDeptQueryXml(String resp1, String resp2, String soap) throws DocumentException {
+ String soapWeb = StringEscapeUtils.unescapeXml(soap);
+ soapWeb = soapWeb.replace("", "");
+ Document doc = DocumentHelper.parseText(soapWeb); // 字符串转xml
+ Element root = doc.getRootElement();//获取根节点
+ Element body = root.element("Body"); // 获取所需节点
+ Element response = body.element(resp1);
+ Element result = response.element(resp2);
+ Element Response = result.element("Response");
+
+ String Result_Code = Response.elementTextTrim("Result_Code");
+
+ List> list = new ArrayList>();
+ if (Result_Code.equals("0000")) {
+ Element resultData = Response.element("Result_Data");
+ Element recordList = resultData.element("Record_List");
+ List elements = recordList.elements();
+ Iterator iterator = elements.iterator();
+ while (iterator.hasNext()) {
+ Element element = iterator.next();
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", "0000");
+ soapMap.put("DEPT_CODE", element.elementTextTrim("DEPT_CODE"));
+ soapMap.put("DEPT_NAME", element.elementTextTrim("DEPT_NAME"));
+ soapMap.put("IS_ONLINE", element.elementTextTrim("IS_ONLINE"));
+ list.add(soapMap);
+ }
+ } else {
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", Result_Code);
+ soapMap.put("Error_Msg", Response.elementTextTrim("Error_Msg"));
+ list.add(soapMap);
+ }
+ return list;
+ }
+
+ public static List> getHidsQueryXml(String resp1, String resp2, String soap) throws DocumentException {
+ String soapWeb = StringEscapeUtils.unescapeXml(soap);
+ soapWeb = soapWeb.replace("", "");
+ Document doc = DocumentHelper.parseText(soapWeb); // 字符串转xml
+ Element root = doc.getRootElement();//获取根节点
+ Element body = root.element("Body"); // 获取所需节点
+ Element response = body.element(resp1);
+ Element result = response.element(resp2);
+ Element Response = result.element("Response");
+
+ String Result_Code = Response.elementTextTrim("Result_Code");
+
+ List> list = new ArrayList>();
+ if (Result_Code.equals("0000")) {
+ Element resultData = Response.element("Result_Data");
+ Element recordList = resultData.element("Record_List");
+ List elements = recordList.elements();
+ Iterator iterator = elements.iterator();
+ while (iterator.hasNext()) {
+ Element element = iterator.next();
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", "0000");
+ soapMap.put("HID", element.elementTextTrim("HID"));
+ soapMap.put("DEPT_CODE", element.elementTextTrim("DEPT_CODE"));
+ soapMap.put("DOCTOR_CODE", element.elementTextTrim("DOCTOR_CODE"));
+ soapMap.put("DOCTOR_NAME", element.elementTextTrim("DOCTOR_NAME"));
+ soapMap.put("CLINIC_DATE", element.elementTextTrim("CLINIC_DATE"));
+ soapMap.put("HB_TIME", element.elementTextTrim("HB_TIME"));
+ soapMap.put("CLINIC_DURATION", element.elementTextTrim("CLINIC_DURATION"));
+ soapMap.put("REGISTERED_FEE", element.elementTextTrim("REGISTERED_FEE"));
+ soapMap.put("PHARMACY_FEE", element.elementTextTrim("PHARMACY_FEE"));
+ soapMap.put("DIAG_FEE", element.elementTextTrim("DIAG_FEE"));
+ soapMap.put("IS_ONLINE", element.elementTextTrim("IS_ONLINE"));
+ soapMap.put("HB_TYPE", element.elementTextTrim("HB_TYPE"));
+ list.add(soapMap);
+ }
+ } else {
+ Map soapMap = new HashMap();
+ soapMap.put("Result_Code", Result_Code);
+ soapMap.put("Error_Msg", Response.elementTextTrim("Error_Msg"));
+ list.add(soapMap);
+ }
+ return list;
+ }
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnum.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnum.java
new file mode 100644
index 0000000..89f3fc9
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnum.java
@@ -0,0 +1,35 @@
+package com.jojubanking.boot.framework.common.validation;
+
+import com.jojubanking.boot.framework.common.core.IntArrayValuable;
+
+import javax.validation.Constraint;
+import javax.validation.Payload;
+import java.lang.annotation.*;
+
+@Target({
+ ElementType.METHOD,
+ ElementType.FIELD,
+ ElementType.ANNOTATION_TYPE,
+ ElementType.CONSTRUCTOR,
+ ElementType.PARAMETER,
+ ElementType.TYPE_USE
+})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Constraint(
+ validatedBy = InEnumValidator.class
+)
+public @interface InEnum {
+
+ /**
+ * @return 实现 EnumValuable 接口的
+ */
+ Class value();
+
+ String message() default "必须在指定范围 {value}";
+
+ Class[] groups() default {};
+
+ Class[] payload() default {};
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnumValidator.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnumValidator.java
new file mode 100644
index 0000000..be9b15f
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/InEnumValidator.java
@@ -0,0 +1,44 @@
+package com.jojubanking.boot.framework.common.validation;
+
+import com.jojubanking.boot.framework.common.core.IntArrayValuable;
+
+import javax.validation.ConstraintValidator;
+import javax.validation.ConstraintValidatorContext;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class InEnumValidator implements ConstraintValidator {
+
+ private List values;
+
+ @Override
+ public void initialize(InEnum annotation) {
+ IntArrayValuable[] values = annotation.value().getEnumConstants();
+ if (values.length == 0) {
+ this.values = Collections.emptyList();
+ } else {
+ this.values = Arrays.stream(values[0].array()).boxed().collect(Collectors.toList());
+ }
+ }
+
+ @Override
+ public boolean isValid(Integer value, ConstraintValidatorContext context) {
+ // 为空时，默认不校验，即认为通过
+ if (value == null) {
+ return true;
+ }
+ // 校验通过
+ if (values.contains(value)) {
+ return true;
+ }
+ // 校验不通过，自定义提示语句（因为，注解上的 value 是枚举类，无法获得枚举类的实际值）
+ context.disableDefaultConstraintViolation(); // 禁用默认的 message 的值
+ context.buildConstraintViolationWithTemplate(context.getDefaultConstraintMessageTemplate()
+ .replaceAll("\\{value}", values.toString())).addConstraintViolation(); // 重新添加错误提示语句
+ return false;
+ }
+
+}
+
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/Mobile.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/Mobile.java
new file mode 100644
index 0000000..24662c3
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/Mobile.java
@@ -0,0 +1,28 @@
+package com.jojubanking.boot.framework.common.validation;
+
+import javax.validation.Constraint;
+import javax.validation.Payload;
+import java.lang.annotation.*;
+
+@Target({
+ ElementType.METHOD,
+ ElementType.FIELD,
+ ElementType.ANNOTATION_TYPE,
+ ElementType.CONSTRUCTOR,
+ ElementType.PARAMETER,
+ ElementType.TYPE_USE
+})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Constraint(
+ validatedBy = MobileValidator.class
+)
+public @interface Mobile {
+
+ String message() default "手机号格式不正确";
+
+ Class[] groups() default {};
+
+ Class[] payload() default {};
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/MobileValidator.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/MobileValidator.java
new file mode 100644
index 0000000..b3f11d7
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/MobileValidator.java
@@ -0,0 +1,25 @@
+package com.jojubanking.boot.framework.common.validation;
+
+import cn.hutool.core.util.StrUtil;
+import com.jojubanking.boot.framework.common.util.validation.ValidationUtils;
+
+import javax.validation.ConstraintValidator;
+import javax.validation.ConstraintValidatorContext;
+
+public class MobileValidator implements ConstraintValidator {
+
+ @Override
+ public void initialize(Mobile annotation) {
+ }
+
+ @Override
+ public boolean isValid(String value, ConstraintValidatorContext context) {
+ // 如果手机号为空，默认不校验，即校验通过
+ if (StrUtil.isEmpty(value)) {
+ return true;
+ }
+ // 校验手机
+ return ValidationUtils.isMobile(value);
+ }
+
+}
diff --git a/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/package-info.java b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/package-info.java
new file mode 100644
index 0000000..36a002f
--- /dev/null
+++ b/joju-framework/joju-common/src/main/java/com/jojubanking/boot/framework/common/validation/package-info.java
@@ -0,0 +1,4 @@
+/**
+ * 使用 Hibernate Validator 实现参数校验
+ */
+package com.jojubanking.boot.framework.common.validation;
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/IntArrayValuable.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/IntArrayValuable.class
new file mode 100644
index 0000000..a48ab27
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/IntArrayValuable.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/KeyValue.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/KeyValue.class
new file mode 100644
index 0000000..edd9e68
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/core/KeyValue.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/CommonStatusEnum.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/CommonStatusEnum.class
new file mode 100644
index 0000000..d6c5a62
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/CommonStatusEnum.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/DocumentEnum.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/DocumentEnum.class
new file mode 100644
index 0000000..53ba9c1
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/DocumentEnum.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/UserTypeEnum.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/UserTypeEnum.class
new file mode 100644
index 0000000..c58a53a
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/UserTypeEnum.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/WebFilterOrderEnum.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/WebFilterOrderEnum.class
new file mode 100644
index 0000000..ef938a4
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/enums/WebFilterOrderEnum.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ErrorCode.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ErrorCode.class
new file mode 100644
index 0000000..f632eab
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ErrorCode.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServerException.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServerException.class
new file mode 100644
index 0000000..d79c0a8
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServerException.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServiceException.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServiceException.class
new file mode 100644
index 0000000..2604a92
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/ServiceException.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/GlobalErrorCodeConstants.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/GlobalErrorCodeConstants.class
new file mode 100644
index 0000000..0e43cb2
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/GlobalErrorCodeConstants.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/ServiceErrorCodeRange.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/ServiceErrorCodeRange.class
new file mode 100644
index 0000000..5ab7042
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/enums/ServiceErrorCodeRange.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/util/ServiceExceptionUtil.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/util/ServiceExceptionUtil.class
new file mode 100644
index 0000000..de078a2
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/exception/util/ServiceExceptionUtil.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/CommonResult.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/CommonResult.class
new file mode 100644
index 0000000..07b72d8
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/CommonResult.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageParam.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageParam.class
new file mode 100644
index 0000000..7020bba
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageParam.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageResult.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageResult.class
new file mode 100644
index 0000000..926995e
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/PageResult.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/SortingField.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/SortingField.class
new file mode 100644
index 0000000..7e352c1
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/pojo/SortingField.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/cache/CacheUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/cache/CacheUtils.class
new file mode 100644
index 0000000..56568dc
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/cache/CacheUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/ArrayUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/ArrayUtils.class
new file mode 100644
index 0000000..f1665de
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/ArrayUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/CollectionUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/CollectionUtils.class
new file mode 100644
index 0000000..46f616a
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/CollectionUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/MapUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/MapUtils.class
new file mode 100644
index 0000000..019cc91
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/MapUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/SetUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/SetUtils.class
new file mode 100644
index 0000000..30c455b
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/collection/SetUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/date/DateUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/date/DateUtils.class
new file mode 100644
index 0000000..573f6e7
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/date/DateUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/HttpUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/HttpUtils.class
new file mode 100644
index 0000000..a20c8e7
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/HttpUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/SoapUtil.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/SoapUtil.class
new file mode 100644
index 0000000..13e1474
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/http/SoapUtil.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/FileUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/FileUtils.class
new file mode 100644
index 0000000..d7fead8
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/FileUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/IoUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/IoUtils.class
new file mode 100644
index 0000000..b8b90e9
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/io/IoUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/json/JsonUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/json/JsonUtils.class
new file mode 100644
index 0000000..cbefa2b
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/json/JsonUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.class
new file mode 100644
index 0000000..51fce28
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/monitor/TracerUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/number/NumberUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/number/NumberUtils.class
new file mode 100644
index 0000000..682086c
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/number/NumberUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/ObjectUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/ObjectUtils.class
new file mode 100644
index 0000000..9e45863
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/ObjectUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/PageUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/PageUtils.class
new file mode 100644
index 0000000..cba5f9f
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/object/PageUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.class
new file mode 100644
index 0000000..652d5b4
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/servlet/ServletUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.class
new file mode 100644
index 0000000..578151a
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringAopUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.class
new file mode 100644
index 0000000..d272309
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/spring/SpringExpressionUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/string/StrUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/string/StrUtils.class
new file mode 100644
index 0000000..d6863e6
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/string/StrUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.class
new file mode 100644
index 0000000..7ce8d7c
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/validation/ValidationUtils.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/xml/XmlUtil.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/xml/XmlUtil.class
new file mode 100644
index 0000000..5da1c2d
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/util/xml/XmlUtil.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnum.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnum.class
new file mode 100644
index 0000000..01308ae
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnum.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnumValidator.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnumValidator.class
new file mode 100644
index 0000000..c3f4b81
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/InEnumValidator.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/Mobile.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/Mobile.class
new file mode 100644
index 0000000..1274ab5
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/Mobile.class differ
diff --git a/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/MobileValidator.class b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/MobileValidator.class
new file mode 100644
index 0000000..165215c
Binary files /dev/null and b/joju-framework/joju-common/target/classes/com/jojubanking/boot/framework/common/validation/MobileValidator.class differ
diff --git a/joju-framework/joju-common/target/joju-common-2.0.0-beta.jar b/joju-framework/joju-common/target/joju-common-2.0.0-beta.jar
new file mode 100644
index 0000000..4c7f841
Binary files /dev/null and b/joju-framework/joju-common/target/joju-common-2.0.0-beta.jar differ
diff --git a/joju-framework/joju-common/target/maven-archiver/pom.properties b/joju-framework/joju-common/target/maven-archiver/pom.properties
new file mode 100644
index 0000000..3776679
--- /dev/null
+++ b/joju-framework/joju-common/target/maven-archiver/pom.properties
@@ -0,0 +1,5 @@
+#Generated by Maven
+#Wed Apr 02 13:07:22 CST 2025
+version=2.0.0-beta
+groupId=com.jojubanking.boot
+artifactId=joju-common
diff --git a/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst b/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
new file mode 100644
index 0000000..f35c1e0
--- /dev/null
+++ b/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
@@ -0,0 +1,41 @@
+com\jojubanking\boot\framework\common\util\number\NumberUtils.class
+com\jojubanking\boot\framework\common\exception\ErrorCode.class
+com\jojubanking\boot\framework\common\exception\util\ServiceExceptionUtil.class
+com\jojubanking\boot\framework\common\util\validation\ValidationUtils.class
+com\jojubanking\boot\framework\common\util\date\DateUtils.class
+com\jojubanking\boot\framework\common\util\http\HttpUtils.class
+com\jojubanking\boot\framework\common\pojo\PageResult.class
+com\jojubanking\boot\framework\common\util\collection\ArrayUtils.class
+com\jojubanking\boot\framework\common\exception\ServiceException.class
+com\jojubanking\boot\framework\common\exception\enums\GlobalErrorCodeConstants.class
+com\jojubanking\boot\framework\common\pojo\PageParam.class
+com\jojubanking\boot\framework\common\util\spring\SpringExpressionUtils.class
+com\jojubanking\boot\framework\common\util\io\IoUtils.class
+com\jojubanking\boot\framework\common\validation\Mobile.class
+com\jojubanking\boot\framework\common\util\io\FileUtils.class
+com\jojubanking\boot\framework\common\util\json\JsonUtils.class
+com\jojubanking\boot\framework\common\validation\MobileValidator.class
+com\jojubanking\boot\framework\common\enums\UserTypeEnum.class
+com\jojubanking\boot\framework\common\util\spring\SpringAopUtils.class
+com\jojubanking\boot\framework\common\enums\DocumentEnum.class
+com\jojubanking\boot\framework\common\util\servlet\ServletUtils.class
+com\jojubanking\boot\framework\common\util\object\PageUtils.class
+com\jojubanking\boot\framework\common\util\string\StrUtils.class
+com\jojubanking\boot\framework\common\enums\WebFilterOrderEnum.class
+com\jojubanking\boot\framework\common\util\object\ObjectUtils.class
+com\jojubanking\boot\framework\common\enums\CommonStatusEnum.class
+com\jojubanking\boot\framework\common\util\collection\MapUtils.class
+com\jojubanking\boot\framework\common\util\collection\SetUtils.class
+com\jojubanking\boot\framework\common\util\monitor\TracerUtils.class
+com\jojubanking\boot\framework\common\exception\enums\ServiceErrorCodeRange.class
+com\jojubanking\boot\framework\common\validation\InEnum.class
+com\jojubanking\boot\framework\common\core\IntArrayValuable.class
+com\jojubanking\boot\framework\common\pojo\CommonResult.class
+com\jojubanking\boot\framework\common\util\cache\CacheUtils.class
+com\jojubanking\boot\framework\common\util\xml\XmlUtil.class
+com\jojubanking\boot\framework\common\core\KeyValue.class
+com\jojubanking\boot\framework\common\util\collection\CollectionUtils.class
+com\jojubanking\boot\framework\common\util\http\SoapUtil.class
+com\jojubanking\boot\framework\common\validation\InEnumValidator.class
+com\jojubanking\boot\framework\common\exception\ServerException.class
+com\jojubanking\boot\framework\common\pojo\SortingField.class
diff --git a/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst b/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
new file mode 100644
index 0000000..67dccad
--- /dev/null
+++ b/joju-framework/joju-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
@@ -0,0 +1,44 @@
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\core\IntArrayValuable.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\package-info.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\spring\SpringAopUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\pojo\PageParam.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\enums\DocumentEnum.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\pojo\PageResult.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\object\ObjectUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\core\KeyValue.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\collection\SetUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\xml\XmlUtil.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\util\ServiceExceptionUtil.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\spring\SpringExpressionUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\http\HttpUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\ServiceException.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\validation\ValidationUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\servlet\ServletUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\validation\InEnumValidator.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\enums\WebFilterOrderEnum.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\pojo\CommonResult.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\json\JsonUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\package-info.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\validation\Mobile.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\date\DateUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\enums\CommonStatusEnum.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\enums\ServiceErrorCodeRange.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\string\StrUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\cache\CacheUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\ServerException.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\io\FileUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\object\PageUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\enums\GlobalErrorCodeConstants.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\validation\MobileValidator.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\validation\package-info.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\exception\ErrorCode.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\pojo\SortingField.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\io\IoUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\validation\InEnum.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\monitor\TracerUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\collection\CollectionUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\collection\ArrayUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\number\NumberUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\enums\UserTypeEnum.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\collection\MapUtils.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-common\src\main\java\com\jojubanking\boot\framework\common\util\http\SoapUtil.java
diff --git a/joju-framework/joju-framework.iml b/joju-framework/joju-framework.iml
new file mode 100644
index 0000000..78b2cc5
--- /dev/null
+++ b/joju-framework/joju-framework.iml
@@ -0,0 +1,2 @@
+
+
\ No newline at end of file
diff --git a/joju-framework/joju-spring-boot-starter-banner/pom.xml b/joju-framework/joju-spring-boot-starter-banner/pom.xml
new file mode 100644
index 0000000..5f2a8bf
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/pom.xml
@@ -0,0 +1,30 @@
+
+
+
+ com.jojubanking.boot
+ joju-framework
+ ${revision}
+
+ 4.0.0
+ joju-spring-boot-starter-banner
+ jar
+
+ ${project.artifactId}
+ Banner 用于在 console 控制台，打印开发文档、接口文档等
+ https://www.jojubanking.com
+
+
+
+ com.jojubanking.boot
+ joju-common
+
+
+
+ org.springframework.boot
+ spring-boot-starter
+
+
+
+
diff --git a/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.java b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.java
new file mode 100644
index 0000000..b3ee63b
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.java
@@ -0,0 +1,20 @@
+package com.jojubanking.boot.framework.banner.config;
+
+import com.jojubanking.boot.framework.banner.core.BannerApplicationRunner;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Banner 的自动配置类
+ *
+ * @author TW
+ */
+@Configuration
+public class JojuBannerAutoConfiguration {
+
+ @Bean
+ public BannerApplicationRunner bannerApplicationRunner() {
+ return new BannerApplicationRunner();
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.java b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.java
new file mode 100644
index 0000000..7ad3848
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.java
@@ -0,0 +1,42 @@
+package com.jojubanking.boot.framework.banner.core;
+
+import cn.hutool.core.thread.ThreadUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.util.ClassUtils;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 项目启动成功后，提供文档相关的地址
+ *
+ * @author TW
+ */
+@Slf4j
+public class BannerApplicationRunner implements ApplicationRunner {
+
+ @Override
+ public void run(ApplicationArguments args) throws Exception {
+ ThreadUtil.execute(() -> {
+ ThreadUtil.sleep(1, TimeUnit.SECONDS); // 延迟 1 秒，保证输出到结尾
+ log.info("\n----------------------------------------------------------\n\t" +
+ "项目启动成功！\n\t" +
+ "----------------------------------------------------------");
+
+ // 数据报表
+ if (isNotPresent("com.jojubanking.boot.module.visualization.framework.security.config.SecurityConfiguration")) {
+ System.out.println("[报表模块 joju-module-visualization - 已禁用]");
+ }
+ // 工作流
+ if (isNotPresent("com.jojubanking.boot.framework.flowable.config.JojuFlowableConfiguration")) {
+ System.out.println("[工作流模块 joju-module-bpm - 已禁用]");
+ }
+ });
+ }
+
+ private static boolean isNotPresent(String className) {
+ return !ClassUtils.isPresent(className, ClassUtils.getDefaultClassLoader());
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/package-info.java b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/package-info.java
new file mode 100644
index 0000000..2564400
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/src/main/java/com/jojubanking/boot/framework/banner/package-info.java
@@ -0,0 +1,6 @@
+/**
+ * Banner 用于在 console 控制台，打印开发文档、接口文档等
+ *
+ * @author TW
+ */
+package com.jojubanking.boot.framework.banner;
diff --git a/joju-framework/joju-spring-boot-starter-banner/src/main/resources/META-INF/spring.factories b/joju-framework/joju-spring-boot-starter-banner/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..901fbdc
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+ com.jojubanking.boot.framework.banner.config.JojuBannerAutoConfiguration
diff --git a/joju-framework/joju-spring-boot-starter-banner/src/main/resources/banner.txt b/joju-framework/joju-spring-boot-starter-banner/src/main/resources/banner.txt
new file mode 100644
index 0000000..da1308f
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/src/main/resources/banner.txt
@@ -0,0 +1,16 @@
+Application Version: ${joju.info.version}
+Spring Boot Version: ${spring-boot.version}
+
+.__ __. ______ .______ __ __ _______
+| \ | | / __ \ | _ \ | | | | / _____|
+| \| | | | | | | |_) | | | | | | | __
+| . ` | | | | | | _ < | | | | | | |_ |
+| |\ | | `--' | | |_) | | `--' | | |__| |
+|__| \__| \______/ |______/ \______/ \______|
+
+███╗ ██╗ ██████╗ ██████╗ ██╗ ██╗ ██████╗
+████╗ ██║██╔═══██╗ ██╔══██╗██║ ██║██╔════╝
+██╔██╗ ██║██║ ██║ ██████╔╝██║ ██║██║ ███╗
+██║╚██╗██║██║ ██║ ██╔══██╗██║ ██║██║ ██║
+██║ ╚████║╚██████╔╝ ██████╔╝╚██████╔╝╚██████╔╝
+╚═╝ ╚═══╝ ╚═════╝ ╚═════╝ ╚═════╝ ╚═════╝
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/classes/META-INF/spring.factories b/joju-framework/joju-spring-boot-starter-banner/target/classes/META-INF/spring.factories
new file mode 100644
index 0000000..901fbdc
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/target/classes/META-INF/spring.factories
@@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+ com.jojubanking.boot.framework.banner.config.JojuBannerAutoConfiguration
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/classes/banner.txt b/joju-framework/joju-spring-boot-starter-banner/target/classes/banner.txt
new file mode 100644
index 0000000..da1308f
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/target/classes/banner.txt
@@ -0,0 +1,16 @@
+Application Version: ${joju.info.version}
+Spring Boot Version: ${spring-boot.version}
+
+.__ __. ______ .______ __ __ _______
+| \ | | / __ \ | _ \ | | | | / _____|
+| \| | | | | | | |_) | | | | | | | __
+| . ` | | | | | | _ < | | | | | | |_ |
+| |\ | | `--' | | |_) | | `--' | | |__| |
+|__| \__| \______/ |______/ \______/ \______|
+
+███╗ ██╗ ██████╗ ██████╗ ██╗ ██╗ ██████╗
+████╗ ██║██╔═══██╗ ██╔══██╗██║ ██║██╔════╝
+██╔██╗ ██║██║ ██║ ██████╔╝██║ ██║██║ ███╗
+██║╚██╗██║██║ ██║ ██╔══██╗██║ ██║██║ ██║
+██║ ╚████║╚██████╔╝ ██████╔╝╚██████╔╝╚██████╔╝
+╚═╝ ╚═══╝ ╚═════╝ ╚═════╝ ╚═════╝ ╚═════╝
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.class b/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.class
new file mode 100644
index 0000000..4642fc7
Binary files /dev/null and b/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/config/JojuBannerAutoConfiguration.class differ
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.class b/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.class
new file mode 100644
index 0000000..45c1452
Binary files /dev/null and b/joju-framework/joju-spring-boot-starter-banner/target/classes/com/jojubanking/boot/framework/banner/core/BannerApplicationRunner.class differ
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/joju-spring-boot-starter-banner-2.0.0-beta.jar b/joju-framework/joju-spring-boot-starter-banner/target/joju-spring-boot-starter-banner-2.0.0-beta.jar
new file mode 100644
index 0000000..4362146
Binary files /dev/null and b/joju-framework/joju-spring-boot-starter-banner/target/joju-spring-boot-starter-banner-2.0.0-beta.jar differ
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/maven-archiver/pom.properties b/joju-framework/joju-spring-boot-starter-banner/target/maven-archiver/pom.properties
new file mode 100644
index 0000000..614178b
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/target/maven-archiver/pom.properties
@@ -0,0 +1,5 @@
+#Generated by Maven
+#Wed Apr 02 13:28:37 CST 2025
+version=2.0.0-beta
+groupId=com.jojubanking.boot
+artifactId=joju-spring-boot-starter-banner
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst b/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
new file mode 100644
index 0000000..6c2415e
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
@@ -0,0 +1,2 @@
+com\jojubanking\boot\framework\banner\core\BannerApplicationRunner.class
+com\jojubanking\boot\framework\banner\config\JojuBannerAutoConfiguration.class
diff --git a/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst b/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
new file mode 100644
index 0000000..bf2bdce
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-banner/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
@@ -0,0 +1,3 @@
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-spring-boot-starter-banner\src\main\java\com\jojubanking\boot\framework\banner\package-info.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-spring-boot-starter-banner\src\main\java\com\jojubanking\boot\framework\banner\core\BannerApplicationRunner.java
+D:\^新版项目\05.九聚项目\32.库尔勒妇幼二期\下园体检\examination\joju-framework\joju-spring-boot-starter-banner\src\main\java\com\jojubanking\boot\framework\banner\config\JojuBannerAutoConfiguration.java
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/joju-spring-boot-starter-biz-data-permission.iml b/joju-framework/joju-spring-boot-starter-biz-data-permission/joju-spring-boot-starter-biz-data-permission.iml
new file mode 100644
index 0000000..78b2cc5
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/joju-spring-boot-starter-biz-data-permission.iml
@@ -0,0 +1,2 @@
+
+
\ No newline at end of file
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/pom.xml b/joju-framework/joju-spring-boot-starter-biz-data-permission/pom.xml
new file mode 100644
index 0000000..8d7207e
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/pom.xml
@@ -0,0 +1,55 @@
+
+
+
+ com.jojubanking.boot
+ joju-framework
+ ${revision}
+
+ 4.0.0
+ joju-spring-boot-starter-biz-data-permission
+ jar
+
+ ${project.artifactId}
+ 数据权限
+ https://www.jojubanking.com
+
+
+
+ com.jojubanking.boot
+ joju-common
+
+
+
+
+ com.jojubanking.boot
+ joju-spring-boot-starter-security
+ true
+ ${revision}
+
+
+
+
+ com.jojubanking.boot
+ joju-spring-boot-starter-mybatis
+ ${revision}
+
+
+
+
+ com.jojubanking.boot
+ joju-module-system-api
+ ${revision}
+
+
+
+
+ com.jojubanking.boot
+ joju-spring-boot-starter-test
+ test
+ ${revision}
+
+
+
+
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDataPermissionAutoConfiguration.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDataPermissionAutoConfiguration.java
new file mode 100644
index 0000000..564ca8f
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDataPermissionAutoConfiguration.java
@@ -0,0 +1,45 @@
+package com.jojubanking.boot.framework.datapermission.config;
+
+import com.jojubanking.boot.framework.datapermission.core.aop.DataPermissionAnnotationAdvisor;
+import com.jojubanking.boot.framework.datapermission.core.db.DataPermissionDatabaseInterceptor;
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRule;
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRuleFactory;
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRuleFactoryImpl;
+import com.jojubanking.boot.framework.mybatis.core.util.MyBatisUtils;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+/**
+ * 数据权限的自动配置类
+ *
+ * @author TW
+ */
+@Configuration
+public class JojuDataPermissionAutoConfiguration {
+
+ @Bean
+ public DataPermissionRuleFactory dataPermissionRuleFactory(List rules) {
+ return new DataPermissionRuleFactoryImpl(rules);
+ }
+
+ @Bean
+ public DataPermissionDatabaseInterceptor dataPermissionDatabaseInterceptor(MybatisPlusInterceptor interceptor,
+ List rules) {
+ // 创建 DataPermissionDatabaseInterceptor 拦截器
+ DataPermissionRuleFactory ruleFactory = dataPermissionRuleFactory(rules);
+ DataPermissionDatabaseInterceptor inner = new DataPermissionDatabaseInterceptor(ruleFactory);
+ // 添加到 interceptor 中
+ // 需要加在首个，主要是为了在分页插件前面。这个是 MyBatis Plus 的规定
+ MyBatisUtils.addInterceptor(interceptor, inner, 0);
+ return inner;
+ }
+
+ @Bean
+ public DataPermissionAnnotationAdvisor dataPermissionAnnotationAdvisor() {
+ return new DataPermissionAnnotationAdvisor();
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDeptDataPermissionAutoConfiguration.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDeptDataPermissionAutoConfiguration.java
new file mode 100644
index 0000000..d999644
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/config/JojuDeptDataPermissionAutoConfiguration.java
@@ -0,0 +1,34 @@
+package com.jojubanking.boot.framework.datapermission.config;
+
+import com.jojubanking.boot.framework.datapermission.core.rule.dept.DeptDataPermissionRule;
+import com.jojubanking.boot.framework.datapermission.core.rule.dept.DeptDataPermissionRuleCustomizer;
+import com.jojubanking.boot.framework.security.core.LoginUser;
+import com.jojubanking.boot.module.system.api.permission.PermissionApi;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+/**
+ * 基于部门的数据权限 AutoConfiguration
+ *
+ * @author TW
+ */
+@Configuration
+@ConditionalOnClass(LoginUser.class)
+@ConditionalOnBean(value = {PermissionApi.class, DeptDataPermissionRuleCustomizer.class})
+public class JojuDeptDataPermissionAutoConfiguration {
+
+ @Bean
+ public DeptDataPermissionRule deptDataPermissionRule(PermissionApi permissionApi,
+ List customizers) {
+ // 创建 DeptDataPermissionRule 对象
+ DeptDataPermissionRule rule = new DeptDataPermissionRule(permissionApi);
+ // 补全表配置
+ customizers.forEach(customizer -> customizer.customize(rule));
+ return rule;
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/annotation/DataPermission.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/annotation/DataPermission.java
new file mode 100644
index 0000000..4ac207d
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/annotation/DataPermission.java
@@ -0,0 +1,35 @@
+package com.jojubanking.boot.framework.datapermission.core.annotation;
+
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRule;
+
+import java.lang.annotation.*;
+
+/**
+ * 数据权限注解
+ * 可声明在类或者方法上，标识使用的数据权限规则
+ *
+ * @author TW
+ */
+@Target({ElementType.TYPE, ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface DataPermission {
+
+ /**
+ * 当前类或方法是否开启数据权限
+ * 即使不添加 @DataPermission 注解，默认是开启状态
+ * 可通过设置 enable 为 false 禁用
+ */
+ boolean enable() default true;
+
+ /**
+ * 生效的数据权限规则数组，优先级高于 {@link #excludeRules()}
+ */
+ Class[] includeRules() default {};
+
+ /**
+ * 排除的数据权限规则数组，优先级最低
+ */
+ Class[] excludeRules() default {};
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationAdvisor.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationAdvisor.java
new file mode 100644
index 0000000..c8f0a81
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationAdvisor.java
@@ -0,0 +1,36 @@
+package com.jojubanking.boot.framework.datapermission.core.aop;
+
+import com.jojubanking.boot.framework.datapermission.core.annotation.DataPermission;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import org.aopalliance.aop.Advice;
+import org.springframework.aop.Pointcut;
+import org.springframework.aop.support.AbstractPointcutAdvisor;
+import org.springframework.aop.support.ComposablePointcut;
+import org.springframework.aop.support.annotation.AnnotationMatchingPointcut;
+
+/**
+ * {@link DataPermission} 注解的 Advisor 实现类
+ *
+ * @author TW
+ */
+@Getter
+@EqualsAndHashCode(callSuper = true)
+public class DataPermissionAnnotationAdvisor extends AbstractPointcutAdvisor {
+
+ private final Advice advice;
+
+ private final Pointcut pointcut;
+
+ public DataPermissionAnnotationAdvisor() {
+ this.advice = new DataPermissionAnnotationInterceptor();
+ this.pointcut = this.buildPointcut();
+ }
+
+ protected Pointcut buildPointcut() {
+ Pointcut classPointcut = new AnnotationMatchingPointcut(DataPermission.class, true);
+ Pointcut methodPointcut = new AnnotationMatchingPointcut(null, DataPermission.class, true);
+ return new ComposablePointcut(classPointcut).union(methodPointcut);
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationInterceptor.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationInterceptor.java
new file mode 100644
index 0000000..cf54a3f
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionAnnotationInterceptor.java
@@ -0,0 +1,72 @@
+package com.jojubanking.boot.framework.datapermission.core.aop;
+
+import com.jojubanking.boot.framework.datapermission.core.annotation.DataPermission;
+import lombok.Getter;
+import org.aopalliance.intercept.MethodInterceptor;
+import org.aopalliance.intercept.MethodInvocation;
+import org.springframework.core.MethodClassKey;
+import org.springframework.core.annotation.AnnotationUtils;
+
+import java.lang.reflect.Method;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * {@link DataPermission} 注解的拦截器
+ * 1. 在执行方法前，将 @DataPermission 注解入栈
+ * 2. 在执行方法后，将 @DataPermission 注解出栈
+ *
+ * @author TW
+ */
+@DataPermission // 该注解，用于 {@link DATA_PERMISSION_NULL} 的空对象
+public class DataPermissionAnnotationInterceptor implements MethodInterceptor {
+
+ /**
+ * DataPermission 空对象，用于方法无 {@link DataPermission} 注解时，使用 DATA_PERMISSION_NULL 进行占位
+ */
+ static final DataPermission DATA_PERMISSION_NULL = DataPermissionAnnotationInterceptor.class.getAnnotation(DataPermission.class);
+
+ @Getter
+ private final Map dataPermissionCache = new ConcurrentHashMap<>();
+
+ @Override
+ public Object invoke(MethodInvocation methodInvocation) throws Throwable {
+ // 入栈
+ DataPermission dataPermission = this.findAnnotation(methodInvocation);
+ if (dataPermission != null) {
+ DataPermissionContextHolder.add(dataPermission);
+ }
+ try {
+ // 执行逻辑
+ return methodInvocation.proceed();
+ } finally {
+ // 出栈
+ if (dataPermission != null) {
+ DataPermissionContextHolder.remove();
+ }
+ }
+ }
+
+ private DataPermission findAnnotation(MethodInvocation methodInvocation) {
+ // 1. 从缓存中获取
+ Method method = methodInvocation.getMethod();
+ Object targetObject = methodInvocation.getThis();
+ Class clazz = targetObject != null ? targetObject.getClass() : method.getDeclaringClass();
+ MethodClassKey methodClassKey = new MethodClassKey(method, clazz);
+ DataPermission dataPermission = dataPermissionCache.get(methodClassKey);
+ if (dataPermission != null) {
+ return dataPermission != DATA_PERMISSION_NULL ? dataPermission : null;
+ }
+
+ // 2.1 从方法中获取
+ dataPermission = AnnotationUtils.findAnnotation(method, DataPermission.class);
+ // 2.2 从类上获取
+ if (dataPermission == null) {
+ dataPermission = AnnotationUtils.findAnnotation(clazz, DataPermission.class);
+ }
+ // 2.3 添加到缓存中
+ dataPermissionCache.put(methodClassKey, dataPermission != null ? dataPermission : DATA_PERMISSION_NULL);
+ return dataPermission;
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionContextHolder.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionContextHolder.java
new file mode 100644
index 0000000..b6c5914
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/aop/DataPermissionContextHolder.java
@@ -0,0 +1,72 @@
+package com.jojubanking.boot.framework.datapermission.core.aop;
+
+import com.jojubanking.boot.framework.datapermission.core.annotation.DataPermission;
+import com.alibaba.ttl.TransmittableThreadLocal;
+
+import java.util.LinkedList;
+import java.util.List;
+
+/**
+ * {@link DataPermission} 注解的 Context 上下文
+ *
+ * @author TW
+ */
+public class DataPermissionContextHolder {
+
+ /**
+ * 使用 List 的原因，可能存在方法的嵌套调用
+ */
+ private static final ThreadLocal> DATA_PERMISSIONS =
+ TransmittableThreadLocal.withInitial(LinkedList::new);
+
+ /**
+ * 获得当前的 DataPermission 注解
+ *
+ * @return DataPermission 注解
+ */
+ public static DataPermission get() {
+ return DATA_PERMISSIONS.get().peekLast();
+ }
+
+ /**
+ * 入栈 DataPermission 注解
+ *
+ * @param dataPermission DataPermission 注解
+ */
+ public static void add(DataPermission dataPermission) {
+ DATA_PERMISSIONS.get().addLast(dataPermission);
+ }
+
+ /**
+ * 出栈 DataPermission 注解
+ *
+ * @return DataPermission 注解
+ */
+ public static DataPermission remove() {
+ DataPermission dataPermission = DATA_PERMISSIONS.get().removeLast();
+ // 无元素时，清空 ThreadLocal
+ if (DATA_PERMISSIONS.get().isEmpty()) {
+ DATA_PERMISSIONS.remove();
+ }
+ return dataPermission;
+ }
+
+ /**
+ * 获得所有 DataPermission
+ *
+ * @return DataPermission 队列
+ */
+ public static List getAll() {
+ return DATA_PERMISSIONS.get();
+ }
+
+ /**
+ * 清空上下文
+ *
+ * 目前仅仅用于单测
+ */
+ public static void clear() {
+ DATA_PERMISSIONS.remove();
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/db/DataPermissionDatabaseInterceptor.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/db/DataPermissionDatabaseInterceptor.java
new file mode 100644
index 0000000..6c72355
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/db/DataPermissionDatabaseInterceptor.java
@@ -0,0 +1,508 @@
+package com.jojubanking.boot.framework.datapermission.core.db;
+
+import cn.hutool.core.collection.CollUtil;
+import com.jojubanking.boot.framework.common.util.collection.SetUtils;
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRule;
+import com.jojubanking.boot.framework.datapermission.core.rule.DataPermissionRuleFactory;
+import com.jojubanking.boot.framework.mybatis.core.util.MyBatisUtils;
+import com.alibaba.ttl.TransmittableThreadLocal;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
+import com.baomidou.mybatisplus.extension.parser.JsqlParserSupport;
+import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import net.sf.jsqlparser.expression.*;
+import net.sf.jsqlparser.expression.operators.conditional.AndExpression;
+import net.sf.jsqlparser.expression.operators.conditional.OrExpression;
+import net.sf.jsqlparser.expression.operators.relational.ExistsExpression;
+import net.sf.jsqlparser.expression.operators.relational.ExpressionList;
+import net.sf.jsqlparser.expression.operators.relational.InExpression;
+import net.sf.jsqlparser.expression.operators.relational.ItemsList;
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.delete.Delete;
+import net.sf.jsqlparser.statement.select.*;
+import net.sf.jsqlparser.statement.update.Update;
+import org.apache.ibatis.executor.Executor;
+import org.apache.ibatis.executor.statement.StatementHandler;
+import org.apache.ibatis.mapping.BoundSql;
+import org.apache.ibatis.mapping.MappedStatement;
+import org.apache.ibatis.mapping.SqlCommandType;
+import org.apache.ibatis.session.ResultHandler;
+import org.apache.ibatis.session.RowBounds;
+
+import java.sql.Connection;
+import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * 数据权限拦截器，通过 {@link DataPermissionRule} 数据权限规则，重写 SQL 的方式来实现
+ * 主要的 SQL 重写方法，可见 {@link #builderExpression(Expression, Table)} 方法
+ *
+ * 整体的代码实现上，参考 {@link com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor} 实现。
+ * 所以每次 MyBatis Plus 升级时，需要 Review 下其具体的实现是否有变更！
+ *
+ * @author TW
+ */
+@RequiredArgsConstructor
+public class DataPermissionDatabaseInterceptor extends JsqlParserSupport implements InnerInterceptor {
+
+ private final DataPermissionRuleFactory ruleFactory;
+
+ @Getter
+ private final MappedStatementCache mappedStatementCache = new MappedStatementCache();
+
+ @Override // SELECT 场景
+ public void beforeQuery(Executor executor, MappedStatement ms, Object parameter,
+ RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
+ // 获得 Mapper 对应的数据权限的规则
+ List rules = ruleFactory.getDataPermissionRule(ms.getId());
+ if (mappedStatementCache.noRewritable(ms, rules)) { // 如果无需重写，则跳过
+ return;
+ }
+
+ PluginUtils.MPBoundSql mpBs = PluginUtils.mpBoundSql(boundSql);
+ try {
+ // 初始化上下文
+ ContextHolder.init(rules);
+ // 处理 SQL
+ mpBs.sql(parserSingle(mpBs.sql(), null));
+ } finally {
+ addMappedStatementCache(ms);
+ ContextHolder.clear();
+ }
+ }
+
+ @Override // 只处理 UPDATE / DELETE 场景，不处理 INSERT 场景
+ public void beforePrepare(StatementHandler sh, Connection connection, Integer transactionTimeout) {
+ PluginUtils.MPStatementHandler mpSh = PluginUtils.mpStatementHandler(sh);
+ MappedStatement ms = mpSh.mappedStatement();
+ SqlCommandType sct = ms.getSqlCommandType();
+ if (sct == SqlCommandType.UPDATE || sct == SqlCommandType.DELETE) {
+ // 获得 Mapper 对应的数据权限的规则
+ List rules = ruleFactory.getDataPermissionRule(ms.getId());
+ if (mappedStatementCache.noRewritable(ms, rules)) { // 如果无需重写，则跳过
+ return;
+ }
+
+ PluginUtils.MPBoundSql mpBs = mpSh.mPBoundSql();
+ try {
+ // 初始化上下文
+ ContextHolder.init(rules);
+ // 处理 SQL
+ mpBs.sql(parserMulti(mpBs.sql(), null));
+ } finally {
+ addMappedStatementCache(ms);
+ ContextHolder.clear();
+ }
+ }
+ }
+
+ @Override
+ protected void processSelect(Select select, int index, String sql, Object obj) {
+ processSelectBody(select.getSelectBody());
+ List withItemsList = select.getWithItemsList();
+ if (!CollectionUtils.isEmpty(withItemsList)) {
+ withItemsList.forEach(this::processSelectBody);
+ }
+ }
+
+ protected void processSelectBody(SelectBody selectBody) {
+ if (selectBody == null) {
+ return;
+ }
+ if (selectBody instanceof PlainSelect) {
+ processPlainSelect((PlainSelect) selectBody);
+ } else if (selectBody instanceof WithItem) {
+ WithItem withItem = (WithItem) selectBody;
+ processSelectBody(withItem.getSubSelect().getSelectBody());
+ } else {
+ SetOperationList operationList = (SetOperationList) selectBody;
+ List selectBodys = operationList.getSelects();
+ if (CollectionUtils.isNotEmpty(selectBodys)) {
+ selectBodys.forEach(this::processSelectBody);
+ }
+ }
+ }
+
+ /**
+ * update 语句处理
+ */
+ @Override
+ protected void processUpdate(Update update, int index, String sql, Object obj) {
+ final Table table = update.getTable();
+ update.setWhere(this.builderExpression(update.getWhere(), table));
+ }
+
+ /**
+ * delete 语句处理
+ */
+ @Override
+ protected void processDelete(Delete delete, int index, String sql, Object obj) {
+ delete.setWhere(this.builderExpression(delete.getWhere(), delete.getTable()));
+ }
+
+ /**
+ * 处理 PlainSelect
+ */
+ protected void processPlainSelect(PlainSelect plainSelect) {
+ FromItem fromItem = plainSelect.getFromItem();
+ Expression where = plainSelect.getWhere();
+ processWhereSubSelect(where);
+ if (fromItem instanceof Table) {
+ Table fromTable = (Table) fromItem;
+ plainSelect.setWhere(builderExpression(where, fromTable));
+ } else {
+ processFromItem(fromItem);
+ }
+ //#3087 github
+ List selectItems = plainSelect.getSelectItems();
+ if (CollectionUtils.isNotEmpty(selectItems)) {
+ selectItems.forEach(this::processSelectItem);
+ }
+ List joins = plainSelect.getJoins();
+ if (CollectionUtils.isNotEmpty(joins)) {
+ processJoins(joins);
+ }
+ }
+
+ /**
+ * 处理where条件内的子查询
+ *
+ * 支持如下:
+ * 1. in
+ * 2. =
+ * 3. >
+ * 4. <
+ * 5. >=
+ * 6. <=
+ * 7. <>
+ * 8. EXISTS
+ * 9. NOT EXISTS
+ *
+ * 前提条件:
+ * 1. 子查询必须放在小括号中
+ * 2. 子查询一般放在比较操作符的右边
+ *
+ * @param where where 条件
+ */
+ protected void processWhereSubSelect(Expression where) {
+ if (where == null) {
+ return;
+ }
+ if (where instanceof FromItem) {
+ processFromItem((FromItem) where);
+ return;
+ }
+ if (where.toString().indexOf("SELECT") > 0) {
+ // 有子查询
+ if (where instanceof BinaryExpression) {
+ // 比较符号 , and , or , 等等
+ BinaryExpression expression = (BinaryExpression) where;
+ processWhereSubSelect(expression.getLeftExpression());
+ processWhereSubSelect(expression.getRightExpression());
+ } else if (where instanceof InExpression) {
+ // in
+ InExpression expression = (InExpression) where;
+ ItemsList itemsList = expression.getRightItemsList();
+ if (itemsList instanceof SubSelect) {
+ processSelectBody(((SubSelect) itemsList).getSelectBody());
+ }
+ } else if (where instanceof ExistsExpression) {
+ // exists
+ ExistsExpression expression = (ExistsExpression) where;
+ processWhereSubSelect(expression.getRightExpression());
+ } else if (where instanceof NotExpression) {
+ // not exists
+ NotExpression expression = (NotExpression) where;
+ processWhereSubSelect(expression.getExpression());
+ } else if (where instanceof Parenthesis) {
+ Parenthesis expression = (Parenthesis) where;
+ processWhereSubSelect(expression.getExpression());
+ }
+ }
+ }
+
+ protected void processSelectItem(SelectItem selectItem) {
+ if (selectItem instanceof SelectExpressionItem) {
+ SelectExpressionItem selectExpressionItem = (SelectExpressionItem) selectItem;
+ if (selectExpressionItem.getExpression() instanceof SubSelect) {
+ processSelectBody(((SubSelect) selectExpressionItem.getExpression()).getSelectBody());
+ } else if (selectExpressionItem.getExpression() instanceof Function) {
+ processFunction((Function) selectExpressionItem.getExpression());
+ }
+ }
+ }
+
+ /**
+ * 处理函数
+ *
支持: 1. select fun(args..) 2. select fun1(fun2(args..),args..)
+ *
fixed gitee pulls/141
+ *
+ * @param function 函数
+ */
+ protected void processFunction(Function function) {
+ ExpressionList parameters = function.getParameters();
+ if (parameters != null) {
+ parameters.getExpressions().forEach(expression -> {
+ if (expression instanceof SubSelect) {
+ processSelectBody(((SubSelect) expression).getSelectBody());
+ } else if (expression instanceof Function) {
+ processFunction((Function) expression);
+ }
+ });
+ }
+ }
+
+ /**
+ * 处理子查询等
+ */
+ protected void processFromItem(FromItem fromItem) {
+ if (fromItem instanceof SubJoin) {
+ SubJoin subJoin = (SubJoin) fromItem;
+ if (subJoin.getJoinList() != null) {
+ processJoins(subJoin.getJoinList());
+ }
+ if (subJoin.getLeft() != null) {
+ processFromItem(subJoin.getLeft());
+ }
+ } else if (fromItem instanceof SubSelect) {
+ SubSelect subSelect = (SubSelect) fromItem;
+ if (subSelect.getSelectBody() != null) {
+ processSelectBody(subSelect.getSelectBody());
+ }
+ } else if (fromItem instanceof ValuesList) {
+ logger.debug("Perform a subquery, if you do not give us feedback");
+ } else if (fromItem instanceof LateralSubSelect) {
+ LateralSubSelect lateralSubSelect = (LateralSubSelect) fromItem;
+ if (lateralSubSelect.getSubSelect() != null) {
+ SubSelect subSelect = lateralSubSelect.getSubSelect();
+ if (subSelect.getSelectBody() != null) {
+ processSelectBody(subSelect.getSelectBody());
+ }
+ }
+ }
+ }
+
+ /**
+ * 处理 joins
+ *
+ * @param joins join 集合
+ */
+ private void processJoins(List joins) {
+ //对于 on 表达式写在最后的 join，需要记录下前面多个 on 的表名
+ Deque tables = new LinkedList<>();
+ for (Join join : joins) {
+ // 处理 on 表达式
+ FromItem fromItem = join.getRightItem();
+ if (fromItem instanceof Table) {
+ Table fromTable = (Table) fromItem;
+ // 获取 join 尾缀的 on 表达式列表
+ Collection originOnExpressions = join.getOnExpressions();
+ // 正常 join on 表达式只有一个，立刻处理
+ if (originOnExpressions.size() == 1) {
+ processJoin(join);
+ continue;
+ }
+ tables.push(fromTable);
+ // 尾缀多个 on 表达式的时候统一处理
+ if (originOnExpressions.size() > 1) {
+ Collection onExpressions = new LinkedList<>();
+ for (Expression originOnExpression : originOnExpressions) {
+ Table currentTable = tables.poll();
+ onExpressions.add(builderExpression(originOnExpression, currentTable));
+ }
+ join.setOnExpressions(onExpressions);
+ }
+ } else {
+ // 处理右边连接的子表达式
+ processFromItem(fromItem);
+ }
+ }
+ }
+
+ /**
+ * 处理联接语句
+ */
+ protected void processJoin(Join join) {
+ if (join.getRightItem() instanceof Table) {
+ Table fromTable = (Table) join.getRightItem();
+ Expression originOnExpression = CollUtil.getFirst(join.getOnExpressions());
+ originOnExpression = builderExpression(originOnExpression, fromTable);
+ join.setOnExpressions(CollUtil.newArrayList(originOnExpression));
+ }
+ }
+
+ /**
+ * 处理条件
+ */
+ protected Expression builderExpression(Expression currentExpression, Table table) {
+ // 获得 Table 对应的数据权限条件
+ Expression equalsTo = buildDataPermissionExpression(table);
+ if (equalsTo == null) { // 如果没条件，则返回 currentExpression 默认
+ return currentExpression;
+ }
+
+ // 表达式为空，则直接返回 equalsTo
+ if (currentExpression == null) {
+ return equalsTo;
+ }
+ // 如果表达式为 Or，则需要 (currentExpression) AND equalsTo
+ if (currentExpression instanceof OrExpression) {
+ return new AndExpression(new Parenthesis(currentExpression), equalsTo);
+ }
+ // 如果表达式为 And，则直接返回 currentExpression AND equalsTo
+ return new AndExpression(currentExpression, equalsTo);
+ }
+
+ /**
+ * 构建指定表的数据权限的 Expression 过滤条件
+ *
+ * @param table 表
+ * @return Expression 过滤条件
+ */
+ private Expression buildDataPermissionExpression(Table table) {
+ // 生成条件
+ Expression allExpression = null;
+ for (DataPermissionRule rule : ContextHolder.getRules()) {
+ // 判断表名是否匹配
+ if (!rule.getTableNames().contains(table.getName())) {
+ continue;
+ }
+ // 如果有匹配的规则，说明可重写。
+ // 为什么不是有 allExpression 非空才重写呢？在生成 column = value 过滤条件时，会因为 value 不存在，导致未重写。
+ // 这样导致第一次无 value，被标记成无需重写；但是第二次有 value，此时会需要重写。
+ ContextHolder.setRewrite(true);
+
+ // 单条规则的条件
+ String tableName = MyBatisUtils.getTableName(table);
+ Expression oneExpress = rule.getExpression(tableName, table.getAlias());
+ // 拼接到 allExpression 中
+ allExpression = allExpression == null ? oneExpress
+ : new AndExpression(allExpression, oneExpress);
+ }
+
+ return allExpression;
+ }
+
+ /**
+ * 判断 SQL 是否重写。如果没有重写，则添加到 {@link MappedStatementCache} 中
+ *
+ * @param ms MappedStatement
+ */
+ private void addMappedStatementCache(MappedStatement ms) {
+ if (ContextHolder.getRewrite()) {
+ return;
+ }
+ // 无重写，进行添加
+ mappedStatementCache.addNoRewritable(ms, ContextHolder.getRules());
+ }
+
+ /**
+ * SQL 解析上下文，方便透传 {@link DataPermissionRule} 规则
+ *
+ * @author TW
+ */
+ static final class ContextHolder {
+
+ /**
+ * 该 {@link MappedStatement} 对应的规则
+ */
+ private static final ThreadLocal> RULES = new TransmittableThreadLocal<>();
+ /**
+ * SQL 是否进行重写
+ */
+ private static final ThreadLocal REWRITE = new TransmittableThreadLocal<>();
+
+ public static void init(List rules) {
+ RULES.set(rules);
+ REWRITE.set(false);
+ }
+
+ public static void clear() {
+ RULES.remove();
+ REWRITE.remove();
+ }
+
+ public static boolean getRewrite() {
+ return REWRITE.get();
+ }
+
+ public static void setRewrite(boolean rewrite) {
+ REWRITE.set(rewrite);
+ }
+
+ public static List getRules() {
+ return RULES.get();
+ }
+
+ }
+
+ /**
+ * {@link MappedStatement} 缓存
+ * 目前主要用于，记录 {@link DataPermissionRule} 是否对指定 {@link MappedStatement} 无效
+ * 如果无效，则可以避免 SQL 的解析，加快速度
+ *
+ * @author TW
+ */
+ static final class MappedStatementCache {
+
+ /**
+ * 指定数据权限规则，对指定 MappedStatement 无需重写（不生效)的缓存
+ *
+ * value：{@link MappedStatement#getId()} 编号
+ */
+ @Getter
+ private final Map, Set> noRewritableMappedStatements = new ConcurrentHashMap<>();
+
+ /**
+ * 判断是否无需重写
+ * ps：虽然有点中文式英语，但是容易读懂即可
+ *
+ * @param ms MappedStatement
+ * @param rules 数据权限规则数组
+ * @return 是否无需重写
+ */
+ public boolean noRewritable(MappedStatement ms, List rules) {
+ // 如果规则为空，说明无需重写
+ if (CollUtil.isEmpty(rules)) {
+ return true;
+ }
+ // 任一规则不在 noRewritableMap 中，则说明可能需要重写
+ for (DataPermissionRule rule : rules) {
+ Set mappedStatementIds = noRewritableMappedStatements.get(rule.getClass());
+ if (!CollUtil.contains(mappedStatementIds, ms.getId())) {
+ return false;
+ }
+ }
+ return true;
+ }
+
+ /**
+ * 添加无需重写的 MappedStatement
+ *
+ * @param ms MappedStatement
+ * @param rules 数据权限规则数组
+ */
+ public void addNoRewritable(MappedStatement ms, List rules) {
+ for (DataPermissionRule rule : rules) {
+ Set mappedStatementIds = noRewritableMappedStatements.get(rule.getClass());
+ if (CollUtil.isNotEmpty(mappedStatementIds)) {
+ mappedStatementIds.add(ms.getId());
+ } else {
+ noRewritableMappedStatements.put(rule.getClass(), SetUtils.asSet(ms.getId()));
+ }
+ }
+ }
+
+ /**
+ * 清空缓存
+ * 目前主要提供给单元测试
+ */
+ public void clear() {
+ noRewritableMappedStatements.clear();
+ }
+
+ }
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRule.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRule.java
new file mode 100644
index 0000000..cbc7d0b
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRule.java
@@ -0,0 +1,36 @@
+package com.jojubanking.boot.framework.datapermission.core.rule;
+
+import com.baomidou.mybatisplus.core.metadata.TableInfoHelper;
+import net.sf.jsqlparser.expression.Alias;
+import net.sf.jsqlparser.expression.Expression;
+
+import java.util.Set;
+
+/**
+ * 数据权限规则接口
+ * 通过实现接口，自定义数据规则。例如说，
+ *
+ * @author TW
+ */
+public interface DataPermissionRule {
+
+ /**
+ * 返回需要生效的表名数组
+ * 为什么需要该方法？Data Permission 数组基于 SQL 重写，通过 Where 返回只有权限的数据
+ *
+ * 如果需要基于实体名获得表名，可调用 {@link TableInfoHelper#getTableInfo(Class)} 获得
+ *
+ * @return 表名数组
+ */
+ Set getTableNames();
+
+ /**
+ * 根据表名和别名，生成对应的 WHERE / OR 过滤条件
+ *
+ * @param tableName 表名
+ * @param tableAlias 别名，可能为空
+ * @return 过滤条件 Expression 表达式
+ */
+ Expression getExpression(String tableName, Alias tableAlias);
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactory.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactory.java
new file mode 100644
index 0000000..41e12e0
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactory.java
@@ -0,0 +1,28 @@
+package com.jojubanking.boot.framework.datapermission.core.rule;
+
+import java.util.List;
+
+/**
+ * {@link DataPermissionRule} 工厂接口
+ * 作为 {@link DataPermissionRule} 的容器，提供管理能力
+ *
+ * @author TW
+ */
+public interface DataPermissionRuleFactory {
+
+ /**
+ * 获得所有数据权限规则数组
+ *
+ * @return 数据权限规则数组
+ */
+ List getDataPermissionRules();
+
+ /**
+ * 获得指定 Mapper 的数据权限规则数组
+ *
+ * @param mappedStatementId 指定 Mapper 的编号
+ * @return 数据权限规则数组
+ */
+ List getDataPermissionRule(String mappedStatementId);
+
+}
diff --git a/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactoryImpl.java b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactoryImpl.java
new file mode 100644
index 0000000..83369b9
--- /dev/null
+++ b/joju-framework/joju-spring-boot-starter-biz-data-permission/src/main/java/com/jojubanking/boot/framework/datapermission/core/rule/DataPermissionRuleFactoryImpl.java
@@ -0,0 +1,62 @@
+package com.jojubanking.boot.framework.datapermission.core.rule;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ArrayUtil;
+import com.jojubanking.boot.framework.datapermission.core.annotation.DataPermission;
+import com.jojubanking.boot.framework.datapermission.core.aop.DataPermissionContextHolder;
+import lombok.RequiredArgsConstructor;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 默认的 DataPermissionRuleFactoryImpl 实现类
+ * 支持通过 {@link DataPermissionContextHolder} 过滤数据权限
+ *
+ * @author TW
+ */
+@RequiredArgsConstructor
+public class DataPermissionRuleFactoryImpl implements DataPermissionRuleFactory {
+
+ /**
+ * 数据权限规则数组
+ */
+ private final List