From 7a8af8c19b40b8028e25ee0b669463d06f723a30 Mon Sep 17 00:00:00 2001
From: 刘帅 <rr.iii@qq.com>
Date: 星期一, 21 九月 2026 15:57:24 +0800
Subject: [PATCH] bug：测试问题统一修改
---
cloud-server-management/src/main/java/com/dsh/guns/modular/system/audit/ManagementAuditWriter.java | 23 +++++++++++++++++++++--
1 files changed, 21 insertions(+), 2 deletions(-)
diff --git a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/audit/ManagementAuditWriter.java b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/audit/ManagementAuditWriter.java
index 0bb2a95..2e04d6b 100644
--- a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/audit/ManagementAuditWriter.java
+++ b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/audit/ManagementAuditWriter.java
@@ -8,6 +8,7 @@
import javax.annotation.Resource;
import java.io.OutputStream;
+import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
@@ -23,7 +24,10 @@
public void append(Map<String, Object> audit) {
try {
List<ServiceInstance> instances = discoveryClient.getInstances("mb-cloud-other");
- if (instances == null || instances.isEmpty()) return;
+ if (instances == null || instances.isEmpty()) {
+ log.warn("管理端审计写入失败：未发现审计服务 mb-cloud-other");
+ return;
+ }
URL url = new URL(instances.get(0).getUri().toString() + "/internal/audit-logs");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setConnectTimeout(1000);
@@ -33,10 +37,25 @@
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
byte[] body = JSON.toJSONString(audit).getBytes(StandardCharsets.UTF_8);
try (OutputStream output = connection.getOutputStream()) { output.write(body); }
- connection.getResponseCode();
+ int status = connection.getResponseCode();
+ if (status < HttpURLConnection.HTTP_OK || status >= HttpURLConnection.HTTP_MULT_CHOICE) {
+ log.warn("管理端审计写入失败，响应状态: {}, 响应内容: {}", status,
+ readResponse(connection.getErrorStream()));
+ }
connection.disconnect();
} catch (Exception e) {
log.warn("管理端审计写入失败", e);
}
}
+
+ private String readResponse(InputStream input) {
+ if (input == null) return "";
+ try (InputStream stream = input) {
+ byte[] buffer = new byte[1024];
+ int length = stream.read(buffer);
+ return length <= 0 ? "" : new String(buffer, 0, length, StandardCharsets.UTF_8);
+ } catch (Exception ignored) {
+ return "";
+ }
+ }
}
--
Gitblit v1.7.1