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

--

Browse Source
This commit is contained in:
skeris 2024-12-02 17:46:00 +03:00
parent 1a0da95d1d
commit 8f8ab4aa0f
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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