更新

src/jfw/modules/bigmember/src/service/analysis/forecastproject.go

@@ -121,6 +121,8 @@ func (this *Analysis) ForPList() {
 				pageNum, _ := this.GetInteger("pageNum")
 				list, count = getNewProjects(main_userId, pageNum)
 				o_member_jy := qutil.ObjToMap((*o_mb)["o_member_jy"])
+				//项目预测检索库
+				getNewForecast(main_userId, pageNum, *o_member_jy)
 				if pageNum == 1 {
 					if (*o_member_jy)["a_items"] != nil {
 						a_items := qutil.ObjArrToMapArr((*o_member_jy)["a_items"].([]interface{}))
@@ -204,3 +206,49 @@ func keysfilter(result []map[string]interface{}) (res []map[string]interface{})
 	}
 	return res
 }
+
+//
+func getNewForecast(userId string, cpage int, o_member_jy map[string]interface{}) ([]map[string]interface{}, int) {
+	if cpage == 0 {
+		cpage = 1
+	}
+	var count int
+	log.Println(o_member_jy, count)
+	return nil, 0
+}
+
+//
+func SubViewDatas(userId, allquery string, pageNum, pageSize int) (keys []interface{}, list *[]map[string]interface{}, hasNextPage bool, count int64) {
+	// if userId == "" {
+	// 	return
+	// }
+	// sql := GetSqlObjFromId(userId, "", -1)
+	// if sql == nil {
+	// 	return
+	// }
+	// //PC端
+	// if pageSize == 0 || pageSize > 100 {
+	// 	pageSize = view_pageSize
+	// }
+	// for _, v := range sql.Keyword {
+	// 	var keys_one []string
+	// 	for _, k := range v.Keyword {
+	// 		keys_one = append(keys_one, k)
+	// 	}
+	// 	//dev3.5 附加词也要高亮
+	// 	for _, k := range v.Appended {
+	// 		keys_one = append(keys_one, k)
+	// 	}
+	// 	keys = append(keys, strings.Join(keys_one, "++"))
+	// }
+	// qstr := GetMemberViewSql(sql)
+	// count = elastic.Count(INDEX, TYPE, qstr)
+	// list = elastic.GetAllByNgram(INDEX, TYPE, qstr, findfields, bidSearch_sort, bidSearch_field, (pageNum-1)*pageSize, pageSize, 0, false)
+	// if list != nil {
+	// 	for _, v := range *list {
+	// 		v["_id"] = EncodeId(qutil.ObjToString(v["_id"]))
+	// 	}
+	// }
+	// hasNextPage = list != nil && len(*list) == pageSize && pageNum < view_maxPageNum
+	return
+}

src/jfw/modules/common/src/qfw/util/jy/bigVipPower.go

@@ -108,7 +108,7 @@ func GetBigVipUserBaseMsg(userId string, mysql *mysql.Mysql, mg MongodbSim) *Big
 		}
 	}
 	//大会员状态
-	data, ok := mg.FindById("user", userId, `{"i_member_status":1,"i_member_give":1,"s_member_mainid":1,"i_member_sub_status":1,"i_member_trial":1,"i_vip_status":1,"o_jy.o_area":1}`)
+	data, ok := mg.FindById("user", userId, `{"i_member_status":1,"i_member_give":1,"s_member_mainid":1,"i_member_sub_status":1,"i_member_trial":1,"i_vip_status":1,"o_vipjy":1,"o_jy":1}`)
 	if ok && *data != nil && len(*data) > 0 {
 		userPower.Status = qutil.IntAllDef((*data)["i_member_status"], 0)
 		//子账号被启用