From f36b59db7fd7448e96faf6d95b82c9aa7deaaa85 Mon Sep 17 00:00:00 2001 From: xudeyou Date: Sun, 16 Sep 2018 14:19:52 +0800 Subject: [PATCH] refact: add Transactional annotation in demo services to get a better code style --- .../yiqiniu/easytrans/demos/wallet/impl/WalletService.java | 6 ++++-- .../yiqiniu/easytrans/demos/wallet/impl/WalletService.java | 6 ++++-- .../yiqiniu/easytrans/demos/wallet/impl/WalletService.java | 6 ++++-- .../yiqiniu/easytrans/demos/wallet/impl/WalletService.java | 6 ++++-- 4 files changed, 16 insertions(+), 8 deletions(-) diff --git a/easytrans-demo/rpc-dubbo/rpcdubbo-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/easytrans-demo/rpc-dubbo/rpcdubbo-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java index e9a4a92..d290768 100644 --- a/easytrans-demo/rpc-dubbo/rpcdubbo-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java +++ b/easytrans-demo/rpc-dubbo/rpcdubbo-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java @@ -4,6 +4,7 @@ import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Transactional; import com.yiqiniu.easytrans.core.EasyTransFacade; import com.yiqiniu.easytrans.demos.wallet.api.vo.WalletPayVO.WalletPayRequestVO; @@ -17,7 +18,7 @@ public class WalletService { @Resource private JdbcTemplate jdbcTemplate; - + @Transactional public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount + ? where user_id = ? and (total_amount - freeze_amount) >= ?;", param.getPayAmount(),param.getUserId(),param.getPayAmount()); @@ -31,7 +32,7 @@ public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { return walletPayTccMethodResult; } - + @Transactional public void doConfirmPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ?, total_amount = total_amount - ? where user_id = ?;", param.getPayAmount(),param.getPayAmount(),param.getUserId()); @@ -41,6 +42,7 @@ public void doConfirmPay(WalletPayRequestVO param) { } } + @Transactional public void doCancelPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ? where user_id = ?;", param.getPayAmount(),param.getUserId()); diff --git a/easytrans-demo/sagatcc/sagatcc-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/easytrans-demo/sagatcc/sagatcc-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java index 1893f12..55a039c 100644 --- a/easytrans-demo/sagatcc/sagatcc-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java +++ b/easytrans-demo/sagatcc/sagatcc-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java @@ -4,6 +4,7 @@ import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Transactional; import com.yiqiniu.easytrans.core.EasyTransFacade; import com.yiqiniu.easytrans.demos.wallet.api.vo.WalletPayVO.WalletPayRequestVO; @@ -16,7 +17,7 @@ public class WalletService { @Resource private JdbcTemplate jdbcTemplate; - + @Transactional public void doTryPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount + ? where user_id = ? and (total_amount - freeze_amount) >= ?;", param.getPayAmount(),param.getUserId(),param.getPayAmount()); @@ -26,7 +27,7 @@ public void doTryPay(WalletPayRequestVO param) { } } - + @Transactional public void doConfirmPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ?, total_amount = total_amount - ? where user_id = ?;", param.getPayAmount(),param.getPayAmount(),param.getUserId()); @@ -36,6 +37,7 @@ public void doConfirmPay(WalletPayRequestVO param) { } } + @Transactional public void doCancelPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ? where user_id = ?;", param.getPayAmount(),param.getUserId()); diff --git a/easytrans-demo/tcc-and-msg/tccandmsg-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/easytrans-demo/tcc-and-msg/tccandmsg-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java index e9a4a92..d290768 100644 --- a/easytrans-demo/tcc-and-msg/tccandmsg-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java +++ b/easytrans-demo/tcc-and-msg/tccandmsg-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java @@ -4,6 +4,7 @@ import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Transactional; import com.yiqiniu.easytrans.core.EasyTransFacade; import com.yiqiniu.easytrans.demos.wallet.api.vo.WalletPayVO.WalletPayRequestVO; @@ -17,7 +18,7 @@ public class WalletService { @Resource private JdbcTemplate jdbcTemplate; - + @Transactional public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount + ? where user_id = ? and (total_amount - freeze_amount) >= ?;", param.getPayAmount(),param.getUserId(),param.getPayAmount()); @@ -31,7 +32,7 @@ public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { return walletPayTccMethodResult; } - + @Transactional public void doConfirmPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ?, total_amount = total_amount - ? where user_id = ?;", param.getPayAmount(),param.getPayAmount(),param.getUserId()); @@ -41,6 +42,7 @@ public void doConfirmPay(WalletPayRequestVO param) { } } + @Transactional public void doCancelPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ? where user_id = ?;", param.getPayAmount(),param.getUserId()); diff --git a/easytrans-demo/tcc-only/tcconly-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/easytrans-demo/tcc-only/tcconly-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java index e9a4a92..d290768 100644 --- a/easytrans-demo/tcc-only/tcconly-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java +++ b/easytrans-demo/tcc-only/tcconly-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java @@ -4,6 +4,7 @@ import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Transactional; import com.yiqiniu.easytrans.core.EasyTransFacade; import com.yiqiniu.easytrans.demos.wallet.api.vo.WalletPayVO.WalletPayRequestVO; @@ -17,7 +18,7 @@ public class WalletService { @Resource private JdbcTemplate jdbcTemplate; - + @Transactional public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount + ? where user_id = ? and (total_amount - freeze_amount) >= ?;", param.getPayAmount(),param.getUserId(),param.getPayAmount()); @@ -31,7 +32,7 @@ public WalletPayResponseVO doTryPay(WalletPayRequestVO param) { return walletPayTccMethodResult; } - + @Transactional public void doConfirmPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ?, total_amount = total_amount - ? where user_id = ?;", param.getPayAmount(),param.getPayAmount(),param.getUserId()); @@ -41,6 +42,7 @@ public void doConfirmPay(WalletPayRequestVO param) { } } + @Transactional public void doCancelPay(WalletPayRequestVO param) { int update = jdbcTemplate.update("update `wallet` set freeze_amount = freeze_amount - ? where user_id = ?;", param.getPayAmount(),param.getUserId());