Method scan_and_sync_task_images

backend/services/history.py:552–642

扫描任务文件夹，同步图片列表 根据实际生成的图片数量自动更新记录状态： - 无图片 -> draft（草稿） - 部分图片 -> partial（部分完成） - 全部图片 -> completed（已完成） Args: task_id: 任务 ID Returns: Dict[str, Any]: 扫描结果 - success: 是否成功 - record_id:

(self, task_id: str)

        }

    def scan_and_sync_task_images(self, task_id: str) -> Dict[str, Any]:
        """
        扫描任务文件夹，同步图片列表

        根据实际生成的图片数量自动更新记录状态：
        - 无图片 -> draft（草稿）
        - 部分图片 -> partial（部分完成）
        - 全部图片 -> completed（已完成）

        Args:
            task_id: 任务 ID

        Returns:
            Dict[str, Any]: 扫描结果
                - success: 是否成功
                - record_id: 关联的记录 ID
                - task_id: 任务 ID
                - images_count: 图片数量
                - images: 图片文件名列表
                - status: 更新后的状态
                - error: 错误信息（失败时）
        """
        task_dir = os.path.join(self.history_dir, task_id)

        if not os.path.exists(task_dir) or not os.path.isdir(task_dir):
            return {
                "success": False,
                "error": f"任务目录不存在: {task_id}"
            }

        try:
            files_by_index = HistoryImageMerger.files_by_index(self.history_dir, task_id)
            image_files = list(files_by_index.values())

            # 查找关联的历史记录
            index = self._load_index()
            record_id = None
            for rec in index.get("records", []):
                # 通过遍历所有记录，找到 task_id 匹配的记录
                record_detail = self.get_record(rec["id"])
                if record_detail and record_detail.get("images", {}).get("task_id") == task_id:
                    record_id = rec["id"]
                    break

            if record_id:
                # 更新历史记录
                record = self.get_record(record_id)
                if record:
                    expected_count = len(record.get("outline", {}).get("pages", []))
                    existing_generated = record.get("images", {}).get("generated", [])
                    merged_images = HistoryImageMerger.merge_many(
                        existing_generated,
                        files_by_index,
                        expected_count,
                    )
                    status = HistoryImageMerger.compute_status(merged_images, expected_count)

                    # 更新图片列表和状态