| | |
| | | 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;
|
| | |
|
| | |
| | | @Resource
|
| | | MemberCoinAddressDao memberMapper;
|
| | |
|
| | | @Resource
|
| | | private UsdtUpdateProducer usdtUpdateProducer;
|
| | |
|
| | | @Override
|
| | | public Result findBlockAddress(String symbol) {
|
| | | //获取用户ID
|
| | |
| | | } 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());
|
| | |
| | | coinAddress.setLabel(uuid);
|
| | | memberMapper.insert(coinAddress);
|
| | | }
|
| | | // 发送新增的地址到监听集合
|
| | | usdtUpdateProducer.sendAddressMsg(address);
|
| | | }
|
| | | break;
|
| | | case "ROC":
|
| | |
| | | return result;
|
| | | }
|
| | |
|
| | | public static void main(String[] args) {
|
| | | String wallet = RocService.createWallet();
|
| | | System.out.println(wallet);
|
| | | }
|
| | | }
|