清理数据接口修改

qixiaoning

20 小时以前 03880bf61cf059f063e252ef17dfea50c932c9dc

 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

}