staffinfoservice.java

这是本人曾经在公司里用的,内部开发框架,基于struts+hibernate今天分享给大家

/**
 * 
 */
package cn.bway.admin.dao;

import java.sql.*;
import java.util.*;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.hibernate.Session;

import cn.bway.admin.vo.StaffInfoVO;
import cn.bway.common.BwayHibernateException;
import cn.bway.common.LoginConstants;
import cn.bway.common.Util;
import cn.bway.common.dao.BaseDAOHibernate;

/**
 * @author Kson
 *
 */
public class StaffInfoService extends BaseDAOHibernate{
	
	protected static final Logger log = LogManager.getLogger(StaffInfoService.class);
	Session session = null;	
	Connection conn = null;
	RoleInfoDAO roleInfo = null;
	
	   /**
     * ��ѯԱ��
     * @param vo StaffInfoVO
     * @return List
	 * @throws SQLException 
     * @throws BwayHibernateException
     */
    public List queryStaffInfo(StaffInfoVO vo) throws   BwayHibernateException
    {
        List arrayList = new ArrayList();
//        List list = new ArrayList();
        try {
            conn =  currentSession().connection();
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            arrayList = dao.queryStaffInfo(vo);
            
//            list.setPageSize(vo.getPageSize());
//            list.setRealPage(vo.getPageNo());
//            list.setList(arrayList);
//            list.setTotalItems(dao.queryStaffInfoCount(vo).intValue());

        } catch (BwayHibernateException ex) {
        	log.debug("��ѯԱ�����: "+ ex.getMessage());
        } catch (Exception ex2) {
            log.debug("��ѯԱ�����: "+ ex2.getMessage());
        }
        finally {
        	closeSession();
        }
        return arrayList;
    }

	/**
     * �޸�Ա����Ϣ
     * @param vo StaffInfoVO
     * @throws BwayHibernateException
     */
    public void modifyStaffInfo(StaffInfoVO vo) throws  BwayHibernateException  {
        try {
            conn = currentSession().connection();
            conn.setAutoCommit(false);
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            dao.updateStaffInfo(vo);
            conn.commit();
        } catch (Exception ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            try {
				throw ex;
			} catch (Exception e) {
				// TODO Auto-generated catch block
				log.info("�޸�Ա����Ϣ�����쳣: "+e.getMessage());
			}
        }
        finally {
        	closeSession();
        }
    }

    /**
     * ɾ��Ա��
     * @param vo StaffInfoVO
     * @throws BwayHibernateException
     */
    public void deleteStaffInfo(StaffInfoVO vo) throws BwayHibernateException {
        try {
            conn = currentSession().connection();
            conn.setAutoCommit(false);
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            dao.deleteStaffInfo(vo);
            conn.commit();
        } catch (BwayHibernateException ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            throw ex;
        } catch (Exception ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            log.info("ɾ��Ա��ҵ���߼��������: "+ ex.getMessage());
        }
        finally {
        	closeSession();
        }
    }

    /**
     * ���Ա��
     * @param vo StaffInfoVO
     * @throws BwayHibernateException
     */
    public void addStaffInfo(StaffInfoVO vo) throws BwayHibernateException {
        try {
            conn = currentSession().connection();
            conn.setAutoCommit(false);
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            dao.insertStaffInfo(vo);
            conn.commit();
        } catch (BwayHibernateException ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            throw ex;
        } catch (Exception ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            	log.info("���Ա�����: "+ex.getMessage());
            }            
        }
        finally {
        	closeSession();
        }
    }

    /**
     * ��ѯԱ��
     * @param vo StaffInfoVO
     * @return List
     * @throws BwayHibernateException
     */
    public List getStaffInfo(StaffInfoVO vo,Connection conn) throws BwayHibernateException  {
        List pageList = new ArrayList();
        try {
//            conn = currentSession().connection();
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            pageList = dao.getStaffInfo(vo);
//            pageList.setList(list);
        } catch (BwayHibernateException ex) {
            log.info("��ѯԱ�����: "+ex.getMessage());
            throw ex;
        } catch (Exception ex2) {
            log.info("��ѯԱ�����: "+ex2.getMessage());
        }
//        finally {
//        	closeSession();
//        }
        return pageList;
    }
    
    /**
     * ��ȡ����
     * @return int
     * @throws BwayHibernateException
     */
    public String querySeq(String tmpTableName) throws BwayHibernateException  {
    	String a = "0";
        try {
            conn = currentSession().connection();
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            a = dao.querySeq(tmpTableName);
        } catch (BwayHibernateException ex) {
        	ex.printStackTrace();
        } catch (Exception ex) {
        	ex.printStackTrace();
        	log.info(ex.getMessage());
        }
        finally {
        	closeSession();
        }
        return a;
    }

    /**
     * �жϵ�ǰ�û��Ƿ���и�Ȩ��
     * @param rightId String
     * @return boolean
     */
    public static boolean isAuth (HttpServletRequest request, String rightId) throws BwayHibernateException {
    	boolean a = false;
        Connection conn = null;
        try {
            conn =  currentSession().connection();
            HttpSession session = request.getSession();
            String staffId = (String) session.getAttribute(LoginConstants.GLOBLE_STAFF_ID);
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            a = dao.isAuth(staffId, rightId);
        } catch (BwayHibernateException ex) {
            log.info("�жϵ�ǰ�û��Ƿ���и�Ȩ�޳��:" + ex);
            throw ex;
        } catch (Exception ex2) {
            log.info("�жϵ�ǰ�û��Ƿ���и�Ȩ�޳��:" + ex2.getMessage());
        }
        finally {
        	closeSession();
        }
        return a;
    }

    /**
     * �޸��û�����
     * @param conditionMap Map
     * @throws BwayHibernateException
     */
    public void modifyStaffPass(Map conditionMap) throws BwayHibernateException {
        try {
            conn = currentSession().connection();
            conn.setAutoCommit(false);
            StaffInfoDAO dao = new StaffInfoDAO(conn);
            dao.modifyPassword(conditionMap);
            conn.commit();
        } catch (BwayHibernateException ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            throw ex;
        } catch (Exception ex) {
            try {
                conn.rollback();
            } catch (SQLException ey) {
            }
            ex.printStackTrace();
        }
        finally {
        	closeSession();
        }
    }
    
	//���µ�½ʱ��IP
	public static void updateusemsg (String tmpTableName ,String userid,
			String usetype,HttpServletRequest request) {
		String sql = "";
		try{
			sql = "update "+tmpTableName + " set lastlogin='"+Util.fotmatDate3(new java.util.Date())
				+"' , lastloginip ='"+request.getRemoteAddr() +"' , logintimes = logintimes+1 " +
						"  where id = '"+userid+"' ";
			currentSession().connection().createStatement().executeUpdate(sql);
		}catch(Exception e){
			e.printStackTrace();
		}
		finally {
        	closeSession();
        }
	}
    
    
}