796cf49ff9
- Evotor catalog: background Celery task syncing stores/groups/products from Evotor API; UI pages with per-store and per-group sync toggles - VK connection: manual token + group ID entry with inline test button - Evotor connection: inline test button (calls /stores) - VK catalog: background task syncing VK Market albums and products; separate catalog UI at /vk-catalog/albums - SyncFilter extended to support entity_type=group with parent_entity_id - Migration 0004: vk_cached_albums + vk_cached_products tables - Beat schedule updated to run both refresh_catalog and refresh_vk_catalog - README updated with new schema, routes, tasks, and config Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
64 lines
2.1 KiB
Python
64 lines
2.1 KiB
Python
from fastapi import APIRouter, Depends, Request
|
|
from fastapi.responses import HTMLResponse, RedirectResponse
|
|
from sqlalchemy.orm import Session
|
|
|
|
from web.auth.session import get_current_user
|
|
from web.config import settings
|
|
from web.database import get_db
|
|
from web.models.connections import VkCachedAlbum, VkCachedProduct, VkConnection
|
|
from web.templates_env import templates
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
def _render(request: Request, template: str, ctx: dict) -> HTMLResponse:
|
|
ctx["request"] = request
|
|
ctx.setdefault("jivosite_widget_id", settings.JIVOSITE_WIDGET_ID)
|
|
return templates.TemplateResponse(ctx.pop("request"), template, ctx)
|
|
|
|
|
|
@router.get("/vk-catalog/albums")
|
|
async def vk_catalog_albums(request: Request, db: Session = Depends(get_db)):
|
|
try:
|
|
user = get_current_user(request, db)
|
|
except Exception:
|
|
return RedirectResponse("/login", 303)
|
|
|
|
vk_conn = db.query(VkConnection).filter_by(user_id=user.id).first()
|
|
albums = (
|
|
db.query(VkCachedAlbum)
|
|
.filter(VkCachedAlbum.user_id == user.id)
|
|
.order_by(VkCachedAlbum.title)
|
|
.all()
|
|
)
|
|
return _render(request, "vk_catalog/albums.html", {
|
|
"user": user,
|
|
"albums": albums,
|
|
"vk_conn": vk_conn,
|
|
"refresh_interval": settings.CATALOG_REFRESH_INTERVAL_SECONDS,
|
|
})
|
|
|
|
|
|
@router.get("/vk-catalog/albums/{album_id}/products")
|
|
async def vk_catalog_products(album_id: str, request: Request, db: Session = Depends(get_db)):
|
|
try:
|
|
user = get_current_user(request, db)
|
|
except Exception:
|
|
return RedirectResponse("/login", 303)
|
|
|
|
album = db.query(VkCachedAlbum).filter_by(user_id=user.id, album_id=album_id).first()
|
|
if not album:
|
|
return RedirectResponse("/vk-catalog/albums", 303)
|
|
|
|
products = (
|
|
db.query(VkCachedProduct)
|
|
.filter(VkCachedProduct.user_id == user.id, VkCachedProduct.album_id == album_id)
|
|
.order_by(VkCachedProduct.name)
|
|
.all()
|
|
)
|
|
return _render(request, "vk_catalog/products.html", {
|
|
"user": user,
|
|
"album": album,
|
|
"products": products,
|
|
})
|