Merge pull request #155 from Mikaelemmmm/dev

Dev
Mikaelemmmm · Nov 23, 2024 · 686a3f3 · 686a3f3
2 parents 4d9cc0b + e159937
commit 686a3f3
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/app/mqueue/cmd/job/internal/logic/routes.go b/app/mqueue/cmd/job/internal/logic/routes.go
@@ -7,7 +7,6 @@ import (
 	"looklook/app/mqueue/cmd/job/jobtype"
 )
 
-
 type CronJob struct {
 	ctx    context.Context
 	svcCtx *svc.ServiceContext
@@ -26,15 +25,15 @@ func (l *CronJob) Register() *asynq.ServeMux {
 	mux := asynq.NewServeMux()
 
 	//scheduler job
-	mux.Handle(jobtype.ScheduleSettleRecord,NewSettleRecordHandler(l.svcCtx))
+	mux.Handle(jobtype.ScheduleSettleRecord, NewSettleRecordHandler(l.svcCtx))
 
 	//defer job
-	mux.Handle(jobtype.DeferCloseHomestayOrder,NewCloseHomestayOrderHandler(l.svcCtx))
+	mux.Handle(jobtype.DeferCloseHomestayOrder, NewCloseHomestayOrderHandler(l.svcCtx))
 
+	//SuccessNotifyUser job
+	mux.Handle(jobtype.MsgPaySuccessNotifyUser, NewPaySuccessNotifyUserHandler(l.svcCtx))
 	//queue job , asynq support queue job
 	// wait you fill..
 
 	return mux
 }
-
-