project items added

2024-11-18 20:21:38 +03:00
parent 7bc16e02d1
commit 1e8f5023e8
9 changed files with 534 additions and 44 deletions
--- a/api_events/events/decision_book/project_decision_book.py
+++ b/api_events/events/decision_book/project_decision_book.py
@@ -1,6 +1,65 @@
+from typing import Union
+
+from api_library.date_time_actions.date_functions import system_arrow
+from databases import (
+    BuildDecisionBookProjects,
+    BuildDecisionBookProjectPerson,
+    BuildDecisionBookPayments,
+    OccupantTypes
+)
+
 from api_events.events.abstract_class import MethodToEvent, ActionsSchema
 from api_objects.auth.token_objects import EmployeeTokenObject, OccupantTokenObject
+from api_validations.validations_request import (
+    InsertBuildDecisionBookProjects,
+    UpdateBuildDecisionBookProjects,
+    ApprovalsBuildDecisionBookProjects,
+    ListOptions,
+)
 from api_validations.core_response import AlchemyJsonResponse
+from databases import (
+    Build,
+    BuildLivingSpace,
+    BuildParts,
+    ApiEnumDropdown
+)
+from databases.sql_models.building.decision_book import BuildDecisionBookProjectItems, BuildDecisionBookItems
+
+
+class ProjectDecisionBookPersonListEvents(MethodToEvent):
+
+    event_type = "LIST"
+
+    __event_keys__ = {
+        "96459b36-37f2-4d5b-8370-c459058d5bce": "project_decision_book_person_list",
+    }
+
+    @classmethod
+    def project_decision_book_person_list(
+            cls,
+            data: ListOptions,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            project_person = BuildDecisionBookProjectPerson.filter_all(
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            )
+            decision_book_ids = [_.build_decision_book_project_id for _ in project_person.data]
+            decision_book_projects = BuildDecisionBookProjects.filter_all(
+                BuildDecisionBookProjects.build_decision_book_project_id.in_(decision_book_ids),
+            )
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_projects,
+            )


 class ProjectDecisionBookCreateEvents(MethodToEvent):
@@ -12,8 +71,51 @@ class ProjectDecisionBookCreateEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_create(cls, request, *args, **kwargs):
-        pass
+    def project_decision_book_create(
+            cls,
+            data: InsertBuildDecisionBookProjects,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            living_space = BuildLivingSpace.filter_one(
+                BuildLivingSpace.living_space_id == token_dict.selected_occupant.living_space_id,
+            ).data
+            if not living_space:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message="Living space not found",
+                    data={}
+                )
+
+            occupant_type = OccupantTypes.filter_by_one(
+                occupant_category_type="PRJ",
+                occupant_code="PRJ-LDR",
+                id=living_space.occupant_type
+            ).data
+            if not occupant_type:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message=f"{token_dict.selected_occupant.occupant_type_uu_id} occupant type is not allowed, only PRJ-LDR occupant type is allowed",
+                    data={}
+                )
+            decision_book_project_person = BuildDecisionBookProjectPerson.filter_one(
+                BuildDecisionBookProjectPerson.build_decision_book_project_uu_id == data.get("build_decision_book_uu_id"),
+                BuildDecisionBookProjectPerson.living_space_id == token_dict.selected_occupant.living_space_id,
+            )
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_project_person,
+            )


 class ProjectDecisionBookUpdateEvents(MethodToEvent):
