From 869769dedf8722109c944db9a5d9fac97591c2d3 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Sat, 16 Jan 2021 14:41:57 +0800
Subject: [PATCH] TRC20版本提交

---
 src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java |   19 +++++++++++++++----
 1 files changed, 15 insertions(+), 4 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 e21dc6b..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
@@ -53,7 +53,7 @@
             } else {
                 memberCoinAddress = memberMapper.selectBlockAddress(Long.parseLong(mId), symbol);
             }
-            log.info("--->{}", memberCoinAddress);
+            //log.info("--->{}", memberCoinAddress);
             if (memberCoinAddress != null) {
                 map.put("address", memberCoinAddress.getAddress());
                 map.put("lable", memberCoinAddress.getLabel());
@@ -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":
@@ -214,4 +221,8 @@
         return result;
     }
 
+    public static void main(String[] args) {
+        String wallet = RocService.createWallet();
+        System.out.println(wallet);
+    }
 }

--
Gitblit v1.9.1