From 70ed38bf585d3d5544778a477556b2f1a56be64b Mon Sep 17 00:00:00 2001
From: admin <2780501319@qq.com>
Date: 星期一, 05 七月 2021 23:54:49 +0800
Subject: [PATCH] 日志修改
---
service-lijin/src/main/java/com/ks/lijin/service/remote/LijinCreateServiceImpl.java | 75 ++++++++++++++++++++++++++++++++++++-
1 files changed, 73 insertions(+), 2 deletions(-)
diff --git a/service-lijin/src/main/java/com/ks/lijin/service/remote/LijinCreateServiceImpl.java b/service-lijin/src/main/java/com/ks/lijin/service/remote/LijinCreateServiceImpl.java
index 3291d57..c9f7304 100644
--- a/service-lijin/src/main/java/com/ks/lijin/service/remote/LijinCreateServiceImpl.java
+++ b/service-lijin/src/main/java/com/ks/lijin/service/remote/LijinCreateServiceImpl.java
@@ -22,16 +22,22 @@
import com.ks.lijin.util.Constant;
import com.ks.lijin.utils.taobao.TaoBaoUtil;
import com.ks.lijin.utils.taobao.TaoKeApiUtil;
+import com.ks.vip.exception.LijinBalanceException;
+import com.ks.vip.pojo.DO.UserLijinRecord;
import com.ks.vip.pojo.DO.VipGradePotence;
import com.ks.vip.pojo.Enums.VIPEnum;
+import com.ks.vip.service.LijinBalanceService;
import com.ks.vip.service.VipCenterService;
import com.ks.vip.service.VipGradePotenceService;
import com.ks.vip.service.VipGradeService;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
import org.apache.dubbo.config.annotation.Reference;
import org.apache.dubbo.config.annotation.Service;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.MoneyBigDecimalUtil;
import org.yeshi.utils.StringUtil;
@@ -48,6 +54,8 @@
@Service(version = "1.0")
public class LijinCreateServiceImpl implements LijinCreateService {
+
+ Logger logger = LoggerFactory.getLogger(LijinCreateService.class);
@Resource(name = "taskExecutor")
private TaskExecutor executor;
@@ -70,6 +78,9 @@
@Reference(version = "1.0", check = false)
private VipGradeService vipGradeService;
+ @Reference(version = "1.0", check = false)
+ private LijinBalanceService lijinBalanceService;
+
@Resource
private LiJinExpendRecordService liJinExpendRecordService;
@@ -77,7 +88,7 @@
private LiJinProviderTaoKeAccountManager liJinProviderTaoKeAccountManager;
@Resource
- private RedisTemplate redisTemplate;
+ private StringRedisTemplate redisTemplate;
@Resource
private LijinGoodsManager lijinGoodsManager;
@@ -189,6 +200,38 @@
return money;
}
+ @Override
+ public int getTodayLeftCount(String uid, Date registerDate) {
+ VipGradePotence potence = vipCenterService.getVipPotence(uid);
+ if (potence == null) {
+ return 0;
+ }
+ // 姣忔棩鏈�澶ф鏁板垽鏂�
+ Integer numMax = potence.getTaolijinMaxNumber();
+ if (numMax == null || numMax.intValue() <= 0) {
+ return 0;
+ }
+ // 浣跨敤娆℃暟宸茬粡瓒呰繃鏈�澶ф鏁�
+ int numExpend = liJinExpendRecordService.countTodayNumByExpend(uid);
+ if (registerDate != null) {
+ //鍒ゆ柇鏂扮敤鎴�
+ String newerHour = lijinConfigManager.getConfigValue("newer-hour");
+ String dayPlusCount = lijinConfigManager.getConfigValue("newer-everyday-plus-lijin-count");
+ if (!StringUtil.isNullOrEmpty(newerHour) && !StringUtil.isNullOrEmpty(dayPlusCount)) {
+ //鏂扮敤鎴锋瘡鏃ラ檮鍔犳鏁�
+ if (System.currentTimeMillis() - registerDate.getTime() < 1000 * 60 * 60L * Integer.parseInt(dayPlusCount)) {
+ numMax += Integer.parseInt(dayPlusCount);
+ }
+ }
+ }
+
+ if (numMax.intValue() > numExpend) {
+ return numMax.intValue() - numExpend;
+ } else {
+ return 0;
+ }
+ }
+
@Override
public boolean userCanCreateTBLijin(String uid, Date registerDate) throws LiJinUserException {
@@ -196,6 +239,7 @@
if (potence == null) {
return false;
}
+
// 姣忔棩鏈�澶ф鏁板垽鏂�
Integer numMax = potence.getTaolijinMaxNumber();
@@ -218,7 +262,7 @@
if (!StringUtil.isNullOrEmpty(newerHour) && !StringUtil.isNullOrEmpty(dayPlusCount)) {
//鏂扮敤鎴锋瘡鏃ラ檮鍔犳鏁�
if (System.currentTimeMillis() - registerDate.getTime() < 1000 * 60 * 60L * Integer.parseInt(dayPlusCount)) {
- numExpend += Integer.parseInt(dayPlusCount);
+ numMax += Integer.parseInt(dayPlusCount);
}
}
}
@@ -246,6 +290,14 @@
if (potence == null) {
return false;
}
+ //鏌ヨ绀奸噾浣欓
+ BigDecimal balance = lijinBalanceService.getBalance(uid);
+ if (balance != null) {
+ if (money.compareTo(balance) > 0) {
+ throw new LiJinUserException(LiJinUserException.CODE_USER_BALANCE_NOT_ENOUGH, "绀奸噾浣欓涓嶈冻");
+ }
+ }
+
// 姣忔棩鏈�澶ф鏁板垽鏂�
Integer numMax = potence.getTaolijinMaxNumber();
@@ -323,6 +375,14 @@
// 鍒涘缓鐨勬窐绀奸噾-閲戦
BigDecimal lijinAmount = getTBLijinAmount(goods, vipRank);
+ //鏌ヨ绀奸噾浣欓
+ BigDecimal balance = lijinBalanceService.getBalance(uid);
+ if (balance != null && lijinAmount != null) {
+ if (lijinAmount.compareTo(balance) > 0) {
+ throw new LiJinUserException(LiJinUserException.CODE_USER_BALANCE_NOT_ENOUGH, "绀奸噾浣欓涓嶈冻");
+ }
+ }
+
// 鎵ц鍒涘缓娣樼ぜ閲�
LiJinCreateParam params = getLiJinCreateBaseParam();
@@ -341,11 +401,15 @@
if (e.getCode() == LiJinGoodsException.CODE_GOODS_CREATED_FULL) {
lijinGoodsManager.createdFullToday(auctionId, now);
}
+ redisTemplate.delete(key);
+ logger.info("娣樼ぜ閲戝垱寤猴紝鍒犻櫎閿佸畾鎴愬姛1 key:{}",key);
throw e;
} finally {
redisTemplate.delete(key);
+ logger.info("娣樼ぜ閲戝垱寤猴紝鍒犻櫎閿佸畾鎴愬姛2 key:{}",key);
}
} else {
+ logger.error("娣樼ぜ閲戝垱寤猴紝鐢ㄦ埛閿佸畾澶辫触 key:{}",key);
throw new LiJinException(LiJinException.CODE_SERVER_BUSY, "鏈嶅姟鍣ㄧ箒蹇欙紝璇风◢鍚庡啀璇�");
}
}
@@ -377,6 +441,13 @@
liJinExpendRecordMapper.insertSelective(record);
//娣诲姞
liJinProviderTaoKeAccountManager.createLijinSuccess(taoLiJinDTO.getAccount().getId(), goodsId, lijinAmount.multiply(new BigDecimal(num)), now);
+ //绀奸噾浣欓鎵ｉ櫎
+ try {
+ lijinBalanceService.consumeLijin(uid, lijinAmount, "璐墿鎶电幇", UserLijinRecord.Category.createGoodsLijin.name(), record.getId() + "");
+ } catch (LijinBalanceException e) {
+ e.printStackTrace();
+ }
+
return record;
}
--
Gitblit v1.8.0