update.go 932 B

123456789101112131415161718192021222324252627282930313233
  1. package service
  2. import (
  3. "context"
  4. "fmt"
  5. "go-common/app/admin/main/search/dao"
  6. "go-common/library/ecode"
  7. )
  8. // Update update some indices.
  9. func (s *Service) Update(c context.Context, esName string, bulkData []dao.BulkItem) (err error) {
  10. if err = s.dao.UpdateBulk(c, esName, bulkData); err != nil {
  11. dao.PromError(fmt.Sprintf("es:%s 更新失败", esName), "s.dao.updateBulk error(%v) ", err)
  12. err = ecode.SearchUpdateIndexFailed
  13. }
  14. return
  15. }
  16. // MapUpdate map update.
  17. func (s *Service) MapUpdate(c context.Context, p []dao.BulkMapItem) (err error) {
  18. err = s.dao.UpdateMapBulk(c, "ssd_archive", p)
  19. return
  20. }
  21. // Index .
  22. func (s *Service) Index(c context.Context, esName string, bulkData []dao.BulkItem) (err error) {
  23. if err = s.dao.BulkIndex(c, esName, bulkData); err != nil {
  24. dao.PromError(fmt.Sprintf("es:%s 写入失败", esName), "s.dao.BulkIndex error(%v) ", err)
  25. err = ecode.SearchUpdateIndexFailed
  26. }
  27. return
  28. }