From c02ce7916f62d26f56a2d6687d8510767fa02cf7 Mon Sep 17 00:00:00 2001 From: kanade Date: Wed, 23 Nov 2022 11:29:00 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0type?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/define/constant.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/define/constant.go b/internal/define/constant.go index 037e1e9..5fa3b34 100755 --- a/internal/define/constant.go +++ b/internal/define/constant.go @@ -37,6 +37,11 @@ var ( AppId: "wxf95835be72b5373c", AppSecret: "1153b31349a1791f56bd542181beeab1", }, + "recook-wxh5": { + Type: "wx", + AppId: "wx0a67d8af4a8252b0", + AppSecret: "de4494be68c27fb306448f46718cbd13", + }, } ) From 4ae2dda68a8e1951769cab04ae853008ff5d4aa6 Mon Sep 17 00:00:00 2001 From: kanade Date: Wed, 23 Nov 2022 11:40:22 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=8D=8F=E7=A8=8B?= 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 53c64bf..d267096 100644 --- a/internal/cron/supply.go +++ b/internal/cron/supply.go @@ -65,8 +65,8 @@ func (s *supplyTask) price() { time.Sleep(time.Second * 3) s.price() }() - pool, _ := ants.NewPool(5) - if err := (skuMessage{}.Consume(supply.Api.Mq.SkuPriceChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) { + pool, _ := ants.NewPool(30) + if err := (skuMessage{}.Consume(supply.Api.Mq.SkuPriceChangeQueue(), false, 30, func(message skuMessage, delivery amqp.Delivery) { pool.Submit(func() { defer delivery.Ack(false) if err := third.SupplyLogic.SyncPrice([]uint{message.SkuId}); err != nil {