feat:方法封装

p/public.go

@@ -310,24 +310,30 @@ func LoadBidding(mgo *MongodbSim, dbName, coll string, startTime int64, redisCac
 		}
 	}
 	if util.IntAll(queryField["filetext"]) > 0 {
-		array := []map[string]interface{}{}
-		for _, v := range res {
-			array = append(array, v)
-			if len(array) == 50 {
-				BiddingRepair(array, "filetext")
-				array = []map[string]interface{}{}
-			}
-		}
-		if len(array) > 0 {
-			BiddingRepair(array, "filetext")
-		}
+		BiddingRepair(res, "filetext")
 	}
 	logger.Info(coll, "数据已经加载结束。。。", index)
 	return &res, endTime
 }
 
 //
-func BiddingRepair(array []map[string]interface{}, fields string) {
+func BiddingRepair(res []map[string]interface{}, fields string) {
+	array := []map[string]interface{}{}
+	for _, v := range res {
+		array = append(array, v)
+		if len(array) == 50 {
+			OnceBiddingRepair(array, fields)
+			array = []map[string]interface{}{}
+		}
+	}
+	if len(array) > 0 {
+		OnceBiddingRepair(array, fields)
+		array = []map[string]interface{}{}
+	}
+}
+
+//
+func OnceBiddingRepair(array []map[string]interface{}, fields string) {
 	ids := []string{}
 	for _, v := range array {
 		ids = append(ids, fmt.Sprintf(`"%s"`, util.ObjToString(v["_id"])))