diff --git a/internal/gigachatwc/scheduler.go b/internal/gigachatwc/scheduler.go index ec58f9f..c360fdc 100644 --- a/internal/gigachatwc/scheduler.go +++ b/internal/gigachatwc/scheduler.go @@ -8,7 +8,6 @@ import ( "gitea.pena/SQuiz/common/dal" "gitea.pena/SQuiz/common/model" "gitea.pena/SQuiz/worker/internal/clients/gigachat" - "gitea.pena/SQuiz/worker/internal/wctools" "github.com/twmb/franz-go/pkg/kgo" "go.uber.org/zap" "time" @@ -148,21 +147,5 @@ func (r *GigaChatTaskScheduler) handleMessage(ctx context.Context, msg MessageGi r.logger.Error("failed to create updated question", zap.Error(err)) continue } - - _, privileges, err := r.dal.AccountRepo.GetAccAndPrivilegeByEmail(ctx, msg.AccountID) - if err != nil { - r.logger.Error("failed to get acc/privilege", zap.Error(err)) - } - - privilege := wctools.HasQuizGigaChatPrivilege(privileges) - if privilege != nil { - privilege.Amount-- - err = r.dal.AccountRepo.UpdatePrivilegeAmount(ctx, privilege.ID, privilege.Amount) - if err != nil { - r.logger.Error("failed to update privilege", zap.Error(err)) - } - continue - } - } }