www.pudn.com > Community_open20061104.rar > NewEliteTop.java~15~

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; 
 
/** 
 * 
Title: 
 
 * 
 * 
Description: 
 
 * 
 * 
Copyright: Copyright (c) 2005
 
 * 
 * 
Company: 
 
 * 
 * @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 void refresh() { 
        try { 
            RMCache.getInstance().invalidateGroup(group); 
        } catch (Exception e) { 
            logger.error(e.getMessage()); 
        } 
    } 
 
    public Vector listNewMsg(int n) { 
        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; 
    } 
 
}