From 8986d6d479bf56432ebb8e18bfa0f344d028eee6 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 12 Jun 2024 18:06:11 +0800
Subject: [PATCH] 星级买入
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 53 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 df7aa05..8a19784 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
@@ -13,8 +13,10 @@
import cc.mrbird.febs.dapp.service.DappWalletService;
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor;
@@ -47,6 +49,7 @@
private final ChainProducer chainProducer;
private final DappSystemDao dappSystemDao;
+ private final DbMemberNodeMapper dbMemberNodeMapper;
@Override
public WalletInfoVo walletInfo() {
@@ -391,4 +394,54 @@
}
return null;
}
+
+ @Override
+ public Long buyStar(BuyStarDto buyStarDto) {
+ DappMemberEntity member = LoginUserUtil.getAppUser();
+
+ String upgrade = redisUtils.getString("APP_UPGRADE");
+ if ("upgrade".equals(upgrade)) {
+ throw new FebsException("功能升级中");
+ }
+
+ /**
+ * 买入先验证当前星团是否已经买入
+ */
+ Integer nodeType = buyStarDto.getNodeType();
+ QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
+ nodeQueryWrapper.eq("member_id",member.getId());
+ nodeQueryWrapper.eq("type", nodeType);
+ nodeQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+ List<DbMemberNode> dbMemberNodes = dbMemberNodeMapper.selectList(nodeQueryWrapper);
+ if(CollUtil.isNotEmpty(dbMemberNodes)){
+ throw new FebsException("已购买");
+ }
+
+ if (ObjectUtil.isEmpty(buyStarDto.getId())) {//第一次
+ DappFundFlowEntity fundFlow = new DappFundFlowEntity(
+ member.getId(),
+ buyStarDto.getAmount().negate(),
+ 18,
+ 1,
+ BigDecimal.ZERO,
+ buyStarDto.getTxHash());
+ dappFundFlowDao.insert(fundFlow);
+ return fundFlow.getId();
+ } else {//第二次
+ DappFundFlowEntity flow = dappFundFlowDao.selectById(buyStarDto.getId());
+ if(ObjectUtil.isEmpty(flow)){
+ return null;
+ }
+ if ("success".equals(buyStarDto.getFlag())) {
+ flow.setFromHash(buyStarDto.getTxHash());
+ flow.setToHash(buyStarDto.getNodeType().toString());
+ dappFundFlowDao.updateById(flow);
+ } else {
+ if (flow.getStatus() == 1) {
+ dappFundFlowDao.deleteById(buyStarDto.getId());
+ }
+ }
+ }
+ return null;
+ }
}
--
Gitblit v1.9.1