From 248ef67e459f6412f47b78718f9ee7d31e411f1c Mon Sep 17 00:00:00 2001
From: shahzeydyfah <shahzeydyfah>
Date: Sat, 21 Sep 2024 13:39:18 +0330
Subject: [PATCH] feat:add get list for progress rial and physical

---
 app/repositories/monitor_physical_progress.py | 4 ++++
 app/repositories/monitor_rial_progress.py     | 6 +++++-
 app/urls/monitor_physical.py                  | 6 ++++++
 app/urls/monitor_rial.py                      | 6 ++++++
 4 files changed, 21 insertions(+), 1 deletion(-)

diff --git a/app/repositories/monitor_physical_progress.py b/app/repositories/monitor_physical_progress.py
index 91511b5..a2feb41 100644
--- a/app/repositories/monitor_physical_progress.py
+++ b/app/repositories/monitor_physical_progress.py
@@ -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
diff --git a/app/repositories/monitor_rial_progress.py b/app/repositories/monitor_rial_progress.py
index 923037f..31d541c 100644
--- a/app/repositories/monitor_rial_progress.py
+++ b/app/repositories/monitor_rial_progress.py
@@ -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
\ No newline at end of file
+        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
\ No newline at end of file
diff --git a/app/urls/monitor_physical.py b/app/urls/monitor_physical.py
index 071b31b..13f4f68 100644
--- a/app/urls/monitor_physical.py
+++ b/app/urls/monitor_physical.py
@@ -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(...)):
diff --git a/app/urls/monitor_rial.py b/app/urls/monitor_rial.py
index a0335d2..9c354b5 100644
--- a/app/urls/monitor_rial.py
+++ b/app/urls/monitor_rial.py
@@ -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):