summaryrefslogtreecommitdiff
path: root/archaeological_warehouse/serializers.py
blob: 888c7d33fa7b583064e3e001d99715a7272c90c7 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
from ishtar_common.serializers import generic_get_results, archive_serialization
from archaeological_warehouse import models


WAREHOUSE_MODEL_LIST = [
    models.Warehouse, models.Container,
    models.WarehouseDivisionLink,
    models.ContainerLocalisation
]

# TODO: associated documents


def warehouse_serialization(archive=False, return_empty_types=False,
                            archive_name=None, operation_queryset=None,
                            site_queryset=None, cr_queryset=None,
                            find_queryset=None):
    result_queryset = {}
    """
    if operation_queryset:
        operation_ids = operation_queryset.values_list("id", flat=True)
        result_queryset = {
            models.BaseFind.__name__:
                models.BaseFind.objects.filter(
                    context_record__operation_id__in=operation_ids),
            models.Find.__name__:
                models.Find.objects.filter(
                    base_finds__context_record__operation_id__in=operation_ids),
        }
    elif site_queryset:
        sites = site_queryset.values_list("id", flat=True)
        f_q = {
            "base_finds__context_record__operation__archaeological_site_id__in": sites
        }
        result_queryset = {
            models.BaseFind.__name__:
                models.BaseFind.objects.filter(
                    context_record__operation__archaeological_site_id__in=sites
                ),
            models.Find.__name__:
                models.Find.objects.filter(**f_q),
        }
    elif cr_queryset:
        cr_ids = cr_queryset.values_list("id", flat=True)
        result_queryset = {
            models.BaseFind.__name__:
                models.BaseFind.objects.filter(
                    context_record__in=cr_ids),
            models.Find.__name__:
                models.Find.objects.filter(
                    base_finds__context_record__in=cr_ids),
        }
    elif find_queryset:
        find_ids = find_queryset.values_list("id", flat=True)
        result_queryset = {
            models.BaseFind.__name__: models.BaseFind.objects.filter(
                find__id__in=find_ids),
            models.Find.__name__: find_queryset,
        }
    """
    result = generic_get_results(WAREHOUSE_MODEL_LIST, "warehouse",
                                 result_queryset=result_queryset)
    full_archive = archive_serialization(
        result, archive_dir="warehouse", archive=archive,
        return_empty_types=return_empty_types, archive_name=archive_name,
    )
    return full_archive