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);
+            }
         }
     }