feat:xiugai

pushentniche/match/job/matchjob.go

@@ -50,7 +50,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, true, query, map[string]interface{}{"filetext": 1})
+	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, true, query, map[string]interface{}{"filetext": 1})
 	if datas == nil || len(*datas) == 0 {
 		return
 	}

pushfollowent/match/job/matchjob.go

@@ -30,7 +30,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, false, query, nil)
+	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, false, query, nil)
 	if datas == nil || len(*datas) == 0 {
 		logger.Info("加载数据到内存中的时候，未查找到数据！")
 		return

pushmember/match/job/matchjob.go

@@ -41,7 +41,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, true, query, map[string]interface{}{"filetext": 1})
+	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, true, query, map[string]interface{}{"filetext": 1})
 	if datas == nil || len(*datas) == 0 {
 		return
 	}

pushsubscribe/match/job/matchjob.go

@@ -28,7 +28,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, true, query, map[string]interface{}{"filetext": -1})
+	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, true, query, map[string]interface{}{"filetext": -1})
 	if datas == nil || len(*datas) == 0 {
 		logger.Info("加载数据到内存中的时候，未查找到数据！")
 		return

pushsupersub/match/job/matchjob.go

@@ -41,7 +41,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, true, query, map[string]interface{}{"filetext": 1})
+	datas, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, true, query, map[string]interface{}{"filetext": 1})
 	if datas == nil || len(*datas) == 0 {
 		logger.Info("加载数据到内存中的时候，未查找到数据！")
 		return

subrecommend/job/matchjob.go

@@ -30,7 +30,7 @@ func (m *MatchJob) Execute() {
 	// 		"$in": ToObjectIds([]string{"65d0e4f966cf0db42abe69b1", "65d0e3d666cf0db42abe6683", "65d0e34066cf0db42abe63dd", "65d0e2b466cf0db42abe62ad", "65d1713466cf0db42abef950", "5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
 	// 	},
 	// }
-	datasTemp, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", Config.LoadBiddingMaxSize, TaskConfig.Pici, false, query, map[string]interface{}{"filetext": 1, "purchasing": 1})
+	datasTemp, endTime := LoadBidding(Mgo_Bidding, DbConf.Mongodb.Bidding.DbName, DbConf.Mongodb.Bidding.Collection, "pici", TaskConfig.Pici, Config.LoadBiddingMaxSize, false, query, map[string]interface{}{"filetext": 1, "purchasing": 1})
 	TaskConfig.Pici = endTime
 	if datasTemp == nil || len(*datasTemp) == 0 {
 		return