counterprocessbean.java

OBPM是一个开源

package cn.myapps.core.counter.ejb;

import cn.myapps.base.dao.DAOFactory;
import cn.myapps.base.dao.IBaseDAO;
import cn.myapps.base.dao.PersistenceUtils;
import cn.myapps.base.ejb.BaseProcessBean;
import cn.myapps.core.counter.dao.CounterDAO;
import cn.myapps.util.sequence.Sequence;

public class CounterProcessBean extends BaseProcessBean implements
		CounterProcess {
	private static final long serialVersionUID = -3768074774695007780L;

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.myapps.core.counter.ejb.CounterProcess#doRemoveByName(java.lang.String)
	 */
	public void doRemoveByName(String name,String application) throws Exception {
		try {
			PersistenceUtils.beginTransaction();
			((CounterDAO) getDAO()).removeByName(name,application);
			PersistenceUtils.commitTransaction();
		} catch (Exception ex) {
			PersistenceUtils.rollbackTransaction();
		}
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.myapps.core.counter.ejb.CounterProcess#getNextValue(java.lang.String)
	 */
	public int getNextValue(String name,String application) throws Exception {
		try { 
			PersistenceUtils.beginTransaction();
			CounterDAO dao = (CounterDAO) getDAO();
			if (name != null) {
				CounterVO vo = dao.findByName(name,application);
				if (vo == null) {
					vo = new CounterVO();
					vo.setId(Sequence.getSequence());
					vo.setApplicationid(application);
					vo.setName(name);
					vo.setCounter(1);
					dao.create(vo);
				} else {
					vo.setCounter(vo.getCounter() + 1);
					dao.update(vo);
				}
				PersistenceUtils.commitTransaction();

				return vo.getCounter();
			}
		} catch (Exception e) {
			e.printStackTrace();
			PersistenceUtils.rollbackTransaction();
		}
		return 0;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.myapps.base.ejb.BaseProcessBean#getDAO()
	 */
	protected IBaseDAO getDAO() throws Exception {
		return DAOFactory.getDefaultDAO(CounterVO.class.getName());
	}
}