|
|
@@ -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 { |
|
|
|