修复交易问题

zainali5120

2020-10-17 53bc6ea0abbeb39146502a40292e6562c5a736d7

 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;



@@ -29,6 +30,9 @@
    MemberDao memberDao;

    @Resource

    MemberCoinAddressDao memberMapper;



    @Resource

    private UsdtUpdateProducer usdtUpdateProducer;



    @Override

    public Result findBlockAddress(String symbol) {

@@ -178,9 +182,8 @@
                                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":