useronlineinterceptor.java

一个jsp写的bbs

package com.laoer.bbscs.web.interceptor;

import net.sf.struts.saif.ActionHaveForwardInterceptor;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionForm;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpSession;
import org.apache.commons.lang.StringUtils;
import com.laoer.bbscs.comm.Constant;
import com.laoer.bbscs.web.servlet.UserSession;
import org.springframework.web.context.support.WebApplicationContextUtils;
import org.springframework.web.context.WebApplicationContext;
import com.laoer.bbscs.service.UserOnlineService;
import com.laoer.bbscs.bean.UserOnline;
import com.laoer.bbscs.service.config.SysConfig;
import com.laoer.bbscs.service.UserService;
import com.laoer.bbscs.bean.UserInfo;
import com.laoer.bbscs.exception.*;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;
import org.apache.struts.action.ActionMessage;
import com.laoer.bbscs.web.action.ActionUtils;
import org.apache.struts.action.ActionMessages;
import com.laoer.bbscs.comm.BBSCSUtil;
import com.laoer.bbscs.bean.Permission;
import java.util.Iterator;
import java.util.Set;
import java.util.Map;
import com.laoer.bbscs.comm.AjaxMessagesXML;
import com.laoer.bbscs.web.servlet.UserCookie;
import java.util.Date;

/**
 * <p>Title: Tianyi BBS</p>
 *
 * <p>Description: BBSCS</p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: Laoer.com</p>
 *
 * @author Gong Tianyi
 * @version 7.0
 */
