27 lines
641 B
Go
27 lines
641 B
Go
package essearchlog
|
|
|
|
import (
|
|
"91jd-server/common/elastic"
|
|
"91jd-server/common/log"
|
|
"91jd-server/models"
|
|
"91jd-server/models/l/searchlogmod"
|
|
)
|
|
|
|
// 同步数据到ES
|
|
func SyncDataToES(data []searchlogmod.SearchLog) error {
|
|
if len(data) == 0 {
|
|
return nil
|
|
}
|
|
var source = elastic.M{}
|
|
for _, v := range data {
|
|
source[v.ID.Hex()] = searchlogmod.ESSearchLogSource(v)
|
|
}
|
|
log.Info("Elastic sync search log data committing...")
|
|
if err := es.Bulk(models.ESLogSearchLogTable, source); err != nil {
|
|
log.Info("Elastic sync search log data commit failed.")
|
|
return err
|
|
}
|
|
log.Info("Elastic sync search log data committed.")
|
|
return nil
|
|
}
|