generatecsvbootstrap.java.svn-base

来自「项目支付宝批量打款,采用httpclient+spring +quarz实现.」· SVN-BASE 代码 · 共 56 行

package com.szhelper.pay.quartz;

import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.Scheduler;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;

import com.szhelper.pay.ApplicationContextWrapper;
import com.szhelper.pay.quartz.base.BaseBootstrap;
import com.szhelper.pay.quartz.base.BaseSender;
import com.szhelper.pay.quartz.job.GenerateCsvJob;

public class GenerateCSVBootstrap extends BaseBootstrap {
	Log logger = LogFactory.getLog(GenerateCSVBootstrap.class);
	private static BaseBootstrap instance = new GenerateCSVBootstrap();
	private BaseSender sender = null;

	private GenerateCSVBootstrap() {
	}

	public static BaseBootstrap getInstance() {		
		return instance;
	}

	public void start() throws java.lang.Exception {		
		runFlag = true;
		logger.info("init generate CSV quartz ....");
		sf = new StdSchedulerFactory();
		Scheduler sched = sf.getScheduler();
		JobDetail generateCsvJob = new JobDetail("generateCsvJob", "groupGenerateCsv",
				GenerateCsvJob.class);
		Map uploadPayConfig = (Map) ApplicationContextWrapper.getInstance()
		.getBean("uploadPayConfig");
		String timeSched = (String)uploadPayConfig.get("jobSchedOfGenerateCSV");
		logger.info("job schedule: "+timeSched);		
		CronTrigger cTrigger1 = new CronTrigger("triggGenerateCsv", "groupGenerateCsv",
				"generateCsvJob", "groupGenerateCsv", timeSched);
		sched.scheduleJob(generateCsvJob, cTrigger1);
		sched.start();
		logger.info("init generate CSV quartz complete");
	}

	public void restart() {
		runFlag = true;
	}

	public void stop() {
		runFlag = false;
	}
}