add new nil

idprm · Oct 8, 2024 · af388ee · af388ee
1 parent baeb7f3
commit af388ee
Show file tree

Hide file tree

Showing 38 changed files with 594 additions and 554 deletions.
diff --git a/MT.txt b/MT.txt
@@ -1,3 +1,34 @@
+
+FOLLOW_TEAM_SUB (Confirmation) can be multiple team
+SMS Alerte: Vous avez souscrit avec succes pour suivre votre equipe favorite! Jusqu au [25]/[04] vous recevrez toutes les infos en direct. [200][F]/souscription
+
+FOLLOW_TEAM_UNVALID_SUB
+SMS Alerte: Desole, votre choix n est pas valide. Envoyez de nouveau au [981] le nom de votre equipe pour obtenir toutes les infos. [200][F]/souscription
+
+FOLLOW_TEAM_EXPIRE_SUB
+SMS Alerte: Desole mais votre abonnement pour suivre votre equipe vient de se terminer. Pour le renouveler, envoyer au [981] le nom de l equipe a suivre. [200][F]
+
+=======================================================
+
+FOLLOW_COMPETITION_SUB
+SMS Alerte: Vous avez souscrit avec succes pour suivre [la Liga]! Jusqu au [day]/[month] vous recevrez toutes les infos en direct. [200][F]/souscription
+
+FOLLOW_COMPETITION_UNVALID_SUB
+SMS Alerte: Desole, mais votre choix n est pas valide. Renvoyez au [9009] la competition que vous voulez suivre en direct. [250F]/SMS
+
+FOLLOW_COMPETITION_EXPIRE_SUB
+SMS Alerte: Desole mais votre abonnement pour suivre votre competition vient de se terminer. Pour le renouveler, envoyer au [9009] le nom de l equipe a suivre. [250][F]/SMS
+
+=======================================================
+
+INFO
+Info Services FFC: [#157#] USSD /[981] SMS Alerte Equipe /[9009] - SMS Alerte Competition /[###] SMS Alerte a la demande /[944] Credit Goal /[985] Pronostic
+
+STOP
+Services FFC: Vous venez d envoyer STOP. Orange vous remercie d avoir utiliser nos services! Visitez www.orange.cm pour en savoir plus sur Football Fan Club
+
+=======================================================
+
 CREDIT_GOAL_SUB (Confirmation)
 Credit Goal: Votre participation a ete enregistree. Si Lille marque des buts lors du prochain match, vous recevrez [100][F] de credit par but. [100][F]/souscription
 
@@ -64,32 +95,4 @@ Prono: Vous avez fait un bon pronostic, mais vous n avez pas ete tire au sort po
 PREDICT_MATCH_END_LOSER_NOTIF
 Prono: Desole! Votre pronostic n a pas ete le bon pour le match Lille- Marseille. Retentez votre chance pour les prochains matchs .Bonne chance!
 
-=======================================================
-
-FOLLOW_TEAM_SUB (Confirmation) can be multiple team
-SMS Alerte: Vous avez souscrit avec succes pour suivre votre equipe favorite! Jusqu au [25]/[04] vous recevrez toutes les infos en direct. [200][F]/souscription
-
-FOLLOW_TEAM_UNVALID_SUB
-SMS Alerte: Desole, votre choix n est pas valide. Envoyez de nouveau au [981] le nom de votre equipe pour obtenir toutes les infos. [200][F]/souscription
-
-FOLLOW_TEAM_EXPIRE_SUB
-SMS Alerte: Desole mais votre abonnement pour suivre votre equipe vient de se terminer. Pour le renouveler, envoyer au [981] le nom de l equipe a suivre. [200][F]
-
-=======================================================
-
-FOLLOW_COMPETITION_SUB
-SMS Alerte: Vous avez souscrit avec succes pour suivre [la Liga]! Jusqu au [day]/[month] vous recevrez toutes les infos en direct. [200][F]/souscription
-
-FOLLOW_COMPETITION_INVALID_SUB
-SMS Alerte: Desole, mais votre choix n est pas valide. Renvoyez au [9009] la competition que vous voulez suivre en direct. [250F]/SMS
-
-FOLLOW_COMPETITION_EXPIRE_SUB
-SMS Alerte: Desole mais votre abonnement pour suivre votre competition vient de se terminer. Pour le renouveler, envoyer au [9009] le nom de l equipe a suivre. [250][F]/SMS
-
-=======================================================
-
-INFO
-Info Services FFC: [#157#] USSD /[981] SMS Alerte Equipe /[9009] - SMS Alerte Competition /[###] SMS Alerte a la demande /[944] Credit Goal /[985] Pronostic
-
-STOP
-Services FFC: Vous venez d envoyer STOP. Orange vous remercie d avoir utiliser nos services! Visitez www.orange.cm pour en savoir plus sur Football Fan Club
+=======================================================
diff --git a/DEDUCTFEE.xml → XML_DEDUCTFEE.xml b/DEDUCTFEE.xml → XML_DEDUCTFEE.xml
diff --git a/PROFILEANDBAL.xml → XML_PROFILEANDBAL.xml b/PROFILEANDBAL.xml → XML_PROFILEANDBAL.xml
diff --git a/cmd/consumer.go b/cmd/consumer.go
@@ -482,8 +482,8 @@ var consumerNewsCmd = &cobra.Command{
 }
 
 var consumerSMSAlerteCmd = &cobra.Command{
-	Use:   "follow_competition",
-	Short: "Consumer Follow Competition Service CLI",
+	Use:   "sms_alerte",
+	Short: "Consumer SMS Alerte Service CLI",
 	Long:  ``,
 	Run: func(cmd *cobra.Command, args []string) {
 		/**

diff --git a/cmd/listener.go b/cmd/listener.go
@@ -70,7 +70,7 @@ var listenerCmd = &cobra.Command{
 			&entity.News{},
 			&entity.NewsLeagues{},
 			&entity.NewsTeams{},
-			&entity.FollowCompetition{},
+			&entity.FollowLeague{},
 			&entity.FollowTeam{},
 			&entity.Country{},
 			&entity.Schedule{},
@@ -79,12 +79,13 @@ var listenerCmd = &cobra.Command{
 			&entity.Subscription{},
 			&entity.SubscriptionCreditGoal{},
 			&entity.SubscriptionPredict{},
-			&entity.SubscriptionFollowCompetition{},
+			&entity.SubscriptionFollowLeague{},
 			&entity.SubscriptionFollowTeam{},
 			&entity.Transaction{},
 			&entity.History{},
 			&entity.Reward{},
 			&entity.Summary{},
+			&entity.MT{},
 		)
 
 		/**
@@ -158,8 +159,8 @@ func routeUrlListener(db *gorm.DB, rds *redis.Client, rmq rmqp.AMQP, logger *log
 	newsRepo := repository.NewNewsRepository(db)
 	newsService := services.NewNewsService(newsRepo)
 
-	followCompetitionRepo := repository.NewFollowCompetitionRepository(db)
-	followCompetitionService := services.NewFollowCompetitionService(followCompetitionRepo)
+	FollowLeagueRepo := repository.NewFollowLeagueRepository(db)
+	FollowLeagueService := services.NewFollowLeagueService(FollowLeagueRepo)
 
 	followTeamRepo := repository.NewFollowTeamRepository(db)
 	followTeamService := services.NewFollowTeamService(followTeamRepo)
@@ -223,7 +224,7 @@ func routeUrlListener(db *gorm.DB, rds *redis.Client, rmq rmqp.AMQP, logger *log
 		leagueService,
 		teamService,
 		newsService,
-		followCompetitionService,
+		FollowLeagueService,
 		followTeamService,
 		&entity.News{},
 	)

diff --git a/cmd/processor.go b/cmd/processor.go
@@ -99,8 +99,8 @@ func (p *Processor) SMS(wg *sync.WaitGroup, message []byte) {
 	subscriptionCreditGoalService := services.NewSubscriptionCreditGoalService(subscriptionCreditGoalRepo)
 	subscriptionPredictRepo := repository.NewSubscriptionPredictRepository(p.db)
 	subscriptionPredictService := services.NewSubscriptionPredictService(subscriptionPredictRepo)
-	subscriptionFollowCompetitionRepo := repository.NewSubscriptionFollowCompetitionRepository(p.db)
-	subscriptionFollowCompetitionService := services.NewSubscriptionFollowCompetitionService(subscriptionFollowCompetitionRepo)
+	SubscriptionFollowLeagueRepo := repository.NewSubscriptionFollowLeagueRepository(p.db)
+	SubscriptionFollowLeagueService := services.NewSubscriptionFollowLeagueService(SubscriptionFollowLeagueRepo)
 	subscriptionFollowTeamRepo := repository.NewSubscriptionFollowTeamRepository(p.db)
 	subscriptionFollowTeamService := services.NewSubscriptionFollowTeamService(subscriptionFollowTeamRepo)
 	verifyRepo := repository.NewVerifyRepository(p.rds)
@@ -123,7 +123,7 @@ func (p *Processor) SMS(wg *sync.WaitGroup, message []byte) {
 		teamService,
 		subscriptionCreditGoalService,
 		subscriptionPredictService,
-		subscriptionFollowCompetitionService,
+		SubscriptionFollowLeagueService,
 		subscriptionFollowTeamService,
 		verifyService,
 		req,
@@ -136,19 +136,16 @@ func (p *Processor) SMS(wg *sync.WaitGroup, message []byte) {
 
 func (p *Processor) MT(wg *sync.WaitGroup, message []byte) {
 
-	subscriptionRepo := repository.NewSubscriptionRepository(p.db)
-	subscriptionService := services.NewSubscriptionService(subscriptionRepo)
-	transactionRepo := repository.NewTransactionRepository(p.db)
-	transactionService := services.NewTransactionService(transactionRepo)
+	mtRepo := repository.NewMTRepository(p.db)
+	mtService := services.NewMTService(mtRepo)
 
 	var req *model.MTRequest
 	json.Unmarshal([]byte(message), &req)
 
 	h := handler.NewMTHandler(
 		p.rmq,
 		p.logger,
-		subscriptionService,
-		transactionService,
+		mtService,
 		req,
 	)
 
@@ -167,8 +164,8 @@ func (p *Processor) News(wg *sync.WaitGroup, message []byte) {
 	teamService := services.NewTeamService(teamRepo)
 	newsRepo := repository.NewNewsRepository(p.db)
 	newsService := services.NewNewsService(newsRepo)
-	followCompetitionRepo := repository.NewFollowCompetitionRepository(p.db)
-	followCompetitionService := services.NewFollowCompetitionService(followCompetitionRepo)
+	FollowLeagueRepo := repository.NewFollowLeagueRepository(p.db)
+	FollowLeagueService := services.NewFollowLeagueService(FollowLeagueRepo)
 	followTeamRepo := repository.NewFollowTeamRepository(p.db)
 	followTeamService := services.NewFollowTeamService(followTeamRepo)
 
@@ -180,7 +177,7 @@ func (p *Processor) News(wg *sync.WaitGroup, message []byte) {
 		leagueService,
 		teamService,
 		newsService,
-		followCompetitionService,
+		FollowLeagueService,
 		followTeamService,
 		news,
 	)

diff --git a/cmd/publisher.go b/cmd/publisher.go
@@ -579,7 +579,7 @@ func populateSMSAlerte(db *gorm.DB, rmq rmqp.AMQP) {
 	subscriptionRepo := repository.NewSubscriptionRepository(db)
 	subscriptionService := services.NewSubscriptionService(subscriptionRepo)
 
-	subs := subscriptionService.FollowCompetition()
+	subs := subscriptionService.FollowLeague()
 
 	for _, s := range *subs {
 		var sub entity.Subscription

diff --git a/cmd/root.go b/cmd/root.go
@@ -33,6 +33,9 @@ var (
 	API_FOOTBALL_URL  string = getEnv("API_FOOTBALL_URL")
 	API_FOOTBALL_KEY  string = getEnv("API_FOOTBALL_KEY")
 	API_FOOTBALL_HOST string = getEnv("API_FOOTBALL_HOST")
+	URL_MT            string = getEnv("URL_MT")
+	USER_MT           string = getEnv("USER_MT")
+	PASS_MT           string = getEnv("PASS_MT")
 )
 
 const (
@@ -42,8 +45,10 @@ const (
 	RMQ_USSD_QUEUE          string = "Q_USSD"
 	RMQ_SMS_EXCHANGE        string = "E_SMS"
 	RMQ_SMS_QUEUE           string = "Q_SMS"
-	RMQ_MT_EXCHANGE         string = "E_MT"
-	RMQ_MT_QUEUE            string = "Q_MT"
+	RMQ_NEWS_EXCHANGE       string = "E_NEWS"
+	RMQ_NEWS_QUEUE          string = "Q_NEWS"
+	RMQ_SMS_ALERTE_EXCHANGE string = "E_SMS_ALERTE"
+	RMQ_SMS_ALERTE_QUEUE    string = "Q_SMS_ALERTE"
 	RMQ_RENEWAL_EXCHANGE    string = "E_RENEWAL"
 	RMQ_RENEWAL_QUEUE       string = "Q_RENEWAL"
 	RMQ_RETRY_EXCHANGE      string = "E_RETRY"
@@ -58,10 +63,8 @@ const (
 	RMQ_PREDICTION_QUEUE    string = "Q_PREDICTION"
 	RMQ_CREDIT_EXCHANGE     string = "E_CREDIT_GOAL"
 	RMQ_CREDIT_QUEUE        string = "Q_CREDIT_GOAL"
-	RMQ_NEWS_EXCHANGE       string = "E_NEWS"
-	RMQ_NEWS_QUEUE          string = "Q_NEWS"
-	RMQ_SMS_ALERTE_EXCHANGE string = "E_SMS_ALERTE"
-	RMQ_SMS_ALERTE_QUEUE    string = "Q_SMS_ALERTE"
+	RMQ_MT_EXCHANGE         string = "E_MT"
+	RMQ_MT_QUEUE            string = "Q_MT"
 	ACT_USSD                string = "USSD"
 	ACT_SMS                 string = "SMS"
 	ACT_CONFIRMATION        string = "CONFIRMATION"
@@ -101,7 +104,6 @@ const (
 	SMS_FOLLOW_COMPETITION_SUB           string = "FOLLOW_COMPETITION_SUB"
 	SMS_FOLLOW_COMPETITION_UNVALID_SUB   string = "FOLLOW_COMPETITION_UNVALID_SUB"
 	SMS_FOLLOW_COMPETITION_EXPIRE_SUB    string = "FOLLOW_COMPETITION_EXPIRE_SUB"
-	SMS_CONFIRMATION                     string = "CONFIRMATION"
 	SMS_INFO                             string = "INFO"
 	SMS_STOP                             string = "STOP"
 )

diff --git a/cmd/seeder.go b/cmd/seeder.go
@@ -278,10 +278,38 @@ func seederDB(db *gorm.DB) {
 		{
 			Category: ACT_CONFIRMATION,
 			Channel:  ACT_SMS,
-			Name:     SMS_CONFIRMATION,
-			Value: `1.S'abonner au jour (50/jour)\n
-			2.S'anonner a la semaine (200/semaine)\n
-			3.S'abonnet au mois (500/mois)`,
+			Name:     SMS_FOLLOW_TEAM_SUB,
+			Value:    "SMS Alerte: Vous avez souscrit avec succes pour suivre votre equipe favorite! Jusqu au {date}/{month} vous recevrez toutes les infos en direct. {price}{currency}/souscription",
+		},
+		{
+			Category: ACT_CONFIRMATION,
+			Channel:  ACT_SMS,
+			Name:     SMS_FOLLOW_TEAM_UNVALID_SUB,
+			Value:    "SMS Alerte: Desole, votre choix n est pas valide. Envoyez de nouveau au {sc} le nom de votre equipe pour obtenir toutes les infos. {price}{currency}/souscription",
+		},
+		{
+			Category: ACT_NOTIFICATION,
+			Channel:  ACT_SMS,
+			Name:     SMS_FOLLOW_TEAM_EXPIRE_SUB,
+			Value:    "SMS Alerte: Desole mais votre abonnement pour suivre votre equipe vient de se terminer. Pour le renouveler, envoyer au {sc} le nom de l equipe a suivre. {price}{currency}",
+		},
+		{
+			Category: ACT_CONFIRMATION,
+			Channel:  ACT_SMS,
+			Name:     SMS_FOLLOW_COMPETITION_SUB,
+			Value:    "SMS Alerte: Vous avez souscrit avec succes pour suivre {league}! Jusqu au {day}/{month} vous recevrez toutes les infos en direct. {price}{currency}/souscription",
+		},
+		{
+			Category: ACT_CONFIRMATION,
+			Channel:  ACT_SMS,
+			Name:     SMS_FOLLOW_COMPETITION_UNVALID_SUB,
+			Value:    "SMS Alerte: Desole, mais votre choix n est pas valide. Renvoyez au {sc} la competition que vous voulez suivre en direct. {price}{currency}/SMS",
+		},
+		{
+			Category: ACT_NOTIFICATION,
+			Channel:  ACT_SMS,
+			Name:     SMS_FOLLOW_COMPETITION_EXPIRE_SUB,
+			Value:    "SMS Alerte: Desole mais votre abonnement pour suivre votre competition vient de se terminer. Pour le renouveler, envoyer au {sc} le nom de l equipe a suivre. {price}{currency}/SMS",
 		},
 		{
 			Category: ACT_CONFIRMATION,
@@ -373,47 +401,11 @@ func seederDB(db *gorm.DB) {
 			Name:     SMS_PREDICT_MATCH_END_LOSER_NOTIF,
 			Value:    "Prono: Desole! Votre pronostic n a pas ete le bon pour le match {home}-{away}. Retentez votre chance pour les prochains matchs .Bonne chance!",
 		},
-		{
-			Category: ACT_CONFIRMATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_TEAM_SUB,
-			Value:    "SMS Alerte: Vous avez souscrit avec succes pour suivre votre equipe favorite! Jusqu au {date}/{month} vous recevrez toutes les infos en direct. {price}{currency}/souscription",
-		},
-		{
-			Category: ACT_CONFIRMATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_TEAM_UNVALID_SUB,
-			Value:    "SMS Alerte: Desole, votre choix n est pas valide. Envoyez de nouveau au {sc} le nom de votre equipe pour obtenir toutes les infos. {price}{currency}/souscription",
-		},
-		{
-			Category: ACT_NOTIFICATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_TEAM_EXPIRE_SUB,
-			Value:    "SMS Alerte: Desole mais votre abonnement pour suivre votre equipe vient de se terminer. Pour le renouveler, envoyer au {sc} le nom de l equipe a suivre. {price}{currency}",
-		},
-		{
-			Category: ACT_CONFIRMATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_COMPETITION_SUB,
-			Value:    "SMS Alerte: Vous avez souscrit avec succes pour suivre {league}! Jusqu au {day}/{month} vous recevrez toutes les infos en direct. {price}{currency}/souscription",
-		},
-		{
-			Category: ACT_CONFIRMATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_COMPETITION_UNVALID_SUB,
-			Value:    "SMS Alerte: Desole, mais votre choix n est pas valide. Renvoyez au {sc} la competition que vous voulez suivre en direct. {price}{currency}/SMS",
-		},
-		{
-			Category: ACT_NOTIFICATION,
-			Channel:  ACT_SMS,
-			Name:     SMS_FOLLOW_COMPETITION_EXPIRE_SUB,
-			Value:    "SMS Alerte: Desole mais votre abonnement pour suivre votre competition vient de se terminer. Pour le renouveler, envoyer au {sc} le nom de l equipe a suivre. {price}{currency}/SMS",
-		},
 		{
 			Category: ACT_CONFIRMATION,
 			Channel:  ACT_SMS,
 			Name:     SMS_INFO,
-			Value:    "Info Services FFC: [#157#] USSD /[981] SMS Alerte Equipe /[9009] - SMS Alerte Competition /[###] SMS Alerte a la demande /[944] Credit Goal /[985] Pronostic",
+			Value:    "Info Services FFC: [#157#] USSD /[981] SMS Alerte Equipe /[9009] - SMS Alerte Competition /[###] SMS Alerte a la demande /[944]",
 		},
 		{
 			Category: ACT_CONFIRMATION,
@@ -433,28 +425,21 @@ func seederDB(db *gorm.DB) {
 		},
 		{
 			CountryID:  1,
-			Name:       ACT_PREDICTION,
-			PublishAt:  time.Now(),
-			UnlockedAt: time.Now(),
-			IsUnlocked: false,
-		},
-		{
-			CountryID:  1,
-			Name:       ACT_CREDIT_GOAL,
+			Name:       ACT_SMS_ALERTE,
 			PublishAt:  time.Now(),
 			UnlockedAt: time.Now(),
 			IsUnlocked: false,
 		},
 		{
 			CountryID:  1,
-			Name:       ACT_SMS_ALERTE,
+			Name:       ACT_PREDICTION,
 			PublishAt:  time.Now(),
 			UnlockedAt: time.Now(),
 			IsUnlocked: false,
 		},
 		{
 			CountryID:  1,
-			Name:       ACT_SMS_ALERTE,
+			Name:       ACT_CREDIT_GOAL,
 			PublishAt:  time.Now(),
 			UnlockedAt: time.Now(),
 			IsUnlocked: false,