From c3d872fff196282cc059211a32172e83795d73a5 Mon Sep 17 00:00:00 2001 From: Vernon Keenan Date: Tue, 19 Jan 2021 09:45:58 -0800 Subject: [PATCH] debug --- rules/new-developer.go | 192 ++++++++++++++++++++++++++++++++++++++--- rules/new-lead.go | 68 +++++++++++++-- 2 files changed, 241 insertions(+), 19 deletions(-) diff --git a/rules/new-developer.go b/rules/new-developer.go index 1b46107..ec782d6 100644 --- a/rules/new-developer.go +++ b/rules/new-developer.go @@ -11,12 +11,24 @@ import ( // NewDeveloperWrapper wraps a contact, account, payment method and a user identifier (app.User) type NewDeveloperWrapper struct { - Contact crm_models.Contact - Account crm_models.Account - PaymentMethod ops_models.PaymentMethod - APIKey string - SagaID string - SagaType string + AccountName string + BillingStreet string + BillingCity string + BillingState string + BillingPostalCode string + Company string + Description string + Email string + FirstName string + LastName string + MobilePhone string + Name string + Phone string + Title string + Website string + APIKey string + SagaID string + SagaType string } // NewDeveloperWorkflow is a Temporal workflow @@ -30,7 +42,48 @@ func NewDeveloperWorkflow( err := workflow.ExecuteActivity(ctx, StoreContactActivity, &app.ContactChannelWrapper{ - Obj: w.Contact, + Obj: crm_models.Contact{ + AccountID: "", + AssistantName: "", + AssistantPhone: "", + BirthDate: "", + Department: "", + Description: w.Description, + DoNotCall: false, + Email: w.Email, + EmailBounceDate: "", + EmailBouncedReason: "", + EnrollmentStatus: "", + Fax: "", + FirstName: w.FirstName, + HasOptedOutOfEmail: false, + HasOptedOutOfFax: false, + HomePhone: "", + IsEmailBounced: false, + IsProvisioned: false, + LastName: w.LastName, + LeadSource: "", + Level: "", + LinkedIn: "", + MailingAddress: &crm_models.Address{}, + MailingLists: "", + MobilePhone: w.MobilePhone, + Name: w.Name, + OtherAddress: &crm_models.Address{}, + OtherPhone: "", + OwnerID: "", + PersonalEmail: "", + Phone: w.Phone, + PhotoURL: "", + RecruitingStatus: "", + Ref: "", + ReportsToID: "", + Salutation: "", + Status: "", + TenantID: "", + Title: w.Title, + Type: "", + }, APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, @@ -41,7 +94,90 @@ func NewDeveloperWorkflow( err = workflow.ExecuteActivity(ctx, StoreAccountActivity, &app.AccountChannelWrapper{ - Obj: w.Account, + Obj: crm_models.Account{ + AccountNumber: "", + AccountSource: "", + Active: false, + AdministrativeLevel: "", + Amount: 0, + AmountInvoiced: 0, + AmountPaid: 0, + AnnualRevenue: 0, + Balance: 0, + BillingAddress: &crm_models.Address{City: w.BillingCity, Street: w.BillingStreet, State: w.BillingState, PostalCode: w.BillingPostalCode}, + BillingContactID: "", + BillingPreference: "", + BusinessAddress: &crm_models.Address{}, + CannabisCustomer: false, + ChannelProgramLevelName: "", + ChannelProgramName: "", + ClientEndDate: "", + ClientStartDate: "", + CompanyID: "", + CoordinateID: "", + CustomerID: "", + CustomerPriority: "", + DBA: "", + DUNSNumber: "", + DandBCompanyID: "", + DefaultAddress: &crm_models.Address{}, + DefaultBackendID: "", + DefaultDeliveryContactID: "", + DefaultEndUserID: "", + Description: w.Description, + EIN: "", + Email: w.Email, + EnrollmentStatus: "", + Fax: "", + ISPCustomer: false, + Industry: "", + IsCustomerPortal: false, + IsPartner: false, + MSPCustomer: false, + NAICSCode: "", + NAICSDesc: "", + Name: w.AccountName, + NumberOfEmployees: 0, + NumberOfLocations: 0, + OpenCharges: 0, + OrderContactID: "", + OrderEmail: "", + OwnerID: "", + Ownership: "", + ParentFK: "", + ParentID: "", + Phone: "", + PlaceID: "", + PreparerID: "", + Rating: "", + RatingEngineID: "", + Ref: "", + RevenueBase: 0, + RevenueNet: 0, + RevenueNotTaxable: 0, + SIC: "", + SICDesc: "", + ShippingAddress: &crm_models.Address{}, + ShippingCensusTract: "", + ShippingConactID: "", + ShippingCounty: "", + Site: "", + Status: "", + TaxExemption: "", + TaxOnTax: 0, + TelecomCustomer: false, + TenantID: "", + TickerSymbol: "", + TradeStyle: "", + Type: "", + UnappliedPayments: 0, + UnitBase: 0, + UpsellOpportunity: "", + WHMCSClientID: 0, + Website: "", + XeroContactID: "", + YearStarted: "", + }, APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, @@ -52,7 +188,34 @@ func NewDeveloperWorkflow( err = workflow.ExecuteActivity(ctx, StorePaymentMethodActivity, &app.PaymentMethodChannelWrapper{ - Obj: w.PaymentMethod, + Obj: ops_models.PaymentMethod{ + AccountID: "todo fix this", + AchAccountType: "", + AchBankAccount: "", + AchRouting: "", + Active: false, + Autopay: false, + BankName: "", + BillingContactID: "", + CCnumber: "", + CCtype: "", + CompanyID: "", + ContractID: "", + CreatedByID: "", + CreatedDate: "", + Default: false, + ExpirationDate: "", + ExpirationMonth: "", + ExpirationYear: "", + Gateway: "", + GatewayKey: "", + LastModifiedByID: "", + LastModifiedDate: "", + Nickname: "", + RecordType: "", + Ref: "", + TenantID: "", + }, APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, @@ -63,7 +226,16 @@ func NewDeveloperWorkflow( err = workflow.ExecuteActivity(ctx, NotifyContactActivity, &app.ContactChannelWrapper{ - Obj: w.Contact, + Obj: crm_models.Contact{ + Description: w.Description, + Email: w.Email, + FirstName: w.FirstName, + LastName: w.LastName, + MobilePhone: w.MobilePhone, + Name: w.Name, + Phone: w.Phone, + Title: w.Title, + }, APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, diff --git a/rules/new-lead.go b/rules/new-lead.go index d9d7067..475b8eb 100644 --- a/rules/new-lead.go +++ b/rules/new-lead.go @@ -10,14 +10,62 @@ import ( // NewLeadWrapper wraps a Lead and a user identifier (app.User) type NewLeadWrapper struct { - Lead crm_models.Lead - APIKey string - SagaID string - SagaType string + // Address *crm_models.Address + Company string + Description string + Email string + FirstName string + ID string + LastName string + MobilePhone string + Name string + OwnerID string + PartnerAccountID string + Phone string + ProductID string + RefererURL string + Status string + TenantID string + Title string + Type string + UTMCampaign string + UTMContent string + UTMMedium string + UTMSource string + UTMTerm string + Website string + APIKey string + SagaID string + SagaType string } // NewLeadWorkflow is a Temporal workflow -func NewLeadWorkflow(ctx temporal_workflow.Context, payload *NewLeadWrapper) error { +func NewLeadWorkflow(ctx temporal_workflow.Context, w *NewLeadWrapper) error { + obj := crm_models.Lead{ + // Address: w.Address, + Company: w.Company, + Description: w.Description, + Email: w.Email, + FirstName: w.FirstName, + LastName: w.LastName, + MobilePhone: w.MobilePhone, + Name: w.Name, + OwnerID: w.OwnerID, + PartnerAccountID: w.PartnerAccountID, + Phone: w.Phone, + ProductID: w.ProductID, + RefererURL: w.RefererURL, + Status: w.Status, + TenantID: w.TenantID, + Title: w.Title, + Type: w.Type, + UTMCampaign: w.UTMCampaign, + UTMContent: w.UTMContent, + UTMMedium: w.UTMMedium, + UTMSource: w.UTMSource, + UTMTerm: w.UTMTerm, + Website: w.Website, + } ctx = temporal_workflow. WithActivityOptions( ctx, @@ -29,8 +77,10 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, payload *NewLeadWrapper) err ctx, StoreLeadActivity, &app.LeadChannelWrapper{ - Obj: payload.Lead, - APIKey: payload.APIKey, + Obj: obj, + SagaID: w.SagaID, + SagaType: w.SagaType, + APIKey: w.APIKey, }).Get(ctx, nil) if err != nil { return err @@ -40,8 +90,8 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, payload *NewLeadWrapper) err ctx, NotifyLeadActivity, &app.LeadChannelWrapper{ - Obj: payload.Lead, - APIKey: payload.APIKey, + Obj: obj, + APIKey: w.APIKey, }).Get(ctx, nil) if err != nil { return err