注释

udpfilterdup/src/main.go

@@ -66,12 +66,12 @@ func init() {
 
 
 	//测试临时注释
-	dupdays = util.IntAllDef(Sysconfig["dupdays"], 3)
-	//加载数据
-	DM = NewDatamap(dupdays, lastid)
-	FilterRegTitle = regexp.MustCompile(util.ObjToString(Sysconfig["specialwords"]))
-	FilterRegTitle_1 = regexp.MustCompile(util.ObjToString(Sysconfig["specialtitle_1"]))
-	FilterRegTitle_2 = regexp.MustCompile(util.ObjToString(Sysconfig["specialtitle_2"]))
+	//dupdays = util.IntAllDef(Sysconfig["dupdays"], 3)
+	////加载数据
+	//DM = NewDatamap(dupdays, lastid)
+	//FilterRegTitle = regexp.MustCompile(util.ObjToString(Sysconfig["specialwords"]))
+	//FilterRegTitle_1 = regexp.MustCompile(util.ObjToString(Sysconfig["specialtitle_1"]))
+	//FilterRegTitle_2 = regexp.MustCompile(util.ObjToString(Sysconfig["specialtitle_2"]))
 
 
 
@@ -90,7 +90,8 @@ func init() {
 }
 
 //新增一个方法 判断
-func mainTest()  {
+func main()  {
+
 	//log.Println("1")
 	//代码copy数据
 	//sessTest :=mgoTest.GetMgoConn()
@@ -103,7 +104,7 @@ func mainTest()  {
 	//
 	//res_test := sessTest.DB("qfw").C("bidding").Find(mongodb.ObjToMQ(`{"comeintime":{"$gte": 1571025600, "$lte": 1571976000}}`, true)).Iter()
 	//res :=sess.DB("extract_kf").C("a_testbidding")
-	//
+	//5
 	//
 	//
 	//
@@ -158,10 +159,13 @@ func mainTest()  {
 	n2:=0
 	n3:=0
 	n4:=0
+	n5:=0
+	n6:=0
 
 	var arr1 []string
 	var arr2 []string
 	for k,v:=range m1{
+
 		if m2[k]==1&&v==0{//0:1
 			n1++
 			arr2 = append(arr2,fmt.Sprintf("目标_id:%s",k))
@@ -176,24 +180,28 @@ func mainTest()  {
 		if m2[k]==1&&v==1{//1:1
 			n4++
 		}
+		if m2[k]==-1&&v==0{ //0:-1
+			n5++
+		}
+		if m2[k]==-1&&v==1{//1:-1
+			n6++
+		}
+
 	}
-	//打印 1：0情况 少打印 300条    38841
+	//打印 1：0情况    66989
 	mm:=0
 	for _,v:=range arr1 {
 		mm++
-		if mm%130==0 {
+		if mm%222==0 {
 			log.Println(v)
 		}
 	}
 
 	log.Println("分割线---------------")
 	log.Println("分割线---------------")
-	log.Println("分割线---------------")
-	log.Println("分割线---------------")
-	log.Println("分割线---------------")
 
 
-	//打印 1：0情况 少打印  1000条   15518
+	//打印 0：1情况  8729
 	nn:=0
 	for _,v:=range arr2 {
 		nn++
@@ -206,14 +214,14 @@ func mainTest()  {
 	log.Println("V1 1:0---",n2)
 	log.Println("V1 0:0---",n3)
 	log.Println("V1 1:1---",n4)
-
-
+	log.Println("V1 0:-1---",n5)
+	log.Println("V1 1:-1---",n6)
 
 }
 
 
 
-func main() {
+func mainTest() {
 	go checkMapJob()
 
 	updport := Sysconfig["udpport"].(string)
@@ -276,6 +284,7 @@ func task(data []byte, mapInfo map[string]interface{}) {
 
 	for tmp := make(map[string]interface{}); it.Next(&tmp); n++ {
 
+
 		if util.ObjToString(tmp["subtype"]) == "变更" {
 			//continue
 		}