/**
    * Copyright By Grandsoft Company Limited.  
    * 2013-9-22 下午05:14:19
    */
   package gboat2.base.plugin.servlet.listener;
   
   import gboat2.base.bridge.model.UserSession;
   
   import java.util.Map;
  import java.util.concurrent.ConcurrentHashMap;
  
  import javax.servlet.http.HttpSession;
  import javax.servlet.http.HttpSessionAttributeListener;
  import javax.servlet.http.HttpSessionBindingEvent;
  import javax.servlet.http.HttpSessionEvent;
  import javax.servlet.http.HttpSessionListener;
  
  import org.apache.commons.lang3.StringUtils;
  
  /**
   * 监听session，限制一个用户在某个时刻只能在一个客户端登陆。<br>
   * 如果同时有多个客户端登陆，其他除了最后一次登陆的所有登陆客户端会自动退出。
   * <pre><code>
   * 在 web.xml 中配置该监听器：
   *    &lt;listener&gt;
   *        &lt;listener-class&gt;gboat2.base.plugin.servlet.listener.SessionListener&lt;/listener-class&gt;
   *    &lt;/listener&gt;
   * </code></pre>
   * @date 2013-9-22
   * @author <a href="mailto:[email protected]">何明旺</a>
   * @since 1.0
   */
  public class SessionListener implements HttpSessionListener, HttpSessionAttributeListener {
  
  	/** 保存已登录的用户信息的 Map，key 为登录名， value 为其对应的 session 对象 */
  	private Map<String, HttpSession> loginedUsers = new ConcurrentHashMap<String, HttpSession>();
  
  	@Override
  	public void sessionCreated(HttpSessionEvent se) {
  		//System.out.println(se);
  	}
  
  	@Override
  	public void sessionDestroyed(HttpSessionEvent se) {
  		Object userSession = se.getSession().getAttribute(UserSession.USER_SESSION_KEY);
  		if(userSession instanceof UserSession) {
  		    loginedUsers.remove(((UserSession)userSession).getLoginId());
  		}
  	}
  
  	@Override
  	public void attributeAdded(HttpSessionBindingEvent se) {
  		if (UserSession.USER_SESSION_KEY.equals(se.getName())) {
  			userLoginIdBinding2HttpSession(se.getSession(), (UserSession) se.getValue());
  		}
  	}
  
  	@Override
  	public void attributeRemoved(HttpSessionBindingEvent se) {
  		//注销有两种方式，一种是：request.getSession().removeAttribute(UserSession.USER_SESSION_KEY);
  		//一种是request.getSession().invalidate();
  		if (UserSession.USER_SESSION_KEY.equals(se.getName())) {
  			sessionDestroyed(se);
  		}
  	}
  
  	@Override
  	public void attributeReplaced(HttpSessionBindingEvent se) {
  		attributeAdded(se);
  	}
  
  	/**
  	 * 检查是否为例外账号
  	 * @param userSession
  	 * @return
  	 */
  	private boolean excludeUser(UserSession userSession) {
  		if ("super".equals(userSession.getLoginId())) {
  			return true;
  		}
  
  		// 测试账号，不对客户端进行限制
  		if (null != userSession.getUserNameEn() && userSession.getUserNameEn().endsWith("@glodon")) {
  			return true;
  		}
  
  		return false;
  	}
  
  	private void userLoginIdBinding2HttpSession(HttpSession session, UserSession userSession) {
  		if (null == userSession || StringUtils.isEmpty(userSession.getLoginId())) {
  			return;
  		}
  
  		//测试账号，不对客户端进行限制
  		if (excludeUser(userSession)) {
  			return;
  		}
  
         synchronized (loginedUsers) {
             if (loginedUsers.containsKey(userSession.getLoginId())) {
                 HttpSession oldSession = loginedUsers.remove(userSession.getLoginId());
                 if (null != oldSession && oldSession != session) {
                     oldSession.invalidate(); // 注销掉以前的session
                 }
             }
             loginedUsers.put(userSession.getLoginId(), session); // 绑定新的session
         }
 	}
 }