|
|
|
@ -7,7 +7,6 @@ import (
|
|
|
|
|
"log"
|
|
|
|
|
"recook/configs"
|
|
|
|
|
order3 "recook/internal/api/mobile/order"
|
|
|
|
|
"recook/internal/cache"
|
|
|
|
|
"recook/internal/dbc"
|
|
|
|
|
order4 "recook/internal/model/order"
|
|
|
|
|
"recook/internal/mq"
|
|
|
|
@ -16,7 +15,6 @@ import (
|
|
|
|
|
"recook/internal/v2/lib/jcook"
|
|
|
|
|
"recook/internal/v2/lib/shama"
|
|
|
|
|
after2 "recook/internal/v2/logic/manage/after"
|
|
|
|
|
"recook/internal/v2/logic/manage/message"
|
|
|
|
|
order2 "recook/internal/v2/logic/manage/order"
|
|
|
|
|
"recook/internal/v2/model/recook/after"
|
|
|
|
|
goods2 "recook/internal/v2/model/recook/goods"
|
|
|
|
@ -39,17 +37,12 @@ func Task(c *cron.Cron) {
|
|
|
|
|
_ = c.AddFunc("*/10 * * * * ?", func() {
|
|
|
|
|
fmt.Println("task live")
|
|
|
|
|
})
|
|
|
|
|
_ = c.AddFunc("0 */10 * * * ?", func() {
|
|
|
|
|
if err := cache.FlushNewerGoodsID(); err != nil {
|
|
|
|
|
fmt.Println("设置新人特惠集合 出错:", err)
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
_ = c.AddFunc("0 */10 * * * ?", func() {
|
|
|
|
|
NoticeDelete()
|
|
|
|
|
})
|
|
|
|
|
_ = c.AddFunc("0 */1 * * * ?", func() {
|
|
|
|
|
message.DeliveryTimeOut()
|
|
|
|
|
})
|
|
|
|
|
//_ = c.AddFunc("0 */1 * * * ?", func() {
|
|
|
|
|
// message.DeliveryTimeOut()
|
|
|
|
|
//})
|
|
|
|
|
_ = c.AddFunc("0 */1 * * * ?", func() {
|
|
|
|
|
order3.PlanMonitorTradeSucOrderTask()
|
|
|
|
|
})
|
|
|
|
|