package com.yami.trading.admin.task.future;

import com.yami.trading.bean.future.domain.FuturesLock;
import com.yami.trading.bean.future.domain.FuturesOrder;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.common.util.MarketOpenChecker;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.service.future.FuturesOrderService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


import java.util.List;

@Component
@Slf4j
public class FuturesOrderCalculationJob implements Runnable {
	@Autowired
	private FuturesOrderService futuresOrderService;
	@Autowired
	private FuturesOrderCalculationService futuresOrderCalculationService;
	@Autowired
	private SysparaService sysparaService;
	@Autowired
	private ItemService itemService;
	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 {
							// 休市不做撮合
							Item bySymbol = itemService.findBySymbol(order.getSymbol());
							if(bySymbol == null){
								continue;
							}
							boolean isOpen = MarketOpenChecker.isMarketOpenByItemCloseType(bySymbol.getOpenCloseType());
							if(!isOpen){
								continue;
							}
							if (!FuturesLock.add(order.getOrderNo())) {
								continue;
							}
							lock = true;

							this.futuresOrderCalculationService.saveCalculation(order);

						} catch (Throwable e) {
							log.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.getOrderNo());
							}

						}

					}

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

	}

	public void start() {

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

	}



}