|
@@ -71,7 +71,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
limit = sum
|
|
|
}
|
|
|
for i := 0; i < pageNum; i++ {
|
|
|
- query = bson.M{"_id": bson.M{"$gte": bson.ObjectIdHex(gid)}}
|
|
|
+ query = bson.M{"_id": bson.M{"$gte": bson.ObjectIdHex(gid), "$lte": bson.ObjectIdHex(lid)}}
|
|
|
log.Println("page=", i+1,"query=", query)
|
|
|
list, b := mongodbutil.Mgo.Find(MgoC,query,nil,bson.M{"_id": 1,MgoFileFiled:1},false,0, limit)
|
|
|
if !b{
|
|
@@ -98,7 +98,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
ChanB <- true
|
|
|
if qu.ObjToString(fileinfo["fid"]) ==""{
|
|
|
<-ChanB
|
|
|
- log.Println(mid, "mgo ", MgoFileFiled,"没有fid ",fileinfo)
|
|
|
+ log.Println(mid, "mgo ", MgoFileFiled,"没有fid ")
|
|
|
continue
|
|
|
}
|
|
|
save(mid,attk, qmap, &fileinfo,&updateNum)
|
|
@@ -184,6 +184,7 @@ func save(mid interface{},attk string, qmap, fileinfo *map[string]interface{},up
|
|
|
} else {
|
|
|
(*fileinfo)["content"] = rdata["context"]
|
|
|
}
|
|
|
+ (*fileinfo)["expend"] = rdata["expend"]
|
|
|
//log.Println((*fileinfo))
|
|
|
|
|
|
(*qmap)[MgoFileFiled].(map[string]interface{})["attachments"].(map[string]interface{})[attk]=*fileinfo
|