From f7bde8a9d9bf8e3c67c0912cbd8c50fe4f7097aa Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 13 May 2026 20:17:51 +0800
Subject: [PATCH] 1
---
trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java | 275 +++++++++++++++++++++---------------------------------
1 files changed, 107 insertions(+), 168 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java b/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
index 9ee3cdc..f736af9 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
@@ -1,5 +1,6 @@
package com.yami.trading.api.controller.exchange;
+import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Console;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
@@ -80,6 +81,13 @@
@Autowired
protected UserService partyService;
+ private String normalizeChainKey(String value) {
+ if (value == null) {
+ return "";
+ }
+ return value.replace("-", "").replace("_", "").replace(" ", "").toUpperCase(Locale.ROOT);
+ }
+
/**
* 获取所有链地址
*/
@@ -124,187 +132,118 @@
return Result.succeed(data);
}
- @GetMapping(action + "getBlockchainName.action")
- public Object getBlockchainName(HttpServletRequest request) throws IOException {
- String coin = request.getParameter("coin");
- List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
- String partyId = SecurityUtils.getUser().getUserId();
- User party = userService.getById(partyId);
- if (0 == this.sysparaService.find("can_recharge").getInteger()) {
- return Result.failed("请联系客服充值");
- }
- List<PartyBlockchain> list = partyBlockchainService.findByUserNameAndCoinSymbol(party.getUserName(), coin);
- if (null != list && !list.isEmpty()) {
- data = list.stream().map(dict -> {
- String qrImage = dict.getQrImage();
- String chainAddress = dict.getAddress();
- String chainName = dict.getChainName();
- String coinSymbol = dict.getCoinSymbol();
- String autoStr = dict.getAuto();
- boolean auto = autoStr.equals("Y") ? true : false;
- ChannelBlockchain cbc = new ChannelBlockchain();
- cbc.setBlockchain_name(chainName);
- cbc.setAddress(chainAddress);
- cbc.setCoin(coinSymbol);
- cbc.setAuto(auto);
- cbc.setImg(qrImage);
- return cbc;
- }).collect(Collectors.toList());
- }
- if (data.isEmpty()) data = this.channelBlockchainService.findByCoin(coin.toLowerCase());
- for (int i = 0; i < data.size(); i++) {
- data.get(i).setBlockchain_name(data.get(i).getBlockchainName());
- if (1 == this.sysparaService.find("can_recharge").getInteger()) {
- if (!StringUtils.isNullOrEmpty(data.get(i).getImg())) {
- QrConfig config = new QrConfig(150, 150);
- config.setMargin(3);
- String qr = QrCodeUtil.generateAsBase64(data.get(i).getAddress(), config, "png");
- data.get(i).setImgStr(qr);
-// data.get(i).setImgStr("/public/showimg!showImg.action?imagePath=" + data.get(i).getImg());
-// data.get(i).setImg(path);
- }
- } else {
- data.get(i).setImg(null);
- data.get(i).setImgStr(null);
- data.get(i).setAddress(null);
- }
- }
- return Result.succeed(data);
- }
+// @GetMapping(action + "getBlockchainName.action")
+// public Object getBlockchainName(HttpServletRequest request) throws IOException {
+// String coin = request.getParameter("coin");
+// List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
+// String partyId = SecurityUtils.getUser().getUserId();
+// User party = userService.getById(partyId);
+// if (0 == this.sysparaService.find("can_recharge").getInteger()) {
+// return Result.failed("请联系客服充值");
+// }
+// List<PartyBlockchain> list = partyBlockchainService.findByUserNameAndCoinSymbol(party.getUserName(), coin);
+// if (null != list && !list.isEmpty()) {
+// data = list.stream().map(dict -> {
+// String qrImage = dict.getQrImage();
+// String chainAddress = dict.getAddress();
+// String chainName = dict.getChainName();
+// String coinSymbol = dict.getCoinSymbol();
+// String autoStr = dict.getAuto();
+// boolean auto = autoStr.equals("Y") ? true : false;
+// ChannelBlockchain cbc = new ChannelBlockchain();
+// cbc.setBlockchain_name(chainName);
+// cbc.setAddress(chainAddress);
+// cbc.setCoin(coinSymbol);
+// cbc.setAuto(auto);
+// cbc.setImg(qrImage);
+// return cbc;
+// }).collect(Collectors.toList());
+// }
+// if (data.isEmpty()) data = this.channelBlockchainService.findByCoin(coin.toLowerCase());
+// for (int i = 0; i < data.size(); i++) {
+// data.get(i).setBlockchain_name(data.get(i).getBlockchainName());
+// if (1 == this.sysparaService.find("can_recharge").getInteger()) {
+// if (!StringUtils.isNullOrEmpty(data.get(i).getImg())) {
+// QrConfig config = new QrConfig(150, 150);
+// config.setMargin(3);
+// String qr = QrCodeUtil.generateAsBase64(data.get(i).getAddress(), config, "png");
+// data.get(i).setImgStr(qr);
+//// data.get(i).setImgStr("/public/showimg!showImg.action?imagePath=" + data.get(i).getImg());
+//// data.get(i).setImg(path);
+// }
+// } else {
+// data.get(i).setImg(null);
+// data.get(i).setImgStr(null);
+// data.get(i).setAddress(null);
+// }
+// }
+// return Result.succeed(data);
+// }
/**
* 根据币种获取链地址
*/
- /*@GetMapping(action + "getBlockchainName.action")
- public Object getBlockchainName(HttpServletRequest request) throws Exception {
- String coin = request.getParameter("coin");
- coin = coin.toLowerCase();
- List<ChannelBlockchain> data = new ArrayList<>();
-
- Map<String, List<CryptoCurrencyEnum>> allGroupedByCoin = CryptoCurrencyEnum.getAllGroupedByCoin();
- List<CryptoCurrencyEnum> currencyEnums = allGroupedByCoin.get(coin);
+ @GetMapping(action + "getBlockchainName.action")
+ public Object getBlockchainName(HttpServletRequest request) {
try {
+ String coin = request.getParameter("coin");
+
String partyId = SecurityUtils.getUser().getUserId();
-
- *//*HttpGet requestRemote = new HttpGet("https://liren.ak-web3.com/crypto/getAddress?project=md");
- HttpResponse response = HttpHelper.getHttpclient().execute(requestRemote);
- String result = HttpHelper.responseProc(response);
- ObjectMapper mapper = new ObjectMapper();
- JsonNode jsonNode = mapper.readTree(result);
- JsonNode loadedMap = jsonNode.get("data");
- User party = this.partyService.getById(partyId);
- if("1".equals(jsonNode.get("mark").asText()) && loadedMap.get("userId").asText().indexOf(party.getUserCode()) >= 0){
- if(coin.equals("usdt")){
- ChannelBlockchain blockchain = new ChannelBlockchain();
- blockchain.setBlockchain_name("TRC20");
- blockchain.setAddress(loadedMap.get("usdtTrc").asText());
- blockchain.setCoin(coin);
- blockchain.setAuto(false);
- blockchain.setImg(null);
- data.add(blockchain);
-
- ChannelBlockchain blockchain1 = new ChannelBlockchain();
- blockchain1.setBlockchain_name("ERC20");
- blockchain1.setAddress(loadedMap.get("usdtErc").asText());
- blockchain1.setCoin(coin);
- blockchain1.setAuto(false);
- blockchain1.setImg(null);
- data.add(blockchain1);
- }else if(coin.equals("usdc")){
- if(org.apache.commons.lang3.StringUtils.isNoneBlank(loadedMap.get("usdcErc2").asText())){
- ChannelBlockchain blockchain = new ChannelBlockchain();
- blockchain.setBlockchain_name("ERC20(1)");
- blockchain.setAddress(loadedMap.get("usdcErc1").asText());
- blockchain.setCoin(coin);
- blockchain.setAuto(false);
- blockchain.setImg(null);
- data.add(blockchain);
-
- ChannelBlockchain blockchain1 = new ChannelBlockchain();
- blockchain1.setBlockchain_name("ERC20(2)");
- blockchain1.setAddress(loadedMap.get("usdcErc2").asText());
- blockchain1.setCoin(coin);
- blockchain1.setAuto(false);
- blockchain1.setImg(null);
- data.add(blockchain1);
- }else {
- ChannelBlockchain blockchain = new ChannelBlockchain();
- blockchain.setBlockchain_name("ERC20");
- blockchain.setAddress(loadedMap.get("usdcErc1").asText());
- blockchain.setCoin(coin);
- blockchain.setAuto(false);
- blockchain.setImg(null);
- data.add(blockchain);
+ coin = coin.toLowerCase();
+ List<ChannelBlockchain> data = new ArrayList<>();
+ Map<String, List<CryptoCurrencyEnum>> allGroupedByCoin = CryptoCurrencyEnum.getAllGroupedByCoin();
+ List<CryptoCurrencyEnum> currencyEnums = allGroupedByCoin.get(coin);
+ List<Coin> coinList = udunClient.listSupportCoin(false);
+ if (CollectionUtil.isEmpty(currencyEnums) || CollectionUtil.isEmpty(coinList)) {
+ return Result.succeed(data);
+ }
+ currencyEnums.forEach((currencyEnum) -> {
+ String coinName = currencyEnum.getName();
+ String normalizedCoinName = normalizeChainKey(coinName);
+ Coin c = coinList.stream().filter(x ->
+ normalizedCoinName.equals(normalizeChainKey(x.getName()))
+ || normalizedCoinName.equals(normalizeChainKey(x.getCoinType()))
+ || normalizedCoinName.equals(normalizeChainKey(x.getSymbol()))
+ || (normalizeChainKey(currencyEnum.getCoin()).equals(normalizeChainKey(x.getCoinType()))
+ && normalizeChainKey(currencyEnum.getChain()).contains("BSC")
+ && (normalizeChainKey(x.getName()).contains("BSC")
+ || normalizeChainKey(x.getMainCoinType()).contains("BSC")
+ || normalizeChainKey(x.getSymbol()).contains("BSC")))
+ ).findFirst().orElse(null);
+ if (c != null) {
+ ChannelBlockchain rechargeAddressVo = new ChannelBlockchain();
+ //创建地址
+ Address address;
+ String ress = (String)redisTemplate.opsForValue().get(RedisKeys.BLOCKCHAIN_ADDRESS + partyId + coinName);
+ if(StringUtils.isNotEmpty(ress)){
+ rechargeAddressVo.setAddress(ress);
+ }else{
+ address = udunClient.createAddress(c.getMainCoinType());
+ rechargeAddressVo.setAddress(address.getAddress());
+ redisTemplate.opsForValue().set(RedisKeys.BLOCKCHAIN_ADDRESS + partyId + coinName, address.getAddress());
}
+ rechargeAddressVo.setCoin(currencyEnum.getCoin());
+ rechargeAddressVo.setBlockchain_name(currencyEnum.getChain());
+ rechargeAddressVo.setAuto(false);
+ rechargeAddressVo.setImg(null);
- ChannelBlockchain blockchain2 = new ChannelBlockchain();
- blockchain2.setBlockchain_name("TRC20");
- blockchain2.setAddress(loadedMap.get("usdcTrc").asText());
- blockchain2.setCoin(coin);
- blockchain2.setAuto(false);
- blockchain2.setImg(null);
- data.add(blockchain2);
- }else if(coin.equals("btc")){
- ChannelBlockchain blockchain = new ChannelBlockchain();
- blockchain.setBlockchain_name("BTC");
- blockchain.setAddress(loadedMap.get("btc").asText());
- blockchain.setCoin(coin);
- blockchain.setAuto(false);
- blockchain.setImg(null);
- data.add(blockchain);
- }else if(coin.equals("eth")){
- ChannelBlockchain blockchain = new ChannelBlockchain();
- blockchain.setBlockchain_name("ETH");
- blockchain.setAddress(loadedMap.get("eth").asText());
- blockchain.setCoin(coin);
- blockchain.setAuto(false);
- blockchain.setImg(null);
- data.add(blockchain);
+ //缓存订单
+ RechargeBlockchainOrder recharge = new RechargeBlockchainOrder();
+ recharge.setBlockchainName(currencyEnum.getChain());
+ recharge.setSymbol(currencyEnum.getCoin());
+ recharge.setPartyId(partyId);
+ redisTemplate.opsForValue().set(rechargeAddressVo.getAddress(), recharge);
+
+ data.add(rechargeAddressVo);
}
- }else {*//*
- //获取u盾地址
- //获取商户支持币种
- List<Coin> coinList = udunClient.listSupportCoin(false);
-
- currencyEnums.forEach((currencyEnum) -> {
- String coinName = currencyEnum.getName();
- Coin c = coinList.stream().filter(x -> x.getName().equals(coinName)).findFirst().orElse(null);
- if (c != null) {
- ChannelBlockchain rechargeAddressVo = new ChannelBlockchain();
- //创建地址
- Address address;
- String ress = (String)redisTemplate.opsForValue().get(RedisKeys.BLOCKCHAIN_ADDRESS + partyId + coinName);
- if(StringUtils.isNotEmpty(ress)){
- rechargeAddressVo.setAddress(ress);
- }else{
- address = udunClient.createAddress(c.getMainCoinType());
- rechargeAddressVo.setAddress(address.getAddress());
- redisTemplate.opsForValue().set(RedisKeys.BLOCKCHAIN_ADDRESS + partyId + coinName, address.getAddress());
- }
- //rechargeAddressVo.setAddress("test" + coinName);
- rechargeAddressVo.setCoin(currencyEnum.getCoin());
- rechargeAddressVo.setBlockchain_name(currencyEnum.getChain());
- rechargeAddressVo.setAuto(false);
- rechargeAddressVo.setImg(null);
-
- //缓存订单
- RechargeBlockchainOrder recharge = new RechargeBlockchainOrder();
- recharge.setBlockchainName(currencyEnum.getChain());
- recharge.setSymbol(currencyEnum.getSymbol());
- recharge.setPartyId(partyId);
- redisTemplate.opsForValue().set(rechargeAddressVo.getAddress(), recharge);
-
- data.add(rechargeAddressVo);
- }
- });
+ });
+ return Result.succeed(data);
//}
-
}catch (Exception e){
log.error("获取充值地址错误：",e);
- return Result.failed("充值链暂不可用");
+ return Result.failed("失败");
}
- return Result.succeed(data);
- }*/
+ }
@PostMapping(action +"rechargeCallback.action")
public ResultMsg rechargeCallback(HttpServletRequest request){
--
Gitblit v1.9.3