refact: add Transactional annotation in demo services to get a better…

… code style
QNJR-GROUP · Sep 16, 2018 · f36b59d · f36b59d
1 parent 60684ab
commit f36b59d
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 8 deletions.
diff --git a/...o-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/...o-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/...c-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/...c-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/...g-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/...g-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/...y-wallet-service/src/main/java/com/yiqiniu/easytrans/demos/wallet/impl/WalletService.java b/...y-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());