28 lines
645 B
Go
28 lines
645 B
Go
package esaudiobook
|
|
|
|
import (
|
|
"91porn-server/common/elastic"
|
|
"91porn-server/common/log"
|
|
"91porn-server/models"
|
|
"91porn-server/models/v/audiobookmod"
|
|
)
|
|
|
|
// 同步用户数据
|
|
func SyncDataToES(data []audiobookmod.AudioBookBase) error {
|
|
if len(data) == 0 {
|
|
return nil
|
|
}
|
|
var source = elastic.M{}
|
|
for k := range data {
|
|
var tmp = data[k]
|
|
source[data[k].ID.Hex()] = tmp
|
|
}
|
|
log.Info("Elastic sync audiobook data committing...")
|
|
if err := es.Bulk(models.ESInfoAudioBookTable, source); err != nil {
|
|
log.Info("Elastic sync audiobook data commit failed.")
|
|
return err
|
|
}
|
|
log.Info("Elastic sync audiobook data committed.")
|
|
return nil
|
|
}
|