From b1e9cbcebcc1f8e396da285d8ae93bd6523be128 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 20 Oct 2025 11:25:49 +0800
Subject: [PATCH] 日志优化
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/AStockTradeListTask.java | 2 +-
trading-order-admin/src/main/resources/logback/logback-prod.xml | 3 +++
trading-order-admin/src/main/resources/logback/logback-local.xml | 3 +++
trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java | 6 +++---
trading-order-admin/src/main/java/com/yami/trading/WebApplication.java | 5 ++++-
5 files changed, 14 insertions(+), 5 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/WebApplication.java b/trading-order-admin/src/main/java/com/yami/trading/WebApplication.java
index d942c37..7d3e0f9 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/WebApplication.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/WebApplication.java
@@ -25,6 +25,8 @@
import javax.annotation.PostConstruct;
import java.util.TimeZone;
+import java.util.logging.Level;
+import java.util.logging.Logger;
/**
* @author lgh
@@ -36,7 +38,8 @@
public class WebApplication extends SpringBootServletInitializer {
public static void main(String[] args) {
-
+ // 开启 OkHttp 连接池的详细日志
+ Logger.getLogger(okhttp3.OkHttpClient.class.getName()).setLevel(Level.FINE);
SpringApplication.run(WebApplication.class, args);
}
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/AStockTradeListTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/AStockTradeListTask.java
index 993063b..d0610c6 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/AStockTradeListTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/AStockTradeListTask.java
@@ -41,7 +41,7 @@
private volatile boolean isUsStockInit = false;
- @Scheduled(cron = "*/5 * * * * ?")
+ //@Scheduled(cron = "*/5 * * * * ?")
public void sendTask() throws InterruptedException {
if(!isAStockInit){
fetchAStock();
diff --git a/trading-order-admin/src/main/resources/logback/logback-local.xml b/trading-order-admin/src/main/resources/logback/logback-local.xml
index 90321a2..de4d2aa 100644
--- a/trading-order-admin/src/main/resources/logback/logback-local.xml
+++ b/trading-order-admin/src/main/resources/logback/logback-local.xml
@@ -11,4 +11,7 @@
<logger name="org.mybatis" level="warn"/>
<logger name="org.apache.ibatis" level="warn"/>
<logger name="com.baomidou.mybatisplus" level="warn"/>
+ <logger name="okhttp3.OkHttpClient" level="DEBUG" additivity="false">
+ <appender-ref ref="CONSOLE"/> <!-- 输出到控制台或文件 -->
+ </logger>
</configuration>
diff --git a/trading-order-admin/src/main/resources/logback/logback-prod.xml b/trading-order-admin/src/main/resources/logback/logback-prod.xml
index 91d6642..b140f46 100644
--- a/trading-order-admin/src/main/resources/logback/logback-prod.xml
+++ b/trading-order-admin/src/main/resources/logback/logback-prod.xml
@@ -39,4 +39,7 @@
<logger name="org.mybatis" level="warn"/>
<logger name="org.apache.ibatis" level="warn"/>
<logger name="com.baomidou.mybatisplus" level="warn"/>
+ <logger name="okhttp3.OkHttpClient" level="DEBUG" additivity="false">
+ <appender-ref ref="CONSOLE"/> <!-- 输出到控制台或文件 -->
+ </logger>
</configuration>
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java
index 27cff5c..61dfeeb 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java
@@ -307,7 +307,7 @@
if ((depth == null || item.getAdjustmentValue() == null || item.getAdjustmentValue().intValue() == 0) && (item.getMultiple().intValue() == 0 || item.getMultiple().intValue() == 1)) {
return depth;
}
- if(CollectionUtil.isNotEmpty(depth.getAsks()) ){
+ if(depth != null && CollectionUtil.isNotEmpty(depth.getAsks()) ){
List<DepthEntry> asks = depth.getAsks();
for (int i = 0; i < asks.size(); i++) {
DepthEntry depthEntry = asks.get(i);
@@ -324,7 +324,7 @@
}
}
- if(CollectionUtil.isNotEmpty(depth.getBids())){
+ if(depth != null && CollectionUtil.isNotEmpty(depth.getBids())){
List<DepthEntry> bids = depth.getBids();
for (int i = 0; i < bids.size(); i++) {
DepthEntry depthEntry = bids.get(i);
@@ -452,7 +452,7 @@
if ((trade == null || item.getAdjustmentValue() == null || item.getAdjustmentValue().doubleValue() == 0) && (item.getMultiple().doubleValue() == 0 || item.getMultiple().doubleValue() == 1)) {
return trade;
}
- if(CollectionUtil.isNotEmpty(trade.getData())){
+ if(trade != null && CollectionUtil.isNotEmpty(trade.getData())){
List<TradeEntry> data = trade.getData();
for (int i = 0; i < data.size(); i++) {
TradeEntry tradeEntry = data.get(i);
--
Gitblit v1.9.3