wishpal_ironfan
/
service
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20240411 #269

Merged
chenhao merged 1 commits from dev-feat-IRONFANS-70-Robin into feat-IRONFANS-70 2024-04-11 19:37:20 +08:00
Conversation 0 Commits 1 Files Changed 2 +12
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 6c47d7fa33 - Show all commits

1
app/mix/service/cronservice.go
View File

@ -57,6 +57,7 @@ func (s *CronService) Init(c any) (err error) {
exec.RegTask("send_contact_customer_services_of_last_minute", s.SendContactCustomerServicesOfLastMinute)
exec.RegTask("cancel_account_at_due_time", s.CancelAccountsAtDueTime)
exec.RegTask("reload_moment_recomm_list", s.ReloadMomentRecommList)
exec.RegTask("clear_zone_moment_create_times", s.ClearZoneMomentCreateTimes)
exec.LogHandler(customLogHandle)
//注册任务handler

11
app/mix/service/xxljob_tasks.go
View File

@ -423,3 +423,14 @@ func (s *CronService) ReloadMomentRecommList(ctx context.Context, param *xxl.Run
logger.Info("Refresh moment recommendation list cached in redis accomplished...")
return "Refresh moment recommendation list cached in redis accomplished"
}
func (s *CronService) ClearZoneMomentCreateTimes(ctx context.Context, param *xxl.RunReq) (msg string) {
logger.Info("task %v param: %v log_id: %v", param.ExecutorHandler, param.ExecutorParams, xxl.Int64ToStr(param.LogID))
logger.Info("Clearing zone_moment_create_times collection...")
if err := _DefaultZoneMomentCreateTimes.OpClear(&gin.Context{}); err != nil {
logger.Error("Clear zone_moment_create_times collection fail: %v", err)
return fmt.Sprintf("Clear zone_moment_create_times collection fail: %v", err)
}
logger.Info("zone_moment_create_times collection has been cleared")
return "zone_moment_create_times collection has been cleared"
}