fix: document deletion bug (#2248)
This commit is contained in:
@ -433,17 +433,17 @@ func (k *knowledgeSVC) DeleteDocument(ctx context.Context, request *DeleteDocume
|
||||
}
|
||||
}
|
||||
|
||||
err = k.documentRepo.DeleteDocuments(ctx, []int64{request.DocumentID})
|
||||
if err != nil {
|
||||
return errorx.New(errno.ErrKnowledgeDBCode, errorx.KV("msg", err.Error()))
|
||||
}
|
||||
|
||||
sliceIDs, err := k.sliceRepo.GetDocumentSliceIDs(ctx, []int64{request.DocumentID})
|
||||
if err != nil {
|
||||
logs.CtxErrorf(ctx, "[DeleteDocument] get document slice ids failed, err: %v", err)
|
||||
return errorx.New(errno.ErrKnowledgeDBCode, errorx.KV("msg", err.Error()))
|
||||
}
|
||||
|
||||
err = k.documentRepo.DeleteDocuments(ctx, []int64{request.DocumentID})
|
||||
if err != nil {
|
||||
return errorx.New(errno.ErrKnowledgeDBCode, errorx.KV("msg", err.Error()))
|
||||
}
|
||||
|
||||
if err = k.emitDeleteKnowledgeDataEvent(ctx, doc.KnowledgeID, sliceIDs, strconv.FormatInt(request.DocumentID, 10)); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user