@@ -25,8 +127,187 @@ class ProjectDecisionBookUpdateEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_update(cls, request, *args, **kwargs):
-        pass
+    def project_decision_book_update(
+            cls,
+            data: UpdateBuildDecisionBookProjects,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            living_space = BuildLivingSpace.filter_one(
+                BuildLivingSpace.living_space_id == token_dict.selected_occupant.living_space_id,
+            ).data
+            if not living_space:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message="Living space not found",
+                    data={}
+                )
+
+            occupant_type = OccupantTypes.filter_by_one(
+                occupant_category_type="PRJ",
+                occupant_code="PRJ-LDR",
+                id=living_space.occupant_type
+            ).data
+            if not occupant_type:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message=f"{token_dict.selected_occupant.occupant_type_uu_id} occupant type is not allowed, only PRJ-LDR occupant type is allowed",
+                    data={}
+                )
+
+            decision_book_project_person = BuildDecisionBookProjectPerson.filter_one(
+                BuildDecisionBookProjects.build_decision_book_project_uu_id == data.get("build_decision_book_project_uu_id"),
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            ).data
+            if not decision_book_project_person:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message="This project is not allowed for this occupant",
+                    data={}
+                )
+            decision_book_project = BuildDecisionBookProjects.filter_one(
+                BuildDecisionBookProjects.id == decision_book_project_person.build_decision_book_project_id,
+            )
+            if decision_book_project.is_completed:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_403_FORBIDDEN",
+                    error_case="NOT_ALLOWED",
+                    message="Project decision book is closed. No modification is allowed",
+                    data={}
+                )
+            data_dict = data.excluded_dump()
+            decision_book_project.update(**data_dict)
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_project_person,
+            )
+
+
+class ProjectDecisionBookApprovalEvents(MethodToEvent):
+
+    event_type = "UPDATE"
+
+    __event_keys__ = {
+        "a83a83fe-8446-4c60-9ae5-d1c06adbf626": "project_decision_book_approval",
+    }
+
+    @classmethod
+    def project_decision_book_approval(
+            cls,
+            data: ApprovalsBuildDecisionBookProjects,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            living_space = BuildLivingSpace.filter_one(
+                BuildLivingSpace.living_space_id == token_dict.selected_occupant.living_space_id,
+            ).data
+            if not living_space:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message="Living space not found",
+                    data={}
+                )
+            occupant_type = OccupantTypes.filter_by_one(
+                occupant_category_type="PRJ",
+                occupant_code="PRJ-LDR",
+                id=living_space.occupant_type
+            ).data
+            if not occupant_type:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message=f"{token_dict.selected_occupant.occupant_type_uu_id} occupant type is not allowed, only PRJ-LDR occupant type is allowed",
+                    data={}
+                )
+
+            decision_book_project_person = BuildDecisionBookProjectPerson.filter_one(
+                BuildDecisionBookProjects.build_decision_book_project_uu_id == data.get(
+                    "build_decision_book_project_uu_id"),
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            ).data
+            if not decision_book_project_person:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_404_NOT_FOUND",
+                    error_case="NOT_FOUND",
+                    message="This project is not allowed for this occupant",
+                    data={}
+                )
+            decision_book_project = BuildDecisionBookProjects.filter_one(
+                BuildDecisionBookProjects.id == decision_book_project_person.build_decision_book_project_id,
+            ).data
+            if decision_book_project.is_completed:
+                raise BuildDecisionBookProjects.raise_http_exception(
+                    status_code="HTTP_403_FORBIDDEN",
+                    error_case="NOT_ALLOWED",
+                    message="Project decision book is closed. No modification is allowed",
+                    data={}
+                )
+            data_dict = data.excluded_dump()
+            data_dict["is_completed"] = True
+            data_dict["status_id"] = 1    # is completed status
+
+            build_parts_list = BuildParts.filter_all(
+                BuildParts.human_livable == True,
+                BuildParts.build_id == token_dict.selected_occupant.build_id,
+            ).data
+
+            decision_book_project_item = BuildDecisionBookItems.filter_one(
+                BuildDecisionBookItems.id == decision_book_project.build_decision_book_item_id
+            ).data
+
+            book_payment_dict = dict(
+                payment_plan_time_periods=str(),
+                build_decision_book_item_id=decision_book_project_item.id,
+                build_decision_book_item_uu_id=str(decision_book_project_item.uu_id),
+                currency=decision_book_project.currency,
+            )
+            payment_type = ApiEnumDropdown.get_debit_search(search_debit="DT-D")
+            for final_price in data.final_price_list:
+                for build_part_single in build_parts_list:
+                    local_date = BuildDecisionBookPayments.client_arrow.get(str(final_price["date"]))
+                    local_date = system_arrow.get(local_date)
+                    payment_amount = abs(float(final_price["price"])) * -1
+                    created_book_payment = BuildDecisionBookPayments.find_or_create(
+                        build_parts_id=build_part_single.id,
+                        build_parts_uu_id=str(build_part_single.uu_id),
+                        payment_amount=payment_amount,
+                        payment_types_id=payment_type.id,
+                        payment_types_uu_id=str(payment_type.uu_id),
+                        process_date=str(local_date),
+                        process_date_m=int(local_date.month),
+                        process_date_y=int(local_date.year),
+                        period_time=f"{local_date.year}-{str(local_date.month).zfill(2)}",
+                        **book_payment_dict,
+                    )
+                    created_book_payment.save_and_confirm()
+                return
+
+            updated_decision_book_project = decision_book_project.update(**data_dict)
+            updated_decision_book_project.save_and_confirm()
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=updated_decision_book_project,
+            )


 class ProjectDecisionBookPatchEvents(MethodToEvent):
