diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java b/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java index 2422440..7c07b35 100644 --- a/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java +++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java @@ -40,6 +40,7 @@ import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Service; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionDefinition; +import org.springframework.transaction.TransactionManager; import org.springframework.transaction.TransactionStatus; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.support.DefaultTransactionDefinition; @@ -130,6 +131,8 @@ public class PayService { private RabbitMsgUtils rabbitMsgUtils; @Autowired private TransactionTemplate transactionTemplate; + @Autowired + private PlatformTransactionManager transactionManager; private final Utils utils; @@ -1023,6 +1026,7 @@ public class PayService { // 提交当前事务 transactionTemplate.execute((TransactionCallback) status -> { status.flush(); // 提交 + transactionManager.commit(status); return null; }); log.info("已经手动提交事务");