checkin.java

该HttpProxy用于从Applet或Swing界面中访问Ejb和服务端的JavaBean。

package com.nari.pmos.amm.amm;

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

import pbos.dao.DB.ConnectParameters;
import pbos.dao.helper.DAOFactory;
import pbos.dao.helper.DAOParameter;
import pbos.dao.services.PbosDAO;

import com.nari.pmos.amm.table_amm.RtOnlineuserVo;
import com.nari.pmos.amm.view_amm.User_Chk_View;
import com.nari.pmos.amm.view_amm.User_Ejb_View;
import com.nari.pmos.amm.view_amm.User_Jsp_View;
import com.nari.pmos.amm.view_amm.User_Member_View;
import com.nari.pmos.amm.view_amm.User_View_View;

/**
 * @author hujun
 * 
 * TODO To change the template for this generated type comment go to Window -
 * Preferences - Java - Code Style - Code Templates
 * 
 * 2008-04-12 修改此文件， 考虑在jsp文件中并发，dao的所有连接只在需要是才去get
 */
public class CheckIn {

	public CheckIn() {
		super();
	}

	public int IsWebRegUser(String usrAccount, String pwd, String cert_dn) {

		// 用于标记返回信息
		int ok = -100;

		// 数据库查找信息
		PbosDAO dao = null;
		Collection col = null;
		try {
			dao = this.getDao();
			col = null;
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Chk_View.class);
			m_params.setFilter("account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
		} catch (RuntimeException e) {
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}

		if (col != null) {

			Iterator it = col.iterator();

			while (it.hasNext()) {
				User_Chk_View uv = (User_Chk_View) it.next();

				if (uv.getAccount().equals(usrAccount)
						&& uv.getPwd().equals(pwd)) {
					ok = 1;
					System.out.println("uv.getCert_Dn() is " + uv.getCert_Dn());
					System.out.println("cert_dn is " + cert_dn);
					if (uv.getCert_Dn().equals("#")
							|| uv.getCert_Dn().equals(cert_dn)) {
						Date dt = dao.getSysDateTime();
						if (uv.getStart_Time().before(dt)
								&& uv.getEnd_Time().after(dt)) {
							if (uv.getMax_Try_Count() - uv.getReal_Try_Count() <= 0) {
								if (uv.getUser_Unlock_Time().before(dt)) {
									if (uv.getPwd_End_Time().before(dt)) {
										ok = -2; // 用户密码超时
									} else {
										ok = 1;
									}
								} else {
									ok = -3; // 用户锁定
								}
							} else {// 该用户没有锁定
								if (uv.getPwd_End_Time().before(dt)) {
									ok = -2; // 用户密码超时
								}
							}
						} else {
							ok = 0;// 用户不在合法时间内
						}
					} else {
						if (cert_dn == null) {
							ok = 1;
						} else {
							// 用户证书不匹配
							ok = -4;
						}
					}
				} else {
					// 密码不正确
					if (uv.getMax_Try_Count() - uv.getReal_Try_Count() <= 0) {
						ok = -3; // 用户密码尝试锁定
					} else {
						ok = -1;
					}
				}
			}
			col.clear();
		} else {
			// 不存在该用户
			ok = -5;
		}

		System.out.println("the result ok is " + ok);

		OnlineUserMgr oum = null;

		if (ok == 1) {
			oum = new OnlineUserMgr();
			oum.clearTryCount(usrAccount);
		}

		if (ok == -1 || ok == -3 || ok == -4) {
			oum = new OnlineUserMgr();
			oum.addTryCount(usrAccount);
		}

		return ok;
	}

	public int IsRegUser(String usrAccount, String pwd) {
		int ok = -1;
		PbosDAO dao = this.getDao();
		try {
			System.out.println("--- CheckIn IsRegUser getDAO --- ");
			Collection col = null;
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Chk_View.class);
			m_params.setFilter("Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
			if (!col.equals(null)) {
				Iterator it = col.iterator();
				while (it.hasNext()) {
					User_Chk_View uv = (User_Chk_View) it.next();
					if (uv.getAccount().equals(usrAccount)
							&& uv.getPwd().equals(pwd)) {
						ok = 0;
						Date dt = new Date();
						if (uv.getStart_Time().before(dt)
								&& uv.getEnd_Time().after(dt))
							ok = 1;
						break;
					}
				}
				col.clear();
			}
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
			System.out.println("--- CheckIn IsRegUser closeDAO --- ");
		}
		return ok;
	}