@@ -38,5 +319,9 @@ class ProjectDecisionBookPatchEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_patch(cls, request, *args, **kwargs):
-        pass
+    def project_decision_book_patch(
+            cls,
+            data,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        return
--- a/api_events/events/decision_book/project_decision_book_items.py
+++ b/api_events/events/decision_book/project_decision_book_items.py
@@ -0,0 +1,19 @@
+from typing import Union
+
+from databases import (
+    BuildDecisionBookProjectItems,
+    BuildDecisionBookProjectPerson,
+)
+
+from api_validations.validations_request import (
+    InsertBuildDecisionBookProjectItems,
+    UpdateBuildDecisionBookProjectItems,
+    ListOptions,
+)
+
+from api_events.events.abstract_class import MethodToEvent, ActionsSchema
+from api_objects.auth.token_objects import EmployeeTokenObject, OccupantTokenObject
+from api_validations.core_response import AlchemyJsonResponse
+
+
+
--- a/api_events/events/decision_book/project_decision_book_person.py
+++ b/api_events/events/decision_book/project_decision_book_person.py
@@ -1,8 +1,57 @@
+from typing import Union
+
+from databases import (
+    BuildDecisionBookProjects,
+    BuildDecisionBookProjectPerson,
+)
+
+from api_validations.validations_request import (
+    InsertBuildDecisionBookProjectPerson,
+    UpdateBuildDecisionBookProjectPerson,
+    ListOptions,
+)
+
 from api_events.events.abstract_class import MethodToEvent, ActionsSchema
 from api_objects.auth.token_objects import EmployeeTokenObject, OccupantTokenObject
 from api_validations.core_response import AlchemyJsonResponse


+class ProjectDecisionBookPersonListEvents(MethodToEvent):
+
+    event_type = "LIST"
+
+    __event_keys__ = {
+        "7101b5ca-8bef-40f9-8b4d-646d9994e18f": "project_decision_book_person_list",
+    }
+
+    @classmethod
+    def project_decision_book_person_list(
+            cls,
+            data: ListOptions,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            project_person = BuildDecisionBookProjectPerson.filter_all(
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            )
+            decision_book_ids = [_.build_decision_book_project_id for _ in project_person.data]
+            decision_book_projects = BuildDecisionBookProjects.filter_all(
+                BuildDecisionBookProjects.build_decision_book_project_id.in_(decision_book_ids),
+            )
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_projects,
+            )
+
+
 class ProjectDecisionBookPersonCreateEvents(MethodToEvent):

    event_type = "CREATE"
@@ -12,8 +61,28 @@ class ProjectDecisionBookPersonCreateEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_create(cls, request, *args, **kwargs):
-        return
+    def project_decision_book_create(
+            cls,
+            data: InsertBuildDecisionBookProjectPerson,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            decision_book = BuildDecisionBookProjects.filter_one(
+                BuildDecisionBookProjects.build_decision_book_uu_id==data.get("build_decision_book_uu_id"),
+                BuildDecisionBookProjects.project_response_living_space_id==token_dict.selected_occupant.living_space_id,
+            )
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book,
+            )


 class ProjectDecisionBookPersonUpdateEvents(MethodToEvent):
@@ -25,8 +94,29 @@ class ProjectDecisionBookPersonUpdateEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_update(cls, request, *args, **kwargs):
-        return
+    def project_decision_book_update(
+            cls,
+            data: UpdateBuildDecisionBookProjectPerson,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            decision_book_project_person = BuildDecisionBookProjectPerson.filter_one(
+                BuildDecisionBookProjects.build_decision_book_project_uu_id == data.get("build_decision_book_uu_id"),
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            )
+
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_project_person,
+            )


 class ProjectDecisionBookPersonPatchEvents(MethodToEvent):
@@ -38,5 +128,26 @@ class ProjectDecisionBookPersonPatchEvents(MethodToEvent):
    }

    @classmethod
-    def project_decision_book_patch(cls, request, *args, **kwargs):
-        return
+    def project_decision_book_patch(
+            cls,
+            data,
+            token_dict: Union[EmployeeTokenObject, OccupantTokenObject],
+    ):
+        if isinstance(token_dict, EmployeeTokenObject):
+            raise BuildDecisionBookProjects.raise_http_exception(
+                status_code="HTTP_403_FORBIDDEN",
+                error_case="NOT_ALLOWED",
+                message="Employee cannot create project project decision book",
+                data={}
+            )
+        elif isinstance(token_dict, OccupantTokenObject):
+            decision_book_project_person = BuildDecisionBookProjectPerson.filter_one(
+                BuildDecisionBookProjects.build_decision_book_project_uu_id == data.get("build_decision_book_uu_id"),
+                BuildDecisionBookProjects.living_space_id == token_dict.selected_occupant.living_space_id,
+            )
+            return AlchemyJsonResponse(
+                status_code="HTTP_200_OK",
+                message="Project decision book created successfully",
+                result=decision_book_project_person,
+            )
+