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

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.trader.domain.Trader;
import com.yami.trading.bean.trader.domain.TraderFollowUser;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.Arith;
import com.yami.trading.dao.trader.TraderFollowUserMapper;
import com.yami.trading.service.trader.TraderFollowUserService;
import com.yami.trading.service.trader.TraderService;
import com.yami.trading.service.trader.TraderUserService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.util.*;

@Service
public class TraderFollowUserServiceImpl implements TraderFollowUserService {
	@Resource
	private TraderService traderService;
	@Resource
	private TraderUserService traderUserService;

	@Resource
	private TraderFollowUserMapper traderFollowUserMapper;

	public List<Map<String, Object>> getPaged(Page pageparam, String partyId, String profit) {

//		StringBuffer queryString = new StringBuffer("");
//		queryString.append(" SELECT * FROM ");
//		queryString.append(" T_TRADER_FOLLOW_USER ");
//		queryString.append(" where 1=1 ");
//
//		Map<String, Object> parameters = new HashMap();
//
//		queryString.append(" and TRADER_PARTY_ID = :partyId");
//		parameters.put("partyId", partyId);

//		if (!StringUtils.isNullOrEmpty(profit)) {
//			queryString.append(" and PROFIT >= 0 ");
//		}
//
//		queryString.append(" order by PROFIT desc ");
		Page page = traderFollowUserMapper.selectPage(pageparam, Wrappers.<TraderFollowUser>lambdaQuery().eq(TraderFollowUser::getTraderPartyId, partyId).ge(TraderFollowUser::getProfit, 0).orderByDesc(TraderFollowUser::getProfit));
//		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		List<Map<String, Object>> data = this.bulidData(page.getRecords());
		return data;
	}

	private List<Map<String, Object>> bulidData(List<TraderFollowUser> traderFollowUsers) {
		List<Map<String, Object>> result_traders = new ArrayList();
		DecimalFormat df2 = new DecimalFormat("#.##");
		df2.setRoundingMode(RoundingMode.FLOOR);// 向下取整
		if (traderFollowUsers == null) {
			return result_traders;
		}
		for (int i = 0; i < traderFollowUsers.size(); i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			TraderFollowUser entity = traderFollowUsers.get(i);
			map.put("name", entity.getUsername());
			map.put("profit", df2.format(entity.getProfit()));
			map.put("amount_sum", df2.format(entity.getAmountSum()));

			result_traders.add(map);
		}

		return result_traders;

	}

	@Override
	public void save(TraderFollowUser entity, String trader_id) {
		if (entity.getVolume() % 1 != 0 || entity.getVolume() <= 0 || entity.getVolumeMax() % 1 != 0) {
			throw new BusinessException(1, "跟单参数输入错误");
		}
		if (entity.getFollowType() == "1" && (entity.getVolume() > 3000 || entity.getVolume() < 1)) {
			throw new BusinessException(1, "跟单参数输入错误");
		}
		if (entity.getFollowType() == "2" && (entity.getVolume() > 5 || entity.getVolume() < 1)) {
			throw new BusinessException(1, "跟单倍数输入错误");
		}
		Trader trader = this.traderService.findById(trader_id);
		if (trader == null) {
			throw new BusinessException(1, "交易员不存在");
		}
		if ("0".equals(trader.getState())) {
			throw new BusinessException(1, "交易员未开启带单");
		}
		if (findByStateAndPartyId(entity.getPartyId(), trader.getPartyId(), "1") != null) {
			throw new BusinessException(1, "用户已跟随交易员");
		}
		if (Arith.sub(trader.getFollowerMax(), trader.getFollowerNow()) < 1) {
			throw new BusinessException(1, "交易员跟随人数已满");
		}
		if (entity.getPartyId().equals(trader.getPartyId())) {
			throw new BusinessException(1, "交易员不能跟随自己");
		}
		Trader trader_user = this.traderService.findByPartyId(entity.getPartyId());
		if (trader_user != null) {
			throw new BusinessException(1, "交易员无法跟随另一个交易员");
		}
		// 跟单固定张数/固定比例---选择 1,固定张数，2，固定比例
		if (trader.getFollowVolumnMin() > 0) {
			switch (entity.getFollowType()) {
			case "1":
				if (entity.getVolume() < trader.getFollowVolumnMin()) {
					throw new BusinessException(1, "跟单参数输入错误");
				}
				if (entity.getVolumeMax() < trader.getFollowVolumnMin()) {
					throw new BusinessException(1, "跟单参数输入错误");
				}
				break;
			case "2":
				throw new BusinessException(1, "交易员已设置最小下单数，无法通过固定比例跟单");
			default:
				break;
			}
		}

		entity.setTraderPartyId(trader.getPartyId());
		entity.setCreateTime(new Date());

		trader.setFollowerNow((int) Arith.add(trader.getFollowerNow(), 1));
		trader.setFollowerSum((int) Arith.add(trader.getFollowerSum(), 1));
		traderService.update(trader);
		/**
		 * 创建累计用户跟随累计表
		 */
		traderUserService.saveTraderUserByPartyId(entity.getPartyId());

//		ApplicationUtil.executeSaveOrUpdate(entity);
		traderFollowUserMapper.insert(entity);

	}

