1

xiaoyong931011

2023-02-01 cdb4f45b507e52f67c235b6d4b7307ec194f02a1

 src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java

@@ -3,13 +3,17 @@
import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.mall.chain.enums.CoinTypeEnum;
import cc.mrbird.febs.mall.chain.service.EthService;
import cc.mrbird.febs.mall.dto.ApiChargeInfoDto;
import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
import cc.mrbird.febs.mall.entity.MallMember;
import cc.mrbird.febs.mall.entity.MemberCoinAddressEntity;
import cc.mrbird.febs.mall.entity.MemberCoinChargeEntity;
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
import cc.mrbird.febs.mall.mapper.MemberCoinAddressDao;
import cc.mrbird.febs.mall.mapper.MemberCoinChargeDao;
import cc.mrbird.febs.mall.service.BlockSerive;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import lombok.extern.slf4j.Slf4j;
@@ -17,6 +21,7 @@
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

@@ -32,6 +37,9 @@

    @Resource
    private AgentProducer agentProducer;

    @Resource
    private MemberCoinChargeDao memberCoinChargeDao;

    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;
@@ -105,4 +113,21 @@
        return new FebsResponse().success().data(value);
    }

    @Override
    public FebsResponse setChargeInfo(ApiChargeInfoDto apiChargeInfoDto) {
        Long mId = LoginUserUtil.getLoginUser().getId();
        MallMember member = memberDao.selectById(mId);
        MemberCoinChargeEntity memberCoinChargeEntity = new MemberCoinChargeEntity();
        memberCoinChargeEntity.setAddress(apiChargeInfoDto.getAddress());
        memberCoinChargeEntity.setMemberId(member.getId());
        memberCoinChargeEntity.setAmount(apiChargeInfoDto.getAmount());
        memberCoinChargeEntity.setSymbol(CoinTypeEnum.USDT.name());
        memberCoinChargeEntity.setTag("ERC20");
        memberCoinChargeEntity.setStatus(1);
        memberCoinChargeEntity.setLastAmount(BigDecimal.ZERO);
        memberCoinChargeEntity.setHash(apiChargeInfoDto.getHash());
        memberCoinChargeDao.insert(memberCoinChargeEntity);
        return new FebsResponse().success();
    }

}