|
@@ -28,7 +28,7 @@ func JsonDataMergeProcessing(j *util.Job, e *ExtractTask) map[string][]*util.Ext
|
|
|
lockclear.Lock()
|
|
|
cfn := e.ClearFn[v]
|
|
|
lockclear.Unlock()
|
|
|
- newNum := clear.DoClearFn(cfn, []interface{}{fmt.Sprint((*j.Jsondata)[v]), ""})
|
|
|
+ newNum := clear.DoClearFn(cfn, []interface{}{util2.Float64All((*j.Jsondata)[v]), ""})
|
|
|
if util2.IntAll(newNum[0]) != 0 {
|
|
|
extFields := make([]*util.ExtField, 0)
|
|
|
extFields = append(extFields, &util.ExtField{Code: "JsonData_" + v, Field: v, ExtFrom: "JsonData_" + v, SourceValue: (*j.Jsondata)[v], Value: newNum[0], Score: 0.1})
|
|
@@ -50,7 +50,7 @@ func JsonDataMergeProcessing(j *util.Job, e *ExtractTask) map[string][]*util.Ext
|
|
|
lockclear.Lock()
|
|
|
cfn := e.ClearFn[v]
|
|
|
lockclear.Unlock()
|
|
|
- newNum := clear.DoClearFn(cfn, []interface{}{fmt.Sprint((*j.Jsondata)[v]), ""})
|
|
|
+ newNum := clear.DoClearFn(cfn, []interface{}{util2.Float64All((*j.Jsondata)[v]), ""})
|
|
|
if util2.IntAll(newNum[0]) != 0 {
|
|
|
extFields := make([]*util.ExtField, 0)
|
|
|
extFields = append(extFields, &util.ExtField{Code: "JsonData_" + v, Field: v, ExtFrom: "JsonData_" + v, SourceValue: (*j.Jsondata)[v], Value: newNum[0], Score: 0.1})
|