feat:add get list for progress rial and physical

This commit is contained in:
shahzeydyfah
2024-09-21 13:39:18 +03:30
parent bf5f1598f2
commit 248ef67e45
4 changed files with 21 additions and 1 deletions
@@ -44,3 +44,7 @@ class PhysicalProgressRepository(BaseRepository):
create = await mongo_inserter(_inp, COLLECTION, getter=self.get)
await ProjectRepository().set_sts_two_for_monitor(_inp.project_id)
return create
async def list_by_project(self,_id:uuid.UUID):
_get = await use_collection(COLLECTION).find({"project_id":_id}).to_list(None)
return _get
+5 -1
View File
@@ -21,4 +21,8 @@ class RialProgressRepository(BaseRepository):
async def create(self,_inp:RialProgressModel):
create = await mongo_inserter(_inp,TaskEnv.CLN_MONITOR_RIAL,getter=self.get)
await ProjectRepository().set_sts_two_for_monitor(_inp.project_id)
return create
return create
async def list_by_project(self, _id: uuid.UUID):
_get = await use_collection(TaskEnv.CLN_MONITOR_RIAL).find({"project_id": _id}).to_list(None)
return _get
+6
View File
@@ -1,3 +1,4 @@
from typing import List
from uuid import UUID
from fastapi import Body
@@ -24,6 +25,11 @@ def create(coding: ThisModel = Body(...)):
def last_record(last:LastRecord):
pass
@router.get('/list/{_id}', response_model=List[ThisModel], tags=_tag_base, description='پیشرفت فیزیکی')
@shrink(repo.list_by_project)
def list_by_project(_id: UUID):
pass
@router.put('/{_id}', response_model=ThisModel, tags=_tag_base, description='پیشرفت فیزیکی')
@shrink(repo.update)
def update(_id: UUID, coding: ThisModel = Body(...)):
+6
View File
@@ -1,3 +1,4 @@
from typing import List
from uuid import UUID
from fastapi import Body
@@ -20,6 +21,11 @@ repo = RialProgressRepository()
def create(coding: ThisModel = Body(...)):
pass
@router.get('/list/{_id}', response_model=List[ThisModel], tags=_tag_base, description='پیشرفت فیزیکی')
@shrink(repo.list_by_project)
def list_by_project(_id: UUID):
pass
@router.post('/last', response_model=ThisModel, tags=_tag_base, description='پیشرفت ریالی')
@shrink(repo.last_record)
def last_record(last:LastRecord):