diff --git a/internal/cron/supply.go b/internal/cron/supply.go index d4c5e86..7dad90a 100644 --- a/internal/cron/supply.go +++ b/internal/cron/supply.go @@ -8,6 +8,7 @@ import ( "log" "recook/internal/v2/lib/supply" "recook/internal/v2/logic/third" + "time" ) type skuMessage struct { @@ -53,6 +54,7 @@ func (s *supplyTask) price() { if recoverErr := recover(); recoverErr != nil { log.Println("供应链价格变动mq错误", recoverErr) } + time.Sleep(time.Second * 3) s.price() }() pool, _ := ants.NewPool(5) @@ -75,6 +77,7 @@ func (s *supplyTask) data() { if recoverErr := recover(); recoverErr != nil { log.Println("供应链商品变动mq错误", recoverErr) } + time.Sleep(time.Second * 3) s.data() }() pool, _ := ants.NewPool(5)