extract

src/jy/extract/extract.go

@@ -811,29 +811,26 @@ func AnalysisSaveResult(j *ju.Job, e *ExtractTask) {
 	}
 
 	if e.TaskInfo.TestColl == "" {
-		if 1 == 2 {
-
-			if len(tmp) > 0 { //保存抽取结果
-				tmparr := []map[string]interface{}{
-					map[string]interface{}{
-						"_id": qu.StringTOBsonId(_id),
-					},
-					map[string]interface{}{"$set": tmp},
-				}
-				e.BidArr = append(e.BidArr, tmparr)
+		if len(tmp) > 0 { //保存抽取结果
+			tmparr := []map[string]interface{}{
+				map[string]interface{}{
+					"_id": qu.StringTOBsonId(_id),
+				},
+				map[string]interface{}{"$set": tmp},
 			}
-			if b, ok := ju.Config["saveresult"].(bool); ok && b {
-				id := tmp["_id"]
-				tmp["result"] = result
-				delete(tmp, "_id")
-				tmparr := []map[string]interface{}{
-					map[string]interface{}{
-						"_id": id,
-					},
-					map[string]interface{}{"$set": tmp},
-				}
-				e.ResultArr = append(e.ResultArr, tmparr)
+			e.BidArr = append(e.BidArr, tmparr)
+		}
+		if b, ok := ju.Config["saveresult"].(bool); ok && b {
+			id := tmp["_id"]
+			tmp["result"] = result
+			delete(tmp, "_id")
+			tmparr := []map[string]interface{}{
+				map[string]interface{}{
+					"_id": id,
+				},
+				map[string]interface{}{"$set": tmp},
 			}
+			e.ResultArr = append(e.ResultArr, tmparr)
 		}
 	} else { //测试结果
 		delete(tmp, "_id")