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

fix in all data update event, if len new tokens = 0, dont go another methods

Browse Source
This commit is contained in:
Pavel 2024-05-27 09:36:38 +03:00
parent 1c1b55f22c
commit 13cf22d740
1 changed files with 25 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
internal/workers/queueUpdater/queue_updater.go
View File

@ -165,32 +165,34 @@ func (wc *QueueUpdater) processMessages(ctx context.Context, message models.Kafk
return err
}
// обновляем информацию о пользователях
err = wc.methods.CheckUsers(ctx, newTokens)
if err != nil {
wc.logger.Error("error update users information", zap.Error(err))
return err
}
if len(newTokens) > 0 {
// обновляем информацию о пользователях
err = wc.methods.CheckUsers(ctx, newTokens)
if err != nil {
wc.logger.Error("error update users information", zap.Error(err))
return err
}
// обновляем информацию о pipelines и их steps
err = wc.methods.CheckPipelinesAndSteps(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users pipelines and users pipelines-steps", zap.Error(err))
return err
}
// обновляем информацию о pipelines и их steps
err = wc.methods.CheckPipelinesAndSteps(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users pipelines and users pipelines-steps", zap.Error(err))
return err
}
// обновляем информацию о tags
err = wc.methods.CheckTags(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users tags", zap.Error(err))
return err
}
// обновляем информацию о tags
err = wc.methods.CheckTags(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users tags", zap.Error(err))
return err
}
// обновляем информацию о fields
err = wc.methods.CheckFields(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users fields", zap.Error(err))
return err
// обновляем информацию о fields
err = wc.methods.CheckFields(ctx, newTokens)
if err != nil {
wc.logger.Error("error updating users fields", zap.Error(err))
return err
}
}
case models.RuleCheck:
token, err := wc.methods.GetTokenByID(ctx, message.AccountID)