Method apply_files_policy_action

apps/admin/services.py:366–435

(
        self,
        file_ids: list[int],
        action: str,
        download_limit: Optional[int] = None,
    )

        }

    async def apply_files_policy_action(
        self,
        file_ids: list[int],
        action: str,
        download_limit: Optional[int] = None,
    ) -> dict[str, Any]:
        unique_ids = list(dict.fromkeys(file_ids))
        updated = []
        failed = []
        missing = []
        action = action.strip().lower()

        if action not in self.POLICY_ACTIONS:
            raise HTTPException(status_code=400, detail="不支持的策略动作")

        if action == "reset_download_limit":
            next_limit = download_limit if download_limit is not None else 5
            if next_limit < 1:
                raise HTTPException(status_code=400, detail="取件次数必须大于 0")

        now = await get_now()
        for file_id in unique_ids:
            file_code = await FileCodes.filter(id=file_id).first()
            if not file_code:
                missing.append(file_id)
                continue

            try:
                update_data = self._build_policy_action_update(
                    file_code=file_code,
                    action=action,
                    now=now,
                    download_limit=download_limit,
                )
                await file_code.update_from_dict(update_data).save()
                updated.append(file_id)
            except Exception as exc:
                failed.append({"id": file_id, "reason": str(exc)})

        if updated:
            await self.record_admin_activity(
                action="files.batch_policy_action",
                target_type="file",
                count=len(updated),
                meta={
                    "policyAction": action,
                    "requestedCount": len(file_ids),
                    "uniqueCount": len(unique_ids),
                    "updated": updated,
                    "missing": missing,
                    "failedCount": len(failed),
                },
            )

        return {
            "requestedCount": len(file_ids),
            "requested_count": len(file_ids),
            "uniqueCount": len(unique_ids),