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

Work on import from Impexium for ISHLT with mutliple events.

Browse Source
This commit is contained in:
Scott Idem
2022-03-21 14:25:20 -04:00
parent 44898fbfd3
commit 0fa04710ff
4 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/methods/e_impexium_methods.py
View File

@@ -28,7 +28,7 @@ api['headers'] = { 'Content-Type': 'application/json;charset=UTF-8' }
# Updated 2022-02-18 # Updated 2022-02-18
@logger_reset @logger_reset
def get_access_token(): def get_access_token():
log.setLevel(logging.INFO) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
log.debug(locals()) log.debug(locals())
log.debug(f'App data:\n{app}') log.debug(f'App data:\n{app}')
@@ -64,7 +64,7 @@ def get_access_token():
# Updated 2022-02-18 # Updated 2022-02-18
@logger_reset @logger_reset
def authenticate(): def authenticate():
log.setLevel(logging.INFO) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
log.debug(locals()) log.debug(locals())
result = get_access_token() result = get_access_token()

2
app/methods/event_person_methods.py
View File

@@ -403,7 +403,7 @@ def create_update_event_person_obj_v4(
event_person_obj.event_id = event_id event_person_obj.event_id = event_id
log.debug(event_person_obj) log.debug(event_person_obj)
event_person_dict = event_person_obj.dict(by_alias=False, exclude_defaults=False, exclude_unset=True, exclude={'event_badge', 'event_person_profile', 'event_registration', 'created_on', 'updated_on'}) event_person_dict = event_person_obj.dict(by_alias=False, exclude_defaults=False, exclude_unset=True, exclude={'event_badge', 'event_person_profile', 'event_registration', 'created_on', 'updated_on', 'external_id_old'})
# ### SECTION ### Process data # ### SECTION ### Process data
if not event_badge_id: if not event_badge_id:

2
app/methods/event_person_profile_methods.py
View File

@@ -144,7 +144,7 @@ def create_update_event_person_profile_obj_v4(
event_person_profile_obj.id = event_person_profile_id event_person_profile_obj.id = event_person_profile_id
log.debug(event_person_profile_obj) log.debug(event_person_profile_obj)
event_person_profile_dict = event_person_profile_obj.dict(by_alias=False, exclude_defaults=False, exclude_unset=True, exclude={'account_id', 'account_id_random', 'contact', 'event_cfg', 'event_id', 'event_id_random', 'event_person_id', 'event_person_id_random', 'organization', 'created_on', 'updated_on'}) event_person_profile_dict = event_person_profile_obj.dict(by_alias=False, exclude_defaults=False, exclude_unset=True, exclude={'account_id', 'account_id_random', 'contact', 'event_cfg', 'event_id', 'event_id_random', 'event_person_id', 'event_person_id_random', 'organization', 'created_on', 'updated_on', 'external_id_old'})
# ### SECTION ### Process data # ### SECTION ### Process data
contact_id = None contact_id = None

11
app/routers/e_impexium.py
View File

@@ -56,12 +56,14 @@ async def event_import_reg(
log.debug(event_registrant) log.debug(event_registrant)
# 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. # 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 = str(event_registrant.get('recordNumber'))+':'+str(event_registrant.get('registrationNumber')) 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'))
event_person_data = {} event_person_data = {}
event_person_data['account_id'] = account_id event_person_data['account_id'] = account_id
event_person_data['event_id'] = event_id event_person_data['event_id'] = event_id
event_person_data['external_id'] = external_id event_person_data['external_id'] = external_id_new
event_person_data['external_id_old'] = external_id_old
email = None email = None
if details: if details:
@@ -92,7 +94,8 @@ async def event_import_reg(
event_badge_data = {} event_badge_data = {}
event_badge_data['event_id'] = event_id event_badge_data['event_id'] = event_id
event_badge_data['external_id'] = external_id event_badge_data['external_id'] = external_id_new
event_badge_data['external_id_old'] = external_id_old
if reg_type_code := event_registrant.get('registrantTypeCode'): if reg_type_code := event_registrant.get('registrantTypeCode'):
event_badge_data['badge_type_code'] = event_registrant.get('registrantTypeCode') # Using this as the badge_type event_badge_data['badge_type_code'] = event_registrant.get('registrantTypeCode') # Using this as the badge_type
@@ -202,7 +205,7 @@ async def event_import_reg(
SELECT id AS event_person_id, id_random AS event_person_id_random, external_id AS event_person_external_id, event_badge_id AS event_badge_id, event_person_profile_id AS event_person_profile_id SELECT id AS event_person_id, id_random AS event_person_id_random, external_id AS event_person_external_id, event_badge_id AS event_badge_id, event_person_profile_id AS event_person_profile_id
FROM `event_person` AS `event_person` FROM `event_person` AS `event_person`
WHERE event_person.event_id = :event_id WHERE event_person.event_id = :event_id
AND event_person.external_id = :external_id AND event_person.external_id = :external_id_old
/*LIMIT 1*/; /*LIMIT 1*/;
""" """