//如果有事務(wù), 那么加入事務(wù), 沒(méi)有的話新建一個(gè)(默認(rèn))
@Transactional(propagation=Propagation.REQUIRED)
//容器不為這個(gè)方法開(kāi)啟事務(wù) 
@Transactional(propagation=Propagation.NOT_SUPPORTED)
//不管是否存在事務(wù), 都創(chuàng)建一個(gè)新的事務(wù), 原來(lái)的掛起, 新的執(zhí)行完畢, 繼續(xù)執(zhí)行老的事務(wù) 
@Transactional(propagation=Propagation.REQUIRES_NEW) 
//必須在一個(gè)已有的事務(wù)中執(zhí)行, 否則拋出異常
@Transactional(propagation=Propagation.MANDATORY) 
//必須在一個(gè)沒(méi)有的事務(wù)中執(zhí)行, 否則拋出異常(與Propagation.MANDATORY相反)
@Transactional(propagation=Propagation.NEVER) 
//如果其他bean調(diào)用這個(gè)方法, 在其他bean中聲明事務(wù), 那就用事務(wù), 如果其他bean沒(méi)有聲明事務(wù), 那就不用事務(wù)
@Transactional(propagation=Propagation.SUPPORTS) 

// 讀取未提交數(shù)據(jù)(會(huì)出現(xiàn)臟讀, 不可重復(fù)讀) 基本不使用
@Transactional(isolation = Isolation.READ_UNCOMMITTED)
// 讀取已提交數(shù)據(jù)(會(huì)出現(xiàn)不可重復(fù)讀和幻讀) Oracle默認(rèn)
@Transactional(isolation = Isolation.READ_COMMITTED)
// 可重復(fù)讀(會(huì)出現(xiàn)幻讀) MySQL默認(rèn)
@Transactional(isolation = Isolation.REPEATABLE_READ)
// 串行化
@Transactional(isolation = Isolation.SERIALIZABLE)

/**
 * 商品業(yè)務(wù)實(shí)現(xiàn)層
 *
 * @author: austin
 * @since: 2023/2/10 14:19
 */
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements IProductService {
 
    @Autowired
    private ProductMapper productMapper;
 
    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void updateProductStockById(Integer stockCount, Long productId) {
        productMapper.updateProductStockById(stockCount, productId);
    }
}

@Service
public class OrderServiceImpl {
 
    @Transactional
    public final void cancel(OrderDTO orderDTO) {
        // 取消訂單
        cancelOrder(orderDTO);
    }
}

/**
 * 商品業(yè)務(wù)實(shí)現(xiàn)層
 *
 * @author: austin
 * @since: 2023/2/10 14:19
 */
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements IProductService {
 
    @Autowired
    private ProductMapper productMapper;
 
    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void updateProductStockById(Integer stockCount, String productId) {
        productMapper.updateProductStockById(stockCount, productId);
    }
}

@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private ProductMapper productMapper;
 
    @Override
    public ResponseEntity submitOrder(Order order) {
        // 保存生成訂單信息
        long orderNo = Math.abs(ThreadLocalRandom.current().nextLong(1000));
        order.setOrderNo("ORDER_" + orderNo);
        orderMapper.insert(order);
 
        // 扣減庫(kù)存
        this.updateProductStockById(order.getProductId(), 1L);
        return new ResponseEntity(HttpStatus.OK);
    }
 
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void updateProductStockById(Integer num, Long productId) {
        productMapper.updateProductStockById(num, productId);
    }
}

@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private ProductMapper productMapper;
 
    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public ResponseEntity submitOrder(Order order) {
        long orderNo = Math.abs(ThreadLocalRandom.current().nextLong(1000));
        order.setOrderNo("ORDER_" + orderNo);
        orderMapper.insert(order);
 
        // 扣減庫(kù)存
        this.updateProductStockById(order.getProductId(), 1L);
        return new ResponseEntity(HttpStatus.OK);
    }
 
 
    /**
     * 扣減庫(kù)存方法事務(wù)類型聲明為NOT_SUPPORTED不支持事務(wù)的傳播
     */
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void updateProductStockById(Integer num, Long productId) {
        productMapper.updateProductStockById(num, productId);
    }
}

@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private ProductMapper productMapper;
 
    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public ResponseEntity submitOrder(Order order) {
        long orderNo = Math.abs(ThreadLocalRandom.current().nextLong(1000));
        order.setOrderNo("ORDER_" + orderNo);
        orderMapper.insert(order);
 
        // 扣減庫(kù)存
        this.updateProductStockById(order.getProductId(), 1L);
        return new ResponseEntity(HttpStatus.OK);
    }
 
    /**
     * 扣減庫(kù)存方法事務(wù)類型聲明為NOT_SUPPORTED不支持事務(wù)的傳播
     */
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void updateProductStockById(Integer num, Long productId) {
        try {
            productMapper.updateProductStockById(num, productId);
        } catch (Exception e) {
            // 這里僅僅是捕獲異常之后的打?。ㄏ喈?dāng)于程序吞掉了異常）
            log.error("Error updating product Stock: {}", e);
        }
    }
}

@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}

<!-- 配置事務(wù)管理器 --> 
<bean class="org.springframework.jdbc.datasource.DataSourceTransactionManager" id="transactionManager"> 
    <property name="dataSource" ref="dataSource"></property> 
</bean> 
<tx:advice id="advice" transaction-manager="transactionManager"> 
    <tx:attributes> 
        <tx:method name="*" propagation="REQUIRED"/>
    </tx:attributes> 
</tx:advice> 
<!-- 用切點(diǎn)把事務(wù)切進(jìn)去 --> 
<aop:config> 
    <aop:pointcut expression="execution(* com.universal.ubdk.*.*(..))" id="pointcut"/> 
    <aop:advisor advice-ref="advice" pointcut-ref="pointcut"/> 
</aop:config> 

@Service
public class OrderServiceImpl {
 
    @Transactional(propagation = Propagation.NEVER)
    public void cancelOrder(UserModel userModel) {
        // 取消訂單
        cancelOrder(orderDTO);
        // 還原庫(kù)存
        restoreProductStock(orderDTO.getProductId(), orderDTO.getProductCount());
    }
}

@Slf4j
@Service
public class OrderServiceImpl {
 
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private MessageService messageService;
 
    @Transactional
    public void orderCommit(orderModel orderModel) throws Exception {
        orderMapper.insertOrder(orderModel);
        new Thread(() -> {
            messageService.sendSms();
        }).start();
    }
}
 
@Service
public class MessageService {
 
    @Transactional
    public void sendSms() {
        // 發(fā)送短信
    }
}