From 300dd4f4ca9ed2556c2f07a03df3a93aa5c12460 Mon Sep 17 00:00:00 2001 From: Ada0317 <03170884@cumt.edu.cn> Date: Sat, 27 Jul 2024 22:38:14 +0800 Subject: [PATCH] fix PaySuccessNotify in cronJob --- app/mqueue/cmd/job/internal/logic/routes.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) 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 } - -