|
@@ -1139,9 +1139,9 @@ func extractFromKv(field, fieldname string, blocks []*ju.Block, vc *RuleCore, kv
|
|
|
"blocktag": bl.Classify,
|
|
|
"weight": vv.Weight,
|
|
|
})
|
|
|
- if field != "winnertel" && field != "winnerperson" {
|
|
|
- break //暂定取第一个
|
|
|
- }
|
|
|
+ //if field != "winnertel" && field != "winnerperson" {
|
|
|
+ // //break //暂定取第一个
|
|
|
+ //}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -1687,19 +1687,19 @@ func AnalysisSaveResult(j, jf *ju.Job, e *ExtractTask) {
|
|
|
//tmp["extract_content"] = j.Content
|
|
|
if e.TaskInfo.TestColl == "" {
|
|
|
if len(tmp) > 0 { //保存抽取结果
|
|
|
- if len(e.SiteFields) <= 0 {
|
|
|
- for field, _ := range e.Fields {
|
|
|
- if tmp[field] == nil {
|
|
|
- tmp[field] = "" //覆盖之前版本数据
|
|
|
- }
|
|
|
- }
|
|
|
+ /* if len(e.SiteFields) <= 0 {
|
|
|
+ //for field, _ := range e.Fields {
|
|
|
+ // if tmp[field] == nil && {
|
|
|
+ // tmp[field] = "" //覆盖之前版本数据
|
|
|
+ // }
|
|
|
+ //}
|
|
|
} else {
|
|
|
- for field, _ := range e.SiteFields {
|
|
|
- if tmp[field] == nil {
|
|
|
- tmp[field] = "" //覆盖之前版本数据
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
+ //for field, _ := range e.SiteFields {
|
|
|
+ // if tmp[field] == nil &&{
|
|
|
+ // tmp[field] = "" //覆盖之前版本数据
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ }*/
|
|
|
tmp["repeat"] = 0
|
|
|
tmparr := []map[string]interface{}{
|
|
|
map[string]interface{}{
|