elastic.go 429 B

123456789101112131415
  1. package partner
  2. import (
  3. "app.yhyue.com/moapp/jy_docs/rpc/partnerlib/entity"
  4. jyDocsRpcUtil "app.yhyue.com/moapp/jy_docs/services/util"
  5. )
  6. // 同步豆丁文档到es
  7. func SyncDocsToES(docs []map[string]interface{}) {
  8. //jyDocsRpcUtil.GetESV7DB().Save(entity.ElasticJYDoc, entity.ElasticJYDoc, docs[0])
  9. if len(docs) > 0 {
  10. jyDocsRpcUtil.GetESV7DB().BulkSave(entity.ElasticJYDoc, entity.ElasticJYDoc, &docs, true)
  11. }
  12. return
  13. }