diff --git a/app/mqueue/cmd/job/internal/logic/routes.go b/app/mqueue/cmd/job/internal/logic/routes.go index 46374938..e8abb7e4 100644 --- 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 } - -