xiugai

src/jfw/modules/subscribepay/src/service/afterPay.go

@@ -410,7 +410,15 @@ func (a *AfterPay) SetUserInfo() error {
 			if ok && data != nil && len(*data) > 0 {
 				log.Println(userId)
 				o_vipjy, _ := (*data)["o_vipjy"].(map[string]interface{})
-				a_items := o_vipjy["a_items"].([]interface{})
+				a_items, errs := o_vipjy["a_items"].([]interface{})
+				log.Println("ok:", errs)
+				if !errs {
+					util.MQFW.UpdateById("user", userId, map[string]interface{}{
+						"$set": map[string]interface{}{
+							"o_vipjy.a_items": []map[string]interface{}{},
+						},
+					})
+				}
 				sitemsArr := []string{} //分类名称数组
 				for _, av := range a_items {
 					_av := qutil.ObjToMap(av)
@@ -547,6 +555,7 @@ func (a *AfterPay) SetUserInfo() error {
 									classify_index = strconv.Itoa(len(a_items)) //索引
 									saveData["o_vipjy.a_items."+classify_index+".a_key"] = []map[string]interface{}{}
 								}
+								log.Println("====", classify_index)
 								saveData["o_vipjy.a_items."+classify_index+".s_item"] = classify_name
 							}
 						}