|
@@ -390,9 +390,9 @@ func esSaveFuc(tmp map[string]interface{}, detail string, saveEsArr *[]map[strin
|
|
saveEs[f] = tmp[f]
|
|
saveEs[f] = tmp[f]
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- *saveEsArr = append(*saveEsArr, saveEs)
|
|
|
|
- if len(*saveEsArr) > 50 {
|
|
|
|
- util.BulkSave("bidding_customer", saveEsArr, false, util.EsCus.(*elastic.EsV7))
|
|
|
|
- saveEsArr = &[]map[string]interface{}{}
|
|
|
|
- }
|
|
|
|
|
|
+ //*saveEsArr = append(*saveEsArr, saveEs)
|
|
|
|
+ //if len(*saveEsArr) > 50 {
|
|
|
|
+ // util.BulkSave("bidding_customer", saveEsArr, false, util.EsCus.(*elastic.EsV7))
|
|
|
|
+ // saveEsArr = &[]map[string]interface{}{}
|
|
|
|
+ //}
|
|
}
|
|
}
|