From 11809442cb728947125f28dd844b3218cf0ba11e Mon Sep 17 00:00:00 2001
From: kanade <kanade@kumo.work>
Date: Wed, 23 Nov 2022 10:25:53 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=B9=B6=E5=8F=91=E6=93=8D?=
 =?UTF-8?q?=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/cron/supply.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/cron/supply.go b/internal/cron/supply.go
index 9a89637..53c64bf 100644
--- a/internal/cron/supply.go
+++ b/internal/cron/supply.go
@@ -88,8 +88,8 @@ func (s *supplyTask) data() {
 		time.Sleep(time.Second * 3)
 		s.data()
 	}()
-	pool, _ := ants.NewPool(5)
-	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) {
+	pool, _ := ants.NewPool(30)
+	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 {