|
|
@@ -195,7 +195,7 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
}
|
|
|
vip_lock.Lock.Lock()
|
|
|
defer vip_lock.Lock.Unlock()
|
|
|
- data, ok := util.MQFW.FindById("user", userId, `{"o_vipjy":1}`)
|
|
|
+ data := util.Compatible.Select(userId, `{"o_vipjy":1}`)
|
|
|
keys := a.GetString("keys")
|
|
|
var repleat = false
|
|
|
var classify_index = -1
|
|
|
@@ -203,7 +203,7 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
if len([]rune(keys)) > 20 {
|
|
|
keys = qutil.SubString(keys, 0, 20)
|
|
|
}
|
|
|
- if ok && data != nil && len(*data) > 0 && keys != "" {
|
|
|
+ if data != nil && len(*data) > 0 && keys != "" {
|
|
|
o_vipjy, _ := (*data)["o_vipjy"].(map[string]interface{})
|
|
|
if o_vipjy["a_items"] != nil {
|
|
|
a_items := o_vipjy["a_items"].([]interface{})
|
|
|
@@ -243,7 +243,7 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
_key["key"] = strings.Split(keys, " ")
|
|
|
a_key[0] = _key
|
|
|
if len(a_key) > 0 {
|
|
|
- ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ ok := util.Compatible.Update(userId, bson.M{
|
|
|
"$push": bson.M{
|
|
|
"o_vipjy.a_items." + strconv.Itoa(classify_index) + ".a_key": bson.M{
|
|
|
"$each": a_key,
|
|
|
@@ -276,15 +276,15 @@ func (a *AfterPay) UpdateUserTips() error {
|
|
|
if userId != "" {
|
|
|
classify_index := a.GetString("classify_index")
|
|
|
kws_tips, _ := a.GetInteger("kws_tips")
|
|
|
- data, ok := util.MQFW.FindById("user", userId, `{"o_vipjy.a_items":1}`)
|
|
|
- if ok && data != nil && len(*data) > 0 {
|
|
|
+ data := util.Compatible.Select(userId, `{"o_vipjy.a_items":1}`)
|
|
|
+ if data != nil && len(*data) > 0 {
|
|
|
o_vipjy, _ := (*data)["o_vipjy"].(map[string]interface{})
|
|
|
a_items := o_vipjy["a_items"].([]interface{})
|
|
|
i, _ := strconv.Atoi(classify_index)
|
|
|
if i < len(a_items) {
|
|
|
saveData := make(map[string]interface{})
|
|
|
saveData["o_vipjy.a_items."+classify_index+".i_tips"] = kws_tips
|
|
|
- flag = util.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
+ flag = util.Compatible.Update(userId, map[string]interface{}{
|
|
|
"$set": saveData,
|
|
|
})
|
|
|
}
|
|
|
@@ -420,12 +420,12 @@ func (a *AfterPay) SetUserInfo() error {
|
|
|
kwscount := a.GetString("kwscount")
|
|
|
|
|
|
//查询用vip关键词信息
|
|
|
- data, ok := util.MQFW.FindById("user", userId, `{"o_vipjy.a_items":1}`)
|
|
|
- if ok && data != nil && len(*data) > 0 {
|
|
|
+ data := util.Compatible.Select(userId, `{"o_vipjy.a_items":1}`)
|
|
|
+ if data != nil && len(*data) > 0 {
|
|
|
o_vipjy, _ := (*data)["o_vipjy"].(map[string]interface{})
|
|
|
a_items, errs := o_vipjy["a_items"].([]interface{})
|
|
|
if !errs {
|
|
|
- util.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
+ util.Compatible.Update(userId, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|
|
|
"o_vipjy.a_items": []map[string]interface{}{},
|
|
|
},
|
|
|
@@ -535,7 +535,7 @@ func (a *AfterPay) SetUserInfo() error {
|
|
|
msg = "关键词已存在"
|
|
|
} else {
|
|
|
if len(a_key) > 0 {
|
|
|
- flag = util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ flag = util.Compatible.Update(userId, bson.M{
|
|
|
"$push": bson.M{
|
|
|
"o_vipjy.a_items." + classify_index + ".a_key": bson.M{
|
|
|
"$each": a_key,
|
|
|
@@ -632,11 +632,11 @@ func (a *AfterPay) SetUserInfo() error {
|
|
|
saveData["o_vipjy.b_keytip"] = true //fasle:需要弹窗 true:不需要弹窗
|
|
|
}
|
|
|
if len(saveData) > 0 {
|
|
|
- flag = util.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
+ flag = util.Compatible.Update(userId, map[string]interface{}{
|
|
|
"$set": saveData,
|
|
|
})
|
|
|
}
|
|
|
- if data, ok := util.MQFW.FindById("user", userId, `{"o_vipjy":1}`); len(*data) > 0 && ok && data != nil {
|
|
|
+ if data := util.Compatible.Select(userId, `{"o_vipjy":1}`); len(*data) > 0 && data != nil {
|
|
|
(*data)["userid"] = userId
|
|
|
(*data)["type"] = "o_vipjy"
|
|
|
(*data)["createtime"] = time.Now().Unix()
|
WH01243