|
@@ -30,13 +30,13 @@ func JsonDataMergeProcessing(j *util.Job, e *ExtractTask) map[string][]*util.Ext
|
|
|
cfn := e.ClearFn[v]
|
|
|
lockclear.Unlock()
|
|
|
newNum := clear.DoClearFn(cfn, []interface{}{(*j.Jsondata)[v], ""})
|
|
|
- if util2.IntAll(newNum[0]) != 0 {
|
|
|
+ //if util2.IntAll(newNum[0]) != 0 {
|
|
|
extFields := make([]*util.ExtField, 0)
|
|
|
extFields = append(extFields, &util.ExtField{Code: "JsonData_" + v + "_" + fmt.Sprint(jdextweight), Field: v, ExtFrom: "JsonData_" + v + "_" + fmt.Sprint(jdextweight), SourceValue: (*j.Jsondata)[v], Value: newNum[0], Score: 0.1,IsTrue:newNum[len(newNum)-1].(bool)})
|
|
|
j.Result[v] = extFields
|
|
|
//AddExtLog("extract", j.SourceMid, nil, newNum[0], &RegLuaInfo{ "JsonData_"+v, "", v, "", false, nil, nil}, e.TaskInfo) //抽取日志
|
|
|
//AddExtLog("clear", j.SourceMid, (*j.Jsondata)[v], newNum[0], &RegLuaInfo{ "JsonData_"+v, "", v, "", false, nil, nil}, e.TaskInfo) //抽取日志
|
|
|
- }
|
|
|
+ //}
|
|
|
continue
|
|
|
}
|
|
|
vv := strings.TrimSpace(util2.ObjToString((*j.Jsondata)[v]))
|
|
@@ -126,7 +126,7 @@ func JsonDataMergeProcessing(j *util.Job, e *ExtractTask) map[string][]*util.Ext
|
|
|
cfn := e.ClearFn[v]
|
|
|
lockclear.Unlock()
|
|
|
newNum := clear.DoClearFn(cfn, []interface{}{(*j.Jsondata)[v], ""})
|
|
|
- if util2.IntAll(newNum[0]) != 0 {
|
|
|
+ //if util2.IntAll(newNum[0]) != 0 {
|
|
|
extFields := make([]*util.ExtField, 0)
|
|
|
if jdextweight >1{
|
|
|
if oneScore < 0{
|
|
@@ -142,7 +142,7 @@ func JsonDataMergeProcessing(j *util.Job, e *ExtractTask) map[string][]*util.Ext
|
|
|
j.Result[v] = append(j.Result[v], extFields...)
|
|
|
//AddExtLog("extract", j.SourceMid, nil, newNum[0], &RegLuaInfo{ "JsonData_"+v, "", v, "", false, nil, nil}, e.TaskInfo) //抽取日志
|
|
|
//AddExtLog("clear", j.SourceMid, (*j.Jsondata)[v], newNum[0], &RegLuaInfo{ "JsonData_"+v, "", v, "", false, nil, nil}, e.TaskInfo) //抽取日志
|
|
|
- }
|
|
|
+ //}
|
|
|
continue
|
|
|
}
|
|
|
|