	@Override
	public void save(TraderFollowUser entity) {
		traderFollowUserMapper.insert(entity);
	}

	@Override
	public void update(TraderFollowUser entity) {
		if (entity.getVolume() % 1 != 0 || entity.getVolume() <= 0 || entity.getVolumeMax() % 1 != 0) {
			throw new BusinessException(1, "跟单参数输入错误");
		}
		if (entity.getFollowType() == "1" && (entity.getVolume() > 3000 || entity.getVolume() < 1)) {
			throw new BusinessException(1, "跟单参数输入错误");
		}
		if (entity.getFollowType() == "2" && (entity.getVolume() > 5 || entity.getVolume() < 1)) {
			throw new BusinessException(1, "跟单倍数输入错误");
		}

//		ApplicationUtil.executeUpdate(entity);
		traderFollowUserMapper.updateById(entity);
	}

	@Override
	public void deleteCancel(String id) {
		TraderFollowUser entity = findById(id);
		/**
		 * 将旧的交易员跟随用户-1
		 */
		Trader trader_before = this.traderService.findByPartyId(entity.getTraderPartyId().toString());
		trader_before.setFollowerNow((int) Arith.sub(trader_before.getFollowerNow(), 1));
		this.traderService.update(trader_before);

		if (entity != null) {
//			ApplicationUtil.executeDelete(entity);
			traderFollowUserMapper.deleteById(entity);
		}

	}

	public List<TraderFollowUser> findByStateAndPartyId(String partyId, String trader_partyId, String state) {
		List<TraderFollowUser> list = traderFollowUserMapper.selectList(Wrappers.<TraderFollowUser>lambdaQuery().eq(TraderFollowUser::getPartyId, partyId).eq(TraderFollowUser::getTraderPartyId, trader_partyId).eq(TraderFollowUser::getState, state));
//		List<TraderFollowUser> list = ApplicationUtil.executeSelect(TraderFollowUser.class,
//				" WHERE PARTY_ID = ? AND TRADER_PARTY_ID = ?  AND STATE = ?  ",
//				new Object[] { partyId, trader_partyId, state });
		if (list.size() > 0)
			return list;
		return null;
	}

	public List<TraderFollowUser> findByTrader_partyId(String trader_partyId) {
		List<TraderFollowUser> list = traderFollowUserMapper.selectList(Wrappers.<TraderFollowUser>lambdaQuery().eq(TraderFollowUser::getTraderPartyId, trader_partyId));
//		List<TraderFollowUser> list = ApplicationUtil.executeSelect(TraderFollowUser.class, " WHERE TRADER_PARTY_ID = ? ",
//				new Object[] { trader_partyId });
		if (list.size() > 0)
			return list;
		return null;
	}

	public List<TraderFollowUser> findByPartyId(String partyId) {
		List<TraderFollowUser> list = traderFollowUserMapper.selectList(Wrappers.<TraderFollowUser>lambdaQuery().eq(TraderFollowUser::getPartyId, partyId));
//		List<TraderFollowUser> list = ApplicationUtil.executeSelect(TraderFollowUser.class, " WHERE PARTY_ID = ? ",
//				new Object[] { partyId });
		if (list.size() > 0)
			return list;
		return null;
	}

	public TraderFollowUser findByPartyIdAndTrader_partyId(String partyId, String trader_partyId) {
		List<TraderFollowUser> list = traderFollowUserMapper.selectList(Wrappers.<TraderFollowUser>lambdaQuery().eq(TraderFollowUser::getPartyId, partyId).eq(TraderFollowUser::getTraderPartyId, trader_partyId));
//		List<TraderFollowUser> list = ApplicationUtil.executeSelect(TraderFollowUser.class,
//				" WHERE PARTY_ID= ? and TRADER_PARTY_ID = ? ",
//				new Object[] { partyId, trader_partyId });
		if (list.size() > 0)
			return list.get(0);
		return null;
	}

	public TraderFollowUser findById(String id) {
//		return ApplicationUtil.executeGet(id, TraderFollowUser.class);
		TraderFollowUser traderFollowUser = traderFollowUserMapper.selectById(id);
		return traderFollowUser;
	}

}