package com.bizzan.bc.wallet.job;


import com.bizzan.bc.wallet.entity.Coin;
import com.bizzan.bc.wallet.entity.Contract;
import com.bizzan.bc.wallet.service.AccountService;
import com.bizzan.bc.wallet.service.EthService;
import com.bizzan.bc.wallet.util.AccountReplay;
import com.bizzan.bc.wallet.util.MessageResult;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.math.BigInteger;

@Component
public class CoinCollectJob {
    private Logger logger = LoggerFactory.getLogger(CoinCollectJob.class);
    @Autowired
    private AccountService accountService;
    @Autowired
    private EthService ethService;
    @Autowired
    private Coin coin;
    @Autowired
    private Contract contract;

    /**
     * 为用户地址充值矿工费(每1小时执行一次)
     */
    @Scheduled(cron = "0 0 */1 * * ?")
    public void rechargeMinerFee(){
        try {
            AccountReplay accountReplay = new AccountReplay(accountService, 100);
            BigDecimal minerFee = ethService.getMinerFee(contract.getGasLimit());

            accountReplay.run(account -> {
                try {
                    BigDecimal ethBalance = ethService.getBalance(account.getAddress());
                    BigDecimal tokenBalance = ethService.getTokenBalance(account.getAddress());
                    //给满足条件的地址充矿工费，条件1：eth额度小于minerFee,条件2:balance大于等于minCollectAmount
                    if (ethBalance.compareTo(minerFee) < 0
                            && tokenBalance.compareTo(coin.getMinCollectAmount()) >= 0) {
                        logger.info("process account:{}", account);
                        //计算本次要转的矿工费
                        BigDecimal feeAmt = minerFee.subtract(ethBalance);

                        MessageResult mr = ethService.transferFromWithdrawWallet(account.getAddress(), feeAmt, false,"");
                        logger.info("transfer fee {},result:{}", feeAmt, mr);
                        if(mr.getCode() == 0){
                            ethBalance = minerFee;
                        }
                    }
                    //同步账户余额
                    accountService.updateBalanceAndGas(account.getAddress(), tokenBalance, ethBalance);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });
        }
        catch (Exception e){
            e.printStackTrace();
        }
    }
}