update organization reference in notification creation for quota distribution
This commit is contained in:
@@ -1,10 +1,11 @@
|
|||||||
|
from django.db import transaction
|
||||||
from django.db.models.signals import post_save
|
from django.db.models.signals import post_save
|
||||||
from django.dispatch import receiver
|
from django.dispatch import receiver
|
||||||
|
|
||||||
|
from apps.pos_device.models import Device
|
||||||
from apps.warehouse.models import InventoryEntry
|
from apps.warehouse.models import InventoryEntry
|
||||||
from apps.warehouse.models import product_models
|
from apps.warehouse.models import product_models
|
||||||
from apps.pos_device.models import Device
|
|
||||||
from .models import Notification
|
from .models import Notification
|
||||||
from django.db import transaction
|
|
||||||
|
|
||||||
|
|
||||||
@receiver(post_save, sender=InventoryEntry)
|
@receiver(post_save, sender=InventoryEntry)
|
||||||
@@ -29,6 +30,7 @@ def create_inventory_entry_notification(sender, instance, created, **kwargs):
|
|||||||
|
|
||||||
transaction.on_commit(_create_notification)
|
transaction.on_commit(_create_notification)
|
||||||
|
|
||||||
|
|
||||||
@receiver(post_save, sender=product_models.QuotaDistribution) # noqa
|
@receiver(post_save, sender=product_models.QuotaDistribution) # noqa
|
||||||
def create_quota_distribution_notification(sender, instance, created, **kwargs):
|
def create_quota_distribution_notification(sender, instance, created, **kwargs):
|
||||||
""" Create notification for organization for quota distribution creation """
|
""" Create notification for organization for quota distribution creation """
|
||||||
@@ -38,7 +40,7 @@ def create_quota_distribution_notification(sender, instance, created, **kwargs):
|
|||||||
|
|
||||||
def _create_notification():
|
def _create_notification():
|
||||||
# create notification for organization on pos device
|
# create notification for organization on pos device
|
||||||
devices = Device.objects.filter(assignment__client__organization=instance.organization)
|
devices = Device.objects.filter(assignment__client__organization=instance.assigned_organization)
|
||||||
for device in devices:
|
for device in devices:
|
||||||
Notification.objects.create(
|
Notification.objects.create(
|
||||||
device=device,
|
device=device,
|
||||||
|
|||||||
Reference in New Issue
Block a user