添加延时时间

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)