@@ -68,6 +68,9 @@ func RunExtractTestTask(ext *ExtractTask, startId, num string) bool {
query := bson.M{"_id": bson.M{"$gte": bson.ObjectIdHex(startId)}}
list, _ := ext.TaskInfo.FDB.Find(ext.TaskInfo.FromColl, query, nil, Fields, false, 0, n)
for _, v := range *list {
+ if qu.ObjToString(v["sensitive"]) != "" { //去除含敏感词数据
+ continue
+ }
//log.Println(v["_id"])
j := PreInfo(v)
ext.TaskInfo.ProcessPool <- true