From 25f0001a7e76d0565fa9de0651f1177b9f61472f Mon Sep 17 00:00:00 2001
From: zhou zhou <zozhouo3o@gmail.com>
Date: 星期四, 07 五月 2026 17:12:00 +0800
Subject: [PATCH] #order打印
---
rsf-server/src/main/java/com/vincent/rsf/server/common/config/MybatisPlusConfig.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/common/config/MybatisPlusConfig.java b/rsf-server/src/main/java/com/vincent/rsf/server/common/config/MybatisPlusConfig.java
index c28485d..d6cad94 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/common/config/MybatisPlusConfig.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/common/config/MybatisPlusConfig.java
@@ -6,10 +6,12 @@
import com.baomidou.mybatisplus.extension.parser.JsqlParserGlobal;
import com.baomidou.mybatisplus.extension.parser.cache.JdkSerialCaffeineJsqlParseCache;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.DynamicTableNameInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.handler.TenantLineHandler;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor;
+import com.vincent.rsf.server.manager.partition.AsnLogPartitionSupport;
import com.vincent.rsf.server.system.entity.User;
import net.sf.jsqlparser.expression.Expression;
import net.sf.jsqlparser.expression.LongValue;
@@ -38,13 +40,18 @@
private static volatile boolean jsqlParserConfigured = false;
@Bean
- public MybatisPlusInterceptor mybatisPlusInterceptor() {
+ public MybatisPlusInterceptor mybatisPlusInterceptor(AsnLogPartitionSupport asnLogPartitionSupport) {
configureJsqlParser();
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
// 娣诲姞涔愯閿佹彃浠�
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
+ // ASN鍘嗗彶鏃ュ織鍔ㄦ�佽〃鍚�
+ interceptor.addInnerInterceptor(new DynamicTableNameInnerInterceptor(
+ (sql, tableName) -> asnLogPartitionSupport.resolveRoutedTable(tableName)
+ ));
+
// 澶氱鎴锋彃浠堕厤缃�
TenantLineHandler tenantLineHandler = new TenantLineHandler() {
@Override
--
Gitblit v1.9.1