public class UserOnlineInterceptor
    implements ActionHaveForwardInterceptor {

  private static final Log logger = LogFactory.getLog(UserOnlineInterceptor.class);

  public UserOnlineInterceptor() {
  }

  /**
   * beforeAction
   *
   * @param action Action
   * @param actionMapping ActionMapping
   * @param actionForm ActionForm
   * @param httpServletRequest HttpServletRequest
   * @param httpServletResponse HttpServletResponse
   * @return ActionForward
   * @throws IOException
   * @throws ServletException
   * @todo Implement this net.sf.struts.saif.ActionHaveForwardInterceptor method
   */
  public ActionForward beforeAction(Action action, ActionMapping actionMapping,
                                    ActionForm actionForm, HttpServletRequest httpServletRequest,
                                    HttpServletResponse httpServletResponse) throws IOException,
      ServletException {
    HttpSession session = httpServletRequest.getSession();
    String ajax = httpServletRequest.getParameter("ajax");
    if (StringUtils.isBlank(ajax)) {
      ajax = "html";
    }
    UserSession us = (UserSession) session.getAttribute(Constant.USER_SESSION_KEY);
    WebApplicationContext wc = WebApplicationContextUtils.getWebApplicationContext(action.
        getServlet().getServletContext());

    SysConfig sysConfig = (SysConfig) wc.getBean("sysConfig");

    long nowTime = System.currentTimeMillis();
    long addedTime = nowTime - us.getLastActiveTime();
    us.setAddedOnlineTime(us.getAddedOnlineTime() + addedTime);
    us.setAddedOnlineHour(us.getAddedOnlineHour() + addedTime);

    //logger.info(us.getUserName() + "累计在线时间:" + us.getAddedOnlineTime());

    if (us.getAddedOnlineTime() >= (sysConfig.getUserOnlineTime() * 1000)) {
      logger.info("用户 " + us.getUserName() + " 在线累计超过" + sysConfig.getUserOnlineTime() + "秒");

      UserOnlineService userOnlineService = (UserOnlineService) wc.getBean("userOnlineService");

      UserOnline uo = userOnlineService.findUserOnlineByUserID(us.getId()); //取得用户在线信息

      if (us.getGroupID() != Constant.USER_GROUP_GUEST) { //如果用户不是游客
        if (uo != null && !uo.getValidateCode().equals(us.getValidateCode())) { //用户重复登录
          if (ajax.equalsIgnoreCase("html") || ajax.equalsIgnoreCase("shtml")) {
            ActionMessages errors = new ActionMessages();
            errors.add("error.login.re", new ActionMessage("error.login.re"));
            ActionUtils.addErrors(httpServletRequest, errors);
            //return actionMapping.findForward("login");
            session.removeAttribute(Constant.USER_SESSION_KEY);
            return ActionUtils.getLoginForward(actionMapping, httpServletRequest, sysConfig, "index");
          }
          else {
            AjaxMessagesXML ajaxMessagesXML = (AjaxMessagesXML) wc.getBean("ajaxMessagesXML");
            ajaxMessagesXML.setMessage(Constant.CODEID_USER_LOGIN_RE,
                                       Constant.MESSAGE.getMessage(httpServletRequest.getLocale(),
                "error.login.re"));
            httpServletRequest.setAttribute("xmlo", ajaxMessagesXML.getXmlo());
            httpServletRequest.setAttribute("messagesDocument", ajaxMessagesXML.getMessagesDocument());
            return actionMapping.findForward("ajaxjsp");

          }
        }
        if (uo == null) {
          uo = new UserOnline();
          uo.setAtPlace("");
          uo.setBoardID(0);
          uo.setNickName(us.getNickName());
          uo.setOnlineTime(nowTime);
          uo.setUserGroupID(us.getGroupID());
          uo.setUserID(us.getId());
          uo.setUserName(us.getUserName());
          uo.setValidateCode(us.getValidateCode());
          uo.setHiddenUser(0);

          try {
            uo = userOnlineService.createUserOnline(uo); //加入在线用户表
          }
          catch (BbscsException ex) {
            logger.error(ex);
          }
        }
      }
      else { //是游客
        if (uo == null) { //用户Online信息不存在
          session.removeAttribute(Constant.USER_SESSION_KEY);
          UserService userService = (UserService) wc.getBean("userService");
          uo = new UserOnline();
          uo.setAtPlace("");
          uo.setBoardID(0);
          uo.setNickName("Guest");
          uo.setOnlineTime(nowTime);
          uo.setUserGroupID(Constant.USER_GROUP_GUEST);
          uo.setUserID(Constant.GUEST_USERID + nowTime);
          uo.setUserName("Guest_" + nowTime);
          uo.setValidateCode(Constant.GUEST_USERID + "_" + nowTime);
          try {
            uo = userOnlineService.createUserOnline(uo);
          }
          catch (BbscsException ex) {
            logger.error(ex);
          }
          Map[] pmap = userService.getUserPermission(Constant.USER_GROUP_GUEST);
          ActionUtils.createGuestSession(httpServletRequest, pmap, uo);
          UserCookie uc = new UserCookie(httpServletRequest, httpServletResponse, sysConfig);
          uc.addGuestCookies( -1);

          return null;
        }
      }

      if (us.getGroupID() != Constant.USER_GROUP_GUEST) { //如果不是游客

        UserService userService = (UserService) wc.getBean("userService");
        UserInfo ui = userService.findUserInfoById(us.getId());

        if (ui != null) { //取得正确用户信息

          ui.setStayTime(ui.getStayTime() + (us.getAddedOnlineTime() / 1000)); //增加用户在线时长
          us.setAddedOnlineTime(0);
          //更新用户权限 此处消耗性能较为严重,暂时注释
          //Map[] pmap = userService.getUserPermission(ui);
          //us = ActionUtils.reloadUserPermission(httpServletRequest, us, pmap);

          if (us.getAddedOnlineHour() >= 3600000) {
            logger.info("用户在线累计超过1个小时，增加用户经验值");

            ui.setExperience(ui.getExperience() + (int) (us.getAddedOnlineHour() / 3600000));
            us.setAddedOnlineHour(0);

          }
          try {
            ui = userService.saveUserInfo(ui);
            userService.writeUserFile(ui);
          }
          catch (BbscsException ex) {
            logger.error(ex);
          }
        }

      }
      else { //游客
        us.setAddedOnlineTime(0);
        if (us.getAddedOnlineHour() >= 3600000) {
          us.setAddedOnlineHour(0);
        }
      }

      //修改Online表用户在线时间
      if (uo.getOnlineTime() != nowTime) {
        uo.setOnlineTime(nowTime);
        try {
          userOnlineService.saveUserOnline(uo);
        }
        catch (BbscsException ex1) {
          logger.error(ex1);
        }
      }
    }

    us.setLastActiveTime(nowTime);
    session.setAttribute(Constant.USER_SESSION_KEY, us);
    return null;
  }

  /**
   * afterAction
   *
   * @param action Action
   * @param actionMapping ActionMapping
   * @param actionForm ActionForm
   * @param httpServletRequest HttpServletRequest
   * @param httpServletResponse HttpServletResponse
   * @return ActionForward
   * @throws IOException
   * @throws ServletException
   * @todo Implement this net.sf.struts.saif.ActionHaveForwardInterceptor method
   */
  public ActionForward afterAction(Action action, ActionMapping actionMapping,
                                   ActionForm actionForm, HttpServletRequest httpServletRequest,
                                   HttpServletResponse httpServletResponse) throws IOException,
      ServletException {
    return null;
  }
}