payuploadbootstrap.java.svn-base

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

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

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

	private PayUploadBootstrap() {
	}

	public static BaseBootstrap getInstance() {		
		return instance;
	}

	public void start() throws java.lang.Exception {
		logger.info("start PayUploadBootstrap ....");
		sender = PayUploadSender.getInstance();
		Thread t = new Thread(sender, "PayUploadSender");
		t.setDaemon(true);
		t.start();
		logger.info("start PayUploadBootstrap complete");
		runFlag = true;
		logger.info("init upload quartz ....");
		sf = new StdSchedulerFactory();
		Scheduler sched = sf.getScheduler();
		JobDetail readPayDataJob = new JobDetail("readPayDataJob", "groupRead",
				PayUploadJob.class);
		
		Map uploadPayConfig = (Map) ApplicationContextWrapper.getInstance()
		.getBean("uploadPayConfig");
		String timeSched = (String)uploadPayConfig.get("jobSchedOfUpload");
		logger.info("job schedule: "+timeSched);
		
		CronTrigger cTrigger1 = new CronTrigger("triggRead", "groupRead",
				"readPayDataJob", "groupRead", timeSched);
		sched.scheduleJob(readPayDataJob, cTrigger1);
		sched.start();
		logger.info("init upload quartz complete");
	}

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

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