locinfomgrconfig.java

中国移动定位引擎的客户端

package ffcs.lbp.common;


import ffcs.config.Config;
import ffcs.lbp.dao.LocInfoMgr;

/**
* <p>Title: LBP项目</p>
* <p>Description:
*   实体信息配置，实现ConnConfigMBean接口
* </p>
* <p>Copyright: 2007 福建福富软件技术股份有限公司 </p>
* <p>Company: 福建福富软件技术股份有限公司</p>
 * @author chenxin
 * @version 1.0 $Date:2007-06-30
*/
public class LocInfoMgrConfig implements ConnConfigMBean {
    
	public static final String KEY_ENQUIRELINK_TIME= "EnquireLinkTime";
	public static final String KEY_LINK_TIMEOUT= "LinkTimeOut";
	public static final String MAX_LINK_FAILCOUNT= "MaxLinkFailCount";
	public static final String CONNECT_INTERVAL_TIME= "ConnectIntervalTime";
	public static final String SYNCH_LOCINFOMGR_TIME= "SynchEmseInfoTime";
	public static final String CONN_TIME_OUT="ConnectTimeout";
	public static final String LINK_NOTIFY_TIME ="LinkNotifyTime";
	
	public static final int LOCINFOMGR_STATUS_VALID= 1;
	public static final int LOCINFOMGR_STATUS_DELETE=0;
	public static final long DEFAULT_SYNCH_LOCINFOMGR_TIME= 300000;
	public static final long DEFAULT_ENQUIRElINK_TIME =60000;
	public static final long DEFAULT_LINK_TIMEOUT =10000;
	public static final long DEFAULT_CONN_TIME_OUT=3;
	public static final long DEFAULT_LINK_FAILCOUNT =2;
	
	
	private LocInfoMgr locInfoMgr;

	private long connTimeOut =3; // seconds　连接超时时间

	private long connIdleTime = 10; // seconds

	protected int moduleNo;//模块编号

	protected long lastReceiveTime;//最后IO时间

	protected long lastLinkTime = System.currentTimeMillis();//最后发送链路的时间

	protected volatile int receiveFlux;//接收流量，秒为单位

	protected volatile int sendFlux;//发送流量，秒为单位
	
	protected int connStatus=0;// DISCONNECT=0; CONNECT=1; LOGIN_ON=2;

	/**
	 *  0-bind_transmitter
		1-bind_receiver
		2-bind_transceiver
		3-代表2条链路（默认）
	 */
	//protected int loginMode=1;

	public LocInfoMgrConfig() {

		locInfoMgr = new LocInfoMgr();
		if(Config.getInstance().getGlobalProp()==null){
			connTimeOut= DEFAULT_CONN_TIME_OUT;
		}
		
		connTimeOut= Long.parseLong(Config.getInstance().getGlobalProp(CONN_TIME_OUT));

	}

	public int getConnID() {
		return locInfoMgr.getEmseId();
	}

	public void setConnID(int connID) {
		locInfoMgr.setEmseId(connID);
	}

	public long getConnIdleTime() {
		return connIdleTime;
	}

	public void setConnIdleTime(long connIdleTime) {
		this.connIdleTime = connIdleTime;
	}

	public void setConnTimeOut(long connTimeOut) {
		this.connTimeOut = connTimeOut;
	}

	public String getHost() {
		return locInfoMgr.getEmseIp();
	}

	public void setHost(String host) {
		locInfoMgr.setEmseIp(host);
	}

	public long getLastLinkTime() {
		return lastLinkTime;
	}

	public void setLastLinkTime(long lastLinkTime) {
		this.lastLinkTime = lastLinkTime;
	}

	public int getMaxReceiveFlux() {
		return locInfoMgr.getMaxReceRate();
	}

	public void setMaxReceiveFlux(int maxReceiveFlux) {
		locInfoMgr.setMaxReceRate(maxReceiveFlux);
	}

	public int getMaxSendFlux() {
		return locInfoMgr.getMaxSendRate();
	}