	/*
	 * 2007-4-28 add by hujun
	 */
	public int IsOnlineUser(String usrAccount, String svrIp) {
		int n = 0;
		PbosDAO dao = this.getDao();
		try {
			System.out.println("--- CheckIn IsOnlineUser getDao --- ");
			Collection col = null;
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(RtOnlineuserVo.class);
			m_params.setFilter("User_Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			m_params.setFilter("Server_Ip = :m_svrIp");
			m_params.setParameter("m_svrIp", svrIp);
			col = (Collection) dao.findData(m_params);
			if (col != null) {
				Iterator it = col.iterator();
				if (it.hasNext())
					n += 1;
				col.clear();
			}
		} catch (Exception e) {
			System.out.println("--- CheckIn IsOnlineUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
			System.out.println("--- CheckIn IsOnlineUser closeDao --- ");
		}
		return n;
	}

	public boolean delOnlineUser(RtOnlineuserVo onlineUser) {
		boolean r = false;
		PbosDAO m_dao = null;
		try {
			m_dao = DAOFactory.getPbosDAO();
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(RtOnlineuserVo.class);
			r = m_dao.deleteData(onlineUser);
			if (r)
				m_dao.Commit();
			else
				m_dao.Rollback();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			m_dao.closeDAO();
		}
		return r;
	}

	public boolean insOnlineUser(RtOnlineuserVo onlineUser) {
		boolean r = false;
		PbosDAO m_dao = null;
		try {
			m_dao = DAOFactory.getPbosDAO();
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(RtOnlineuserVo.class);
			r = m_dao.updateData(onlineUser);
			if (r)
				m_dao.Commit();
			else
				m_dao.Rollback();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			m_dao.closeDAO();
		}
		return r;
	}

	public int CheckOnEjb(String usrAccount, String ejbName, String methodName) {
		int ok = 0;

		return ok;
	}

	public User_Member_View RetrieveTopDown(String usrAccount, String usrPwd) {

		User_Member_View uv = null;

		PbosDAO dao = this.getDao();
		try {
			Collection col = null;
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Member_View.class);
			m_params.setFilter("Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
			if (col != null) {
				Iterator it = col.iterator();
				if (it.hasNext())
					uv = (User_Member_View) it.next();
				col.clear();
			}
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return uv;
	}

	public Collection RetrieveJsps(String usrAccount, String pwd) {
		Collection col = null;

		PbosDAO dao = this.getDao();
		try {
			System.out.println("--- CheckIn RetrieveJsps getDao --- ");
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Jsp_View.class);
			m_params.setFilter("Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
			System.out.println("--- CheckIn RetrieveJsps closeDao --- ");
		}
		return col;
	}

	public Collection RetrieveEjbs(String usrAccount, String pwd) {
		Collection col = null;
		PbosDAO dao = this.getDao();
		try {
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Ejb_View.class);
			m_params.setFilter("Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return col;
	}

	public Collection RetrieveViews(String usrAccount, String pwd) {
		Collection col = null;
		PbosDAO dao = this.getDao();
		try {
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_View_View.class);
			m_params.setFilter("Account = :m_account");
			m_params.setParameter("m_account", usrAccount);
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return col;
	}

	public Collection RetrieveJspsById(int usrId, String pwd) {
		Collection col = null;
		PbosDAO dao = this.getDao();
		try {
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Jsp_View.class);
			m_params.setFilter("User_Id = :m_id");
			m_params.setParameter("m_id", new Integer(usrId));
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return col;
	}

	public Collection RetrieveEjbsById(int usrId, String pwd) {
		Collection col = null;
		PbosDAO dao = this.getDao();
		try {
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_Ejb_View.class);
			m_params.setFilter("User_Id = :m_id");
			m_params.setParameter("m_id", new Integer(usrId));
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return col;
	}

	public Collection RetrieveViewsById(int usrId, String pwd) {
		Collection col = null;
		PbosDAO dao = this.getDao();
		try {
			DAOParameter m_params = DAOFactory.getDAOParameter();
			m_params.setCandiateClass(User_View_View.class);
			m_params.setFilter("User_Id = :m_id");
			m_params.setParameter("m_id", new Integer(usrId));
			col = (Collection) dao.findData(m_params);
		} catch (Exception e) {
			System.out.println("--- CheckIn IsRegUser exception --- ");
			e.printStackTrace();
		} finally {
			dao.closeDAO();
		}
		return col;
	}

	/**
	 * @return Returns the dao.
	 */
	public PbosDAO getDao() {
		// ConnectParameters.DataSource = "jdbc/pmosDB";
		PbosDAO dao = DAOFactory.getPbosDAO();
		return dao;
	}

	/**
	 * @param dao
	 *            The dao to set.
	 */
	public void setDao(PbosDAO dao) {
		// this.dao = dao;
	}

	public static void main(String[] args) {
		ConnectParameters.IP = "192.168.1.20";
		ConnectParameters.Port = 1521;
		ConnectParameters.ServerName = "pmos";
		ConnectParameters.UserName = "hbcc";
		ConnectParameters.Password = "pmos2000";
		// PbosDAO m_dao = DAOFactory.getPbosDAO();
		// CheckIn checkIn = new CheckIn(m_dao);
		CheckIn checkIn = new CheckIn();
		System.out.println("Register User: " + checkIn.IsRegUser("jm", "1"));
		User_Member_View uu = checkIn.RetrieveTopDown("jm", "1");
		System.out.println(uu);
		ViewSet viewSet = new ViewSet();
		Collection col = checkIn.RetrieveViews("sgcc_jyy_1", "w");
		if (col != null) {
			Iterator it = col.iterator();
			while (it.hasNext()) {
				// System.out.println(it.next());
				User_View_View uv = (User_View_View) it.next();
				viewSet.add(uv);
			}
			System.out.println(viewSet.size());
			for (int i = 0; i < viewSet.size(); i++) {
				User_View_View uv = viewSet.get(i);
				System.out.println(uv);
			}
		}
		/*
		 * ConnectParameters.IP = ""; ConnectParameters.Port=1521;
		 * ConnectParameters.ServerName=""; ConnectParameters.UserName="";
		 * ConnectParameters.Password=""; //ConnectParameters.DataSource="";
		 * PbosDAO m_dao = DAOFactory.getPbosDAO(); DAOParameter
		 * m_params=DAOFactory.getDAOParameter();
		 * m_params.setCandiateClass(User_Jsp_View.class);
		 * m_params.setFilter("User_Id = :m_id");
		 * m_params.setParameter("m_id",new Integer(5001)); Collection col =
		 * (Collection)m_dao.findData(m_params); if(col != null) { Iterator it =
		 * col.iterator(); while( it.hasNext()) { System.out.println(it.next()); } }
		 * m_params.setResult("Count(a), max(b), min(c)"); Collection col =
		 * (Collection)m_dao.findData(m_params);
		 */
	}

}