package com.yami.trading.service.trader.impl;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.trader.domain.TraderOrder;
import com.yami.trading.dao.trader.TraderOrderMapper;
import com.yami.trading.service.trader.TraderOrderService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class TraderOrderServiceImpl implements TraderOrderService {

	@Resource
	private TraderOrderMapper traderOrderMapper;

	public List<Map<String, Object>> getPaged(Page page, String partyId) {
//		StringBuffer queryString = new StringBuffer(" " + " SELECT trader_order.SYMBOL symbol , "
//				+ " trader_order.TRADE_AVG_PRICE trade_avg_price,  " + " trader_order.DIRECTION direction , "
//				+ "  trader_order.STATE state,trader_order.PROFIT profit, "
//				+ " trader_order.CLOSE_AVG_PRICE close_avg_price,trader_order.CHANGE_RATIO change_ratio , "
//				+ "  DATE_FORMAT(trader_order.CLOSE_TIME, '%Y-%m-%d %H:%i:%S') close_time,DATE_FORMAT(trader_order.CREATE_TIME, '%Y-%m-%d %H:%i:%S') create_time, "
//				+ "  trader_order.VOLUME_OPEN volume_open,item.NAME itemname, " + " trader_order.ORDER_NO order_no   ");
//		queryString.append(" FROM T_TRADER_ORDER trader_order  ");
//		queryString.append(" LEFT JOIN T_ITEM item ON trader_order.SYMBOL = item.SYMBOL  ");
//		queryString.append("  WHERE 1 = 1 ");
//		Map<String, Object> parameters = new HashMap();
//		queryString.append(" and trader_order.PARTY_ID =:partyId");
//		parameters.put("partyId", partyId);
//
//		queryString.append(" order by trader_order.CREATE_TIME desc ");
		List<Map<String, Object>> traders = traderOrderMapper.listDatas((page.getCurrent() - 1) * page.getSize(), page.getSize(), partyId);

		List<Map<String, Object>> data = this.bulidData(traders);
		return data;
	}

	private List<Map<String, Object>> bulidData(List<Map<String, Object>> traders) {
		List<Map<String, Object>> result_traders = new ArrayList();
		DecimalFormat df2 = new DecimalFormat("#.##");
		df2.setRoundingMode(RoundingMode.FLOOR);// 向下取整
		if (traders == null) {
			return result_traders;
		}
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		for (int i = 0; i < traders.size(); i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			Map<String, Object> entity = traders.get(i);
			map.put("order_no", entity.get("order_no"));
			map.put("name", entity.get("itemname"));
			map.put("close_avg_price", entity.get("close_avg_price"));
			map.put("trade_avg_price", entity.get("trade_avg_price"));
			map.put("direction", entity.get("direction"));
			map.put("state", entity.get("state"));
			map.put("profit", entity.get("profit"));
			map.put("lever_rate", entity.get("lever_rate"));
			map.put("follow_now", entity.get("follow_now"));
			map.put("follow_max", entity.get("follow_max"));
			if (entity.get("close_time") != null) {
				try {
					map.put("close_time", sdf.parse(entity.get("close_time").toString()));
				} catch (ParseException e) {
					throw new RuntimeException(e);
				}
			} else {
				map.put("close_time", "");
			}
			// 验证下以 map 方式返回的日期类型字段，在 java 里是使用 String 来接，还是 Date 来接 TODO
			if (entity.get("create_time") != null) {
				try {
					map.put("create_time", sdf.parse(entity.get("create_time").toString()));
				} catch (ParseException e) {
					throw new RuntimeException(e);
				}
			} else {
				map.put("create_time", "");
			}

			map.put("volume_open", entity.get("volume_open"));
			map.put("itemname", entity.get("itemname"));
			map.put("change_ratio", entity.get("change_ratio"));

			result_traders.add(map);
		}

		return result_traders;

	}

	@Override
	public void delete(String id) {
//		TraderOrder entity = findById(id);
//		if (entity != null) {
//			ApplicationUtil.executeDelete(entity);
//		}
		traderOrderMapper.deleteById(id);
	}

	@Override
	public void update(TraderOrder entity) {
//		ApplicationUtil.executeUpdate(entity);
		traderOrderMapper.updateById(entity);
	}

	@Override
	public void save(TraderOrder entity) {
//		ApplicationUtil.executeSaveOrUpdate(entity);
		traderOrderMapper.insert(entity);
	}

	@Override
	public TraderOrder findById(String id) {
//		return ApplicationUtil.executeGet(id, TraderOrder.class);
		TraderOrder traderOrder = traderOrderMapper.selectById(id);
		return traderOrder;
	}

}