treasuremgr.java

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

package com.redmoon.forum;

import java.io.FileInputStream;
import java.net.URL;
import org.jdom.Document;
import java.io.FileOutputStream;
import org.jdom.output.XMLOutputter;
import org.jdom.input.SAXBuilder;
import org.jdom.Element;
import org.apache.log4j.Logger;
import java.util.Vector;
import java.util.List;
import java.util.Iterator;
import cn.js.fan.cache.jcs.RMCache;
import cn.js.fan.util.*;
import javax.servlet.http.HttpServletRequest;
import com.redmoon.forum.treasure.TreasureUserDb;
import org.jdom.output.Format;
import cn.js.fan.web.SkinUtil;
import java.net.URLDecoder;

public class TreasureMgr {
    RMCache rmCache;
    final String group = "TREASURE";
    final String ALLENTRANCE = "ALLTREASURE";

    static Logger logger;
    public final String FILENAME = "config_treasure.xml";

    public static Document doc = null;
    public static Element root = null;
    public static String xmlPath;
    public static boolean isInited = false;
    public static URL confURL;

    public TreasureMgr() {
        rmCache = RMCache.getInstance();

        logger = Logger.getLogger(this.getClass().getName());
        confURL = getClass().getClassLoader().getResource(FILENAME);
    }

    public static void init() {
        if (!isInited) {
            xmlPath = confURL.getPath();
            xmlPath = URLDecoder.decode(xmlPath);

            SAXBuilder sb = new SAXBuilder();
            try {
                FileInputStream fin = new FileInputStream(xmlPath);
                doc = sb.build(fin);
                root = doc.getRootElement();
                fin.close();
                isInited = true;
            } catch (org.jdom.JDOMException e) {
                logger.error(e.getMessage());
            } catch (java.io.IOException e) {
                logger.error(e.getMessage());
            }
        }
    }

    public Element getRootElement() {
        return root;
    }

    public void reload() {
        isInited = false;
        try  {
            rmCache.invalidateGroup(group);
        }
        catch (Exception e) {
            logger.error("reload:" + e.getMessage());
        }
    }

    public boolean use(HttpServletRequest request, String userName, String code, int msgId) throws ErrMsgException {
        if (code.equals("changeColorRed")) {
            // 检查用户有无此宝贝
            TreasureUserDb tud = new TreasureUserDb();
            tud = tud.getTreasureUserDb(userName, code);
            if (!tud.isLoaded() || tud.getAmount()==0)
                throw new ErrMsgException(SkinUtil.LoadString(request, "res.forum.TreasureMgr", "err_no_treasure"));

            MsgDb md = new MsgDb();
            md = md.getMsgDb(msgId);
            java.util.Date d = md.getColorExpire();
            try {
                if (md.ChangeColor(msgId, "red",
                                   DateUtil.addDate(d,
                        getTreasureUnit(code).getDay()))) {
                    // 将宝贝的数目减去1
                    int amount = tud.getAmount();
                    amount -= 1;
                    if (amount > 0) {
                        tud.setAmount(tud.getAmount() - 1);
                        tud.save();
                    } else
                        tud.del();
                }
            }
            catch (ResKeyException e) {
                throw new ErrMsgException(e.getMessage(request));
        }
        }
        if (code.equals("changeBold")) {
            // 检查用户有无此宝贝
            TreasureUserDb tud = new TreasureUserDb();
            tud = tud.getTreasureUserDb(userName, code);
            if (!tud.isLoaded() || tud.getAmount()==0)
                throw new ErrMsgException(SkinUtil.LoadString(request, "res.forum.TreasureMgr", "err_no_treasure"));

            MsgDb md = new MsgDb();
            md = md.getMsgDb(msgId);
            java.util.Date d = md.getColorExpire();
            try {
                if (md.ChangeBold(msgId, 1,
                                  DateUtil.addDate(d,
                        getTreasureUnit(code).getDay()))) {
                    // 将宝贝的数目减去1
                    int amount = tud.getAmount();
                    amount -= 1;
                    if (amount > 0) {
                        tud.setAmount(tud.getAmount() - 1);
                        tud.save();
                    } else
                        tud.del();
                }
            }
            catch (ResKeyException e) {
                throw new ErrMsgException(e.getMessage(request));
            }
        }
        return true;
    }

