From 7df3c82d6dca47dbd4176b3dedf0ad0987401613 Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Tue, 7 Jan 2025 14:52:22 +0800
Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E5=A4=8Dbugs?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../police/service/impl/ModelRecordTypeServiceImpl.java     | 6 ------
 .../police/service/impl/TaskRecordServiceImpl.java          | 4 +++-
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/supervision/police/service/impl/ModelRecordTypeServiceImpl.java b/src/main/java/com/supervision/police/service/impl/ModelRecordTypeServiceImpl.java
index aeb7062..e586237 100644
--- a/src/main/java/com/supervision/police/service/impl/ModelRecordTypeServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/ModelRecordTypeServiceImpl.java
@@ -355,20 +355,14 @@ public class ModelRecordTypeServiceImpl extends ServiceImpl<ModelRecordTypeMappe
             if (ObjectUtil.isNotEmpty(tripleInfo.getRelGraphId())) {
                 // 先移除关系
                 neo4jService.deleteRel(tripleInfo.getRelGraphId());
-            } else {
-                break;
             }
             if (ObjectUtil.isNotEmpty(tripleInfo.getEndNodeGraphId())) {
                 // 再移除尾节点
                 neo4jService.delNode(tripleInfo.getEndNodeGraphId());
-            } else {
-                break;
             }
             if (ObjectUtil.isNotEmpty(tripleInfo.getStartNodeGraphId())) {
                 // 尝试删除头节点(只有头节点不存在任何关系的时候才进行删除)
                 neo4jService.deleteNoRelationNode(tripleInfo.getStartNodeGraphId());
-            } else {
-                break;
             }
             // 更新状态
             tripleInfoService.lambdaUpdate().set(TripleInfo::getAddNeo4j, "0")
diff --git a/src/main/java/com/supervision/police/service/impl/TaskRecordServiceImpl.java b/src/main/java/com/supervision/police/service/impl/TaskRecordServiceImpl.java
index ae723d6..6df2615 100644
--- a/src/main/java/com/supervision/police/service/impl/TaskRecordServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/TaskRecordServiceImpl.java
@@ -120,7 +120,9 @@ public class TaskRecordServiceImpl extends ServiceImpl<TaskRecordMapper, TaskRec
             neo4jService.saveTripleInfo(tripleInfo);
         }
         if (CollUtil.isNotEmpty(tripleInfos)) {
-            tripleInfoService.updateNeo4jFlag(tripleInfos.stream().map(TripleInfo::getId).toList(), "1");
+            for (TripleInfo tripleInfo : tripleInfos) {
+                tripleInfoService.updateById(tripleInfo);
+            }
         }
     }