public class DailyCountFilter implements SmsFilter {

  private int ipDailyMaxSendCount;
  private int mobileDailyMaxSendCount;
  private SmsDao smsDao;

  // 省略了部分無用代碼

  @Override
  public boolean filter(SmsEntity smsEntity) {
    if (smsDao.getMobileCount(smsEntity.getMobile()) >= mobileDailyMaxSendCount) {
      return false;
    }
    if (smsDao.getIPCount(smsEntity.getIp()) >= ipDailyMaxSendCount) {
      return false;
    }
    smsDao.saveEntity(smsEntity);
    return true;
  }

}

// 在上面代碼的基礎(chǔ)上, 再添加如下代碼
public class DailyCountFilter implements SmsFilter {

  private Scheduler sched;

  @Override
  public void init() throws SchedulerException {
    smsDao.createTable(0); // 創(chuàng)建這個月的數(shù)據(jù)表
    smsDao.createTable(1); // 創(chuàng)建下個月的數(shù)據(jù)表

    SchedulerFactory sf = new StdSchedulerFactory();
    sched = sf.getScheduler(); // 創(chuàng)建Quartz容器

    JobDataMap jobDataMap = new JobDataMap();
    jobDataMap.put("smsDao", smsDao);  // 創(chuàng)建運行任務(wù)時需要使用的數(shù)據(jù)map 

    // 創(chuàng)建job對象, 該對象執(zhí)行實際的任務(wù)
    JobDetail job = JobBuilder.newJob(CreateSmsTableJob.class)
        .usingJobData(jobDataMap)
        .withIdentity("create sms table job").build();

    // 創(chuàng)建trigger對象, 該對象用來描述觸發(fā)執(zhí)行job的時間規(guī)則
    // 比如這里的每月20號2點
    CronTrigger trigger = TriggerBuilder.newTrigger()
        .withIdentity("create sms table trigger")
        .withSchedule(CronScheduleBuilder.cronSchedule("0 0 2 20 * ?"))// 每月的20號2點
        .build();

    sched.scheduleJob(job, trigger);  // 注冊任務(wù)和觸發(fā)規(guī)則
    sched.start(); // 啟動調(diào)度
  }

  @Override
  public void destroy() {
    try {
      sched.shutdown();
    }
    catch (SchedulerException e) {}
  }

  public static class CreateSmsTableJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
      JobDataMap dataMap = context.getJobDetail().getJobDataMap();
      SmsDao smsDao = (SmsDao) dataMap.get("smsDao"); // 獲得傳過來的smsDao對象
      smsDao.createTable(1); // 創(chuàng)建下個月的數(shù)據(jù)表
      smsDao.createTable(2); // 創(chuàng)建下下個月的數(shù)據(jù)表
     }
  }
}

public class SmsDao {

  /**
   * 創(chuàng)建新的日志表
   *
   * @param monthExcursion 偏移的月數(shù)
   */
  public void createTable(int monthExcursion){
    String sql = "CREATE TABLE IF NOT EXISTS "
      + getTableName(monthExcursion) + " LIKE sms";
    // 執(zhí)行sql語句
  }

  /**
   * 保存SmsEntity實體對象
   */
  public void saveEntity(SmsEntity smsEntity){
    String sql = "INSERT INTO "
      + getNowTableName() + " (mobile, ip, type) VALUES(?, ?, ?)";
    // 執(zhí)行sql語句
  }

  /**
   * 獲得指定手機號今天請求發(fā)送短信的次數(shù)
   *
   * @param mobile 用戶手機號
   * @return 今天請求發(fā)送短信的次數(shù)
   */
  public long getMobileCount(String mobile){
    String sql = "SELECT count(id) FROM "
      + getNowTableName() + " WHERE mobile=? AND time >= CURDATE()";
    // 執(zhí)行sql語句, 返回查詢結(jié)果
  }

  // 省略了getIPCount方法

  /**
   * 獲得現(xiàn)在使用的表的名字
   */
  private String getNowTableName() {
    return getTableName(0);
  }

  private DateFormat dateFormat = new SimpleDateFormat("yyyy_MM");

  /**
   * 獲得相對現(xiàn)在偏移monthExcursion月的表名
   *
   * @param monthExcursion 偏移的月數(shù)
   * @return 對應(yīng)月的表名
   */
  private String getTableName(int monthExcursion) {
    Calendar calendar = Calendar.getInstance();
    calendar.add(Calendar.MONTH, monthExcursion);
    Date date = calendar.getTime();
    return "sms_" + dateFormat.format(date);
  }

}