From c9fdff7d45ae118eac10397d8f34661e9f2e968a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 12 一月 2022 10:28:18 +0800
Subject: [PATCH] 礼金bug修复

---
 service-vip/src/main/java/com/ks/vip/service/remote/LijinBalanceServiceImpl.java |   10 +++++++++-
 1 files changed, 9 insertions(+), 1 deletions(-)

diff --git a/service-vip/src/main/java/com/ks/vip/service/remote/LijinBalanceServiceImpl.java b/service-vip/src/main/java/com/ks/vip/service/remote/LijinBalanceServiceImpl.java
index 875f607..bf85eab 100644
--- a/service-vip/src/main/java/com/ks/vip/service/remote/LijinBalanceServiceImpl.java
+++ b/service-vip/src/main/java/com/ks/vip/service/remote/LijinBalanceServiceImpl.java
@@ -7,6 +7,8 @@
 import com.ks.vip.pojo.DO.UserLijinRecord;
 import com.ks.vip.service.LijinBalanceService;
 import org.apache.dubbo.config.annotation.Service;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.transaction.annotation.Transactional;
 import org.yeshi.utils.TimeUtil;
 
@@ -18,6 +20,8 @@
 
 @Service(version = "1.0")
 public class LijinBalanceServiceImpl implements LijinBalanceService {
+
+    Logger logger = LoggerFactory.getLogger(LijinBalanceService.class);
 
     @Resource
     private LijinBalanceMapper lijinBalanceMapper;
@@ -76,10 +80,13 @@
         userLijinRecordDao.save(record);
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void consumeLijin(String uid, BigDecimal money, String title, String category, String identifyCode) throws LijinBalanceException {
+        logger.info("寮�濮嬫墸闄ょぜ閲�");
         //娣诲姞璁板綍
         LijinBalance lijinBalance = lijinBalanceMapper.selectByPrimaryKeyForUpdate(uid);
+        logger.info("鐢ㄦ埛绀奸噾閿佸畾鎴愬姛");
         if (lijinBalance == null) {
             throw new LijinBalanceException(LijinBalanceException.CODE_NOT_INIT, "浣欓鏈垵濮嬪寲");
         }
@@ -94,6 +101,7 @@
         update.setBalance(lijinBalance.getBalance().subtract(money));
         update.setUpdateTime(new Date());
         lijinBalanceMapper.updateByPrimaryKeySelective(update);
+        logger.info("鍑忎綑棰濇垚鍔�");
         //澧炲姞璁板綍
         UserLijinRecord record = new UserLijinRecord();
         record.setMoney(money);
@@ -105,7 +113,7 @@
         record.setCreateTime(new Date());
         record.setIdentifyCode(identifyCode);
         userLijinRecordDao.save(record);
-
+        logger.info("澧炲姞璁板綍鎴愬姛");
     }
 
     @Override

--
Gitblit v1.8.0