From 664184af3e070dee665ee736caffa0297804975f Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 18 Mar 2025 11:46:02 +0800
Subject: [PATCH] perf(mall): 移除会员利润计算中的异步执行
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 53 ++++++++++++++++++++++++++++++++++-------------------
1 files changed, 34 insertions(+), 19 deletions(-)
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 275e13c..ae9058e 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
@@ -30,7 +30,6 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
-import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
/**
@@ -765,24 +764,40 @@
continue;
}
for (MallMember item : directMembers) {
- CompletableFuture.runAsync(() -> {
- BigDecimal realScore = calculateDirectScore(memberRunVip, item, operationDate, runVipMap);
- if(BigDecimal.ZERO.compareTo(realScore) >= 0){
- return;
- }
- walletService.addScore(realScore, memberId);
- String orderNo = MallUtils.getOrderNum("ZLS");
- mallMoneyFlowService.runVipMoneyFlowAdd(
- memberId,
- item.getId(),
- orderNo,
- FlowTypeEnum.SCORE.getValue(),
- RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getValue(),
- realScore,
- StrUtil.format(RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getDescription(), realScore),
- YesOrNoEnum.YES.getValue()
- );
- },febsConfigure.asyncThreadPoolTaskExecutor());
+ BigDecimal realScore = calculateDirectScore(memberRunVip, item, operationDate, runVipMap);
+ if(BigDecimal.ZERO.compareTo(realScore) >= 0){
+ return;
+ }
+ walletService.addScore(realScore, memberId);
+ String orderNo = MallUtils.getOrderNum("ZLS");
+ mallMoneyFlowService.runVipMoneyFlowAdd(
+ memberId,
+ item.getId(),
+ orderNo,
+ FlowTypeEnum.SCORE.getValue(),
+ RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getValue(),
+ realScore,
+ StrUtil.format(RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getDescription(), realScore),
+ YesOrNoEnum.YES.getValue()
+ );
+// CompletableFuture.runAsync(() -> {
+// BigDecimal realScore = calculateDirectScore(memberRunVip, item, operationDate, runVipMap);
+// if(BigDecimal.ZERO.compareTo(realScore) >= 0){
+// return;
+// }
+// walletService.addScore(realScore, memberId);
+// String orderNo = MallUtils.getOrderNum("ZLS");
+// mallMoneyFlowService.runVipMoneyFlowAdd(
+// memberId,
+// item.getId(),
+// orderNo,
+// FlowTypeEnum.SCORE.getValue(),
+// RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getValue(),
+// realScore,
+// StrUtil.format(RunVipMoneyFlowTypeEnum.DIRECT_SCORE.getDescription(), realScore),
+// YesOrNoEnum.YES.getValue()
+// );
+// },febsConfigure.asyncThreadPoolTaskExecutor());
}
}
} catch (Exception e) {
--
Gitblit v1.9.1