This commit is contained in:
parent
32b5509f04
commit
2422bce16b
5
es/es.go
5
es/es.go
|
@ -45,8 +45,9 @@ func (es *ElasticSearch) CreateStreamerAcct(ctx context.Context, streameraccts [
|
||||||
|
|
||||||
func (es *ElasticSearch) UpdateStreamerAcct(ctx context.Context, streameracct *dbstruct.EsStreamerAcct) error {
|
func (es *ElasticSearch) UpdateStreamerAcct(ctx context.Context, streameracct *dbstruct.EsStreamerAcct) error {
|
||||||
_, err := es.clientMix.Update().Index(es.getIndexStreamerAcct()).Id(fmt.Sprint(streameracct.Mid)).Doc(map[string]any{
|
_, err := es.clientMix.Update().Index(es.getIndexStreamerAcct()).Id(fmt.Sprint(streameracct.Mid)).Doc(map[string]any{
|
||||||
"name": streameracct.Name,
|
"name": streameracct.Name,
|
||||||
"ut": streameracct.Ut,
|
"pinyin": streameracct.PinYin,
|
||||||
|
"ut": streameracct.Ut,
|
||||||
}).Do(ctx)
|
}).Do(ctx)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue