package project.monitor.bonus.job;

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

import kernel.util.ThreadUtils;
import project.monitor.bonus.BonusSettlementService;

/**
 * 结算信号触发
 * 
 * @author User
 *
 */
public class TriggerJob implements Runnable {
	
	private static final Logger logger = LoggerFactory.getLogger(TriggerJob.class);
	
	private BonusSettlementService bonusSettlementService;

	public void start() {
		new Thread(this, "TriggerJob").start();
		if (logger.isInfoEnabled()) {
			logger.info("清算结算线程启动");
		}

	}

	public void run() {
		while (true) {
			try {

				Signal item = TriggerQueue.poll();

				if (item != null) {
					bonusSettlementService.saveHandle(item);
				}

			} catch (Throwable e) {

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

			} finally {

				ThreadUtils.sleep(1000 * 30);
			}
		}

	}

	public void setBonusSettlementService(BonusSettlementService bonusSettlementService) {
		this.bonusSettlementService = bonusSettlementService;
	}

}