messagemgr.java

oa 源码

package com.redmoon.oa.message;


import cn.js.fan.util.*;
import javax.servlet.http.*;
import javax.servlet.ServletContext;
import com.cloudwebsoft.framework.aop.ProxyFactory;
import com.cloudwebsoft.framework.aop.base.Advisor;
import com.cloudwebsoft.framework.aop.Pointcut.MethodNamePointcut;
import org.apache.log4j.Logger;

public class MessageMgr {
    
    boolean debug = true;
    Privilege privilege;
    MessageDb MsgDB = new MessageDb();

    public MessageMgr() {
        privilege = new Privilege();
    }

    public int getNewMsgCount(HttpServletRequest request) {
        String name;
        com.redmoon.oa.pvg.Privilege pvg = new com.redmoon.oa.pvg.Privilege();
        name = pvg.getUser(request);
        MessageDb md = new MessageDb();
        return md.getNewMsgCount(name);
    }

    public boolean AddMsg(ServletContext application, HttpServletRequest request) throws
            ErrMsgException {
        Logger.getLogger(this.getClass().getName()).info("AddMsg:");
        com.redmoon.oa.pvg.Privilege pvg = new com.redmoon.oa.pvg.Privilege();
        if (pvg.isUserLogin(request)) {
            Logger.getLogger(this.getClass().getName()).info("AddMsg:has login");
            if (!com.redmoon.oa.sms.SMSFactory.isUseSMS()) {
                MsgDB.AddMsg(application, request, pvg.getUser(request));
            }
            else {
                ProxyFactory proxyFactory = new ProxyFactory(
                        "com.redmoon.oa.message.MessageDb");
                Advisor adv = new Advisor();
                MobileAfterAdvice mba = new MobileAfterAdvice();
                adv.setAdvice(mba);
                adv.setPointcut(new MethodNamePointcut("AddMsg", false));
                proxyFactory.addAdvisor(adv);
                IMessage imsg = (IMessage) proxyFactory.getProxy();
                imsg.AddMsg(application, request, pvg.getUser(request));
            }
        } else
            throw new ErrMsgException("您尚未登录！");
        return true;
    }

    public boolean delMsg(HttpServletRequest request) throws ErrMsgException {
        com.redmoon.oa.pvg.Privilege pvg = new com.redmoon.oa.pvg.Privilege();
        if (!pvg.isUserLogin(request))
            throw new ErrMsgException("您尚未登录!");
        String[] ids = request.getParameterValues("ids");
        if (ids == null)
            throw new ErrMsgException("缺少标识!");
        if (!privilege.canManage(request, ids))
            throw new ErrMsgException("非法操作！");

        return MsgDB.delMsg(ids);
    }

    public boolean sendDraft(HttpServletRequest request) throws ErrMsgException {
        com.redmoon.oa.pvg.Privilege pvg = new com.redmoon.oa.pvg.Privilege();
        if (!pvg.isUserLogin(request))
            throw new ErrMsgException("您尚未登录!");
        int id = ParamUtil.getInt(request, "id");
        if (!privilege.canSendDraft(request, id))
            throw new ErrMsgException("非法操作！");

        MessageDb md = new MessageDb();
        md = (MessageDb)md.getMessageDb(id);
        md.setDraft(false);
        return md.save();
    }

    public MessageDb getMessageDb(int id) throws ErrMsgException {
        return (MessageDb)MsgDB.getMessageDb(id);
    }

    public boolean IKnow(HttpServletRequest request) throws ErrMsgException {
        String[] strids = request.getParameterValues("ids");
        if (strids==null)
            return false;
        int len = strids.length;
        int[] ids = new int[len];
        MessageDb md;
        boolean re = false;
        for (int i=0; i<len; i++) {
            ids[i] = Integer.parseInt(strids[i]);
            md = getMessageDb(ids[i]);
            md.setReaded(true);
            re = md.save();
        }
        return re;
    }
    
	public boolean TransmitMsg(ServletContext application,
			HttpServletRequest request) throws ErrMsgException {
		com.redmoon.oa.pvg.Privilege pvg = new com.redmoon.oa.pvg.Privilege();
		if (pvg.isUserLogin(request)) {
			int id = ParamUtil.getInt(request, "id");
			MsgDB.TransmitMsg(application, request, pvg.getUser(request), id);
		} else
			throw new ErrMsgException("您尚未登陆！");
		return true;
	}    

}