Work on membership related

2022-01-04 19:01:02 -05:00
parent bf58944fda
commit 3cfc8a69dc
4 changed files with 364 additions and 39 deletions
--- a/app/routers/membership_person.py
+++ b/app/routers/membership_person.py
@@ -9,7 +9,7 @@ from app.db_sql import sql_insert, sql_update, sql_insert_or_update, sql_select,

 from app.routers.api_crud import delete_obj_template, get_obj_template, get_obj_li_template, patch_obj_template, post_obj_template

-from app.methods.membership_person_methods import get_membership_person_rec_list, load_membership_person_obj
+from app.methods.membership_person_methods import create_membership_person_obj, get_membership_person_rec_list, load_membership_person_obj, update_membership_person_obj

 from app.models.membership_person_models import Membership_Person_Base
 from app.models.response_models import Resp_Body_Base, mk_resp
@@ -42,6 +42,74 @@ async def post_membership_person_obj(
    return result


+# ### BEGIN ### API Membership Person ### post_membership_person_obj_create() ###
+# Using create_membership_person_obj()
+# Updated 2022-01-04
+@router.post('/membership/person/create', response_model=Resp_Body_Base)
+async def post_membership_person_obj_create(
+        membership_person_obj: Membership_Person_Base,
+        create_sub_obj: bool = False,
+        fail_any: bool = True, # Fail if any thing goes wrong for sub objects
+
+        enabled: str = 'enabled', # For now this covers any included objects or object lists
+        inc_membership_group_person_list: bool = False,
+        inc_membership_type_person: bool = False,
+        inc_contact: bool = False,
+        return_obj: bool = True,
+        limit: int = 50,
+        by_alias: bool = True,
+        # include: Optional[list] = [],
+        # exclude: Optional[list] = [],
+        exclude_unset: Optional[bool] = True,
+        # exclude_none: Optional[bool] = True,
+
+        x_account_id: str = Header(...),
+        response: Response = Response,
+        ):
+    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
+    log.debug(locals())
+
+    person_id = membership_person_obj.person_id
+    person_id_random = membership_person_obj.person_id_random
+    log.debug(f'Person ID: {person_id}, Person ID Random: {person_id_random}')
+
+    if create_membership_person_obj_result := create_membership_person_obj(
+            account_id = x_account_id,
+            person_id = person_id,
+            membership_person_dict_obj = membership_person_obj,
+            # process_contact = process_contact,
+            # process_organization = process_organization,
+            # process_user = process_user,
+            ): pass
+    else: return mk_resp(data=False, status_code=400, response=response, status_message='The membership person was not created. Check the field names and data types.')
+
+    if isinstance(create_membership_person_obj_result, int):
+        membership_person_id = create_membership_person_obj_result
+        if return_obj:
+            if load_membership_person_obj_result := load_membership_person_obj(
+                    membership_person_id = membership_person_id,
+                    enabled = enabled,
+                    # inc_address = inc_address,
+                    # inc_contact = inc_contact,
+                    # inc_organization = inc_organization,
+                    # inc_user = inc_user,
+                    ):
+                data = load_membership_person_obj_result
+            else:
+                data = False
+                return mk_resp(data=data, response=response, status_message='The membership person was probably created, but there was a problem returning the data.')
+        else:
+            membership_person_id = create_membership_person_obj_result
+            membership_person_id_random = get_id_random(record_id=membership_person_id, table_name='membership_person')
+            data = {}
+            data['membership_person_id'] = membership_person_id
+            data['membership_person_id_random'] = membership_person_id_random
+        return mk_resp(data=data, response=response, status_message='The membership person was created.')
+    else:
+        return mk_resp(data=False, status_code=400, response=response, status_message='The result from trying to create a membership person was unexpected.')
+# ### BEGIN ### API Membership Person ### post_membership_person_obj_create() ###
+
+
@router.patch('/membership/person/{obj_id}', response_model=Resp_Body_Base)
 async def patch_membership_person_obj(
        obj_id: str = Query(..., min_length=1, max_length=22),
@@ -70,6 +138,77 @@ async def patch_membership_person_obj(
    return result


+# ### BEGIN ### API Membership Person ### patch_membership_person_obj_update() ###
+# Using update_membership_person_obj()
+# Updated 2022-01-04
+@router.patch('/membership/person/{membership_person_id}/update', response_model=Resp_Body_Base)
+async def patch_membership_person_obj_update(
+        membership_person_obj: Membership_Person_Base,
+        membership_person_id: Optional[str] = Query(None, min_length=11, max_length=22),
+        create_sub_obj: bool = False,
+        fail_any: bool = True, # Fail if any thing goes wrong for sub objects
+
+        enabled: str = 'enabled', # For now this covers any included objects or object lists
+        inc_membership_group_person_list: bool = False,
+        inc_membership_type_person: bool = False,
+        inc_contact: bool = False,
+        return_obj: bool = True,
+        limit: int = 50,
+        by_alias: bool = True,
+        # include: Optional[list] = [],
+        # exclude: Optional[list] = [],
+        exclude_unset: Optional[bool] = True,
+        # exclude_none: Optional[bool] = True,
+
+        x_account_id: str = Header(...),
+        response: Response = Response,
+        ):
+    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
+    log.debug(locals())
+
+    if account_id := redis_lookup_id_random(record_id_random=x_account_id, table_name='account'): pass
+    else: return mk_resp(data=False, status_code=404, response=response) # Not Found
+
+    membership_person_id_random = membership_person_id # This is used later for the response data
+    if membership_person_id := redis_lookup_id_random(record_id_random=membership_person_id, table_name='membership_person'): pass
+    else: return mk_resp(data=False, status_code=404, response=response) # Not Found
+
+    log.debug(f'Membership Person ID: {membership_person_id}')
+
+    if update_membership_person_obj_result := update_membership_person_obj(
+            membership_person_id = membership_person_id,
+            membership_person_dict_obj = membership_person_obj,
+            # process_contact = process_contact,
+            # process_organization = process_organization,
+            # process_user = process_user,
+            ): pass
+    else: return mk_resp(data=False, status_code=400, response=response, status_message='The membership person was not updated. Check the field names and data types.')
+
+    if update_membership_person_obj_result:
+        if return_obj:
+            if load_membership_person_obj_result := load_membership_person_obj(
+                    membership_person_id = membership_person_id,
+                    enabled = enabled,
+                    # inc_address = inc_address,
+                    # inc_contact = inc_contact,
+                    # inc_organization = inc_organization,
+                    # inc_user = inc_user,
+                    ):
+                data = load_membership_person_obj_result
+            else:
+                data = False
+                return mk_resp(data=data, response=response, status_message='The membership person was probably updated, but there was a problem returning the data.')
+        else:
+            # membership_person_id_random = get_id_random(record_id=membership_person_id, table_name='membership_person')
+            data = {}
+            data['membership_person_id'] = membership_person_id
+            data['membership_person_id_random'] = membership_person_id_random
+        return mk_resp(data=data, response=response, status_message='The membership person was updated.')
+    else:
+        return mk_resp(data=False, status_code=400, response=response, status_message='The result from trying to update a membership person was unexpected.')
+# ### BEGIN ### API Membership Person ### patch_membership_person_obj_update() ###
+
+
@router.get('/membership/person/list', response_model=Resp_Body_Base)
 async def get_membership_person_obj_li(
        for_obj_type: Optional[str] = Query(None, min_length=2, max_length=50),