You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
33 lines
932 B
33 lines
932 B
package service |
|
|
|
import ( |
|
"context" |
|
"fmt" |
|
|
|
"go-common/app/admin/main/search/dao" |
|
"go-common/library/ecode" |
|
) |
|
|
|
// Update update some indices. |
|
func (s *Service) Update(c context.Context, esName string, bulkData []dao.BulkItem) (err error) { |
|
if err = s.dao.UpdateBulk(c, esName, bulkData); err != nil { |
|
dao.PromError(fmt.Sprintf("es:%s 更新失败", esName), "s.dao.updateBulk error(%v) ", err) |
|
err = ecode.SearchUpdateIndexFailed |
|
} |
|
return |
|
} |
|
|
|
// MapUpdate map update. |
|
func (s *Service) MapUpdate(c context.Context, p []dao.BulkMapItem) (err error) { |
|
err = s.dao.UpdateMapBulk(c, "ssd_archive", p) |
|
return |
|
} |
|
|
|
// Index . |
|
func (s *Service) Index(c context.Context, esName string, bulkData []dao.BulkItem) (err error) { |
|
if err = s.dao.BulkIndex(c, esName, bulkData); err != nil { |
|
dao.PromError(fmt.Sprintf("es:%s 写入失败", esName), "s.dao.BulkIndex error(%v) ", err) |
|
err = ecode.SearchUpdateIndexFailed |
|
} |
|
return |
|
}
|
|
|