From f7fc7c82d2d683a3e90e88ddbf8831bfa3800e11 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 31 May 2022 16:48:25 +0800
Subject: [PATCH] add online-tranfer, finish mining、distrib profit
---
src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java | 25 ++++++++++++++++++++-----
1 files changed, 20 insertions(+), 5 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 3c5f2c5..489d780 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
@@ -6,10 +6,14 @@
import cc.mrbird.febs.dapp.chain.*;
import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
+import cc.mrbird.febs.dapp.entity.DappOnlineTransferEntity;
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
+import cc.mrbird.febs.dapp.mapper.DappOnlineTransferDao;
import cc.mrbird.febs.dapp.service.DappMemberService;
+import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -19,6 +23,8 @@
import java.math.BigDecimal;
import java.math.BigInteger;
import java.math.RoundingMode;
+import java.util.HashMap;
+import java.util.Map;
@Slf4j
@Service
@@ -32,6 +38,12 @@
@Resource
private DappFundFlowDao dappFundFlowDao;
+
+ @Resource
+ private ChainProducer chainProducer;
+
+ @Resource
+ private DappOnlineTransferDao dappOnlineTransferDao;
@Override
@@ -65,12 +77,15 @@
// 如果系统会开启，则使用自动打款
if (!"start".equals(hasStart)) {
- String hash = ChainService.getInstance(ChainEnum.BSC_TFC_MAKE.name()).transfer(e.from, transferAmount);
+ DappOnlineTransferEntity bsc = new DappOnlineTransferEntity(e.from, transferAmount, 1, 1, ChainEnum.BSC_TFC_MAKE.name(), "BSC", fundFlow.getId().toString());
+ dappOnlineTransferDao.insert(bsc);
- // 更新为已打款
- fundFlow.setStatus(3);
- fundFlow.setToHash(hash);
- dappFundFlowDao.updateById(fundFlow);
+ Map<String, String> map = new HashMap<>();
+ map.put("batchNo", fundFlow.getId().toString());
+ map.put("type", "flow");
+
+ // 发送转账消息
+ chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
}
// 若源池中的USDT达到或超过8万U，则启动整个系统
--
Gitblit v1.9.1