fix --> assign document

Dockerfile

@@ -17,6 +17,15 @@ RUN pip config --user set global.index https://mirror-pypi.runflare.com/simple
 RUN pip config --user set global.index-url https://mirror-pypi.runflare.com/simple
 RUN pip config --user set global.trusted-host mirror-pypi.runflare.com
 RUN pip install --upgrade pip
+#RUN apt-get update && apt-get install -y \
+#    libcairo2 \
+#    libpango-1.0-0 \
+#    libpangocairo-1.0-0 \
+#    libgdk-pixbuf2.0-0 \
+#    libffi-dev \
+#    shared-mime-info \
+#    fonts-dejavu \
+#    && rm -rf /var/lib/apt/lists/*
 COPY ./requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 

apps/authentication/api/v1/api.py

@@ -30,7 +30,7 @@ from apps.authentication.models import (
     Organization,
     OrganizationType,
     BankAccountInformation,
-    BlacklistedAccessToken
+    BlacklistedAccessToken, OrganizationLocationInfo
 )
 from apps.authentication.tools import get_token_jti
 from apps.authorization.api.v1 import api as authorize_view
@@ -261,14 +261,21 @@ class OrganizationViewSet(BaseViewSet, ModelViewSet, DynamicSearchMixin):
     def list(self, request, *args, **kwargs):
         """ all organization """
         org = get_organization_by_user(request.user)
+        param = self.request.query_params  # noqa
 
         queryset = self.get_queryset(
             visibility_by_org_scope=True
         ) if org.free_visibility_by_scope else self.get_queryset()
 
-        query = self.filter_query(queryset)
+        #  filter by organization type
+        if 'org_type' in param.keys():
+            queryset = queryset.filter(type__id=param.get('org_type', 0))
 
-        page = self.paginate_queryset(query.order_by('-create_date'))  # paginate queryset
+        # filter on search
+        if 'search' in param.keys():
+            queryset = self.filter_query(queryset)
+
+        page = self.paginate_queryset(queryset.order_by('-create_date'))  # paginate queryset
 
         if page is not None:  # noqa
             serializer = self.serializer_class(page, many=True)
@@ -284,6 +291,18 @@ class OrganizationViewSet(BaseViewSet, ModelViewSet, DynamicSearchMixin):
         if serializer.is_valid():
             organization = serializer.save()
 
+            if 'addresses' in request.data.keys():
+                # import multiple addresses with postal_code to orgs
+
+                address_obj_list = []
+                for addr in request.data['addresses']:
+                    addr.update({'org': organization.id})
+                    address_obj_list.append(
+                        OrganizationLocationInfo(**addr)
+                    )
+
+                OrganizationLocationInfo.objects.bulk_create(*address_obj_list)
+
             if 'user_relations' in request.data.keys():
                 user_relations = CustomOperations().custom_create(  # create user relations
                     request=request,
@@ -315,6 +334,20 @@ class OrganizationViewSet(BaseViewSet, ModelViewSet, DynamicSearchMixin):
         serializer.is_valid(raise_exception=True)
         organization = serializer.save()
 
+        if 'addresses' in request.data.keys():
+            # import multiple addresses with postal_code to orgs
+
+            organization.locations.delete()  # remove ex locations
+            # create new locations
+            address_obj_list = []
+            for addr in request.data['addresses']:
+                addr.update({'org': organization.id})
+                address_obj_list.append(
+                    OrganizationLocationInfo(**addr)
+                )
+
+            OrganizationLocationInfo.objects.bulk_create(*address_obj_list)
+
         if 'user_relations' in request.data.keys():
             user_relations = CustomOperations().custom_update(  # update user relations
                 request=request,

apps/authentication/api/v1/serializers/serializer.py

@@ -363,6 +363,13 @@ class OrganizationSerializer(serializers.ModelSerializer):
                         'name': city.name,
                     } for city in instance.service_area.all()
                 ]
+
+            representation['addresses'] = [
+                {
+                    "postal_code": addr.postal_code,
+                    "address": addr.address
+                } for addr in instance.locations.all()
+            ]
         return representation
 
     def update(self, instance, validated_data):

