fix: 知识库文档删除，知识库状态变更

src/main/java/cn/com/poc/knowledge/aggregate/impl/KnowledgeServiceImpl.java

@@ -140,15 +140,18 @@ public class KnowledgeServiceImpl implements KnowledgeService {
         }.getType());
         List<KnowledgeQueryItem> knowledgeQueryItems = bizKnowledgeDocumentService.searchKnowledge(null, null, bizKnowledgeInfoEntity.getMemberId(), null, kdIdList, null);
         boolean isCompleted = true;
-        for (KnowledgeQueryItem knowledgeQueryItem : knowledgeQueryItems) {
-            if (!KnowledgeConstant.TrainStatus.COMPLETE.equals(knowledgeQueryItem.getTrainStatus())) {
-                isCompleted = false;
-                break;
+        String lock = knowledgeInfoId.toString().intern();
+        synchronized (lock) {
+            for (KnowledgeQueryItem knowledgeQueryItem : knowledgeQueryItems) {
+                if (!KnowledgeConstant.TrainStatus.COMPLETE.equals(knowledgeQueryItem.getTrainStatus())) {
+                    isCompleted = false;
+                    break;
+                }
+            }
+            if (isCompleted) {
+                bizKnowledgeInfoEntity.setTrainStatus(KnowledgeConstant.TrainStatus.COMPLETE);
+                bizKnowledgeInfoService.update(bizKnowledgeInfoEntity);
             }
-        }
-        if (isCompleted) {
-            bizKnowledgeInfoEntity.setTrainStatus(KnowledgeConstant.TrainStatus.COMPLETE);
-            bizKnowledgeInfoService.update(bizKnowledgeInfoEntity);
         }
         return true;
     }
@@ -218,10 +221,9 @@ public class KnowledgeServiceImpl implements KnowledgeService {
             }.getType());
             kdIds.addAll(kdIdList);
         }
-        knowledgeInfoEntity.setKdIds(JsonUtils.serialize(kdIds));
         knowledgeInfoEntity.setId(knowledgeInfoId);
         knowledgeInfoEntity.setTrainStatus(KnowledgeConstant.TrainStatus.TRAINING);
-        knowledgeInfoEntity.setKdIds(JsonUtils.serialize(kdIds));
+        knowledgeInfoEntity.setKdIds(JsonUtils.serialize(kdIds.stream().distinct().collect(Collectors.toList())));
         bizKnowledgeInfoService.update(knowledgeInfoEntity);
         return true;
     }