|
@@ -333,7 +333,7 @@ func pcSetUserKeys(user map[string]interface{}, shareid, pccodepre string) (map[
|
|
|
}
|
|
|
if len(newkeys) > 0 {
|
|
|
for _, keys := range newkeys {
|
|
|
- tmp = append(tmp, map[string]interface{}{"key": strings.Split(keys, "++")})
|
|
|
+ tmp = append(tmp, map[string]interface{}{"key": strings.Split(keys, "++"), "notkey": []string{}, "area": []string{}, "from": 1})
|
|
|
}
|
|
|
o_jy["a_key"] = tmp
|
|
|
result = "ok"
|
|
@@ -342,14 +342,14 @@ func pcSetUserKeys(user map[string]interface{}, shareid, pccodepre string) (map[
|
|
|
}
|
|
|
} else {
|
|
|
for _, key := range keys {
|
|
|
- tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++")})
|
|
|
+ tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++"), "notkey": []string{}, "area": []string{}, "from": 1})
|
|
|
}
|
|
|
o_jy["a_key"] = tmp
|
|
|
result = "ok"
|
|
|
}
|
|
|
} else {
|
|
|
for _, key := range keys {
|
|
|
- tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++")})
|
|
|
+ tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++"), "notkey": []string{}, "area": []string{}, "from": 1})
|
|
|
}
|
|
|
o_jy["a_key"] = tmp
|
|
|
result = "ok"
|
|
@@ -358,7 +358,7 @@ func pcSetUserKeys(user map[string]interface{}, shareid, pccodepre string) (map[
|
|
|
} else {
|
|
|
tmp := []interface{}{}
|
|
|
for _, key := range keys {
|
|
|
- tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++")})
|
|
|
+ tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++"), "notkey": []string{}, "area": []string{}, "from": 1})
|
|
|
}
|
|
|
o_jy["a_key"] = tmp
|
|
|
result = "ok"
|
|
@@ -367,8 +367,8 @@ func pcSetUserKeys(user map[string]interface{}, shareid, pccodepre string) (map[
|
|
|
user["o_jy"] = o_jy
|
|
|
} else {
|
|
|
tmp := []interface{}{}
|
|
|
- for _, key := range keys {
|
|
|
- tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++")})
|
|
|
+ for _, key := range keys { //订阅指令以及pc端订阅向导订阅 from :1
|
|
|
+ tmp = append(tmp, map[string]interface{}{"key": strings.Split(key, "++"), "notkey": []string{}, "area": []string{}, "from": 1})
|
|
|
}
|
|
|
user["o_jy"] = map[string]interface{}{
|
|
|
"a_key": tmp,
|
|
@@ -1936,11 +1936,12 @@ func fastSubscribe(content, openId string) (int, string, bool) {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- key := map[string][]string{}
|
|
|
+ key := map[string]interface{}{}
|
|
|
key["key"] = strings.Split(keyWord, "++")
|
|
|
key["notkey"] = []string{}
|
|
|
key["infotype"] = []string{}
|
|
|
key["area"] = []string{}
|
|
|
+ key["from"] = 1
|
|
|
a_key = append(a_key, key)
|
|
|
tools.MQFW.Update("user", `{"s_m_openid":"`+openId+`"}`, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|