package project.futures.job;

import java.util.List;

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

import kernel.util.ThreadUtils;
import project.futures.FuturesLock;
import project.futures.FuturesOrder;
import project.futures.FuturesOrderService;
import project.syspara.SysparaService;

public class FuturesOrderCalculationJob implements Runnable {
	private static final Logger logger = LoggerFactory.getLogger(FuturesOrderCalculationJob.class);
	private FuturesOrderService futuresOrderService;
	private FuturesOrderCalculationService futuresOrderCalculationService;
	private SysparaService sysparaService;

	public void run() {
		try {
			while (true) {
				try {
					List<FuturesOrder> list = this.futuresOrderService.cacheSubmitted();
					
					//每单处理的时间间隔（毫秒）
					int futures_cal_time = sysparaService.find("futures_cal_time").getInteger();
					for (int i = 0; i < list.size(); i++) {
						FuturesOrder order = list.get(i);
						boolean lock = false;
						try {

							if (!FuturesLock.add(order.getOrder_no())) {
								continue;
							}
							lock = true;

							this.futuresOrderCalculationService.saveCalculation(order);

						} catch (Throwable e) {
							logger.error("error:", e);
						} finally {
							if (lock) {
								if (futures_cal_time>0) {
									/**
									 * 每秒处理30个订单
									 */
									ThreadUtils.sleep(futures_cal_time);
								} else {
									/**
									 * 每秒处理200个订单
									 */
									ThreadUtils.sleep(5);
								}
								FuturesLock.remove(order.getOrder_no());
							}

						}

					}

				} catch (Throwable e) {
					logger.error("run fail", e);
				} finally {
					/**
					 * 暂停0.1秒
					 */
					ThreadUtils.sleep(1000);
				}
			}
		} catch (Throwable e) {
			logger.error("run fail", e);
		} finally{
			ThreadUtils.sleep(1000);
			/**
			 * 重新启动
			 */
			new Thread(this, "FuturesOrderCalculationJob").start();
			if (logger.isInfoEnabled()) {
				logger.info("交割合约持仓单盈亏计算线程启动！");
			}
		}

	}

	public void start() {

		new Thread(this, "FuturesOrderCalculationJob").start();
		if (logger.isInfoEnabled()) {
			logger.info("交割合约持仓单盈亏计算线程启动！");
		}

	}

	public void setFuturesOrderCalculationService(FuturesOrderCalculationService futuresOrderCalculationService) {
		this.futuresOrderCalculationService = futuresOrderCalculationService;
	}

	public void setFuturesOrderService(FuturesOrderService futuresOrderService) {
		this.futuresOrderService = futuresOrderService;
	}

	public void setSysparaService(SysparaService sysparaService) {
		this.sysparaService = sysparaService;
	}

}