parsealipayrzipbootstrap.java

来自「项目支付宝批量打款,采用httpclient+spring +quarz实现.」· Java 代码 · 共 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.ParseAlipayRZipJob;

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

	private ParseAlipayRZipBootstrap() {
	}

	public static BaseBootstrap getInstance() {		
		return instance;
	}

	public void start() throws java.lang.Exception {
		logger.info("start ParseAlipayRZipBootstrap ....");
		sender = ParseAlipayRZipSender.getInstance();
		Thread t = new Thread(sender, "PayDownloadSender");
		t.setDaemon(true);
		t.start();
		logger.info("start ParseAlipayRZipBootstrap complete");
		runFlag = true;
		logger.info("init parse quartz ....");
		sf = new StdSchedulerFactory();
		Scheduler sched = sf.getScheduler();
		JobDetail parsePayDataJob = new JobDetail("parsePayDataJob", "groupParse",
				ParseAlipayRZipJob.class);
		Map downloadPayConfig = (Map) ApplicationContextWrapper.getInstance()
		.getBean("downloadPayConfig");
		String timeSched = (String)downloadPayConfig.get("jobSchedOfParseRZip");
		logger.info("job schedule: "+timeSched);		
		CronTrigger cTrigger1 = new CronTrigger("triggParse", "groupParse",
				"parsePayDataJob", "groupParse", timeSched);
		sched.scheduleJob(parsePayDataJob, cTrigger1);
		sched.start();
		logger.info("init parse quartz complete");
	}

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

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