qinfengge

public interface TenantLineHandler {

    /**
     * テナント ID 値の式を取得します。単一の ID 値のみをサポートします。
     * <p>
     *
     * @return テナント ID 値の式
     */
    Expression getTenantId();

    /**
     * テナントフィールド名を取得します。
     * <p>
     * デフォルトのフィールド名は: tenant_id
     *
     * @return テナントフィールド名
     */
    default String getTenantIdColumn() {
        // このフィールドが固定でない場合は、SqlInjectionUtils.checkで安全性を確認してください
        return "tenant_id";
    }

    /**
     * テーブル名に基づいてマルチテナント条件の結合を無視するかどうかを判断します。
     * <p>
     * デフォルトでは、すべてのテーブルが解析され、マルチテナント条件が結合されます。
     *
     * @param tableName テーブル名
     * @return 無視するかどうか、true:無視、false:解析してマルチテナント条件を結合する必要があります
     */
    default boolean ignoreTable(String tableName) {
        return false;
    }
}

# マルチテナント設定
tenant:
    # マルチテナントモードを有効にするか
    enable: true
    # テナントフィールド名
    column: tenant_id
    # マルチテナントを判断する必要があるテーブル名
    includes:
      - sr_card
      - sr_room
      - sr_seat
      - sr_room_seat
      - sr_swiper
      - sys_oss

@Data
@Component
@ConfigurationProperties(prefix = "tenant")
public class TenantProperties {

    /**
     * マルチテナントモードを有効にするか
     */
    private Boolean enable;

    /**
     * テナントフィールド名
     */
    private String column;

    /**
     * マルチテナントを判断する必要があるテーブル名
     */
    private List<String> includes;
}

    @Resource
    private TenantProperties tenantProperties;

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();

        if (tenantProperties.getEnable()) {
            // マルチテナントプラグイン
            interceptor.addInnerInterceptor(tenantLineInnerInterceptor());
        }

        // データ権限処理
        interceptor.addInnerInterceptor(dataPermissionInterceptor());
        // ページネーションプラグイン
        interceptor.addInnerInterceptor(paginationInnerInterceptor());
        // オプティミスティックロックプラグイン
        interceptor.addInnerInterceptor(optimisticLockerInnerInterceptor());
        return interceptor;
    }

public TenantLineInnerInterceptor tenantLineInnerInterceptor() {

        return new TenantLineInnerInterceptor(new TenantLineHandler() {
            @Override
            public Expression getTenantId() {
                try {
                    LoginUser loginUser = LoginUserShareMap.getLoginUser();
                    if (loginUser == null) {
                        System.err.println("現在ログインしていないユーザー！");
                        //マルチテナントモード、テナントIDはnull
                        return new LongValue(0L);
                    } else {
                        //マルチテナントモード、テナントIDは現在のユーザーから取得
                        return new LongValue(loginUser.getUserId());
                    }
                } catch (Exception e) {
                    throw new RuntimeException("現在のログインユーザー情報の取得に失敗しました！", e);
                }

            }

            @Override
            public String getTenantIdColumn() {
                // データベースのテナントIDの列名に対応
                System.err.println("現在のテナント列名：" + tenantProperties.getColumn());
                return tenantProperties.getColumn();
            }

            // これはdefaultメソッドで、デフォルトではfalseを返し、すべてのテーブルがマルチテナント条件を結合する必要があることを示します
            @Override
            public boolean ignoreTable(String tableName) {
                LoginUser loginUser = LoginUserShareMap.getLoginUser();
                // ログインしているかどうかを判断し、ログインしている場合はフィルタリング
                if (loginUser != null) {
                    // プラットフォームのスーパーユーザーかどうかを判断し、プラットフォームのスーパーユーザーであればすべてのデータ権限を持つ
                    if (!LoginHelper.isAdmin()) {
                        // テナントをフィルタリングする必要があるテーブル
                        List<String> includes = tenantProperties.getIncludes();
                        return !includes.contains(tableName);
                    }
                }
                return true;
            }
        });
    }

# SQL解析キャッシュアノテーションを有効にします。MPバージョンが3.1.1以上の場合は設定は不要です。
mybatis-plus:
  global-config:
    sql-parser-cache: true

public interface TenantMapper extends BaseMapper<Tenant> {
    /**
     * 自定Wrapper, @SqlParser(filter = true)アノテーションはSQL解析を行わず、テナントの追加条件がないことを示します。
     *
     * @return
     */
    @SqlParser(filter = true)
    @Select("SELECT count(5) FROM t_tenant ")
    public Integer myCount();
}