Skip to content

Commit ba297d0

Browse files
committed
remove donation retrieval from the automated ingest process
1 parent 6516d9b commit ba297d0

File tree

1 file changed

+1
-21
lines changed

1 file changed

+1
-21
lines changed

src/server/api/API_ingest/salesforce_api_handler.py

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from sqlalchemy.orm import sessionmaker
44
from simple_salesforce import Salesforce
55
from config import engine
6-
from models import SalesForceContacts, SalesforceDonations
6+
from models import SalesForceContacts
77

88
def ingest_data():
99

@@ -35,24 +35,4 @@ def ingest_data():
3535
if not done:
3636
results = sf.query_more(results['nextRecordsUrl'])
3737

38-
39-
40-
session.execute("TRUNCATE TABLE salesforcedonations")
41-
results = sf.query("SELECT Opportunity_ID_18__c, npe03__Recurring_Donation__c, Opportunity.Account.Name, Contact_ID_18__c, Amount, CloseDate, Type, Campaign.Name FROM Opportunity")
42-
done = False
43-
while not done:
44-
for row in results['records']:
45-
account_name = row['Account']['Name'] if row['Account'] is not None else None
46-
donation = SalesforceDonations(opp_id=row['Opportunity_ID_18__c'],
47-
recurring_donor=False if row['npe03__Recurring_Donation__c'] is None else True,
48-
primary_contact= account_name,
49-
contact_id=row['Contact_ID_18__c'],
50-
amount=row['Amount'],
51-
close_date=row['CloseDate'],
52-
donation_type=row['Type'])
53-
session.add(donation)
54-
done = results['done']
55-
if not done:
56-
results = sf.query_more(results['nextRecordsUrl'])
57-
5838
session.commit()

0 commit comments

Comments
 (0)