trainservice.java

HR系统模拟企业对内部职员的管理

/*$Id: TrainService.java,v 1.1 2008/07/15 03:38:23 liqi Exp $
 *--------------------------------------
 * Apusic (Kingdee Middleware)
 *---------------------------------------
 * Copyright By Apusic ,All right Reserved
 * author   date   comment
 * chenhongxin  2008-4-14  Created
*/
package org.operamasks.example.ejb.hr.service;

import java.util.List;

import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;

import org.operamasks.example.ejb.hr.entity.Train;

/** 
 * @generated
 */
@Stateless
@SuppressWarnings("unchecked")
public class TrainService implements ITrainService {
	/** 
	 * @generated default persist manager
	 */
	@PersistenceContext
	private EntityManager _innerDao;

	/** 
	 * @generated default persist method 
	 */
	@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
	public void createTrain(Train vo) {
		_innerDao.persist(vo);
	}

	/** 
	 * @generated default persist method
	 */
	@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
	public void modifyTrain(Train vo) {
		_innerDao.merge(vo);
	}

	/** 
	 * @generated default remove method
	 */
	@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
	public void removeTrain(Train vo) {
		Train managed = _innerDao.merge(vo);
		_innerDao.remove(managed);
	}

	/** 
	 * @generated default query method
	 */
	@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
	public List<Train> listTrain() {
		Query q = _innerDao.createQuery("SELECT o FROM Train o ");
		return q.getResultList();
	}

	@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
	public Train findById(String id) {
		Query q = _innerDao.createQuery("SELECT o FROM Train o where o.id='" + id + "'");
		return (Train)q.getSingleResult();
	}

	public List<Object[]> getDepartmentReport() {
		StringBuilder buf = new StringBuilder();
		buf.append("SELECT o.employee.department,");
		buf.append("COUNT(o.employee),");
		buf.append("SUM(o.period),");
		buf.append("COUNT(DISTINCT o.employee.id) ");
		buf.append("FROM Train o ");
		buf.append("GROUP BY o.employee.department");
		Query q = _innerDao.createQuery(buf.toString());
		return q.getResultList();
	}
	
	public List<Object[]> getRankReport() {
		StringBuffer buf = new StringBuffer();
		buf.append("SELECT o.employee.rank,");
		buf.append("COUNT(o.employee),");
		buf.append("SUM(o.period),");
		buf.append("COUNT(DISTINCT o.employee.id) ");
		buf.append("FROM Train o ");
		buf.append("GROUP BY o.employee.rank");
		Query q = _innerDao.createQuery(buf.toString());
		return q.getResultList();
	}
}