java 多表连接查询模板实现类

package com.mes.em.service.common.impl;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONArray;
import com.mes.em.service.common.FactoryService;
import com.mes.em.dto.common.Condition;
import com.mes.em.dto.common.JoinPocoInfos;
import com.mes.em.dto.common.SqlParams;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.query.NativeQuery;
import org.hibernate.query.Query;
import org.hibernate.transform.Transformers;
import org.springframework.stereotype.Service;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;


@Service
public class FactoryServiceImpl implements FactoryService {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public List selectFactoryHql(String hql, List> sqlParams, List conList, Class cls) {

        Session session = (Session) entityManager.getDelegate();
        Query hqlQuery = session.createQuery(hql, cls);
        if (null != sqlParams) {
            sqlParams.forEach(e -> {
                hqlQuery.setParameterList(e.getParamName(), e.getParamValues());
            });
        }
        if (null != conList) {
            conList.forEach(e -> {
                hqlQuery.setParameter(e.getParamName(), e.getParamValue());
            });
        }
        List list = hqlQuery.getResultList();
        return list;
    }

    @Override
    public List selectFactory(String sql, Class cls) {
        javax.persistence.Query nativeQuery = entityManager.createNativeQuery(sql);
        List list = new ArrayList<>();
        List> resultList = nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
        if (CollUtil.isNotEmpty(resultList)) {
            JSONArray jsonArray = new JSONArray();
            jsonArray.addAll(resultList);
            list = jsonArray.toJavaList(cls);
        }
        return list;
    }
    
    @Override
    public List selectFactory(String sql, List joinPocoInfos, String table, List> sqlParams, List conList, Class clazz) {
        Session session = (Session) entityManager.getDelegate();
        NativeQuery sqlQuery = session.createSQLQuery(sql);
        if (StrUtil.isNotBlank(table)) {
            sqlQuery.addEntity(table, clazz);
        } else {
            sqlQuery.addEntity(clazz);
        }
        if (CollUtil.isNotEmpty(joinPocoInfos)) {
            joinPocoInfos.forEach(e -> {
                sqlQuery.addJoin(e.getJoinPocoAlias(), e.getJoinPocoPath());
            });
        }
        if (CollUtil.isNotEmpty(sqlParams)) {
            sqlParams.forEach(e -> {
                sqlQuery.setParameterList(e.getParamName(), e.getParamValues());
            });
        }
        if (CollUtil.isNotEmpty(conList)) {
            conList.forEach(e -> {
                sqlQuery.setParameter(e.getParamName(), e.getParamValue());
            });
        }
        List list = sqlQuery.getResultList();

        return list;
    }

    @Override
    public List selectFactoryDto(String sql, List> sqlParams, List conList, Class clazz) {
        javax.persistence.Query nativeQuery = entityManager.createNativeQuery(sql);
        List list = new ArrayList<>();
        if(CollUtil.isNotEmpty(sqlParams)){
            sqlParams.forEach(e ->{
                nativeQuery.setParameter(e.getParamName(),e.getParamValues());
            });
        }
        if(CollUtil.isNotEmpty(conList)){
            conList.forEach(e ->{
                nativeQuery.setParameter(e.getParamName(),e.getParamValue());
            });
        }
        List> resultList = nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
        if (CollUtil.isNotEmpty(resultList)) {
            JSONArray jsonArray = new JSONArray();
            jsonArray.addAll(resultList);
            list = jsonArray.toJavaList(clazz);
        }
        return list;
    }

    @Override
    public List selectFactory(String sql, List> sqlParams, List conList, Class cls) {
        javax.persistence.Query nativeQuery = entityManager.createNativeQuery(sql);
        List list = new ArrayList<>();
        if(CollUtil.isNotEmpty(sqlParams)){
            sqlParams.forEach(e ->{
                nativeQuery.setParameter(e.getParamName(),e.getParamValues());
            });
        }
        if(CollUtil.isNotEmpty(conList)){
            conList.forEach(e ->{
                nativeQuery.setParameter(e.getParamName(),e.getParamValue());
            });
        }
        List> resultList = nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
        if (CollUtil.isNotEmpty(resultList)) {
            JSONArray jsonArray = new JSONArray();
            jsonArray.addAll(resultList);
            list = jsonArray.toJavaList(cls);
        }
        return list;
    }

    @Override
    public List selectFactory(String sql, List conList, Class cls) {
        javax.persistence.Query nativeQuery = entityManager.createNativeQuery(sql);
        List list = new ArrayList<>();
        if(CollUtil.isNotEmpty(conList)){
            conList.forEach(e ->{
                nativeQuery.setParameter(e.getParamName(),e.getParamValue());
            });
        }
        List> resultList = nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
        if (CollUtil.isNotEmpty(resultList)) {
            JSONArray jsonArray = new JSONArray();
            jsonArray.addAll(resultList);
            list = jsonArray.toJavaList(cls);
        }
        return list;
    }
}