分包属性

src/jy/extract/extract.go

@@ -42,7 +42,6 @@ func StartExtractTestTask(taskId, startId, num, resultcoll, trackcoll string) bo
 	ext.InitRuleBacks()
 	ext.InitRuleCore()
 	ext.InitPkgCore()
-	return false
 	ext.InitTag()
 	ext.InitClearFn()
 	if ext.IsExtractCity { //版本上控制是否开始城市抽取

src/jy/extract/extractInit.go

@@ -340,7 +340,6 @@ func (e *ExtractTask) InitPkgCore() {
 	defer qu.Catch()
 	e.PkgRuleCores = []*RuleCore{}
 	pkginfos, _ := db.Mgo.Find("pkg_info", `{"vid":"`+e.TaskInfo.VersionId+`","delete":false}`, nil, nil, false, -1, -1)
-	log.Println(len(*pkginfos))
 	for _, pkginfo := range *pkginfos {
 		if b, _ := pkginfo["isuse"].(bool); !b {
 			continue
@@ -385,7 +384,6 @@ func (e *ExtractTask) InitPkgCore() {
 				}
 			}
 			rcore.RuleBacks = ruleBacks
-			//
 			e.PkgRuleCores = append(e.PkgRuleCores, rcore)
 		}
 	}

src/main_test.go

@@ -14,7 +14,7 @@ import (
 func Test_task(t *testing.T) {
 	Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_kf")
 	//extract.StartExtractTaskId("5b8f804025e29a290415aee1")
-	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5a999f3140d2d9bbe820dbb1", "5", "mxs_v3", "mxs_v3")
+	extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5c2a49d0a5cb26b9b766bd98", "5", "mxs_v3", "mxs_v3")
 	//extract.StartExtractTestTask("5c3d75c96984142998eb00e1", "5c2a3d28a5cb26b9b76144dd", "100", "mxs_v3", "mxs_v3")
 	time.Sleep(5 * time.Second)
 }