|
@@ -20,6 +20,43 @@ type AfterPay struct {
|
|
|
setUserInfo xweb.Mapper `xweb:"/afterPay/setUserInfo"` //保存用户当前支付后的信息
|
|
|
}
|
|
|
|
|
|
+//初始化vip订阅关键词
|
|
|
+func MergeKws() {
|
|
|
+ defer qutil.Catch()
|
|
|
+ userId, _ := a.GetSession("userId").(string)
|
|
|
+ if userId == "" {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ data, ok := util.MQFW.FindById("user", userId, `{"o_jy":1,"o_vipjy":1}`)
|
|
|
+ var o_jy map[string]interface{}
|
|
|
+ var o_vipjy map[string]interface{}
|
|
|
+ if ok && data != nil && len(*data) > 0 {
|
|
|
+ o_vipjy, _ = (*data)["o_vipjy"].(map[string]interface{})
|
|
|
+ a_items, _ := o_vipjy["a_items"].([]interface{})
|
|
|
+ if a_items == nil { //首次
|
|
|
+ var o_kws = make(map[string]interface{})
|
|
|
+ o_jy, _ = (*data)["o_jy"].(map[string]interface{})
|
|
|
+ a_key, _ := o_jy["a_key"].([]interface{})
|
|
|
+ var _key = make([]map[string]interface{}, len(a_key))
|
|
|
+ if len(a_key) > 0 {
|
|
|
+ o_kws["s_item"] = "未分类"
|
|
|
+ for k, v := range a_key {
|
|
|
+ keyarr := v.(map[string]interface{})
|
|
|
+ _key[k] = map[string]interface{}{"key": keyarr["key"].([]interface{})}
|
|
|
+ }
|
|
|
+ }
|
|
|
+ o_kws["a_key"] = _key
|
|
|
+ if o_kws != nil && len(o_kws) > 0 {
|
|
|
+ a := util.MQFW.UpdateById("user", userId, bson.M{
|
|
|
+ "$push": bson.M{"o_vipjy.a_items": o_kws},
|
|
|
+ })
|
|
|
+ log.Println(a)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
//
|
|
|
func (a *AfterPay) SetUserInfo() error {
|
|
|
defer qutil.Catch()
|