账号唯一性登陆

display-server/src/main/java/com/ai/server/bean/LoginBean.java

@@ -1,5 +1,10 @@
package com.ai.server.bean;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import com.ai.ipu.server.cache.intf.ICache;
import com.ai.ipu.server.frame.session.ISession;
import com.ai.ipu.server.util.MobileUtility;
import com.ai.server.core.bean.IpuAppBean;
import com.ai.server.core.context.IpuContextData;
@@ -8,6 +13,33 @@ import com.ai.server.util.Constant;
import com.ailk.common.data.IData;
public class LoginBean extends IpuAppBean{
	private final static Map<String, String> uniqueAccounts = new ConcurrentHashMap<String, String>();
	public IData uniqueLogin(IData param) throws Exception{
		/*
		 * 通过传入的账号密码做登陆校验
		 */
		boolean isSuccess = true; //登陆成功
		if(isSuccess){
			String account = param.getString("ACCOUNT");
			String sessionId = uniqueAccounts.get(account);
			
			ICache cache = IpuSessionManager.getSessionCache();
			ISession session = (ISession)cache.get(sessionId);
			if (sessionId != null && session != null) {
				cache.remove(sessionId);//删除旧的Session
			}
			
			IpuContextData contextData = new IpuContextData();
			contextData.setAccount(param.getString("ACCOUNT"));
			sessionId = IpuSessionManager.getInstance().createSession(contextData);
			uniqueAccounts.put(account, sessionId);//记录新的唯一性关系
			param.put(Constant.Session.SESSION_ID, sessionId);
		}else{
			MobileUtility.error("登陆失败!");
		}
		return param;
	}
	
	public IData login(IData param) throws Exception{
		/*