onlineusermgr.java

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

package com.nari.pmos.amm.amm;

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.Rt_Onlineuser;

/**
 * @author wangyj
 */
public class OnlineUserMgr {

	/**
	 * 添加在线用户信息
	 * 
	 * @param RtOnlineuserVo
	 *            登录用户信息
	 * @return flag 0,1表示可以登录 2表示该用户不能登录
	 */
	public int addLoginUser(Rt_Onlineuser m_onlineuser) {

		int flag = 0;
		PbosDAO dao = DAOFactory.getPbosDAO();
		DAOParameter m_params = DAOFactory.getDAOParameter();
		// 调用存储过程
		m_params
				.setProcedure("{call pmosframe.AddLoginUser(:m_account, :m_cIp, :m_sIp, :m_cType, :m_flag) }");
		m_params.setParameter("m_account", m_onlineuser.getUser_Account());
		m_params.setParameter("m_cIp", m_onlineuser.getClient_Ip());
		m_params.setParameter("m_sIp", m_onlineuser.getServer_Ip());
		m_params.setParameter("m_cType", m_onlineuser.getClient_Type());
		m_params.setParameter("m_flag", Integer.class);
		// 存储过程调用是否成功
		boolean cr = dao.callStoredProcedure(m_params);
		if (cr) {
			flag = Integer.parseInt(m_params.getParameter("m_flag").toString());
		}
		dao.closeDAO();
		return flag;
	}

	/**
	 * 删除在线用户信息
	 * 
	 * @param account,client_type
	 *            登录用户信息
	 * @return flag true 删除成功 false 删除不成功
	 */
	public boolean delOnlineUser(String account, String client_type) {
		boolean flag = false;
		PbosDAO dao = null;
		dao = DAOFactory.getPbosDAO();
		DAOParameter m_params = DAOFactory.getDAOParameter();
		m_params
				.setProcedure("{call pmosframe.DelLogoutUser(:m_account, :m_cType) }");
		m_params.setParameter("m_account", account);
		m_params.setParameter("m_cType", client_type);
		flag = dao.callStoredProcedure(m_params);
		dao.closeDAO();
		return flag;
	}

	/**
	 * 删除所有在线用户信息
	 * 
	 * @return flag true 删除成功 false 删除不成功
	 */
	public boolean clearAllOnlineUser() {
		boolean flag = false;
		PbosDAO dao = DAOFactory.getPbosDAO();
		DAOParameter m_params = DAOFactory.getDAOParameter();
		m_params.setProcedure("{call pmosframe.ClearLoginUser()}");
		flag = dao.callStoredProcedure(m_params);
		dao.closeDAO();
		return flag;
	}

	/**
	 * 增加尝试次数
	 */
	public boolean clearTryCount(String account) {
		boolean flag = false;
		PbosDAO dao = DAOFactory.getPbosDAO();
		DAOParameter m_params = DAOFactory.getDAOParameter();
		m_params.setProcedure("{call pmosframe.ClearTryCount(:m_account)}");
		m_params.setParameter("m_account", account);
		flag = dao.callStoredProcedure(m_params);
		dao.closeDAO();
		return flag;
	}

	/**
	 * 清除尝试次数
	 */
	public boolean addTryCount(String account) {
		System.out.println("addTryCount " + account);
		boolean flag = false;
		PbosDAO dao = DAOFactory.getPbosDAO();
		DAOParameter m_params = DAOFactory.getDAOParameter();
		m_params.setProcedure("{call pmosframe.AddTryCount(:m_account)}");
		m_params.setParameter("m_account", account);
		flag = dao.callStoredProcedure(m_params);
		dao.closeDAO();
		return flag;
	}
}