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

Updates for Cvent and IDAA custom status field

Browse Source
This commit is contained in:
Scott Idem
2022-03-15 17:33:34 -04:00
parent 655ba409b4
commit efb0a950d5
2 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/methods/e_cvent_methods.py
View File

@@ -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)

11
app/routers/c_idaa.py
View File

@@ -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