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 { 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", + }, } )