30 lines
986 B
Python
30 lines
986 B
Python
from fastapi import HTTPException
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from repositories import DealRepository
|
|
from schemas.deal import (
|
|
GetDealsResponse,
|
|
DealSchema,
|
|
UpdateDealResponse,
|
|
UpdateDealRequest,
|
|
)
|
|
|
|
|
|
class DealService:
|
|
def __init__(self, session: AsyncSession):
|
|
self.repository = DealRepository(session)
|
|
|
|
async def get_deals(self, board_id: int) -> GetDealsResponse:
|
|
deals = await self.repository.get_all(board_id)
|
|
return GetDealsResponse(
|
|
deals=[DealSchema.model_validate(deal) for deal in deals]
|
|
)
|
|
|
|
async def update_deal(self, deal_id: int, request: UpdateDealRequest):
|
|
deal = await self.repository.get_by_id(deal_id)
|
|
if not deal:
|
|
raise HTTPException(status_code=404, detail="Сделка не найдена")
|
|
|
|
await self.repository.update(deal, request.deal)
|
|
return UpdateDealResponse(message="Сделка успешно обновлена")
|