downloadalipayrzipbootstrap.java.svn-base

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

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.DownloadAlipayRZipJob;

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

	private DownloadAlipayRZipBootstrap() {
	}

	public static BaseBootstrap getInstance() {		
		return instance;
	}

	public void start() throws java.lang.Exception {
		logger.info("start DownloadAlipayRZipBootstrap ....");
		sender = DownloadAlipayRZipSender.getInstance();
		Thread t = new Thread(sender, "PayDownloadSender");
		t.setDaemon(true);
		t.start();
		logger.info("start DownloadAlipayRZipBootstrap complete");
		runFlag = true;
		logger.info("init download quartz ....");
		sf = new StdSchedulerFactory();
		Scheduler sched = sf.getScheduler();
		JobDetail downloadPayDataJob = new JobDetail("downloadPayDataJob", "groupDownload",
				DownloadAlipayRZipJob.class);
		Map downloadPayConfig = (Map) ApplicationContextWrapper.getInstance()
		.getBean("downloadPayConfig");
		String timeSched = (String)downloadPayConfig.get("jobSchedOfDownloadRZip");
		logger.info("job schedule: "+timeSched);		
		CronTrigger cTrigger1 = new CronTrigger("triggDownload", "groupDownload",
				"downloadPayDataJob", "groupDownload", timeSched);
		sched.scheduleJob(downloadPayDataJob, cTrigger1);
		sched.start();
		logger.info("init download quartz complete");
	}

	public void restart() {
		runFlag = true;
		ParseAlipayRZipSender.getInstance().setRunFlag(true);
	}

	public void stop() {
		runFlag = false;
		ParseAlipayRZipSender.getInstance().setRunFlag(false);
	}
}