add new

idprm · Oct 23, 2024 · 6e45e1f · 6e45e1f
1 parent 6297297
commit 6e45e1f
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/internal/handler/sms_handler.go b/internal/handler/sms_handler.go
@@ -17,6 +17,10 @@ import (
 	"github.com/wiliehidayat87/rmqp"
 )
 
+const (
+	LIMIT_PER_DAY int = 1
+)
+
 type SMSHandler struct {
 	rmq                             rmqp.AMQP
 	rds                             *redis.Client
@@ -225,6 +229,7 @@ func (h *SMSHandler) SubAlerteCompetition(league *entity.League) {
 			&entity.SubscriptionFollowLeague{
 				SubscriptionID: sub.GetId(),
 				LeagueID:       league.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)
@@ -234,6 +239,7 @@ func (h *SMSHandler) SubAlerteCompetition(league *entity.League) {
 			&entity.SubscriptionFollowLeague{
 				SubscriptionID: sub.GetId(),
 				LeagueID:       league.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)
@@ -535,6 +541,7 @@ func (h *SMSHandler) SubAlerteEquipe(team *entity.Team) {
 			&entity.SubscriptionFollowTeam{
 				SubscriptionID: sub.GetId(),
 				TeamID:         team.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)
@@ -544,6 +551,7 @@ func (h *SMSHandler) SubAlerteEquipe(team *entity.Team) {
 			&entity.SubscriptionFollowTeam{
 				SubscriptionID: sub.GetId(),
 				TeamID:         team.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)
@@ -831,6 +839,7 @@ func (h *SMSHandler) AlreadySubAlerteCompetition(league *entity.League) {
 			&entity.SubscriptionFollowLeague{
 				SubscriptionID: sub.GetId(),
 				LeagueID:       league.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)
@@ -900,6 +909,7 @@ func (h *SMSHandler) AlreadySubAlerteEquipe(team *entity.Team) {
 			&entity.SubscriptionFollowTeam{
 				SubscriptionID: sub.GetId(),
 				TeamID:         team.GetId(),
+				LimitPerDay:    LIMIT_PER_DAY,
 				IsActive:       true,
 			},
 		)