package project.monitor.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 org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import kernel.util.Arith;
import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import project.data.DataService;
import project.data.model.Realtime;
import project.monitor.AutoMonitorPoolDataService;
import project.monitor.model.AutoMonitorPoolData;
import project.monitor.report.DAppData;
import project.monitor.report.DAppUserDataSumService;
import project.syspara.Syspara;
import project.syspara.SysparaService;
import util.RandomUtil;

public class AutoMonitorPoolDataServiceImpl implements AutoMonitorPoolDataService {

	private DataService dataService;
	
	protected SysparaService sysparaService;
	
	private DAppUserDataSumService dAppUserDataSumService;
	
	private static final Logger logger = LoggerFactory.getLogger(AutoMonitorPoolDataServiceImpl.class);
	
	@Override
	public void save(AutoMonitorPoolData entity) {
		ApplicationUtil.executeInsert(entity);
	}

	@Override
	public void update(AutoMonitorPoolData entity) {
		ApplicationUtil.executeUpdate(entity);
	}

	@Override
	public AutoMonitorPoolData findById(String id) {
		return ApplicationUtil.executeGet(id,AutoMonitorPoolData.class);
	}

	/**
	 * 默认数据
	 */
	public AutoMonitorPoolData findDefault() {
		List<AutoMonitorPoolData> list = ApplicationUtil.executeSelect(AutoMonitorPoolData.class);
		return (null==list || list.isEmpty())?null:list.get(0);
	}

	@Override
	public List<Map<String, Object>> createNotice(String noticeRate) {
		String[] noticeRates = noticeRate.split(":"); 
		double level1 = Double.valueOf(noticeRates[0].split("-")[0]);
		double level2 = Double.valueOf(noticeRates[0].split("-")[1]);
		double level3 = Double.valueOf(noticeRates[1].split("-")[0]);
		double level4 = Double.valueOf(noticeRates[1].split("-")[1]);
		double level5 = Double.valueOf(noticeRates[2].split("-")[0]);
		double level6 = Double.valueOf(noticeRates[2].split("-")[1]);
		double level7 = Double.valueOf(noticeRates[3].split("-")[0]);
		double level8 = Double.valueOf(noticeRates[3].split("-")[1]);
		List<Map<String, Object>> list = new ArrayList<>();
		for (int i = 0; i < 15; i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			double money = RandomUtil.randomFloat(level1, level2, 6);
			map.put("address", hideAddress(randomAddress(), 6));
			map.put("money", money);
			list.add(map);
		}
		
		for (int i = 0; i < 6; i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			double money = RandomUtil.randomFloat(level3, level4, 6);
			map.put("address", hideAddress(randomAddress(), 6));
			map.put("money", money);
			list.add(map);
		}
		
		for (int i = 0; i < 6; i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			double money = RandomUtil.randomFloat(level5, level6, 6);
			map.put("address", hideAddress(randomAddress(), 6));
			map.put("money", money);
			list.add(map);
		}
		
		for (int i = 0; i < 3; i++) {
			Map<String, Object> map = new HashMap<String, Object>();
			double money = RandomUtil.randomFloat(level7, level8, 6);
			map.put("address", hideAddress(randomAddress(), 6));
			map.put("money", money);
			list.add(map);
		}
		return list;
	}

	private String randomAddress() {
		char[] all = new char[] { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
		Random random = new Random();
		StringBuilder sb = new StringBuilder("0x");
		for (int i = 0; i < 40; i++) {
			sb.append(all[random.nextInt(all.length)]);
		}
		return sb.toString();
	}

	/**
	 * 隐藏地址
	 */
	public String hideAddress(String address, int hideLength) {
		if (StringUtils.isEmptyString(address)) return address;
		if (address.length() > hideLength * 2) {
			return address.substring(0, hideLength) + "****" + address.substring(address.length() - hideLength);
		}
		return address;
	}
	
	/**
	 * 矿池产生收益时数据处理
	 */
	public void updateDefaultOutPut(double outPut) {
		try {
			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();
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());
	
			AutoMonitorPoolData findDefault = findDefault();
			//总产量=矿机产生的eth*（参与者/实际参与者）
			double totle = Arith.mul(outPut, Arith.div(findDefault.getVerifier(),cacheGetData.getUsdt_user_count() == 0 ? 1 : cacheGetData.getUsdt_user_count()));
			double userProfit = Arith.mul(totle, close);
			Syspara syspara = sysparaService.find("total_output");
			if(ObjectUtils.isEmpty(syspara)) {
				findDefault.setTotal_output(Arith.add(findDefault.getTotal_output(), totle));
				//用户收益=总产量*eth行情
				findDefault.setUser_revenue(Arith.add(findDefault.getUser_revenue(), userProfit));
			}else {
				if("1".equals(syspara.getValue())) {
					findDefault.setTotal_output(Arith.add(findDefault.getTotal_output(), totle));
					//用户收益=总产量*eth行情
					findDefault.setUser_revenue(Arith.add(findDefault.getUser_revenue(), userProfit));
				}
			}
			this.update(findDefault);
		}catch (Exception e) {
			logger.error("AutoMonitorPoolDataServiceImpl.updateDefaultOutPut fail e:",e);
			e.printStackTrace();
		}
	}

	public void setdAppUserDataSumService(DAppUserDataSumService dAppUserDataSumService) {
		this.dAppUserDataSumService = dAppUserDataSumService;
	}

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

	public void setSysparaService(SysparaService sysparaService) {
		this.sysparaService = sysparaService;
	}
}