|
|
@@ -62,8 +62,8 @@ func StartTask() {
|
|
|
LatestId = endId //替换起始id
|
|
|
field := map[string]interface{}{"detail": 1}
|
|
|
logger.Debug("query：", q)
|
|
|
- it := sess.DB("mxs").C("bidding_back").Find(q).Select(field).Sort("_id").Iter()
|
|
|
- count := Mgo.Count("bidding_back", q)
|
|
|
+ it := sess.DB("qfw").C("bidding").Find(q).Select(field).Sort("_id").Iter()
|
|
|
+ count := Mgo.Count("bidding", q)
|
|
|
fmt.Println("共加载数据", count)
|
|
|
sum := 0
|
|
|
wg := &sync.WaitGroup{}
|
|
|
@@ -190,7 +190,7 @@ func InitDomainName() {
|
|
|
func GetEndId(query map[string]interface{}) (string, bool) {
|
|
|
endId := ""
|
|
|
ok := false
|
|
|
- list, _ := Mgo.Find("bidding_back", query, `{"_id":-1}`, `{_id:1}`, false, 0, 1)
|
|
|
+ list, _ := Mgo.Find("bidding", query, `{"_id":-1}`, `{_id:1}`, false, 0, 1)
|
|
|
if len(*list) == 1 {
|
|
|
endId = mgo.BsonIdToSId((*list)[0]["_id"])
|
|
|
if endId >= LatestId {
|
