Compare commits

..

No commits in common. "15477cf6cedf20b0d8b52938dc36f70355e92869" and "18ec053e445fe445e50ad6658ecf40d8e7bce793" have entirely different histories.

5 changed files with 6 additions and 55 deletions

View File

@ -2,7 +2,6 @@
from fastapi import APIRouter, Depends, HTTPException, status from fastapi import APIRouter, Depends, HTTPException, status
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from src.db.models.form_type import FormTypeEnum
from src.services.expense_item_service import ExpenseItemService from src.services.expense_item_service import ExpenseItemService
from src.db.models.app_user import AppUser from src.db.models.app_user import AppUser
from src.api.v1.deps import require_admin, require_executor from src.api.v1.deps import require_admin, require_executor
@ -42,18 +41,10 @@ async def get_expense_item_by_id(
db: AsyncSession = Depends(get_db), db: AsyncSession = Depends(get_db),
current_user: AppUser = Depends(require_executor), current_user: AppUser = Depends(require_executor),
r_start: bool | None = None, r_start: bool | None = None,
sheet: str | None = None,
direction: str | None = None,
form_type: FormTypeEnum | str | None = None
): ):
"""Получение записей expense item""" """Получение записей expense item"""
service = ExpenseItemService(db) service = ExpenseItemService(db)
result = await service.get_list( result = await service.get_list(r_start=r_start)
r_start=r_start,
sheet=sheet,
direction=direction,
form_type=form_type,
)
return BaseListResponse( return BaseListResponse(
success=True, success=True,

View File

@ -9,7 +9,7 @@ from src.db.models.ckk import Ckk
from src.db.models.collegial_approval import CollegialApproval from src.db.models.collegial_approval import CollegialApproval
from src.db.models.contract_detail import ContractDetail from src.db.models.contract_detail import ContractDetail
from src.db.models.contract_summary import ContractSummary from src.db.models.contract_summary import ContractSummary
from src.db.models.expense_item import ExpenseItem, ExpenseItemFormType from src.db.models.expense_item import ExpenseItem
from src.db.models.form3_phase import Form3Phase from src.db.models.form3_phase import Form3Phase
from src.db.models.form_limit import FormLimit from src.db.models.form_limit import FormLimit
from src.db.models.form_phase import FormPhase from src.db.models.form_phase import FormPhase

View File

@ -25,12 +25,3 @@ class ExpenseItem(Base):
direction: Mapped[str | None] = mapped_column(String) direction: Mapped[str | None] = mapped_column(String)
parent_id: Mapped[int | None] = mapped_column(Integer, ForeignKey("v3.expense_item.id")) parent_id: Mapped[int | None] = mapped_column(Integer, ForeignKey("v3.expense_item.id"))
depth: Mapped[int | None] = mapped_column(Integer, default=0) depth: Mapped[int | None] = mapped_column(Integer, default=0)
class ExpenseItemFormType(Base):
__tablename__ = "expense_item_form_type"
__table_args__ = {"schema": "v3"}
form_type_code: Mapped[str] = mapped_column(String, primary_key=True)
expense_item_id: Mapped[int] = mapped_column(Integer, ForeignKey("v3.expense_item.id"), primary_key=True)

View File

@ -1,8 +1,7 @@
from sqlalchemy import select from sqlalchemy import select
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from src.db.models.form_type import FormTypeEnum from src.db.models.expense_item import ExpenseItem
from src.db.models.expense_item import ExpenseItem, ExpenseItemFormType
class ExpenseItemRepository: class ExpenseItemRepository:
@ -13,31 +12,10 @@ class ExpenseItemRepository:
query = select(ExpenseItem).where(ExpenseItem.id == item_id).limit(1) query = select(ExpenseItem).where(ExpenseItem.id == item_id).limit(1)
return (await self.db.execute(query)).scalar_one_or_none() return (await self.db.execute(query)).scalar_one_or_none()
async def get_list( async def get_list(self, r_start: bool | None = None) -> list[ExpenseItem]:
self,
r_start: bool | None = None,
sheet: str | None = None,
direction: str | None = None,
form_type: FormTypeEnum | str | None = None,
) -> list[ExpenseItem]:
where = [] where = []
query = select(ExpenseItem)
if form_type is not None:
query = query.join(
ExpenseItemFormType,
ExpenseItemFormType.expense_item_id == ExpenseItem.id,
).where(
ExpenseItemFormType.form_type_code == (form_type.value if isinstance(form_type, FormTypeEnum) else form_type)
)
if r_start is not None: if r_start is not None:
where.append(ExpenseItem.item_id.startswith("R")) where.append(ExpenseItem.item_id.startswith("R"))
if sheet is not None:
where.append(ExpenseItem.sheet == sheet)
if direction is not None:
where.append(ExpenseItem.direction == direction)
query = query.where(*where)
query = select(ExpenseItem).where(*where)
return (await self.db.execute(query)).scalars().all() return (await self.db.execute(query)).scalars().all()

View File

@ -1,6 +1,5 @@
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from src.db.models.form_type import FormTypeEnum
from src.db.models.role import UserRoleEnum from src.db.models.role import UserRoleEnum
from src.db.models.app_user import AppUser from src.db.models.app_user import AppUser
from src.db.models.expense_item import ExpenseItem from src.db.models.expense_item import ExpenseItem
@ -23,13 +22,5 @@ class ExpenseItemService:
async def get_list( async def get_list(
self, self,
r_start: bool | None = None, r_start: bool | None = None,
sheet: str | None = None,
direction: str | None = None,
form_type: FormTypeEnum | str | None = None,
) -> list[ExpenseItem]: ) -> list[ExpenseItem]:
return await self.repo.get_list( return await self.repo.get_list(r_start=r_start)
r_start=r_start,
sheet=sheet,
direction=direction,
form_type=form_type,
)