|
@@ -15,7 +15,7 @@ import (
|
|
|
var N = 200
|
|
|
|
|
|
//生enterprise表
|
|
|
-func main1() {
|
|
|
+func main() {
|
|
|
// 参数 mongodb(网站库) mongodb(公示库) elastic collection area index-db inde-type N
|
|
|
initConfig(os.Args[1], "web", "qfw")
|
|
|
if os.Args[4] == "enterprise" {
|
|
@@ -42,7 +42,7 @@ func main1() {
|
|
|
query := ecps_session.DB("qfw").C(os.Args[4]).Find(m).Iter()
|
|
|
arr := make([]map[string]interface{}, 0)
|
|
|
for tmp := make(map[string]interface{}); query.Next(tmp); i++ {
|
|
|
- arr = append(arr, tmp)
|
|
|
+ arr = append(arr, elastic.ConverData(&tmp))
|
|
|
if i%N == 0 && i != 0 {
|
|
|
elastic.BulkSave(os.Args[6], os.Args[7], &arr, true)
|
|
|
arr = make([]map[string]interface{}, 0)
|
|
@@ -102,7 +102,7 @@ func main1() {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
-func main() {
|
|
|
+func main1() {
|
|
|
// 参数 mongodb(网站库) elastic collection query
|
|
|
initConfig(os.Args[1], "web", "qfw")
|
|
|
InitMongodbPool()
|