diff --git a/internal/workers/post_deals_worker/deals_worker.go b/internal/workers/post_deals_worker/deals_worker.go index ffcf9c1..eaac9ad 100644 --- a/internal/workers/post_deals_worker/deals_worker.go +++ b/internal/workers/post_deals_worker/deals_worker.go @@ -61,6 +61,7 @@ func (wc *PostDeals) Start(ctx context.Context) { func (wc *PostDeals) startFetching(ctx context.Context) { results, err := wc.amoRepo.AmoRepo.GettingAmoUsersTrueResults(ctx) + fmt.Printn("StartFetchingResults", results,err) if err != nil { wc.logger.Error("error fetching users answers true results, for sending data to amo", zap.Error(err)) return @@ -70,7 +71,9 @@ func (wc *PostDeals) startFetching(ctx context.Context) { mapTokenDomain := make(map[string]string) for _, result := range results { + fmt.Printn("StartFetchingResult", result) userPrivileges, err := wc.amoRepo.AccountRepo.GetPrivilegesByAccountID(ctx, result.QuizAccountID) + fmt.Printn("StartFetchingUP", userPrivileges, err) if err != nil { wc.logger.Error("error getting user privileges", zap.Error(err)) return @@ -82,11 +85,13 @@ func (wc *PostDeals) startFetching(ctx context.Context) { } allAnswers, err := wc.amoRepo.AnswerRepo.GetAllAnswersByQuizID(ctx, result.Session) + fmt.Printn("StartFetchingAA", allAnswers, err) if err != nil { wc.logger.Error("error getting all user answers by result session", zap.Error(err)) return } userTags, err := wc.amoRepo.AmoRepo.GetUserTagsByID(ctx, result.AmoAccountID) + fmt.Printn("StartFetchingUT", userTags, err) if err != nil { wc.logger.Error("error getting user tags by ano account id", zap.Error(err)) return @@ -113,12 +118,14 @@ func (wc *PostDeals) startFetching(ctx context.Context) { } leadFields, contactData, companyData, customerToCreate, err := wc.constructField(ctx, allAnswers, result) + fmt.Printn("StartFetchingCF", leadFields, contactData, companyData, customerToCreate, err) if err != nil { wc.logger.Error("error construct fields", zap.Error(err)) return } currentFields, err := wc.amoRepo.AmoRepo.GetUserFieldsByID(ctx, result.AmoAccountID) + fmt.Printn("StartFetchingcuF", currentFields, err) if err != nil { wc.logger.Error("error getting current user fields from db", zap.Error(err)) return @@ -127,6 +134,7 @@ func (wc *PostDeals) startFetching(ctx context.Context) { utmFields := tools.ConstructUTMFields(result.UTMs, currentFields) _, err = wc.amoClient.CreatingCustomer(customerToCreate, result.AccessToken, result.SubDomain) + fmt.Printn("StartFetchingcC", currentFields, err) if err != nil { wc.logger.Error("error sending requests for create customer", zap.Error(err)) continue