From f6a85a3f1f36b412daf60cac6d8ea9278cffa108 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 15 Sep 2025 18:09:07 +0800
Subject: [PATCH] 提现充值
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java | 51 ++++++++++-----------------------------------------
1 files changed, 10 insertions(+), 41 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
index 1be2313..a26758f 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
@@ -4,20 +4,26 @@
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.lang.Console;
+import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpStatus;
import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
import com.yami.trading.api.UD.*;
import com.yami.trading.bean.ico.domain.Ico;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.model.ChannelBlockchain;
+import com.yami.trading.bean.model.Withdraw;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.util.ApplicationContextUtils;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.huobi.data.internal.KlineInitService;
import com.yami.trading.security.common.enums.CryptoCurrencyEnum;
import com.yami.trading.security.common.util.SecurityUtils;
+import com.yami.trading.service.WithdrawService;
import com.yami.trading.service.ico.IcoService;
import com.yami.trading.service.item.ItemService;
import lombok.extern.slf4j.Slf4j;
@@ -53,48 +59,11 @@
@Autowired
RedisTemplate redisTemplate;
- //@Scheduled(cron = "*/5 * * * * ?")
- public void test() {
- String coin = "usdt";
- List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
- Map<String, List<CryptoCurrencyEnum>> allGroupedByCoin = CryptoCurrencyEnum.getAllGroupedByCoin();
- List<CryptoCurrencyEnum> currencyEnums = allGroupedByCoin.get(coin);
- try {
- String partyId = SecurityUtils.getUser().getUserId();
- //获取u盾地址
- //获取商户支持币种
- List<Coin> coinList = udunClient.listSupportCoin(false);
+ @Autowired
+ WithdrawService withdrawService;
- 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(partyId + coinName);
- if(StringUtils.isNotEmpty(ress)){
- rechargeAddressVo.setAddress(ress);
- rechargeAddressVo.setCoin(coinName);
- rechargeAddressVo.setBlockchain_name(coinName);
- rechargeAddressVo.setAuto(false);
- rechargeAddressVo.setImg(null);
- }else{
- address = udunClient.createAddress(c.getMainCoinType(),null,null);
- rechargeAddressVo.setAddress(address.getAddress());
- rechargeAddressVo.setCoin(coinName);
- rechargeAddressVo.setBlockchain_name(coinName);
- rechargeAddressVo.setAuto(false);
- rechargeAddressVo.setImg(null);
- redisTemplate.opsForValue().set(partyId + coinName, address.getAddress());
- }
- data.add(rechargeAddressVo);
- }
- });
- }catch (Exception e){
- e.printStackTrace();
- log.error("获取充值地址错误：",e);
- }
+ //@Scheduled(cron = "*/5 * * * * ?")
+ public void test() throws JsonProcessingException {
}
/**
* ico转入产品
--
Gitblit v1.9.3