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

Work on importing person and membership data

Browse Source
This commit is contained in:
Scott Idem
2021-11-29 15:46:18 -05:00
parent 1cb0372009
commit 96a159c007
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
app/routers/importing.py
View File

@@ -403,6 +403,9 @@ async def ins_up_person_contact_address_user_data(
contact_id = person_rec.get('contact_id', None) contact_id = person_rec.get('contact_id', None)
address_id = person_rec.get('address_id', None) address_id = person_rec.get('address_id', None)
user_id = person_rec.get('user_id', None) user_id = person_rec.get('user_id', None)
# import_new_person(person_id=person_id, contact_id=contact_id, address=address_id, user_id=user_id)
person_data['id'] = person_id person_data['id'] = person_id
log.info(f'Found Person ID: {person_id} Contact ID: {contact_id} Address ID: {address_id} User ID: {user_id}') log.info(f'Found Person ID: {person_id} Contact ID: {contact_id} Address ID: {address_id} User ID: {user_id}')
@@ -812,7 +815,7 @@ async def ins_up_membership_person_data(
if external_id := record.get('external_id', None): pass if external_id := record.get('external_id', None): pass
else: else:
log.info('No external ID was found.') log.warning('No external ID was found.')
continue continue
if source_id := record.get('source_id', None): pass if source_id := record.get('source_id', None): pass
@@ -824,7 +827,7 @@ async def ins_up_membership_person_data(
else: else:
log.info('No email address was found.') log.info('No email address was found.')
continue continue
log.debug(f'External ID: {external_id}, Source ID {source_id}, Email: {email}') log.info(f'External ID: {external_id}, Source ID {source_id}, Email: {email}')
person_data = {} person_data = {}
if source_id: if source_id:
@@ -832,7 +835,7 @@ async def ins_up_membership_person_data(
else: else:
person_data['external_import_id'] = email person_data['external_import_id'] = email
external_import_id = person_data['external_import_id'] external_import_id = person_data['external_import_id']
log.info(external_import_id) log.debug(external_import_id)
if membership_type_name := record.get('membership_type', None): pass if membership_type_name := record.get('membership_type', None): pass
else: continue else: continue
@@ -861,6 +864,7 @@ async def ins_up_membership_person_data(
membership_person_id = person_rec.get('membership_person_id', None) membership_person_id = person_rec.get('membership_person_id', None)
log.info(f'Found membership_person_id: {membership_person_id}') log.info(f'Found membership_person_id: {membership_person_id}')
else: else:
log.warning(f'A person was not found with External ID: {external_id}')
continue continue
membership_person_data = {} membership_person_data = {}
@@ -915,6 +919,9 @@ async def ins_up_membership_person_data(
membership_person_data['level'] = 1 membership_person_data['level'] = 1
membership_type_person_data['level'] = 1 membership_type_person_data['level'] = 1
membership_person_data['enable'] = True
membership_type_person_data['enable'] = True
if membership_person_id: # Update the membership records if membership_person_id: # Update the membership records
membership_person_data['id'] = membership_person_id membership_person_data['id'] = membership_person_id
# sql_update() # UPDATE membership_person # sql_update() # UPDATE membership_person
@@ -991,7 +998,7 @@ async def ins_up_membership_person_data(
person_data_min['membership_type_person_id'] = membership_type_person_id person_data_min['membership_type_person_id'] = membership_type_person_id
person_data_min['membership_type_name'] = membership_type_name person_data_min['membership_type_name'] = membership_type_name
person_data_li.append(person_data_min) person_data_li.append(person_data_min)
log.debug(f"Record processed: {person_id} {record['email']}") log.debug(f"Record processed: {person_id} {record['email']} External ID: {external_id}")
# log.debug('*** *** *** *** END TEST RUN *** *** *** ***') # log.debug('*** *** *** *** END TEST RUN *** *** *** ***')
# break # break