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); } 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(); 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> 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> trading-order-huobi/src/main/java/com.yami.trading.huobi/hobi/internal/HobiDataServiceImpl.java
@@ -306,7 +306,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); @@ -323,7 +323,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); @@ -451,7 +451,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);