diff --git a/app/repositories/monitor_physical_progress.py b/app/repositories/monitor_physical_progress.py index a2feb41..d565f35 100644 --- a/app/repositories/monitor_physical_progress.py +++ b/app/repositories/monitor_physical_progress.py @@ -38,6 +38,14 @@ class PhysicalProgressRepository(BaseRepository): three_month = await self.search_last(TaskEnv.CLN_MONITOR_PYSICAL, _inp, 95, 85) if three_month: send['three_month'] = three_month + _avg = await use_collection(TaskEnv.CLN_MONITOR_PYSICAL).aggregate([ + {'$match':{'project_id':_inp.project_id}}, + {'$group': {'_id': None, 'avg': {'$avg': "$real"}}} + ]).to_list(None) + if _avg: + send['avg'] = _avg[0]['avg'] + else: + send['avg'] = None return send async def create(self, _inp: MODEL):