|
@@ -739,7 +739,7 @@ func (i *Info) AppNewUerSales() {
|
|
|
}
|
|
|
}
|
|
|
infoMap["keyword"] = keyWord
|
|
|
- oJy := jy.GetSubScribeInfo(i.Session(), MQFW, "f", "10000") //免费用户关键词
|
|
|
+ oJy := jy.GetSubScribeInfo(i.Session(), MQFW, "", "10000") //免费用户关键词
|
|
|
vipJy := jy.GetSubScribeInfo(i.Session(), MQFW, "v", "10000") //超级订阅关键词
|
|
|
memberJy := jy.GetSubScribeInfo(i.Session(), MQFW, "m", "10000") //大会员关键词
|
|
|
if data.Data.Member.Status > 0 {
|
|
@@ -767,7 +767,7 @@ func (i *Info) AppNewUerSales() {
|
|
|
if !keyB || a_key == nil || len(a_key) == 0 {
|
|
|
//不存在关键词 填充
|
|
|
var arryMap []map[string]interface{}
|
|
|
- for _, v := range keyWord {
|
|
|
+ for _, v := range key {
|
|
|
arryMap = append(arryMap, map[string]interface{}{"from": 1, "appendkey": nil, "key": processKeyword(v), "notkey": nil, "updatetime": time.Now().Unix()})
|
|
|
}
|
|
|
(*oJy)["a_key"] = arryMap
|
|
@@ -791,7 +791,7 @@ func (i *Info) AppNewUerSales() {
|
|
|
|
|
|
}
|
|
|
go SetLog(userId, types)
|
|
|
- if len(keyWord) > 0 {
|
|
|
+ if len(m) > 0 {
|
|
|
jy.Publish(Mgo_Log, Sysconfig.Nsq, Sysconfig.NsqTopic, "task", qu.ObjToString(i.GetSession("mgoUserId")), jy.Jywx_node1, map[string]interface{}{
|
|
|
"code": 1015, //首次订阅
|
|
|
"types": "subscribeKeyWords",
|