From 1f3c2b3c89f8a7336f803511889fb45c4798869f Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 18 三月 2025 09:47:08 +0800
Subject: [PATCH] #输出socket下发日志
---
src/main/java/com/zy/core/thread/impl/NyShuttleThread.java | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java b/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
index 02824c8..80e5c64 100644
--- a/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
@@ -220,7 +220,6 @@
JSONObject resultResponse = JSON.parseObject(socketResult.get("response").toString());
JSONObject resultBody = JSON.parseObject(resultResponse.get("body").toString());
String responseType = resultBody.get("responseType").toString();
- String responseTaskId = resultBody.get("taskId").toString();
if (DEBUG) {
result = socketResult;
break;
@@ -230,8 +229,11 @@
continue;//鍝嶅簲绫诲瀷涓庤姹傜被鍨嬩笉涓�鑷达紝涓嶅湪璋冭瘯妯″紡涓�
}
- if (taskId != null && !responseTaskId.equals(taskId)) {
- continue;//鍝嶅簲ID涓庤姹侷D涓嶄竴鑷达紝涓嶅湪璋冭瘯妯″紡涓�
+ if (taskId != null) {
+ String responseTaskId = resultBody.get("taskId").toString();
+ if (!responseTaskId.equals(taskId)) {
+ continue;//鍝嶅簲ID涓庤姹侷D涓嶄竴鑷达紝涓嶅湪璋冭瘯妯″紡涓�
+ }
}
result = socketResult;
--
Gitblit v1.9.1