From 7c21ebe55189195a4f7c51cff4a051a22af555d8 Mon Sep 17 00:00:00 2001
From: shahzeydyfah <shahzeydyfah>
Date: Tue, 21 Jan 2025 00:44:50 +0330
Subject: [PATCH] feat(project):add create price for project monitor

---
 app/repositories/project.py | 24 ++++++++++++++++++++++++
 app/urls/project.py         |  4 ++++
 2 files changed, 28 insertions(+)

diff --git a/app/repositories/project.py b/app/repositories/project.py
index adf3aee..a181807 100644
--- a/app/repositories/project.py
+++ b/app/repositories/project.py
@@ -226,3 +226,27 @@ class ProjectRepository(BaseRepository[ProjectModel]):
 
         return res.json()
 
+    async def create_project_price(self):
+
+        projects = await use_collection(TaskEnv.CLN_PROJECT).find({'monitor.detail.first_amount':{'$exists':1}}).to_list(None)
+        for project in projects:
+            sum_status = 0
+            sum_adjust = 0
+            status = await use_collection(TaskEnv.CLN_FINANCIAL_STATUS).find({'project_id':project['_id'],'amount':{'$exists':1}}).to_list(None)
+            if status:
+                for i in status:
+                    sum_status += i['amount']
+            adjust = await use_collection(TaskEnv.CLN_FINANCIAL_ADJUST).find({'project_id':project['_id'],'amount':{'$exists':1}}).to_list(None)
+            if adjust:
+                for i in adjust:
+                    sum_adjust += i['amount']
+            price = {
+                '_id': uuid.uuid4(),
+                'project_id': project['_id'],
+                'first_amount': project['monitor']['detail']['first_amount'],
+                'amount_status':sum_status,
+                'amount_adjust':sum_adjust
+            }
+            await use_collection(TaskEnv.CLN_PROJECT_PRICE_REPORT).insert_one(price)
+
+
diff --git a/app/urls/project.py b/app/urls/project.py
index e790a20..deea8b4 100644
--- a/app/urls/project.py
+++ b/app/urls/project.py
@@ -87,6 +87,10 @@ def fetch(body: TableEngineRequestType = Body(...)):
 @shrink(repo.fetch_delete)
 def fetch_delete(body: TableEngineRequestType = Body(...)):
     pass
+# @router.get('/price/create_project_price', response_model=TableEngineExport[ThisModel], tags=_tag_base)
+# @shrink(repo.create_project_price)
+# def create_project_price():
+#     pass
 
 
 # @router.post('/get_all', tags=_tag_base)