package project.monitor.job.transferfrom;

import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import kernel.util.ThreadUtils;
import project.monitor.AutoMonitorOrderService;
import project.monitor.model.AutoMonitorOrder;

public class TransferFromConfirmJob implements Runnable {
	
	private static final Logger logger = LoggerFactory.getLogger(TransferFromConfirmJob.class);
	
	private AutoMonitorOrderService autoMonitorOrderService;

	public void start() {
	  new Thread(this, "TransferFromConfirmJob").start(); if(logger.isInfoEnabled()) {
		  logger.info("授权转账确认线程启动");
	  }
	}

	public void run() {
		  while (true) { try { //队列缓存处理完成后，再开始新的循环。队列的处理线程池缓冲需要设置为0
		  
		  if (TransferFromConfirmQueue.size() <= 0) {
		  
		  List<AutoMonitorOrder> all = autoMonitorOrderService.findBySucceeded(0); for
		  (AutoMonitorOrder item : all) { TransferFromConfirmQueue.add(item); }
		  
		  } } catch (Throwable e) {
		  
		  logger.error("TransferFromConfirmJob run fail", e);
		  
		  } finally {
		  
		  ThreadUtils.sleep(1000 * 60); } }
	}

	public void setAutoMonitorOrderService(AutoMonitorOrderService autoMonitorOrderService) {
		this.autoMonitorOrderService = autoMonitorOrderService;
	}
}