项目手脚架(ssh).zip

package com.jzwb.dao.impl; import com.jzwb.dao.BaseDao; import com.jzwb.common.Filter; import com.jzwb.common.Filter.Operator; import com.jzwb.common.Order; import com.jzwb.common.Order.Direction; import com.jzwb.common.Page; import com.jzwb.common.Pageable; import com.jzwb.entity.OrderEntity; import org.apache.commons.lang.StringUtils; import javax.persistence.EntityManager; import javax.persistence.FlushModeType; import javax.persistence.LockModeType; import javax.persistence.PersistenceContext; import javax.persistence.TypedQuery; import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criteria.CriteriaQuery; import javax.persistence.criteria.Fetch; import javax.persistence.criteria.From; import javax.persistence.criteria.Join; import javax.persistence.criteria.Path; import javax.persistence.criteria.Predicate; import javax.persistence.criteria.Root; import javax.persistence.criteria.Selection; import java.io.Serializable; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; /** * Dao - 基类 */ public abstract class BaseDaoImpl<T, ID extends Serializable> implements BaseDao<T, ID> { //实体类类型 private Class<T> entityClass; //别名数 private static volatile long aliasCount = 0; @PersistenceContext protected EntityManager entityManager; public BaseDaoImpl() { Type type = getClass().getGenericSuperclass(); Type[] parameterizedType = ((ParameterizedType) type).getActualTypeArguments(); entityClass = (Class<T>) parameterizedType[0]; } @Override public T find(ID id) { if (id != null) return entityManager.find(entityClass, id); return null; } @Override public T find(ID id, LockModeType lockModeType) { if (id != null) { if (lockModeType != null) return entityManager.find(entityClass, id, lockModeType); else return entityManager.find(entityClass, id); } return null; } @Override public List<T> findList(Integer first, Integer count, List<Filter> filters, List<Order> orders) { CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); CriteriaQuery<T> criteriaQuery = criteriaBuilder.createQuery(entityClass); criteriaQuery.select(criteriaQuery.from(entityClass)); return findList(criteriaQuery, first, count, filters, orders); } @Override public List<Object[]> findList(Integer first, Integer count, List<Filter> filters, List<Order> orders, String[] properties) { if (properties == null || properties.length <= 0) { return null; } CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); CriteriaQuery<Object[]> criteriaQuery = criteriaBuilder.createQuery(Object[].class); Root<T> root = criteriaQuery.from(entityClass); List<Selection<?>> list = new ArrayList<>(); for (String property : properties) { list.add(root.get(property)); } criteriaQuery.multiselect(list); return findList(criteriaQuery, root, first, count, filters, orders); } @Override public List<Map<String, Object>> findListMap(Integer first, Integer count, List<Filter> filters, List<Order> orders, String... properties) { List<Object[]> list = findList(first, count, filters, orders, properties); if (list == null || list.isEmpty()) { return Collections.emptyList(); } List<Map<String, Object>> listMap = new ArrayList<>(); if (properties.length == 1) { for (Object object : list) { Map<String, Object> map = new HashMap<>(); map.put(properties[0], object); listMap.add(map); } } else { for (Object[] objects : list) { Map<String, Object> map = new HashMap<>(); for (int i = 0; i < properties.length; i++) { map.put(properties[i], objects[i]); } listMap.add(map); } } return listMap; } @Override public Page<T> findPage(Pageable pageable) { CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); CriteriaQuery<T> criteriaQuery = criteriaBuilder.createQuery(entityClass); criteriaQuery.select(criteriaQuery.from(entityClass)); return findPage(criteriaQuery, pageable); } @Override public Page<Object[]> findPage(Pageable pageable, String[] properties) { CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); CriteriaQuery<Object[]> criteriaQuery = criteriaBuilder.createQuery(Object[].class); Root<T> root = criteriaQuery.from(entityClass); List<Selection<?>> list = new ArrayList<>(); for (String property : properties) { list.add(root.get(property)); } criteriaQuery.multiselect(list); return findPage(criteriaQuery, pageable, root); } @Override public Page<Map<String, Object>> findPageMap(Pageable pageable, String... properties) { Page<Object[]> page = findPage(pageable, properties); long total = page.getTotal(); List<Object[]> list = page.getContent(); if (list == null || list.isEmpty()) { return new Page<>(Collections.emptyList(), total, pageable); } List<Map<String, Object>> listMap = new ArrayList<>(); if (properties.length == 1) { for (Object object : list) { Map<String, Object> map = new HashMap<>(); map.put(properties[0], object); listMap.add(map); } } else { for (Object[] objects : list) { Map<String, Object> map = new HashMap<>(); for (int i = 0; i < properties.length; i++) { map.put(properties[i], objects[i]); } listMap.add(map); } } return new Page<>(listMap, total, pageable); } @Override public long count(Filter... filters) { CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); CriteriaQuery<T> criteriaQuery = criteriaBuilder.createQuery(entityClass); criteriaQuery.select(criteriaQuery.from(entityClass)); return count(criteriaQuery, filters != null ? Arrays.asList(filters) : null); } @Override public void persist(T entity) { entityManager.persist(entity); } @Override public T merge(T entity) { return entityManager.merge(entity); } @Override public void remove(T entity) { if (entity != null) entityManager.remove(entity); } @Override public void refresh(T entity) { if (entity != null) entityManager.refresh(entity); } @Override public void refresh(T entity, LockModeType lockModeType) { if (entity != null) { if (lockModeType != null) entityManager.refresh(entity, lockModeType); else entityManager.refresh(entity); } } @Override public ID getIdentifier(T entity) { return (ID) entityManager.getEntityManagerFactory().getPersistenceUnitUtil().getIdentifier(entity); } @Override public boolean isManaged(T entity) { return entityManager.contains(entity); } public void detach(T entity) { entityManager.detach(entity); } @Override public void lock(T entity, LockModeType lockModeType) { if (entity != null && lockModeType != null) entityManager.lock(entity, lockModeType); } @Override public void clear() { entityManager.clear(); } @Override public void flush() { entityManager.flush(); } protected List<T> findList(CriteriaQuery<T> criteriaQuery, Integer first, Integer count, List<Filter> filters, List<Order> orders) { CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder(); Root<T> root = getRoot(criteriaQuery); addRestrictions(criteriaQuery, filters); addOrders(criteriaQuery, orders); if (criteriaQuery.getOrderList().isEmpty()) { if (OrderEntity.class.isAssignableFrom(entityClass)) criteriaQuery.orderBy(criteriaBuilder.asc(root.get(OrderEntity.ORDER_PROPERTY_NAME))); else criteriaQuery.orderBy(criteriaBuilder.desc(root.get(OrderEntity.CREATE_DATE_PROPERTY_NAME))); } TypedQuery<T> query = entityManager.createQuery(criteriaQuery).setFlushMode(FlushModeType.COMMIT); if (first != null) query.setFirstResult(first); if (count != null) query.setMaxResults(count); return query.getResultList(); } protected List<Object[]> f