blame | history | patch | commit | commitdiff | show whitespace
kaiyu
2021-09-23 d32bc8f5fa5cd1a9ef293614124420b17acdaa5f 
 screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java


@@ -1,10 +1,20 @@


package com.moral.api.config.mybatis;




import com.baomidou.mybatisplus.annotation.DbType;


import com.baomidou.mybatisplus.extension.parsers.DynamicTableNameParser;


import com.baomidou.mybatisplus.extension.parsers.ITableNameHandler;


import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;


import com.baomidou.mybatisplus.extension.plugins.handler.TableNameHandler;


import com.baomidou.mybatisplus.extension.plugins.inner.DynamicTableNameInnerInterceptor;


import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;


import com.moral.api.entity.HistoryFiveMinutely;


import com.moral.api.mapper.HistoryFiveMinutelyMapper;


import com.moral.api.service.HistorySecondUavService;


import com.moral.api.service.impl.HistorySecondUavServiceImpl;


import com.moral.api.service.impl.OrganizationServiceImpl;


import org.apache.ibatis.reflection.MetaObject;


import org.apache.ibatis.session.SqlSessionFactory;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.context.annotation.Bean;


import org.springframework.context.annotation.Configuration;




@@ -15,29 +25,37 @@


@Configuration


public class MybatisPlusConfig {




    /**


    * @Description: 设置动态表名


            * @Param: []


            * @return: com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor


            * @Author: 陈凯裕


            * @Date: 2021/7/15


            */


    public static ThreadLocal<String> tableName = new ThreadLocal<>();




    @Bean


    public MybatisPlusInterceptor mybatisPlusInterceptor(){


        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();




        //分页插件


        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));


        interceptor.addInnerInterceptor(new PaginationInnerInterceptorIIL(DbType.MYSQL));




        // 动态表名SQL解析器


        DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();


        HashMap<String, TableNameHandler> map = new HashMap<String, TableNameHandler>();


        map.put("history_five_minutely",(sql,tableName)->{ Date date = new Date();


            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMM");


            String month = sdf.format(date);


            return tableName+"_"+month;});


        HashMap<String, TableNameHandler> map = new HashMap<>();


        map.put("history_hourly", (sql, tableName) -> tableName+this.tableName.get());


        map.put("history_five_minutely", (sql, tableName) -> tableName+this.tableName.get());




        dynamicTableNameInnerInterceptor.setTableNameHandlerMap(map);


        interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);




        return interceptor;


    }




    /*@Bean


    public MybatisPlusInterceptor mybatisPlusInterceptor() {


        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();




        //分页插件


        PaginationInnerInterceptorIIL paginationInnerInterceptorIIL = new PaginationInnerInterceptorIIL(DbType.MYSQL);


        paginationInnerInterceptorIIL.setMultiTableQueryName(multiTableQueryNames);


        interceptor.addInnerInterceptor(paginationInnerInterceptorIIL);




        return interceptor;


    }*/




}