抽取日志

src/jy/extract/extract.go

@@ -717,6 +717,13 @@ func AnalysisSaveResult(doc *map[string]interface{}, result map[string][]*ju.Ext
 		}
 		db.Mgo.Update("extract_result", `{"_id":"`+_id+`"}`, map[string]interface{}{"$set": tmp}, true, false)
 	} else { //测试结果
+		//保存抽取详情
+		tmp["result"] = result
+		for k, v := range *doc {
+			if tmp[k] == nil { //&& (k != "detail" || k != "contenthtml") {
+				tmp[k] = v
+			}
+		}
 		db.Mgo.Update(task.TestColl, `{"_id":"`+_id+`"}`, map[string]interface{}{"$set": tmp}, true, false)
 	}
 }

src/main_test.go

@@ -13,7 +13,7 @@ import (
 func Test_task(t *testing.T) {
 	Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_v3")
 	//extract.StartExtractTaskId("5b8f804025e29a290415aee1")
-	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5b8dcc45a5cb26b9b7f68469", "10", "result_v3", "v3.0_track")
+	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5b8dcc45a5cb26b9b7f68469", "10", "result_v3", "track_v3")
 	time.Sleep(300 * time.Second)
 }
 func Test_reg(t *testing.T) {