MNPC/RasadDam_Backend
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix product stat signal

Browse Source
This commit is contained in:
Mojtaba-z
2025-08-03 10:36:00 +03:30
parent ac729db167
commit d9a9cfde35
12 changed files with 285 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
apps/product/signals.py
View File

@@ -1,6 +1,7 @@
from django.db.models import Sum, Q
from django.db.models.signals import post_save, post_delete
from common.helpers import get_organization_by_user
from rest_framework.exceptions import APIException
from django.dispatch import receiver
from .models import (
QuotaDistribution,
@@ -83,18 +84,20 @@ def update_product_stats(instance: Product, distribution: QuotaDistribution = No
)
# number of quotas
quotas_count = instance.quotas.filter(is_closed=False).count() # noqa
quotas_count = instance.quotas.filter(is_closed=False, registerer_organization=organization) # noqa
total_quotas_weight = quotas_count.aggregate( # noqa
total=models.Sum('quota_weight')
)['total'] or 0
quotas_count = quotas_count.count()
# total weight of product that assigned in quota
active_quotas_weight = instance.quotas.filter(is_closed=False).aggregate(
active_quotas_weight = instance.quotas.filter(is_closed=False, registerer_organization=organization).aggregate(
total=models.Sum('quota_weight')
)['total'] or 0
closed_quotas_weight = instance.quotas.filter(is_closed=True).aggregate( # noqa
total=models.Sum('quota_weight')
)['total'] or 0
total_quotas_weight = instance.quotas.all().aggregate( # noqa
closed_quotas_weight = instance.quotas.filter(is_closed=True, registerer_organization=organization).aggregate( # noqa
total=models.Sum('quota_weight')
)['total'] or 0
@@ -103,34 +106,43 @@ def update_product_stats(instance: Product, distribution: QuotaDistribution = No
total=models.Sum('remaining_weight')
)['total'] or 0
total_distribution_weight = QuotaDistribution.objects.filter(
received_distribution_weight = QuotaDistribution.objects.filter(
quota__product_id=instance.id,
quota__is_closed=False,
quota__sale_unit=distribution.quota.sale_unit,
assigned_organization=distribution.assigned_organization
).aggregate(total_weight=models.Sum('weight'))['total_weight'] or 0
assigned_organization=organization
)
received_distribution_number = received_distribution_weight.count()
received_distribution_weight = received_distribution_weight.aggregate(
total_weight=models.Sum('weight')
)['total_weight'] or 0
# product total distributed weight from quota
total_distributed_weight = QuotaDistribution.objects.filter(
given_distribution_weight = QuotaDistribution.objects.filter(
quota__product_id=instance.id,
quota__is_closed=False,
quota__sale_unit=distribution.quota.sale_unit,
assigner_organization=distribution.assigner_organization
).aggregate(total_weight=models.Sum('weight'))['total_weight'] or 0
assigner_organization=organization
)
total_remaining_distribution_weight = QuotaDistribution.objects.filter(
quota__product_id=instance.id,
quota__is_closed=False,
quota__sale_unit=distribution.quota.sale_unit,
assigner_organization=distribution.assigner_organization
).aggregate(total_weight=models.Sum('remaining_weight'))['total_weight'] or 0
given_distribution_number = given_distribution_weight.count()
given_distribution_weight = given_distribution_weight.aggregate(
total_weight=models.Sum('weight')
)['total_weight'] or 0
if received_distribution_weight > 0:
distribution_weight_balance = received_distribution_weight - given_distribution_weight
else:
distribution_weight_balance = given_distribution_weight
# total sold of product from quota
total_sold = QuotaDistribution.objects.filter(
quota__product_id=instance.id,
quota__is_closed=False,
quota__sale_unit=distribution.quota.sale_unit,
assigned_organization=distribution.assigned_organization
assigned_organization=organization
).aggregate(total_sold=models.Sum('been_sold'))['total_sold'] or 0
# total entry from product to inventory
@@ -138,17 +150,19 @@ def update_product_stats(instance: Product, distribution: QuotaDistribution = No
quota__product_id=instance.id,
quota__is_closed=False,
quota__sale_unit=distribution.quota.sale_unit,
assigned_organization=distribution.assigned_organization
assigned_organization=organization
).aggregate(total_entry=models.Sum('warehouse_entry'))['total_entry'] or 0
stat.quotas_number = quotas_count
stat.active_quotas_weight = active_quotas_weight
stat.closed_quotas_weight = closed_quotas_weight
stat.total_quota_weight = total_quotas_weight
stat.total_remaining = total_remaining_quotas_weight
stat.total_remaining_distribution_weight = total_remaining_distribution_weight
stat.total_distributed_weight = total_distributed_weight
stat.total_distribution_weight = total_distribution_weight
stat.total_quota_remaining = total_remaining_quotas_weight
stat.total_remaining_distribution_weight = distribution_weight_balance
stat.received_distribution_weight = received_distribution_weight
stat.given_distribution_weight = given_distribution_weight
stat.received_distribution_number = received_distribution_number
stat.given_distribution_number = given_distribution_number
stat.total_warehouse_entry = total_warehouse_entry
stat.total_sold = total_sold
stat.save(update_fields=[
@@ -156,8 +170,11 @@ def update_product_stats(instance: Product, distribution: QuotaDistribution = No
"active_quotas_weight",
"closed_quotas_weight",
"total_quota_weight",
"total_remaining",
"total_distributed_weight",
"total_quota_remaining",
"total_remaining_distribution_weight",
"received_distribution_weight",
"given_distribution_weight",
"received_distribution_number",
"total_warehouse_entry",
"total_sold",
])