package project.monitor.job.approve;

import java.util.List;

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

import kernel.util.ThreadUtils;
import project.monitor.AutoMonitorWalletService;
import project.monitor.model.AutoMonitorWallet;

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

	private AutoMonitorWalletService autoMonitorWalletService;

	private ApproveConfirmServer approveConfirmServer;

	public void start() {

		new Thread(this, "ApproveConfirmJob").start();
		if (logger.isInfoEnabled()) {
			logger.info("授权监控确认线程启动");
		}

	}

	public void run() {
		while (true) {

			while (true) {
				if (approveConfirmServer.isRunning() || approveConfirmServer.islock()) {
					/**
					 * 任务启动中，等待完成
					 */
					ThreadUtils.sleep(1000);
					continue;
				}
				// 拿到权限
				break;
			}

			try {
				approveConfirmServer.lock();

				List<AutoMonitorWallet> items = autoMonitorWalletService.findAllSucceeded_0();

				/**
				 * 开始任务处理
				 */
				approveConfirmServer.start(items);

			} catch (Throwable e) {

				logger.error("ApproveConfirmJob run fail", e);

			} finally {

				ThreadUtils.sleep(1000 * 30);
			}
		}

	}

	public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
		this.autoMonitorWalletService = autoMonitorWalletService;
	}

	public void setApproveConfirmServer(ApproveConfirmServer approveConfirmServer) {
		this.approveConfirmServer = approveConfirmServer;
	}

}