From 1774094398c5c6ca376ffb677d0d86fa16c79710 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 26 Oct 2022 15:52:43 +0800
Subject: [PATCH] 20221021

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java |   14 ++++++++++++--
 1 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
index 9360c15..05705df 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
@@ -28,6 +28,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.aspectj.bridge.MessageUtil;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -49,6 +50,9 @@
     private final RedisUtils redisUtils;
     private final DappOnHookAwardDao dappOnHookAwardDao;
     private final DappWalletService dappWalletService;
+
+    @Value("${spring.profiles.active}")
+    private String active;
     @Override
     @Transactional(rollbackFor = Exception.class)
     public FebsResponse start(ApiStartDto apiStartDto) {
@@ -163,7 +167,13 @@
             throw new FebsException(MessageSourceUtils.getString("login_err_003"));
         }
         //获取下一个开奖
-        String redisKey = "on_hook_award_id";
+
+        String redisKey = "";
+        if("prod".equals(active)){
+            redisKey = "on_hook_award_id";
+        }else{
+            redisKey = "on_hook_award_id_test";
+        }
         String onHookAwardRedisId = redisUtils.getString(redisKey);
         DappOnHookAward dappOnHookAward = dappOnHookAwardDao.selectById(Long.parseLong(onHookAwardRedisId));
         if(ObjectUtil.isEmpty(dappOnHookAward)){
@@ -254,7 +264,7 @@
 
         DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
         BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
-            //设置成盈利,如果中奖,返回收益,如果没中奖,则返回本金,最后加上剩余总挂机金额
+            //如果中奖,返回收益,最后加上剩余总挂机金额
 //            total = totalProfit.add(totalAmount).add(igtOnHookPlanOrder.getAvaAmount()).setScale(4, BigDecimal.ROUND_DOWN);
         BigDecimal total = totalProfit.add(igtOnHookPlanOrder.getAvaAmount()).setScale(4, BigDecimal.ROUND_DOWN);
         dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),total);

--
Gitblit v1.9.1