alien_py_cloud/alien_store/services/contract_server.py

from sqlalchemy.ext.asyncio import AsyncSession
from alien_store.repositories.contract_repo import ContractRepository
from alien_store.schemas.request.contract_store import TemplatesCreate


class ContractServer:
    def __init__(self, db: AsyncSession):
        self.db = db
        self.esign_repo = ContractRepository(db)

    async def create_template(self, template_data: TemplatesCreate):
        await self.esign_repo.create(template_data)
        return {
            "message": "模板创建成功",
            "template_data": template_data
        }
    async def list_by_store(self, store_id: int):
        return await self.esign_repo.get_by_store_id(store_id)

    async def list_all_paged(self, page: int, page_size: int = 10):
        return await self.esign_repo.get_all_paged(page, page_size)

    async def mark_signed_by_phone(self, contact_phone: str, signing_time):
        return await self.esign_repo.mark_signed_by_phone(contact_phone, signing_time)