Преглед на файлове

fix

release_toaliyun_real
xiaohanzi преди 5 години
родител
ревизия
d4751f8ec0
променени са 20 файла, в които са добавени 155 реда и са изтрити 966 реда
  1. +0
    -5
      mallinkAdmin/pom.xml
  2. +2
    -106
      mallinkAdmin/src/main/java/com/iformall/config/MyBatisConfiguration.java
  3. +0
    -5
      mallinkBApi/pom.xml
  4. +2
    -100
      mallinkBApi/src/main/java/com/iformall/config/MyBatisConfiguration.java
  5. +0
    -5
      mallinkCApi/pom.xml
  6. +2
    -100
      mallinkCApi/src/main/java/com/iformall/config/MyBatisConfiguration.java
  7. +0
    -5
      mallinkCallback/pom.xml
  8. +2
    -105
      mallinkCallback/src/main/java/com/iformall/config/MyBatisConfiguration.java
  9. +0
    -5
      mallinkMQConsumer/pom.xml
  10. +2
    -100
      mallinkMQConsumer/src/main/java/com/iformall/config/MyBatisConfiguration.java
  11. +1
    -6
      mallinkPosApi/pom.xml
  12. +2
    -100
      mallinkPosApi/src/main/java/com/iformall/config/MyBatisConfiguration.java
  13. +1
    -6
      mallinkSchedule/pom.xml
  14. +2
    -105
      mallinkSchedule/src/main/java/com/iformall/config/MyBatisConfiguration.java
  15. +5
    -1
      mallinkService/pom.xml
  16. +129
    -0
      mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java
  17. +0
    -6
      mallinkSysAdmin/pom.xml
  18. +2
    -100
      mallinkSysAdmin/src/main/java/com/iformall/config/MyBatisConfiguration.java
  19. +1
    -6
      mallinkWebSocketServer/pom.xml
  20. +2
    -100
      mallinkWebSocketServer/src/main/java/com/iformall/config/MyBatisConfiguration.java

+ 0
- 5
mallinkAdmin/pom.xml Целия файл

@@ -23,11 +23,6 @@
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>


