From 03880bf61cf059f063e252ef17dfea50c932c9dc Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期三, 12 十一月 2025 09:11:03 +0800
Subject: [PATCH] 清理数据接口修改
---
camera-common/models/Record.go | 27 +++++++++++++--------------
1 files changed, 13 insertions(+), 14 deletions(-)
diff --git a/camera-common/models/Record.go b/camera-common/models/Record.go
index a72bfe1..0cbc697 100644
--- a/camera-common/models/Record.go
+++ b/camera-common/models/Record.go
@@ -220,6 +220,10 @@
// client.WithOffset(offset),
)
+ if err != nil {
+
+ }
+
// 2. 鎻愬彇ID鍜屾枃浠惰矾寰�
var ids []int64
var imgPaths []string
@@ -256,38 +260,29 @@
VideoPath := VideoPathColumn[i]
videoPaths = append(videoPaths, VideoPath)
}
-
}
}
}
-
+ // 鍥剧墖鍒犻櫎鏂囦欢
+ deletedFiles := 0
if len(ids) > 0 {
idField := entity.NewColumnInt64("id", ids)
err = do.client.client.DeleteByPks(ctx, collectionName, "", idField)
if err != nil {
return 0, fmt.Errorf("failed to delete from Milvus: %v", err)
}
- err = do.client.client.DeleteByPks(ctx, "smartrag", "", idField)
- if err != nil {
- return 0, fmt.Errorf("failed to delete from Milvus: %v", err)
- }
+ deletedFiles = len(ids)
}
- // 鍥剧墖鍒犻櫎鏂囦欢
- deletedFiles := 0
for _, path := range imgPaths {
if err := do.deleteFile(path); err != nil {
logger.Debug("failed to delete file " + path + " " + err.Error())
- } else {
- deletedFiles++
}
}
//鍒犻櫎鎻忚堪鍥剧墖
for _, path := range imgDesPaths {
if err := do.deleteFile(path); err != nil {
logger.Debug("failed to delete file " + path + " " + err.Error())
- } else {
- deletedFiles++
}
}
@@ -295,11 +290,15 @@
for _, path := range videoPaths {
if err := do.deleteFile(path); err != nil {
logger.Debug("failed to delete file " + path + " " + err.Error())
- } else {
- deletedFiles++
}
}
+ //鍒犻櫎rag
+ err = do.client.client.Delete(ctx, "smartrag", "", filterExpr)
+ if err != nil {
+ logger.Debug("delete rag failed!")
+ }
+
return deletedFiles, err
}
--
Gitblit v1.8.0