Java - TransactionTemplate 使用

2024年03月20日 16:51 · 阅读(737) ·

扩展

收款平台-@Transactional 失效问题

公共类-AssertUtil

  1. import cn.hutool.core.util.StrUtil;
  2. import com.luoma.finance.excepiton.InternalApiException;
  4. /**
  5.  *
  6.  * 断言工具类
  7.  */
  8. public class AssertUtil {
  11.     /**
  12.      * 断言
  13.      * @param flag 断言标识
  14.      * @param code  异常码
  15.      * @param message
  16.      *   异常信息，
  17.      *   如果异常信息需要多语言统一{@link com.luoma.finance.handler.GlobalExceptionHandler}中做多语言处理，
  18.      *   以message 作为key去获取多语言信息，
  19.      *   如果需要支持带动态参数的多语言需要拓展 {@link com.luoma.finance.excepiton.InternalApiException}
  20.      * @param messageParam 异常信息参数
  21.      */
  22.     public static void  isTrue(boolean flag,int  code,String message,Object... messageParam){
  23.         if(!flag){
  24.             throw new InternalApiException(code, StrUtil.format(message,messageParam));
  25.         }
  26.     }
  28. }

第一种情况，入口没有加 @Transactional，TransactionTemplate 里面报错

  1. @Resource
  2. IPaymentWalletAccountService accountService;
  4. @Resource
  5. private TransactionTemplate transactionTemplate;
  7. @GetMapping("/testPaymentWalletAccount")
  8. public PaymentWalletAccount testPaymentWalletAccount() {
  9.     PaymentWalletAccount dto = new PaymentWalletAccount();
  10.     dto.setSourceSystem("FPP");
  11.     dto.setSourceNum("FPP1");
  12.     dto.setReferenceId("FPP1");
  13.     dto.setRechargeOrderNumber("1");
  14.     dto.setPayOrderNumber("1");
  15.     dto.setOrgCode("101");
  16.     dto.setOrgName("OU_101");
  17.     dto.setPayCurrencyCode("CNY");
  18.     dto.setPayAmount(new BigDecimal("2.22"));
  19.     dto.setIsReconciliation("Y");
  20.     dto.setReconciliationStatus("FAILED");
  21.     dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  22.     dto.setActualPayMonth("202403");
  23.     dto.setPayMonth("202404");
  24.     int count = accountService.getBaseMapper().insert(dto);
  25.     String methodName = "testPaymentWalletAccount() >> ";
  26.     log.info(methodName + "count:{}", count);
  28.     transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  29.         @Override
  30.         protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
  31.             PaymentWalletAccount dto = new PaymentWalletAccount();
  32.             dto.setSourceSystem("FPP");
  33.             dto.setSourceNum("FPP");
  34.             dto.setReferenceId(UUID.randomUUID().toString());
  35.             dto.setRechargeOrderNumber("1");
  36.             dto.setPayOrderNumber("1");
  37.             dto.setOrgCode("101");
  38.             dto.setOrgName("OU_101");
  39.             dto.setPayCurrencyCode("CNY");
  40.             dto.setPayAmount(new BigDecimal("2.22"));
  41.             dto.setIsReconciliation("Y");
  42.             dto.setReconciliationStatus("FAILED");
  43.             dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  44.             dto.setActualPayMonth("202403");
  45.             dto.setPayMonth("202404");
  46.             int count = accountService.getBaseMapper().insert(dto);
  47.             String methodName = "testPaymentWalletAccount() >> ";
  48.             log.info(methodName + "count:{}", count);
  50.             //故意设置失败
  51.             count = 0;
  53.             AssertUtil.isTrue(count > 0, ResponseCode.UNKNOWN_EXCEPTION.value(),"insert 数据失败");
  54.         }
  55.     });
  57.     return dto;
  58. }
  • 调用接口，查询数据库，添加了外层的数据

