From 03ec6194650d6a79e2256337892a00f52a7be8bf Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 17 Nov 2025 11:59:24 +0800
Subject: [PATCH] 优化
---
trading-order-service/src/main/java/com/yami/trading/service/impl/WalletServiceImpl.java | 27 +++++++++++++++++++++++++--
1 files changed, 25 insertions(+), 2 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/service/impl/WalletServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/impl/WalletServiceImpl.java
index b66ddd8..dec84c2 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/impl/WalletServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/impl/WalletServiceImpl.java
@@ -1,6 +1,7 @@
package com.yami.trading.service.impl;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
@@ -664,8 +665,8 @@
// 统计拓展钱包
List<Item> items = itemService.findByType(symbolType);
List<String> symbolList = items.stream().map(Item::getSymbol).collect(Collectors.toList());
- List<Realtime> realtimeList = dataService.realtimeByType(symbolType);
- double convertUsdt = getWalletExtendConvertUsdt(partyId, realtimeList, symbolList);
+ //List<Realtime> realtimeList = dataService.realtimeByType(symbolType);
+ double convertUsdt = getWalletExtendConvertUSDT(partyId, symbolList);
// logger.info("getTotalAssets ==> "+partyId + " ===> "+symbolType+"====>"+convertUsdt);
@@ -1036,6 +1037,28 @@
return walletExtendAll;
}
+ public double getWalletExtendConvertUSDT(String partyId, List<String> symbolList) {
+ double walletExtendAll = 0;
+ List<WalletExtend> walletExtends = findExtend(partyId, symbolList);
+ for (WalletExtend walletExtend : walletExtends) {
+ String symbol = symbolList.stream()
+ .filter( x -> x.equalsIgnoreCase(walletExtend.getWallettype()))
+ .findFirst().orElse(null);
+ if (symbol != null) {
+ List<Realtime> realtimeList = dataService.realtime(symbol);
+ if (!CollectionUtil.isEmpty(realtimeList)) {
+ Realtime realtime = realtimeList.get(0);
+ Item item = itemService.findBySymbol(symbol);
+ String type = item.getType();
+ double currency = Arith.mul(realtime.getClose(), walletExtend.getAmount());
+ BigDecimal usdtByType = exchangeRateService.getUsdtByType(BigDecimal.valueOf(currency), type);
+ walletExtendAll = Arith.add(walletExtendAll, usdtByType.doubleValue());
+ }
+ }
+ }
+ return walletExtendAll;
+ }
+
/*
* 获取 所有订单 交割合约总资产、总未实现盈利 redis
*/
--
Gitblit v1.9.3