apps/authentication/models.py

@@ -167,6 +167,23 @@ class Organization(BaseModel):
         super(Organization, self).save(*args, **kwargs)
 
 
+class OrganizationLocationInfo(BaseModel):
+    org = models.ForeignKey(
+        Organization,
+        on_delete=models.CASCADE,
+        related_name='locations',
+        null=True
+    )
+    postal_code = models.CharField(max_length=150, null=True, blank=True)
+    address = models.TextField(max_length=2000, null=True, blank=True)
+
+    def __str__(self):
+        return f'{self.org.name}-{self.postal_code}-{self.address}'
+
+    def save(self, *args, **kwargs):
+        super(OrganizationLocationInfo, self).save(*args, **kwargs)
+
+
 class OrganizationStats(BaseModel):
     organization = models.OneToOneField(
         Organization,

apps/tag/migrations/0043_tagdistributionbatch_owner_org_and_more.py

@@ -0,0 +1,25 @@
+# Generated by Django 5.0 on 2026-02-07 07:29
+
+import django.db.models.deletion
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('authentication', '0060_organization_ownership_code'),
+        ('tag', '0042_tagdistribution_parent_and_more'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='tagdistributionbatch',
+            name='owner_org',
+            field=models.ForeignKey(null=True, on_delete=django.db.models.deletion.CASCADE, related_name='tag_distribution_batch', to='authentication.organization'),
+        ),
+        migrations.AddField(
+            model_name='tagdistributionbatch',
+            name='top_root_distribution',
+            field=models.BooleanField(default=False),
+        ),
+    ]

apps/tag/migrations/0044_tagdistributionbatch_exit_doc_status_and_more.py

@@ -0,0 +1,23 @@
+# Generated by Django 5.0 on 2026-02-08 07:27
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('tag', '0043_tagdistributionbatch_owner_org_and_more'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='tagdistributionbatch',
+            name='exit_doc_status',
+            field=models.BooleanField(default=False),
+        ),
+        migrations.AddField(
+            model_name='tagdistributionbatch',
+            name='warehouse_exit_doc',
+            field=models.CharField(max_length=350, null=True),
+        ),
+    ]

apps/tag/models.py

@@ -138,6 +138,12 @@ class TagDistributionBatch(BaseModel):
         null=True
     )
     dist_batch_identity = models.CharField(max_length=20, default="0", unique=True, null=True)
