newelitetop.java~16~

源码/软件简介: 云网论坛1.1RC国际版是采用JSP开发的集论坛、CMS（网站内容管理系统）、博客、聊天室、商城、交友、语音灌水等于一体的门户式社区。拥有CWBBS ( Cloud Web BBS

package com.redmoon.forum.miniplugin.index;

import java.util.Vector;

import cn.js.fan.base.ObjectDb;
import cn.js.fan.db.Conn;
import cn.js.fan.db.PrimaryKey;
import cn.js.fan.util.*;
import com.redmoon.forum.*;
import com.redmoon.forum.plugin.auction.AuctionShopDb;
import cn.js.fan.cache.jcs.RMCache;
import org.apache.log4j.Logger;
import com.cloudwebsoft.framework.db.JdbcTemplate;
import cn.js.fan.web.Global;
import com.cloudwebsoft.framework.db.Connection;
import com.cloudwebsoft.framework.db.DataSource;
import java.sql.SQLException;
import cn.js.fan.db.ResultIterator;
import cn.js.fan.db.ResultRecord;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class NewEliteTop {
    final String NEW_MSG = "cwbbs_new_msg";
    final String ELITE_MSG = "cwbbs_elite_msg";
    final String TOP_MSG = "cwbbs_top_msg";
    final String group = "cwbbs_index_group";

    Logger logger = Logger.getLogger(NewEliteTop.class.getName());

    public static long lastRefreshTime = System.currentTimeMillis();

    public void refresh() {
        try {
            RMCache.getInstance().invalidateGroup(group);
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    }

    public Vector listNewMsg(int n) {
        if (System.currentTimeMillis() - lastRefreshTime > 600000) {
            refresh();
            lastRefreshTime = System.currentTimeMillis(); // 每隔10分钟刷新一次
        }

        Vector v = null;
        try {
            v = (Vector)RMCache.getInstance().getFromGroup(NEW_MSG, group);
        }
        catch (Exception e) {
            logger.error("listNewMsg1:" + e.getMessage());
        }
        if (v==null) {
            try {
                JdbcTemplate jt = new JdbcTemplate(new DataSource());
                String sql = "select id from sq_message order by lydate desc";
                ResultIterator ri = jt.executeQuery(sql, 1, n);
                MsgMgr mm = new MsgMgr();
                while (ri.hasNext()) {
                    ResultRecord rr = (ResultRecord) ri.next();
                    v.addElement(mm.getMsgDb(rr.getInt(1)));
                }
                try {
                    RMCache.getInstance().putInGroup(NEW_MSG, group, v);
                }
                catch (Exception e) {
                    logger.error("listNewMsg2:" + e.getMessage());
                }
            } catch (SQLException e) {
                logger.error("listNewMsg3:" + e.getMessage());
            }
        }
        return v;
    }

    public Vector listEliteMsg(int n) {
        Vector v = null;
         try {
             v = (Vector)RMCache.getInstance().getFromGroup(ELITE_MSG, group);
         }
         catch (Exception e) {
             logger.error("listEliteMsg1:" + e.getMessage());
         }
         if (v==null) {
             try {
                 JdbcTemplate jt = new JdbcTemplate(new DataSource());
                 String sql = "select id from sq_message where iselite=1 order by lydate desc";
                 ResultIterator ri = jt.executeQuery(sql, 1, n);
                 MsgMgr mm = new MsgMgr();
                 while (ri.hasNext()) {
                     ResultRecord rr = (ResultRecord) ri.next();
                     v.addElement(mm.getMsgDb(rr.getInt(1)));
                 }
                 try {
                     RMCache.getInstance().putInGroup(ELITE_MSG, group, v);
                 }
                 catch (Exception e) {
                     logger.error("listEliteMsg2:" + e.getMessage());
                 }
             } catch (SQLException e) {
                 logger.error("listEliteMsg:" + e.getMessage());
             }
         }
        return v;
    }

    public Vector listTopMsg(int n) {
        Vector v = null;
        try {
            v = (Vector) RMCache.getInstance().getFromGroup(TOP_MSG, group);
        } catch (Exception e) {
            logger.error("listTopMsg1:" + e.getMessage());
        }
        if (v == null) {
            try {
                JdbcTemplate jt = new JdbcTemplate(new DataSource());
                String sql = "select id from sq_message where level>=0 order by level desc, lydate desc";
                ResultIterator ri = jt.executeQuery(sql, 1, n);
                MsgMgr mm = new MsgMgr();
                while (ri.hasNext()) {
                    ResultRecord rr = (ResultRecord) ri.next();
                    v.addElement(mm.getMsgDb(rr.getInt(1)));
                }
                try {
                    RMCache.getInstance().putInGroup(TOP_MSG, group, v);
                } catch (Exception e) {
                    logger.error("listTopMsg2:" + e.getMessage());
                }
            } catch (SQLException e) {
                logger.error("listTopMsg3:" + e.getMessage());
            }
        }
        return v;
    }

}