package cc.mrbird.febs.mall.chain;
|
|
import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;
|
import cc.mrbird.febs.common.enumerates.GameFlowTypeEnum;
|
import cc.mrbird.febs.common.utils.MallUtils;
|
import cc.mrbird.febs.common.utils.RedisUtils;
|
import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
|
import cc.mrbird.febs.mall.entity.MallMember;
|
import cc.mrbird.febs.mall.entity.MallMemberCharge;
|
import cc.mrbird.febs.mall.entity.MallMemberWallet;
|
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
|
import cc.mrbird.febs.mall.mapper.MallMemberChargeMapper;
|
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
|
import cc.mrbird.febs.mall.mapper.MallMemberWalletMapper;
|
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import sun.rmi.runtime.Log;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.math.BigInteger;
|
import java.math.RoundingMode;
|
|
@Slf4j
|
@Service
|
public class BscUsdtContractEvent implements ContractEventService {
|
|
@Resource
|
private RedisUtils redisUtils;
|
|
@Resource
|
private DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
|
@Resource
|
private MallMemberMapper mallMemberMapper;
|
@Resource
|
private MallMemberChargeMapper mallMemberChargeMapper;
|
@Resource
|
private IMallMoneyFlowService mallMoneyFlowService;
|
@Resource
|
private MallMemberWalletMapper mallMemberWalletMapper;
|
|
@Override
|
public void compile(EthUsdtContract.TransferEventResponse e) {
|
return;
|
}
|
|
@Override
|
public void sdmUSDT(EthUsdtContract.TransferEventResponse e) {
|
if (e.to == null) {
|
return;
|
}
|
|
|
// 判断收款地址是否是设置的平台地址
|
if ("0xFB81C6649cd853e3193acE1e7c91A4e6cF0c6D92".toLowerCase().equals(e.to)) {
|
|
ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name());
|
int decimals = sourceUsdtInstance.decimals();
|
|
String fromAddress = e.from;
|
if (fromAddress.equals("0xFB81C6649cd853e3193acE1e7c91A4e6cF0c6D92")) {
|
return;
|
}
|
|
QueryWrapper<MallMember> objectQueryWrapper = new QueryWrapper<>();
|
objectQueryWrapper.eq("bind_phone",fromAddress.toLowerCase());
|
MallMember fromMember = mallMemberMapper.selectOne(objectQueryWrapper);
|
if(ObjectUtil.isEmpty(fromMember)){
|
return;
|
}
|
|
BigInteger tokens = e.tokens;
|
BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
|
log.info("用户充值，{}，金额：{}",fromAddress,amount);
|
|
MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(fromMember.getId());
|
mallMemberWallet.setBalance(mallMemberWallet.getBalance().add(amount));
|
mallMemberWalletMapper.updateBalanceWithVersion(mallMemberWallet);
|
|
MallMemberCharge mallMemberCharge = new MallMemberCharge();
|
mallMemberCharge.setMemberId(fromMember.getId());
|
mallMemberCharge.setAmount(amount);
|
mallMemberCharge.setAddress(fromAddress);
|
mallMemberCharge.setState(2);
|
mallMemberChargeMapper.insert(mallMemberCharge);
|
|
mallMoneyFlowService.addMoneyFlow(
|
fromMember.getId(),
|
amount.abs(),
|
GameFlowTypeEnum.PLAYER_CHARGE.getValue(),
|
MallUtils.getOrderNum("CZ"),
|
GameFlowTypeEnum.PLAYER_CHARGE.getDescrition());
|
|
}
|
}
|
|
|
}
|
