1. 修复bugs

master
xueqingkun 5 months ago
parent 9979750f24
commit 7df3c82d6d

@ -355,20 +355,14 @@ public class ModelRecordTypeServiceImpl extends ServiceImpl<ModelRecordTypeMappe
if (ObjectUtil.isNotEmpty(tripleInfo.getRelGraphId())) { if (ObjectUtil.isNotEmpty(tripleInfo.getRelGraphId())) {
// 先移除关系 // 先移除关系
neo4jService.deleteRel(tripleInfo.getRelGraphId()); neo4jService.deleteRel(tripleInfo.getRelGraphId());
} else {
break;
} }
if (ObjectUtil.isNotEmpty(tripleInfo.getEndNodeGraphId())) { if (ObjectUtil.isNotEmpty(tripleInfo.getEndNodeGraphId())) {
// 再移除尾节点 // 再移除尾节点
neo4jService.delNode(tripleInfo.getEndNodeGraphId()); neo4jService.delNode(tripleInfo.getEndNodeGraphId());
} else {
break;
} }
if (ObjectUtil.isNotEmpty(tripleInfo.getStartNodeGraphId())) { if (ObjectUtil.isNotEmpty(tripleInfo.getStartNodeGraphId())) {
// 尝试删除头节点(只有头节点不存在任何关系的时候才进行删除) // 尝试删除头节点(只有头节点不存在任何关系的时候才进行删除)
neo4jService.deleteNoRelationNode(tripleInfo.getStartNodeGraphId()); neo4jService.deleteNoRelationNode(tripleInfo.getStartNodeGraphId());
} else {
break;
} }
// 更新状态 // 更新状态
tripleInfoService.lambdaUpdate().set(TripleInfo::getAddNeo4j, "0") tripleInfoService.lambdaUpdate().set(TripleInfo::getAddNeo4j, "0")

@ -120,7 +120,9 @@ public class TaskRecordServiceImpl extends ServiceImpl<TaskRecordMapper, TaskRec
neo4jService.saveTripleInfo(tripleInfo); neo4jService.saveTripleInfo(tripleInfo);
} }
if (CollUtil.isNotEmpty(tripleInfos)) { if (CollUtil.isNotEmpty(tripleInfos)) {
tripleInfoService.updateNeo4jFlag(tripleInfos.stream().map(TripleInfo::getId).toList(), "1"); for (TripleInfo tripleInfo : tripleInfos) {
tripleInfoService.updateById(tripleInfo);
}
} }
} }

Loading…
Cancel
Save