payuploaddaoimpl.java

项目支付宝批量打款,采用httpclient+spring +quarz实现.

package com.szhelper.pay.dao.impl;

import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.szhelper.pay.Constants;
import com.szhelper.pay.dao.IPayUploadDao;
import com.szhelper.pay.model.UploadPayBean;
import com.szhelper.pay.quartz.base.Message;
import com.szhelper.pay.quartz.message.PayUploadMessage;

/**
 * 
 * @author Fang
 * @version 1.0
 * @date 2008-08-06
 */
public class PayUploadDaoImpl extends BaseDaoImpl implements IPayUploadDao {
	private static Log logger = LogFactory.getLog(PayUploadDaoImpl.class);
	private static final String processNameWeb_tkxx = "Web_tkxx";
	private static final String processNameWeb_tkxxth = "Web_tkxxth";

	public List<UploadPayBean> load() {
		return this.executeProcess(processNameWeb_tkxx);
	}

	public boolean rollbackLoad(Message message) {
		StringBuffer buf = ((PayUploadMessage) message).getSeqsUploaded();
		if (buf.toString().endsWith(Constants.ALIPAY_SEPARATOR))
			buf.deleteCharAt(buf.length()-1);
		
		List<UploadPayBean> list = this.executeProcess(processNameWeb_tkxxth,
				new String[] { buf.toString(),message.getOpUser() });
		for (UploadPayBean bean : list) {
			if (bean.getJYDM() == 1301) {
				logger.info("Because System can't successfully upload file to Alipay,rollback data and success. rollback autoid list:" + buf.toString());
				return true;
			}
			logger.info("Because System can't successfully upload file to Alipay,rollback data and defeat. rollback autoid list:" + buf.toString());
			return false;
		}
		logger.info("Because System can't successfully upload file to Alipay,rollback data and database error. rollback autoid list:" + buf.toString());
		return false;
	}
}