copyofcheckin.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
 * 备份此文件
 */
public class CopyOfCheckIn {
	private PbosDAO dao = null;

	/**
	 * 
	 */
	public CopyOfCheckIn(PbosDAO dao) {
		super();

		if (dao == null) {
			ConnectParameters.DataSource = "jdbc/pmosDB";
			this.dao = DAOFactory.getPbosDAO();
		} else
			this.dao = dao;
		// TODO Auto-generated constructor stub
	}

	public int IsRegUser(String usrAccount, String pwd) {
		int ok = -1;
		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();
		}
		return ok;
	}

	/*
	 * 2007-4-28 add by hujun
	 */
	public int IsOnlineUser(String usrAccount, String svrIp) {
		int n = 0;
		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();
		}
		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;
		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();
		}
		return uv;
	}

	public Collection RetrieveJsps(String usrAccount, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	public Collection RetrieveEjbs(String usrAccount, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	public Collection RetrieveViews(String usrAccount, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	public Collection RetrieveJspsById(int usrId, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	public Collection RetrieveEjbsById(int usrId, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	public Collection RetrieveViewsById(int usrId, String pwd) {
		Collection col = null;
		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);
		return col;
	}

	/**
	 * @return Returns the dao.
	 */
	public PbosDAO getDao() {
		// ConnectParameters.DataSource = "jdbc/pmosDB";
		// 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();
		CopyOfCheckIn checkIn = new CopyOfCheckIn(m_dao);
		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);
		 */
	}

}