From acf0e1696da79bc7fd73f6356182a172a0adaad8 Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Mon, 11 Jan 2021 22:59:55 +0800 Subject: [PATCH] TRC20版本提交 --- src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java | 13 ++++++++++--- 1 files changed, 10 insertions(+), 3 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 73054d1..6bba54c 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 @@ -161,7 +161,7 @@ memberMapper.insert(coinAddress); } - } else { + } else if ("ERC20".equals(lable)) { MemberCoinAddressEntity ethAddress2 = memberMapper.selectBlockAddress(Long.parseLong(mId), "ETH"); if (ethAddress2 != null) { address = ethAddress2.getAddress(); @@ -182,8 +182,15 @@ coinAddress.setLabel(uuid); memberMapper.insert(coinAddress); } - // 发送新增的地址到监听集合 - usdtUpdateProducer.sendAddressMsg(address); + // 发送新增的地址到监听集合 + usdtUpdateProducer.sendAddressMsg(address+","+"ERC20"); + } else if ("TRC20".equals(lable)) { + Map<String, String> usdtMap = Trc20Service.createAddress(); + address = usdtMap.get("address"); + key = usdtMap.get("privateKey"); + map.put("address", address); + // 发送新增的地址到监听集合 + usdtUpdateProducer.sendAddressMsg(address+","+"TRC20"); } break; case "ROC": -- Gitblit v1.9.1