diff --git a/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java b/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java index 4faf77d3c..add3e55d6 100644 --- a/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java +++ b/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java @@ -337,6 +337,20 @@ public class BaseMyBatisConfiguration { wxCarPayOrderSharding.setRule(EnumShardingRule.HASH.getCode()); shardingList.add(wxCarPayOrderSharding); + ShardingSphere wxCouponBatchSharding = new ShardingSphere(); + wxCouponBatchSharding.setColumn("tenant_id"); + wxCouponBatchSharding.setTableName("wx_coupon_batch"); + wxCouponBatchSharding.setCount(100); + wxCouponBatchSharding.setRule(EnumShardingRule.HASH.getCode()); + shardingList.add(wxCouponBatchSharding); + + ShardingSphere wxCouponBatchItemSharding = new ShardingSphere(); + wxCouponBatchItemSharding.setColumn("tenant_id"); + wxCouponBatchItemSharding.setTableName("wx_coupon_batch_item"); + wxCouponBatchItemSharding.setCount(100); + wxCouponBatchItemSharding.setRule(EnumShardingRule.HASH.getCode()); + shardingList.add(wxCouponBatchItemSharding); + //初始化 shardingSpherePlugin.setShardingSpheres(shardingList); Properties properties = new Properties();