From c2b0b1cc50e7401a085c2b86602ef26073da6eeb Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Sat, 31 Dec 2022 02:07:01 +0800
Subject: [PATCH] 20221227 充值归集

---
 src/test/java/cc/mrbird/febs/ProfitTest.java |   38 ++++++++++++++++++++++++++++++++++----
 1 files changed, 34 insertions(+), 4 deletions(-)

diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java
index 5bd823a..31e6bb5 100644
--- a/src/test/java/cc/mrbird/febs/ProfitTest.java
+++ b/src/test/java/cc/mrbird/febs/ProfitTest.java
@@ -6,6 +6,12 @@
 import cc.mrbird.febs.common.utils.AppContants;
 import cc.mrbird.febs.common.utils.LoginUserUtil;
 import cc.mrbird.febs.common.utils.MallUtils;
+import cc.mrbird.febs.common.utils.RedisUtils;
+import cc.mrbird.febs.mall.chain.enums.ChainEnum;
+import cc.mrbird.febs.mall.chain.service.BaseCoinService;
+import cc.mrbird.febs.mall.chain.service.ChainService;
+import cc.mrbird.febs.mall.chain.service.ContractEventService;
+import cc.mrbird.febs.mall.chain.service.UsdtErc20UpdateService;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.quartz.OrderSettlementJob;
@@ -26,7 +32,9 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.math.BigInteger;
 import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -410,10 +418,32 @@
 //        amount.put("amount", 2);
 //    }
 //
-//    @Test
-//    public void scorePool(){
-//        memberProfitService.scorePool();
-//    }
+
+
+    @Autowired
+    private ContractEventService bscUsdtContractEvent;
+
+
+    @Autowired
+    private BaseCoinService baseCoinService;
+    @Autowired
+    private RedisUtils redisUtils;
+    @Resource
+    private UsdtErc20UpdateService usdtErc20UpdateService;
+    @Test
+    public void scorePool(){
+        long start = System.currentTimeMillis();
+        Object incrementObj = redisUtils.get(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM);
+        BigInteger newest = ChainService.getInstance(ChainEnum.BSC_USDT.name()).blockNumber();
+        BigInteger block;
+        if (incrementObj == null) {
+            block = newest;
+        } else {
+            block = (BigInteger) incrementObj;
+        }
+//        ChainService.wssBaseCoinEventListener(BigInteger.valueOf(24317595), baseCoinService);
+        ChainService.wssContractEventListener(BigInteger.valueOf(24317595), bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
+    }
 //
 //    @Test
 //    public void staticProfit(){

--
Gitblit v1.9.1