添加并发操作

internal/cron/supply.go

@@ -88,8 +88,8 @@ func (s *supplyTask) data() {
 		time.Sleep(time.Second * 3)
 		s.data()
 	}()
-	pool, _ := ants.NewPool(5)
+	pool, _ := ants.NewPool(30)
-	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) {
+	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 30, func(message skuMessage, delivery amqp.Delivery) {
 		pool.Submit(func() {
 			defer delivery.Ack(false)
 			if err := third.SupplyLogic.SyncData([]uint{message.SkuId}); err != nil {