package project.data.internal;

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

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

import kernel.util.DateUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.data.DataCache;
import project.data.KlineService;
import project.data.model.Kline;
import project.data.model.Realtime;
import project.syspara.SysparaService;

public class KlineServiceImpl implements KlineService {
	
	private SysparaService sysparaService;
	
	private static final Logger logger = LoggerFactory.getLogger(KlineServiceImpl.class);
	
	public void saveInit(String symbol,String line,List<Kline> klineList) {
		ApplicationUtil.executeDelete(Kline.class, "WHERE SYMBOL=? AND PERIOD=?", new Object[] {symbol,line});
		ApplicationUtil.executeBatchInsert(klineList);
	}

	@Override
	public void saveOne(String symbol, String line) {
		Realtime realtime = DataCache.getRealtime(symbol);
		if (realtime == null) {
			logger.error("saveOne error, realtime is null,symbol [" + symbol + "]");
			return;
		}

		Kline lastOne = null;

		List<Kline> list = this.find(symbol, line, 1);
		if (list.size() > 0) {
			lastOne = list.get(0);
		}
		
		String key = symbol + "_" + line;
		Kline hobiOne = DataCache.getKline_hobi().get(key);
		if (hobiOne == null || lastOne == null) {
			// 取不到远程数据，直接退出
			return;
		}

		Kline kline = this.bulidKline(realtime, lastOne, hobiOne, line);

		kline.setPeriod(line);
		if(null==kline.getId()) kline.setId(ApplicationUtil.getCurrentTimeUUID());
		ApplicationUtil.executeInsert(kline);

		KlineTimeObject timeObject = DataCache.getKline(symbol, line);
		if (timeObject == null) {
			timeObject = new KlineTimeObject();
		}
		timeObject.getKline().add(kline);
		timeObject.setLastTime(new Date());
		DataCache.putKline(symbol, line, timeObject);
	}

	public Kline bulidKline(Realtime realtime, Kline lastOne, Kline hobiOne, String line) {
		Kline kline = new Kline();
		kline.setSymbol(realtime.getSymbol());
		kline.setTs(realtime.getTs());
		kline.setOpen(realtime.getOpen());
		kline.setHigh(realtime.getHigh());
		kline.setLow(realtime.getLow());
		kline.setClose(realtime.getClose());
		/**
		 * 新传回来的volume是固定的 需要除以Arith.div(realtime.getVolume(), 倍数)
		 */
		kline.setVolume(realtime.getVolume());

		if (lastOne != null) {
			kline.setOpen(lastOne.getClose());
		}
		int interval = this.sysparaService.find("data_interval").getInteger().intValue() / 1000;

		HighLow highLow = null;
		switch (line) {
		case "1min":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60) / interval, interval);
			break;

		case "5min":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 5) / interval, interval);
			break;
		case "15min":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 15) / interval, interval);
			break;
		case "30min":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 30) / interval, interval);
			break;

		case "60min":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 60) / interval, interval);
			break;

		case "4hour":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 60 * 4) / interval, interval);
			break;
		case "1day":
			highLow = HighLowHandle.get(realtime.getSymbol(), (60 * 60 * 24) / interval, interval);
			break;

		case Kline.PERIOD_1WEEK:
			highLow = HighLowHandle.getByDay(realtime.getSymbol(), 7);
			break;

		case Kline.PERIOD_1MON:
			highLow = HighLowHandle.getByDay(realtime.getSymbol(), 30);
			break;

		}

		if (highLow != null && highLow.getHigh() != null) {
			kline.setHigh(highLow.getHigh());
		}
		if (highLow != null && highLow.getLow() != null) {
			kline.setLow(highLow.getLow());
		}

		kline.setVolume(hobiOne.getVolume());

		return kline;
	}

	@Override
	public List<Kline> find(String symbol, String line, int pageSize) {
		Page page = new Page(0, pageSize, Integer.MAX_VALUE);
		List<Kline> list=ApplicationUtil.executeSelect(Kline.class,"WHERE SYMBOL=? AND PERIOD=? ORDER BY TS DESC LIMIT ?,?",new Object[] {symbol,line,page.getFirstElementNumber(),pageSize});
		Collections.sort(list);
		return list;
	}

	@Override
	public void delete(String line, int days) {
		Long ts = DateUtils.addDate(new Date(), days).getTime();
		ApplicationUtil.executeDelete(Kline.class, "WHERE PERIOD=? AND TS<?", new Object[] {line,ts});
	}

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