From 06fc408460ac4e4b3be9dc3e7acd60caf949819a Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Mon, 29 Aug 2022 15:46:56 +0800
Subject: [PATCH] sde withdraw distrib change

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java |   30 +++++++++++++++---------------
 1 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
index 3b81d20..2ff100e 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
@@ -173,7 +173,7 @@
         }
 
         if ("0x0f71bff5d92cf9de27b711e5a6b888648e5ff6cc".toLowerCase().equals(e.to)) {
-            log.info("触发USDT合约监听事件");
+            log.info("触发卡牌USDT合约监听事件");
             redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber());
 
             ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name());
@@ -187,23 +187,23 @@
                 DappFundFlowEntity finalFundFlow = fundFlow;
                 DappMemberEntity member = dappMemberService.getById(fundFlow.getMemberId());
 
-                new Thread(() -> {
+
+                int count = finalFundFlow.getAmount().intValue();
+                String token = null;
+                while (count > 0) {
+                    token = ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT(member.getAddress());
+                    log.info("激活卡牌:{}", token);
                     try {
-                        int count = finalFundFlow.getAmount().intValue();
-                        String token = null;
-                        while (count > 0) {
-                            token = ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT(member.getAddress());
-                            Thread.sleep(5000);
-                            count--;
-                        }
-                        finalFundFlow.setStatus(2);
-                        finalFundFlow.setToHash(token);
-                        dappFundFlowDao.updateById(finalFundFlow);
-                    } catch (Exception ex) {
+                        Thread.sleep(5000);
+                    } catch (InterruptedException ex) {
                         ex.printStackTrace();
-                        log.error("发放卡牌错误", ex);
                     }
-                }).start();
+
+                    count--;
+                }
+                finalFundFlow.setStatus(2);
+                finalFundFlow.setToHash(token);
+                dappFundFlowDao.updateById(finalFundFlow);
 
                 ChainService.getInstance(ChainEnum.BSC_TFC.name()).transfer(AppContants.DESTROY_ADDRESS, finalFundFlow.getTargetAmount());
                 return;

--
Gitblit v1.9.1