From 200ae637c9a501d2e71098cd3f104742bb61a386 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Sat, 06 Jul 2024 13:31:23 +0800
Subject: [PATCH] 逻辑
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 31 +++++++++++++++++++++++++++++++
1 files changed, 31 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index 47107c2..ae56277 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -21,6 +21,7 @@
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -58,6 +59,7 @@
private final ChainProducer chainProducer;
private final DappSystemDao dappSystemDao;
private final DbMemberNodeMapper dbMemberNodeMapper;
+ private final DappStorageMapper dappStorageMapper;
@Override
public WalletInfoVo walletInfo() {
@@ -79,6 +81,22 @@
);
BigDecimal withdrawPercent = new BigDecimal(withdrawPercentDic.getValue());
walletInfo.setWithdrawPercent(withdrawPercent);
+
+ QueryWrapper<DappStorage> objectQueryWrapper = new QueryWrapper<>();
+ objectQueryWrapper.eq("member_id",member.getId());
+ objectQueryWrapper.eq("state",1);
+ List<DappStorage> dappStorages = dappStorageMapper.selectList(objectQueryWrapper);
+ BigDecimal storageAva = BigDecimal.ZERO;
+ if(CollUtil.isNotEmpty(dappStorages)){
+ storageAva = dappStorages.stream().map(DappStorage::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
+ }
+ walletInfo.setStorageAva(storageAva);
+
+ BigDecimal staticPerk = dappFundFlowDao.selectSumAmountByMemberIdAndType(member.getId(), MoneyFlowEnum.STATIC_PERK.getValue());
+ walletInfo.setStaticPerk(staticPerk);
+
+ BigDecimal runPerk = dappFundFlowDao.selectSumRunPerkByMemberId(member.getId());
+ walletInfo.setRunPerk(runPerk);
return walletInfo;
}
@@ -380,6 +398,13 @@
throw new FebsException("存储数量必须是"+bigDecimal+"的整数倍");
}
+ DappStorage dappStorage = dappStorageMapper.selectAmountByAmountDesc(0, 1);
+ if(ObjectUtil.isNotEmpty(dappStorage)){
+ if(amount.compareTo(dappStorage.getAmount()) < 0){
+ throw new FebsException("存储数量必须大于："+dappStorage.getAmount());
+ }
+ }
+
if (ObjectUtil.isEmpty(transferDto.getId())) {
DappFundFlowEntity fundFlow = new DappFundFlowEntity(
@@ -639,6 +664,12 @@
DataDictionaryEnum.JI_SHU_CHI.getType(),
DataDictionaryEnum.JI_SHU_CHI.getCode()
).getValue());
+ List<DappStorage> dappStorages = dappStorageMapper.selectListGroupByMemberId();
+ apiIndexInfoVo.setAddressNum(CollUtil.isEmpty(dappStorages) ? 0 : dappStorages.size());
+
+ DappStorage dappStorage = dappStorageMapper.selectOneByCreateTimeDesc(0, 1);
+ apiIndexInfoVo.setBuChangDate(ObjectUtil.isEmpty(dappStorage) ?
+ DateUtil.offsetDay(new Date(), 1) : DateUtil.offsetDay(dappStorage.getCreateTime(), 1));
return apiIndexInfoVo;
}
--
Gitblit v1.9.1