	public void setMaxSendFlux(int maxSendFlux) {
		locInfoMgr.setMaxSendRate(maxSendFlux);
	}

	public int getPort() {
		return locInfoMgr.getEmsePort();
	}

	public void setPort(int port) {
		locInfoMgr.setEmsePort(port);
	}

	public int getReceiveFlux() {
		return receiveFlux;
	}

	public void setReceiveFlux(int receiveFlux) {
		this.receiveFlux = receiveFlux;
	}

	public int getSendFlux() {
		return sendFlux;
	}

	public void setSendFlux(int sendFlux) {
		this.sendFlux = sendFlux;
	}

	public int getLoginMode() {
		return locInfoMgr.getLoginMode();
	}

	public void setLoginMode(int loginMode) {
		locInfoMgr.setLoginMode(loginMode);
	}

	public String getLoginId() {
		return locInfoMgr.getInteUser();
	}

	public void setLoginId(String s) {
		locInfoMgr.setIntePassword(s);
	}

	public String getLoginPassword() {
		return locInfoMgr.getIntePassword();
	}

	public void setLoginPassword(String password) {
		locInfoMgr.setIntePassword(password);
	}

	public long getLastReceiveTime() {
		return lastReceiveTime;
	}

	public void setLastReceiveTime(long lastReceiveTime) {
		this.lastReceiveTime = lastReceiveTime;
	}

	public int getModuleNo() {
		return moduleNo;
	}

	public void setModuleNo(int moduleNo) {
		this.moduleNo = moduleNo;
	}

	public int getStatus() {
		return locInfoMgr.getEmseStatus();
	}

	public void setStatus(int status) {
		locInfoMgr.setEmseStatus(status);
	}

	public LocInfoMgr getEmseInfo() {
		return locInfoMgr;
	}

	public void setEmseInfo(LocInfoMgr locInfoMgr) {
		this.locInfoMgr = locInfoMgr;
	}

	public int getConnStatus() {
		return connStatus;
	}

	public void setConnStatus(int connStatus) {
		this.connStatus = connStatus;
	}
	
	/**
	 * 如果在该时间没收到数据包，就发送链路检测请求包
	 * @return
	 */
	public  long getEnquireLinkTime(){
		
		if(Config.getInstance().getGlobalProp()==null){
		    return DEFAULT_ENQUIRElINK_TIME;
		}
		return Long.parseLong(Config.getInstance().getGlobalProp(KEY_ENQUIRELINK_TIME));
	}
	/**
	 * 链路检测超时时间，在该时间内没收到链咱检测应答包，算超时一次
	 * @return
	 */
	public long getLinkTimeOut(){
		if(Config.getInstance().getGlobalProp()==null){
		    return DEFAULT_LINK_TIMEOUT;
		}
		return Long.parseLong(Config.getInstance().getGlobalProp(KEY_LINK_TIMEOUT));

	}
	/**
	 * 链路检测最大失败次数，达到该次数，关闭连接 
	 * @return
	 */
	public  long getMaxLinkFailCount(){
		if(Config.getInstance().getGlobalProp()==null){
		    return DEFAULT_LINK_FAILCOUNT;
		}
		return Long.parseLong(Config.getInstance().getGlobalProp(MAX_LINK_FAILCOUNT));
	}
	
	public long getConnTimeOut() {
	     return connTimeOut;
	}
	
	public Object clone() throws CloneNotSupportedException{
		LocInfoMgrConfig result = (LocInfoMgrConfig)super.clone();
		result.locInfoMgr =(LocInfoMgr) locInfoMgr.clone();
	    return result;
	}
	/**
	 * 链路检测最大失败次数，达到该次数，关闭连接 
	 * @return
	 */
	public  static long getSynchEmseInfoTime(){
		if(Config.getInstance().getGlobalProp()==null){
		    return DEFAULT_SYNCH_LOCINFOMGR_TIME;
		}
		return Long.parseLong(Config.getInstance().getGlobalProp(SYNCH_LOCINFOMGR_TIME));
	}
	
}