From 74e6993aee71c84dce965bdd6428b0cff5bda57f Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 08 Dec 2022 17:58:30 +0800
Subject: [PATCH] 20221130
---
src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java | 2 ++
src/main/java/cc/mrbird/febs/dapp/service/DappMemberService.java | 2 ++
src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java | 11 +++++++++++
src/main/java/cc/mrbird/febs/dapp/controller/MemberController.java | 9 +++++++++
src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java | 7 +++++++
src/main/resources/mapper/dapp/DappWalletCoinDao.xml | 8 ++++++++
6 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/controller/MemberController.java b/src/main/java/cc/mrbird/febs/dapp/controller/MemberController.java
index a051f94..3ecabbb 100644
--- a/src/main/java/cc/mrbird/febs/dapp/controller/MemberController.java
+++ b/src/main/java/cc/mrbird/febs/dapp/controller/MemberController.java
@@ -322,4 +322,13 @@
Map<String, Object> data = getDataTable(dappMemberService.showMessageList(dappMessageEntity, request));
return new FebsResponse().success().data(data);
}
+
+ /**
+ * 一键操作用户金额清零
+ */
+ @GetMapping(value = "/reloadSystem")
+ public FebsResponse reloadSystem() {
+ dappMemberService.reloadSystem();
+ return new FebsResponse().success();
+ }
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java b/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
index d417057..05901f6 100644
--- a/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
+++ b/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
@@ -41,4 +41,6 @@
void addTotalAndaddAvailableByMemberId(@Param("memberId")Long id, @Param("balance")BigDecimal multiply);
List<DappMemberEntity> selectByIdentity();
+
+ void updateAmountToZero();
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/DappMemberService.java b/src/main/java/cc/mrbird/febs/dapp/service/DappMemberService.java
index 93a113b..fcf89ca 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/DappMemberService.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/DappMemberService.java
@@ -120,4 +120,6 @@
IPage<DappMessageEntity> showMessageList(DappMessageEntity dappMessageEntity, QueryRequest request);
IPage<ApiMessageListVo> getMessageListInPage(ApiMessageListDto apiMessageListDto);
+
+ void reloadSystem();
}
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 8593b13..d728856 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
@@ -228,6 +228,10 @@
igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);
BigDecimal totalMoney = planAmount.add(totalProfit);
+
+ if("ON".equals(onOffStr)){
+ totalMoney = BigDecimal.ZERO;
+ }
DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);
@@ -637,6 +641,9 @@
dappMemberEntity.setIsOnHook(3);
dappMemberDao.updateById(dappMemberEntity);
+ if("ON".equals(onOffStr)){
+ totalMoney = BigDecimal.ZERO;
+ }
DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
index eb24deb..71460b2 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
@@ -1193,6 +1193,17 @@
return records;
}
+ @Override
+ public void reloadSystem() {
+ //系统开关设置为ON
+ DataDictionaryCustom onOff = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.ON_OFF.getType(), DataDictionaryEnum.ON_OFF.getCode());
+ onOff.setValue("OFFSET!");
+ dataDictionaryCustomMapper.updateById(onOff);
+// dappWalletCoinDao.updateAmountToZero();
+// //将所有的挂机记录结束
+// igtOnHookPlanOrderDao.updatePlanOrder();
+ }
+
public String generateAsaToken(String token) {
RSA rsa = new RSA(null, AppContants.PUBLIC_KEY);
return rsa.encryptBase64(token + "_" + System.currentTimeMillis(), KeyType.PublicKey);
diff --git a/src/main/resources/mapper/dapp/DappWalletCoinDao.xml b/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
index 01c35a7..1b50c71 100644
--- a/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
+++ b/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
@@ -145,4 +145,12 @@
inner join dapp_member b on a.member_id = b.id
where b.identity != 'LEVEL_TM' and b.identity is not null
</select>
+
+ <update id="updateAmountToZero">
+ update dapp_wallet_coin
+ set
+ total_amount = 0,
+ available_amount = 0,
+ frozen_amount = 0
+ </update>
</mapper>
\ No newline at end of file
--
Gitblit v1.9.1