From ec2afc99fad12cef1215b8e7bc25562e13ec2884 Mon Sep 17 00:00:00 2001 From: lijianlin Date: Thu, 4 Dec 2025 15:07:26 +0800 Subject: [PATCH] =?UTF-8?q?12-04=20=E7=B4=AF=E5=85=85=E4=BA=8B=E5=8A=A1?= =?UTF-8?q?=E9=9A=94=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/example/demo/service/Temporary/RedService.java | 1 + .../java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java | 4 +++- src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java | 4 ++-- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/example/demo/service/Temporary/RedService.java b/src/main/java/com/example/demo/service/Temporary/RedService.java index c34495e..de60f87 100644 --- a/src/main/java/com/example/demo/service/Temporary/RedService.java +++ b/src/main/java/com/example/demo/service/Temporary/RedService.java @@ -14,6 +14,7 @@ import java.math.BigDecimal; **/ public interface RedService { BigDecimal selectSum(Integer jwcode, Integer type); + void addAmount(Integer jwcode,BigDecimal sum, Integer type); String sendJwcode(Integer jwcode); } diff --git a/src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java index 91041e7..29f0f98 100644 --- a/src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java @@ -10,6 +10,7 @@ import com.example.demo.service.Temporary.RedService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import java.io.IOException; @@ -62,7 +63,8 @@ public class RedServiceImpl implements RedService { } @Override - @Transactional(rollbackFor = Exception.class) + // @Transactional(rollbackFor = Exception.class) + @Transactional(propagation = Propagation.REQUIRES_NEW) public void addAmount(Integer jwcode, BigDecimal sum, Integer type) { // 1. 基础参数校验 validateParams(jwcode, type, sum); diff --git a/src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java index 4c5772d..2185034 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java @@ -120,7 +120,7 @@ public class AuditServiceImpl implements AuditService { //累充 - /* try { + try { BigDecimal sum = BigDecimal.valueOf( order.getPermanentGold()) .divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP); @@ -128,7 +128,7 @@ public class AuditServiceImpl implements AuditService { redService.addAmount(order.getJwcode(), sum, 1); // ← 直接调你写好的方法! } catch (Exception e) { log.warn("红包累加失败,主流程继续 | jwcode={}", order.getJwcode(), e); - }*/ + } redService.sendJwcode(order.getJwcode());