onlineusercache.java

cwbbs 云网论坛源码

package com.redmoon.forum;

import cn.js.fan.base.ObjectCache;
import cn.js.fan.util.StrUtil;
import java.util.Calendar;

public class OnlineUserCache extends ObjectCache {
    String ALLCOUNTSQL = "select count(*) from sq_online";
    String ALLUSERCOUNTSQL = "select count(*) from sq_online where isguest=0";
    String BOARDCOUNTSQL = "select count(*) from sq_online where boardcode=";
    String BOARDUSERCOUNTSQL =
                "select count(*) from sq_online where isguest=0 and boardcode=";

    public OnlineUserCache(OnlineUserDb ou) {
        super(ou);
    }

    public void setGroup() {
        group = "OL_USER_";
    }

    public void setGroupCount() {
        COUNT_GROUP_NAME = "OL_USER_COUNT_";
    }

    public int getAllCount() {
        int count = getObjectCount(ALLCOUNTSQL);
        return count;
    }

    public int getAllUserCount() {
        int count = getObjectCount(ALLUSERCOUNTSQL);
        return count;
    }

    public int getBoardCount(String boardcode) {
        BOARDCOUNTSQL += StrUtil.sqlstr(boardcode);
        int count = getObjectCount(BOARDCOUNTSQL);
        return count;
    }

    
    public int getBoardUserCount(String boardcode) {
        BOARDUSERCOUNTSQL += StrUtil.sqlstr(boardcode);
        int count = getObjectCount(BOARDUSERCOUNTSQL);
        return count;
    }

    
    public void refreshBoardCount(String countsql, String boardcode) {
        try {
            rmCache.remove(countsql + StrUtil.sqlstr(boardcode), COUNT_GROUP_NAME);
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    }

    
    public void refreshAll() {
        try {
            rmCache.invalidateGroup(COUNT_GROUP_NAME);

            
            int allcount = getAllCount();
            ForumDb forum = new ForumDb();
            if (allcount > forum.getMaxOnlineCount()) {
                forum.setMaxOnlineCount(allcount);
                Calendar cal = Calendar.getInstance();
                forum.setMaxOnlineDate(cal.getTime());
                forum.save();
            }
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    }
}