From 676177dc1c4967b30470ee50df6fc30caf396aa9 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 17 Jun 2024 09:53:57 +0800
Subject: [PATCH] 节点限购200个
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 20 +++++++++++++++++---
1 files changed, 17 insertions(+), 3 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 f5d03db..806da59 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
@@ -52,7 +52,6 @@
private final ChainProducer chainProducer;
private final DappSystemDao dappSystemDao;
private final DbMemberNodeMapper dbMemberNodeMapper;
- private final DappWalletService dappWalletService;
@Override
public WalletInfoVo walletInfo() {
@@ -379,6 +378,21 @@
if (buyNode >= Integer.parseInt(buyNodeCodeCntDic.getValue())) {
throw new FebsException("Do not repeat purchase");
}
+ /**
+ * 限购总数200
+ */
+
+ DataDictionaryCustom perKNumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PERK_NUM.getType(),
+ DataDictionaryEnum.PERK_NUM.getCode()
+ );
+ int perKNum = Integer.parseInt(ObjectUtil.isEmpty(perKNumDic) ? "200" : perKNumDic.getValue());
+
+ List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectList(null);
+ int sum1 = dappMemberEntities.stream().mapToInt(DappMemberEntity::getBuyNode).sum();
+ if(perKNum < sum1 + 1){
+ throw new FebsException("节点已售完");
+ }
if (ObjectUtil.isEmpty(transferDto.getId())) {
DappFundFlowEntity fundFlow = new DappFundFlowEntity(
@@ -585,8 +599,8 @@
dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_DISAGREE);
dappFundFlowDao.updateById(dappFundFlowEntity);
- dappWalletService.updateWalletCoinWithLock(memberCoinWithdrawEntity.getAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
- dappWalletService.updateWalletMineWithLock(memberCoinWithdrawEntity.getFeeAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
+ this.updateWalletCoinWithLock(memberCoinWithdrawEntity.getAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
+ this.updateWalletMineWithLock(memberCoinWithdrawEntity.getFeeAmount(), memberCoinWithdrawEntity.getMemberId(), 1);
DappFundFlowEntity feeFlow = new DappFundFlowEntity(memberCoinWithdrawEntity.getMemberId(), memberCoinWithdrawEntity.getFeeAmount(), 22, 2, null, null);
dappFundFlowDao.insert(feeFlow);
--
Gitblit v1.9.1