From 41e346085248e484cc6d6fda995fe5e136f700eb Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Thu, 3 Jul 2025 16:18:08 +0800
Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=8D=97=E6=B5=B7?=
 =?UTF-8?q?=E5=86=9C=E5=95=86tagent=E7=AE=A1=E7=90=86=E9=A1=B5=E9=9D=A2?=
 =?UTF-8?q?=E7=9B=B8=E5=85=B3=E9=9C=80=E6=B1=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

关联 #[1437561216532480]南海农商tagent管理页面相关需求 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1437561216532480
---
 .../tagent/dao/mapper/TagentMapper.java       |  8 ++++
 .../tagent/dao/mapper/TagentMapper.xml        | 37 +++++++++++++++++++
 .../tagent/service/TagentService.java         | 23 ++++++++++++
 .../tagent/service/TagentServiceImpl.java     | 31 ++++++++++++++++
 4 files changed, 99 insertions(+)

diff --git a/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.java b/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.java
index dde3ac1..91822f6 100644
--- a/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.java
+++ b/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.java
@@ -33,6 +33,8 @@ public interface TagentMapper {
 
     Long getAccountIdById(Long id);
 
+    List<Long> getAccountIdListByIdList(List<Long> idList);
+
     TagentOSVo getOsByName(String name);
 
     TagentVo getTagentByIpAndPort(@Param("ip") String ip, @Param("port") Integer port);
@@ -105,14 +107,20 @@ public interface TagentMapper {
 
     void deleteTagentById(Long id);
 
+    void deleteTagentByIdList(List<Long> idList);
+
     int deleteAllIpByTagentId(Long id);
 
+    int deleteAllIpByTagentIdList(List<Long> tagentIdList);
+
     void deleteTagentVersionById(Long id);
 
     void deleteTagentIp(@Param("tagentId") Long tagentId, @Param("ip") String ip);
 
     void deleteAccountById(Long id);
 
+    void deleteAccountByIdList(List<Long> idList);
+
     void deleteAccountListByIdList(List<Long> idList);
 
 }
diff --git a/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.xml b/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.xml
index 3930650..f613886 100644
--- a/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.xml
+++ b/src/main/java/neatlogic/framework/tagent/dao/mapper/TagentMapper.xml
@@ -156,6 +156,15 @@
         WHERE `id` = #{id}
     </delete>
 
+    <delete id="deleteTagentByIdList" parameterType="java.lang.Long">
+        DELETE
+        FROM tagent
+        WHERE `id` IN
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
     <select id="getOsByName" resultType="neatlogic.framework.tagent.dto.TagentOSVo">
         SELECT `id`,
                `name`,
@@ -185,6 +194,15 @@
         where id = #{id}
     </select>
 
+    <select id="getAccountIdListByIdList" parameterType="java.lang.Long" resultType="java.lang.Long">
+        SELECT `account_id`
+        FROM `tagent`
+        WHERE id IN
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </select>
+
     <select id="getGroupNetworkList" resultType="neatlogic.framework.dto.runner.GroupNetworkVo" useCache="false">
         SELECT id,
                group_id   as groupId,
@@ -708,6 +726,16 @@
         FROM tagent_ip
         WHERE tagent_id = #{value}
     </delete>
+
+    <delete id="deleteAllIpByTagentIdList" parameterType="java.lang.Long">
+        DELETE
+        FROM `tagent_ip`
+        WHERE `tagent_id` IN
+        <foreach collection="list" item="id" separator="," open="(" close=")">
+            #{id}
+        </foreach>
+    </delete>
+
     <delete id="deleteTagentVersionById">
         delete
         from tagent_version
@@ -728,6 +756,15 @@
         where id = #{id}
     </delete>
 
+    <delete id="deleteAccountByIdList" parameterType="java.lang.Long">
+        delete
+        from `tagent_account`
+        where `id` IN
+        <foreach collection="list" item="id" separator="," open="(" close=")">
+            #{id}
+        </foreach>
+    </delete>
+
     <delete id="deleteAccountListByIdList">
         delete
         from tagent_account
diff --git a/src/main/java/neatlogic/framework/tagent/service/TagentService.java b/src/main/java/neatlogic/framework/tagent/service/TagentService.java
index c57f995..9946b7f 100644
--- a/src/main/java/neatlogic/framework/tagent/service/TagentService.java
+++ b/src/main/java/neatlogic/framework/tagent/service/TagentService.java
@@ -111,6 +111,14 @@ public interface TagentService {
      */
     TagentVo getTagentMGById(long id);
 
+    /**
+     * 根据tagentId列表批量获取tagent心跳信息
+     *
+     * @param idList tagentId列表
+     * @return tagent对象
+     */
+    List<TagentVo> getTagentMGListByIdList(List<Long> idList);
+
     /**
      * 根据条件列表获取runnerIdList
      *
@@ -126,6 +134,21 @@ public interface TagentService {
      */
     void deleteTagentMGById(long id);
 
+    /**
+     * 根据id列表删除tagent在mongodb中的数据
+     *
+     * @param idList id列表
+     */
+    void deleteTagentMGByIdList(List<Long> idList);
+
+    /**
+     * 根据id列表删除tagent在mysql中的数据
+     *
+     * @param idList id列表
+     * @param accountIdList 账号id列表
+     */
+    void deleteTagentByIdList(List<Long> idList, List<Long> accountIdList);
+
     /**
      * 跟新tagent所有字段
      *
diff --git a/src/main/java/neatlogic/framework/tagent/service/TagentServiceImpl.java b/src/main/java/neatlogic/framework/tagent/service/TagentServiceImpl.java
index 953a2dc..bbfa0dd 100644
--- a/src/main/java/neatlogic/framework/tagent/service/TagentServiceImpl.java
+++ b/src/main/java/neatlogic/framework/tagent/service/TagentServiceImpl.java
@@ -65,6 +65,7 @@ import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.io.ByteArrayInputStream;
@@ -288,6 +289,21 @@ public class TagentServiceImpl implements TagentService {
         return tagentVo;
     }
 
+    @Override
+    public List<TagentVo> getTagentMGListByIdList(List<Long> idList) {
+        List<TagentVo> tagentList = new ArrayList<>();
+        Query query = new Query();
+        query.addCriteria(Criteria.where("id").in(idList));
+        List<Document> documentList = mongoTemplate.find(query, Document.class, "_tagent_info");
+        if (CollectionUtils.isNotEmpty(documentList)) {
+            for (Document doc : documentList) {
+                TagentVo tagentVo = mapToTagentVo(doc);
+                tagentList.add(tagentVo);
+            }
+        }
+        return tagentList;
+    }
+
     private TagentVo mapToTagentVo(Document doc) {
         TagentVo vo = new TagentVo();
         vo.setId(doc.getLong("id"));
@@ -321,6 +337,21 @@ public class TagentServiceImpl implements TagentService {
         mongoTemplate.getCollection("_tagent_info").findOneAndDelete(whereDoc);
     }
 
+    @Override
+    public void deleteTagentMGByIdList(List<Long> idList) {
+        Query query = new Query();
+        query.addCriteria(Criteria.where("id").in(idList));
+        mongoTemplate.remove(query, "_tagent_info");
+    }
+
+    @Override
+    @Transactional
+    public void deleteTagentByIdList(List<Long> idList, List<Long> accountIdList) {
+        tagentMapper.deleteTagentByIdList(idList);
+        tagentMapper.deleteAllIpByTagentIdList(idList);
+        tagentMapper.deleteAccountByIdList(accountIdList);
+    }
+
     /**
      * 根据tagentId列表获取runnerIdList
      *
-- 
Gitee