diff --git a/app/methods/e_cvent_methods.py b/app/methods/e_cvent_methods.py index 821ac51..b8a9ae7 100644 --- a/app/methods/e_cvent_methods.py +++ b/app/methods/e_cvent_methods.py @@ -467,7 +467,7 @@ def create_update_aether_person( cvent_contact_obj: dict, account_id: str, person_id: str=None, - log_lvl: int = logging.INFO, # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL + log_lvl: int = logging.DEBUG, # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL ): log.setLevel(log_lvl) diff --git a/app/routers/c_idaa.py b/app/routers/c_idaa.py index 2754b59..bc3f3d9 100644 --- a/app/routers/c_idaa.py +++ b/app/routers/c_idaa.py @@ -100,12 +100,19 @@ async def refresh_membership_status( log.warning(f'The SQL UPDATE of user table records failed for not members') + # sql = f""" + # UPDATE person + # INNER JOIN membership_person ON person.id = membership_person.person_id + # SET person.enable = 1, person.group = 'pending_member' + # WHERE person.account_id = 13 AND membership_person.end_on >= NOW() + # AND (person.external_sys_id IS NULL OR person.external_sys_id = ''); + # """ sql = f""" UPDATE person INNER JOIN membership_person ON person.id = membership_person.person_id SET person.enable = 1, person.group = 'pending_member' WHERE person.account_id = 13 AND membership_person.end_on >= NOW() - AND (person.external_sys_id IS NULL OR person.external_sys_id = ''); + AND person.status = 'pending'; """ if person_update_result := sql_update(sql=sql): # Pull out IDs of existing person record @@ -118,7 +125,7 @@ async def refresh_membership_status( INNER JOIN membership_person ON person.id = membership_person.person_id SET person.enable = 1, person.group = 'current_member' WHERE person.account_id = 13 AND membership_person.end_on >= NOW() - AND (person.external_sys_id IS NOT NULL AND person.external_sys_id != ''); + AND (person.status IS NULL OR person.status = 'approved'); """ if person_update_result := sql_update(sql=sql): # Pull out IDs of existing person record