From 0fdce6b13b1634a5fe5202afb12bac9065ac01c0 Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Fri, 6 Feb 2026 17:11:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86=E7=A3=81=E7=9B=98=E5=81=A5?=
 =?UTF-8?q?=E5=BA=B7=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/tongran/rocketmq/domain/AllDiskName.java | 4 ++--
 .../java/com/tongran/rocketmq/domain/InitialDiskInfo.java  | 2 ++
 .../main/resources/mapper/rocketmq/AllDiskNameMapper.xml   | 6 +++++-
 .../resources/mapper/rocketmq/InitialDiskInfoMapper.xml    | 7 +++++--
 4 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/AllDiskName.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/AllDiskName.java
index e0957bf..b0d4616 100644
--- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/AllDiskName.java
+++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/AllDiskName.java
@@ -63,7 +63,7 @@ public class AllDiskName extends BaseEntity
     private String type;
     /** 表名 */
     private String tableName;
-    /** 健康状态 0 不健康，1健康 */
-    private Long healthStatus;
+    /** 健康信息 */
+    private String healthInfo;
 
 }
diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialDiskInfo.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialDiskInfo.java
index 82683da..040cef3 100644
--- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialDiskInfo.java
+++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialDiskInfo.java
@@ -87,6 +87,8 @@ public class InitialDiskInfo extends BaseEntity
     private String unit;
     /** 健康状态 0-不健康 1-健康) */
     private Long healthStatus;
+    /** 健康分数 */
+    private Integer healthScore;
 
 
 }
diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/AllDiskNameMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/AllDiskNameMapper.xml
index 70f1c76..6c430e1 100644
--- a/tongran-rocketmq/src/main/resources/mapper/rocketmq/AllDiskNameMapper.xml
+++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/AllDiskNameMapper.xml
@@ -153,7 +153,11 @@
         TRUNCATE(IFNULL(b.read_speed,0)/(1024*1024), 0) as readSpeed,
         b.type,
         TRUNCATE(IFNULL(b.used_space,0)/(1024 * 1024 * 1024), 0) as usedSpace,
-        b.health_status as healthStatus
+        CASE
+        WHEN b.health_score IS NOT NULL THEN b.health_score
+        WHEN b.health_status = 1 THEN '健康'
+        WHEN b.health_status = 0 THEN '不健康' ELSE null
+        END AS healthInfo
         FROM all_disk_name a
         LEFT JOIN (
         SELECT client_id, name, MAX(create_time) as max_create_time
diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialDiskInfoMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialDiskInfoMapper.xml
index f10e359..7a026e5 100644
--- a/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialDiskInfoMapper.xml
+++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialDiskInfoMapper.xml
@@ -20,6 +20,7 @@
         <result property="type"    column="type"    />
         <result property="usedSpace"    column="used_space"    />
         <result property="healthStatus"    column="health_status"    />
+        <result property="healthScore"    column="health_score"    />
         <result property="createBy"    column="create_by"    />
         <result property="updateBy"    column="update_by"    />
         <result property="createTime"    column="create_time"    />
@@ -43,7 +44,7 @@
     </select>
     <select id="selectInitialDiskInfoListByCondition" parameterType="InitialDiskInfo" resultMap="InitialDiskInfoResult">
         select id, client_id, name, serial, total, write_speed, read_speed, write_times, read_times, write_bytes,
-        read_bytes, type, used_space,health_status, create_by, update_by, create_time, update_time
+        read_bytes, type, used_space,health_status, health_score, create_by, update_by, create_time, update_time
         from ${tableName}
         <where>
             <if test="clientId != null  and clientId != ''"> and client_id = #{clientId}</if>
@@ -156,6 +157,7 @@
         type,
         used_space,
         health_status,
+        health_score,
         create_by,
         update_by,
         create_time,
@@ -178,6 +180,7 @@
             #{item.type},
             #{item.usedSpace},
             #{item.healthStatus},
+            #{item.healthScore},
             #{item.createBy},
             #{item.updateBy},
             <choose>
@@ -202,7 +205,7 @@
 
     <select id="getDistDetailsMsgByClientId" parameterType="InitialDiskInfo" resultMap="InitialDiskInfoResult">
         select id, client_id, name, serial, total, write_speed, read_speed, write_times, read_times, write_bytes,
-               read_bytes, type, used_space,health_status, create_by, update_by, create_time, update_time
+               read_bytes, type, used_space,health_status, health_score, create_by, update_by, create_time, update_time
         from ${tableName}
         where client_id = #{clientId} and `name`= #{name}
         order by create_time desc