|
@@ -189,7 +189,7 @@ func PrapareCodeBaseInfo() {
|
|
|
map[string]interface{}{
|
|
|
"platform": "python",
|
|
|
"state": map[string]interface{}{
|
|
|
- "$in": []int{1, 2, 6}, //待审核、未通过
|
|
|
+ "$in": []int{1, 2, 6}, //待审核、未通过、已下架
|
|
|
},
|
|
|
},
|
|
|
},
|
|
@@ -1107,7 +1107,7 @@ func CreateTask(t *Task, sp *Spider, upsertBulk *[][]map[string]interface{}, loc
|
|
|
} else if state_old == 0 && t.State == 0 && t.ErrType > qu.IntAll(type_old) { //新任务、历史任务均为待确认,取异常类型等级高者
|
|
|
result["s_type"] = fmt.Sprint(t.ErrType)
|
|
|
}
|
|
|
- if times_old >= 3 { //某爬虫第四次建任务时,任务状态变为待处理
|
|
|
+ if times_old > 3 { //某爬虫第四次建任务时,任务状态变为待处理
|
|
|
result["i_state"] = 1
|
|
|
}
|
|
|
//任务紧急度urgency
|