diff --git a/pom.xml b/pom.xml
index b22e84e9..7c4217ec 100644
--- a/pom.xml
+++ b/pom.xml
@@ -35,12 +35,14 @@
7.2.23
3.4.0
4.4
- 2.7.0
+
+ 2.9.2
2.9.9
2.8.5
1.2.83
4.6.10
1.18.4
+ 4.1.1
-
- com.yungouos.pay
- yungouos-pay-sdk
- 2.0.10
-
-
org.hibernate.validator
hibernate-validator
@@ -129,11 +130,11 @@
5.5.0
-
- com.alibaba
- druid
- 1.1.10
-
+
+
+
+
+
com.auth0
@@ -183,6 +184,12 @@
com.aliyun.oss
aliyun-sdk-oss
3.4.0
+
+
+ aliyun-java-sdk-core
+ com.aliyun
+
+
com.aliyun
@@ -247,16 +254,40 @@
+
+
+
+
+
+
+
mysql
mysql-connector-java
${mysql.version}
+
+
+
+
+
+
- com.oracle
- ojdbc6
- ${oracle.version}
+ org.apache.shardingsphere
+ sharding-core-api
+ ${shardingsphere.version}
+ compile
+
+
+ org.apache.shardingsphere
+ sharding-jdbc-core
+ ${shardingsphere.version}
+ compile
+
+
+ org.springframework.boot
+ spring-boot-starter-actuator
@@ -265,10 +296,10 @@
${mssql.version}
-
- org.postgresql
- postgresql
-
+
+
+
+
com.alibaba
druid-spring-boot-starter
@@ -327,14 +358,25 @@
io.springfox
- springfox-swagger2
+ springfox-swagger-ui
${swagger.version}
io.springfox
- springfox-swagger-ui
+ springfox-swagger2
${swagger.version}
+
+ io.swagger
+ swagger-annotations
+ 1.5.22
+
+
+ io.swagger
+ swagger-models
+ 1.5.22
+
+
com.qiniu
qiniu-java-sdk
diff --git a/src/main/java/com/sqx/SqxApplication.java b/src/main/java/com/sqx/SqxApplication.java
index a3c22cfd..adc28108 100644
--- a/src/main/java/com/sqx/SqxApplication.java
+++ b/src/main/java/com/sqx/SqxApplication.java
@@ -1,6 +1,5 @@
package com.sqx;
-import com.sqx.modules.pay.wuyou.WuyouPay;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
@@ -18,25 +17,7 @@ import java.util.Map;
public class SqxApplication {
public static void main(String[] args) {
- ConfigurableApplicationContext context = SpringApplication.run(SqxApplication.class, args);
- context.getEnvironment().getPropertySources().forEach(source -> {
- if (source.getName().contains("application-dev.yml") || source.getName().contains("application-prod.yml")) {
- if (source.getSource() instanceof Map) {
- ((Map) source.getSource()).forEach((key, value) -> {
- System.out.println(key + ": " + value);
- if ("pay.orderNotifyUrl".equals(key)) {
- WuyouPay.setNotifyUrl(value.toString());
- }
- if ("pay.extractNotifyUrl".equals(key)) {
- WuyouPay.setExtractNotifyUrl(value.toString());
- }
- if ("pay.h5BaseUrl".equals(key)) {
- WuyouPay.setH5BaseUrl(value.toString());
- }
- });
- }
- }
- });
+ SpringApplication.run(SqxApplication.class, args);
System.out.println("(♥◠‿◠)ノ゙ 短剧系统启动成功 ლ(´ڡ`ლ)゙ \n"+
" _ \n" +
" | | \n" +
diff --git a/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java b/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
index b7315939..22cf198d 100644
--- a/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
+++ b/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
@@ -1,5 +1,6 @@
package com.sqx.common.aspect;
+import cn.hutool.core.thread.ThreadUtil;
import com.google.gson.Gson;
import com.sqx.common.utils.HttpContextUtils;
import com.sqx.common.utils.IPUtils;
@@ -21,9 +22,9 @@ import javax.servlet.http.HttpServletRequest;
@Slf4j
public class AppApiMethodAspect {
- @Pointcut("execution(public * (com.sqx.modules.*.controller.*).*(..)) " +
- "&& " +
- "!execution(public * (com.sqx.modules.sys.controller.SysLoginController).*(..))")
+ @Pointcut("!execution(public * (com.sqx.modules.sys.controller.SysLoginController).*(..)) " +
+ "&& (execution(public * (com.sqx.modules.*.controller.*).*(..)) " +
+ "|| execution(public * (com.sqx.modules.app.*.controller.*).*(..)))")
public void pkg() {
}
@@ -44,22 +45,31 @@ public class AppApiMethodAspect {
// 执行被拦截的方法
Object result = pjp.proceed();
-
- //请求的参数
- String resultJson = new Gson().toJson(result);
- try{
- HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
- long end = System.currentTimeMillis();
- if(StringUtils.isNotBlank(resultJson) && !"null".equals(resultJson)){
- log.info("\n>>>>>> {} {}\n>>>>>> IP: {} \n>>>>>> execute time:{}ms \n>>>>>> Request: {}\n>>>>>> Response: {}",
- request.getMethod(), request.getRequestURL(), IPUtils.getIpAddr(request),end-start,
- params,
- resultJson
- );
+ long end = System.currentTimeMillis();
+ HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
+ String method = request.getMethod();
+ String requestUrl = request.getRequestURL().toString();
+ String requestIp = IPUtils.getIpAddr(request);
+ long useTime = end - start;
+ ThreadUtil.execAsync(() -> {
+ //请求的参数
+ String resultJson = new Gson().toJson(result);
+ try {
+ if (StringUtils.isNotBlank(resultJson) && !"null".equals(resultJson)) {
+ log.info("\n>>>>>> {} {}" +
+ "\n>>>>>> IP: {} " +
+ "\n>>>>>> execute time:{}ms " +
+ "\n>>>>>> Request: {}" +
+ "\n>>>>>> Response: {}",
+ method, requestUrl, requestIp, useTime,
+ params,
+ resultJson
+ );
+ }
+ } catch (Exception e) {
+ log.error("Request 为空" + e.getMessage());
}
- }catch (Exception e){
- log.error("Request 为空"+e.getMessage());
- }
+ });
return result;
}
}
diff --git a/src/main/java/com/sqx/common/utils/IPUtils.java b/src/main/java/com/sqx/common/utils/IPUtils.java
index 0fbd6c9f..24248d3f 100644
--- a/src/main/java/com/sqx/common/utils/IPUtils.java
+++ b/src/main/java/com/sqx/common/utils/IPUtils.java
@@ -1,6 +1,6 @@
package com.sqx.common.utils;
-import com.alibaba.druid.util.StringUtils;
+import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/src/main/java/com/sqx/common/utils/RedisKeys.java b/src/main/java/com/sqx/common/utils/RedisKeys.java
index 0f736498..373db19e 100644
--- a/src/main/java/com/sqx/common/utils/RedisKeys.java
+++ b/src/main/java/com/sqx/common/utils/RedisKeys.java
@@ -10,6 +10,8 @@ public class RedisKeys {
public static final String FREE_WATCH_KEY = "free:watch:";
public static final String LOCK_KEY = "SYS:LOCK:";
+ public static final String RATE_LIMIT = "RATE:z";
+
public static String getSysConfigKey(String key){
@@ -41,4 +43,12 @@ public class RedisKeys {
}
return key.toString();
}
+
+ public static String getUserIpRateKey(long userId, String ip) {
+ return RATE_LIMIT + "user:" + userId + ":ip:" + ip;
+ }
+
+ public static String getUserUrlRateKey(long userId, String url) {
+ return RATE_LIMIT + "user:" + userId + ":url:" + url;
+ }
}
diff --git a/src/main/java/com/sqx/config/RedisConfig.java b/src/main/java/com/sqx/config/RedisConfig.java
index 6fddb78c..3188988c 100644
--- a/src/main/java/com/sqx/config/RedisConfig.java
+++ b/src/main/java/com/sqx/config/RedisConfig.java
@@ -1,5 +1,6 @@
package com.sqx.config;
+import com.sqx.common.utils.RedisUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
@@ -70,4 +71,10 @@ public class RedisConfig {
public ZSetOperations zSetOperations(RedisTemplate redisTemplate) {
return redisTemplate.opsForZSet();
}
+
+ @Bean
+ public RedisUtils redisUtils() {
+ // 根据实际情况初始化RedisUtils实例,可能需要传入相关配置参数,如Redis连接信息等
+ return new RedisUtils();
+ }
}
diff --git a/src/main/java/com/sqx/config/ShardingConfig.java b/src/main/java/com/sqx/config/ShardingConfig.java
new file mode 100644
index 00000000..f8efb899
--- /dev/null
+++ b/src/main/java/com/sqx/config/ShardingConfig.java
@@ -0,0 +1,150 @@
+package com.sqx.config;
+
+import com.sqx.sharding.MasterSlaveRules;
+import com.sqx.sharding.ShardingDataBase;
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.shardingsphere.api.config.masterslave.MasterSlaveRuleConfiguration;
+import org.apache.shardingsphere.api.config.sharding.ShardingRuleConfiguration;
+import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration;
+import org.apache.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.annotation.PostConstruct;
+import javax.sql.DataSource;
+import java.sql.SQLException;
+import java.util.*;
+import java.util.stream.Collectors;
+
+
+/**
+ * sharding-jdbc 配置文件
+ */
+@Slf4j
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "spring.shardingsphere")
+public class ShardingConfig {
+
+ /**
+ * 读取数据源信息
+ */
+ private Map datasource;
+ /**
+ * 读写分离的配置
+ */
+ private Map masterSlaveRules;
+ /**
+ * 显示sharding-jdbc的sql
+ */
+ private String showSql;
+
+ /**
+ * 中心库的节点
+ */
+ private String centerTablesDataNode;
+
+ @Value("${center-tables}")
+ private String tableNamesAsString;
+
+ /**
+ * 中心表,不进行分库操作
+ */
+// @Value("${center-tables}")
+ private Set centerTables;
+
+ @PostConstruct
+ public void init() {
+ // 使用换行符进行分割,然后去除空白字符,收集到Set集合中
+ centerTables = Arrays.stream(tableNamesAsString.split(","))
+ .map(String::trim)
+ .collect(Collectors.toSet());
+ }
+
+
+ /**
+ * 配置sharding-jdbc数据源
+ */
+ @Bean
+ public DataSource dataSource() throws SQLException {
+ ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
+
+ // 配置数据库主从
+ shardingRuleConfig.setMasterSlaveRuleConfigs(masterSlaveRuleConfigs());
+
+ // 配置表的切分策略
+ shardingRuleConfig.setTableRuleConfigs(addTableRuleConfigs());
+
+ // 配置是否显示sql
+ Properties props = new Properties();
+ props.put("sql.show", showSql);
+
+ // 配置数据源
+ Map dataSourceMap = getShardingDataBase();
+ return ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig, props);
+ }
+
+ /**
+ * 配置
+ */
+ private Set addTableRuleConfigs() {
+ Set sets = new HashSet<>();
+ for (String centerTable : centerTables) {
+ TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(centerTable,
+ String.format(centerTablesDataNode, centerTable));
+ sets.add(tableRuleConfig);
+ }
+
+// // 定义区域表的分库规则
+// InlineShardingStrategyConfiguration databaseShardingStrategyConfig = new InlineShardingStrategyConfiguration(
+// regionTablesShardingDatabaseColumn, regionTablesShardingDatabaseAlgorithm);
+// for (String regionTable : regionTables) {
+// TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(regionTable, String.format(regionTablesDataNode, regionTable));
+// tableRuleConfig.setDatabaseShardingStrategyConfig(databaseShardingStrategyConfig);
+// sets.add(tableRuleConfig);
+// }
+ return sets;
+ }
+
+ /**
+ * 配置数据源
+ */
+ private Map getShardingDataBase() {
+ String testQuery = "SELECT 1";
+ Map map = new HashMap<>();
+ datasource.forEach((datasourceName, shardingDataBase) -> {
+ HikariConfig config = new HikariConfig();
+ config.setDriverClassName(shardingDataBase.getDriverClassName());
+ config.setJdbcUrl(shardingDataBase.getJdbcUrl());
+ config.setUsername(shardingDataBase.getUsername());
+ config.setPassword(shardingDataBase.getPassword());
+ config.setPoolName(datasourceName);
+ config.setMinimumIdle(shardingDataBase.getMinimumIdle());
+ config.setMaximumPoolSize(shardingDataBase.getMaximumPoolSize());
+ config.setIdleTimeout(shardingDataBase.getIdleTimeout());
+ config.setMaxLifetime(shardingDataBase.getMaxLifetime());
+ config.setConnectionTimeout(shardingDataBase.getConnectionTimeout());
+ config.setConnectionTestQuery(testQuery);
+ map.put(datasourceName, new HikariDataSource(config));
+ });
+ return map;
+ }
+
+ /**
+ * 配置读写分离
+ */
+ private Set masterSlaveRuleConfigs() {
+ Set sets = new HashSet<>();
+ masterSlaveRules.forEach((databaseName, masterSlaveRules) -> {
+ MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration(databaseName,
+ masterSlaveRules.getMasterDataSourceName(), masterSlaveRules.getSlaveDataSourceNames());
+ sets.add(masterSlaveRuleConfig);
+ });
+ return sets;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/sqx/config/SwaggerConfig.java b/src/main/java/com/sqx/config/SwaggerConfig.java
index 8cf4bfee..8f991bfa 100644
--- a/src/main/java/com/sqx/config/SwaggerConfig.java
+++ b/src/main/java/com/sqx/config/SwaggerConfig.java
@@ -1,58 +1,85 @@
-package com.sqx.config;
-
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
-import springfox.documentation.builders.ApiInfoBuilder;
-import springfox.documentation.builders.PathSelectors;
-import springfox.documentation.builders.RequestHandlerSelectors;
-import springfox.documentation.service.ApiInfo;
-import springfox.documentation.service.ApiKey;
-import springfox.documentation.spi.DocumentationType;
-import springfox.documentation.spring.web.plugins.Docket;
-import springfox.documentation.swagger2.annotations.EnableSwagger2;
-
-import java.util.List;
-
-import static com.google.common.collect.Lists.newArrayList;
-
-@Configuration
-@EnableSwagger2
-public class SwaggerConfig implements WebMvcConfigurer {
-
- @Value("${swagger.enabled}")
- private boolean enabled;
-
- @Bean
- public Docket createRestApi() {
- return new Docket(DocumentationType.SWAGGER_2)
- .enable(enabled)
- .apiInfo(apiInfo())
- .select()
- //加了ApiOperation注解的类,才生成接口文档
- .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class))
- //包下的类,才生成接口文档
- //.apis(RequestHandlerSelectors.basePackage("com.sqx.controller"))
- .paths(PathSelectors.any())
- .build()
- .securitySchemes(security());
- }
-
- private ApiInfo apiInfo() {
- return new ApiInfoBuilder()
- .title("")
- .description("sqx-fast文档")
- .termsOfServiceUrl("")
- .version("3.0.0")
- .build();
- }
-
- private List security() {
- return newArrayList(
- new ApiKey("token", "token", "header")
- );
- }
-
-}
\ No newline at end of file
+//package com.sqx.config;
+//
+//import io.swagger.annotations.Api;
+//import io.swagger.annotations.ApiOperation;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.context.annotation.Profile;
+//import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+//import springfox.documentation.builders.ApiInfoBuilder;
+//import springfox.documentation.builders.PathSelectors;
+//import springfox.documentation.builders.RequestHandlerSelectors;
+//import springfox.documentation.service.ApiInfo;
+//import springfox.documentation.service.ApiKey;
+//import springfox.documentation.spi.DocumentationType;
+//import springfox.documentation.spring.web.plugins.Docket;
+//import springfox.documentation.swagger2.annotations.EnableSwagger2;
+//
+//import java.util.List;
+//
+//import static com.google.common.collect.Lists.newArrayList;
+//
+////@Configuration
+////@EnableSwagger2
+////public class SwaggerConfig implements WebMvcConfigurer {
+////
+//// @Value("${swagger.enabled}")
+//// private boolean enabled;
+////
+//// @Bean
+//// public Docket createRestApi() {
+//// return new Docket(DocumentationType.SWAGGER_2)
+//// .enable(enabled)
+//// .apiInfo(apiInfo())
+//// .select()
+//// //加了ApiOperation注解的类,才生成接口文档
+//// .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class))
+//// //包下的类,才生成接口文档
+//// //.apis(RequestHandlerSelectors.basePackage("com.sqx.controller"))
+//// .paths(PathSelectors.any())
+//// .build()
+//// .securitySchemes(security());
+//// }
+////
+//// private ApiInfo apiInfo() {
+//// return new ApiInfoBuilder()
+//// .title("")
+//// .description("sqx-fast文档")
+//// .termsOfServiceUrl("")
+//// .version("3.0.0")
+//// .build();
+//// }
+////
+//// private List security() {
+//// return newArrayList(
+//// new ApiKey("token", "token", "header")
+//// );
+//// }
+////
+////}
+//
+//@Configuration
+//@EnableSwagger2
+//@Profile({"local", "dev"})
+//public class SwaggerConfig {
+//
+// @Bean
+// public Docket api() {
+// return new Docket(DocumentationType.SWAGGER_2)
+// .apiInfo(apiInfo())
+// .select()
+// .apis(RequestHandlerSelectors.withClassAnnotation(Api.class))
+// .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class))
+// .paths(PathSelectors.any())
+// .build();
+// }
+//
+// private ApiInfo apiInfo() {
+// return new ApiInfoBuilder()
+// .title("悠车位后台API接口文档")
+// .description("悠车位服务端后台API接口文档")
+// .version("1.0")
+// .build();
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/sqx/datasource/annotation/DataSource.java b/src/main/java/com/sqx/datasource/annotation/DataSource.java
deleted file mode 100644
index 082da71b..00000000
--- a/src/main/java/com/sqx/datasource/annotation/DataSource.java
+++ /dev/null
@@ -1,14 +0,0 @@
-package com.sqx.datasource.annotation;
-
-import java.lang.annotation.*;
-
-/**
- * 多数据源注解
- */
-@Target({ElementType.METHOD, ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-@Inherited
-public @interface DataSource {
- String value() default "";
-}
diff --git a/src/main/java/com/sqx/datasource/aspect/DataSourceAspect.java b/src/main/java/com/sqx/datasource/aspect/DataSourceAspect.java
deleted file mode 100644
index b3c5d0ac..00000000
--- a/src/main/java/com/sqx/datasource/aspect/DataSourceAspect.java
+++ /dev/null
@@ -1,61 +0,0 @@
-package com.sqx.datasource.aspect;
-
-
-import com.sqx.datasource.annotation.DataSource;
-import com.sqx.datasource.config.DynamicContextHolder;
-import org.aspectj.lang.ProceedingJoinPoint;
-import org.aspectj.lang.annotation.Around;
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Pointcut;
-import org.aspectj.lang.reflect.MethodSignature;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.core.Ordered;
-import org.springframework.core.annotation.Order;
-import org.springframework.stereotype.Component;
-
-import java.lang.reflect.Method;
-
-/**
- * 多数据源,切面处理类
- */
-@Aspect
-@Component
-@Order(Ordered.HIGHEST_PRECEDENCE)
-public class DataSourceAspect {
- protected Logger logger = LoggerFactory.getLogger(getClass());
-
- @Pointcut("@annotation(com.sqx.datasource.annotation.DataSource) " +
- "|| @within(com.sqx.datasource.annotation.DataSource)")
- public void dataSourcePointCut() {
-
- }
-
- @Around("dataSourcePointCut()")
- public Object around(ProceedingJoinPoint point) throws Throwable {
- MethodSignature signature = (MethodSignature) point.getSignature();
- Class targetClass = point.getTarget().getClass();
- Method method = signature.getMethod();
-
- DataSource targetDataSource = (DataSource)targetClass.getAnnotation(DataSource.class);
- DataSource methodDataSource = method.getAnnotation(DataSource.class);
- if(targetDataSource != null || methodDataSource != null){
- String value;
- if(methodDataSource != null){
- value = methodDataSource.value();
- }else {
- value = targetDataSource.value();
- }
-
- DynamicContextHolder.push(value);
- logger.debug("set datasource is {}", value);
- }
-
- try {
- return point.proceed();
- } finally {
- DynamicContextHolder.poll();
- logger.debug("clean datasource");
- }
- }
-}
\ No newline at end of file
diff --git a/src/main/java/com/sqx/datasource/config/DynamicContextHolder.java b/src/main/java/com/sqx/datasource/config/DynamicContextHolder.java
deleted file mode 100644
index f059bf76..00000000
--- a/src/main/java/com/sqx/datasource/config/DynamicContextHolder.java
+++ /dev/null
@@ -1,47 +0,0 @@
-package com.sqx.datasource.config;
-
-import java.util.ArrayDeque;
-import java.util.Deque;
-
-/**
- * 多数据源上下文
- */
-public class DynamicContextHolder {
- @SuppressWarnings("unchecked")
- private static final ThreadLocal> CONTEXT_HOLDER = new ThreadLocal() {
- @Override
- protected Object initialValue() {
- return new ArrayDeque();
- }
- };
-
- /**
- * 获得当前线程数据源
- *
- * @return 数据源名称
- */
- public static String peek() {
- return CONTEXT_HOLDER.get().peek();
- }
-
- /**
- * 设置当前线程数据源
- *
- * @param dataSource 数据源名称
- */
- public static void push(String dataSource) {
- CONTEXT_HOLDER.get().push(dataSource);
- }
-
- /**
- * 清空当前线程数据源
- */
- public static void poll() {
- Deque deque = CONTEXT_HOLDER.get();
- deque.poll();
- if (deque.isEmpty()) {
- CONTEXT_HOLDER.remove();
- }
- }
-
-}
\ No newline at end of file
diff --git a/src/main/java/com/sqx/datasource/config/DynamicDataSource.java b/src/main/java/com/sqx/datasource/config/DynamicDataSource.java
deleted file mode 100644
index 4374032b..00000000
--- a/src/main/java/com/sqx/datasource/config/DynamicDataSource.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package com.sqx.datasource.config;
-
-import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
-
-/**
- * 多数据源
- */
-public class DynamicDataSource extends AbstractRoutingDataSource {
-
- @Override
- protected Object determineCurrentLookupKey() {
- return DynamicContextHolder.peek();
- }
-
-}
diff --git a/src/main/java/com/sqx/datasource/config/DynamicDataSourceConfig.java b/src/main/java/com/sqx/datasource/config/DynamicDataSourceConfig.java
deleted file mode 100644
index 9c1033fd..00000000
--- a/src/main/java/com/sqx/datasource/config/DynamicDataSourceConfig.java
+++ /dev/null
@@ -1,53 +0,0 @@
-package com.sqx.datasource.config;
-
-import com.alibaba.druid.pool.DruidDataSource;
-import com.sqx.datasource.properties.DataSourceProperties;
-import com.sqx.datasource.properties.DynamicDataSourceProperties;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * 配置多数据源
- */
-@Configuration
-@EnableConfigurationProperties(DynamicDataSourceProperties.class)
-public class DynamicDataSourceConfig {
- @Autowired
- private DynamicDataSourceProperties properties;
-
- @Bean
- @ConfigurationProperties(prefix = "spring.datasource.druid")
- public DataSourceProperties dataSourceProperties() {
- return new DataSourceProperties();
- }
-
- @Bean
- public DynamicDataSource dynamicDataSource(DataSourceProperties dataSourceProperties) {
- DynamicDataSource dynamicDataSource = new DynamicDataSource();
- dynamicDataSource.setTargetDataSources(getDynamicDataSource());
-
- //默认数据源
- DruidDataSource defaultDataSource = DynamicDataSourceFactory.buildDruidDataSource(dataSourceProperties);
- dynamicDataSource.setDefaultTargetDataSource(defaultDataSource);
-
- return dynamicDataSource;
- }
-
- private Map