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

Merge pull request 'by Robin at 20240411' (#269) from dev-feat-IRONFANS-70-Robin into feat-IRONFANS-70 

Reviewed-on: http://121.41.31.146:3000/wishpal_ironfan/service/pulls/269
This commit is contained in:
chenhao 2024-04-11 19:37:19 +08:00
parent 127c289735 6c47d7fa33
commit 78e22c4f59
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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("send_contact_customer_services_of_last_minute", s.SendContactCustomerServicesOfLastMinute)
exec.RegTask("cancel_account_at_due_time", s.CancelAccountsAtDueTime) exec.RegTask("cancel_account_at_due_time", s.CancelAccountsAtDueTime)
exec.RegTask("reload_moment_recomm_list", s.ReloadMomentRecommList) exec.RegTask("reload_moment_recomm_list", s.ReloadMomentRecommList)
exec.RegTask("clear_zone_moment_create_times", s.ClearZoneMomentCreateTimes)
exec.LogHandler(customLogHandle) exec.LogHandler(customLogHandle)
//注册任务handler //注册任务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...") logger.Info("Refresh moment recommendation list cached in redis accomplished...")
return "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"
}