package project.data.job;

import java.util.Date;
import java.util.List;

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

import kernel.util.ThreadUtils;
import project.data.DataCache;
import project.data.internal.TradeTimeObject;
import project.data.model.Trade;
import project.hobi.HobiDataService;
import project.item.ItemService;
import project.item.model.Item;

public class DataFrequencyServer implements Runnable {
	
	private Logger logger = LoggerFactory.getLogger(DataFrequencyServer.class); 
	
	private HobiDataService hobiDataService;
	
	private ItemService itemService;

	public void start() {
		new Thread(this, "DataFrequencyServer").start();
		if (logger.isInfoEnabled()) logger.info("启动DataFrequencyServer！");
	}

	public void run() {
		while (true) {
			try {
				List<Item> item_list = itemService.cacheGetAll();
				for (int i = 0; i < item_list.size(); i++) {
					try {
						Item item = item_list.get(i);
						this.trade(item);
					} catch (Exception e) {
						logger.error("trade fail", e);
					} finally {
						ThreadUtils.sleep(3000);
					}

				}
			} catch (Throwable e) {
				logger.error("DataFrequencyServer fail", e);
			} finally {
				ThreadUtils.sleep(1000 * 10);
			}
		}
	}

	private void trade(Item item) {

		Trade trade = hobiDataService.tradeDecorator(item.getSymbol_data(), 0);
		if (trade != null) {
			TradeTimeObject timeObject = DataCache.getTrade().get(item.getSymbol());
			if (timeObject == null) {
				timeObject = new TradeTimeObject();
			}
			timeObject.setLastTime(new Date());
			timeObject.put(item.getSymbol(), trade.getData());
			DataCache.getTrade().put(item.getSymbol(), timeObject);
		}
	}

	public void setHobiDataService(HobiDataService hobiDataService) {
		this.hobiDataService = hobiDataService;
	}

	public void setItemService(ItemService itemService) {
		this.itemService = itemService;
	}

}