Scott.Idem/OSIT-AE-API-FastAPI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Work on ISHLT Impexium importing

Browse Source
This commit is contained in:
Scott Idem
2022-04-15 18:25:06 -04:00
parent 789d7372d9
commit a2e5f804d6
6 changed files with 303 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
app/routers/e_impexium.py
View File

@@ -22,7 +22,7 @@ router = APIRouter()
# ### BEGIN ### API Impexium ### event_import_reg() ###
# Updated 2021-10-07
# Updated 2022-04-15
@router.get('/event/{e_impexium_event_id}/import_reg', response_model=Resp_Body_Base)
async def event_import_reg(
e_impexium_event_id: str = Query(..., min_length=11, max_length=22), # For ISHLT: 42_AM (2022-04); EX22_AM (2022-04); 41V_2 (2021-04)
@@ -70,18 +70,24 @@ async def event_import_reg(
# Creating an external ID from the Impexium record number and registration number. Very explicitly converting each number to a string before joining, just in case.
external_id_old = str(event_registrant.get('recordNumber'))+':'+str(event_registrant.get('registrationNumber'))
external_id_new = str(e_impexium_event_id)+':'+str(event_registrant.get('recordNumber'))+':'+str(event_registrant.get('registrationNumber'))
external_id_v2 = str(e_impexium_event_id)+':'+str(event_registrant.get('recordNumber'))+':'+str(event_registrant.get('registrationNumber'))
external_id_v3 = str(e_impexium_event_id)+':'+str(event_registrant.get('recordNumber'))
external_sys_id = event_registrant.get('id') # Impexium UUID for person
external_reg_id = event_registrant.get('recordNumber') # Impexium record number for a registration (guest should match)
event_person_summary_data = {}
event_person_summary_data['external_id'] = external_id_new
event_person_summary_data['external_id'] = external_id_v3
event_person_data = {}
event_person_data['enable'] = True
event_person_data['account_id'] = account_id
event_person_data['event_id'] = event_id
event_person_data['external_id'] = external_id_new
event_person_data['external_id'] = external_id_v3
event_person_data['external_sys_id'] = external_sys_id
event_person_data['external_reg_id'] = external_reg_id
# event_person_data['external_id_old'] = external_id_old
email = None
@@ -122,6 +128,7 @@ async def event_import_reg(
event_person_profile_data = {}
event_person_profile_data['enable'] = True
event_person_profile_data['pronouns'] = event_registrant.get('gender')
event_person_profile_data['informal_name'] = event_registrant.get('preferredFirstName')
@@ -136,8 +143,8 @@ async def event_import_reg(
else:
event_person_profile_data['professional_title'] = None # event_registrant.get('title') # Should this be None if no degrees found above???
event_person_profile_data['display_name'] = event_registrant.get('badgeName')
event_person_summary_data['display_name'] = event_registrant.get('badgeName')
event_person_profile_data['full_name'] = event_registrant.get('badgeName')
event_person_summary_data['full_name'] = event_registrant.get('badgeName')
if organization_name:
event_person_profile_data['affiliations'] = organization_name # Ideally should be organization_name for ISHLT
@@ -150,9 +157,11 @@ async def event_import_reg(
event_person_data['event_person_profile'] = event_person_profile_data
event_badge_data = {}
event_badge_data['enable'] = True
event_badge_data['event_id'] = event_id
event_badge_data['external_id'] = external_id_new
event_badge_data['external_id'] = external_id_v3
event_badge_data['external_sys_id'] = external_sys_id
event_badge_data['external_reg_id'] = external_reg_id
# event_badge_data['external_id_old'] = external_id_old
if reg_type_code := event_registrant.get('registrantTypeCode'):
@@ -182,15 +191,36 @@ async def event_import_reg(
else:
event_badge_data['badge_type'] = event_registrant.get('registrantTypeName')
if custom_fields := event_registrant.get('itemizedCustomFields'):
if isinstance(custom_fields, list):
log.info('Found list of custom fields for an exhibitor. Searching for "exhibitor_reg_type')
for field in custom_fields:
if field.get('name') == 'registration_type':
event_badge_data['registration_type_code'] = field.get('name')
event_badge_data['registration_type'] = field.get('value')
break
else: log.info('Found custom fields section, but no list was found.')
else:
log.warning('The custom fields were not found at all. Are the "details" being included?')
event_badge_data['event_badge_template_id'] = 3
elif e_impexium_event_id == '42_AM':
if not reg_type_code and event_registrant.get('guestOfRecordNumber'):
event_badge_data['badge_type_code'] = 'GUEST'
event_badge_data['badge_type'] = 'Guest'
event_badge_data['registration_type_code'] = 'GUEST'
event_badge_data['registration_type'] = 'Guest'
else:
event_badge_data['badge_type_code'] = 'UNKNOWN'
event_badge_data['badge_type'] = 'Unknown Type'
event_badge_data['registration_type_code'] = 'UNKNOWN'
event_badge_data['registration_type'] = 'Unknown Type'
event_badge_data['event_badge_template_id'] = 3
elif e_impexium_event_id == 'EX22_AM':
event_badge_data['badge_type_code'] = 'EX'
event_badge_data['badge_type'] = 'Exhibit Staff'
@@ -206,35 +236,63 @@ async def event_import_reg(
elif field.get('value') == 'Exhibitor All Access ':
event_badge_data['badge_type_code'] = 'EXALL'
event_badge_data['badge_type'] = 'Exhibitor All Access'
event_badge_data['registration_type_code'] = field.get('value')
event_badge_data['registration_type'] = field.get('value')
break
else: log.info('Found custom fields section, but no list was found.')
else:
log.warning('The custom fields were not found at all. Are the "details" being included?')
event_badge_data['event_badge_template_id'] = 3
elif e_impexium_event_id == '2022HEART':
if not reg_type_code and event_registrant.get('guestOfRecordNumber'):
event_badge_data['badge_type_code'] = 'GUEST'
event_badge_data['badge_type'] = 'Guest'
event_badge_data['registration_type_code'] = 'GUEST'
event_badge_data['registration_type'] = 'Guest'
else:
event_badge_data['badge_type_code'] = 'HEART'
event_badge_data['badge_type'] = 'HFTX Core'
event_badge_data['registration_type_code'] = 'HEART'
event_badge_data['registration_type'] = 'HFTX Core'
event_badge_data['event_badge_template_id'] = 5
# event_badge_data['registration_type_code'] = event_registrant.get('registrantTypeCode')
# event_badge_data['registration_type'] = event_registrant.get('registrantTypeName')
elif e_impexium_event_id == '2022LUNG':
if not reg_type_code and event_registrant.get('guestOfRecordNumber'):
event_badge_data['badge_type_code'] = 'GUEST'
event_badge_data['badge_type'] = 'Guest'
event_badge_data['badge_type_code'] = 'GUEST'
event_badge_data['badge_type'] = 'Guest'
else:
event_badge_data['badge_type_code'] = 'LUNG'
event_badge_data['badge_type'] = 'LTX Core'
event_badge_data['registration_type_code'] = 'LUNG'
event_badge_data['registration_type'] = 'LTX Core'
event_badge_data['event_badge_template_id'] = 5
# event_badge_data['registration_type_code'] = event_registrant.get('registrantTypeCode')
# event_badge_data['registration_type'] = event_registrant.get('registrantTypeName')
else:
event_badge_data['badge_type_code'] = 'UNKNOWN'
event_badge_data['badge_type'] = 'Unknown Type'
event_badge_data['event_badge_template_id'] = 3
event_badge_data['registration_type_code'] = event_registrant.get('registrantTypeCode')
event_badge_data['registration_type'] = event_registrant.get('registrantTypeName')
event_badge_data['member_type_code'] = event_registrant.get('customerType') # Using this as the member_type
event_badge_data['registration_type_code'] = event_registrant.get('registrantTypeCode')
event_badge_data['registration_type'] = event_registrant.get('registrantTypeName')
event_badge_data['pronouns'] = event_registrant.get('gender')
event_badge_data['informal_name'] = event_registrant.get('preferredFirstName')
@@ -250,7 +308,7 @@ async def event_import_reg(
else:
event_badge_data['professional_title'] = None # event_registrant.get('title') # Should this be None if no degrees found above???
event_badge_data['display_name'] = event_registrant.get('badgeName')
event_badge_data['full_name'] = event_registrant.get('badgeName')
if organization_name:
event_badge_data['affiliations'] = organization_name # Ideally should be organization_name for ISHLT
@@ -369,7 +427,7 @@ async def event_import_reg(
# event_badge_data['professional_title'] = event_registrant.get('title')
# event_badge_data['display_name'] = event_registrant.get('badgeName')
# event_badge_data['full_name'] = event_registrant.get('badgeName')
# event_badge_data['affiliations'] = event_registrant.get('badgeOrganization')

83
app/routers/event_exhibit_tracking.py
View File

@@ -9,6 +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.event_badge_methods import load_event_badge_obj
from app.methods.event_exhibit_tracking_methods import create_event_exhibit_tracking_obj, remove_event_exhibit_tracking_obj, get_event_exhibit_tracking_rec_list, load_event_exhibit_tracking_obj, update_event_exhibit_tracking_obj
from app.models.event_exhibit_tracking_models import Event_Exhibit_Tracking_Base
@@ -301,3 +302,85 @@ def delete_event_exhibit_tracking_obj(
log.warning('Likely bad request')
return mk_resp(data=False, status_code=400, response=response) # Bad Request
# ### END ### API Event Exhibit Tracking ### delete_event_exhibit_tracking_obj() ###
# ### BEGIN ### API Event Exhibit Tracking ### lookup_event_badge_id_tracking() ###
# Updated 2022-04-15
@router.get('/e/event/exhibit/lookup_id_for_tracking', response_model=Resp_Body_Base)
async def lookup_event_badge_id_tracking(
event_exhibit_id: str = Query(..., min_length=11, max_length=22),
event_badge_id: str = Query(..., min_length=11, max_length=22),
# add: bool = False,
remove: bool = False,
commons: Common_Route_Params = Depends(common_route_params),
):
log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
log.debug(locals())
if event_exhibit_id := redis_lookup_id_random(record_id_random=event_exhibit_id, table_name='event_exhibit'): pass
else: return mk_resp(data=None, status_code=404, response=commons.response, status_message='The Event Exhibit ID was invalid or not found.')
if event_badge_id := redis_lookup_id_random(record_id_random=event_badge_id, table_name='event_badge'): pass
else: return mk_resp(data=None, status_code=404, response=commons.response, status_message='The Event Badge ID was invalid or not found.')
if event_badge_obj_result := load_event_badge_obj(
event_badge_id = event_badge_id,
return_basic_model = True):
event_badge_obj = event_badge_obj_result
event_badge_id_random = event_badge_obj.id_random
log.info(f'Event Badge ID found: {event_badge_id_random}')
log.debug(event_badge_obj)
event_exhibit_tracking_data = {}
if event_badge_obj.allow_tracking is True:
event_exhibit_tracking_data['hide'] = False
else:
event_exhibit_tracking_data['hide'] = True
event_exhibit_tracking_data['notes'] = 'Added by external API'
if get_event_exhibit_tracking_rec_list_result := get_event_exhibit_tracking_rec_list(
event_exhibit_id = event_exhibit_id,
event_badge_id = event_badge_id,
hidden = 'all',
limit = 1,
):
event_exhibit_tracking_rec = get_event_exhibit_tracking_rec_list_result[0]
event_exhibit_tracking_id = event_exhibit_tracking_rec.get('event_exhibit_tracking_id')
if update_event_exhibit_tracking_obj_result := update_event_exhibit_tracking_obj(
event_exhibit_tracking_id = event_exhibit_tracking_id,
event_exhibit_tracking_dict_obj = event_exhibit_tracking_data,
):
log.info(f'Updated Event Exhibit Tracking ID: {event_exhibit_tracking_id}')
else:
log.info(f'Event Exhibit Tracking ID not updated for Event Badge ID: {event_badge_id}')
log.debug(update_event_exhibit_tracking_obj_result)
else:
if create_event_exhibit_tracking_obj_result := create_event_exhibit_tracking_obj(
event_exhibit_id = event_exhibit_id,
event_exhibit_tracking_dict_obj = event_exhibit_tracking_data,
event_badge_id = event_badge_id
):
event_exhibit_tracking_id = create_event_exhibit_tracking_obj_result
# event_exhibit_tracking_id_random = event_exhibit_tracking_obj.id_random
log.info(f'New Event Exhibit Tracking ID: {event_exhibit_tracking_id}')
# log.debug(event_exhibit_tracking_id)
else:
log.info(f'New Event Exhibit Tracking ID not created for Event Badge ID: {event_badge_id}')
log.debug(create_event_exhibit_tracking_obj_result)
if event_badge_obj.allow_tracking is True:
return mk_resp(data=event_badge_obj, response=commons.response) # Success
else:
log.info('Tracking is now allowed')
return mk_resp(data=None, status_code=404, response=commons.response, status_message='The Event Badge could not be returned. They have not opted in to lead retrieval at this time.') # Not Found
elif event_badge_obj_result is None: # None
log.info('No results')
return mk_resp(data=None, status_code=404, response=commons.response, status_message='The Event Badge could not be returned. They may not have opted in to lead retrieval at this time.') # Not Found
else:
log.warning('Likely bad request')
return mk_resp(data=False, status_code=400, response=commons.response) # Bad Request
# ### END ### API Event Exhibit Tracking ###