From 14b0e39d5be922ad02ca6ffae4b8a04df562c7f1 Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Fri, 9 Jan 2026 19:18:21 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=AF=A6=E6=83=85=E5=8D=87?=
 =?UTF-8?q?=E7=BA=A7=E5=88=B0=E6=9C=80=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/RmResourceRegistrationMapper.xml       |  6 +++++-
 .../impl/RmAgentManagementServiceImpl.java        | 15 ++++++++-------
 2 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml
index 4284613..6578b5a 100644
--- a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml
+++ b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml
@@ -345,6 +345,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </update>
     <select id="getMaxAgentVersion" resultType="RmResourceRegistration">
         select agent_version maxAgentVersion from rm_resource_registration where del_flag=0
-        order by create_time desc limit 1
+        ORDER BY
+            CAST(SUBSTRING_INDEX(agent_version, '.', 1) AS UNSIGNED) DESC,
+            CAST(SUBSTRING_INDEX(SUBSTRING_INDEX(agent_version, '.', 2), '.', -1) AS UNSIGNED) DESC,
+            CAST(SUBSTRING_INDEX(agent_version, '.', -1) AS UNSIGNED) DESC
+        limit 1
     </select>
 </mapper>
\ No newline at end of file
diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/RmAgentManagementServiceImpl.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/RmAgentManagementServiceImpl.java
index 3436352..911f098 100644
--- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/RmAgentManagementServiceImpl.java
+++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/RmAgentManagementServiceImpl.java
@@ -205,15 +205,16 @@ public class RmAgentManagementServiceImpl implements IRmAgentManagementService
     @Override
     public RmAgentManagement isNew(RmAgentManagement rmAgentManagement) {
         RmAgentManagement query = new RmAgentManagement();
-        query.setClientId(rmAgentManagement.getClientId());
+        query.setAgentVersion(rmAgentManagement.getAgentVersion());
         List<RmAgentManagement> managementList = rmAgentManagementMapper.selectRmAgentManagementList(query);
         if(managementList != null && !managementList.isEmpty()){
-            RmAgentManagement agentManagement = managementList.get(0);
-            String addr = agentManagement.getFileUrl();
-            if(addr != null){
-                if(addr.contains(rmAgentManagement.getAgentVersion())){
-                    agentManagement.setNewFlag(true);
-                    return agentManagement;
+            for (RmAgentManagement agentManagement : managementList) {
+                String addr = agentManagement.getFileUrl();
+                if(addr != null){
+                    if(addr.contains(rmAgentManagement.getAgentVersion())){
+                        agentManagement.setNewFlag(true);
+                        return agentManagement;
+                    }
                 }
             }
         }