数据归档

src/main/java/com/gaotao/modules/automatedWarehouse/mapper/DataArchiveMapper.java

@@ -0,0 +1,112 @@
+package com.gaotao.modules.automatedWarehouse.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * @Description 数据归档Mapper接口 - rqrq
+ * @Author rqrq
+ * @Date 2025/11/11
+ */
+@Mapper
+public interface DataArchiveMapper {
+
+    /**
+     * @Description 查询倒数第N条记录的ID（通用方法）- rqrq
+     * @param tableName 表名
+     * @param keepCount 保留记录数量
+     * @return 倒数第N条的ID
+     * @author rqrq
+     */
+    Long getThresholdIdByKeepCount(@Param("tableName") String tableName, 
+                                   @Param("keepCount") int keepCount);
+
+    // ========== interface_call_log 归档相关方法 ========== - rqrq
+
+    /**
+     * @Description 插入interface_call_log数据到历史表 - rqrq
+     * @param thresholdId 阈值ID，小于此ID的数据将被归档
+     * @return 插入的记录数
+     * @author rqrq
+     */
+    int insertInterfaceCallLogToHistory(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 删除interface_call_log中小于阈值ID的数据 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 删除的记录数
+     * @author rqrq
+     */
+    int deleteInterfaceCallLogByThresholdId(@Param("thresholdId") Long thresholdId);
+
+    // ========== wcs_callback_pallet_scan 归档相关方法 ========== - rqrq
+
+    /**
+     * @Description 插入wcs_callback_pallet_scan数据到历史表 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 插入的记录数
+     * @author rqrq
+     */
+    int insertWcsCallbackPalletScanToHistory(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 删除wcs_callback_pallet_scan中小于阈值ID的数据 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 删除的记录数
+     * @author rqrq
+     */
+    int deleteWcsCallbackPalletScanByThresholdId(@Param("thresholdId") Long thresholdId);
+
+    // ========== wcs_callback_task 归档相关方法 ========== - rqrq
+
+    /**
+     * @Description 插入wcs_callback_task数据到历史表 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 插入的记录数
+     * @author rqrq
+     */
+    int insertWcsCallbackTaskToHistory(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 删除wcs_callback_task中小于阈值ID的数据 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 删除的记录数
+     * @author rqrq
+     */
+    int deleteWcsCallbackTaskByThresholdId(@Param("thresholdId") Long thresholdId);
+
+    // ========== wms_transport_task 归档相关方法 ========== - rqrq
+
+    /**
+     * @Description 插入wms_transport_task_detail数据到历史表（通过task_no关联主表）- rqrq
+     * @param thresholdId 主表阈值ID
+     * @return 插入的记录数
+     * @author rqrq
+     */
+    int insertWmsTransportTaskDetailToHistory(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 插入wms_transport_task数据到历史表 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 插入的记录数
+     * @author rqrq
+     */
+    int insertWmsTransportTaskToHistory(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 删除wms_transport_task_detail中关联的数据 - rqrq
+     * @param thresholdId 主表阈值ID
+     * @return 删除的记录数
+     * @author rqrq
+     */
+    int deleteWmsTransportTaskDetailByThresholdId(@Param("thresholdId") Long thresholdId);
+
+    /**
+     * @Description 删除wms_transport_task中小于阈值ID的数据 - rqrq
+     * @param thresholdId 阈值ID
+     * @return 删除的记录数
+     * @author rqrq
+     */
+    int deleteWmsTransportTaskByThresholdId(@Param("thresholdId") Long thresholdId);
+}
+

src/main/java/com/gaotao/modules/automatedWarehouse/service/DataArchiveService.java

@@ -0,0 +1,42 @@
+package com.gaotao.modules.automatedWarehouse.service;
+
+/**
+ * @Description 数据归档服务接口 - rqrq
+ * @Author rqrq
+ * @Date 2025/11/11
+ */
+public interface DataArchiveService {
+
+    /**
+     * @Description 归档接口调用日志 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    int archiveInterfaceCallLog(int keepCount);
+
+    /**
+     * @Description 归档WCS回调栈板扫描数据 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    int archiveWcsCallbackPalletScan(int keepCount);
+
+    /**
+     * @Description 归档WCS回调任务数据 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    int archiveWcsCallbackTask(int keepCount);
+
+    /**
+     * @Description 归档WMS运输任务数据（包含主表和明细表）- rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的主表记录数量
+     * @author rqrq
+     */
+    int archiveWmsTransportTask(int keepCount);
+}
+

src/main/java/com/gaotao/modules/automatedWarehouse/service/impl/DataArchiveServiceImpl.java

@@ -0,0 +1,189 @@
+package com.gaotao.modules.automatedWarehouse.service.impl;
+
+import com.gaotao.modules.automatedWarehouse.mapper.DataArchiveMapper;
+import com.gaotao.modules.automatedWarehouse.service.DataArchiveService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @Description 数据归档服务实现类 - rqrq
+ * @Author rqrq
+ * @Date 2025/11/11
+ */
+@Slf4j
+@Service
+public class DataArchiveServiceImpl implements DataArchiveService {
+
+    @Autowired
+    private DataArchiveMapper dataArchiveMapper;
+
+    /**
+     * @Description 归档接口调用日志 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int archiveInterfaceCallLog(int keepCount) {
+        System.out.println("开始归档interface_call_log数据 - rqrq，保留最新" + keepCount + "条");
+
+        try {
+            // 1. 查询倒数第N条的ID - rqrq
+            Long thresholdId = dataArchiveMapper.getThresholdIdByKeepCount("interface_call_log", keepCount);
+
+            if (thresholdId == null) {
+                System.out.println("数据量不足" + keepCount + "条，无需归档 - rqrq");
+                return 0;
+            }
+
+            System.out.println("查询到阈值ID=" + thresholdId + "，将归档小于此ID的数据 - rqrq");
+
+            // 2. 插入到历史表（不带id字段）- rqrq
+            int insertCount = dataArchiveMapper.insertInterfaceCallLogToHistory(thresholdId);
+            System.out.println("已插入" + insertCount + "条数据到interface_call_log_history - rqrq");
+
+            // 3. 删除原表数据 - rqrq
+            int deleteCount = dataArchiveMapper.deleteInterfaceCallLogByThresholdId(thresholdId);
+            System.out.println("已删除" + deleteCount + "条数据从interface_call_log - rqrq");
+
+            System.out.println("interface_call_log归档完成 - rqrq，归档数量=" + deleteCount);
+            return deleteCount;
+
+        } catch (Exception e) {
+            System.out.println("归档interface_call_log失败 - rqrq：" + e.getMessage());
+            throw new RuntimeException("归档interface_call_log失败：" + e.getMessage(), e);
+        }
+    }
+
+    /**
+     * @Description 归档WCS回调栈板扫描数据 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int archiveWcsCallbackPalletScan(int keepCount) {
+        System.out.println("开始归档wcs_callback_pallet_scan数据 - rqrq，保留最新" + keepCount + "条");
+
+        try {
+            // 1. 查询倒数第N条的ID - rqrq
+            Long thresholdId = dataArchiveMapper.getThresholdIdByKeepCount("wcs_callback_pallet_scan", keepCount);
+
+            if (thresholdId == null) {
+                System.out.println("数据量不足" + keepCount + "条，无需归档 - rqrq");
+                return 0;
+            }
+
+            System.out.println("查询到阈值ID=" + thresholdId + "，将归档小于此ID的数据 - rqrq");
+
+            // 2. 插入到历史表（不带id字段）- rqrq
+            int insertCount = dataArchiveMapper.insertWcsCallbackPalletScanToHistory(thresholdId);
+            System.out.println("已插入" + insertCount + "条数据到wcs_callback_pallet_scan_history - rqrq");
+
+            // 3. 删除原表数据 - rqrq
+            int deleteCount = dataArchiveMapper.deleteWcsCallbackPalletScanByThresholdId(thresholdId);
+            System.out.println("已删除" + deleteCount + "条数据从wcs_callback_pallet_scan - rqrq");
+
+            System.out.println("wcs_callback_pallet_scan归档完成 - rqrq，归档数量=" + deleteCount);
+            return deleteCount;
+
+        } catch (Exception e) {
+            System.out.println("归档wcs_callback_pallet_scan失败 - rqrq：" + e.getMessage());
+            throw new RuntimeException("归档wcs_callback_pallet_scan失败：" + e.getMessage(), e);
+        }
+    }
+
+    /**
+     * @Description 归档WCS回调任务数据 - rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的记录数量
+     * @author rqrq
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int archiveWcsCallbackTask(int keepCount) {
+        System.out.println("开始归档wcs_callback_task数据 - rqrq，保留最新" + keepCount + "条");
+
+        try {
+            // 1. 查询倒数第N条的ID - rqrq
+            Long thresholdId = dataArchiveMapper.getThresholdIdByKeepCount("wcs_callback_task", keepCount);
+
+            if (thresholdId == null) {
+                System.out.println("数据量不足" + keepCount + "条，无需归档 - rqrq");
+                return 0;
+            }
+
+            System.out.println("查询到阈值ID=" + thresholdId + "，将归档小于此ID的数据 - rqrq");
+
+            // 2. 插入到历史表（不带id字段）- rqrq
+            int insertCount = dataArchiveMapper.insertWcsCallbackTaskToHistory(thresholdId);
+            System.out.println("已插入" + insertCount + "条数据到wcs_callback_task_history - rqrq");
+
+            // 3. 删除原表数据 - rqrq
+            int deleteCount = dataArchiveMapper.deleteWcsCallbackTaskByThresholdId(thresholdId);
+            System.out.println("已删除" + deleteCount + "条数据从wcs_callback_task - rqrq");
+
+            System.out.println("wcs_callback_task归档完成 - rqrq，归档数量=" + deleteCount);
+            return deleteCount;
+
+        } catch (Exception e) {
+            System.out.println("归档wcs_callback_task失败 - rqrq：" + e.getMessage());
+            throw new RuntimeException("归档wcs_callback_task失败：" + e.getMessage(), e);
+        }
+    }
+
+    /**
+     * @Description 归档WMS运输任务数据（包含主表和明细表）- rqrq
+     * @param keepCount 保留最新记录数量
+     * @return 归档的主表记录数量
+     * @author rqrq
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int archiveWmsTransportTask(int keepCount) {
+        System.out.println("开始归档wms_transport_task及明细数据 - rqrq，保留最新" + keepCount + "条");
+
+        try {
+            // 1. 查询倒数第N条的ID - rqrq
+            Long thresholdId = dataArchiveMapper.getThresholdIdByKeepCount("wms_transport_task", keepCount);
+
+            if (thresholdId == null) {
+                System.out.println("数据量不足" + keepCount + "条，无需归档 - rqrq");
+                return 0;
+            }
+
+            System.out.println("查询到阈值ID=" + thresholdId + "，将归档小于此ID的数据 - rqrq");
+
+            // 2. 先归档明细表 wms_transport_task_detail - rqrq
+            // 2.1 插入明细数据到历史表（根据task_no关联）- rqrq
+            int detailInsertCount = dataArchiveMapper.insertWmsTransportTaskDetailToHistory(thresholdId);
+            System.out.println("已插入" + detailInsertCount + "条数据到wms_transport_task_detail_history - rqrq");
+
+            // 3. 再归档主表 wms_transport_task - rqrq
+            // 3.1 插入主表数据到历史表 - rqrq
+            int taskInsertCount = dataArchiveMapper.insertWmsTransportTaskToHistory(thresholdId);
+            System.out.println("已插入" + taskInsertCount + "条数据到wms_transport_task_history - rqrq");
+
+            // 4. 删除原表数据（先删明细，再删主表）- rqrq
+            // 4.1 删除明细表数据 - rqrq
+            int detailDeleteCount = dataArchiveMapper.deleteWmsTransportTaskDetailByThresholdId(thresholdId);
+            System.out.println("已删除" + detailDeleteCount + "条数据从wms_transport_task_detail - rqrq");
+
+            // 4.2 删除主表数据 - rqrq
+            int taskDeleteCount = dataArchiveMapper.deleteWmsTransportTaskByThresholdId(thresholdId);
+            System.out.println("已删除" + taskDeleteCount + "条数据从wms_transport_task - rqrq");
+
+            System.out.println("wms_transport_task及明细归档完成 - rqrq，归档任务数=" + taskDeleteCount + "，明细数=" + detailDeleteCount);
+            return taskDeleteCount;
+
+        } catch (Exception e) {
+            System.out.println("归档wms_transport_task失败 - rqrq：" + e.getMessage());
+            throw new RuntimeException("归档wms_transport_task失败：" + e.getMessage(), e);
+        }
+    }
+}
+

src/main/java/com/gaotao/modules/automatedWarehouse/task/DataArchiveScheduler.java

@@ -0,0 +1,146 @@
+package com.gaotao.modules.automatedWarehouse.task;
+
+import com.gaotao.modules.automatedWarehouse.service.DataArchiveService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description 数据归档定时任务类 - rqrq
+ * @Author rqrq
+ * @Date 2025/11/11
+ * 
+ * 功能说明：
+ * 1. 将历史数据定期归档到历史表，防止主表数据过多导致查询效率降低
+ * 2. 所有定时任务统一在每天晚上11:30执行
+ * 3. 通过配置文件控制定时任务的执行时间和开关
+ */
+@Slf4j
+@Component
+public class DataArchiveScheduler {
+
+    @Autowired
+    private DataArchiveService dataArchiveService;
+
+    /**
+     * 数据归档任务开关 - rqrq
+     */
+    @Value("${scheduler.dataArchive.enabled:false}")
+    private boolean enabled;
+
+    /**
+     * @Description 定时任务：归档接口调用日志 - rqrq
+     * @Title archiveInterfaceCallLog
+     * @author rqrq
+     * @date 2025/11/11
+     * 
+     * 业务逻辑：
+     * 1. 保留interface_call_log表中ID最大的2000条记录
+     * 2. 将多余的数据转移到interface_call_log_history表
+     * 3. 删除interface_call_log表中的多余数据
+     */
+    @Scheduled(cron = "${scheduler.dataArchive.interfaceCallLog.cron:0 30 23 * * ?}")
+    public void archiveInterfaceCallLog() {
+        // 检查定时任务开关 - rqrq
+        if (!enabled) {
+            return;
+        }
+
+        log.info("=== 开始归档接口调用日志数据 - rqrq ===");
+
+        try {
+            int archivedCount = dataArchiveService.archiveInterfaceCallLog(2000);
+            log.info("=== 接口调用日志归档完成 - rqrq：归档数量={} ===", archivedCount);
+        } catch (Exception e) {
+            log.error("=== 接口调用日志归档失败 - rqrq ===", e);
+        }
+    }
+
+    /**
+     * @Description 定时任务：归档WCS回调栈板扫描数据 - rqrq
+     * @Title archiveWcsCallbackPalletScan
+     * @author rqrq
+     * @date 2025/11/11
+     * 
+     * 业务逻辑：
+     * 1. 保留wcs_callback_pallet_scan表中ID最大的2000条记录
+     * 2. 将多余的数据转移到wcs_callback_pallet_scan_history表
+     * 3. 删除wcs_callback_pallet_scan表中的多余数据
+     */
+    @Scheduled(cron = "${scheduler.dataArchive.wcsCallbackPalletScan.cron:0 30 23 * * ?}")
+    public void archiveWcsCallbackPalletScan() {
+        // 检查定时任务开关 - rqrq
+        if (!enabled) {
+            return;
+        }
+
+        log.info("=== 开始归档WCS回调栈板扫描数据 - rqrq ===");
+
+        try {
+            int archivedCount = dataArchiveService.archiveWcsCallbackPalletScan(2000);
+            log.info("=== WCS回调栈板扫描数据归档完成 - rqrq：归档数量={} ===", archivedCount);
+        } catch (Exception e) {
+            log.error("=== WCS回调栈板扫描数据归档失败 - rqrq ===", e);
+        }
+    }
+
+    /**
+     * @Description 定时任务：归档WCS回调任务数据 - rqrq
+     * @Title archiveWcsCallbackTask
+     * @author rqrq
+     * @date 2025/11/11
+     * 
+     * 业务逻辑：
+     * 1. 保留wcs_callback_task表中ID最大的2000条记录
+     * 2. 将多余的数据转移到wcs_callback_task_history表
+     * 3. 删除wcs_callback_task表中的多余数据
+     */
+    @Scheduled(cron = "${scheduler.dataArchive.wcsCallbackTask.cron:0 30 23 * * ?}")
+    public void archiveWcsCallbackTask() {
+        // 检查定时任务开关 - rqrq
+        if (!enabled) {
+            return;
+        }
+
+        log.info("=== 开始归档WCS回调任务数据 - rqrq ===");
+
+        try {
+            int archivedCount = dataArchiveService.archiveWcsCallbackTask(2000);
+            log.info("=== WCS回调任务数据归档完成 - rqrq：归档数量={} ===", archivedCount);
+        } catch (Exception e) {
+            log.error("=== WCS回调任务数据归档失败 - rqrq ===", e);
+        }
+    }
+
+    /**
+     * @Description 定时任务：归档WMS运输任务数据 - rqrq
+     * @Title archiveWmsTransportTask
+     * @author rqrq
+     * @date 2025/11/11
+     * 
+     * 业务逻辑：
+     * 1. 保留wms_transport_task表中ID最大的2000条记录
+     * 2. 根据task_no关联，先转移wms_transport_task_detail到历史表
+     * 3. 再转移wms_transport_task到历史表
+     * 4. 删除原表中的多余数据（先删detail，再删主表）
+     */
+    @Scheduled(cron = "${scheduler.dataArchive.wmsTransportTask.cron:0 30 23 * * ?}")
+    public void archiveWmsTransportTask() {
+        // 检查定时任务开关 - rqrq
+        if (!enabled) {
+            return;
+        }
+
+        log.info("=== 开始归档WMS运输任务数据 - rqrq ===");
+
+        try {
+            int archivedCount = dataArchiveService.archiveWmsTransportTask(2000);
+            log.info("=== WMS运输任务数据归档完成 - rqrq：归档任务数量={} ===", archivedCount);
+        } catch (Exception e) {
+            log.error("=== WMS运输任务数据归档失败 - rqrq ===", e);
+        }
+    }
+}
+

src/main/resources/mapper/automatedWarehouse/DataArchiveMapper.xml

@@ -0,0 +1,148 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.gaotao.modules.automatedWarehouse.mapper.DataArchiveMapper">
+
+    <!-- rqrq - 查询倒数第N条记录的ID（通用方法）-->
+    <select id="getThresholdIdByKeepCount" resultType="java.lang.Long">
+        SELECT id 
+        FROM ${tableName} WITH (NOLOCK)
+        ORDER BY id DESC 
+        OFFSET #{keepCount} ROWS 
+        FETCH NEXT 1 ROWS ONLY
+    </select>
+
+    <!-- ========== interface_call_log 归档相关SQL ========== rqrq -->
+
+    <!-- rqrq - 插入interface_call_log数据到历史表（不包含id字段）-->
+    <insert id="insertInterfaceCallLogToHistory">
+        INSERT INTO interface_call_log_history (
+            interface_name, method_name, request_data, response_data, 
+            status, error_message, execution_time, site, business_key, 
+            created_time, created_by, remark
+        )
+        SELECT 
+            interface_name, method_name, request_data, response_data, 
+            status, error_message, execution_time, site, business_key, 
+            created_time, created_by, remark
+        FROM interface_call_log WITH (NOLOCK)
+        WHERE id &lt; #{thresholdId}
+    </insert>
+
+    <!-- rqrq - 删除interface_call_log中小于阈值ID的数据 -->
+    <delete id="deleteInterfaceCallLogByThresholdId">
+        DELETE FROM interface_call_log 
+        WHERE id &lt; #{thresholdId}
+    </delete>
+
+    <!-- ========== wcs_callback_pallet_scan 归档相关SQL ========== rqrq -->
+
+    <!-- rqrq - 插入wcs_callback_pallet_scan数据到历史表（不包含id字段）-->
+    <insert id="insertWcsCallbackPalletScanToHistory">
+        INSERT INTO wcs_callback_pallet_scan_history (
+            site, pallet_id, task_no, item_no, wcs_scan_time, 
+            wcs_barcode_list, wcs_total_quantity, sore_type, process_status, 
+            process_time, error_msg, retry_count, created_at, 
+            updated_at, json_str, action_type
+        )
+        SELECT 
+            site, pallet_id, task_no, item_no, wcs_scan_time, 
+            wcs_barcode_list, wcs_total_quantity, sore_type, process_status, 
+            process_time, error_msg, retry_count, created_at, 
+            updated_at, json_str, action_type
+        FROM wcs_callback_pallet_scan WITH (NOLOCK)
+        WHERE id &lt; #{thresholdId}
+    </insert>
+
+    <!-- rqrq - 删除wcs_callback_pallet_scan中小于阈值ID的数据 -->
+    <delete id="deleteWcsCallbackPalletScanByThresholdId">
+        DELETE FROM wcs_callback_pallet_scan 
+        WHERE id &lt; #{thresholdId}
+    </delete>
+
+    <!-- ========== wcs_callback_task 归档相关SQL ========== rqrq -->
+
+    <!-- rqrq - 插入wcs_callback_task数据到历史表（不包含id字段）-->
+    <insert id="insertWcsCallbackTaskToHistory">
+        INSERT INTO wcs_callback_task_history (
+            site, pallet_id, trans_type_desc, to_warehouse_id, 
+            to_location_id, status, created_time, process_start_time, 
+            process_end_time, error_msg, retry_count, remark, 
+            task_no, item_no, to_station
+        )
+        SELECT 
+            site, pallet_id, trans_type_desc, to_warehouse_id, 
+            to_location_id, status, created_time, process_start_time, 
+            process_end_time, error_msg, retry_count, remark, 
+            task_no, item_no, to_station
+        FROM wcs_callback_task WITH (NOLOCK)
+        WHERE id &lt; #{thresholdId}
+    </insert>
+
+    <!-- rqrq - 删除wcs_callback_task中小于阈值ID的数据 -->
+    <delete id="deleteWcsCallbackTaskByThresholdId">
+        DELETE FROM wcs_callback_task 
+        WHERE id &lt; #{thresholdId}
+    </delete>
+
+    <!-- ========== wms_transport_task 归档相关SQL ========== rqrq -->
+
+    <!-- rqrq - 插入wms_transport_task_detail数据到历史表（通过task_no关联主表，不包含id字段）-->
+    <insert id="insertWmsTransportTaskDetailToHistory">
+        INSERT INTO wms_transport_task_detail_history (
+            site, task_no, item_no, seq_no, action_type, comment, 
+            from_location, to_location, agv_code, status, 
+            start_time, complete_time, error_code, error_msg
+        )
+        SELECT 
+            d.site, d.task_no, d.item_no, d.seq_no, d.action_type, d.comment, 
+            d.from_location, d.to_location, d.agv_code, d.status, 
+            d.start_time, d.complete_time, d.error_code, d.error_msg
+        FROM wms_transport_task_detail d WITH (NOLOCK)
+        WHERE d.task_no IN (
+            SELECT task_no 
+            FROM wms_transport_task WITH (NOLOCK)
+            WHERE id &lt; #{thresholdId}
+        )
+    </insert>
+
+    <!-- rqrq - 插入wms_transport_task数据到历史表（不包含id字段）-->
+    <insert id="insertWmsTransportTaskToHistory">
+        INSERT INTO wms_transport_task_history (
+            site, task_no, item_no, source_type, source_bill_no, 
+            source_line_id, part_no, qty, batch_no, serial_no, 
+            from_location, to_location, pallet_id, agv_code, priority, 
+            status, wms_send_time, wcs_receive_time, start_time, 
+            complete_time, error_code, error_msg, created_by, 
+            created_time, updated_time, wcs_task_id, finish_qty, 
+            wms_status, pallet_type, to_area
+        )
+        SELECT 
+            site, task_no, item_no, source_type, source_bill_no, 
+            source_line_id, part_no, qty, batch_no, serial_no, 
+            from_location, to_location, pallet_id, agv_code, priority, 
+            status, wms_send_time, wcs_receive_time, start_time, 
+            complete_time, error_code, error_msg, created_by, 
+            created_time, updated_time, wcs_task_id, finish_qty, 
+            wms_status, pallet_type, to_area
+        FROM wms_transport_task WITH (NOLOCK)
+        WHERE id &lt; #{thresholdId}
+    </insert>
+
+    <!-- rqrq - 删除wms_transport_task_detail中关联的数据 -->
+    <delete id="deleteWmsTransportTaskDetailByThresholdId">
+        DELETE FROM wms_transport_task_detail 
+        WHERE task_no IN (
+            SELECT task_no 
+            FROM wms_transport_task WITH (NOLOCK)
+            WHERE id &lt; #{thresholdId}
+        )
+    </delete>
+
+    <!-- rqrq - 删除wms_transport_task中小于阈值ID的数据 -->
+    <delete id="deleteWmsTransportTaskByThresholdId">
+        DELETE FROM wms_transport_task 
+        WHERE id &lt; #{thresholdId}
+    </delete>
+
+</mapper>
+