分包抽取

src/jy/admin/rule.go

@@ -70,20 +70,20 @@ func init() {
 	Admin.POST("/rulelogic/use", RuleLogicUse)
 
 	//pkglogic
-	Admin.GET("/pkglogic", func(c *gin.Context) {
-		vid := c.Query("vid")
-		pid := c.Query("pid")
-		c.HTML(200, "pkg_logiclist.html", gin.H{"vid": vid, "pid": pid})
-	})
-	Admin.POST("/pkglogic/data", PkgLogicData)
-	Admin.POST("/pkglogic/save", PkgLogicSave)
-	Admin.POST("/pkgrulelogic/del", func(c *gin.Context) {
-		_id, _ := c.GetPostForm("_id")
-		b := Mgo.UpdateById("pkg_logic", _id, `{"$set":{"delete":true}}`)
-		go DelPkgLogicBack(_id)
-		c.JSON(200, gin.H{"rep": b})
-	})
-	Admin.POST("/pkglogic/use", PkgLogicUse)
+	//Admin.GET("/pkglogic", func(c *gin.Context) {
+	//	vid := c.Query("vid")
+	//	pid := c.Query("pid")
+	//	c.HTML(200, "pkg_logiclist.html", gin.H{"vid": vid, "pid": pid})
+	//})
+	//Admin.POST("/pkglogic/data", PkgLogicData)
+	//Admin.POST("/pkglogic/save", PkgLogicSave)
+	//Admin.POST("/pkgrulelogic/del", func(c *gin.Context) {
+	//	_id, _ := c.GetPostForm("_id")
+	//	b := Mgo.UpdateById("pkg_logic", _id, `{"$set":{"delete":true}}`)
+	//	go DelPkgLogicBack(_id)
+	//	c.JSON(200, gin.H{"rep": b})
+	//})
+	//Admin.POST("/pkglogic/use", PkgLogicUse)
 
 	Admin.GET("/logicpre", func(c *gin.Context) {
 		vid := c.Query("vid")
@@ -134,11 +134,11 @@ func init() {
 
 	Admin.GET("/pkglogicback", func(c *gin.Context) {
 		vid := c.Query("vid")
-		pid := c.Query("pid")
+		s_field := c.Query("s_field")
 		sid := c.Query("sid")
 		//查询属性字段
-		tmp, _ := Mgo.FindById("pkg_info", pid, `{"s_field":1}`)
-		c.HTML(200, "pkg_logicbacklist.html", gin.H{"vid": vid, "pid": pid, "sid": sid, "field": (*tmp)["s_field"]})
+		//tmp, _ := Mgo.FindById("pkg_info", pid, `{"s_field":1}`)
+		c.HTML(200, "pkg_logicbacklist.html", gin.H{"vid": vid, "sid": sid, "field": s_field,"s_field":s_field})
 	})
 	Admin.POST("/pkglogicback/data", PkgLogicBackData)
 	Admin.POST("/pkglogicback/save", PkgLogicBackSave)
@@ -379,10 +379,10 @@ func RuleLogicBackData(c *gin.Context) {
 }
 func PkgLogicBackData(c *gin.Context) {
 	vid, _ := c.GetPostForm("vid")
-	pid, _ := c.GetPostForm("pid")
+	s_field, _ := c.GetPostForm("s_field")
 	sid, _ := c.GetPostForm("sid")
 	data, _ := Mgo.Find("pkg_logicback", `{"sid":"`+sid+`","delete":false}`, `{"_id":-1}`, nil, false, -1, -1)
-	c.JSON(200, gin.H{"data": data, "vid": vid, "pid": pid, "sid": sid})
+	c.JSON(200, gin.H{"data": data, "vid": vid, "s_field": s_field, "sid": sid})
 }
 func RuleLogicBackSave(c *gin.Context) {
 	data := GetPostForm(c)

src/jy/admin/rulecheck.go

@@ -324,6 +324,7 @@ func checkBackScript(table, code, name, version, infoid, script string, alone bo
 	e.TaskInfo = &extract.TaskInfo{Version: qu.ObjToString((*vsion)["s_version"]), VersionId: qu.BsonIdToSId((*vsion)["_id"]), TestLua: true}
 	e.InitSite()
 	e.InitRulePres()
+	e.InitPkgCore()
 	e.InitRuleBacks(false)
 	e.InitRuleBacks(true)
 	e.InitRuleCore(false)

src/jy/admin/version.go

@@ -262,6 +262,17 @@ func init() {
 		//b := Mgo.Del("versioninfo", `{"_id":"`+_id+`"}`)
 		c.JSON(200, gin.H{"rep": b})
 	})
+
+	Admin.GET("/version/pkglogicore", func(c *gin.Context) {
+		vid := c.Query("vid")
+		s_field := c.Query("s_field")
+		sid := c.Query("sid")
+		c.HTML(200, "pkg_logicore.html", gin.H{"vid": vid, "sid": sid, "field": s_field})
+	})
+	Admin.POST("/version/pkglogicore/data", PkgRuleLogicCoreData)
+	Admin.POST("/version/pkglogicore/save", PkgRuleLogicCoreSave)
+	Admin.POST("/version/pkglogicore/del", PkgRuleLogicCoreDel)
+	Admin.POST("/version/pkglogicore/use", PkgRuleLogicCoreUse)
 	//分块配置
 	Admin.GET("/version/blockinfo", func(c *gin.Context) {
 		vid := c.Query("vid")
@@ -789,3 +800,47 @@ func getCode(code string) string {
 	tmp := tmps[:len(tmps)-1]
 	return strings.Join(tmp, "_")
 }
+func PkgRuleLogicCoreData(c *gin.Context) {
+	vid, _ := c.GetPostForm("vid")
+	sid, _ := c.GetPostForm("sid")
+	s_field, _ := c.GetPostForm("s_field")
+	data, _ := Mgo.Find("pkg_logicore", `{"sid":"`+sid+`","delete":false}`, `{"_id":-1}`, nil, false, -1, -1)
+	c.JSON(200, gin.H{"data": data, "vid": vid, "s_field": s_field, "sid": sid})
+}
+func PkgRuleLogicCoreSave(c *gin.Context) {
+	data := GetPostForm(c)
+	_id, _ := c.GetPostForm("_id")
+	b := false
+	if _id == "" {
+		data["l_createtime"] = time.Now().Unix()
+		data["s_username"] = sessions.Default(c).Get("username")
+		data["delete"] = false
+		s_type := data["s_type"]
+		code := ""
+		if s_type == "0" { //抽取逻辑正则
+			code = util.GetSyncIndex(E_CE)
+		} else { //抽取逻辑脚本
+			code = util.GetSyncIndex(E_CL)
+		}
+		data["s_code"] = code
+		b = Mgo.Save("pkg_logicore", data) != ""
+	} else {
+		data["l_lasttime"] = time.Now().Unix()
+		b = Mgo.Update("pkg_logicore", `{"_id":"`+_id+`"}`, map[string]interface{}{
+			"$set": data,
+		}, true, false)
+	}
+	c.JSON(200, gin.H{"rep": b})
+}
+func PkgRuleLogicCoreDel(c *gin.Context) {
+	_id, _ := c.GetPostForm("_id")
+	//b := Mgo.Del("rule_logicore", `{"_id":"`+_id+`"}`)
+	b := Mgo.UpdateById("pkg_logicore", _id, `{"$set":{"delete":true}}`)
+	c.JSON(200, gin.H{"rep": b})
+}
+func PkgRuleLogicCoreUse(c *gin.Context) {
+	_id, _ := c.GetPostForm("_id")
+	isuse, _ := c.GetPostForm("isuse")
+	b := Mgo.UpdateById("pkg_logicore", _id, `{"$set":{"isuse":`+isuse+`}}`)
+	c.JSON(200, gin.H{"rep": b})
+}

src/jy/extract/exportask.go

@@ -63,6 +63,7 @@ func extractAndExport(v string, t map[string]interface{}) {
 	e.InitClearFn(true)
 	e.InfoTypeList()
 	e.InitBlockRule()
+	e.InitPkgCore()
 	//品牌抽取是否开启
 	ju.IsBrandGoods = ju.Config["brandgoods"].(bool)
 

src/jy/extract/extpackage.go

@@ -7,29 +7,33 @@ import (
 	"log"
 	qu "qfw/util"
 	"reflect"
+	"regexp"
 	"sort"
 )
 
-func pkvdata(pkg *ju.BlockPackage, sonJobResult *map[string]interface{}, e *ExtractTask,isSite bool,codeSite string) {
+func pkvdata(pkg *ju.BlockPackage, sonJobResult *map[string]interface{}, e *ExtractTask, isSite bool, codeSite string) {
 
 	if pkg.ColonKV != nil {
-		kvparse(pkg.ColonKV,  e, sonJobResult,isSite,codeSite)
+		kvparse(pkg.ColonKV, e, sonJobResult, isSite, codeSite)
 	}
 	if pkg.TableKV != nil {
-		kvparse(pkg.TableKV,  e, sonJobResult,isSite,codeSite)
+		kvparse(pkg.TableKV, e, sonJobResult, isSite, codeSite)
 	}
 	if pkg.SpaceKV != nil {
-		kvparse(pkg.SpaceKV,  e, sonJobResult,isSite,codeSite)
+		kvparse(pkg.SpaceKV, e, sonJobResult, isSite, codeSite)
 	}
 }
 
-func kvparse(p *ju.JobKv,  e *ExtractTask, sonJobResult *map[string]interface{},isSite bool,codeSite string) {
+func kvparse(p *ju.JobKv, e *ExtractTask, sonJobResult *map[string]interface{}, isSite bool, codeSite string) {
 	if p != nil {
 		for pk, pv2 := range p.KvTags {
 			if len(pv2) > 1 && !(pk == "预算" || pk == "中标金额") {
 				tmp := []*ju.Tag{}
 				var tmpindex, tmpweight int = -9999, -9999
 				for ii, vv := range pv2 {
+					if pk == "中标单位" && regexp.MustCompile("[0-9.元人￥$]").MatchString(vv.Value){
+						continue
+					}
 					if tmpweight < vv.Weight {
 						tmpindex = ii
 						tmpweight = vv.Weight
@@ -43,9 +47,9 @@ func kvparse(p *ju.JobKv,  e *ExtractTask, sonJobResult *map[string]interface{},
 			if len(pv) == 0 {
 				continue
 			}
-			tags := ju.GetTags(pk,isSite,codeSite)
+			tags := ju.GetTags(pk, isSite, codeSite)
 			if tags.Len() > 0 {
-				if ((*sonJobResult)["name"]  == nil || (*sonJobResult)["name"] == "")&& tags[0].Key == "项目名称"{
+				if ((*sonJobResult)["name"] == nil || (*sonJobResult)["name"] == "") && tags[0].Key == "项目名称" {
 					(*sonJobResult)["name"] = pv[0].Value
 				}
 				if qu.Float64All((*sonJobResult)["budget"]) == 0 && tags[0].Key == "预算" {
@@ -64,7 +68,7 @@ func kvparse(p *ju.JobKv,  e *ExtractTask, sonJobResult *map[string]interface{},
 					(*sonJobResult)["bidamount"] = data[0]
 					continue
 				}
-				if ((*sonJobResult)["winner"] == nil || (*sonJobResult)["winner"] == "" )&& tags[0].Key == "中标单位"{
+				if ((*sonJobResult)["winner"] == nil || (*sonJobResult)["winner"] == "") && tags[0].Key == "中标单位" {
 					(*sonJobResult)["winner"] = pv[0].Value
 				}
 
@@ -77,12 +81,24 @@ func kvparse(p *ju.JobKv,  e *ExtractTask, sonJobResult *map[string]interface{},
 }
 
 //处理分包信息
-func PackageDetail(j *ju.Job, e *ExtractTask,isSite bool,codeSite string) {
+func PackageDetail(j *ju.Job, e *ExtractTask, isSite bool, codeSite string) {
 	qu.Try(func() {
 		if len(j.BlockPackage) > 0 {
+			for _, ev := range e.PkgRuleCores {
+				for _, eve := range ev.RuleCores {
+					if !eve.IsLua {
+						ExtRuleCoreByPkgReg(j, eve, e) // 分包正则抽取   预算   中标单位 中标价 成交状态
+					}
+				}
+				for _, evb := range ev.RuleBacks {
+					if !evb.IsLua {
+						ExtRegBackPkg(j, evb) // 分包正则清理  中标单位 成交状态   内容 名称
+					}
+				}
+			}
 			tmpkeys := []string{}
 			for k, _ := range j.BlockPackage {
-				if k == ""{
+				if k == "" {
 					continue
 				}
 				tmpkeys = append(tmpkeys, k)
@@ -90,7 +106,7 @@ func PackageDetail(j *ju.Job, e *ExtractTask,isSite bool,codeSite string) {
 			sort.Strings(tmpkeys)
 			packageResult := map[string]map[string]interface{}{}
 			//packagenum := len(j.BlockPackage)
-			for i, pkName := range tmpkeys {
+			for _, pkName := range tmpkeys {
 				pkg, ok := j.BlockPackage[pkName]
 				if !ok {
 					continue
@@ -103,36 +119,32 @@ func PackageDetail(j *ju.Job, e *ExtractTask,isSite bool,codeSite string) {
 					sonJobResult["text"] = pkg.Text
 					sonJobResult["budget"] = pkg.Budget
 					sonJobResult["bidamount"] = pkg.Bidamount
-					wins := make([]map[string]interface{}, 0)
 					if pkg.Winner == "" && len(j.Winnerorder) > 0 {
 						if sonJobResult["winnerorder"] == nil {
-							for _, tv := range j.Winnerorder {
-									if tv["type"].(int) == i{
-										wins = append(wins, tv)
-									}
+							sonJobResult["winnerorder"] = j.Winnerorder
+							if sonJobResult["bidamount"].(float64) <= 0 {
+								sonJobResult["bidamount"] = qu.Float64All(j.Winnerorder[0]["price"])
+							}
+							if sonJobResult["winner"] == "" {
+								sonJobResult["winner"] = j.Winnerorder[0]["entname"]
 							}
-							sonJobResult["winnerorder"] = wins
-						}
-						if len(wins) >0{
-							sonJobResult["bidamount"] = wins[0]["price"]
-							sonJobResult["winner"] = wins[0]["entname"]
 						}
 					} else {
 						if len(j.Winnerorder) > 0 {
-							sonJobResult["bidamount"] = j.Winnerorder[0]["price"]
-							sonJobResult["winner"] = wins[0]["entname"]
+							sonJobResult["bidamount"] = qu.Float64All(j.Winnerorder[0]["price"])
+							sonJobResult["winner"] = j.Winnerorder[0]["entname"]
 						}
 						sonJobResult["winnerorder"] = pkg.WinnerOrder
 					}
-					pkvdata(pkg, &sonJobResult, e,isSite,codeSite)
+					pkvdata(pkg, &sonJobResult, e, isSite, codeSite)
 
 					sonJobResult["type"] = pkg.Type
-					if len(tmpkeys) == 1{
-						if qu.Float64All(sonJobResult["budget"])==0{
-							for _,bv := range j.Block{
-								kvparse(bv.ColonKV,e,&sonJobResult,isSite,codeSite)
-								kvparse(bv.TableKV,e,&sonJobResult,isSite,codeSite)
-								kvparse(bv.SpaceKV,e,&sonJobResult,isSite,codeSite)
+					if len(tmpkeys) == 1 {
+						if qu.Float64All(sonJobResult["budget"]) == 0 {
+							for _, bv := range j.Block {
+								kvparse(bv.ColonKV, e, &sonJobResult, isSite, codeSite)
+								kvparse(bv.TableKV, e, &sonJobResult, isSite, codeSite)
+								kvparse(bv.SpaceKV, e, &sonJobResult, isSite, codeSite)
 							}
 						}
 					}
@@ -253,7 +265,7 @@ func PackageDetail(j *ju.Job, e *ExtractTask,isSite bool,codeSite string) {
 				j.PackageInfo = packageResult
 			}
 		}
-		extRegBackPack(j, e)
+		//extRegBackPack(j, e)
 	}, func(err interface{}) {
 		log.Println("PackageDetail err", err)
 	})

src/jy/extract/extract.go

@@ -847,6 +847,139 @@ func ExtRuleCoreByReg(extfrom string, doc map[string]interface{}, j *ju.Job, in
 	}
 }
 
+//pkg抽取-规则-正则
+func ExtRuleCoreByPkgReg(j *ju.Job, in *RegLuaInfo, e *ExtractTask) {
+	defer qu.Catch()
+	//根据field配置项目，是否抽取。例如：废标、流标等跳过,
+	b := IsExtract(in.Field, j.Title, j.Content)
+	if !b {
+		return
+	}
+	//块抽取
+	if in.Field != "" {
+		for k, vbpkg := range j.BlockPackage {
+			rep := map[string]string{}
+			if in.RegCore.Bextract { //正则是两部分的，可以直接抽取的（含下划线）
+				if (in.Field == "budget" && vbpkg.Budget > 0) || (in.Field == "bidamount" && vbpkg.Bidamount > 0) || (in.Field == "winner" && vbpkg.Winner == "") || (in.Field == "bidstatus" && vbpkg.BidStatus == "")|| (in.Field == "projectname" && vbpkg.Name == "") {
+					continue
+				}
+				//处理正负数修正
+				ptmp := strings.Split(in.RuleText, "#")
+				sign := 0
+				if len(ptmp) == 2 {
+					if ptmp[1] == "正" {
+						sign = 1
+					} else if ptmp[1] == "负" {
+						sign = -1
+					}
+				}
+				tmp := strings.Split(ptmp[0], "__")
+				if len(tmp) == 2 {
+					epos := strings.Split(tmp[1], ",")
+					posm := map[string]int{}
+					for _, v := range epos {
+						ks := strings.Split(v, ":")
+						if len(ks) == 2 { //(.*)招标公告(.*)__2:projectname,4:area
+							posm[ks[1]] = qu.IntAll(ks[0])
+						} else {
+							posm[in.Field] = qu.IntAll(ks[0])
+						}
+					}
+					var pattern string
+					if strings.Contains(tmp[0], "\\u") {
+						tmp[0] = strings.Replace(tmp[0], "\\", "\\\\", -1)
+						tmp[0] = strings.Replace(tmp[0], "\\\\u", "\\u", -1)
+						pattern, _ = strconv.Unquote(`"` + tmp[0] + `"`)
+					} else {
+						pattern = tmp[0]
+					}
+					//log.Debug("pattern", pattern)
+					//fmt.Println(text)
+					reg := regexp.MustCompile(pattern)
+					apos := reg.FindAllStringSubmatchIndex(vbpkg.Text, -1)
+					for i, _ := range apos {
+						pos := apos[i]
+						for k, p := range posm {
+							if len(pos) > p {
+								if pos[p] == -1 || pos[p+1] == -1 {
+									continue
+								}
+								val := vbpkg.Text[pos[p]:pos[p+1]]
+								if string(val) == "" {
+									continue
+								}
+								if sign == -1 {
+									rep[k+"_"+fmt.Sprint(i)] = "-" + val
+								} else {
+									rep[k+"_"+fmt.Sprint(i)] = val
+								}
+							}
+						}
+					}
+					//fmt.Println(text)
+					for i := 0; i < len(apos); i++ {
+						if strings.TrimSpace(rep[in.Field+"_"+fmt.Sprint(i)]) != "" {
+							if in.Field == "budget" && vbpkg.Budget <= 0 {
+								lock.Lock()
+								cfn := e.ClearFn[in.Field]
+								lock.Unlock()
+								data := clear.DoClearFn(cfn, []interface{}{strings.TrimSpace(rep[in.Field+"_"+fmt.Sprint(i)]), j.Content})
+								j.BlockPackage[k].Budget = qu.Float64All(data[0])
+								break
+							}
+							if in.Field == "bidamount" && vbpkg.Bidamount <= 0 {
+								lock.Lock()
+								cfn := e.ClearFn[in.Field]
+								lock.Unlock()
+								data := clear.DoClearFn(cfn, []interface{}{strings.TrimSpace(rep[in.Field+"_"+fmt.Sprint(i)]), j.Content})
+								j.BlockPackage[k].Bidamount = qu.Float64All(data[0])
+								break
+							} else {
+								//if j.BlockPackage[k].RegKV == nil{
+								//	j.BlockPackage[k].RegKV = ju.NewJobKv()
+								//	j.BlockPackage[k].RegKV.KvTags
+								//}
+							}
+						}
+					}
+				}
+			} else {
+				pos := in.RegCore.Reg.FindStringIndex(vbpkg.Text)
+				val := ""
+				if len(pos) == 2 {
+					//"text" = "text"[pos[1]:]
+					val = "text"[pos[1]:]
+					rs := regexp.MustCompile("[^\r\n\t]+")
+					tmp := rs.FindAllString("text", -1)
+					if len(tmp) > 0 {
+						val = tmp[0]
+					}
+				}
+				if val != "" {
+					if in.Field == "budget" && vbpkg.Budget <= 0 {
+						lock.Lock()
+						cfn := e.ClearFn[in.Field]
+						lock.Unlock()
+						data := clear.DoClearFn(cfn, []interface{}{val, j.Content})
+						j.BlockPackage[k].Budget = qu.Float64All(data[0])
+						break
+					}
+					if in.Field == "bidamount" && vbpkg.Bidamount <= 0 {
+						lock.Lock()
+						cfn := e.ClearFn[in.Field]
+						lock.Unlock()
+						data := clear.DoClearFn(cfn, []interface{}{val, j.Content})
+						j.BlockPackage[k].Bidamount = qu.Float64All(data[0])
+						break
+					} else {
+
+					}
+				}
+			}
+		}
+	}
+}
+
 //lua脚本根据属性设置提取kv值
 func getKvByLuaFields(vc *RuleCore, j *ju.Job, et *ExtractTask) (map[string][]map[string]interface{}, bool) {
 	kvmap := map[string][]map[string]interface{}{}
@@ -1179,6 +1312,22 @@ func ExtRegBack(j *ju.Job, in *RegLuaInfo, t *TaskInfo) {
 	}
 }
 
+//后置过滤
+func ExtRegBackPkg(j *ju.Job, in *RegLuaInfo) {
+	defer qu.Catch()
+	for k,v := range j.BlockPackage{
+		if in.Field == "winner"{
+			j.BlockPackage[k].Winner = in.RegPreBac.Reg.ReplaceAllString(v.Winner, in.RegPreBac.Replace)
+		}else if in.Field == "bidstatus"{
+			j.BlockPackage[k].BidStatus = in.RegPreBac.Reg.ReplaceAllString(v.BidStatus, in.RegPreBac.Replace)
+		}else if in.Field == ""{
+			j.BlockPackage[k].Text = in.RegPreBac.Reg.ReplaceAllString(v.Text, in.RegPreBac.Replace)
+		}else if in.Field== "projectname"{
+			j.BlockPackage[k].Name = in.RegPreBac.Reg.ReplaceAllString(v.Name, in.RegPreBac.Replace)
+		}
+	}
+}
+
 //KV过滤
 func ExtRuleKV(j *ju.Job, in *RegLuaInfo, t *TaskInfo) {
 	defer qu.Catch()

src/jy/extract/extractInit.go

@@ -85,15 +85,20 @@ type ExtractTask struct {
 
 	ResultChanel chan bool //抽取结果详情
 	sync.RWMutex
-	ResultArr [][]map[string]interface{} //抽取结果详情
-	BidChanel chan bool                  //抽取结果
-	BidArr    [][]map[string]interface{} //抽取结果
-	BidTotal int                         //结果数量
+	ResultArr [][]map[string]interface {
+	}                   //抽取结果详情
+	BidChanel chan bool //抽取结果
+	BidArr    [][]map[string]interface {
+	}                   //抽取结果
+	BidTotal int        //结果数量
 
-	RecogFieldMap map[string]map[string]interface{}   //识别字段
-	FidClassMap   map[string][]map[string]interface{} //分类
-	CidRuleMap map[string][]map[string]interface{}    //规则
-	AuditFields []string                              //需要审核的字段名称
+	RecogFieldMap map[string]map[string]interface {
+	}                    //识别字段
+	FidClassMap map[string][]map[string]interface {
+	}                    //分类
+	CidRuleMap map[string][]map[string]interface {
+	}                    //规则
+	AuditFields []string //需要审核的字段名称
 
 	SiteCityMap          map[string]*SiteCity //站点对应的省市区
 	ProvinceMap          map[string]string    //省全称简称(key:浙江省 val:浙江)
@@ -119,7 +124,8 @@ type ExtractTask struct {
 	PostCodeMap map[string]*PostCode //邮编
 	AreaCodeMap map[string]*AreaCode //区号
 
-	InfoType []map[string]interface{}
+	InfoType []map[string]interface {
+	}
 
 	Trie_Full_Province  *ju.Trie       //省全称 省、直辖市、自治区
 	Trie_Full_City      *ju.Trie       //市全称 地级市
@@ -385,7 +391,7 @@ func (e *ExtractTask) InitRuleCore(isSite bool) {
 	defer qu.Catch()
 	allFields := getALLFields()
 	e.Fields = map[string]int{}
-	var versioninfodb, rule_logicdb, rule_logicpredb, rule_logicbackdb, rule_logicoredb,rule_logickvdb string
+	var versioninfodb, rule_logicdb, rule_logicpredb, rule_logicbackdb, rule_logicoredb, rule_logickvdb string
 	eSiteRuleCores := make(map[string]map[string][]*RuleCore)
 	if isSite {
 		versioninfodb = "site_versioninfo"
@@ -393,7 +399,7 @@ func (e *ExtractTask) InitRuleCore(isSite bool) {
 		rule_logicpredb = "site_rule_logicpre"
 		rule_logicbackdb = "site_rule_logicback"
 		rule_logicoredb = "site_rule_logicore"
-		rule_logickvdb= "site_rule_logickv"
+		rule_logickvdb = "site_rule_logickv"
 		e.SiteRuleCores = make(map[string]map[string][]*RuleCore)
 	} else {
 		versioninfodb = "versioninfo"
@@ -401,7 +407,7 @@ func (e *ExtractTask) InitRuleCore(isSite bool) {
 		rule_logicpredb = "rule_logicpre"
 		rule_logicbackdb = "rule_logicback"
 		rule_logicoredb = "rule_logicore"
-		rule_logickvdb= "rule_logickv"
+		rule_logickvdb = "rule_logickv"
 		e.RuleCores = make(map[string]map[string][]*RuleCore)
 	}
 
@@ -679,55 +685,101 @@ func (e *ExtractTask) InitPkgCore() {
 			continue
 		}
 		s_field := qu.ObjToString(pkginfo["s_field"])
-		pid := qu.BsonIdToSId(pkginfo["_id"])
-		logicList, _ := db.Mgo.Find("pkg_logic", `{"pid":"`+pid+`","delete":false}`, nil, nil, false, -1, -1)
-		for _, vv := range *logicList {
-			if b, _ := vv["isuse"].(bool); !b {
-				continue
+		sid := qu.BsonIdToSId(pkginfo["_id"])
+		rcore := &RuleCore{}
+		rcore.Field = s_field
+		rcore.ExtFrom = "detail"
+		//后置规则
+		ruleBacks := []*RegLuaInfo{}
+		blist, _ := db.Mgo.Find("pkg_logicback", `{"sid":"`+sid+`","delete":false}`, nil, nil, false, -1, -1)
+		for _, v := range *blist {
+			rinfo := &RegLuaInfo{
+				Field: qu.ObjToString(v["s_field"]),
+				Code:  v["s_code"].(string),
+				Name:  v["s_name"].(string),
+				IsLua: qu.If(v["s_type"].(string) == "1", true, false).(bool),
 			}
-			rcore := &RuleCore{}
-			rcore.Field = s_field
-			rcore.LuaLogic = qu.ObjToString(vv["s_luascript"]) //是否进入逻辑脚本
-			rcore.ExtFrom = qu.If(vv["extfrom"].(bool), "title", "detail").(string)
-			//后置规则
-			ruleBacks := []*RegLuaInfo{}
-			blist, _ := db.Mgo.Find("pkg_logicback", `{"sid":"`+qu.BsonIdToSId(vv["_id"])+`","delete":false}`, nil, nil, false, -1, -1)
-			for _, v := range *blist {
-				rinfo := &RegLuaInfo{
-					Field: qu.ObjToString(v["s_field"]),
-					Code:  v["s_code"].(string),
-					Name:  v["s_name"].(string),
-					IsLua: qu.If(v["s_type"].(string) == "1", true, false).(bool),
-				}
-				if rinfo.IsLua {
-					rinfo.RuleText = v["s_luascript"].(string)
+			if rinfo.IsLua {
+				rinfo.RuleText = v["s_luascript"].(string)
+				ruleBacks = append(ruleBacks, rinfo)
+			} else {
+				qu.Try(func() {
+					rinfo.RuleText = v["s_rule"].(string)
+					tmp := strings.Split(rinfo.RuleText, "__")
+					var pattern string
+					if strings.Contains(tmp[0], "\\u") {
+						tmp[0] = strings.Replace(tmp[0], "\\", "\\\\", -1)
+						tmp[0] = strings.Replace(tmp[0], "\\\\u", "\\u", -1)
+						pattern, _ = strconv.Unquote(`"` + tmp[0] + `"`)
+					} else {
+						pattern = tmp[0]
+					}
+					if len(tmp) == 2 {
+						rinfo.RegPreBac = &ExtReg{Reg: regexp.MustCompile(pattern), Replace: tmp[1]}
+					} else {
+						rinfo.RegPreBac = &ExtReg{Reg: regexp.MustCompile(pattern), Replace: ""}
+					}
 					ruleBacks = append(ruleBacks, rinfo)
-				} else {
-					qu.Try(func() {
-						rinfo.RuleText = v["s_rule"].(string)
-						tmp := strings.Split(rinfo.RuleText, "__")
-						var pattern string
-						if strings.Contains(tmp[0], "\\u") {
-							tmp[0] = strings.Replace(tmp[0], "\\", "\\\\", -1)
-							tmp[0] = strings.Replace(tmp[0], "\\\\u", "\\u", -1)
-							pattern, _ = strconv.Unquote(`"` + tmp[0] + `"`)
-						} else {
-							pattern = tmp[0]
-						}
-						if len(tmp) == 2 {
-							rinfo.RegPreBac = &ExtReg{Reg: regexp.MustCompile(pattern), Replace: tmp[1]}
-						} else {
-							rinfo.RegPreBac = &ExtReg{Reg: regexp.MustCompile(pattern), Replace: ""}
+				}, func(err interface{}) {
+					log.Debug(rinfo.Code, rinfo.Field, err)
+				})
+			}
+		}
+		rcore.RuleBacks = ruleBacks
+		//抽取规则
+		ruleCores := []*RegLuaInfo{}
+		clist, _ := db.Mgo.Find("pkg_logicore", `{"sid":"`+sid+`","delete":false}`, nil, nil, false, -1, -1)
+		for _, v := range *clist {
+			if b, _ := v["isuse"].(bool); !b {
+				continue
+			}
+			field := qu.ObjToString(v["s_field"])
+			e.Fields[field] = 1 //加入抽取属性组备用
+			rinfo := &RegLuaInfo{
+				Field: field,
+				Code:  v["s_code"].(string),
+				Name:  v["s_name"].(string),
+				IsLua: qu.If(v["s_type"].(string) == "1", true, false).(bool),
+			}
+			if rinfo.IsLua {
+				rinfo.RuleText = v["s_luascript"].(string)
+				//提取全部属性
+				ruleCores = append(ruleCores, rinfo)
+			} else {
+				qu.Try(func() {
+					rinfo.RuleText = v["s_rule"].(string)
+					tmp := strings.Split(rinfo.RuleText, "__")
+					var pattern string
+					if strings.Contains(tmp[0], "\\u") {
+						tmp[0] = strings.Replace(tmp[0], "\\", "\\\\", -1)
+						tmp[0] = strings.Replace(tmp[0], "\\\\u", "\\u", -1)
+						pattern, _ = strconv.Unquote(`"` + tmp[0] + `"`)
+					} else {
+						pattern = tmp[0]
+					}
+					if len(tmp) == 2 {
+						epos := strings.Split(tmp[1], ",")
+						posm := map[string]int{}
+						for _, v := range epos {
+							ks := strings.Split(v, ":")
+							if len(ks) == 2 { //(.*)招标公告(.*)__2:projectname,4:area
+								posm[ks[1]] = qu.IntAll(ks[0])
+							} else { //(.*)招标公告__2
+								posm[rinfo.Field] = qu.IntAll(ks[0])
+							}
 						}
-						ruleBacks = append(ruleBacks, rinfo)
-					}, func(err interface{}) {
-						log.Debug(rinfo.Code, rinfo.Field, err)
-					})
-				}
+						rinfo.RegCore = &ExtReg{Reg: regexp.MustCompile(pattern), Bextract: true, ExtractPos: posm}
+					} else {
+						rinfo.RegCore = &ExtReg{Reg: regexp.MustCompile(pattern), Bextract: false}
+					}
+					ruleCores = append(ruleCores, rinfo)
+				}, func(err interface{}) {
+					log.Debug(rinfo.Code, rinfo.Field, err)
+				})
 			}
-			rcore.RuleBacks = ruleBacks
-			e.PkgRuleCores = append(e.PkgRuleCores, rcore)
 		}
+		rcore.RuleCores = ruleCores
+		e.PkgRuleCores = append(e.PkgRuleCores, rcore)
 	}
 }
 

src/jy/extract/extractudp.go

@@ -106,6 +106,7 @@ func ExtractByUdp(sid, eid string, ra *net.UDPAddr, instanceId ...string) {
 		ext.InitRuleCore(false)
 		ext.InitRuleCore(true)
 		ext.InitBlockRule()
+		ext.InitPkgCore()
 		ext.InitTag(false)
 		ext.InitTag(true)
 		ext.InitClearFn(false)

src/jy/pretreated/analystep.go

@@ -208,13 +208,13 @@ func processTableResult(tabres *TableResult, block *util.Block, job *util.Job,is
 	}
 	//处理中标人排序
 	wror := []map[string]interface{}{}
-	for _, v := range tabres.WinnerOrder {
+	for i, v := range tabres.WinnerOrder {
 		entName, _ := v["entname"].(string)
 		v["entname"] = winnerOrderEntity.clear("中标单位", entName)
 		if price, ok := v["price"].(string); ok {
 			v["price"] = winnerOrderEntity.clear("中标金额", price)
 		}
-		v["type"] = 2
+		v["type"] = i
 		wror = append(wror, v)
 	}
 	if len(wror) > 0 {

src/jy/pretreated/division.go

@@ -597,7 +597,6 @@ func divisionPackageChild(blockPackage *map[string]*util.BlockPackage, content,
 		if len(pkg) == 1 && strings.HasSuffix(con, v[0]) {
 			return false, ""
 		}
-		//
 		is := regexp.MustCompile(v[0]+"[:：]*").FindAllStringIndex(con, -1)
 		for _, sv := range is {
 			appendWarpIndex = append(appendWarpIndex, sv[0])
@@ -731,6 +730,7 @@ func divisionPackageChild(blockPackage *map[string]*util.BlockPackage, content,
 					Type:     bv[1],
 					Accuracy: accuracy,
 				}
+				//fmt.Println(text)
 				finalKv := GetKVAll(strings.TrimLeft(text, headKey), "", nil, 4,isSite,codeSite)
 				if headKey != "" {
 					kvAgain := GetKVAll(text, "", nil, 4,isSite,codeSite)
@@ -785,10 +785,12 @@ func interceptText(indexs []int, indexPkgMap map[int]string, pkgIndexMap map[str
 		} else {
 			text = con[iv:]
 		}
+		//fmt.Println(text)
 		tmptext := text
-		if strings.Contains(text, "、") {
-			text = strings.Split(text, "、")[0]
-		} else if strings.Contains(text, "\n") {
+		//if strings.Contains(text, "、") {
+		//	text = strings.Split(text, "、")[0]
+		//} else
+		if strings.Contains(text, "\n") {
 			texts := strings.Split(text, "\n")
 			text2 :=""
 			if ik+1 < len(indexs)-1 {

src/jy/util/article.go

@@ -126,7 +126,7 @@ type Segment struct {
 
 //包
 type BlockPackage struct {
-	Origin   string                   //包的原始值
+	Origin      string                   //包的原始值
 	Name        string                   //标段（包）名称
 	Text        string                   //包文 (包对应的正文)
 	Budget      float64                  //标段（包）预算

src/main_blocktest.go

@@ -84,6 +84,7 @@ func com(doc map[string]interface{}) {
 	e.InitRuleCore(false)
 	e.InitRuleCore(true)
 	e.InitBlockRule()
+	e.InitPkgCore()
 	e.InitTag(false)
 	e.InitTag(true)
 	e.InitClearFn(false)

src/web/templates/admin/pkg_info.html

@@ -85,9 +85,13 @@ $(function () {
 				}
 				return tmp
 			}},
-			{"data":"_id",render:function(val,a,row){
-				return '<a class="btn btn-sm btn-success" href="/admin/pkglogic?vid={{.vid}}&pid='+val+'">配置逻辑</a>'
-			}},
+			{"data":"_id","width":"25%",render:function(val,a,row){
+					tmp = '<div class="btn-group">'+
+							'<a class="btn btn-sm btn-success" href="/admin/version/pkglogicore?vid={{.vid}}&s_field='+row.s_field+'&sid='+row._id+'">抽取规则</a>'+
+							'<a class="btn btn-sm btn-info" href="/admin/pkglogicback?vid={{.vid}}&s_field='+row.s_field+'&sid='+row._id+'">后置规则</a>'+
+							'</div>';
+					return  tmp
+				}},
 			{"data":"_id",render:function(val,a,row){
 				return '<a class="btn btn-sm btn-primary opr" opr="edit">编辑</a>&nbsp;<a class="btn btn-sm btn-danger" href="#" onclick="del(\''+val+'\')">删除</a>'
 			}}

src/web/templates/admin/pkg_logicbacklist.html

@@ -9,13 +9,11 @@
 	<section class="content-header">
 		<h1>
 			<small><a class="btn btn-primary opr" opr="new">新增正则</a></small>
-			<small><a class="btn btn-primary opr" opr="newlua">新增脚本</a></small>
 		</h1>
 		<ol class="breadcrumb">
 		  <li><a href="/admin/version"><i class="fa fa-dashboard"></i>版本管理</a></li>
-		  <li><a href="/admin/version/pkginfo?vid={{.vid}}&pid={{.pid}}">分包属性</a></li>
-		  <li><a href="/admin/pkglogic?vid={{.vid}}&pid={{.pid}}">抽取逻辑</a></li>
-		  <li class="active"><a href="/admin/pkglogicback?vid={{.vid}}&pid={{.pid}}&sid={{.sid}}">后置规则</a></li>
+		  <li><a href="/admin/version/pkginfo?vid={{.vid}}">分包属性</a></li>
+		  <li class="active"><a href="/admin/pkglogicback?vid={{.vid}}&s_field={{.s_field}}&sid={{.sid}}">后置规则</a></li>
 		</ol>
     </section>
   <!-- Main content -->
@@ -61,7 +59,7 @@ $(function () {
 		"ajax": {
 			"url": "/admin/pkglogicback/data",
 			"type": "post",
-			"data":{"vid":{{.vid}},"pid":{{.pid}},"sid":{{ .sid}} }
+			"data":{"vid":{{.vid}},"s_field":{{.s_field}},"sid":{{ .sid}} }
 		 },
 		"language": {
             "url": "/res/dist/js/dataTables.chinese.lang"
@@ -119,7 +117,7 @@ $(function () {
 								if (bcon){								
 									$.post("/admin/pkglogicback/save",obj,function(data){
 										if(data&&data.rep){
-											window.location.href="/admin/pkglogicback?vid={{.vid}}&pid={{.pid}}&sid={{.sid}}"								
+											window.location.href="/admin/pkglogicback?vid={{.vid}}&s_field={{.s_field}}&sid={{.sid}}"
 										}else{
 											showTip(data.msg,1000)
 										}
@@ -140,9 +138,9 @@ $(function () {
 			case "new":
 				comtag=[{label:"名称",s_label:"s_name",placeholder:"",must:true},{label:"描述",s_label:"s_descript",type:"tpl_text"}]
 				regtag=[{label:"字段",s_label:"s_field",type:"tpl_list_local",url:"/admin/getfields",default:{{.field}}},{label:"正则",s_label:"s_rule",type:"tpl_text",must:true}]
-				luatag=[{label:"脚本",s_label:"s_luascript",type:"tpl_text",must:true}]
+				luatag=[{label:"脚本",s_label:"s_field",type:"tpl_list_local",url:"/admin/getfields",default:{{.field}}},{label:"脚本",s_label:"s_luascript",type:"tpl_text",must:true}]
 				testcon=[{label:"测试内容",s_label:"s_testcon",type:"tpl_text",must:true}]
-				hiddentag=[{s_label:"_id",type:"tpl_hidden"},{s_label:"vid",type:"tpl_hidden"},{s_label:"pid",type:"tpl_hidden"},{s_label:"sid",type:"tpl_hidden"},{s_label:"s_type",type:"tpl_hidden"}]
+				hiddentag=[{s_label:"_id",type:"tpl_hidden"},{s_label:"vid",type:"tpl_hidden"},{s_label:"s_field",type:"tpl_hidden"},{s_label:"sid",type:"tpl_hidden"},{s_label:"s_type",type:"tpl_hidden"}]
 				islua=false
 				tag = com.pushArry(tag,comtag)
 				if(n=="edit"){
@@ -179,7 +177,7 @@ $(function () {
 					tag = com.pushArry(tag,hiddentag)
 					check=[{label:"测试",class:"btn-warning",
 								fun:function(){
-									window.location.href="/admin/check/lua/pkgcoreback?vid={{.vid}}&pid={{.pid}}&sid={{.sid}}&s_code="+obj.s_code
+									window.location.href="/admin/check/lua/pkgcoreback?vid={{.vid}}&s_field={{.s_field}}&sid={{.sid}}&s_code="+obj.s_code
 								}
 							}]
 					bts = com.pushArry(bts,check)
@@ -187,12 +185,12 @@ $(function () {
 					_tit="新增规则"
 					if(n=="newlua"){
 						_tit="新增脚本"
-						obj={"s_luascript":"--code脚本代码，result 抽取结果，过滤后返回result，对象结构不可改变\nfunction main(code,result)\n\t--过滤操作\n\treturn result\nend","vid":"{{.vid}}","pid":"{{.pid}}","sid":"{{.sid}}","s_type":"1"}
+						obj={"s_luascript":"--code脚本代码，result 抽取结果，过滤后返回result，对象结构不可改变\nfunction main(code,result)\n\t--过滤操作\n\treturn result\nend","vid":"{{.vid}}","s_field":"{{.s_field}}","sid":"{{.sid}}","s_type":"1"}
 						tag = com.pushArry(tag,luatag)
 						tag = com.pushArry(tag,hiddentag)
 						islua=true
 					}else{
-						obj={"vid":"{{.vid}}","pid":"{{.pid}}","sid":"{{.sid}}","s_type":"0"}
+						obj={"vid":"{{.vid}}","s_field":"{{.s_field}}","sid":"{{.sid}}","s_type":"0"}
 						tag = com.pushArry(tag,regtag)
 						tag = com.pushArry(tag,hiddentag)
 					}
@@ -218,7 +216,7 @@ function del(_id){
 			data:{"_id":_id},
 			success:function(r){
 				if(r.rep){				
-					window.location.href="/admin/pkglogicback?vid={{.vid}}&pid={{.pid}}&sid={{.sid}}"
+					window.location.href="/admin/pkglogicback?vid={{.vid}}&s_field={{.s_field}}&sid={{.sid}}"
 				}else{
 					showTip("删除失败", 1000);
 				}

src/web/templates/admin/pkg_logiclist.html

@@ -1,198 +0,0 @@
-{{template "inc"}}
-<!-- Main Header -->
-{{template "header"}}
-<!-- Left side column. 权限菜单 -->
-{{template "memu"}}
-
-<!-- Content Wrapper. Contains page content -->
-<div class="content-wrapper">
-	<section class="content-header">
-		<h1>
-			<small><a class="btn btn-primary opr" opr="new">新增逻辑</a></small>
-		</h1>
-		<ol class="breadcrumb">
-		  <li><a href="/admin/version"><i class="fa fa-dashboard"></i>版本管理</a></li>
-		  <li class="active"><a href="/admin/version/pkginfo?vid={{.vid}}">分包属性</a></li>
-		  <li class="active"><a href="/admin/pkglogic?vid={{.vid}}&pid={{.pid}}">抽取逻辑</a></li>
-		</ol>
-    </section>
-  <!-- Main content -->
-  <section class="content">
-      <div class="row">
-	      <div class="col-xs-12">
-	        <div class="box">
-		        <div class="box-body">
-		            <table id="dataTable" class="table table-bordered table-hover">
-		              <thead>
-		              <tr>
-						<th>名称</th>
-						<th>创建人</th>
-						<th>描述</th>
-						<th>是否启用</th>
-						<th>配置规则</th>
-						<th>操作</th>
-		              </tr>
-		              </thead>
-		            </table>
-		        </div>
-	          <!-- /.box-body -->
-	        </div>
-        <!-- /.box -->
-		</div>
-	</div>
-  </section>
-</div>
-{{template "luares"}}
-{{template "dialog"}}
-{{template "footer"}}
-
-<script>
-menuActive("version")
-$(function () {
-	ttable=$('#dataTable').DataTable({
-		"paging"      : false,
-		"lengthChange": false,
-		"searching"   : true,
-		"ordering"    : false,
-		"info"        : true,
-		"autoWidth"   : false,
-		"ajax": {
-			"url": "/admin/pkglogic/data",
-			"type": "post",
-			"data":{"vid":{{ .vid}} ,"pid":{{ .pid}} }
-		 },
-		"language": {
-            "url": "/res/dist/js/dataTables.chinese.lang"
-        },
-		"columns": [
-			{ "data": "s_name"},
-			{ "data": "s_username"},
-			{ "data": "s_descript"},
-			{ "data": "isuse",render:function(val,a,row){
-				tmp=""
-				if(val){
-					tmp="<a href='#' title='停用' onclick='use(\""+row._id+"\",false)'><i class='fa fa-fw fa-circle text-green'></i></a>已启用"
-				}else{
-					tmp="<a href='#' title='启用' onclick='use(\""+row._id+"\",true)'><i class='fa fa-fw fa-circle text-red'></i></a>未启用"
-				}
-				return tmp
-			}},
-			{"data":"_id","width":"25%",render:function(val,a,row){
-				tmp = '<div class="btn-group">'+
-					'<a class="btn btn-sm btn-info" href="/admin/pkglogicback?vid='+{{.vid}}+'&pid='+{{.pid}}+'&sid='+row._id+'">后置规则</a>'+
-					'</div>';
-				return  tmp
-			}},
-			{"data":"s_version","width":"15%",render:function(val,a,row,pos){
-				return '<a class="btn btn-sm btn-primary opr" opr="edit" row="'+pos.row+'" >编辑</a>'+
-					'&nbsp;&nbsp;<a class="btn btn-sm btn-warning" onclick="del(\''+row._id+'\')">删除</a>';
-			}}
-       	]
-	});
-	ttable.on('init.dt', function () {
-		$(".opr").click(function(){
-			var n=$(this).attr("opr")
-			var htmlObj={},obj,tag=[]
-			var _tit="" 
-			switch(n){
-			case "edit":			
-				obj=ttable.row($(this).closest("tr")).data()
-			case "editlua":
-				obj=ttable.row($(this).closest("tr")).data()
-			case "new":
-				tag=[{label:"名称",s_label:"s_name",placeholder:"",must:true},
-					{label:"描述",s_label:"s_descript",type:"tpl_text"},
-					{label:"启用",s_label:"isuse",type:"tpl_list_local",list:[{"s_name":"是","_id":true},{"s_name":"否","_id":false}],default:true},
-					{label:"标题抽取",s_label:"extfrom",type:"tpl_list_local",list:[{"s_name":"是","_id":true},{"s_name":"否","_id":false}],default:false},
-					{label:"是否适用",s_label:"s_luascript",type:"tpl_text",must:true},
-					{s_label:"_id",type:"tpl_hidden"},
-					{s_label:"vid",type:"tpl_hidden"},{s_label:"pid",type:"tpl_hidden"}]
-				if(n=="edit"){
-					_tit="编辑-"+obj.s_name
-				}else{
-					_tit="新增逻辑"
-					obj={"s_luascript":"function logic(doc)\n\treturn true\nend","vid":"{{.vid}}","pid":"{{.pid}}","s_type":"0"}
-				}
-				
-				htmlObj={
-					title:_tit,
-					tag:tag,
-					lua:true,
-					bts:[
-						{label:"保存",class:"btn-primary",
-							fun:function(){
-								var obj={}
-								var bcon=true
-								$("#_con").find("input[id!=s_show],textarea").each(function(i,el){
-									var val=$(el).val();
-									if(el.id=="s_luascript"){
-										val=editor_1.getValue()
-										obj[el.id]=val
-									}else{
-										obj[el.id]=$(el).val()
-									}
-									if(el.id!="_id"&&$(el).attr("must")&&!val){
-										bcon=false
-										return false
-									}
-								})
-								if (bcon){								
-									$.post("/admin/pkglogic/save",obj,function(data){
-										if(data&&data.rep){
-											window.location.href="/admin/pkglogic?vid={{.vid}}&pid={{.pid}}"	
-										}else{
-											showTip(data.msg,1000)
-										}
-									},'json')
-								}else{
-									alert("红色标签的表单不能为空！")
-								}
-							}
-						}
-					]
-				}
-			OpenDialog(htmlObj,obj)
-			break;
-			}
-		});
-	})
-})
-function del(_id){
-	showConfirm("确定删除？", function() {
-		$.ajax({
-			url:"/admin/pkgrulelogic/del",
-			type:"post",
-			data:{"_id":_id},
-			success:function(r){
-				if(r.rep){				
-					window.location.href="/admin/pkglogic?vid={{.vid}}&pid={{.pid}}";
-				}else{
-					showTip("删除失败", 1000);
-				}
-			}
-		})
-	});
-}
-function use(_id,utype){
-	smg=""
-	if(utype){
-		smg="确定启用？"
-	}else{
-		smg="确定停用？"
-	}
-	showConfirm(smg, function() {
-		$.ajax({
-			url:"/admin/pkglogic/use",
-			type:"post",
-			data:{"_id":_id,"isuse":utype},
-			success:function(r){
-				if(r.rep){				
-					window.location.href="/admin/pkglogic?vid={{.vid}}&pid={{.pid}}"
-				}else{
-					showTip("启用失败", 1000, function() {});
-				}
-			}
-		})
-	});
-}
-</script>

src/web/templates/admin/pkg_logicore.html

@@ -0,0 +1,308 @@
+{{template "inc"}}
+<!-- Main Header -->
+{{template "header"}}
+<!-- Left side column. 权限菜单 -->
+{{template "memu"}}
+
+<!-- Content Wrapper. Contains page content -->
+<div class="content-wrapper">
+    <section class="content-header">
+        <h1>
+            <small><a class="btn btn-primary opr" opr="new">新增正则</a></small>
+        </h1>
+        <ol class="breadcrumb">
+            <li><a href="/admin/version"><i class="fa fa-dashboard"></i>版本管理</a></li>
+            <li><a href="/admin/version/pkginfo?vid={{.vid}}">分包属性</a></li>
+            <li class="active"><a
+                        href="/admin/version/pkglogicore?vid={{.vid}}&sid={{.sid}}&s_field={{.field}}">抽取规则</a></li>
+        </ol>
+    </section>
+    <!-- Main content -->
+    <section class="content">
+        <div class="row">
+            <div class="col-xs-12">
+                <div class="box">
+                    <div class="box-body">
+                        <table id="dataTable" class="table table-bordered table-hover">
+                            <thead>
+                            <tr>
+                                <th>代码</th>
+                                <th>名称</th>
+                                <th>创建人</th>
+                                <th>描述</th>
+                                <th>类型</th>
+                                <th>是否启用</th>
+                                <th>操作</th>
+                            </tr>
+                            </thead>
+                        </table>
+                    </div>
+                    <!-- /.box-body -->
+                </div>
+                <!-- /.box -->
+            </div>
+        </div>
+    </section>
+    <!--
+    <div class="form-group"><select class="form-control select2" multiple="multiple" data-placeholder="Select a State" style="width: 100%;"><option>Alabama</option><option>Alaska</option></select></div>
+    -->
+</div>
+{{template "luares"}}
+{{template "dialog"}}
+{{template "footer"}}
+
+<script>
+    $('.select2').select2()
+    menuActive("version")
+    $(function () {
+        ttable = $('#dataTable').DataTable({
+            "paging": false,
+            "lengthChange": false,
+            "searching": true,
+            "ordering": false,
+            "info": true,
+            "autoWidth": false,
+            "ajax": {
+                "url": "/admin/version/pkglogicore/data",
+                "type": "post",
+                "data": {"s_field":{{.field}},"vid":{{.vid}}, "sid":{{ .sid}} },
+            },
+            "language": {
+                "url": "/res/dist/js/dataTables.chinese.lang"
+            },
+            "columns": [
+                {"data": "s_code"},
+                {"data": "s_name"},
+                {"data": "s_username"},
+                {"data": "s_descript"},
+                {
+                    "data": "s_type", render: function (val, a, row) {
+                        if (val == "0") {
+                            return "正则"
+                        } else {
+                            return "lua脚本"
+                        }
+                    }
+                },
+                {
+                    "data": "isuse", render: function (val, a, row) {
+                        tmp = ""
+                        if (val) {
+                            tmp = "<a href='#' title='停用' onclick='use(\"" + row._id + "\",false)'><i class='fa fa-fw fa-circle text-green'></i></a>已启用"
+                        } else {
+                            tmp = "<a href='#' title='启用' onclick='use(\"" + row._id + "\",true)'><i class='fa fa-fw fa-circle text-red'></i></a>未启用"
+                        }
+                        return tmp
+                    }
+                },
+                {
+                    "data": "_id", render: function (val, a, row, pos) {
+                        tmp = ""
+                        if (row.s_type == "0") {
+                            tmp = '<div>' +
+                                '<a class="btn btn-sm btn-primary opr" opr="edit" row="' + pos.row + '" >编辑</a>　' +
+                                '<a class="btn btn-sm btn-warning" onclick="del(\'' + val + '\')">删除</a>　' +
+                                '</div>';
+                        } else {
+                            tmp = '<div>' +
+                                '<a class="btn btn-sm btn-primary opr" opr="editlua" row="' + pos.row + '" >编辑</a>　' +
+                                '<a class="btn btn-sm btn-warning" onclick="del(\'' + val + '\')">删除</a>　' +
+                                '</div>';
+                        }
+                        return tmp
+                    }
+                }
+            ]
+        });
+        ttable.on('init.dt', function () {
+            $(".opr").click(function () {
+                var n = $(this).attr("opr")
+                var htmlObj = {}, obj, tag = []
+                var bts = [{
+                    label: "保存", class: "btn-primary",
+                    fun: function () {
+                        var obj = {}
+                        var bcon = true
+                        $("#_con").find("input[id!=s_show],textarea").each(function (i, el) {
+                            var val = $(el).val();
+                            if (el.id == "s_luascript") {
+                                val = editor_1.getValue()
+                                obj[el.id] = val
+                            } else {
+                                obj[el.id] = $(el).val()
+                            }
+                            if (el.id != "_id" && $(el).attr("must") && !val) {
+                                bcon = false
+                                return false
+                            }
+                        })
+                        if (bcon) {
+                            $.post("/admin/version/pkglogicore/save", obj, function (data) {
+                                if (data && data.rep) {
+                                    window.location.href = "/admin/version/pkglogicore?vid={{.vid}}&sid={{.sid}}&s_field={{.field}}"
+                                } else {
+                                    showTip(data.msg, 1000)
+                                }
+                            }, 'json')
+                        } else {
+                            alert("红色标签的表单不能为空！")
+                        }
+                    }
+                }
+                ]
+                var _tit = ""
+                switch (n) {
+                    case "edit":
+                        obj = ttable.row($(this).closest("tr")).data();
+                    case "editlua":
+                        obj = ttable.row($(this).closest("tr")).data();
+                    case "newlua":
+                    case "new":
+                        comtag = [{label: "名称", s_label: "s_name", placeholder: "", must: true}, {
+                            label: "描述",
+                            s_label: "s_descript",
+                            type: "tpl_text"
+                        }, {
+                            label: "启用",
+                            s_label: "isuse",
+                            type: "tpl_list_local",
+                            list: [{"s_name": "是", "_id": true}, {"s_name": "否", "_id": false}],
+                            default: true
+                        }]
+                        regtag = [{
+                            label: "字段",
+                            s_label: "s_field",
+                            type: "tpl_list_local",
+                            url: "/admin/getfields",
+                            default:{{.field}}}, {label: "正则", s_label: "s_rule", type: "tpl_text", must: true}]
+                        luatag = [{
+                            label: "脚本",
+                            s_label: "s_field",
+                            type: "tpl_list_local",
+                            url: "/admin/getfields",
+                            default:{{.field}}}, {label: "脚本", s_label: "s_luascript", type: "tpl_text", must: true}]
+                        testcon = [{label: "测试内容", s_label: "s_testcon", type: "tpl_text", must: true}]
+                        hiddentag = [{s_label: "_id", type: "tpl_hidden"}, {
+                            s_label: "vid",
+                            type: "tpl_hidden"
+                        }, {s_label: "s_field", type: "tpl_hidden"}, {
+                            s_label: "sid",
+                            type: "tpl_hidden"
+                        }, {s_label: "s_type", type: "tpl_hidden"}]
+                        islua = false
+                        tag = com.pushArry(tag, comtag)
+                        if (n == "edit") {
+                            _tit = "编辑-" + obj.s_name
+                            tag = com.pushArry(tag, regtag)
+                            tag = com.pushArry(tag, hiddentag)
+                            tag = com.pushArry(tag, testcon)
+                            check = [{
+                                label: "测试", class: "btn-warning",
+                                fun: function () {
+                                    var obj = {}
+                                    var bcon = true
+                                    $("#_con").find("input[id!=s_show],textarea").each(function (i, el) {
+                                        var val = $(el).val();
+                                        obj[el.id] = $(el).val()
+                                        if (el.id != "_id" && $(el).attr("must") && !val) {
+                                            bcon = false
+                                            return false
+                                        }
+                                    })
+                                    if (bcon) {
+                                        $.post("/admin/check/extrule", obj, function (data) {
+                                            showMsg(JSON.stringify(data.rep))
+                                        }, 'json')
+                                    } else {
+                                        alert("红色标签的表单不能为空！")
+                                    }
+                                }
+                            }]
+                            bts = com.pushArry(bts, check)
+                        } else if (n == "editlua") {
+                            _tit = "编辑-" + obj.s_name
+                            islua = true
+                            tag = com.pushArry(tag, luatag)
+                            tag = com.pushArry(tag, hiddentag)
+                            check = [{
+                                label: "测试", class: "btn-warning",
+                                fun: function () {
+                                    window.location.href = "/admin/check/lua/core?vid={{.vid}}&sid={{.sid}}&s_code=" + obj.s_code
+                                }
+                            }]
+                            bts = com.pushArry(bts, check)
+                        } else {
+                            _tit = "新增规则"
+                            if (n == "newlua") {
+                                _tit = "新增脚本"
+                                obj = {
+                                    "s_luascript": "--code脚本代码，doc数据源，block块对象，kvs抽取kv对象，返回kvs对象，kvs结构不可改变\nfunction main(code,doc,block,kvs)\n\t--自定义抽取\n\treturn kvs\nend",
+                                    "vid": "{{.vid}}",
+                                    "s_field": "{{.field}}",
+                                    "sid": "{{.sid}}",
+                                    "s_type": "1"
+                                }
+
+                                tag = com.pushArry(tag, luatag)
+                                tag = com.pushArry(tag, hiddentag)
+                                islua = true
+                            } else {
+                                obj = {"vid": "{{.vid}}", "s_field":{{.field}}, "sid": "{{.sid}}", "s_type": "0"}
+                                tag = com.pushArry(tag, regtag)
+                                tag = com.pushArry(tag, hiddentag)
+                            }
+                        }
+                        htmlObj = {
+                            title: _tit,
+                            tag: tag,
+                            lua: islua,
+                            bts: bts
+                        }
+                        OpenDialog(htmlObj, obj)
+                        break;
+                }
+            });
+        })
+    })
+
+    function del(_id) {
+        showConfirm("确定删除？", function () {
+            $.ajax({
+                url: "/admin/version/pkglogicore/del",
+                type: "post",
+                data: {"_id": _id},
+                success: function (r) {
+                    if (r.rep) {
+                        window.location.href = "/admin/version/pkglogicore?vid={{.vid}}&sid={{.sid}}&s_field={{.field}}";
+                    } else {
+                        showTip("删除失败", 1000);
+                    }
+                }
+            })
+        });
+    }
+
+    function use(_id, utype) {
+        smg = ""
+        if (utype) {
+            smg = "确定启用？"
+        } else {
+            smg = "确定停用？"
+        }
+        showConfirm(smg, function () {
+            $.ajax({
+                url: "/admin/version/pkglogicore/use",
+                type: "post",
+                data: {"_id": _id, "isuse": utype},
+                success: function (r) {
+                    if (r.rep) {
+                        window.location.reload()
+                    } else {
+                        showTip("启用失败", 1000, function () {
+                        });
+                    }
+                }
+            })
+        });
+    }
+</script>