UserFacade.java

package fi.insomnia.bortal.facade;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import javax.ejb.EJB;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;
import javax.persistence.metamodel.SingularAttribute;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import fi.insomnia.bortal.beans.EventBeanLocal;
import fi.insomnia.bortal.facade.callbacks.FacadeCallback;
import fi.insomnia.bortal.facade.callbacks.OrderCallback;
import fi.insomnia.bortal.facade.callbacks.StringSearchPredicateCreator;
import fi.insomnia.bortal.model.User;
import fi.insomnia.bortal.model.User_;
import fi.insomnia.bortal.utilities.SearchQuery;
import fi.insomnia.bortal.utilities.SearchResult;

@Stateless
@LocalBean
public class UserFacade extends IntegerPkGenericFacade<User> {

	private static final Logger logger = LoggerFactory.getLogger(UserFacade.class);

	private static List<SingularAttribute<User, String>> SEARCHATTRS;

	static List<SingularAttribute<User, String>> getAttrlist() {
		if (SEARCHATTRS == null)
		{
			ArrayList<SingularAttribute<User, String>> buildAttrs = new ArrayList<SingularAttribute<User, String>>();

			buildAttrs.add(User_.nick);
			buildAttrs.add(User_.login);
			buildAttrs.add(User_.firstnames);
			buildAttrs.add(User_.lastname);
			buildAttrs.add(User_.email);
			buildAttrs.add(User_.phone);
			logger.warn("Initiating attrlist {}", buildAttrs);

			SEARCHATTRS = Collections.unmodifiableList(buildAttrs);
		}
		return SEARCHATTRS;
	}

	@EJB
	private EventBeanLocal eventBean;

	// final String[] NAMEFIELDS = { "nick", "login", "firstnames", "lastname",
	// "email" };

	//
	// public enum UserField {
	// id, nick, login, firstname, lastname
	// }

	public UserFacade() {
		super(User.class);
	}

	/**
	 * Find user by username.
	 * 
	 * @param login
	 */
	public User findByLogin(String login) {
		CriteriaBuilder cb = getEm().getCriteriaBuilder();
		CriteriaQuery<User> cq = cb.createQuery(User.class);
		Root<User> root = cq.from(User.class);
		cq.where(cb.equal(root.get(User_.login), login.toLowerCase().trim()));

		return getSingleNullableResult(getEm().createQuery(cq));
	}

	// public SearchResult<User> searchForName(String name) {
	// return super.searcher(0, 0,
	// new StringSearchPredicateCreator<User>(name, Userfields.values()),
	// new OrderCallback<User>(true, User_.login)
	// );
	// // return this.search(name, NAMEFIELDS, "login");
	// }

	@Override
	public void create(User user) {
		user.setLogin(user.getLogin().toLowerCase().trim());
		super.create(user);
	}

	@Override
	public User merge(User user) {
		user.setLogin(user.getLogin().toLowerCase().trim());
		return super.merge(user);
	}

	public SearchResult<User> searchAllUsers(SearchQuery search) {

		List<FacadeCallback<User>> callbacks = new ArrayList<FacadeCallback<User>>();
		if (search.getSort() == null || search.getSort().isEmpty()) {
			callbacks.add(new OrderCallback<User>(false, User_.id));
		} else {
			callbacks.add(new OrderCallback<User>(false, search.getSort()));
		}
		callbacks.add(new StringSearchPredicateCreator<User>(search.getSearch(), getAttrlist()));

		return super.searcher(search, callbacks);
		// return this.search(page, pagesize, query, NAMEFIELDS, sort);
	}

	// public long searchUserCount(String search) {
	// String query = null;
	// if (search != null) {
	// query = new
	// StringBuilder().append("%").append(search).append('%').toString();
	// }
	// return this.searchCount(query, NAMEFIELDS);
	// }

	public List<User> findByEmail(String email) {
		CriteriaBuilder cb = getEm().getCriteriaBuilder();
		CriteriaQuery<User> cq = cb.createQuery(User.class);
		Root<User> root = cq.from(User.class);
		cq.where(cb.equal(root.get(User_.email), email));

		return getEm().createQuery(cq).getResultList();
	}

	public void evict() {
		getEm().getEntityManagerFactory().getCache().evictAll();
	}

	public List<User> findAll()
	{
		CriteriaBuilder cb = getEm().getCriteriaBuilder();
		CriteriaQuery<User> cq = cb.createQuery(User.class);
		return getEm().createQuery(cq).getResultList();
	}

	// public SearchResult<User> searchEventUsers(SearchQuery query)
	// {
	// ArrayList<FacadeCallback<EventUser>> callbacks = new
	// ArrayList<FacadeCallback<EventUser>>();
	// callbacks.add(new OrderCallback<EventUser>(false, EventUser_.id));
	// callbacks.add(new EventLimiter(eventBean.getCurrentEvent()));
	//
	// CriteriaBuilder cb = getEm().getCriteriaBuilder();
	//
	// CriteriaQuery<User> listCQuery = cb.createQuery(User.class);
	// CriteriaQuery<Long> countCQuery = cb.createQuery(Long.class);
	//
	// Root<EventUser> listRoot = searchCallbacks(listCQuery, callbacks,
	// EventUser.class);
	// Root<EventUser> countRoot = searchCallbacks(countCQuery, callbacks,
	// EventUser.class);
	//
	// listCQuery.select(listRoot.join(EventUser_.user));
	// countCQuery.select(cb.count(countRoot.get(EventUser_.user)));
	//
	// TypedQuery<Long> countQ = getEm().createQuery(countCQuery);
	// TypedQuery<User> listQ = getEm().createQuery(listCQuery);
	//
	// if (query.getPagesize() > 0) {
	// listQ.setFirstResult(query.getPage() * query.getPagesize());
	// listQ.setMaxResults(query.getPagesize());
	// }
	// return new SearchResult<User>(listQ.getResultList(),
	// countQ.getSingleResult());
	// }

}