fix:redis 缓存放开

src/jfw/modules/publicapply/src/bidcollection/entity/entity.go

@@ -521,25 +521,27 @@ func GetInfoById(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, idlist
 	}
 	infos := map[string]map[string]interface{}{}
 	//redis
-	//es_ids := ids
-	//for _, v := range ids {
-	//	info_i := redis.Get("pushcache_1", fmt.Sprintf("info_%s", v))
-	//	if info_i != nil {
-	//		info_m, _ := info_i.(map[string]interface{})
-	//		info_m["_id"] = v
-	//		infos[v] = info_m
-	//	} else {
-	//		es_ids = append(es_ids, v)
-	//	}
-	//}
-	//	log.Println(es_ids)
+	es_ids := ids
+	for _, v := range ids {
+		info_i := redis.Get("pushcache_1", fmt.Sprintf("info_%s", v))
+		if info_i != nil {
+			info_m, _ := info_i.(map[string]interface{})
+			info_m["_id"] = v
+			infos[v] = info_m
+		} else {
+			es_ids = append(es_ids, v)
+		}
+	}
+	log.Println(es_ids)
 	//elasticsearch
 
-	list := elastic.Get("bidding", "bidding", fmt.Sprintf(querys, strings.Join(ids, `","`), len(ids)))
-	if list != nil {
-		for _, v := range *list {
-			_id := qu.ObjToString(v["_id"])
-			infos[_id] = v
+	if len(es_ids) > 0 {
+		list := elastic.Get("bidding", "bidding", fmt.Sprintf(querys, strings.Join(es_ids, `","`), len(es_ids)))
+		if list != nil {
+			for _, v := range *list {
+				_id := qu.ObjToString(v["_id"])
+				infos[_id] = v
+			}
 		}
 	}