package project.web.api;

import java.io.IOException;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import kernel.util.Arith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import kernel.exception.BusinessException;
import kernel.util.StringUtils;
import kernel.util.ThreadUtils;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.contract.ContractLockService;
import project.contract.ContractOrder;
import project.contract.ContractOrderService;
import project.data.DataService;
import project.data.model.Realtime;
import project.wallet.Wallet;
import project.wallet.WalletService;

/**
 * 永续合约持仓单
 */
@RestController
@CrossOrigin
public class ContractOrderController extends BaseAction {

	@Autowired
	private DataService dataService;
	
	@Autowired
	private ContractLockService contractLockService;
	
	@Autowired
	private ContractOrderService contractOrderService;

	@Autowired
	private WalletService walletService;

	private final String action = "/api/contractOrder!";
	
	private static final Logger logger = LoggerFactory.getLogger(ContractOrderController.class);

	/**
	 * 平仓
	 * 
	 * order_no 订单号
	 */
	@RequestMapping(action + "close.action")
	public Object close(HttpServletRequest request) throws IOException {
		String order_no = request.getParameter("order_no");

		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		try {

			CloseDelayThread lockDelayThread = new CloseDelayThread(this.getLoginPartyId(), order_no, this.contractOrderService, false);
			Thread t = new Thread(lockDelayThread);
			t.start();

		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 一键平仓
	 */
	@RequestMapping(action + "closeAll.action")
	public Object closeAll(HttpServletRequest request) throws IOException {

		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		try {

			CloseDelayThread lockDelayThread = new CloseDelayThread(this.getLoginPartyId(), "", this.contractOrderService, true);
			Thread t = new Thread(lockDelayThread);
			t.start();

		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 订单列表
	 * 
	 * page_no 页码
	 * symbol 币种
	 * type 查询类型：orders 当前持仓单；hisorders 历史持仓单；
	 */
	@RequestMapping(action + "list.action")
	public Object list(HttpServletRequest request) throws IOException {
		String page_no = request.getParameter("page_no");
		String symbol = request.getParameter("symbol");
		String type = request.getParameter("type");
		String startTime = request.getParameter("startTime");
		String endTime = request.getParameter("endTime");
		List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();

		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}

		try {

			if (StringUtils.isNullOrEmpty(page_no)) {
				page_no = "1";
			}
			if (!StringUtils.isInteger(page_no)) {
				throw new BusinessException("页码不是整数");
			}
			if (Integer.valueOf(page_no).intValue() <= 0) {
				throw new BusinessException("页码不能小于等于0");
			}

			int page_no_int = Integer.valueOf(page_no).intValue();
			
			if ("orders".equals(type)) {
//				// 页条数配成1000达到不分页的效果
//				data = this.contractOrderService.getPaged(page_no_int, 1000, this.getLoginPartyId(), symbol, type);
				data = this.contractOrderService.findSubmittedRedis(this.getLoginPartyId(), symbol);
			} else if ("hisorders".equals(type)) {
				data = this.contractOrderService.getPaged(page_no_int, 10, this.getLoginPartyId(), symbol, type,startTime,endTime);
			}
			
			String symbolsStr = "";
			Set<String> symbols = new HashSet<String>();
			for (int i = 0; i < data.size(); i++) {
				String sym = data.get(i).get("symbol").toString();
				if (!symbols.contains(sym)) {
					symbols.add(sym);
					if (i != 0) {
						symbolsStr = symbolsStr + "," + sym;
					} else {
						symbolsStr = sym;
					}
				}			
			}
			
			List<Realtime> realtime_all = this.dataService.realtime(symbolsStr);
			if (realtime_all.size() <= 0) {
				realtime_all = new ArrayList<Realtime>();
//				throw new BusinessException("系统错误，请稍后重试");
			}
			
			Map<String, Realtime> realtimeMap = new HashMap<String, Realtime>();
			for (int i = 0; i < realtime_all.size(); i++) {
				realtimeMap.put(realtime_all.get(i).getSymbol(), realtime_all.get(i));
			}
			
			for (int i = 0; i < data.size(); i++) {
				Map<String, Object> map = data.get(i);

				double depositOpen =  Double.parseDouble(map.get("deposit_open").toString());
				double leverRate = Double.parseDouble(map.get("lever_rate").toString());
				double tradeAvgPrice =  Double.parseDouble(map.get("trade_avg_price").toString());

				double mul = Arith.mul(depositOpen, leverRate);//仓位
				double div = Arith.div(mul, tradeAvgPrice);//持有币的数量
				/**
				 * 计算全仓收益 保证金
				 */
				double profit = 0;
				List<ContractOrder> list = contractOrderService.findSubmitted(this.getLoginPartyId(), null, null);
				for (int f = 0; f < list.size(); f++) {
					ContractOrder close_line = list.get(f);
					if(close_line.getProfit() > 0){
						profit = Arith.add(profit, Arith.add(close_line.getProfit(), close_line.getDeposit()));
					}else{
						profit = Arith.add(profit, close_line.getDeposit());
					}				}
				Wallet wallet = this.walletService.saveWalletByPartyId(this.getLoginPartyId());
				double totleMoney = wallet.getMoney();
				profit = Arith.add(profit,totleMoney);


				if (map.get("direction") != null) {
					String direction = map.get("direction").toString();
					double liquidationPrice;
					double deposit =  profit;

					if(leverRate == 1){
						liquidationPrice = 0;
					}else {
						if ("sell".equals(direction)) {
							double lossPercentage = deposit / Double.parseDouble(map.get("amount").toString());
							double priceIncrease = lossPercentage * tradeAvgPrice;
							liquidationPrice = tradeAvgPrice + priceIncrease;
						} else {
							double lossPercentage = deposit / Double.parseDouble(map.get("amount").toString());
							double priceDrop = lossPercentage * tradeAvgPrice;
							liquidationPrice = tradeAvgPrice - priceDrop;
						}
					}
					DecimalFormat dfs = new DecimalFormat("#.#####");
					String formattedPrice = dfs.format(liquidationPrice);
					map.put("qiangPing", formattedPrice);
				}
				// 标记价格
				Realtime realtime = realtimeMap.get(map.get("symbol"));
				if (null == realtime) {
					map.put("mark_price", 0);
				} else {
					map.put("mark_price", realtime.getClose());
				}
			}
			
			resultObject.setData(data);
			
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 订单详情
	 * 
	 * order_no 订单号
	 */
	@RequestMapping(action + "get.action")
	public Object get(HttpServletRequest request) throws IOException {
		String order_no = request.getParameter("order_no");

		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}

		try {
			
			if (StringUtils.isNullOrEmpty(order_no)) {
				logger.info("contractOrder!get order_no null");
				throw new BusinessException("订单不存在");
			}

			ContractOrder order = this.contractOrderService.findByOrderNo(order_no);
						
			if (null == order) {
				logger.info("contractOrder!get order_no:" + order_no + ", order null");
				throw new BusinessException("订单不存在");
			}
						
			resultObject.setData(this.contractOrderService.bulidOne(order));
		
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 新线程处理，直接拿到订单锁处理完成后退出
	 */
	public class CloseDelayThread implements Runnable {
		private String partyId;
		private String order_no;
		private ContractOrderService contractOrderService;
		private boolean all = false;

		public void run() {
			
			try {
				
				while (true) {
					if (true == all) {
						// 一键平仓
						// if (ContractLock.add("all")) {
						if (contractLockService.getContractLock("all")) {
							this.contractOrderService.saveCloseRemoveAllByPartyId(partyId);
							// 处理完退出
							break;
						}
						ThreadUtils.sleep(500);	
					} else {
						// if (ContractLock.add(order_no)) {
						if (contractLockService.getContractLock(order_no)) {
							this.contractOrderService.saveClose(partyId, order_no);
							// 处理完退出
							break;
						}
						ThreadUtils.sleep(500);						
					}
				}

			} catch (Throwable t) {
				logger.error("error:", t);
			} finally {
				if (true == all) {
					// ContractLock.remove("all");
					contractLockService.removeContractLock("all");
				} else {
					// ContractLock.remove(order_no);
					contractLockService.removeContractLock(order_no);
				}
			}
		}

		public CloseDelayThread(String partyId, String order_no, ContractOrderService contractOrderService, boolean all) {
			this.partyId = partyId;
			this.order_no = order_no;
			this.contractOrderService = contractOrderService;
			this.all = all;
		}
	}
	
}