sysnumstatjob.java

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

package com.laoer.bbscs.sys;

import org.quartz.*;
import org.springframework.scheduling.quartz.*;
import com.laoer.bbscs.business.*;
import java.util.*;
import com.laoer.bbscs.bean.SysNumStat;
import com.laoer.comm.util.*;
import com.laoer.bbscs.bean.Boards;
import com.laoer.bbscs.bean.Board;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;

/**
 * <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 SysNumStatJob
    extends QuartzJobBean {

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

  private IUserInfoService userInfoService;
  private IBoardService boardService;
  private ISysNumStatService sysNumStatService;

  public SysNumStatJob() {
  }

  /**
   * executeInternal
   *
   * @param jobExecutionContext JobExecutionContext
   * @throws JobExecutionException
   * @todo Implement this org.springframework.scheduling.quartz.QuartzJobBean
   *   method
   */
  protected void executeInternal(JobExecutionContext jobExecutionContext) throws
      JobExecutionException {
    java.util.Calendar cld = java.util.Calendar.getInstance();
    cld.setTime(new Date());
    cld.add(java.util.Calendar.DATE, -1);
    logger.info(Util.formatDate(cld.getTime()) + " 统计数据");

    SysNumStat snsnow = new SysNumStat();
    int usernumall = this.getUserInfoService().getAllUserNum();
    logger.info("社区人数:" + usernumall);
    List l = this.getBoardService().findAllBoard();
    Board b;
    Boards bs;
    int mainnum_total = 0;
    int postnum_total = 0;
    for (int i = 0; i < l.size(); i++) {
      b = (Board) l.get(i);
      Iterator it = b.getBoards().values().iterator();
      while (it.hasNext()) {
        bs = (Boards) it.next();
        mainnum_total += bs.getMainPostNum();
        postnum_total += bs.getPostNum();
      }
    }
    logger.info("主题数:" + mainnum_total);
    logger.info("帖子总数:" + postnum_total);
    snsnow.setNum0(usernumall);
    snsnow.setNum1(mainnum_total);
    snsnow.setNum2(postnum_total);
    snsnow.setNum3(0);
    snsnow.setNum4(0);
    snsnow.setNum5(0);

    cld.add(java.util.Calendar.DATE, -1);
    logger.info("查找 " + Util.formatDate(cld.getTime()) + " 数据");
    SysNumStat sns = this.getSysNumStatService().findSysNumStatByRecDate(Util.
        formatDate4(cld.getTime()));

    if (sns == null) {
      snsnow.setNumInc0(0);
      snsnow.setNumInc1(0);
      snsnow.setNumInc2(0);
      snsnow.setNumInc3(0);
      snsnow.setNumInc4(0);
      snsnow.setNumInc5(0);
    }
    else {
      snsnow.setNumInc0(usernumall - sns.getNum0());
      snsnow.setNumInc1(mainnum_total - sns.getNum1());
      snsnow.setNumInc2(postnum_total - sns.getNum2());
      snsnow.setNumInc3(0);
      snsnow.setNumInc4(0);
      snsnow.setNumInc5(0);
    }

    cld.add(java.util.Calendar.DATE, 1);
    logger.info("记录 " + Util.formatDate(cld.getTime()) + " 数据");
    this.getSysNumStatService().recSysNum(Util.formatDate4(cld.getTime()),
                                          snsnow);
  }

  public void setUserInfoService(IUserInfoService userInfoService) {
    this.userInfoService = userInfoService;
  }

  public void setBoardService(IBoardService boardService) {
    this.boardService = boardService;
  }

  public void setSysNumStatService(ISysNumStatService sysNumStatService) {
    this.sysNumStatService = sysNumStatService;
  }

  public IUserInfoService getUserInfoService() {
    return userInfoService;
  }

  public IBoardService getBoardService() {
    return boardService;
  }

  public ISysNumStatService getSysNumStatService() {
    return sysNumStatService;
  }
}