From 7ae23e17d8e90dc634f3f86e2eee209cbacaace3 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 30 Nov 2020 17:15:53 +0800
Subject: [PATCH] 20201130
---
src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
index 33c2c20..577b401 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
@@ -6,6 +6,7 @@
import javax.annotation.Resource;
import com.xcong.excoin.modules.blackchain.service.*;
+import com.xcong.excoin.rabbit.producer.UsdtUpdateProducer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@@ -30,6 +31,9 @@
@Resource
MemberCoinAddressDao memberMapper;
+ @Resource
+ private UsdtUpdateProducer usdtUpdateProducer;
+
@Override
public Result findBlockAddress(String symbol) {
//获取用户ID
@@ -49,7 +53,6 @@
} else {
memberCoinAddress = memberMapper.selectBlockAddress(Long.parseLong(mId), symbol);
}
- log.info("--->{}", memberCoinAddress);
if (memberCoinAddress != null) {
map.put("address", memberCoinAddress.getAddress());
map.put("lable", memberCoinAddress.getLabel());
@@ -178,13 +181,12 @@
coinAddress.setLabel(uuid);
memberMapper.insert(coinAddress);
}
- if(!UsdtErc20UpdateService.ALL_ADDRESS_LIST.contains(address)){
- UsdtErc20UpdateService.ALL_ADDRESS_LIST.add(address);
- }
+ // 发送新增的地址到监听集合
+ usdtUpdateProducer.sendAddressMsg(address);
}
break;
- case "ROC":
- address = RocService.createWallet();
+ case "SER":
+// address = RocService.createWallet();
map.put("address", address);
break;
default:
--
Gitblit v1.9.1