newelitetop.java

cwbbs 云网论坛源码

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;


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(); 
        }

        Vector v = null;
        try {
            v = (Vector)RMCache.getInstance().getFromGroup(NEW_MSG, group);
        }
        catch (Exception e) {
            logger.error("listNewMsg1:" + e.getMessage());
        }
        if (v==null) {
            v = new Vector();
            try {
                JdbcTemplate jt = new JdbcTemplate(new DataSource());
                String sql = "select id from sq_thread 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) {
             v = new Vector();
             try {
                 JdbcTemplate jt = new JdbcTemplate(new DataSource());
                 String sql = "select id from sq_thread where iselite=1 order by lydate desc";
                 ResultIterator ri = jt.executeQuery(sql, 1, n);
                 if (ri.getTotal()>0) {
                     MsgMgr mm = new MsgMgr();
                     while (ri.hasNext()) {
                         ResultRecord rr = (ResultRecord) ri.next();
                         v.addElement(mm.getMsgDb((int) rr.getLong(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) {
            v = new Vector();
            try {
                JdbcTemplate jt = new JdbcTemplate(new DataSource());
                String sql = "select id from sq_thread where level>=0 order by level desc, lydate desc";
                ResultIterator ri = jt.executeQuery(sql, 1, n);
                if (ri.getTotal()>0) {
                    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;
    }

}