From 4c5bbc17d3e949ef5205d23c6aadbd3b845ac5ef Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Wed, 14 Jun 2023 15:59:45 +0800
Subject: [PATCH] =?UTF-8?q?=E8=81=9A=E5=90=88=E5=85=85=E5=80=BC+=E6=8A=96?=
 =?UTF-8?q?=E9=9F=B3=E5=9B=A2=E9=95=BF=E5=95=86=E5=93=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consume/zhios_tikTok_goods_update.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/consume/zhios_tikTok_goods_update.go b/consume/zhios_tikTok_goods_update.go
index be1f587..1c06ee4 100644
--- a/consume/zhios_tikTok_goods_update.go
+++ b/consume/zhios_tikTok_goods_update.go
@@ -4,7 +4,6 @@ import (
 	"applet/app/db"
 	"applet/app/db/model"
 	"applet/app/utils"
-	"applet/app/utils/cache"
 	"applet/app/utils/logx"
 	"applet/consume/md"
 	"code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit"
@@ -26,7 +25,7 @@ func ZhiosTikTokUpdate(queue md.MqQueue) {
 	//1、将自己绑定到交换机上
 	ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey)
 	//2、取出数据进行消费
-	ch.Qos(20)
+	ch.Qos(5)
 	delivery := ch.Consume(queue.Name, true)
 
 	var res amqp.Delivery
@@ -58,7 +57,7 @@ func ZhiosTikTokAllUpdate(queue md.MqQueue) {
 	//1、将自己绑定到交换机上
 	ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey)
 	//2、取出数据进行消费
-	ch.Qos(15)
+	ch.Qos(5)
 	delivery := ch.Consume(queue.Name, true)
 
 	var res amqp.Delivery
@@ -100,7 +99,7 @@ func handleZhiosTikTokGoodsUpdate(msg []byte) error {
 	var v md.TikTokData
 	json.Unmarshal([]byte(canalMsg.Data), &v)
 	var tmp model.TikTokTeamGoods
-	cache.HSet("tik_"+canalMsg.Mid, canalMsg.Cid+"_"+v.GoodsID, string(msg))
+	//cache.HSet("tik_"+canalMsg.Mid, canalMsg.Cid+"_"+v.GoodsID, string(msg))
 	get, _ := eg.Where("gid=? and activity_id=?", v.GoodsID, canalMsg.Cid).Get(&tmp)
 	if get {
 		//if tmp.IsDown == 1 {