async def get_entity_id(
    business_id: str,
    product_id: Optional[str] = None
) -> Optional[str]

async def get_business_info(
    business_id: str,
    product_id: Optional[str] = None
) -> dict

{
    "business_name": "...",
    "business_url": "...",
    "product_name": "..."  # Only if product_id provided
}

async def update_prompt_visibility(
    entity_id: str,
    prompt: str,
    visibility_results: dict
) -> bool

async def batch_update_visibility_results(
    entity_id: str,
    results: list[dict]
) -> int

async def update_visibility_scores(
    business_id: str,
    product_id: Optional[str],
    platform_scores: dict,
    overall_score: int,
    total_queries: int,
    total_visible: int
) -> None

async def get_visibility_results_from_db(
    business_id: str,
    product_id: Optional[str] = None,
    limit: int = 100
) -> list[dict]

async def get_visibility_trends_from_db(
    business_id: str,
    product_id: Optional[str] = None,
    days: int = 30
) -> list[dict]

src/app/apis/cron/analyze_visibility/database_operations.py