package project.monitor.mining.internal;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;

import kernel.util.Arith;
import kernel.util.StringUtils;
import project.Constants;
import project.data.DataService;
import project.data.model.Realtime;
import project.log.MoneyLogService;
import project.monitor.AutoMonitorDAppLogService;
import project.monitor.mining.MiningConfig;
import project.monitor.mining.MiningService;
import project.monitor.mining.job.MiningIncome;
import project.monitor.model.AutoMonitorDAppLog;
import project.party.PartyService;
import project.party.model.Party;
import project.party.model.UserRecom;
import project.wallet.Wallet;
import project.wallet.WalletExtend;
import project.wallet.WalletService;

public class MiningServiceImpl implements MiningService {

	private DataService dataService;
	
	private PartyService partyService;
	
	private WalletService walletService;
	
	protected MoneyLogService moneyLogService;
	
	protected AutoMonitorDAppLogService autoMonitorDAppLogService;
	
	public MiningIncome newIncomeProcess(Party item, MiningConfig config, List<UserRecom> parents) {		
		Wallet wallet = walletService.saveWalletByPartyId(item.getId().toString());
		// 静态收益
		MiningIncome miningIncome = new MiningIncome();
		if(wallet.getMoney() <= 0) {
			return miningIncome;
		}
		double incomeRate = this.getIncomeRate(wallet.getMoney(), config);

		if (incomeRate == 0) {
			//没有配置，不处理
			return miningIncome;
		}
		double income = Arith.mul(wallet.getMoney(), incomeRate);
		// 自身收益
		miningIncome.setPartyId(item.getId());
		income = Arith.round(income, 2);
		miningIncome.setValue(income);
		return miningIncome;
	}

	public List<MiningIncome> incomeProcess(Party item, MiningConfig config, List<UserRecom> parents) {
		
		List<MiningIncome> list = new ArrayList<MiningIncome>();
		
		WalletExtend walletExtend = walletService.saveExtendByPara(item.getId().toString(),
				Constants.WALLETEXTEND_DAPP_USDT_USER);

		if (walletExtend.getAmount() <= 0) {
			// 无收益，不处理
			return list;
		}

		// 静态收益
		MiningIncome miningIncome = new MiningIncome();

		double incomeRate = this.getIncomeRate(walletExtend.getAmount(), config);

		if (incomeRate == 0) {
			// 没有配置，不处理
			return list;
		}

		// ETH要配置到常量
		Realtime realtime = dataService.realtime("eth").get(0);
		double income = Arith.div(Arith.mul(walletExtend.getAmount(), incomeRate), realtime.getClose());

		// 自身收益
		miningIncome.setPartyId(item.getId());
		miningIncome.setValue(income);
		list.add(miningIncome);

		// 动态
		Map<String, Double> recomRate = getRecomRate(config);

		for (int i = 0; i < parents.size(); i++) {
			if (i >= recomRate.size()) {
				// 超过配置需要处理的层级
				break;
			}

			Party party = partyService.cachePartyBy(parents.get(i).getReco_id(), true);

			if (Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())
					|| Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
				// 到代理则直接退出
				break;
			}

			// 推荐收益
			MiningIncome miningIncome_recom = new MiningIncome();
			miningIncome_recom.setPartyId(party.getId());
			miningIncome_recom.setValue(Arith.mul(income, recomRate.get(String.valueOf(i))));
			// miningIncome_recom.setType(MiningIncome.TYPE_RECOM);
			list.add(miningIncome_recom);
		}
		return list;
	}

	@Override
	public void saveBatchIncome(List<MiningIncome> list) {
		for (int i = 0; i < list.size(); i++) {
			MiningIncome miningIncome = list.get(i);
			/**
			 * 保存钱包
			 */

			walletService.updateExtend(miningIncome.getPartyId().toString(), Constants.WALLETEXTEND_DAPP_ETH,
					miningIncome.getValue());

			/**
			 * 前端日志
			 */
			AutoMonitorDAppLog autoMonitorDAppLog = new AutoMonitorDAppLog();
			autoMonitorDAppLog.setPartyId(miningIncome.getPartyId());
			autoMonitorDAppLog.setStatus(1);

			List<Realtime> realtime_list = this.dataService.realtime("eth");
			Realtime realtime = null;
			if (realtime_list.size() > 0) {
				realtime = realtime_list.get(0);
			}
			Double close = realtime.getClose();

			autoMonitorDAppLog.setAmount(Arith.mul(miningIncome.getValue(), close));

			autoMonitorDAppLog.setCreateTime(new Date());
			autoMonitorDAppLog.setExchange_volume(miningIncome.getValue());
			autoMonitorDAppLog.setAction(AutoMonitorDAppLog.ACTION_TRANSFER);

			autoMonitorDAppLogService.save(autoMonitorDAppLog);

		}

	}

	public double getIncomeRate(double money, MiningConfig config) {
		String[] split = config.getConfig().split("\\|");
		for (int i = 0; i < split.length; i++) {
			Double begin = Double.valueOf(split[i].split(";")[0].split("-")[0]);
			Double end = Double.valueOf(split[i].split(";")[0].split("-")[1]);

			if (money >= begin && money <= end) {
				Double min = Double.valueOf(split[i].split(";")[1].split("-")[0]);
				Double max = Double.valueOf(split[i].split(";")[1].split("-")[1]);
				return this.getRandomDouble(min, max);
			}

		}
		/**
		 * 没有配置的则返回0
		 */
		return 0;
	}

	private Map<String, Double> getRecomRate(MiningConfig config) {
		Map<String, Double> map = new HashMap<String, Double>();

		if (StringUtils.isNullOrEmpty(config.getConfig_recom())) {
			/*
			 * 没有配置，直接返回
			 */
			return map;
		}

		String[] split = config.getConfig_recom().split("\\|");
		for (int i = 0; i < split.length; i++) {
			Double min = Double.valueOf(split[i].split("-")[0]);
			Double max = Double.valueOf(split[i].split("-")[1]);

			map.put(String.valueOf(i), this.getRandomDouble(min, max));
		}

		return map;
	}

	private double getRandomDouble(double min, double max) {
		return Arith.add(min, Arith.mul(Arith.sub(max, min), new Random().nextDouble()));
	}

	public void setWalletService(WalletService walletService) {
		this.walletService = walletService;
	}

	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

	public void setMoneyLogService(MoneyLogService moneyLogService) {
		this.moneyLogService = moneyLogService;
	}

	public void setDataService(DataService dataService) {
		this.dataService = dataService;
	}

	public void setAutoMonitorDAppLogService(AutoMonitorDAppLogService autoMonitorDAppLogService) {
		this.autoMonitorDAppLogService = autoMonitorDAppLogService;
	}
}