subscibesendtimertask.java

天乙社区6.0是一套基于JAVA技术的网络虚拟社区

package com.laoer.bbscs.sys;

import java.util.*;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.laoer.bbscs.bean.*;
import com.laoer.bbscs.sys.*;
import com.laoer.bbscs.sys.mail.*;
import com.laoer.bbscs.business.*;
import com.laoer.comm.util.*;
import javax.servlet.*;
import org.springframework.web.context.support.WebApplicationContextUtils;

/**
 * <p>Title: TianYi BBS</p>
 * <p>Description: TianYi BBS System</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: LAOER.COM/TIANYISOFT.NET</p>
 * @author laoer
 * @version 6.0
 */

public class SubscibeSendTimerTask
    extends TimerTask {

  private static final Log logger = LogFactory.getLog(SubscibeSendTimerTask.class);

  //ServletContext sc;
  ISubscibeService subscibeService;
  IGuestBookService guestBookService;

  /*
  public SubscibeSendTimerTask(ServletContext sc) {
    this.sc = sc;

  }*/

  public SubscibeSendTimerTask() {
  }


  public void run() {
    logger.info("Send Subscibe, subscibeQueue's Num:" +
                RunTimConstant.getInstance().getSubscibeQueue().size());
    /*ISubscibeService subscibeService = (ISubscibeService)
        WebApplicationContextUtils.
        getRequiredWebApplicationContext(sc).getBean("subscibeService");
         IGuestBookService guestBookService = (IGuestBookService)
        WebApplicationContextUtils.
        getRequiredWebApplicationContext(sc).getBean("guestBookService");*/
    Subscibe subs = null;
    GuestBook gb = null;
    while (RunTimConstant.getInstance().getSubscibeQueue().size() > 0) {
      Forum forum = (Forum) RunTimConstant.getInstance().getSubscibeQueue().get();
      List sendlist = getSubscibeService().getSubscibeSendList(forum.getId2(),
          forum.getBoardID());
      String content = FileIO.readFile(SysUtil.getForumPath(forum.
          getBoardID(), forum.getPostTime()) + forum.getDetail(),
                                       Constant.CHARSET);
      for (int i = 0; i < sendlist.size(); i++) {
        subs = (Subscibe) sendlist.get(i);
        if (subs.getUserID() != forum.getUserID()) {
          if (subs.getMsginform() == 1) {
            gb = GuestBookFactory.getInstance(subs.getUserID());
            gb.setFromID(forum.getUserID());
            gb.setFromNickName(forum.getNickName());
            gb.setFromUserName(forum.getUserName());
            gb.setIsNew( (short) 0);
            gb.setMtype( (short) 1);
            gb.setNote("<a href='read" + Constant.FILEPREFIX + "?bid=" +
                       forum.getBoardID() + "&id=" +
                       forum.getId2() + "'>" + forum.getTitle() + "</a>");
            gb.setStime(SysUtil.getLongTime());
            gb.setToID(subs.getUserID());
            gb.setToNickName(subs.getNickName());
            gb.setToUserName(subs.getUserName());
            getGuestBookService().saveGuestBook(gb);
          }
          if (subs.getEmailinform() == 1) {
            //SendMail mail = new SendMail();
            SendMail.sendMail(subs.getUserEmail(), forum.getTitle(), content);
          }
        }
      }
    }
  }

  public ISubscibeService getSubscibeService() {
    return subscibeService;
  }

  public IGuestBookService getGuestBookService() {
    return guestBookService;
  }

  public void setGuestBookService(IGuestBookService guestBookService) {
    this.guestBookService = guestBookService;
  }

  public void setSubscibeService(ISubscibeService subscibeService) {
    this.subscibeService = subscibeService;
  }

}