From c03bdf1a24bb4860e6a278f1f4005c5722563817 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Thu, 5 Feb 2026 03:21:06 +0800
Subject: [PATCH] =?UTF-8?q?refactor(data-management):=20=E7=A7=BB=E9=99=A4?=
 =?UTF-8?q?=E6=9C=AA=E4=BD=BF=E7=94=A8=E7=9A=84=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E6=93=8D=E4=BD=9C=E6=96=B9=E6=B3=95=E5=B9=B6=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=9D=A1=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 从 DatasetFileMapper 中移除未使用的 update 和 deleteById 方法
- 从 DatasetMapper 中移除未使用的 deleteById 方法
- 在 Python 项目中添加 or_ 操作符导入用于复杂查询
- 为数据集文件查询添加状态过滤条件，排除已归档的文件记录
---
 .../persistence/mapper/DatasetFileMapper.java  |  2 --
 .../persistence/mapper/DatasetMapper.java      |  1 -
 .../resources/mappers/DatasetFileMapper.xml    | 18 ------------------
 .../main/resources/mappers/DatasetMapper.xml   |  4 ----
 .../app/module/annotation/interface/project.py |  7 +++++--
 5 files changed, 5 insertions(+), 27 deletions(-)

diff --git a/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetFileMapper.java b/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetFileMapper.java
index 02b44ac..d55c6cc 100644
--- a/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetFileMapper.java
+++ b/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetFileMapper.java
@@ -26,8 +26,6 @@ public interface DatasetFileMapper extends BaseMapper<DatasetFile> {
                                      @Param("status") String status,
                                      RowBounds rowBounds);
 
-    int update(DatasetFile file);
-    int deleteById(@Param("id") String id);
     int updateFilePathPrefix(@Param("datasetId") String datasetId,
                              @Param("oldPrefix") String oldPrefix,
                              @Param("newPrefix") String newPrefix);
diff --git a/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetMapper.java b/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetMapper.java
index 4450511..1590c5d 100644
--- a/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetMapper.java
+++ b/backend/services/data-management-service/src/main/java/com/datamate/datamanagement/infrastructure/persistence/mapper/DatasetMapper.java
@@ -28,6 +28,5 @@ public interface DatasetMapper extends BaseMapper<Dataset> {
                          @Param("keyword") String keyword,
                          @Param("tagNames") List<String> tagNames);
 
-    int deleteById(@Param("id") String id);
     AllDatasetStatisticsResponse getAllDatasetStatistics();
 }
diff --git a/backend/services/data-management-service/src/main/resources/mappers/DatasetFileMapper.xml b/backend/services/data-management-service/src/main/resources/mappers/DatasetFileMapper.xml
index 0b773a2..ef3ccb5 100644
--- a/backend/services/data-management-service/src/main/resources/mappers/DatasetFileMapper.xml
+++ b/backend/services/data-management-service/src/main/resources/mappers/DatasetFileMapper.xml
@@ -97,24 +97,6 @@
     </select>
 
 
-    <update id="update" parameterType="com.datamate.datamanagement.domain.model.dataset.DatasetFile">
-        UPDATE t_dm_dataset_files
-        SET file_name = #{fileName},
-            file_path = #{filePath},
-            logical_path = #{logicalPath},
-            version = #{version},
-            file_type = #{fileType},
-            file_size = #{fileSize},
-            upload_time = #{uploadTime},
-            last_access_time = #{lastAccessTime},
-            status = #{status}
-        WHERE id = #{id}
-    </update>
-
-    <delete id="deleteById" parameterType="string">
-        DELETE FROM t_dm_dataset_files WHERE id = #{id}
-    </delete>
-
     <update id="updateFilePathPrefix">
         UPDATE t_dm_dataset_files
         SET file_path = CONCAT(#{newPrefix}, SUBSTRING(file_path, LENGTH(#{oldPrefix}) + 1))
diff --git a/backend/services/data-management-service/src/main/resources/mappers/DatasetMapper.xml b/backend/services/data-management-service/src/main/resources/mappers/DatasetMapper.xml
index 44021d8..4358745 100644
--- a/backend/services/data-management-service/src/main/resources/mappers/DatasetMapper.xml
+++ b/backend/services/data-management-service/src/main/resources/mappers/DatasetMapper.xml
@@ -139,10 +139,6 @@
         </where>
     </select>
 
-    <delete id="deleteById" parameterType="string">
-        DELETE FROM t_dm_datasets WHERE id = #{id}
-    </delete>
-
     <select id="getAllDatasetStatistics" resultType="com.datamate.datamanagement.interfaces.dto.AllDatasetStatisticsResponse">
       SELECT
         (SELECT COUNT(*) FROM t_dm_datasets) AS total_datasets,
diff --git a/runtime/datamate-python/app/module/annotation/interface/project.py b/runtime/datamate-python/app/module/annotation/interface/project.py
index 4a6a875..44f0159 100644
--- a/runtime/datamate-python/app/module/annotation/interface/project.py
+++ b/runtime/datamate-python/app/module/annotation/interface/project.py
@@ -3,7 +3,7 @@ import math
 import uuid
 
 from fastapi import APIRouter, Depends, HTTPException, Query, Path
-from sqlalchemy import select, update
+from sqlalchemy import select, update, or_
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from app.db.session import get_db
@@ -125,7 +125,10 @@ async def create_mapping(
             )
 
         file_result = await db.execute(
-            select(DatasetFiles).where(DatasetFiles.dataset_id == request.dataset_id)
+            select(DatasetFiles).where(
+                DatasetFiles.dataset_id == request.dataset_id,
+                or_(DatasetFiles.status.is_(None), DatasetFiles.status != "ARCHIVED"),
+            )
         )
         file_records = file_result.scalars().all()
         snapshot_file_ids: list[str] = []