package cc.mrbird.febs.mall.chain.ercCoin;

import cc.mrbird.febs.common.enumerates.RunVipDataDictionaryEnum;
import cc.mrbird.febs.common.enumerates.YesOrNoEnum;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.mall.entity.MallCharge;
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.mall.mapper.MallChargeMapper;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.math.RoundingMode;
import java.util.List;

@Slf4j
@Service
public class BscUsdtContractEvent implements ContractEventService {

    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;

    @Resource
    private MallChargeMapper mallChargeMapper;
    @Resource
    private AgentProducer agentProducer;
    @Resource
    private RedisUtils redisUtils;

    @Override
    public void sdmUSDT(EthUsdtContract.TransferEventResponse e) {
        if (e.to == null) {
            return;
        }
        String sysAddress = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                RunVipDataDictionaryEnum.CHARGE_SYS_ADDRESS_BSC.getType(),  RunVipDataDictionaryEnum.CHARGE_SYS_ADDRESS_BSC.getCode()
        ).getValue();
        String type = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                RunVipDataDictionaryEnum.CHARGE_TYPE_BSC.getType(),  RunVipDataDictionaryEnum.CHARGE_TYPE_BSC.getCode()
        ).getValue();
        if(StrUtil.isBlank(sysAddress)){
            log.info("系统未设置充值地址");
            return;
        }

        // 判断收款地址是否是设置的平台地址
        if (sysAddress.toLowerCase().equals(e.to)) {

            String transactionHash = e.log.getTransactionHash();
            LambdaQueryWrapper<MallCharge> mallChargeLambdaQueryWrapper = new LambdaQueryWrapper<>();
            mallChargeLambdaQueryWrapper.eq(MallCharge::getTransHash, transactionHash);
            List<MallCharge> list = mallChargeMapper.selectList(mallChargeLambdaQueryWrapper);
            if(CollUtil.isNotEmpty(list)){
                log.info("扫描到HASH已使用：{}",transactionHash);
                return;
            }

            ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name());
            int decimals = sourceUsdtInstance.decimals();

            String fromAddress = e.from;
            if (fromAddress.equals(sysAddress.toLowerCase())) {
                log.info("系统地址转出：{}",transactionHash);
                return;
            }

            BigInteger tokens = e.tokens;
            BigDecimal amount = new BigDecimal(tokens.toString())
                    .divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN)
                    .setScale(2,RoundingMode.DOWN);


            String chargeRedis = redisUtils.getString(AppContants.CHARGE_AMOUNT_PROFIX + amount);
            if (StrUtil.isBlank(chargeRedis)) {
                log.info("Redis未扫描到充值金额：{}",transactionHash);
                return;
            }else{
                redisUtils.del(AppContants.CHARGE_AMOUNT_PROFIX + amount);
                log.info("Redis扫描到充值记录：{}，{}",transactionHash,chargeRedis);
            }

            LambdaQueryWrapper<MallCharge> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(MallCharge::getSysAddress, sysAddress);
            queryWrapper.eq(MallCharge::getAmountReal, amount);
            queryWrapper.eq(MallCharge::getMemberId, Long.parseLong(chargeRedis));
            queryWrapper.eq(MallCharge::getType, type);
            queryWrapper.eq(MallCharge::getState, YesOrNoEnum.ING.getValue());
            List<MallCharge> mallCharges = mallChargeMapper.selectList(queryWrapper);
            if(CollUtil.isEmpty(mallCharges)){
                log.info("未查询到匹配充值记录，充值地址：{}，HASH：{}",fromAddress,transactionHash);
                return;
            }
            MallCharge mallCharge = mallCharges.get(0);
            mallCharge.setState(YesOrNoEnum.YES.getValue());
            mallChargeMapper.updateById(mallCharge);

            if(StrUtil.isNotEmpty(mallCharge.getVipCode())){
                agentProducer.sendBuyVipSuccessMsg(mallCharge.getId());
            }else{
                agentProducer.sendChargeSuccessMsg(mallCharge.getId());
            }

            log.info("扫描到用户ID：{}，地址：{}，充值金额：{}",mallCharge.getMemberId(),fromAddress,amount);

        }
    }


}