Add get_updated_contact_data()

Author: c-simpson

src/server/api/API_ingest/updated_data.py

@@ -0,0 +1,79 @@
+
+from sqlalchemy.orm import  sessionmaker
+from simple_salesforce import Salesforce
+from config import engine
+
+import structlog
+logger = structlog.get_logger()
+
+
+def get_updated_contact_data():
+    Session = sessionmaker(engine)
+
+    qry = """ -- Collect latest foster/volunteer dates
+        with ev_dates as 
+        (select 
+            person_id, 
+            max(case when event_type=1 then time else null end) adopt,
+            max(case when event_type=2 then time else null end) foster_out,
+           --  max(case when event_type=3 then time else null end) rto,
+            max(case when event_type=5 then time else null end) foster_return
+           
+        from 
+            sl_animal_events sla
+            left join sl_event_types sle on sle.id = sla.event_type
+            
+        where sle.id in (1,2,5)
+        group by person_id
+        order by person_id
+        )
+  
+
+    select json_agg (upd)  as "cd" from (
+            select
+            slsf.source_id as "contactId" ,  -- long salesforce string
+            slp.id   as  "personId" ,           -- short PAWS-local shelterluv id
+        
+            case
+                when 
+                    (extract(epoch from now())::bigint - foster_out < 365*86400)  -- foster out in last year 
+                    or (extract(epoch from now())::bigint - foster_return < 365*86400) -- foster return 
+                then 'Active'
+                else 'Inactive'
+            end  as "updatedVolunteerStatus" ,
+        
+            (to_timestamp(foster_out ) at time zone  'America/New_York')::date   as "updatedFosterStartDate",
+            (to_timestamp(foster_return ) at time zone 'America/New_York')::date  as "updatedFosterEndDate",
+
+            min(vs.from_date) as "updatedFirstVolunteerDate",
+            max(vs.from_date) as "updatedLastVolunteerDate"
+        -- ,    slc.source_id as sl_id, slc.matching_id,  vc.source_id as vc_id
+
+            
+        from 
+            ev_dates
+            left join pdp_contacts slc on slc.source_id = person_id::text and slc.source_type = 'shelterluvpeople'
+            left join pdp_contacts slsf on slsf.matching_id = slc.matching_id and slsf.source_type = 'salesforcecontacts'
+            left join shelterluvpeople slp on slp.internal_id = person_id::text
+            left join pdp_contacts vc on vc.matching_id = slc.matching_id and vc.source_type = 'volgistics'
+            left join volgisticsshifts vs on vs.volg_id::text = vc.source_id 
+
+    where 
+        slsf.source_id is not null
+
+        group by
+            slsf.source_id,
+            slp.id,
+            foster_out ,
+            foster_return
+        
+    ) upd ;
+
+
+    """
+
+    with Session() as session:
+        result = session.execute(qry)
+        sfdata = result.fetchone()[0]
+        logger.debug("Query for Salesforce update returned %d records", len(sfdata))
+        return sfdata