userdaoimpl.java

评分系统,acegi+JSF+spring+hibernate,可上传附件

package com.sgm.partybranch.persistence.sysadmin.hibernateImpl;

import java.util.Date;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.dao.DataAccessException;

import com.sgm.partybranch.common.constants.ErrorCode;
import com.sgm.partybranch.persistence.PaginationHibernateDaoSupport;
import com.sgm.partybranch.persistence.sysadmin.UserDAO;
import com.sgm.partybranch.vo.sysadmin.PartyBranch;
import com.sgm.partybranch.vo.sysadmin.PartyGroup;
import com.sgm.partybranch.vo.sysadmin.User;

public class UserDAOImpl extends PaginationHibernateDaoSupport implements
		UserDAO {
	private static final Log log = LogFactory.getLog(UserDAOImpl.class);
	// property constants
	public static final String ACCOUNT = "account";
	public static final String ENABLED = "enabled";
	public static final String USERNAME = "username";
	public static final String STAFF_NO = "staffNo";
	public static final String PARTY_BRANCH = "partyBranch";
	public static final String PARTY_GROUP = "partyGroup";

	public void create(User user) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("creting user: " + user);
		}
		try {
			getHibernateTemplate().save(user);
			log.debug("create user: " + user + "successful");
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE + "create user "
					+ user + "failed");
			throw e;
		}

	}

	public void delete(User user) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("deleting user: " + user);
		}
		try {
			getHibernateTemplate().delete(user);
			log.debug("delete user: " + user + "successful");
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE + "delete user "
					+ user + "failed");
			throw e;
		}

	}

	public List<User> getAllUsers(Integer offset, Integer pageSize)
			throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting all users");
		}
		List<User> result = null;
		try {
			String hql = "from User";
			result = findByPage(hql, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ " getting all users failed");
			throw e;
		}
	}

	public List<User> getUserByAccount(String account, Integer offset,
			Integer pageSize) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting User By Account:" + account);
		}
		List<User> result = null;
		try {
			String hql = getPropertyHql(ACCOUNT);
			result = findByPage(hql, account, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ "get user by account " + account + "failed", e);
			throw e;
		}
	}

	public User getUserById(String uuid) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting user by id: " + uuid);
		}
		try {
			User user = (User) getHibernateTemplate().get(User.class, uuid);
			return user;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE + "get user by id: "
					+ uuid + "failed");
			throw e;
		}
	}

	public List<User> getUserByUsername(String username, Integer offset,
			Integer pageSize) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting User By username:" + username);
		}
		List<User> result = null;
		try {
			String hql = getPropertyHql(USERNAME);
			result = findByPage(hql, username, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ "get user by username " + username + "failed", e);
			throw e;
		}
	}

	public List<User> getUsersByPartyBranch(PartyBranch partyBranch,
			Integer offset, Integer pageSize) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting User By partyBranch:" + partyBranch);
		}
		List<User> result = null;
		try {
			String hql = getPropertyHql(PARTY_BRANCH);
			result = findByPage(hql, partyBranch, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ "get users by partyBranch " + partyBranch + "failed", e);
			throw e;
		}
	}

	public List<User> getUsersByPartyGroup(PartyGroup partyGroup,
			Integer offset, Integer pageSize) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting User By partyGroup:" + partyGroup);
		}
		List<User> result = null;
		try {
			String hql = getPropertyHql(PARTY_GROUP);
			result = findByPage(hql, partyGroup, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ "get users by partyGroup " + partyGroup + "failed", e);
			throw e;
		}
	}

	public List<User> getUsersByStaffNo(String staffNo, Integer offset,
			Integer pageSize) throws DataAccessException {
		if (log.isDebugEnabled()) {
			log.debug("getting User By staffNo:" + staffNo);
		}
		List<User> result = null;
		try {
			String hql = getPropertyHql(STAFF_NO);
			result = findByPage(hql, staffNo, offset, pageSize);
			return result;
		} catch (DataAccessException e) {
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE
					+ "get user by staffNo " + staffNo + "failed", e);
			throw e;
		}
	}

	public void update(User user) throws DataAccessException {
		if(log.isDebugEnabled()){
			log.debug("updating user:" + user);
		}
		try{
			getHibernateTemplate().update(user);
			log.debug("update user: "+user+"successful");
		}catch(DataAccessException e){
			log.error(ErrorCode.DATA_ACCESS_EXCEPTION_CODE+"update user"+user+"failed");
			throw e;
		}

	}

	private String getPropertyHql(String property) {
		return "from User as u where u." + property + "= ?";
	}
	
/**	public static void main(String[] args){
		ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(
		"applicationContext.xml");
		
		UserDAOImpl ud=(UserDAOImpl) ctx.getBean("userDAO");
		PartyBranchDAOImpl pbd=(PartyBranchDAOImpl) ctx.getBean("partyBranchDAO");
		PartyBranch pb=pbd.getPartyBranchById("40288a8a1e07d8a3011e07d8a5a00001");
		List<User> users=ud.getUsersByPartyBranch(pb, null, null);
		System.out.println(users.isEmpty());
		//pbd.create(pb);
		//System.out.println(ud.getUsersByPartyBranch(partyBranch, offset, pageSize));		
	}*/

}