    public void setTreasureCount(String code, int count) {
        init();
        List list = root.getChildren();
        if (list != null) {
            Iterator ir = list.iterator();
            while (ir.hasNext()) {
                Element child = (Element) ir.next();
                String ecode = child.getAttributeValue("code");
                logger.info("ecode=" + ecode + " code=" + code);
                if (ecode.equals(code)) {
                    child.getChild("count").setText("" + count);
                    writemodify();
                    reload();
                    return;
                }
            }
        }
    }

    public TreasureUnit getTreasureUnit(String code) {
        TreasureUnit tu = null;
        try {
            tu = (TreasureUnit)rmCache.getFromGroup(code, group);
        }
        catch (Exception e) {
            logger.error("getTreasureUnit1:" + e.getMessage());
        }
        if (tu==null) {
            init();
            List list = root.getChildren();
            if (list != null) {
                Iterator ir = list.iterator();
                while (ir.hasNext()) {
                    Element child = (Element) ir.next();
                    String ecode = child.getAttributeValue("code");
                    // logger.info("ecode=" + ecode + " code=" + code);
                    if (ecode.equals(code)) {
                        String name = child.getChildText("name");
                        String className = child.getChildText("className");
                        String desc = child.getChildText("desc");
                        String image = child.getChildText("image");
                        String sCount = child.getChildText("count");
                        int count = 0;
                        if (StrUtil.isNumeric(sCount))
                            count = Integer.parseInt(sCount);
                        String sDay = child.getChildText("day");
                        int day = 0;
                        if (StrUtil.isNumeric(sDay))
                            day = Integer.parseInt(sDay);

                        Element ePrice = child.getChild("price");
                        List listScore = ePrice.getChildren("score");
                        Vector price = new Vector();
                        if (listScore!=null) {
                            Iterator irScore = listScore.iterator();
                            while (irScore.hasNext()) {
                                Element eScore = (Element)irScore.next();
                                String scoreCode = eScore.getAttributeValue("code");
                                String scoresValue = eScore.getChildText("value");
                                double value = 0;
                                if (StrUtil.isNumeric(scoresValue)) {
                                    value = Double.parseDouble(scoresValue);
                                }
                                TreasurePrice ts = new TreasurePrice();
                                ts.scoreCode = scoreCode;
                                ts.value = value;
                                price.addElement(ts);
                            }
                        }

                        tu = new TreasureUnit(code);
                        tu.setName(name);
                        tu.setClassName(className);
                        tu.setDesc(desc);
                        tu.setImage(image);
                        tu.setCount(count);
                        tu.setPrice(price);
                        tu.setDay(day);
                        try {
                            rmCache.putInGroup(code, group, tu);
                        } catch (Exception e) {
                            logger.error("getTreasureUnit2:" + e.getMessage());
                        }
                    }
                }
            }
            else {
                logger.error("getTreasureUnit:Error when parsing！");
            }
        }
        else {
            tu.renew();
        }
        return tu;
    }

    public Vector getAllTreasure() {
        Vector v = null;
        try {
            v = (Vector) rmCache.getFromGroup(ALLENTRANCE, group);
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
        if (v==null) {
            v = new Vector();
            init();
            List list = root.getChildren();
            if (list != null) {
                Iterator ir = list.iterator();
                while (ir.hasNext()) {
                    Element child = (Element) ir.next();
                    String code = child.getAttributeValue("code");
                    v.addElement(getTreasureUnit(code));
                }
                try {
                    rmCache.putInGroup(ALLENTRANCE, group, v);
                }
                catch (Exception e) {
                    logger.error("getAllTreasure:" + e.getMessage());
                }
            }
        }
        return v;
    }

    public void writemodify() {
        String indent = "    ";
        boolean newLines = true;
        // XMLOutputter outp = new XMLOutputter(indent, newLines, "utf-8");
        Format format = Format.getPrettyFormat();
        format.setIndent(indent);
        format.setEncoding("utf-8");
        XMLOutputter outp = new XMLOutputter(format);
        try {
            FileOutputStream fout = new FileOutputStream(xmlPath);
            outp.output(doc, fout);
            fout.close();
        } catch (java.io.IOException e) {}
    }

}