From 9b0f5ea9a1133472191eeb4e45a1164acc66291e Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 09:56:16 +0800
Subject: [PATCH] 星级买入
---
src/main/java/cc/mrbird/febs/dapp/service/DappWalletService.java | 3 +
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 87 +++++++++++++++-------------
src/main/java/cc/mrbird/febs/dapp/controller/ApiDappMemberController.java | 10 +++
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 20 ++++++
src/main/java/cc/mrbird/febs/dapp/vo/NodeTypeVo.java | 19 ++++++
src/main/java/cc/mrbird/febs/dapp/enumerate/NodeType.java | 37 ++++++++----
6 files changed, 122 insertions(+), 54 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/controller/ApiDappMemberController.java b/src/main/java/cc/mrbird/febs/dapp/controller/ApiDappMemberController.java
index 3d5e86e..0a6f69a 100644
--- a/src/main/java/cc/mrbird/febs/dapp/controller/ApiDappMemberController.java
+++ b/src/main/java/cc/mrbird/febs/dapp/controller/ApiDappMemberController.java
@@ -10,6 +10,7 @@
import cc.mrbird.febs.dapp.service.DappMemberService;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.DappWalletService;
+import cc.mrbird.febs.dapp.vo.NodeTypeVo;
import cc.mrbird.febs.dapp.vo.TeamListVo;
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import io.swagger.annotations.Api;
@@ -56,6 +57,15 @@
return new FebsResponse().success().data(dappWalletService.buyNode(buyNodeDto));
}
+ @ApiOperation(value = "获取星团集合", notes = "获取星团集合")
+ @ApiResponses({
+ @ApiResponse(code = 200, message = "success", response = NodeTypeVo.class)
+ })
+ @PostMapping(value = "/nodeList")
+ public FebsResponse nodeList() {
+ return dappWalletService.nodeList();
+ }
+
@ApiOperation(value = "购买星团", notes = "购买星团")
@PostMapping(value = "/buyStar")
public FebsResponse buyStar(@RequestBody BuyStarDto buyStarDto) {
diff --git a/src/main/java/cc/mrbird/febs/dapp/enumerate/NodeType.java b/src/main/java/cc/mrbird/febs/dapp/enumerate/NodeType.java
index 410fcd4..e669bbe 100644
--- a/src/main/java/cc/mrbird/febs/dapp/enumerate/NodeType.java
+++ b/src/main/java/cc/mrbird/febs/dapp/enumerate/NodeType.java
@@ -3,6 +3,9 @@
import lombok.Getter;
import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
@Getter
public enum NodeType {
/**
@@ -12,19 +15,19 @@
* 30*1.4*1.4
*/
- NODE_13(13,"566.9","793.66"),
- NODE_12(12,"405","566.9"),
- NODE_11(11,"289.3","405"),
- NODE_10(10,"206.6","289.3"),
- NODE_9(9,"147.6","206.6"),
- NODE_8(8,"105.4","147.6"),
- NODE_7(7,"75.3","105.4"),
- NODE_6(6,"53.8","75.3"),
- NODE_5(5,"38.4","53.8"),
- NODE_4(4,"27.4","38.4"),
- NODE_3(3,"19.6","27.4"),
- NODE_2(2,"14","19.6"),
- NODE_1(1,"10","14");
+ NODE_13(13,"1700.817","2381.144"),
+ NODE_12(12,"1214.869","1700.817"),
+ NODE_11(11,"867.763","1214.869"),
+ NODE_10(10,"619.831","867.763"),
+ NODE_9(9,"442.736","619.831"),
+ NODE_8(8,"316.24","442.736"),
+ NODE_7(7,"225.886","316.24"),
+ NODE_6(6,"161.347","225.886"),
+ NODE_5(5,"115.248","161.347"),
+ NODE_4(4,"82.32","115.248"),
+ NODE_3(3,"58.8","82.32"),
+ NODE_2(2,"42","58.8"),
+ NODE_1(1,"30","42");
private int nodeType;
@@ -56,4 +59,12 @@
return null;
}
+ public List<NodeType> getNodeList() {
+ List<NodeType> objects = new ArrayList<>();
+ for (NodeType value : NodeType.values()) {
+ objects.add(value);
+ }
+ return objects;
+ }
+
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/DappWalletService.java b/src/main/java/cc/mrbird/febs/dapp/service/DappWalletService.java
index f2e0a25..322853f 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/DappWalletService.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/DappWalletService.java
@@ -1,5 +1,6 @@
package cc.mrbird.febs.dapp.service;
+import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.dapp.dto.*;
import cc.mrbird.febs.dapp.entity.DappAccountMoneyChangeEntity;
@@ -45,4 +46,6 @@
Long buyNode(BuyNodeDto buyNodeDto);
Long buyStar(BuyStarDto buyStarDto);
+
+ FebsResponse nodeList();
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index a63588c..bd152c4 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -268,49 +268,54 @@
if(inviteNum > dappMemberEntities.size()){
return;
}
+ //任何星级，10轮,收益本金都返回
Integer countFund = dbMemberNodeRoot.getCountFund();
- Integer type = dbMemberNodeRoot.getType();
- //如果是13星局，则直接复投产生收益
- if(NodeType.NODE_13.getNodeType() == type){
- //复投
- futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
- //产生收益
- BigDecimal perkAmount = dbMemberNodeRoot.getAmount().multiply(new BigDecimal("1.4"));
- perkSevenTeen(memberId,perkAmount,countFund);
- return;
- }
- //如果是1到12星团
- if(type >=NodeType.NODE_1.getNodeType() && type <= NodeType.NODE_12.getNodeType()){
- //需要复投本轮，
- //如果是第一轮,当下一个星团没有投入时，收益复投下一个新团
- //如果是第一轮,下一个新团有投入，则产生收益
- //复投或者收益的金额
- BigDecimal nodeAmount = dbMemberNodeRoot.getAmount().multiply(new BigDecimal("1.4"));
- if(1 == countFund){//第一轮
- //复投本轮，轮数 +1
- futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
- //收益复投(当前的下一个星团没有已投入)，还是收益提出
- Integer nextType = type + 1;
- QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
- nodeQueryWrapper.eq("member_id",memberId);
- nodeQueryWrapper.eq("type", nextType);
- nodeQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
- DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(nodeQueryWrapper);
- if(ObjectUtil.isEmpty(dbMemberNode)){
- futouSixTeen(memberId,nodeAmount,nextType,1);
- }else{
- perkSevenTeen(memberId,nodeAmount,countFund);
- }
- }else if(countFund <= 9 && countFund >= 2){//2-9轮
- //复投本轮，轮数 +1
- futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
- perkSevenTeen(memberId,nodeAmount,countFund);
- }else{//10轮,收益本金都返回
- BigDecimal add = dbMemberNodeRoot.getAmount().add(nodeAmount);
- perkSevenTeen(memberId,add,countFund);
+ //收益
+ BigDecimal perkAmount = dbMemberNodeRoot.getAmount().multiply(new BigDecimal("1.4"));
+ if(10 == countFund){//任何星级，10轮,收益本金都返回
+ BigDecimal add = dbMemberNodeRoot.getAmount().add(perkAmount);
+ perkSevenTeen(memberId,add,countFund);
- dbMemberNodeRoot.setWorkState(DbMemberNode.STATE_TWO);
- dbMemberNodeMapper.updateById(dbMemberNodeRoot);
+ dbMemberNodeRoot.setWorkState(DbMemberNode.STATE_TWO);
+ dbMemberNodeMapper.updateById(dbMemberNodeRoot);
+
+ return;
+ }else{
+ Integer type = dbMemberNodeRoot.getType();
+ //如果是13星局，则直接复投产生收益
+ if(NodeType.NODE_13.getNodeType() == type){
+ //复投
+ futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
+ //产生收益
+ perkSevenTeen(memberId,perkAmount,countFund);
+ return;
+ }
+ //如果是1到12星团
+ if(type >=NodeType.NODE_1.getNodeType() && type <= NodeType.NODE_12.getNodeType()){
+ //需要复投本轮，
+ //如果是第一轮,当下一个星团没有投入时，收益复投下一个新团
+ //如果是第一轮,下一个新团有投入，则产生收益
+ //复投或者收益的金额
+ if(1 == countFund){//第一轮
+ //复投本轮，轮数 +1
+ futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
+ //收益复投(当前的下一个星团没有已投入)，还是收益提出
+ Integer nextType = type + 1;
+ QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
+ nodeQueryWrapper.eq("member_id",memberId);
+ nodeQueryWrapper.eq("type", nextType);
+ nodeQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+ DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(nodeQueryWrapper);
+ if(ObjectUtil.isEmpty(dbMemberNode)){
+ futouSixTeen(memberId,perkAmount,nextType,1);
+ }else{
+ perkSevenTeen(memberId,perkAmount,countFund);
+ }
+ }else{//2-9轮
+ //复投本轮，轮数 +1
+ futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
+ perkSevenTeen(memberId,perkAmount,countFund);
+ }
}
}
}
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 8a19784..71bf14b 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
@@ -1,5 +1,6 @@
package cc.mrbird.febs.dapp.service.impl;
+import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.LoginUserUtil;
@@ -9,8 +10,10 @@
import cc.mrbird.febs.dapp.dto.*;
import cc.mrbird.febs.dapp.entity.*;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
+import cc.mrbird.febs.dapp.enumerate.NodeType;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappWalletService;
+import cc.mrbird.febs.dapp.vo.NodeTypeVo;
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
@@ -26,6 +29,7 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -444,4 +448,20 @@
}
return null;
}
+
+ @Override
+ public FebsResponse nodeList() {
+ List<NodeType> nodeList = NodeType.NODE_1.getNodeList();
+ List<NodeTypeVo> objects = new ArrayList<>();
+ if(CollUtil.isNotEmpty(nodeList)){
+ for(NodeType nodeType : nodeList){
+ NodeTypeVo nodeTypeVo = new NodeTypeVo();
+ nodeTypeVo.setNodeType(nodeType.getNodeType());
+ nodeTypeVo.setNodeAmount(nodeType.getNodeAmount());
+ nodeTypeVo.setNodePerk(nodeType.getNodePerk());
+ objects.add(nodeTypeVo);
+ }
+ }
+ return new FebsResponse().success().data(objects);
+ }
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/vo/NodeTypeVo.java b/src/main/java/cc/mrbird/febs/dapp/vo/NodeTypeVo.java
new file mode 100644
index 0000000..5e504c0
--- /dev/null
+++ b/src/main/java/cc/mrbird/febs/dapp/vo/NodeTypeVo.java
@@ -0,0 +1,19 @@
+package cc.mrbird.febs.dapp.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel(value = "NodeTypeVo", description = "星团")
+public class NodeTypeVo {
+
+ @ApiModelProperty(value = "星团类型")
+ private int nodeType;
+
+ @ApiModelProperty(value = "投入金额")
+ private String nodeAmount;
+
+ @ApiModelProperty(value = "奖励")
+ private String nodePerk;
+}
--
Gitblit v1.9.1