第二种情况，入口加 @Transactional，TransactionTemplate 里面报错

  1. @Resource
  2. IPaymentWalletAccountService accountService;
  4. @Resource
  5. private TransactionTemplate transactionTemplate;
  7. @GetMapping("/testPaymentWalletAccount")
  8. @Transactional(rollbackFor = Exception.class)
  9. public PaymentWalletAccount testPaymentWalletAccount() {
  10.     PaymentWalletAccount dto = new PaymentWalletAccount();
  11.     dto.setSourceSystem("FPP");
  12.     dto.setSourceNum("FPP1");
  13.     dto.setReferenceId("FPP1");
  14.     dto.setRechargeOrderNumber("1");
  15.     dto.setPayOrderNumber("1");
  16.     dto.setOrgCode("101");
  17.     dto.setOrgName("OU_101");
  18.     dto.setPayCurrencyCode("CNY");
  19.     dto.setPayAmount(new BigDecimal("2.22"));
  20.     dto.setIsReconciliation("Y");
  21.     dto.setReconciliationStatus("FAILED");
  22.     dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  23.     dto.setActualPayMonth("202403");
  24.     dto.setPayMonth("202404");
  25.     int count = accountService.getBaseMapper().insert(dto);
  26.     String methodName = "testPaymentWalletAccount() >> ";
  27.     log.info(methodName + "count:{}", count);
  29.     transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  30.         @Override
  31.         protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
  32.             PaymentWalletAccount dto = new PaymentWalletAccount();
  33.             dto.setSourceSystem("FPP");
  34.             dto.setSourceNum("FPP");
  35.             dto.setReferenceId(UUID.randomUUID().toString());
  36.             dto.setRechargeOrderNumber("1");
  37.             dto.setPayOrderNumber("1");
  38.             dto.setOrgCode("101");
  39.             dto.setOrgName("OU_101");
  40.             dto.setPayCurrencyCode("CNY");
  41.             dto.setPayAmount(new BigDecimal("2.22"));
  42.             dto.setIsReconciliation("Y");
  43.             dto.setReconciliationStatus("FAILED");
  44.             dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  45.             dto.setActualPayMonth("202403");
  46.             dto.setPayMonth("202404");
  47.             int count = accountService.getBaseMapper().insert(dto);
  48.             String methodName = "testPaymentWalletAccount() >> ";
  49.             log.info(methodName + "count:{}", count);
  51.             //故意设置失败
  52.             count = 0;
  54.             AssertUtil.isTrue(count > 0, ResponseCode.UNKNOWN_EXCEPTION.value(),"insert 数据失败");
  55.         }
  56.     });
  58.     return dto;
  59. }
  • 调用接口，查询数据库，无数据

第三种情况，入口加 @Transactional，外面报错

  1. @Resource
  2. IPaymentWalletAccountService accountService;
  4. @Resource
  5. private TransactionTemplate transactionTemplate;
  7. @GetMapping("/testPaymentWalletAccount")
  8. @Transactional(rollbackFor = Exception.class)
  9. public PaymentWalletAccount testPaymentWalletAccount() {
  10.     PaymentWalletAccount dto = new PaymentWalletAccount();
  11.     dto.setSourceSystem("FPP");
  12.     dto.setSourceNum("FPP1");
  13.     dto.setReferenceId("FPP1");
  14.     dto.setRechargeOrderNumber("1");
  15.     dto.setPayOrderNumber("1");
  16.     dto.setOrgCode("101");
  17.     dto.setOrgName("OU_101");
  18.     dto.setPayCurrencyCode("CNY");
  19.     dto.setPayAmount(new BigDecimal("2.22"));
  20.     dto.setIsReconciliation("Y");
  21.     dto.setReconciliationStatus("FAILED");
  22.     dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  23.     dto.setActualPayMonth("202403");
  24.     dto.setPayMonth("202404");
  25.     int count = accountService.getBaseMapper().insert(dto);
  26.     String methodName = "testPaymentWalletAccount() >> ";
  27.     log.info(methodName + "count:{}", count);
  29.     transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  30.         @Override
  31.         protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
  32.             PaymentWalletAccount dto = new PaymentWalletAccount();
  33.             dto.setSourceSystem("FPP");
  34.             dto.setSourceNum("FPP");
  35.             dto.setReferenceId(UUID.randomUUID().toString());
  36.             dto.setRechargeOrderNumber("1");
  37.             dto.setPayOrderNumber("1");
  38.             dto.setOrgCode("101");
  39.             dto.setOrgName("OU_101");
  40.             dto.setPayCurrencyCode("CNY");
  41.             dto.setPayAmount(new BigDecimal("2.22"));
  42.             dto.setIsReconciliation("Y");
  43.             dto.setReconciliationStatus("FAILED");
  44.             dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  45.             dto.setActualPayMonth("202403");
  46.             dto.setPayMonth("202404");
  47.             int count = accountService.getBaseMapper().insert(dto);
  48.             String methodName = "testPaymentWalletAccount() >> ";
  49.             log.info(methodName + "count:{}", count);
  51.             //故意设置失败
  52.             //count = 0;
  54.             AssertUtil.isTrue(count > 0, ResponseCode.UNKNOWN_EXCEPTION.value(),"insert 数据失败");
  55.         }
  56.     });
  58.     AssertUtil.isTrue(false, ResponseCode.UNKNOWN_EXCEPTION.value(),"故意抛出异常");
  60.     return dto;
  61. }
  • 调用接口，查询数据库，无数据

