diff --git a/consume/zhios_tikTok_goods_update.go b/consume/zhios_tikTok_goods_update.go index 2191452..be1f587 100644 --- a/consume/zhios_tikTok_goods_update.go +++ b/consume/zhios_tikTok_goods_update.go @@ -4,6 +4,7 @@ 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" @@ -99,6 +100,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)) get, _ := eg.Where("gid=? and activity_id=?", v.GoodsID, canalMsg.Cid).Get(&tmp) if get { //if tmp.IsDown == 1 {