|
|
@@ -231,7 +231,8 @@ func ExtractByUdp(sid, eid string, ra *net.UDPAddr, instanceId ...string) {
|
|
|
} else { //普通抽取
|
|
|
query := bson.M{"_id": bson.M{"$gte": bson.ObjectIdHex(sid), "$lte": bson.ObjectIdHex(eid)}}
|
|
|
count := ext.TaskInfo.FDB.Count(ext.TaskInfo.FromColl, query)
|
|
|
- log.Debug("查询条件为:",query,"查询条数:",count) pageNum := (count + PageSize - 1) / PageSize
|
|
|
+ log.Debug("查询条件为:",query,"查询条数:",count)
|
|
|
+ pageNum := (count + PageSize - 1) / PageSize
|
|
|
limit := PageSize
|
|
|
if count < PageSize {
|
|
|
limit = count
|
fengweiqiang