add base logic for activate promo

This commit is contained in:
Pavel 2024-01-12 16:46:36 +03:00
parent b31c3a81c6
commit 483eb27723
5 changed files with 91 additions and 0 deletions

@ -83,3 +83,30 @@ func (p *PromoCodeController) GetList(c *fiber.Ctx) error {
}
return c.Status(fiber.StatusOK).JSON(resp)
}
func (p *PromoCodeController) Activate(c *fiber.Ctx) error {
var req models.ActivateReq
if err := c.BodyParser(&req); err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "Invalid request payload"})
}
if req.Codeword == "" {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "codeword is required"})
}
greetings, err := p.promoCodeService.ActivatePromo(c.Context(), &req)
if err != nil {
p.logger.Error("Failed to activate promocode", zap.Error(err))
if errors.Is(err, repository.ErrPromoCodeNotFound) {
return c.Status(fiber.StatusNotFound).JSON(fiber.Map{"error": "PromoCode not found"})
}
return c.Status(fiber.StatusInternalServerError).JSON(fiber.Map{"error": "Internal Server Error"})
}
resp := models.ActivateResp{
Greetings: greetings,
}
return c.Status(fiber.StatusOK).JSON(resp)
}

@ -56,3 +56,11 @@ type GetPromoCodesListResp struct {
Count int64 `json:"count"` // количество в выборке всего
Items []PromoCode `json:"items"` // "страница" промокодов
}
type ActivateReq struct {
Codeword string `json:"codeword"`
}
type ActivateResp struct {
Greetings string `json:"greetings"` // поле из активированного промокода
}

@ -185,3 +185,47 @@ func (r *PromoCodeRepository) GetPromoCodesList(ctx context.Context, req *models
return promoCodes, count, nil
}
func (r *PromoCodeRepository) ActivatePromo(ctx context.Context, req *models.ActivateReq) (string, error) {
session, err := r.mdb.Database().Client().StartSession()
if err != nil {
return "", err
}
defer session.EndSession(ctx)
var greetings string
transactionErr := mongo.WithSession(ctx, session, func(sc mongo.SessionContext) error {
filter := bson.M{
"codeword": req.Codeword,
"delete": false,
"outdated": false,
"offLimit": false,
"activationCount": bson.M{"$gt": 0},
"dueTo": bson.M{"$gt": time.Now().Unix()},
}
update := bson.M{
"$inc": bson.M{"activationCount": -1},
}
opts := options.FindOneAndUpdate().SetReturnDocument(options.After)
var updatedPromoCode models.PromoCode
err := r.mdb.FindOneAndUpdate(sc, filter, update, opts).Decode(&updatedPromoCode)
if err != nil {
if err == mongo.ErrNoDocuments {
return ErrPromoCodeNotFound
}
return err
}
greetings = updatedPromoCode.Greetings
return nil
})
if transactionErr != nil {
return "", transactionErr
}
return greetings, nil
}

@ -60,6 +60,7 @@ func (s *Server) registerRoutes() {
s.app.Post("/promocode/create", s.PromoCodeController.CreatePromoCode)
s.app.Put("/promocode/edit", s.PromoCodeController.EditPromoCode)
s.app.Post("/promocode/getList", s.PromoCodeController.GetList)
s.app.Post("/promocode/activate", s.PromoCodeController.Activate)
//... other
}

@ -10,6 +10,7 @@ type PromoCodeRepository interface {
CreatePromoCode(ctx context.Context, req *models.PromoCode) (*models.PromoCode, error)
EditPromoCode(ctx context.Context, req *models.ReqEditPromoCode) (*models.PromoCode, error)
GetPromoCodesList(ctx context.Context, req *models.GetPromoCodesListReq) ([]models.PromoCode, int64, error)
ActivatePromo(ctx context.Context, req *models.ActivateReq) (string, error)
}
type PromoDeps struct {
@ -58,3 +59,13 @@ func (s *PromoCodeService) GetPromoCodesList(ctx context.Context, req *models.Ge
return promoCodes, count, nil
}
func (s *PromoCodeService) ActivatePromo(ctx context.Context, req *models.ActivateReq) (string, error) {
greetings, err := s.promoCodeRepo.ActivatePromo(ctx, req)
if err != nil {
s.logger.Error("Failed to activate promocode", zap.Error(err))
return "", err
}
return greetings, nil
}