Updata:去除微服务中的余量更新定时任务
This commit is contained in:
parent
c4ec01846f
commit
cb8305f83b
@ -11,19 +11,9 @@ import (
|
|||||||
func InitCronJob() {
|
func InitCronJob() {
|
||||||
c := cron.New(cron.WithSeconds())
|
c := cron.New(cron.WithSeconds())
|
||||||
|
|
||||||
spec := "0 0 0 1 * *"
|
|
||||||
|
|
||||||
_, err := c.AddFunc(spec, func() {
|
|
||||||
log.Printf("执行余量每月数据更新")
|
|
||||||
logic.UpdateBundleBalance()
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// 避免冲突,任务余额每月更新定时任务 - 每月1号1点执行
|
// 避免冲突,任务余额每月更新定时任务 - 每月1号1点执行
|
||||||
taskBalanceSpec := "0 0 1 1 * *"
|
taskBalanceSpec := "0 0 1 1 * *"
|
||||||
_, err = c.AddFunc(taskBalanceSpec, func() {
|
_, err := c.AddFunc(taskBalanceSpec, func() {
|
||||||
log.Printf("执行任务余额每月数据更新")
|
log.Printf("执行任务余额每月数据更新")
|
||||||
logic.UpdateTaskBalanceEveryMonLogic()
|
logic.UpdateTaskBalanceEveryMonLogic()
|
||||||
})
|
})
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user