userserviceimpl.java

来自「电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tom」· Java 代码 · 共 169 行

package com.tarena.netctoss.model.biz;

import java.util.*;
import org.hibernate.*;
import com.tarena.util.*;
import com.tarena.netctoss.model.biz.entity.ServiceUser;
import com.tarena.netctoss.model.biz.entity.User;
import com.tarena.netctoss.model.persist.*;

public class UserServiceImpl implements IUserService {
	
	public void add(User user) {
		Session session = HibernateFactoryManager.getSession();
		Transaction t = session.beginTransaction();
		IUserDAO dao = DAOFactory.getUserDAO();
		try {
			dao.insert(user);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}

	public void remove(Long user_id) {
		Session session = HibernateFactoryManager.getSession();
		Transaction t = session.beginTransaction();
		IUserDAO dao = DAOFactory.getUserDAO();
		try {
			User user =dao.findUserByID(user_id);
			dao.delete(user);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}

	public List<User> findAll() {
		List<User> users = null;
		Session session = HibernateFactoryManager.getSession();
		IUserDAO dao = DAOFactory.getUserDAO();
		Transaction t = session.beginTransaction();
		try {
			users = dao.findAll();
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
		return users;
	}

	public User findUser(String login_name, String login_password) {
		User user = null;
		Session session = HibernateFactoryManager.getSession();
		IUserDAO dao = DAOFactory.getUserDAO();
		Transaction t = session.beginTransaction();
		try {
			user = dao.findUser(login_name, login_password);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
		return user;
	}

	public void modify(User user) {
		Session session = HibernateFactoryManager.getSession();
		IUserDAO dao = DAOFactory.getUserDAO();
		Transaction t = session.beginTransaction();
		try {
			dao.update(user);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}
	
	public List<ServiceUser> findByName(String login_name){
		List<ServiceUser> serviceUsers = null;
		Session session = HibernateFactoryManager.getSession();
		IUserDAO udao = DAOFactory.getUserDAO();
		IServiceUserDAO sdao = DAOFactory.getServiceUserDAO();
		Transaction t = session.beginTransaction();
		try {
			User user = udao.findUserByLogin_Name(login_name);
			serviceUsers = sdao.findByUser(user);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
		return serviceUsers;
	}
	
	public User findByID(Long user_id){
		User user = null;
		Session session = HibernateFactoryManager.getSession();
		IUserDAO dao = DAOFactory.getUserDAO();
		Transaction t = session.beginTransaction();
		try {
			user = dao.findUserByID(user_id);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
		return user;
	}
	
	public void modify(Long user_id,int status){
		Session session = HibernateFactoryManager.getSession();
		IUserDAO udao = DAOFactory.getUserDAO();
		IServiceUserDAO sdao = DAOFactory.getServiceUserDAO();
		Transaction t = session.beginTransaction();
		try {
			User user = udao.findUserByID(user_id);
			user.setUser_status(status);
			List<ServiceUser> serviceUsers = sdao.findByUser(user);
			Iterator<ServiceUser> it = serviceUsers.iterator(); 
			while(it.hasNext()){
				ServiceUser s_user = it.next();
				s_user.setService_user_status(status);
				sdao.update(s_user);
			}
			udao.update(user);
			t.commit();
		} catch (UserException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}
}