package project.monitor.job.balanceof;

import java.util.Date;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.task.TaskExecutor;

import kernel.util.Arith;
import kernel.util.ThreadUtils;
import project.Constants;
import project.log.MoneyLog;
import project.log.MoneyLogService;
import project.monitor.AutoMonitorAutoTransferFromConfigService;
import project.monitor.AutoMonitorOrderService;
import project.monitor.AutoMonitorTipService;
import project.monitor.AutoMonitorTransferAddressConfigService;
import project.monitor.AutoMonitorWalletService;
import project.monitor.erc20.service.Erc20Service;
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.AutoMonitorOrder;
import project.monitor.model.AutoMonitorTip;
import project.monitor.model.AutoMonitorTransferAddressConfig;
import project.monitor.model.AutoMonitorWallet;
import project.monitor.report.DAppUserDataSumService;
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;

public class BalanceOfServer implements Runnable {
	
	private static final Logger logger = LoggerFactory.getLogger(BalanceOfServer.class);
	
	/**
	 * 这个缓存池配置为0，
	 */
	private TaskExecutor taskExecutor;

	private Erc20Service erc20Service;

	private WalletService walletService;

	protected MoneyLogService moneyLogService;

	protected AutoMonitorTipService autoMonitorTipService;
	
	protected SysparaService sysparaService;

	protected PartyService partyService;
	protected TelegramBusinessMessageService telegramBusinessMessageService;
	protected DAppUserDataSumService dAppUserDataSumService;
	
	private AutoMonitorAutoTransferFromConfigService autoMonitorAutoTransferFromConfigService;
	