+ 2
- 106
mallinkAdmin/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -3,21 +3,15 @@ package com.iformall.config;
import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import com.iformall.plugin.MultiTenancy;
import com.iformall.plugin.shard.impl.EnumShardingRule;
import com.iformall.plugin.shard.impl.ShardingSphere;
import com.iformall.plugin.shard.plugin.ShardingSpherePlugin;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration{


@Bean
@@ -34,105 +28,7 @@ public class MyBatisConfiguration {
@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}

@Bean


+ 0
- 5
mallinkBApi/pom.xml Целия файл

@@ -17,11 +17,6 @@
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>
<build>
<plugins>


+ 2
- 100
mallinkBApi/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -13,7 +13,7 @@ import java.util.List;
import java.util.Properties;

@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration{

@Bean
public MultiTenancy multiTenancy() {
@@ -29,104 +29,6 @@ public class MyBatisConfiguration {
@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 0
- 5
mallinkCApi/pom.xml Целия файл

@@ -17,11 +17,6 @@
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>
<build>
<plugins>


+ 2
- 100
mallinkCApi/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -13,7 +13,7 @@ import java.util.List;
import java.util.Properties;

@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public MultiTenancy multiTenancy() {
@@ -29,104 +29,6 @@ public class MyBatisConfiguration {
@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 0
- 5
mallinkCallback/pom.xml Целия файл

@@ -23,11 +23,6 @@
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>

<build>


+ 2
- 105
mallinkCallback/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -1,119 +1,16 @@
package com.iformall.config;

import com.iformall.plugin.shard.impl.EnumShardingRule;
import com.iformall.plugin.shard.impl.ShardingSphere;
import com.iformall.plugin.shard.plugin.ShardingSpherePlugin;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration{

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 0
- 5
mallinkMQConsumer/pom.xml Целия файл

@@ -18,11 +18,6 @@
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>

<build>


+ 2
- 100
mallinkMQConsumer/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -12,108 +12,10 @@ import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 1
- 6
mallinkPosApi/pom.xml Целия файл

@@ -21,12 +21,7 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependency>
</dependencies>
<build>
<plugins>


+ 2
- 100
mallinkPosApi/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -12,108 +12,10 @@ import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 1
- 6
mallinkSchedule/pom.xml Целия файл

@@ -17,12 +17,7 @@
<groupId>com.iformall</groupId>
<artifactId>mallinkService</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependency>
</dependencies>

<build>


+ 2
- 105
mallinkSchedule/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -1,119 +1,16 @@
package com.iformall.config;

import com.iformall.plugin.shard.impl.EnumShardingRule;
import com.iformall.plugin.shard.impl.ShardingSphere;
import com.iformall.plugin.shard.plugin.ShardingSpherePlugin;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 5
- 1
mallinkService/pom.xml Целия файл

@@ -30,7 +30,11 @@
<artifactId>ons-client</artifactId>
<version>1.8.4.Final</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>


+ 129
- 0
mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java Целия файл

@@ -0,0 +1,129 @@
package com.iformall.config;

import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import com.iformall.plugin.shard.impl.EnumShardingRule;
import com.iformall.plugin.shard.impl.ShardingSphere;
import com.iformall.plugin.shard.plugin.ShardingSpherePlugin;

public class BaseMyBatisConfiguration {
//分表配置
protected ShardingSpherePlugin baseShardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxPosOrderSharding = new ShardingSphere();
wxPosOrderSharding.setColumn("tenant_id");
wxPosOrderSharding.setTableName("pos_order");
wxPosOrderSharding.setCount(100);
wxPosOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPosOrderSharding);
ShardingSphere wxPosPayOrderSharding = new ShardingSphere();
wxPosPayOrderSharding.setColumn("tenant_id");
wxPosPayOrderSharding.setTableName("pos_pay_order");
wxPosPayOrderSharding.setCount(100);
wxPosPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPosPayOrderSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
}
}

+ 0
- 6
mallinkSysAdmin/pom.xml Целия файл

@@ -40,12 +40,6 @@
<artifactId>kaptcha</artifactId>
<version>0.0.9</version>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependencies>

<build>


+ 2
- 100
mallinkSysAdmin/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -12,108 +12,10 @@ import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

+ 1
- 6
mallinkWebSocketServer/pom.xml Целия файл

@@ -25,12 +25,7 @@
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-reactor-netty</artifactId>
</dependency>
<dependency>
<groupId>com.iformall</groupId>
<artifactId>mybatis-multi-tenancy</artifactId>
<version>1.0</version>
</dependency>
</dependency>
</dependencies>

<build>


+ 2
- 100
mallinkWebSocketServer/src/main/java/com/iformall/config/MyBatisConfiguration.java Целия файл

@@ -12,108 +12,10 @@ import java.util.Properties;

@EnableTransactionManagement
@Configuration
public class MyBatisConfiguration {
public class MyBatisConfiguration extends BaseMyBatisConfiguration {

@Bean
public ShardingSpherePlugin shardingSpherePlugin() {
ShardingSpherePlugin shardingSpherePlugin = new ShardingSpherePlugin();
Properties properties = new Properties();
properties.setProperty("dialect", "mysql");
shardingSpherePlugin.setProperties(properties);
List<ShardingSphere> shardingList = new ArrayList<ShardingSphere>();
shardingSpherePlugin.setShardingSpheres(shardingList);
ShardingSphere wxCUserSharding = new ShardingSphere();
wxCUserSharding.setColumn("tenant_id");
wxCUserSharding.setTableName("wx_c_user");
wxCUserSharding.setCount(100);
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserSharding);
ShardingSphere basicInfoSharding = new ShardingSphere();
basicInfoSharding.setColumn("final_tenant_id");
basicInfoSharding.setTableName("wx_c_user_basic_info");
basicInfoSharding.setCount(100);
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(basicInfoSharding);
ShardingSphere wxOrderSharding = new ShardingSphere();
wxOrderSharding.setColumn("tenant_id");
wxOrderSharding.setTableName("wx_order");
wxOrderSharding.setCount(100);
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderSharding);
ShardingSphere wxPayOrderSharding = new ShardingSphere();
wxPayOrderSharding.setColumn("tenant_id");
wxPayOrderSharding.setTableName("wx_pay_order");
wxPayOrderSharding.setCount(100);
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPayOrderSharding);
ShardingSphere wxCouponOrderSharding = new ShardingSphere();
wxCouponOrderSharding.setColumn("tenant_id");
wxCouponOrderSharding.setTableName("wx_coupon_order");
wxCouponOrderSharding.setCount(100);
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponOrderSharding);

ShardingSphere wxOrderGroupSharding = new ShardingSphere();
wxOrderGroupSharding.setColumn("tenant_id");
wxOrderGroupSharding.setTableName("wx_order_group");
wxOrderGroupSharding.setCount(100);
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderGroupSharding);
ShardingSphere wxOrderPressSharding = new ShardingSphere();
wxOrderPressSharding.setColumn("tenant_id");
wxOrderPressSharding.setTableName("wx_order_press");
wxOrderPressSharding.setCount(100);
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxOrderPressSharding);
ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding);
ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history");
wxScoreHistorySharding.setCount(100);
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log");
wxCarCmdLogSharding.setCount(100);
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCarCmdLogSharding);
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere();
wxMerchantSubsidySharding.setColumn("tenant_id");
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy");
wxMerchantSubsidySharding.setCount(100);
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxMerchantSubsidySharding);
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere();
wxProfitSharingOrderSharding.setColumn("tenant_id");
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order");
wxProfitSharingOrderSharding.setCount(100);
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxProfitSharingOrderSharding);

ShardingSphere wxCouponActionLogSharding = new ShardingSphere();
wxCouponActionLogSharding.setColumn("tenant_id");
wxCouponActionLogSharding.setTableName("wx_coupon_action_log");
wxCouponActionLogSharding.setCount(100);
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCouponActionLogSharding);
return shardingSpherePlugin;
return baseShardingSpherePlugin();
}
}

Зареждане…
Отказ
Запис