diff --git a/backend/app/db/models/hubspot_deal_data.py b/backend/app/db/models/hubspot_deal_data.py index 2935f2bf..5104f377 100644 --- a/backend/app/db/models/hubspot_deal_data.py +++ b/backend/app/db/models/hubspot_deal_data.py @@ -82,6 +82,11 @@ class HubspotDealData(SQLModel, table=True): domna_survey_required: Optional[bool] = Field(default=None) domna_survey_date: Optional[datetime] = Field(default=None) + date_booking_made: Optional[datetime] = Field(default=None) + last_contact_date: Optional[datetime] = Field(default=None) + last_outbound_call: Optional[datetime] = Field(default=None) + last_outbound_email: Optional[datetime] = Field(default=None) + created_at: Optional[datetime] = Field( sa_column=Column( DateTime(timezone=True), diff --git a/etl/hubspot/hubspotClient.py b/etl/hubspot/hubspotClient.py index 1300b579..482ae460 100644 --- a/etl/hubspot/hubspotClient.py +++ b/etl/hubspot/hubspotClient.py @@ -347,6 +347,10 @@ class HubspotClient: "sent_to_iw_for_pricing", "osmosis_survey_required", "osmosis_survey_date", + "date_booking_made", + "last_contact_date", + "last_outbound_call", + "last_outbound_email", ], ) ) diff --git a/etl/hubspot/hubspotDataTodB.py b/etl/hubspot/hubspotDataTodB.py index ad5f5c33..042571da 100644 --- a/etl/hubspot/hubspotDataTodB.py +++ b/etl/hubspot/hubspotDataTodB.py @@ -293,6 +293,10 @@ class HubspotDataToDb: deal_data.get("osmosis_survey_required") ), "domna_survey_date": parse_hs_date(deal_data.get("osmosis_survey_date")), + "date_booking_made": parse_hs_date(deal_data.get("date_booking_made")), + "last_contact_date": parse_hs_date(deal_data.get("last_contact_date")), + "last_outbound_call": parse_hs_date(deal_data.get("last_outbound_call")), + "last_outbound_email": parse_hs_date(deal_data.get("last_outbound_email")), }.items(): setattr(existing, attr, value) @@ -391,6 +395,10 @@ class HubspotDataToDb: deal_data.get("osmosis_survey_required") ), domna_survey_date=parse_hs_date(deal_data.get("osmosis_survey_date")), + date_booking_made=parse_hs_date(deal_data.get("date_booking_made")), + last_contact_date=parse_hs_date(deal_data.get("last_contact_date")), + last_outbound_call=parse_hs_date(deal_data.get("last_outbound_call")), + last_outbound_email=parse_hs_date(deal_data.get("last_outbound_email")), ) def _handle_existing_photo_upload( diff --git a/etl/hubspot/hubspot_deal_differ.py b/etl/hubspot/hubspot_deal_differ.py index 9df456e6..40eef059 100644 --- a/etl/hubspot/hubspot_deal_differ.py +++ b/etl/hubspot/hubspot_deal_differ.py @@ -114,6 +114,10 @@ class HubspotDealDiffer: ("property_halted_date", "property_halted_date"), ("sent_to_iw_for_pricing", "sent_to_installer_for_pricing"), ("osmosis_survey_date", "domna_survey_date"), + ("date_booking_made", "date_booking_made"), + ("last_contact_date", "last_contact_date"), + ("last_outbound_call", "last_outbound_call"), + ("last_outbound_email", "last_outbound_email"), ] for hs_field, db_field in date_fields: