Merge branch 'dev3.1' of http://192.168.3.207:10080/qmx/jy-data-extract into dev3.1

src/jy/extract/extract.go

@@ -898,7 +898,6 @@ func (e *ExtractTask) QualityAudit(resulttmp map[string]interface{}) {
 						if field == "buyer" || field == "winner" { //field为buyer和winner时特殊处理，先从Redis中查，有直接通过，没有走匹配规则
 							e.RedisMatch(field, fv, val) //redis匹配
 						} else { //除了buyer和winner，其他字段走规则匹配
-							//fv := qu.ObjToString(resulttmp[field])
 							e.RuleMatch(field, fv, val)
 						}
 					}
@@ -912,7 +911,6 @@ func (e *ExtractTask) QualityAudit(resulttmp map[string]interface{}) {
 				if field == "buyer" || field == "winner" { //field为buyer和winner时特殊处理，先从Redis中查，有直接通过，没有走匹配规则
 					e.RedisMatch(field, fv, resulttmp) //redis匹配
 				} else { //除了buyer和winner，其他字段走规则匹配
-					//fv := qu.ObjToString(resulttmp[field])
 					e.RuleMatch(field, fv, resulttmp)
 				}
 			}

src/main_test.go

@@ -14,7 +14,7 @@ import (
 func Test_task(t *testing.T) {
 	Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_kf")
 	//extract.StartExtractTaskId("5b8f804025e29a290415aee1")
-	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5c2a49d0a5cb26b9b766bd98", "5", "mxs_v3", "mxs_v3")
+	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5c2a49d0a5cb26b9b766bd98", "100", "mxs_v3", "mxs_v3")
 	//extract.StartExtractTestTask("5c3d75c96984142998eb00e1", "5c2a3d28a5cb26b9b76144dd", "100", "mxs_v3", "mxs_v3")
 	time.Sleep(5 * time.Second)
 }