mybatis表名反射实体

package com.eshore.wbtimer.executor.service.impl;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.SqlHelper;
import com.eshore.wbtimer.executor.service.CommonService;
import com.eshore.wbtimer.executor.util.field.SpringContextUtil;
import org.springframework.stereotype.Service;
import org.springframework.util.ReflectionUtils;

import java.lang.reflect.Method;

/**
 * 此方法利用动态代理和反射实现通用插入，根据bean类获取相应mapper接口，利用代理注入mapper，再反射调用响应方法
 */
@Service
public class CommonServiceImpl implements CommonService {

    @Override
    public boolean commonMapperSave(Class<?> bean, Object dataBean) {
        String mapperPath = SqlHelper.table(bean).getCurrentNamespace();
        Class<?> dataMapperClass = null;
        try {
            dataMapperClass = Class.forName(mapperPath);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return false;
        }
        try {
            Object mapperServiceBean = SpringContextUtil.getBean(dataMapperClass);
            Method mapperServiceBeanMethod = ReflectionUtils.findMethod(mapperServiceBean.getClass(), "insert", Object.class);
            // 执行方法
            ReflectionUtils.invokeMethod(mapperServiceBeanMethod, mapperServiceBean, dataBean);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

    @Override
    public boolean commonMapperSelect(String className) {
        String mapperPath = "com.eshore.wbtimer.executor.mapper.bean."+className;
        Class<?> dataMapperClass = null;
        try {
            dataMapperClass = Class.forName(mapperPath);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return false;
        }
        String dataPath = SqlHelper.table(dataMapperClass).getCurrentNamespace();
        Class<?> mapperClass = null;
        try {
            mapperClass = Class.forName(dataPath);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        try {
            Object mapperServiceBean = SpringContextUtil.getBean(mapperClass);
            EntityWrapper ew = new EntityWrapper();
            ew.setEntity(mapperServiceBean);
            ew.where("UPLOAD_TIMESTAMP < DATA_TIMESTAMP").or("UPLOAD_TIMESTAMP is  null");
            if(className.startsWith("SJ")) {
                ew.where(" and CITY='SYGNGD' ");
            }
            Method mapperServiceBeanMethod = ReflectionUtils.findMethod(mapperServiceBean.getClass(), "select", EntityWrapper.class);
            // 执行方法
            Object obj = ReflectionUtils.invokeMethod(mapperServiceBeanMethod, mapperServiceBean, ew);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }
}

接口CommonService；

package com.eshore.wbtimer.executor.service;

/**
 * @author 
 * @Description:
 * @date 2019/3/21 14:48
 */
public interface CommonService {
    public boolean commonMapperSave(Class<?> bean, Object dataBean);

    public boolean commonMapperSelect(String className);
}