|
@@ -64,6 +64,7 @@ type ExtractTask struct {
|
|
|
Tag map[string][]*Tag //标签库
|
|
|
ClearFn map[string][]string //清理函数
|
|
|
IsExtractCity bool //是否开启城市抽取
|
|
|
+ Fields map[string]int //抽取属性组
|
|
|
|
|
|
ResultChanel chan bool //抽取结果详情
|
|
|
ResultArr [][]map[string]interface{} //抽取结果详情
|
|
@@ -261,6 +262,7 @@ func (e *ExtractTask) InitRuleBacks() {
|
|
|
//加载抽取规则
|
|
|
func (e *ExtractTask) InitRuleCore() {
|
|
|
defer qu.Catch()
|
|
|
+ e.Fields = map[string]int{}
|
|
|
e.RuleCores = []*RuleCore{}
|
|
|
vinfos, _ := db.Mgo.Find("versioninfo", `{"vid":"`+e.TaskInfo.VersionId+`","delete":false}`, nil, nil, false, -1, -1)
|
|
|
for _, vinfo := range *vinfos {
|
|
@@ -357,8 +359,10 @@ func (e *ExtractTask) InitRuleCore() {
|
|
|
if b, _ := v["isuse"].(bool); !b {
|
|
|
continue
|
|
|
}
|
|
|
+ field := qu.ObjToString(v["s_field"])
|
|
|
+ e.Fields[field] = 1 //加入抽取属性组备用
|
|
|
rinfo := &RegLuaInfo{
|
|
|
- Field: qu.ObjToString(v["s_field"]),
|
|
|
+ Field: field,
|
|
|
Code: v["s_code"].(string),
|
|
|
Name: v["s_name"].(string),
|
|
|
IsLua: qu.If(v["s_type"].(string) == "1", true, false).(bool),
|