|
@@ -687,12 +687,14 @@ func (s *Spider) DownloadHighDetail() {
|
|
|
for {
|
|
|
logger.Info("Running Code:", s.Code, "Stop:", s.Stop)
|
|
|
if !s.Stop { //爬虫是运行状态
|
|
|
+ comeintimeQuery := map[string]interface{}{"$gte": GetTime(-util.Config.DayNum)} //采集一周内的数据,防止有数据一直采不下来,造成积累
|
|
|
+ if delayDay := util.Config.DelaySites[s.Name]; delayDay > 0 && delayDay <= util.Config.DayNum { //判断该爬虫是否属于要延迟采集的站点
|
|
|
+ comeintimeQuery["$lte"] = GetTime(-delayDay + 1)
|
|
|
+ }
|
|
|
q := map[string]interface{}{
|
|
|
"spidercode": s.Code,
|
|
|
"state": 0, //0:入库状态;-1:采集失败;1:成功
|
|
|
- "comeintime": map[string]interface{}{ //采集一周内的数据,防止有数据一直采不下来,造成积累
|
|
|
- "$gte": GetTime(-util.Config.DayNum),
|
|
|
- },
|
|
|
+ "comeintime": comeintimeQuery,
|
|
|
}
|
|
|
o := map[string]interface{}{"_id": -1}
|
|
|
f := map[string]interface{}{
|