From cdb4f45b507e52f67c235b6d4b7307ec194f02a1 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 01 Feb 2023 09:51:43 +0800 Subject: [PATCH] 1 --- src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java | 25 +++++++++++++++++++++++++ 1 files changed, 25 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java index b0f58dd..8e7c211 100644 --- a/src/main/java/cc/mrbird/febs/mall/service/impl/BlockSeriveImpl.java +++ b/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(); + } + } -- Gitblit v1.9.1