SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix typo

Browse Source
This commit is contained in:
skeris 2024-12-02 20:31:20 +03:00
parent c29636f2d3
commit b375f8dbbc
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
internal/workers/post_deals_worker/deals_worker.go
View File

@ -1,7 +1,6 @@
package post_deals_worker
import (
"fmt"
"amocrm/internal/models"
"amocrm/internal/repository"
"amocrm/internal/tools"
@ -62,7 +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)
fmt.Println("StartFetchingResults", results,err)
if err != nil {
wc.logger.Error("error fetching users answers true results, for sending data to amo", zap.Error(err))
return
@ -72,9 +71,9 @@ func (wc *PostDeals) startFetching(ctx context.Context) {
mapTokenDomain := make(map[string]string)
for _, result := range results {
fmt.Printn("StartFetchingResult", result)
fmt.Println("StartFetchingResult", result)
userPrivileges, err := wc.amoRepo.AccountRepo.GetPrivilegesByAccountID(ctx, result.QuizAccountID)
fmt.Printn("StartFetchingUP", userPrivileges, err)
fmt.Println("StartFetchingUP", userPrivileges, err)
if err != nil {
wc.logger.Error("error getting user privileges", zap.Error(err))
return
@ -86,13 +85,13 @@ func (wc *PostDeals) startFetching(ctx context.Context) {
}
allAnswers, err := wc.amoRepo.AnswerRepo.GetAllAnswersByQuizID(ctx, result.Session)
fmt.Printn("StartFetchingAA", allAnswers, err)
fmt.Println("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)
fmt.Println("StartFetchingUT", userTags, err)
if err != nil {
wc.logger.Error("error getting user tags by ano account id", zap.Error(err))
return
@ -119,14 +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)
fmt.Println("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)
fmt.Println("StartFetchingcuF", currentFields, err)
if err != nil {
wc.logger.Error("error getting current user fields from db", zap.Error(err))
return
@ -135,7 +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)
fmt.Println("StartFetchingcC", currentFields, err)
if err != nil {
wc.logger.Error("error sending requests for create customer", zap.Error(err))
continue