package project.monitor.bonus.internal;

import java.util.Date;
import java.util.List;

import kernel.util.Arith;
import project.monitor.AutoMonitorOrderService;
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
import project.monitor.bonus.BonusSettlementService;
import project.monitor.bonus.SettleOrderService;
import project.monitor.bonus.job.Signal;
import project.monitor.bonus.job.TriggerQueue;
import project.monitor.bonus.job.transfer.SettleTransferQueue;
import project.monitor.bonus.model.SettleAddressConfig;
import project.monitor.bonus.model.SettleOrder;
import project.monitor.erc20.dto.TransactionResponseDto;
import project.monitor.erc20.service.Erc20Service;
import project.monitor.etherscan.GasOracle;
import project.monitor.model.AutoMonitorOrder;
import project.monitor.report.DAppUserDataSumService;
import project.monitor.telegram.business.TelegramBusinessMessageService;
import project.syspara.SysparaService;
import project.tip.TipConstants;
import project.tip.TipService;
import util.DateUtil;
import util.RandomUtil;

public class BonusSettlementServiceImpl implements BonusSettlementService {
	protected AutoMonitorOrderService autoMonitorOrderService;
	protected SysparaService sysparaService;
	protected SettleOrderService settleOrderService;
	protected Erc20Service erc20Service;
	protected AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
	protected DAppUserDataSumService dAppUserDataSumService;

	protected TelegramBusinessMessageService telegramBusinessMessageService;
	protected TipService tipService;
	
	@Override
	public void signal() {
		TriggerQueue.add(new Signal());
	}

	@Override
	public void saveHandle(Signal item) {
//		List<AutoMonitorOrder> list = autoMonitorOrderService.findBySucceeded(1);
		//转账完成且未结算的订单
		List<AutoMonitorOrder> list = autoMonitorOrderService.findBySucceededAndSettleState(1,0);

		if (list.size() <= 0) {
			return;
		}
		
		SettleAddressConfig settleAddressConfig = autoMonitorSettleAddressConfigService.findDefault();
		if(settleAddressConfig.getSettle_rate()<=0d) {
			//收益率为0不生成清算订单处理
			return;
		}
		if(item.isSettleLast()) {
			single(list, settleAddressConfig);
			return;
		}
		switch (settleAddressConfig.getSettle_type()) {
		case 1:// 1.每笔都分成
			single(list,settleAddressConfig);
			break;
		case 2:// 2.达标后一起分成
			batch(list,settleAddressConfig);
			break;
		default:
			break;
		}
	}

	public void single(List<AutoMonitorOrder> list,SettleAddressConfig settleAddressConfig) {

		SettleOrder item = this.build(list,settleAddressConfig);
		SettleTransferQueue.add(item);
	}

	public void batch(List<AutoMonitorOrder> list,SettleAddressConfig settleAddressConfig) {
		// 一起分成的达标线，例如达到1w后才开始分成
		Double settlement_limit = settleAddressConfig.getSettle_limit_amount();

		double amount = 0;
		for (int i = 0; i < list.size(); i++) {
			amount = Arith.add(amount, list.get(i).getVolume());
		}

		if (amount < settlement_limit) {
			return;
		}

		SettleOrder item = this.build(list,settleAddressConfig);
		SettleTransferQueue.add(item);
	}

	private SettleOrder build(List<AutoMonitorOrder> list,SettleAddressConfig settleAddressConfig) {

		SettleOrder settleOrder =  new SettleOrder();
		settleOrder.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
		settleOrder.setFrom_address(settleAddressConfig.getChannel_address());
		settleOrder.setTo_address(settleAddressConfig.getSettle_address());
		settleOrder.setCreated(new Date());
		settleOrder.setVolume(0d);
		for (int i = 0; i < list.size(); i++) {
			AutoMonitorOrder order = list.get(i);

			settleOrder.setVolume(Arith.add(settleOrder.getVolume(), order.getSettle_amount()));

			order.setSettle_state(1);
			order.setSettle_order_no(settleOrder.getOrder_no());
			order.setSettle_time(new Date());

			autoMonitorOrderService.update(order);

		}

		this.settleOrderService.save(settleOrder);

		return settleOrder;
	}

	@Override
	public void saveTransfer(SettleOrder settleOrder) {

		SettleAddressConfig settleAddressConfig = autoMonitorSettleAddressConfigService.findDefault();
		if (!settleOrder.getFrom_address().equals(settleAddressConfig.getChannel_address())) {
			settleOrder.setSucceeded(2);
			settleOrder.setError("地址鉴权错误");
			settleOrderService.update(settleOrder);
			
			this.recover(settleOrder);
			
			return;
		}

		TransactionResponseDto transactionResponseDto = erc20Service.tokenTrans(settleOrder.getFrom_address(),
				settleOrder.getTo_address(), String.valueOf(settleOrder.getVolume()),
				autoMonitorSettleAddressConfigService.desDecrypt(settleAddressConfig.getChannel_private_key()), GasOracle.GAS_PRICE_NORMAL);

		// 网络请求成功会返回一个hash
		if (TransactionResponseDto.CODE_LOCAL_SUCCESS.equals(transactionResponseDto.getCode())) {
			settleOrder.setTxn_hash(transactionResponseDto.getHash());
			settleOrderService.update(settleOrder);
		} else {
			settleOrder.setSucceeded(2);
			settleOrder.setError(transactionResponseDto.getError());
			
			settleOrderService.update(settleOrder);
			
			this.recover(settleOrder);
			/**
			 * 补通知
			 */
			telegramBusinessMessageService.sendSettleTransferErrorTeleg(settleOrder);
		}

		settleOrderService.update(settleOrder);

	}

	@Override
	public void saveConfirm(SettleOrder settleOrder, Integer status) {
		
		if (status == 0) {
			/**
			 * 交易失败
			 */

			settleOrder.setSucceeded(2);
			
			settleOrderService.update(settleOrder);
			
			this.recover(settleOrder);
			
			/**
			 * 补通知
			 */
			telegramBusinessMessageService.sendSettleTransferErrorTeleg(settleOrder);
		} else if (status == 1) {
			/**
			 * 交易成功
			 */

			/*
			 * 保存订单状态
			 */

			settleOrder.setSucceeded(1);
			
			settleOrderService.update(settleOrder);
			
			autoMonitorOrderService.updateSucceedByBonusOrderNo(settleOrder.getOrder_no());

			/*
			 * 报表处理
			 */
			dAppUserDataSumService.saveSettle(settleOrder.getVolume());

		}

	}
	
	
	private void recover(SettleOrder settleOrder) {
		SettleOrder rebirth = new SettleOrder();
		rebirth.setCreated(new Date());
		rebirth.setFrom_address(settleOrder.getFrom_address());
		rebirth.setTo_address(settleOrder.getTo_address());
		rebirth.setVolume(settleOrder.getVolume());
		rebirth.setOrder_no(settleOrder.getOrder_no());
		rebirth.setSucceeded(-1);
		
		this.settleOrderService.save(rebirth);
		
		tipService.saveTip(rebirth.getId().toString(), TipConstants.AUTO_MONITOR_SETTLE);
	}

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

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

	public void setSettleOrderService(SettleOrderService settleOrderService) {
		this.settleOrderService = settleOrderService;
	}

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

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

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

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

	public void setTipService(TipService tipService) {
		this.tipService = tipService;
	}

}