|
@@ -32,8 +32,9 @@ func (a *AfterPay) FastImport() error {
|
|
|
flagInt := 0
|
|
|
var _keys []map[string]interface{}
|
|
|
kwsCount := 0
|
|
|
- classify_index := 0
|
|
|
- kws_index := 0
|
|
|
+ classify_index, _ := a.GetInteger("c_index")
|
|
|
+ kws_index, _ := a.GetInteger("k_index")
|
|
|
+ classify_name := a.GetString("c_name")
|
|
|
if userId != "" {
|
|
|
data, ok := util.MQFW.FindById("user", userId, `{"o_jy":1,"o_vipjy":1,"i_vip_fastimport":1}`)
|
|
|
if ok && data != nil && len(*data) > 0 {
|
|
@@ -43,14 +44,14 @@ func (a *AfterPay) FastImport() error {
|
|
|
o_vipjy, _ := (*data)["o_vipjy"].(map[string]interface{})
|
|
|
if o_vipjy["a_items"] != nil {
|
|
|
a_items := o_vipjy["a_items"].([]interface{})
|
|
|
- for k, v := range a_items {
|
|
|
+ for _, v := range a_items {
|
|
|
tmp := qutil.ObjToMap(v.(map[string]interface{}))
|
|
|
a_key := (*tmp)["a_key"].([]interface{})
|
|
|
kwsCount = kwsCount + len(a_key)
|
|
|
- if (*tmp)["s_item"] == "未分类" {
|
|
|
- classify_index = k
|
|
|
- kws_index = len(a_key)
|
|
|
- }
|
|
|
+ // if (*tmp)["s_item"] == "未分类" {
|
|
|
+ // classify_index = k
|
|
|
+ // kws_index = len(a_key)
|
|
|
+ // }
|
|
|
for _, n := range a_key {
|
|
|
ntmp := qutil.ObjToMap(n.(interface{}))
|
|
|
nkey := qutil.ObjArrToStringArr((*ntmp)["key"].([]interface{}))
|
|
@@ -70,28 +71,20 @@ func (a *AfterPay) FastImport() error {
|
|
|
if len(_keys)+kwsCount >= 300 {
|
|
|
_keys = _keys[:(300 - kwsCount)]
|
|
|
}
|
|
|
- if classify_index == 0 && kws_index == 0 {
|
|
|
- //首次添加分类和关键词
|
|
|
- var o_kws = make(map[string]interface{})
|
|
|
- classify_name := "未分类"
|
|
|
- o_kws["s_item"] = classify_name
|
|
|
- o_kws["i_tips"] = 0
|
|
|
- o_kws["a_key"] = _keys
|
|
|
- ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
- "$push": bson.M{"o_vipjy.a_items": o_kws},
|
|
|
- "$set": bson.M{"o_vipjy.l_modifydate": time.Now().Unix(), "i_vip_fastimport": 1},
|
|
|
- })
|
|
|
- if ok {
|
|
|
- flagInt = 1 //导入成功
|
|
|
- }
|
|
|
- } else {
|
|
|
- ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
- "$push": bson.M{"o_vipjy.a_items." + strconv.Itoa(classify_index) + ".a_key": bson.M{"$each": _keys}},
|
|
|
- "$set": bson.M{"o_vipjy.l_modifydate": time.Now().Unix(), "i_vip_fastimport": 1},
|
|
|
- })
|
|
|
- if ok {
|
|
|
- flagInt = 1 //导入成功
|
|
|
- }
|
|
|
+ ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ "$push": bson.M{
|
|
|
+ "o_vipjy.a_items." + strconv.Itoa(classify_index) + ".a_key": bson.M{
|
|
|
+ "$each": _keys,
|
|
|
+ },
|
|
|
+ },
|
|
|
+ "$set": bson.M{
|
|
|
+ "o_vipjy.l_modifydate": time.Now().Unix(),
|
|
|
+ "i_vip_fastimport": 1,
|
|
|
+ "o_vipjy.a_items." + strconv.Itoa(classify_index) + ".s_item": classify_name,
|
|
|
+ },
|
|
|
+ })
|
|
|
+ if ok {
|
|
|
+ flagInt = 1 //导入成功
|
|
|
}
|
|
|
}
|
|
|
} else {
|
|
@@ -128,7 +121,7 @@ func (a *AfterPay) CheckOrder() error {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
+//搜索关键词直接订阅
|
|
|
func (a *AfterPay) DirectSubKWS() error {
|
|
|
defer qutil.Catch()
|
|
|
userId, _ := a.GetSession("userId").(string)
|
|
@@ -138,9 +131,11 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
keys := a.GetString("keys")
|
|
|
var repleat = false
|
|
|
var classify_index = 0
|
|
|
- var kws_index = 0
|
|
|
var kwsCount = 0
|
|
|
- if ok && data != nil && len(*data) > 0 {
|
|
|
+ if len([]rune(keys)) > 20 {
|
|
|
+ keys = qutil.SubString(keys, 0, 20)
|
|
|
+ }
|
|
|
+ if ok && 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{})
|
|
@@ -150,7 +145,6 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
kwsCount = kwsCount + len(a_key)
|
|
|
if (*tmp)["s_item"] == "未分类" {
|
|
|
classify_index = k
|
|
|
- kws_index = len(a_key)
|
|
|
}
|
|
|
for _, n := range a_key {
|
|
|
ntmp := qutil.ObjToMap(n.(interface{}))
|
|
@@ -170,31 +164,23 @@ func (a *AfterPay) DirectSubKWS() error {
|
|
|
} else if kwsCount >= 300 {
|
|
|
flag = "m"
|
|
|
} else {
|
|
|
- if classify_index == 0 && kws_index == 0 {
|
|
|
- //首次添加分类和关键词
|
|
|
- var _key = make(map[string]interface{})
|
|
|
- var a_key = make([]map[string]interface{}, 1)
|
|
|
- var o_kws = make(map[string]interface{})
|
|
|
- classify_name := "未分类"
|
|
|
- o_kws["s_item"] = classify_name
|
|
|
- _key["key"] = strings.Split(keys, " ")
|
|
|
- a_key[0] = _key
|
|
|
- o_kws["a_key"] = a_key
|
|
|
- o_kws["i_tips"] = 0
|
|
|
- if o_kws != nil && len(o_kws) > 0 {
|
|
|
- ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
- "$push": bson.M{"o_vipjy.a_items": o_kws},
|
|
|
- "$set": bson.M{"o_vipjy.l_modifydate": time.Now().Unix()},
|
|
|
- })
|
|
|
- if ok {
|
|
|
- flag = "y"
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- var saveData = make(map[string]interface{})
|
|
|
- saveData["o_vipjy.a_items."+strconv.Itoa(classify_index)+".a_key."+strconv.Itoa(kws_index)+".key"] = strings.Split(keys, " ")
|
|
|
- ok := util.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
- "$set": saveData,
|
|
|
+ //首次添加分类和关键词
|
|
|
+ var _key = make(map[string]interface{})
|
|
|
+ var a_key = make([]map[string]interface{}, 1)
|
|
|
+ classify_name := "未分类"
|
|
|
+ _key["key"] = strings.Split(keys, " ")
|
|
|
+ a_key[0] = _key
|
|
|
+ if len(a_key) > 0 {
|
|
|
+ ok := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ "$push": bson.M{
|
|
|
+ "o_vipjy.a_items." + strconv.Itoa(classify_index) + ".a_key": bson.M{
|
|
|
+ "$each": a_key,
|
|
|
+ },
|
|
|
+ },
|
|
|
+ "$set": bson.M{
|
|
|
+ "o_vipjy.l_modifydate": time.Now().Unix(),
|
|
|
+ "o_vipjy.a_items." + strconv.Itoa(classify_index) + ".s_item": classify_name,
|
|
|
+ },
|
|
|
})
|
|
|
if ok {
|
|
|
flag = "y"
|
|
@@ -281,7 +267,6 @@ func (a *AfterPay) SetUserInfo() error {
|
|
|
kws_index := a.GetString("kws_index")
|
|
|
kws_name := strings.Trim(a.GetString("kws_name"), " ")
|
|
|
actionType := a.GetString("actionType")
|
|
|
- kwscount := a.GetString("kwscount")
|
|
|
addtion_kws := a.GetSlice("addition_kws")
|
|
|
not_kws := a.GetSlice("not_kws")
|
|
|
if len([]rune(kws_name)) > 20 {
|
|
@@ -310,38 +295,29 @@ func (a *AfterPay) SetUserInfo() error {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- if kwscount != "0" {
|
|
|
- //修改关键词
|
|
|
- saveData["o_vipjy.a_items."+classify_index+".s_item"] = classify_name
|
|
|
- saveData["o_vipjy.a_items."+classify_index+".a_key."+kws_index+".key"] = _kws
|
|
|
- if len(addtion_kws) > 0 {
|
|
|
- saveData["o_vipjy.a_items."+classify_index+".a_key."+kws_index+".appendkey"] = addtion_kws
|
|
|
- }
|
|
|
- if len(not_kws) > 0 {
|
|
|
- saveData["o_vipjy.a_items."+classify_index+".a_key."+kws_index+".notkey"] = not_kws
|
|
|
- }
|
|
|
- } else {
|
|
|
- //首次添加分类和关键词
|
|
|
- var _key = make(map[string]interface{})
|
|
|
- var a_key = make([]map[string]interface{}, 1)
|
|
|
- var o_kws = make(map[string]interface{})
|
|
|
- if classify_name == "" {
|
|
|
- classify_name = "未分类"
|
|
|
- }
|
|
|
- o_kws["s_item"] = classify_name
|
|
|
- _key["key"] = _kws
|
|
|
- _key["appendkey"] = addtion_kws
|
|
|
- _key["notkey"] = not_kws
|
|
|
- a_key[0] = _key
|
|
|
- o_kws["a_key"] = a_key
|
|
|
- o_kws["i_tips"] = 0
|
|
|
- if o_kws != nil && len(o_kws) > 0 {
|
|
|
- flag = util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
- "$push": bson.M{"o_vipjy.a_items": o_kws},
|
|
|
- "$set": bson.M{"o_vipjy.l_modifydate": time.Now().Unix()},
|
|
|
- })
|
|
|
- }
|
|
|
+ var _key = make(map[string]interface{})
|
|
|
+ var a_key = make([]map[string]interface{}, 1)
|
|
|
+ if classify_name == "" {
|
|
|
+ classify_name = "未分类"
|
|
|
+ }
|
|
|
+ _key["key"] = _kws
|
|
|
+ _key["appendkey"] = addtion_kws
|
|
|
+ _key["notkey"] = not_kws
|
|
|
+ a_key[0] = _key
|
|
|
+ if len(a_key) > 0 {
|
|
|
+ flag = util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ "$push": bson.M{
|
|
|
+ "o_vipjy.a_items." + classify_index + ".a_key": bson.M{
|
|
|
+ "$each": a_key,
|
|
|
+ },
|
|
|
+ },
|
|
|
+ "$set": bson.M{
|
|
|
+ "o_vipjy.l_modifydate": time.Now().Unix(),
|
|
|
+ "o_vipjy.a_items." + classify_index + ".s_item": classify_name,
|
|
|
+ },
|
|
|
+ })
|
|
|
}
|
|
|
+ // }
|
|
|
} else if actionType == "DK" { //删除关键词
|
|
|
data, ok := util.MQFW.FindById("user", userId, `{"o_vipjy.a_items":1}`)
|
|
|
if ok && data != nil && len(*data) > 0 {
|