+    owner_org = models.ForeignKey(
+        Organization,
+        on_delete=models.CASCADE,
+        related_name='tag_distribution_batch',
+        null=True
+    )
     assigner_org = models.ForeignKey(
         Organization,
         on_delete=models.CASCADE,
@@ -163,6 +169,9 @@ class TagDistributionBatch(BaseModel):
     total_tag_count = models.IntegerField(default=0)
     total_distributed_tag_count = models.PositiveBigIntegerField(default=0)
     remaining_tag_count = models.PositiveBigIntegerField(default=0)
+    top_root_distribution = models.BooleanField(default=False)
+    warehouse_exit_doc = models.CharField(max_length=350, null=True)
+    exit_doc_status = models.BooleanField(default=False)
     is_closed = models.BooleanField(default=False)
 
     def __str__(self):

apps/tag/services/tag_distribution_services.py

@@ -76,11 +76,13 @@ class TagDistributionService:
             # create distribution batch
             distributions_batch = TagDistributionBatch.objects.create(
                 parent=TagDistributionBatch.objects.get(id=data.get('parent')) if data.get('parent') else None,
+                owner_org=assigned_org,
                 assigner_org=org,
                 assigned_org=assigned_org,
                 total_tag_count=total_counted_tags,
                 dist_batch_identity=generate_unique_code(f"{random.randint(1000, 9999)}"),
                 distribution_type=distribution_type,
+                top_root_distribution=True
             )
             distributions_batch.distributions.add(*distributions)
 
@@ -186,7 +188,9 @@ class TagDistributionService:
                 parent_tag_distribution = TagDistribution.objects.get(
                     id=dist_data['parent_tag_distribution']
                 )
-                batch = TagBatch.objects.get(batch_identity=dist_data.get('batch_identity'))
+                batch = TagBatch.objects.get(
+                    batch_identity=dist_data.get('batch_identity')
+                ) if dist_data.get('batch_identity') else None
 
                 tags = Tag.objects.filter(
                     distributions__tag_distribution_batch=parent_batch,
@@ -218,10 +222,11 @@ class TagDistributionService:
 
             dist_batch = TagDistributionBatch.objects.create(
                 parent=parent_batch,
+                owner_org=assigned_org,
                 assigner_org=org,
                 assigned_org=assigned_org,
                 total_tag_count=total_counted_tags,
-                distribution_type='batch',
+                distribution_type=parent_batch.distribution_type,
                 dist_batch_identity=generate_unique_code(
                     f"{random.randint(1000, 9999)}"
                 )
@@ -243,7 +248,7 @@ class TagDistributionService:
         with transaction.atomic():
 
             if tag_batch.assigner_org != org:
-                raise PermissionDenied("اجازه ویرایش این توزیع را ندارید")
+                raise PermissionDenied("اجازه ویرایش این توزیع را ندارید")  # noqa
 
             for dist in tag_batch.distributions.all():
                 dist.tag.all().update(
@@ -266,7 +271,9 @@ class TagDistributionService:
                 parent_tag_distribution = TagDistribution.objects.get(
                     id=dist_data['parent_tag_distribution']
                 )
-                batch = TagBatch.objects.get(batch_identity=dist_data.get('batch_identity'))
+                batch = TagBatch.objects.get(
+                    batch_identity=dist_data.get('batch_identity')
+                ) if dist_data.get('batch_identity') else None
                 count = dist_data['count']
 
                 tags = Tag.objects.filter(

apps/tag/signals/tag_distribution_signals.py

@@ -1,3 +1,5 @@
+from django.db.models import Sum
+from django.db.models.functions import Coalesce
 from django.db.models.signals import m2m_changed
 from django.db.models.signals import post_save
 from django.dispatch import receiver
@@ -15,14 +17,19 @@ def update_batch_on_distribution_change(
     if not instance.batch:
         return
 
+    if instance.parent:
+        return
+    
     batch = instance.batch
 
     distributions = TagDistribution.objects.filter(batch=batch)
 
     distributed_tags = Tag.objects.filter(
-        distributions__batch=batch
+        distributions__batch=batch,
+        status__in=['R', 'A'],
     ).distinct().count()
 
+    print("distributed_tags", distributed_tags)
     batch.total_distributed_tags = distributed_tags
     batch.total_remaining_tags = (
             int(batch.request_number) - distributed_tags
@@ -53,121 +60,16 @@ def calculate_tag_distribution_detail(sender, instance: TagDistributionBatch, **
     tag_dist_batch = instance
     parent = tag_dist_batch.parent
     if parent:
-        # parent.total_distributed_tag_count += tag_dist_batch.total_tag_count
+        parent.total_distributed_tag_count = parent.children.aggregate(
-        parent.remaining_tag_count = 20
+            total=Coalesce(Sum('total_tag_count'), 0)
-        print(parent.remaining_tag_count)
+        )['total']
-        parent.save(update_fields=['remaining_tag_count'])
+        parent.remaining_tag_count = (
+                parent.total_tag_count - parent.total_distributed_tag_count
+        )
+        parent.parent_flag = True
+        parent.save(update_fields=['remaining_tag_count', 'total_distributed_tag_count'])
 
-    tag_dist_batch.remaining_tag_count = tag_dist_batch.total_tag_count
+    if not getattr(instance, 'parent_flag', False):
-    instance.flag = True
+        tag_dist_batch.remaining_tag_count = tag_dist_batch.total_tag_count
-    tag_dist_batch.save(update_fields=['remaining_tag_count'])
+        instance.flag = True
-
+        tag_dist_batch.save(update_fields=['remaining_tag_count'])
-# @receiver(m2m_changed, sender=TagDistribution.tag.through)
-# def on_tags_added_to_distribution(sender, instance, action, pk_set, **kwargs):
-#     if action != 'post_add':
-#         return
-#
-#     if not pk_set:
-#         return
-#
-#     with transaction.atomic():
-#
-#         Tag.objects.filter(
-#             id__in=pk_set
-#         ).update(
-#             status='R',
-#             organization=instance.assigned_org
-#         )
-#
-#         total = instance.tag.count()
-#
-#         instance.total_tag_count = total
-#         instance.distributed_number = total - instance.remaining_number
-#         instance.remaining_number = total - instance.distributed_number
-#         instance.save(update_fields=[
-#             'total_tag_count',
-#             'distributed_number',
-#             'remaining_number'
-#         ])
-#
-#         if instance.batch:
-#             batch = instance.batch
-#
-#             distributed_tags = Tag.objects.filter(
-#                 batches=batch,
-#                 status__in=['R', 'A']
-#             ).count()
-#
-#             total_tags = batch.tag.count()
-#
-#             batch.total_distributed_tags = distributed_tags
-#             batch.total_remaining_tags = total_tags - distributed_tags
-#             batch.status = (
-#                 'distributed'
-#                 if batch.total_remaining_tags == 0
-#                 else 'created'
-#             )
-#
-#             batch.save(update_fields=[
-#                 'total_distributed_tags',
-#                 'total_remaining_tags',
-#                 'status'
-#             ])
-#
-#
-# @receiver(m2m_changed, sender=TagDistribution.tag.through)
-# def on_tags_removed_from_distribution(sender, instance, action, pk_set, **kwargs):
-#     if action not in ['post_remove', 'post_clear']:
-#         return
-#
-#     if action == 'post_clear':
-#         pk_set = list(instance.tag.values_list('id', flat=True))
-#
-#     if not pk_set:
-#         return
-#
-#     with transaction.atomic():
-#
-#         Tag.objects.filter(id__in=pk_set).update(
-#             status='R',
-#             organization=instance.assigner_org
-#         )
-#
-#         total = instance.tag.count()
-#         instance.total_tag_count = total
-#         instance.distributed_number = total
-#         instance.remaining_number = 0
-#         instance.save(update_fields=[
-#             'total_tag_count',
-#             'distributed_number',
-#             'remaining_number'
-#         ])
-#
-#         if instance.batch:
-#             batch = instance.batch
-#             distributed_tags = Tag.objects.filter(
-#                 batches=batch,
-#                 status__in=['R', 'A']
-#             ).count()
-#             total_tags = batch.tag.count()
-#             batch.total_distributed_tags = distributed_tags
-#             batch.total_remaining_tags = total_tags - distributed_tags
-#             batch.status = 'distributed' if batch.total_remaining_tags == 0 else 'created'
-#             batch.save(update_fields=[
-#                 'total_distributed_tags',
-#                 'total_remaining_tags',
-#                 'status'
-#             ])
-#
-#         for dist_batch in instance.tag_distribution_batch.all():
-#             total_dist = dist_batch.distributions.aggregate(
-#                 total=Count('tag')
-#             ).get('total', 0)
-#             dist_batch.total_distributed_tag_count = total_dist
-#             dist_batch.remaining_tag_count = dist_batch.total_tag_count - total_dist
-#             dist_batch.is_closed = dist_batch.remaining_tag_count == 0
-#             dist_batch.save(update_fields=[
-#                 'total_distributed_tag_count',
-#                 'remaining_tag_count',
-#                 'is_closed'
-#             ])

apps/tag/templates/pdf/tag_distribution.html

@@ -0,0 +1,92 @@
+<!DOCTYPE html>
+<html lang="fa" dir="rtl">
+<head>
+    <meta charset="UTF-8">
+    <style>
+        @page {
+            size: A4;
+            margin: 2cm;
+        }
+
+        body {
+            font-family: DejaVu Sans;
+            font-size: 12px;
+        }
+
+        h1 {
+            text-align: center;
+            margin-bottom: 20px;
+        }
+
+        .meta {
+            margin-bottom: 20px;
+        }
+
+        .meta div {
+            margin-bottom: 5px;
+        }
+
+        table {
+            width: 100%;
+            border-collapse: collapse;
+        }
+
+        th, td {
+            border: 1px solid #333;
+            padding: 6px;
+            text-align: center;
+        }
+
+        th {
+            background: #f0f0f0;
+        }
+
+        .footer {
+            margin-top: 30px;
+            font-size: 10px;
+            text-align: center;
+            color: #666;
+        }
+    </style>
+</head>
+<body>
+
+<h1>سند توزیع پلاک دام</h1>
+
+<div class="meta">
+    <div><strong>شناسه توزیع:</strong> {{ batch.dist_batch_identity }}</div>
+    <div><strong>سازمان تخصیص‌دهنده:</strong> {{ batch.assigner_org.name }}</div>
+    <div><strong>سازمان دریافت‌کننده:</strong> {{ batch.assigned_org.name }}</div>
+    <div><strong>تاریخ ایجاد:</strong> {{ batch.create_date }}</div>
+    <div><strong>تعداد کل پلاک:</strong> {{ batch.total_tag_count }}</div>
+</div>
+
+<table>
+    <thead>
+    <tr>
+        <th>کد گونه</th>
+        <th>از سریال</th>
+        <th>تا سریال</th>
+        <th>تعداد کل</th>
+        <th>باقی‌مانده</th>
+    </tr>
+    </thead>
+    <tbody>
+    {% for dist in batch.distributions.all %}
+        <tr>
+            <td>{{ dist.species_code }}</td>
+            <td>{{ dist.serial_from }}</td>
+            <td>{{ dist.serial_to }}</td>
+            <td>{{ dist.total_tag_count }}</td>
+            <td>{{ dist.remaining_number }}</td>
+        </tr>
+    {% endfor %}
+    </tbody>
+</table>
+
+<div class="footer">
+    این سند به صورت سیستمی تولید شده و معتبر می‌باشد.
+</div>
+
+</body>
+</html>

apps/tag/web/api/v1/api.py

@@ -1,3 +1,4 @@
+import random
 import typing
 
 from django.db import transaction
@@ -21,6 +22,7 @@ from apps.tag.services.tag_distribution_services import TagDistributionService
 from apps.tag.services.tag_services import TagService
 from common.helpers import get_organization_by_user
 from common.liara_tools import upload_to_liara
+from common.storage import upload_to_storage
 from .serializers import (
     TagSerializer,
     TagAssignmentSerializer,
@@ -28,6 +30,9 @@ from .serializers import (
 )
 
 
+# from weasyprint import HTML
+
+
 class TagViewSet(BaseViewSet, TagService, SoftDeleteMixin, DynamicSearchMixin, viewsets.ModelViewSet):
     """ Tag View Set """
     queryset = tag_models.Tag.objects.all()
@@ -297,8 +302,8 @@ class TagAssignmentViewSet(BaseViewSet, SoftDeleteMixin, DynamicSearchMixin, vie
             check_response = GeneralOTPViewSet().check_otp(request)
             if check_response.status_code == 200:
                 return Response(check_response.status_code, status=status.HTTP_200_OK)
-            else:
+            return Response(check_response.status_code, status=status.HTTP_403_FORBIDDEN)
-                return Response(check_response.status_code, status=status.HTTP_403_FORBIDDEN)
+        return Response(status=status.HTTP_200_OK)
 
 
 class AllocatedTagsViewSet(SoftDeleteMixin, viewsets.ModelViewSet):
@@ -478,9 +483,9 @@ class TagDistributionViewSet(
     @action(
         methods=['put'],
         detail=True,
-        url_path='distribute_distribution',
+        url_path='edit_distribute_distribution',
-        url_name='distribute_distribution',
+        url_name='edit_distribute_distribution',
-        name='distribute_distribution',
+        name='edit_distribute_distribution',
     )
     def update_distribute_from_distribution(self, request, pk=None):
         """
@@ -558,9 +563,9 @@ class TagDistributionViewSet(
 
 class TagDistributionBatchViewSet(
     BaseViewSet,
+    viewsets.ModelViewSet,
     SoftDeleteMixin,
     DynamicSearchMixin,
-    viewsets.ModelViewSet,
     TagDistributionService
 ):
     queryset = tag_models.TagDistributionBatch.objects.all()
@@ -578,8 +583,23 @@ class TagDistributionBatchViewSet(
         """
         list of tag distribution batches
         """
+        org = get_organization_by_user(request.user)
 
-        queryset = self.get_queryset(visibility_by_org_scope=True).filter(is_closed=False).order_by('-create_date')
+        queryset = self.get_queryset(
+            visibility_by_org_scope=True
+        ).filter(
+            is_closed=False,
+            top_root_distribution=True,
+        ).order_by('-create_date')
+
+        if not queryset:
+            queryset = self.get_queryset(
+                visibility_by_org_scope=True
+            ).filter(
+                is_closed=False,
+                owner_org=org,
+                top_root_distribution=False,
+            ).order_by('-create_date')
 
         queryset = self.filter_query(self.filter_queryset(queryset))
 
@@ -598,6 +618,26 @@ class TagDistributionBatchViewSet(
         serializer = self.serializer_class(distribution_batch)
         return Response(serializer.data, status=status.HTTP_200_OK)
 
+    @action(
+        methods=['get'],
+        detail=True,
+        url_path='child_list',
+        url_name='child_list',
+        name='child_list'
+    )
+    def child_list(self, request, pk=None):
+        """
+        list of all child from a tag distribution batch
+        """
+        dist_batch = self.get_object()
+        queryset = dist_batch.children.all()
+
+        page = self.paginate_queryset(queryset)
+        if page is not None:  # noqa
+            serializer = self.get_serializer(page, many=True)
+            return self.get_paginated_response(serializer.data)
+        return Response(self.serializer_class(queryset).data)
+
     @action(
         methods=['post'],
         detail=True,
@@ -612,6 +652,8 @@ class TagDistributionBatchViewSet(
         dist_batch.is_closed = True
         dist_batch.save()
         dist_batch.distributions.all().update(is_closed=True)  # close distributions of batch
+        for distribute in dist_batch.distributions.all():
+            distribute.tag.all().update(status='F')
 
         return Response(status=status.HTTP_200_OK)
 
@@ -670,3 +712,93 @@ class TagDistributionBatchViewSet(
         dashboard_data = self.distribution_batch_main_dashboard(org=org, is_closed=params.get('is_closed'))
 
         return Response(dashboard_data, status=status.HTTP_200_OK)
+
+    # @action(
+    #     methods=['get'],
+    #     detail=True,
+    #     url_path='distribution_pdf_view',
+    #     url_name='distribution_pdf_view',
+    #     name='distribution_pdf_view',
+    # )
+    # def distribution_pdf_view(self, request, pk=None):
+    #     batch = tag_models.TagDistributionBatch.objects.select_related(
+    #         'assigner_org', 'assigned_org'
+    #     ).prefetch_related('distributions').get(id=pk)
+    #
+    #     html_string = render_to_string(
+    #         'pdf/tag_distribution.html',  # noqa
+    #         {'batch': batch}
+    #     )
+    #
+    #     html = HTML(
+    #         string=html_string,
+    #         base_url=request.build_absolute_uri('/')
+    #     )
+    #
+    #     pdf = html.write_pdf()
+    #
+    #     response = HttpResponse(pdf, content_type='application/pdf')
+    #     response['Content-Disposition'] = (
+    #         f'inline; filename="distribution_{batch.dist_batch_identity}.pdf"'
+    #     )
+    #
+    #     return response
+
+    @action(
+        methods=['post', ],
+        detail=True,
+        url_name='assign_document',
+        url_path='assign_document',
+        name='assign_document'
+    )
+    @transaction.atomic
+    def assign_document(self, request, pk=None):
+        """ set document for tag assignment """
+
+        # get tag assignment object & set document url
+        dist_batch = self.queryset.get(id=pk)
+
+        # upload document file to liara storage
+        document = request.FILES.get('dist_exit_document')
+        document_url = upload_to_storage(
+            document,
+            f'{random.randint(1000, 9999)}_distribution_batch_document.{str(document).split(".")[1]}'
+        )
+        dist_batch.warehouse_exit_doc = document_url
+        dist_batch.save(update_fields=['warehouse_exit_doc'])
+        serializer = self.serializer_class(dist_batch)
+        return Response(serializer.data, status=status.HTTP_200_OK)
+
+    @action(
+        methods=['post'],
+        detail=True,
+        url_path='accept_exit_doc',
+        url_name='accept_exit_doc',
+        name='accept_exit_doc',
+    )
+    def accept_exit_doc(self, request, pk=None):
+        """
+        accept exit document from warehouse on distribution batch
+        """
+
+        dist_batch = self.get_object()
+        dist_batch.exit_doc_status = True
+        dist_batch.save(update_fields=['exit_doc_status'])
+
+        return Response(status=status.HTTP_200_OK)
+
+    def destroy(self, request, pk=None, *args, **kwargs):
+        """
+        delete tag distribution batch and free their tag from distribute
+        """
+
+        dist_batch = self.get_object()
+
+        for distribute in dist_batch.distributions.all():
+            distribute.tag.all().update(status='F')
+            distribute.tag.clear()
+            distribute.soft_delete()
+
+        dist_batch.soft_delete()
+
+        return Response(status=status.HTTP_200_OK)

apps/warehouse/web/api/v1/api.py

@@ -281,8 +281,14 @@ class InventoryQuotaSaleTransactionViewSet(
 
         org = get_organization_by_user(request.user)
         if org.free_visibility_by_scope:
+
             tr_objects = self.get_queryset(visibility_by_org_scope=True)
-            tr_item_objects = InventoryQuotaSaleItemViewSet().get_queryset(visibility_by_org_scope=True)
+
+            tr_item_view = InventoryQuotaSaleItemViewSet()
+            tr_item_view.request = request
+            tr_item_view.kwargs = {'pk': None}
+            tr_item_objects = tr_item_view.get_queryset(visibility_by_org_scope=True)
+
             transaction_dashboard_data = self.get_dashboard(
                 org,
                 free_visibility_tr_objects=tr_objects,

common/storage.py

@@ -1,4 +1,31 @@
+import boto3
+from botocore.exceptions import NoCredentialsError
+
 STORAGE_ENDPOINT = 'https://s3.rasadyar.com/rasaddam'
 STORAGE_BUCKET_NAME = 'ticket-rasadyar'
 STORAGE_ACCESS_KEY = "zG3ewsbYsTqCmuws"
 STORAGE_SECRET_KEY = 'RInUMB78zlQZp6CNf8+sRoSh2cNDHcGQhXrLnTJ1AuI='
+
+
+def upload_to_storage(file_obj, file_name):
+    try:
+        s3 = boto3.client(
+            's3',
+            endpoint_url=STORAGE_ENDPOINT,
+            aws_access_key_id=STORAGE_ACCESS_KEY,
+            aws_secret_access_key=STORAGE_SECRET_KEY
+        )
+
+        s3.upload_fileobj(
+            file_obj,
+            STORAGE_BUCKET_NAME,
+            file_name,
+            ExtraArgs={'ACL': 'public-read'}  # دسترسی عمومی
+        )
+
+        return f"{STORAGE_ENDPOINT}/{STORAGE_ENDPOINT}/{file_name}"
+
+    except NoCredentialsError:
+        raise Exception("اعتبارنامه‌های AWS معتبر نیستند")
+    except Exception as e:
+        raise Exception(f"خطا در آپلود فایل: {e}")

requirements.txt

@@ -84,3 +84,4 @@ channels_redis
 daphne
 django-jazzmin
 python-dotenv
+weasyprint