From fa039ab4ede44c9ae3f07056bdcaa9cae8f94ad8 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 15 May 2024 17:25:56 +0800
Subject: [PATCH] 错误流水恢复
---
src/test/java/cc/mrbird/febs/MemberTest.java | 36 ++++++++++++++++++++++++------------
1 files changed, 24 insertions(+), 12 deletions(-)
diff --git a/src/test/java/cc/mrbird/febs/MemberTest.java b/src/test/java/cc/mrbird/febs/MemberTest.java
index 048c3a2..975f594 100644
--- a/src/test/java/cc/mrbird/febs/MemberTest.java
+++ b/src/test/java/cc/mrbird/febs/MemberTest.java
@@ -3,12 +3,19 @@
import cc.mrbird.febs.common.contants.AppContants;
import cc.mrbird.febs.common.enumerates.DataDicEnum;
import cc.mrbird.febs.common.utils.RedisUtils;
+import cc.mrbird.febs.dapp.chain.ChainEnum;
+import cc.mrbird.febs.dapp.chain.ChainService;
+import cc.mrbird.febs.dapp.chain.ContractEventService;
+import cc.mrbird.febs.dapp.entity.DappAchieve;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
+import cc.mrbird.febs.dapp.mapper.DappAchieveMapper;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
+import cc.mrbird.febs.dapp.service.AsyncCjService;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import org.apache.commons.lang3.StringUtils;
import org.junit.jupiter.api.Test;
@@ -17,6 +24,7 @@
import org.springframework.scheduling.annotation.Scheduled;
import java.math.BigDecimal;
+import java.math.BigInteger;
import java.util.List;
/**
@@ -34,20 +42,24 @@
@Autowired
private DappSystemService dappSystemService;
+ @Autowired
+ private DappAchieveMapper dappAchieveMapper;
+
+ @Autowired
+ private AsyncCjService asyncCjService;
+
+ @Autowired
+ private ContractEventService bscCoinContractEvent;
+
@Test
public void mineJob() {
- BigDecimal usdtAmount = new BigDecimal(
- redisUtils.getString(DataDicEnum.GFA_HUA_DIAN_WALLET_USDT_AMOUNT.getValue())
- ).setScale(2,BigDecimal.ROUND_DOWN);
- BigDecimal coinAmount = new BigDecimal(
- redisUtils.getString(DataDicEnum.GFA_HUA_DIAN_WALLET_COIN_AMOUNT.getValue())
- ).setScale(2,BigDecimal.ROUND_DOWN);
- if(BigDecimal.ZERO.compareTo(usdtAmount) > 0){
- return;
- }
- if(BigDecimal.ZERO.compareTo(coinAmount) > 0){
- return;
- }
+ ChainService.coinRewardEventListener(BigInteger.valueOf(40116050), null, bscCoinContractEvent, ChainEnum.BSC_GFA.name());
+// List<DappAchieve> dappAchieves = dappAchieveMapper.selectList(null);
+// if(CollUtil.isNotEmpty(dappAchieves)){
+// for(DappAchieve dappAchieve : dappAchieves){
+// asyncCjService.calculateAchieve(dappAchieve);
+// }
+// }
// dappSystemService.tradeProfitDistribute(1L);
}
}
--
Gitblit v1.9.1