备份-测试代码

udpfilterdup/src/main.go

@@ -7,7 +7,6 @@ package main
 import (
 	"encoding/json"
 	"fmt"
-	"gopkg.in/mgo.v2/bson"
 	"log"
 	mu "mfw/util"
 	"net"
@@ -22,6 +21,9 @@ var (
 	Sysconfig    map[string]interface{} //配置文件
 	mconf        map[string]interface{} //mongodb配置信息
 	mgo          *mongodb.MongodbSim    //mongodb操作对象
+
+	mgoTest          *mongodb.MongodbSim    //mongodb操作对象
+
 	extract      string
 	extract_copy string
 	bidding      string
@@ -62,61 +64,121 @@ func init() {
 
 
 	//测试临时注释
-	dupdays = util.IntAllDef(Sysconfig["dupdays"], 3)
-	//加载数据
-	DM = NewDatamap(dupdays, lastid)
-	sw := util.ObjToString(Sysconfig["specialwords"])
-	if sw != "" {
-		FilterRegexp = regexp.MustCompile(sw)
+	//dupdays = util.IntAllDef(Sysconfig["dupdays"], 3)
+	////加载数据
+	//DM = NewDatamap(dupdays, lastid)
+	//sw := util.ObjToString(Sysconfig["specialwords"])
+	//if sw != "" {
+	//	FilterRegexp = regexp.MustCompile(sw)
+	//}
+
+
+	//数据库
+	//mongodb.InitMongodbPool(5, "192.168.3.207:27081", "")
+
+	mgoTest = &mongodb.MongodbSim{
+		MongodbAddr: "192.168.3.207:27081",
+		Size:        5,
+		DbName:      "qfw",
 	}
+	mgoTest.InitPool()
+
+
 }
 
 //新增一个方法 判断
-func mainTest()  {
+func main222()  {
+	log.Println("1")
+
+	sessTest :=mgoTest.GetMgoConn()
+	defer sessTest.Close()
 
 	sess := mgo.GetMgoConn()
-	defer mgo.DestoryMongoConn(sess)
-	res, _ := mgo.Find(extract, nil, nil, nil, false, -1, -1)
-	res_copy, _ := mgo.Find(extract_copy, nil, nil, nil, false, -1, -1)
-	m1 :=map[string]int{} //新版本
-	m2 :=map[string]int{} //老版本
-	for _,v:=range *res{
-		m1[(v["_id"].(bson.ObjectId).Hex())]= util.IntAll(v["repeat"])
-	}
-	for _,v:=range *res_copy{
-		m2[(v["_id"].(bson.ObjectId).Hex())]= util.IntAll(v["repeat"])
-	}
-	fmt.Println(len(m1),len(m2))
-	n1:=0
-	n2:=0
-	var arr1 []string
-	var arr2 []string
-	for k,v:=range m2{
-		if m1[k]!=v{
-			if m1[k]==0{
-				n1++
-				arr1 = append(arr1,fmt.Sprintf("目标_id:%s",k))
-			}
-			if m1[k]==1{
-				n2++
-				arr2 = append(arr2,fmt.Sprintf("目标_id:%s",k))
-			}
+	defer sess.Close()
+
+	//var arr []map[string]interface{}
+
+	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")
+
+
+
+
+
+	i:=0
+	for dict := make(map[string]interface{}); res_test.Next(&dict); i++{
+
+		//插入
+		if i%2000==0 {
+			log.Println("当前：",i)
 		}
-	}
-	for _,v:=range arr1 {
-		log.Println(v)
+		res.Insert(dict)
+		//if len(arr)>=500 {
+		//	arr = make([]map[string]interface{},0)
+		//}else {
+		//	arr = append(arr,dict)
+		//}
 	}
 
-	log.Println("------")
-	log.Println("------")
-	log.Println("------")
 
-	for _,v:=range arr2 {
-		log.Println(v)
-	}
 
-	log.Println("0:1 对应数量",n1)
-	log.Println("1:0 对应数量",n2)
+	//sess := mgo.GetMgoConn()
+	//defer mgo.DestoryMongoConn(sess)
+	//res, _ := mgo.Find(extract_copy, nil, nil, nil, false, -1, -1)
+	//res_copy, _ := mgo.Find(extract, nil, nil, nil, false, -1, -1)
+
+	//m1 :=map[string]int{} //老版本
+	//m2 :=map[string]int{} //新版本
+	//for _,v:=range *res{
+	//	m1[(v["_id"].(bson.ObjectId).Hex())]= util.IntAll(v["repeat"])
+	//}
+	//for _,v:=range *res_copy{
+	//	m2[(v["_id"].(bson.ObjectId).Hex())]= util.IntAll(v["repeat"])
+	//}
+	//fmt.Println(len(m1),len(m2))
+	//n1:=0
+	//n2:=0
+	//var arr1 []string
+	//var arr2 []string
+	//for k,v:=range m1{
+	//	if m2[k]!=v{
+	//		if m2[k]==0{ //1:0
+	//			n1++
+	//			arr1 = append(arr1,fmt.Sprintf("目标_id:%s",k))
+	//		}
+	//		if m2[k]==1{//0:1
+	//			n2++
+	//		}
+	//	}
+	//}
+	//for _,v:=range arr1 {
+	//	log.Println(v)
+	//}
+	//log.Println("V1版本：1:0 对应数量",n1)
+	//log.Println("V1版本：0:1 对应数量",n2)
+	//
+	//
+	//n1=0
+	//n2=0
+	//for k,v:=range m2{
+	//	if m1[k]!=v{
+	//		if m1[k]==0{
+	//			n1++
+	//		}
+	//		if m1[k]==1{
+	//			n2++
+	//			arr2 = append(arr2,fmt.Sprintf("目标_id:%s",k))
+	//		}
+	//	}
+	//}
+	//for _,v:=range arr2 {
+	//	log.Println(v)
+	//}
+	//log.Println("V2版本：0:1 对应数量",n1)
+	//log.Println("V2版本：1:0 对应数量",n2)
+
+	// 10-14   10-25   1571025600  1571976000
+
 }