Browse Source

12-04 累充事务隔离

milestone-20251205-消费
lijianlin 1 month ago
parent
commit
ec2afc99fa
  1. 1
      src/main/java/com/example/demo/service/Temporary/RedService.java
  2. 4
      src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java
  3. 4
      src/main/java/com/example/demo/serviceImpl/coin/AuditServiceImpl.java

1
src/main/java/com/example/demo/service/Temporary/RedService.java

@ -14,6 +14,7 @@ import java.math.BigDecimal;
**/ **/
public interface RedService { public interface RedService {
BigDecimal selectSum(Integer jwcode, Integer type); BigDecimal selectSum(Integer jwcode, Integer type);
void addAmount(Integer jwcode,BigDecimal sum, Integer type); void addAmount(Integer jwcode,BigDecimal sum, Integer type);
String sendJwcode(Integer jwcode); String sendJwcode(Integer jwcode);
} }

4
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 lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.io.IOException; import java.io.IOException;
@ -62,7 +63,8 @@ public class RedServiceImpl implements RedService {
} }
@Override @Override
@Transactional(rollbackFor = Exception.class)
// @Transactional(rollbackFor = Exception.class)
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void addAmount(Integer jwcode, BigDecimal sum, Integer type) { public void addAmount(Integer jwcode, BigDecimal sum, Integer type) {
// 1. 基础参数校验 // 1. 基础参数校验
validateParams(jwcode, type, sum); validateParams(jwcode, type, sum);

4
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( BigDecimal sum = BigDecimal.valueOf(
order.getPermanentGold()) order.getPermanentGold())
.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP); .divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP);
@ -128,7 +128,7 @@ public class AuditServiceImpl implements AuditService {
redService.addAmount(order.getJwcode(), sum, 1); // 直接调你写好的方法 redService.addAmount(order.getJwcode(), sum, 1); // 直接调你写好的方法
} catch (Exception e) { } catch (Exception e) {
log.warn("红包累加失败,主流程继续 | jwcode={}", order.getJwcode(), e); log.warn("红包累加失败,主流程继续 | jwcode={}", order.getJwcode(), e);
}*/
}
redService.sendJwcode(order.getJwcode()); redService.sendJwcode(order.getJwcode());

Loading…
Cancel
Save