filetext

udpcreateindex/src/bidingpurchasing.go

@@ -23,6 +23,7 @@ func biddingPurchaingTask(q map[string]interface{}) {
 	itype, _ := bidding["type"].(string)
 	//
 	session := mgo.GetMgoConn(86400)
+	defer mgo.DestoryMongoConn(session)
 	count, _ := session.DB(db).C(c).Find(&q).Count()
 	log.Println("biddingPurchaingTask:	", db, c, "查询语句:", q, "同步总数:", count, "elastic库:", index)