抽取前置···，预处理

src/jy/extract/extractudp.go

@@ -345,8 +345,8 @@ func ExtractByUdpPre(n_sid, n_eid string, f_sid, f_eid string) {
 	count1 := ext.TaskInfo.FDB.Count("bidding_nomal", query1)
 	count2 := ext.TaskInfo.FDB.Count("bidding_file", query2)
 	log.Debug("待抽取数量：", count1+count2)
-	list1, _ := ext.TaskInfo.FDB.Find("zktest_bidding_nomal", query1, nil, Fields, false, -1, -1)
-	list2, _ := ext.TaskInfo.FDB.Find("zktest_bidding_file", query2, nil, Fields, false, -1, -1)
+	list1, _ := ext.TaskInfo.FDB.Find("bidding_nomal", query1, nil, Fields, false, -1, -1)
+	list2, _ := ext.TaskInfo.FDB.Find("bidding_file", query2, nil, Fields, false, -1, -1)
 	new_list := append(*list1, *list2...)
 	now_time := time.Now().Unix()
 	total := 0

src/jy/extract/extraxtmethod.go

@@ -481,7 +481,8 @@ func EmployPostEntDfa(data map[string]interface{}) map[string]interface{} {
 	info := map[string]interface{}{}
 	client := &http.Client{Timeout: 2 * time.Second}
 	jsonStr, _ := json.Marshal(data)
-	resp, err := client.Post("http://extcity.spdata.jianyu360.com/service/entity/", "application/json", bytes.NewBuffer(jsonStr))
+	//172.17.4.238:9996,extcity.spdata.jianyu360.com
+	resp, err := client.Post("http://172.17.4.238:9996/service/entity/", "application/json", bytes.NewBuffer(jsonStr))
 	if err != nil {
 		return info
 	}

src/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	log "github.com/donnie4w/go-logger/logger"
+	"gopkg.in/mgo.v2/bson"
 	_ "jy/admin"
 	_ "jy/admin/audit"
 	_ "jy/admin/distribution"
@@ -47,5 +48,7 @@ func testMain() {
 }
 
 func testPostDfa() {
-	//http://extcity.spdata.jianyu360.com/service/entity/test?text=我是正文开滦（集团）有限责任公司
+	text := "正文描述广州城市职业学院正文描述"
+	dfa_info := extract.EmployPostEntDfa(bson.M{"detail": text})
+	log.Debug(dfa_info)
 }