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"
\ 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 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;
+ }
}
}
}