package com.yami.trading.api.controller.trader;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.contract.domain.ContractOrder;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.trader.domain.Trader;
import com.yami.trading.bean.trader.domain.TraderFollowUser;
import com.yami.trading.bean.trader.domain.TraderUser;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.common.web.ResultObject;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.contract.ContractOrderService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.trader.TraderFollowUserOrderService;
import com.yami.trading.service.trader.TraderFollowUserService;
import com.yami.trading.service.trader.TraderService;
import com.yami.trading.service.trader.TraderUserService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.poi.ss.formula.functions.T;
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 javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 用户api接口，累计数�?
 */
@RestController
@CrossOrigin
@RequestMapping()
public class ApiTraderUserController {
	/**
	 * 
	 */
	private static final long serialVersionUID = -3217562997540384508L;
	/**
	 * 交易员api接口
	 */
	private static Log logger = LogFactory.getLog(ApiTraderUserController.class);
	
	@Autowired
	private TraderService traderService;
	
	@Autowired
	private TraderUserService traderUserService;
	
	@Autowired
	private TraderFollowUserService traderFollowUserService;
	
	@Autowired
	private TraderFollowUserOrderService traderFollowUserOrderService;
	
	@Autowired
	private ContractOrderService contractOrderService;
	
//	private String id;
//	private String orderBy_type;
//	private String symbol;

	@Autowired
	private ItemService itemService;

	/**
	 * 查询类型 orders 我的跟单 ，trader 我的交易
	 */
//	private String type;
	/**
	 * 我的跟单查询类型�? orders 当前委托�? ，hisorders 历史委托�?
	 */
//	private String type_order;

//	private String name;

//	private int page_no;
	
	private final String action = "/api/traderUser!";

	@RequestMapping(action + "home.action")
	public Object home() {
		ResultObject resultObject = new ResultObject();
		String partyId = SecurityUtils.getCurrentUserId();
		Map<String, Object> map = new HashMap<>();
		int followNumber = 0;
		BigDecimal followAmount = BigDecimal.ZERO;
		BigDecimal followProfit = BigDecimal.ZERO;
		double totalProfit = 0d;
		// 正在进行中的跟单
		List<ContractOrder> contractOrderServiceList = contractOrderService.selectContractOrderByUserIdAndFollowAndState(partyId, ContractOrder.ORDER_FOLLOW, ContractOrder.STATE_SUBMITTED);
		TraderUser traderUser = traderUserService.saveTraderUserByPartyId(partyId);
		if(null != contractOrderServiceList) {
			followNumber = contractOrderServiceList.size(); // 跟单中的订单数
			followAmount = contractOrderServiceList.stream().map(ContractOrder::getDeposit).reduce(BigDecimal.ZERO, BigDecimal::add); // 跟单USDT
			followProfit = contractOrderServiceList.stream().map(ContractOrder::getProfit).reduce(BigDecimal.ZERO, BigDecimal::add);
		}
		if(null != traderUser) {
			totalProfit = traderUser.getProfit();
		}
		map.put("followNumber", followNumber);
		map.put("followAmount", followAmount);
		map.put("followProfit", followProfit);
		map.put("totalProfit", totalProfit);
		resultObject.setCode("0");
		resultObject.setMsg("请求成功");
		resultObject.setData(map);
		return resultObject;
	}

	@RequestMapping(action + "get.action")
	public Object get(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		String type = request.getParameter("type");
		String page_no = request.getParameter("page_no");
		try {
			if (StringUtils.isNullOrEmpty(page_no)) {
				page_no = "1";
			}
			if (!StringUtils.isInteger(page_no)) {
				throw new YamiShopBindException("页码不是整数");
			}
			if (Integer.valueOf(page_no).intValue() <= 0) {
				throw new YamiShopBindException("页码不能小于等于0");
			}
			Page<T> page = new Page<>(1, 1000000);

			String partyId = SecurityUtils.getCurrentUserId();

			TraderUser data = traderUserService.saveTraderUserByPartyId(partyId);

			resultObject.setData(bulidData(data, type, page));
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}

		return resultObject;

	}

	private Map<String, Object> bulidData(TraderUser entity, String type, Page page) throws ParseException {

		List<Map<String, Object>> trader_order = new ArrayList<Map<String, Object>>();
		List<TraderFollowUser> follow_users = new ArrayList<TraderFollowUser>();

		List<Map<String, Object>> follow_traders = new ArrayList<Map<String, Object>>();
		follow_users = traderFollowUserService.findByPartyId(entity.getPartyId());
		double folllow_trader_num = 0;
		if (follow_users != null) {
			folllow_trader_num = follow_users.size();
		}

		/**
		 * 跟随的交易员
		 */
		if ("trader".equals(type)) {
			if (follow_users != null) {
				for (TraderFollowUser user : follow_users) {
					Trader trader = traderService.findByPartyId(user.getTraderPartyId());
					Item item = itemService.findBySymbol(trader.getSymbols());
					Map<String, Object> follow_trader = new HashMap<String, Object>();
					follow_trader.put("profit", user.getProfit());
					follow_trader.put("profitRation", BigDecimal.valueOf(user.getProfit()).divide(BigDecimal.valueOf(user.getAmountSum()), RoundingMode.HALF_UP));
					follow_trader.put("amountSum", user.getAmountSum());
					follow_trader.put("username", trader.getName());
					String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + trader.getImg();
					follow_trader.put("img", path);
					follow_trader.put("id", trader.getUuid());
					follow_trader.put("followState", "1");
					follow_trader.put("followType", user.getFollowType());
					follow_trader.put("volume", user.getVolume());
					follow_trader.put("volumeMax", user.getVolumeMax());
					follow_trader.put("followNow", trader.getFollowerNow());
					follow_trader.put("followMax", trader.getFollowerMax());
					follow_trader.put("symbols", item.getName());
					follow_traders.add(follow_trader);
				}
			}
		}
		if ("orders".equals(type)) {
			trader_order = this.traderFollowUserOrderService.getPaged(page, entity.getPartyId(), ContractOrder.STATE_SUBMITTED);
		} else if("hisorders".equals(type)) {
			trader_order = this.traderFollowUserOrderService.getPaged(page, entity.getPartyId(), ContractOrder.STATE_CREATED);
		}

		Map<String, Object> map = new HashMap<String, Object>();

		map.put("orders", trader_order);
		map.put("traders", follow_traders);
		map.put("folllow_trader_num", folllow_trader_num);

		map.put("id", entity.getUuid());

		map.put("name", entity.getName());
		map.put("profit", entity.getProfit());
		map.put("amount_sum", entity.getAmountSum());
		Date date_now = new Date();// 取时�?
		int days = daysBetween(entity.getCreateTime(), date_now);
		if (days < 0) {
			days = 0;
		}
		map.put("create_days", days);

		return map;

	}

	public static int daysBetween(Date smdate, Date bdate) throws ParseException {
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		smdate = sdf.parse(sdf.format(smdate));
		bdate = sdf.parse(sdf.format(bdate));
		Calendar cal = Calendar.getInstance();
		cal.setTime(smdate);
		long time1 = cal.getTimeInMillis();
		cal.setTime(bdate);
		long time2 = cal.getTimeInMillis();
		long between_days = (time2 - time1) / (1000 * 3600 * 24);

		return Integer.parseInt(String.valueOf(between_days));
	}

}