配置

zainali5120

2020-11-23 72086633f99f775e42c70f7aabce836e5b8b0597

 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;