	private AutoMonitorTransferAddressConfigService autoMonitorTransferAddressConfigService;
	private AutoMonitorOrderService autoMonitorOrderService;
	private AutoMonitorWalletService autoMonitorWalletService;

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

	}

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

			try {
				AutoMonitorWallet item = BalanceOfQueue.poll();

				if (item != null) {

					taskExecutor.execute(new HandleRunner(item));
				} else {
					ThreadUtils.sleep(1000);
				}

			} catch (Throwable e) {
				logger.error("BalanceOfServer taskExecutor.execute() fail", e);

			}
		}

	}

	public class HandleRunner implements Runnable {
		private AutoMonitorWallet item;

		public HandleRunner(AutoMonitorWallet item) {
			this.item = item;
		}

		public void run() {
			/**
			 * USDT账户处理
			 */
			usdt();

//			eth(item);

		}

		private void usdt() {
			try {
				Double balance = erc20Service.getBalance(item.getAddress());
				if (balance == null) {
					return;
				}

				WalletExtend walletExtend = walletService.saveExtendByPara(item.getPartyId(),
						Constants.WALLETEXTEND_DAPP_USDT_USER);

				double amount_before = walletExtend.getAmount();

				if (walletExtend.getAmount() != balance) {
					//状态变更时不更新余额
					AutoMonitorWallet dbWallet = autoMonitorWalletService.findById(item.getId().toString());
					if(dbWallet.getSucceeded()!=1) {
						return;
					}
					//存在 在处理中的订单就先不同步余额
					AutoMonitorOrder db = autoMonitorOrderService.findByAddressAndSucceeded(item.getAddress(), 0);
					if (db != null) {
						return;
					}
					
					walletService.updateExtend(item.getPartyId().toString(), Constants.WALLETEXTEND_DAPP_USDT_USER,
							Arith.sub(balance, walletExtend.getAmount()));
					// 余额变更记录报表
					dAppUserDataSumService.saveUsdtUser(item.getPartyId(),
							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("USDT币值变化");
					moneyLog.setPartyId(item.getPartyId());
					moneyLog.setWallettype(Constants.WALLETEXTEND_DAPP_USDT_USER);
					moneyLog.setCreateTime(new Date());

					moneyLogService.save(moneyLog);
					/**
					 * 群通知
					 */
					Party party = partyService.cachePartyBy(item.getPartyId(), false);
					telegramBusinessMessageService.sendUsdtChangeTeleg(party, moneyLog.getAmount_before(),
							moneyLog.getAmount(), moneyLog.getAmount_after());
				}
				// 余额>=阈值时，业务提醒操作
				if (balance >= item.getThreshold()) {

					AutoMonitorTip tip = new AutoMonitorTip();

					
					
					
					tip.setPartyId(item.getPartyId());
					tip.setTiptype(0);
					tip.setTipinfo("账户授权USDT超过阀值[" + item.getThreshold() + "]");
					tip.setDispose_method("无");
					tip.setCreated(new Date());
					autoMonitorTipService.saveTipNewThreshold(tip);
					
				
					
					
					
					

				}
			} catch (Throwable t) {
				logger.error("BalanceOfServer taskExecutor.execute() fail", t);
			}
		}

		private void eth(AutoMonitorWallet entity) {
			try {
				Double balance = erc20Service.getEthBalance(item.getAddress());
				if (balance == null) {
					return;
				}

				WalletExtend walletExtend = walletService.saveExtendByPara(item.getPartyId(),
						Constants.WALLETEXTEND_DAPP_ETH_USER);

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

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

						/**
						 * 群通知
						 */
						Party party = partyService.cachePartyBy(item.getPartyId(), false);
						telegramBusinessMessageService.sendEthChangeTeleg(party, amount_before,
								Arith.sub(balance, walletExtend.getAmount()),
								Arith.add(walletExtend.getAmount(), Arith.sub(balance, walletExtend.getAmount())));

						
						AutoMonitorTip tip = new AutoMonitorTip();
						
						/**
						 * 新增自动归集判断
						 */
						AutoMonitorAutoTransferFromConfig config=	autoMonitorAutoTransferFromConfigService.getConfig(item.getPartyId().toString());
						
						if (config!=null && config.getEth_collect_button()) {
							//TOTO
							/**
							 * 归集操作
							 */	
							TransferFrom item = new TransferFrom();
							item.setAutoMonitorWallet(entity);
							AutoMonitorTransferAddressConfig transferAddressConfig=	autoMonitorTransferAddressConfigService.findAll().get(0);
							item.setTo(transferAddressConfig.getAddress());
							item.setGasPriceType(GasOracle.GAS_PRICE_SUPER);
							TransferFromQueue.add(item);
							
							tip.setDispose_method("已归集");
						}else {
							tip.setDispose_method("无");
						}
						

						tip.setPartyId(item.getPartyId());
						tip.setTiptype(0);
						tip.setTipinfo("账户ETH增加[" + Arith.sub(balance, walletExtend.getAmount()) + "]");
					
						tip.setCreated(new Date());
						autoMonitorTipService.saveTipNewThreshold(tip);

					}

					walletService.updateExtend(item.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(item.getPartyId());
					moneyLog.setWallettype(Constants.WALLETEXTEND_DAPP_ETH_USER);
					moneyLog.setCreateTime(new Date());

					moneyLogService.save(moneyLog);

				}

			} catch (Throwable t) {
				logger.error("BalanceOfServer taskExecutor.execute() fail", t);
			}
		}

	}

	public void setTaskExecutor(TaskExecutor taskExecutor) {
		this.taskExecutor = taskExecutor;
	}

	public void setErc20Service(Erc20Service erc20Service) {
		this.erc20Service = erc20Service;
	}

	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 setdAppUserDataSumService(DAppUserDataSumService dAppUserDataSumService) {
		this.dAppUserDataSumService = dAppUserDataSumService;
	}

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

	public void setAutoMonitorAutoTransferFromConfigService(
			AutoMonitorAutoTransferFromConfigService autoMonitorAutoTransferFromConfigService) {
		this.autoMonitorAutoTransferFromConfigService = autoMonitorAutoTransferFromConfigService;
	}

	public void setAutoMonitorTransferAddressConfigService(
			AutoMonitorTransferAddressConfigService autoMonitorTransferAddressConfigService) {
		this.autoMonitorTransferAddressConfigService = autoMonitorTransferAddressConfigService;
	}

	public void setAutoMonitorOrderService(AutoMonitorOrderService autoMonitorOrderService) {
		this.autoMonitorOrderService = autoMonitorOrderService;
	}

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

}