From 02be66cea8554fedcbe02a94f811b4d0ba162c39 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 26 Nov 2020 17:17:05 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 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 fbc5759..ee703fc 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,9 +31,11 @@
@Resource
MemberCoinAddressDao memberMapper;
+ @Resource
+ private UsdtUpdateProducer usdtUpdateProducer;
+
@Override
public Result findBlockAddress(String symbol) {
- System.out.println("币种"+symbol);
//获取用户ID
String mId = LoginUserUtils.getAppLoginUser().getId().toString();
MemberEntity member = memberDao.selectById(mId);
@@ -179,13 +182,14 @@
coinAddress.setLabel(uuid);
memberMapper.insert(coinAddress);
}
+ // 发送新增的地址到监听集合
+ usdtUpdateProducer.sendAddressMsg(address);
}
break;
case "CPV":
address = RocService.createWallet();
map.put("address", address);
- System.out.println("币种"+address);
break;
default:
break;
--
Gitblit v1.9.1