From 487436c06905bf5599d062990c90d5cc4b383733 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 20 May 2024 16:53:56 +0800
Subject: [PATCH] 直推和间接直推的奖励各50%
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 101 ++++++++++++++++++++++++++++----------------------
src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java | 5 ++
2 files changed, 61 insertions(+), 45 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java b/src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java
index cd2ca46..c3b5003 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/IMemberProfitService.java
@@ -1,5 +1,8 @@
package cc.mrbird.febs.mall.service;
+import cc.mrbird.febs.mall.entity.MallMember;
+
+import java.math.BigDecimal;
import java.util.Date;
/**
@@ -61,4 +64,6 @@
void fcmOrderSellInsureMsg(Long sellRecordId);
void fcmOrderBuyCancelMsg(Long buyRecordId);
+
+ void createPerk(MallMember mallMember, BigDecimal basicPerkDirect);
}
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
index f8bd903..8215a58 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
@@ -1298,51 +1298,10 @@
/**
* 如果用户是冻结，则直接销毁
*/
- Integer isFrozen = directMember.getIsFrozen();
- if(ProductEnum.MEMBER_FROZEN.getValue() == isFrozen){
-
- MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(directMember.getId());
- if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
- return;
- }
- mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
- mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmountMine);
- //插入一条流水记录
- String orderNo = MallUtils.getOrderNum("FNFTW");
- mallMoneyFlowService.addMoneyFlow(
- directMember.getId(),
- basicPerkDirect.negate(),
- MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
- orderNo,
- null,
- FlowTypeNewEnum.NFT.getValue(),
- MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
- AppContants.MEMBER_FLOW_ING);
-
- }else {
-
- MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(directMember.getId());
- if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
- return;
- }
- mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
- mallMemberAmountMapper.updateTotalPerkById(mallMemberAmountMine);
-
- MallMemberAmount mallMemberAmountNft = mallMemberAmountMapper.selectByMemberId(directMember.getId());
- mallMemberAmountNft.setTrendsNft(mallMemberAmountNft.getTrendsNft().add(basicPerkDirect));
- mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountNft);
-
- //插入一条流水记录
- String orderNo = MallUtils.getOrderNum("NFT");
- mallMoneyFlowService.addMoneyFlow(
- directMember.getId(),
- basicPerkDirect,
- MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
- orderNo,
- null,
- FlowTypeNewEnum.NFT.getValue(),
- MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
- AppContants.MEMBER_FLOW_DONE);
+ createPerk(directMember,basicPerkDirect.multiply(new BigDecimal(0.5)));
+ if(StrUtil.isNotEmpty(directMember.getReferrerId())){
+ MallMember directMemberDirect = mallMemberMapper.selectInfoByInviteId(directMember.getReferrerId());
+ createPerk(directMemberDirect,basicPerkDirect.multiply(new BigDecimal(0.5)));
}
}
}
@@ -1350,6 +1309,58 @@
}
}
+
+ @Override
+ public void createPerk(MallMember mallMember,BigDecimal basicPerkDirect){
+ /**
+ * 如果用户是冻结，则直接销毁
+ */
+ Integer isFrozen = mallMember.getIsFrozen();
+ if(ProductEnum.MEMBER_FROZEN.getValue() == isFrozen){
+ MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
+ if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
+ return;
+ }
+ mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
+ mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmountMine);
+ //插入一条流水记录
+ String orderNo = MallUtils.getOrderNum("FNFTW");
+ mallMoneyFlowService.addMoneyFlow(
+ mallMember.getId(),
+ basicPerkDirect.negate(),
+ MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
+ orderNo,
+ null,
+ FlowTypeNewEnum.NFT.getValue(),
+ MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
+ AppContants.MEMBER_FLOW_ING);
+
+ }else {
+ MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
+ if(BigDecimal.ZERO.compareTo(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect)) >= 0){
+ return;
+ }
+ mallMemberAmountMine.setTotalPerk(mallMemberAmountMine.getTotalPerk().subtract(basicPerkDirect));
+ mallMemberAmountMapper.updateTotalPerkById(mallMemberAmountMine);
+
+ MallMemberAmount mallMemberAmountNft = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
+ mallMemberAmountNft.setTrendsNft(mallMemberAmountNft.getTrendsNft().add(basicPerkDirect));
+ mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountNft);
+
+ //插入一条流水记录
+ String orderNo = MallUtils.getOrderNum("NFT");
+ mallMoneyFlowService.addMoneyFlow(
+ mallMember.getId(),
+ basicPerkDirect,
+ MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
+ orderNo,
+ null,
+ FlowTypeNewEnum.NFT.getValue(),
+ MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
+ AppContants.MEMBER_FLOW_DONE);
+ }
+ }
+
@Override
public void fcmOrderBuyCancelMsg(Long buyRecordId) {
MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(buyRecordId);
--
Gitblit v1.9.1