documentprocessbean.java

OBPM是一个开源

package cn.myapps.core.dynaform.document.ejb;

import java.util.Collection;
import java.util.Date;

import org.apache.commons.beanutils.PropertyUtils;

import cn.myapps.base.action.ParamsTable;
import cn.myapps.base.dao.DAOFactory;
import cn.myapps.base.dao.DataPackage;
import cn.myapps.base.dao.IBaseDAO;
import cn.myapps.base.dao.PersistenceUtils;
import cn.myapps.base.dao.ValueObject;
import cn.myapps.base.ejb.BaseProcessBean;
import cn.myapps.core.dynaform.document.dao.DocumentDAO;
import cn.myapps.core.dynaform.form.action.ImpropriateException;
import cn.myapps.core.user.action.WebUser;
import cn.myapps.core.user.ejb.UserVO;

public class DocumentProcessBean extends BaseProcessBean implements
		DocumentProcess {
	public void doCreate(ValueObject vo, WebUser user) throws Exception {
		super.doCreate(vo, user);
	}

	public void doCreate(ValueObject vo) throws Exception {
		super.doCreate(vo);
	}

	public void doUpdate(ValueObject vo) throws Exception {
		if (vo != null) {
			((Document) vo).setIstmp(false);
		}

		try {
			PersistenceUtils.beginTransaction();
			ValueObject po = getDAO().find(vo.getId());
			if (po != null
					&& ((Document) vo).getVersion() != ((Document) po)
							.getVersion())
				throw new ImpropriateException(
						"Already having been impropriate by others , can not Save");
			((Document) vo).setVersion(((Document) vo).getVersion() + 1);
			if (po != null) {
				Collection childs = ((Document) po).getChilds();
				PropertyUtils.copyProperties(po, vo);
				((Document) po).setItems(((Document) vo).getItems());
				((Document) po).setChilds(childs);
				getDAO().update(po);
			} else {
				getDAO().update(vo);
			}

			PersistenceUtils.commitTransaction();
		} catch (ImpropriateException e) {
			PersistenceUtils.rollbackTransaction();
			throw e;
		} catch (Exception e) {
			e.printStackTrace();
			PersistenceUtils.rollbackTransaction();
		}
	}

	public void doUpdate(ValueObject vo, WebUser user) throws Exception {
		if (vo != null) {
			((Document) vo).setIstmp(false);
		}
		super.doUpdate(vo, user);
	}

	public Document doStore(Document docVO, WebUser user) throws Exception {
		((DocumentDAO) getDAO()).create(docVO, user);
		// dao.store(docVO, user);

		return docVO;
	}

	public DataPackage queryByDQL(String dql, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).queryByDQL(dql, application);
	}

	public DataPackage queryByFormName(String formname, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).queryByFormName(formname, application);
	}

	public Document findByItemAndFormname(String itemName, String itemValue,
			String formanme, String application) throws Exception {
		return ((DocumentDAO) getDAO()).findByItemAndFormname(itemName,
				itemValue, formanme, application);
	}

	public void removeByItemAndFormname(String itemName, String itemValue,
			String formname, String application) throws Exception {
		((DocumentDAO) getDAO()).removeByItemAndFormname(itemName, itemValue,
				formname, application);
	}

	public Collection findDocsByItemAndFormname(String itemName,
			String itemValue, String formanme, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).findDocsByItemAndFormname(itemName,
				itemValue, formanme, application);
	}

	public Collection queryByHql(String hql, String application)
			throws Exception {
		ParamsTable params = new ParamsTable();
		if (application == null || application.trim().length() > 0)
			params.setParameter("application", application);
		return ((DocumentDAO) getDAO()).getDatas(hql, params);
	}

	public Collection queryByHqlWithCache(String hql, String application)
			throws Exception {
		ParamsTable params = new ParamsTable();
		if (application == null || application.trim().length() > 0)
			params.setParameter("application", application);
		return ((DocumentDAO) getDAO()).getDatas(hql, params);
	}

	public DataPackage queryByDQLPage(String dql, int page, int lines,
			String application) throws Exception {
		return ((DocumentDAO) getDAO()).queryByDQLPage(dql, page, lines,
				application);
	}

	public DataPackage queryByDQL(String dql, ParamsTable params,
			String application) throws Exception {
		return ((DocumentDAO) getDAO()).queryByDQL(dql, params, application);
	}

	public DataPackage queryByDQLPage(String dql, ParamsTable params, int page,
			int lines, String application) throws Exception {
		return ((DocumentDAO) getDAO()).queryByDQLPage(dql, params, page,
				lines, application);
	}

	public DataPackage queryByHQL(String dql, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).queryByHQL(dql, application);
	}

	public DataPackage queryByHQLPage(String dql, int page, int lines,
			String application) throws Exception {
		return ((DocumentDAO) getDAO()).queryByHQLPage(dql, page, lines,
				application);
	}

	protected IBaseDAO getDAO() throws Exception {
		return DAOFactory.getDefaultDAO(Document.class.getName());
	}

	public DataPackage queryByDQLAndDocumentLastModifyDate(String dql,
			Date date, int page, int lines, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).queryByDQLAndDocumentLastModifyDate(
				dql, date, page, lines, application);
	}

	public int getNeedExportDocumentTotal(String dql, Date date,
			String application) throws Exception {
		return ((DocumentDAO) getDAO()).getNeedExportDocumentTotal(dql, date,
				application);

	}

	public String getFormFullName(String formid, String application)
			throws Exception {
		return ((DocumentDAO) getDAO()).findFormFullName(formid, application);

	}

	public Collection doQueryField(String fieldName, String moduleid,
			String application) throws Exception {
		return ((DocumentDAO) getDAO()).queryField(fieldName, moduleid,
				application);
	}
}