xiugai

src/config.json

@@ -46,7 +46,8 @@
 		"addr": "192.168.3.207:27092",
 		"size": 15,
 		"db": "mxs",
-		"coll": "usermail"
+		"coll": "usermail",
+		"coll_test": "usermail_history"
 	},
 	"es": {
 		"addr": "http://192.168.3.128:9800",

src/history/util_history.go

@@ -564,7 +564,7 @@ func SaveMgo() {
 					defer func() {
 						<-SP
 					}()
-					MgoSave.SaveBulk(SaveColl, arru...)
+					MgoSave.SaveBulk(SaveColl_test, arru...)
 				}(arru)
 				arru = make([]map[string]interface{}, 500)
 				indexu = 0
@@ -576,7 +576,7 @@ func SaveMgo() {
 					defer func() {
 						<-SP
 					}()
-					MgoSave.SaveBulk(SaveColl, arru...)
+					MgoSave.SaveBulk(SaveColl_test, arru...)
 				}(arru[:indexu])
 				arru = make([]map[string]interface{}, 500)
 				indexu = 0

src/util/config.go

@@ -31,9 +31,10 @@ var (
 	Itype           string
 	TaskTime        int64 //定时任务时间
 	//历史数据
-	SId          string
-	EId          string
-	CustomerName string
+	SId           string
+	EId           string
+	CustomerName  string
+	SaveColl_test string
 )
 
 var (
@@ -185,6 +186,7 @@ func initdb() {
 	//mgo save
 	save := Sysconfig["save"].(map[string]interface{})
 	SaveColl = qu.ObjToString(save["coll"])
+	SaveColl_test = qu.ObjToString(save["coll_test"])
 	MgoSave = &mgo.MongodbSim{
 		MongodbAddr: qu.ObjToString(save["addr"]),
 		DbName:      qu.ObjToString(save["db"]),