From 855af7e52a49f1b5387dbb52cf0b01235a9cdd1e Mon Sep 17 00:00:00 2001 From: shahzeydyfah Date: Sat, 16 Mar 2024 06:50:18 +0330 Subject: [PATCH] feat(register status):add --- app/config/__init__.py | 17 +---------------- app/repositories/register_status.py | 10 +++++++++- app/urls/register_status.py | 8 +++++++- 3 files changed, 17 insertions(+), 18 deletions(-) diff --git a/app/config/__init__.py b/app/config/__init__.py index c92f218..78f49ef 100644 --- a/app/config/__init__.py +++ b/app/config/__init__.py @@ -1,17 +1,2 @@ class TaskEnv: - CLN_SUB = 'subscription' - CLN_SUB_USER = 'subscription_users' - CLN_USER = 'customer' - CLN_FAV = 'favs' - CLN_STORY = 'story' - CLN_STORY_COMMENT = 'story-comment' - CLN_ORDER = 'order' - CLN_CATEGORY = 'category' - CLN_PRODUCT = 'product' - CLN_TASK = "task" - CLN_CONST = "const" - CLN_DEPENDENCY = "dependency" - CLN_MEMBER = "member" - CLN_PROJECT = "project" - CLN_TAGS = "tags" - CLN_WORKSPACE = "workspace" + CLN_AUDIT_STATUS = 'audit_status' diff --git a/app/repositories/register_status.py b/app/repositories/register_status.py index 8d23d2d..875d21a 100644 --- a/app/repositories/register_status.py +++ b/app/repositories/register_status.py @@ -1,7 +1,15 @@ +import uuid + +from app.config import TaskEnv from app.models.register_status import RegisterStatusModel from core.repositories.base import BaseRepository +from core.service.mongo_db import use_collection class RegisterStatusRepository(BaseRepository[RegisterStatusModel]): def __int__(self): - super().__init__(collection='register_status',model=RegisterStatusModel) + super().__init__(collection=TaskEnv.CLN_AUDIT_STATUS,model=RegisterStatusModel) + + async def get_last(self,project_id:uuid.UUID): + last = await use_collection(TaskEnv.CLN_AUDIT_STATUS).find_one({"project_id":project_id}).sort('$natural', -1) + return last diff --git a/app/urls/register_status.py b/app/urls/register_status.py index d910bf2..7449fd1 100644 --- a/app/urls/register_status.py +++ b/app/urls/register_status.py @@ -2,6 +2,7 @@ from uuid import UUID from fastapi import Body +from app.config import TaskEnv from app.models.register_status import RegisterStatusModel from app.repositories.register_status import RegisterStatusRepository from core.app import app @@ -14,13 +15,17 @@ _tag_base = [router_base_url] router = generate_router(router_base_url, auth_dependencies=False, version='v2') -repo = RegisterStatusRepository(collection='register_status') +repo = RegisterStatusRepository(collection=TaskEnv.CLN_AUDIT_STATUS) @router.post('/create', response_model=ThisModel, tags=_tag_base) @shrink(repo.create) def create(coding: ThisModel = Body(...)): pass +@router.get('/last/{project_id}', response_model=ThisModel, tags=_tag_base) +@shrink(repo.get_last) +def get_last(project_id: UUID): + pass @router.put('/{_id}', response_model=ThisModel, tags=_tag_base) @shrink(repo.update) def update(_id: UUID, coding: ThisModel = Body(...)): @@ -33,6 +38,7 @@ def get(_id: UUID): pass + @router.post('', response_model=TableEngineExport[ThisModel], tags=_tag_base) @shrink(repo.fetch) def fetch(body: TableEngineRequestType = Body(...)):