第四种情况，入口不加 @Transactional，外面报错

  1. @Resource
  2. IPaymentWalletAccountService accountService;
  4. @Resource
  5. private TransactionTemplate transactionTemplate;
  7. @GetMapping("/testPaymentWalletAccount")
  8. public PaymentWalletAccount testPaymentWalletAccount() {
  9.     PaymentWalletAccount dto = new PaymentWalletAccount();
  10.     dto.setSourceSystem("FPP");
  11.     dto.setSourceNum("FPP1");
  12.     dto.setReferenceId("FPP1");
  13.     dto.setRechargeOrderNumber("1");
  14.     dto.setPayOrderNumber("1");
  15.     dto.setOrgCode("101");
  16.     dto.setOrgName("OU_101");
  17.     dto.setPayCurrencyCode("CNY");
  18.     dto.setPayAmount(new BigDecimal("2.22"));
  19.     dto.setIsReconciliation("Y");
  20.     dto.setReconciliationStatus("FAILED");
  21.     dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  22.     dto.setActualPayMonth("202403");
  23.     dto.setPayMonth("202404");
  24.     int count = accountService.getBaseMapper().insert(dto);
  25.     String methodName = "testPaymentWalletAccount() >> ";
  26.     log.info(methodName + "count:{}", count);
  28.     transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  29.         @Override
  30.         protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
  31.             PaymentWalletAccount dto = new PaymentWalletAccount();
  32.             dto.setSourceSystem("FPP");
  33.             dto.setSourceNum("FPP");
  34.             dto.setReferenceId(UUID.randomUUID().toString());
  35.             dto.setRechargeOrderNumber("1");
  36.             dto.setPayOrderNumber("1");
  37.             dto.setOrgCode("101");
  38.             dto.setOrgName("OU_101");
  39.             dto.setPayCurrencyCode("CNY");
  40.             dto.setPayAmount(new BigDecimal("2.22"));
  41.             dto.setIsReconciliation("Y");
  42.             dto.setReconciliationStatus("FAILED");
  43.             dto.setActualPayDate(CommonUtil.getDataStr(LocalDateTime.now(), null));
  44.             dto.setActualPayMonth("202403");
  45.             dto.setPayMonth("202404");
  46.             int count = accountService.getBaseMapper().insert(dto);
  47.             String methodName = "testPaymentWalletAccount() >> ";
  48.             log.info(methodName + "count:{}", count);
  50.             //故意设置失败
  51.             //count = 0;
  53.             AssertUtil.isTrue(count > 0, ResponseCode.UNKNOWN_EXCEPTION.value(),"insert 数据失败");
  54.         }
  55.     });
  57.     AssertUtil.isTrue(false, ResponseCode.UNKNOWN_EXCEPTION.value(),"故意抛出异常");
  59.     return dto;
  60. }
  • 调用接口，查询数据库，有两条数据，外部错误不影响 transactionTemplate 内部事务