parsealipayrzipjob.java

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

package com.szhelper.pay.quartz.job;

import java.util.ArrayList;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.methods.MultipartPostMethod;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import com.szhelper.pay.ApplicationContextWrapper;
import com.szhelper.pay.Constants;
import com.szhelper.pay.quartz.ParseAlipayRZipBootstrap;
import com.szhelper.pay.quartz.ParseAlipayRZipSender;
import com.szhelper.pay.quartz.PayUploadBootstrap;
import com.szhelper.pay.quartz.PayUploadSender;
import com.szhelper.pay.quartz.base.BaseSender;
import com.szhelper.pay.quartz.base.Message;
import com.szhelper.pay.quartz.message.ParseAlipayRZipMessage;
import com.szhelper.pay.service.IPayProxyService;
import com.szhelper.pay.service.impl.PayProxyServiceImpl;

/**
 * 
 * @author Fang
 * @version 1.0
 * @date 2008-08-06
 */
public class ParseAlipayRZipJob implements Job {
	private static Log logger = LogFactory.getLog(ParseAlipayRZipJob.class);

	public ParseAlipayRZipJob() {
	}

	public void execute(JobExecutionContext context)
			throws JobExecutionException {
		if (ParseAlipayRZipBootstrap.getInstance().isRunFlag()) {
			BaseSender sender = ParseAlipayRZipSender.getInstance();
			IPayProxyService payProxyService = (PayProxyServiceImpl) ApplicationContextWrapper
					.getInstance().getBean("PayProxyService");
			// Message message = payProxyService.downloadPayResultHandledPM();
			ParseAlipayRZipMessage message = (ParseAlipayRZipMessage) payProxyService
					.analyzePayResultHandledPM();
			if (message != null) {
				logger.info("push " + message.getZipnameList().size()
						+ " message to download analyzing queue.");
				for (String zipfile : message.getZipnameList()) {
					ParseAlipayRZipMessage msg = new ParseAlipayRZipMessage();	
					msg.setZipname(zipfile);
					msg.setOpUser(message.getOpUser());
					sender.getQueue().push(msg);
				}
			}
		}
	}
}