package cc.mrbird.febs.dapp.service.impl;
|
|
import cc.mrbird.febs.dapp.chain.ChainEnum;
|
import cc.mrbird.febs.dapp.chain.ChainService;
|
import cc.mrbird.febs.dapp.chain.ContractEventService;
|
import cc.mrbird.febs.dapp.chain.EthUsdtContract;
|
import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
|
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
|
import cc.mrbird.febs.dapp.entity.DappStorage;
|
import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
|
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
|
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
|
import cc.mrbird.febs.dapp.mapper.DappStorageMapper;
|
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
|
import cc.mrbird.febs.dapp.service.DappMemberService;
|
import cc.mrbird.febs.rabbit.producer.ChainProducer;
|
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;
|
|
@Slf4j
|
@Service
|
public class BscUsdtContractEvent implements ContractEventService {
|
|
@Resource
|
private DappMemberService dappMemberService;
|
@Resource
|
private DappFundFlowDao dappFundFlowDao;
|
@Resource
|
private DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
@Resource
|
private DappStorageMapper dappStorageMapper;
|
@Resource
|
private ChainProducer chainProducer;
|
|
@Override
|
public void compile(EthUsdtContract.TransferEventResponse e) {
|
return;
|
}
|
|
@Override
|
public void sdmUSDT(EthUsdtContract.TransferEventResponse e) {
|
return;
|
}
|
|
@Override
|
public void receivePeopleEvent(EthUsdtContract.ReceivePeopleEventResponse e) {
|
if (e.from == null) {
|
return;
|
}
|
|
if (e.regFlow == null) {
|
return;
|
}
|
|
Long flowId = Long.parseLong(e.regFlow);
|
|
int decimals = ChainService.getInstance(ChainEnum.BSC_TFC.name()).decimals();
|
BigInteger tokens = e.tokens;
|
BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
|
log.info("触发用户存储：{}，金额：{}，流水ID：{}",e.from,amount,flowId);
|
// 账户是否已经注册
|
DappMemberEntity fromMember = dappMemberService.findByAddress(e.from, null);
|
if (fromMember == null) {
|
return;
|
}
|
// 判断是否已经同步过了
|
DappFundFlowEntity fundFlow = dappFundFlowDao.selectById(flowId);
|
if (fundFlow != null && fundFlow.getStatus() != 1) {
|
return;
|
}
|
// 更改状态为已同步
|
fundFlow.setStatus(2);
|
dappFundFlowDao.updateById(fundFlow);
|
|
log.info("触发用户存储：{}，金额：{}，流水ID：{}",e.from,amount,flowId);
|
|
/**
|
* 新增一条记录
|
*/
|
DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
DataDictionaryEnum.RELEASE_PERCENT.getType(),
|
DataDictionaryEnum.RELEASE_PERCENT.getCode()
|
);
|
BigDecimal releasePercent = new BigDecimal(dataDictionaryCustom.getValue());
|
DappStorage dappStorage = new DappStorage();
|
dappStorage.setState(1);
|
dappStorage.setAmount(amount);
|
dappStorage.setReleasePercent(releasePercent);
|
BigDecimal releaseAmount = amount.multiply(releasePercent).setScale(2, BigDecimal.ROUND_DOWN);
|
dappStorage.setReleaseAmount(releaseAmount);
|
dappStorageMapper.insert(dappStorage);
|
|
Long id = fundFlow.getId();
|
Long memberId = fromMember.getId();
|
/**
|
* 发送直推8%
|
*/
|
chainProducer.sendDirectPerkMsg(id);
|
/**
|
* DAO成员动态：
|
* * 1.直推1个拿2代，直推10个拿20代，直推15个拿30代，最高30代
|
*/
|
chainProducer.sendMemberDynamicPerkMsg(id);
|
/**
|
*
|
* * 六、永动补偿池2％
|
* * 五、DAO永动激励池：6%
|
* * 四、DAO联盟委员会 ： 5% （50名全球DAO委员）
|
*/
|
chainProducer.sendNodePerkMsg(id);
|
/**
|
*3. 成员升级
|
* * DAO1：小区业绩30万/币 加权分红50%
|
* * DAO2：小区业绩100万/币 加权分红30%
|
* * DAO3：小区业绩500万/币加权分红20%
|
*/
|
chainProducer.sendMemberLevel(memberId);
|
}
|
|
}
|
