diff --git a/app/routers/importing.py b/app/routers/importing.py index 3602d7c..90da641 100644 --- a/app/routers/importing.py +++ b/app/routers/importing.py @@ -403,6 +403,9 @@ async def ins_up_person_contact_address_user_data( contact_id = person_rec.get('contact_id', None) address_id = person_rec.get('address_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 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 else: - log.info('No external ID was found.') + log.warning('No external ID was found.') continue if source_id := record.get('source_id', None): pass @@ -824,7 +827,7 @@ async def ins_up_membership_person_data( else: log.info('No email address was found.') 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 = {} if source_id: @@ -832,7 +835,7 @@ async def ins_up_membership_person_data( else: person_data['external_import_id'] = email 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 else: continue @@ -861,6 +864,7 @@ async def ins_up_membership_person_data( membership_person_id = person_rec.get('membership_person_id', None) log.info(f'Found membership_person_id: {membership_person_id}') else: + log.warning(f'A person was not found with External ID: {external_id}') continue membership_person_data = {} @@ -915,6 +919,9 @@ async def ins_up_membership_person_data( membership_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 membership_person_data['id'] = membership_person_id # 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_name'] = membership_type_name 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 *** *** *** ***') # break