jy-data-extract/src/main_test.go

package main

import (
	"jy/admin/track"
	"jy/extract"
	. "jy/mongodbutil"
	"log"
	"regexp"
	"testing"
	"time"
)

func Test_task(t *testing.T) {
	Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_v3")
	extract.StartExtractTaskId("5b8f804025e29a290415aee1")
	//extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5b8dcc45a5cb26b9b7f68469", "10", "result_v3", "track_v3")
	time.Sleep(300 * time.Second)
}
func Test_reg(t *testing.T) {
	context := ` 项目名称：   新碶街道2018年美女姜河、向家村河、塘湾河①河道清淤工程招标公告`
	str := `[\s\\u3000\\u2003\\u00a0a-z0-9.、一二三]*项目名称[：:][\n\s\\u3000\\u2003\\u00a0]*([^，,。；;：:\n]{4,40})`
	reg := regexp.MustCompile(str)
	tmp := reg.FindAllStringSubmatch(context, -1)
	for k, v := range tmp {
		log.Println(k, v[1])
	}
}

func Test_paths(t *testing.T) {
	Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_v3")
	tracks := track.GetTrackPath("5b8dd276a5cb26b9b7faaa7c", "projectname", "rack_v3", "result_v3")
	for code, v := range tracks {
		if tmp, ok := v.([]map[string]interface{}); ok {
			for k, v := range tmp {
				if k == 0 {
					log.Println(v)
				} else {
					log.Println(code, v["code"], v["value"])
				}
			}
		}
		break
	}
}