usershandlerbean.java

j2ee源码

package com.leeman.wkexs.master.users.handler;

/*
 * Bean implementation class for Enterprise Bean: ActorManagementHandler
 */
import java.sql.*;
import java.util.*;
import javax.ejb.*;
import javax.naming.*;
import java.util.ArrayList;

import com.leeman.wkexs.master.users.dao.*;
import com.leeman.wkexs.master.users.entity.*;
import com.leeman.common.db.*;
import com.leeman.common.util.*;
import com.leeman.common.data.Dao;

public class UsersHandlerBean implements javax.ejb.SessionBean {
	private javax.ejb.SessionContext mySessionCtx;
	
	private UsersDao usersDao;
	
	/**
	 * getSessionContext
	 */
	public javax.ejb.SessionContext getSessionContext() {
		return mySessionCtx;
	}
	/**
	 * setSessionContext
	 */
	public void setSessionContext(javax.ejb.SessionContext ctx) {
		mySessionCtx = ctx;
	}
	/**
	 * ejbCreate
	 */
	public void ejbCreate() throws javax.ejb.CreateException {
	}
	/**
	 * ejbActivate
	 */
	public void ejbActivate() {
	}
	/**
	 * ejbPassivate
	 */
	public void ejbPassivate() {
	}
	/**
	 * ejbRemove
	 */
	public void ejbRemove() {
		if (usersDao != null){
			usersDao.releaseDbConn();
		}
	}
	
	private UsersHome getUsersHome() throws javax.naming.NamingException{	
		return (UsersHome)EjbGetter.getEJBHome(Users.JNDINAME, UsersHome.class);
	}	
	
	public void add(UsersVO usersVO) throws Exception
	{
		try{
			Users users = getUsersHome().create(usersVO.getCompany_id(), usersVO.getUser_id());
			users.setCreate_dttm(usersVO.getCreate_dttm());
			users.setCreate_by(usersVO.getCreate_by());
			update(usersVO);
		}
		catch(Exception e)
		{
			mySessionCtx.setRollbackOnly();
			throw e;
		}
	}

	public void update(UsersVO usersVO) throws Exception
	{
		try{
			UsersHome uhome = getUsersHome();
			Users users = uhome.findByPrimaryKey(new UsersKey(usersVO.getCompany_id(), usersVO.getUser_id()));
			users.setName(usersVO.getName());
			users.setPassword(usersVO.getPassword());
			users.setActive(usersVO.getActive());
			users.setRole_id(usersVO.getRole_id());
			users.setDept_id(usersVO.getDept_id());
			users.setPosition(usersVO.getPosition());
			users.setEmail(usersVO.getEmail());
			users.setFax(usersVO.getFax());
			users.setTelephone(usersVO.getTelephone());
			users.setApproval_password(usersVO.getApproval_password());
			users.setLast_modify_dttm(usersVO.getLast_modify_dttm());
			users.setLast_modify_by(usersVO.getLast_modify_by());
		}
		catch(Exception e)
		{
			mySessionCtx.setRollbackOnly();
			throw e;
		}
	}
	
	public void delete(UsersVO usersVO) throws Exception
	{
		Users users = getUsersHome().findByPrimaryKey(new UsersKey(usersVO.getCompany_id(), usersVO.getUser_id()));
		users.remove(); 
	}
	
	public boolean isExist(UsersVO usersKey) throws Exception
	{
		try{
			Users users = getUsersHome().findByPrimaryKey(new UsersKey(usersKey.getCompany_id(), usersKey.getUser_id()));
			return true;
		}
		catch(ObjectNotFoundException ex){
			return false;
		}
	}
		
	public UsersVO get(UsersVO usersKey) throws Exception{
		try
		{		
			UsersHome uhome = getUsersHome();
			Users users = uhome.findByPrimaryKey(new UsersKey(usersKey.getCompany_id(), usersKey.getUser_id()));
			
			UsersVO usersVO = new UsersVO();
			usersVO.setCompany_id(usersKey.getCompany_id());
			usersVO.setUser_id(usersKey.getUser_id());
			usersVO.setName(users.getName());
			usersVO.setPassword(users.getPassword());
			usersVO.setActive(users.getActive());
			usersVO.setRole_id(users.getRole_id());
			usersVO.setDept_id(users.getDept_id());
			usersVO.setPosition(users.getPosition());
			usersVO.setEmail(users.getEmail());
			usersVO.setTelephone(users.getTelephone());
			usersVO.setFax(users.getFax());
			usersVO.setApproval_password(users.getApproval_password());
			usersVO.setCreate_dttm(users.getCreate_dttm());
			usersVO.setCreate_by(users.getCreate_by());
			usersVO.setLast_modify_dttm(users.getLast_modify_dttm());
			usersVO.setLast_modify_by(users.getLast_modify_by());
			
			return usersVO;
		}
		catch(ObjectNotFoundException e)
		{
			return null;
		}
	}
		
	public long getListCount(UsersSO usersSO) throws Exception{
		initUserDao();
		return usersDao.getListCount(usersSO);
	}
	
	public ArrayList getList(UsersSO usersSO, int fr, int to) throws Exception{
		initUserDao();
		return usersDao.getList(usersSO, fr, to);
	}
	
	public void initUserDao(){
		if (usersDao == null){
			usersDao = new UsersDao(); 
		}
	}
	
	public long getUserIdCount(UsersVO userVO, String table) throws Exception{
			initUserDao();
		return usersDao.getUserIdCount(userVO,table);
	}
}