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