try:es批量del禁止冲突检测
This commit is contained in:
parent
ae1b785273
commit
9bf4150990
@ -1,3 +1,4 @@
|
||||
using Elasticsearch.Net;
|
||||
using Nest;
|
||||
using SJZY.Expand.ElasticSearch.Services;
|
||||
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
|
||||
@ -217,10 +218,8 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
|
||||
|
||||
public async Task DeleteTrackAsync(int[] orderIds, List<string> trackCodes)
|
||||
{
|
||||
var r = await Context.UpdateByQueryAsync<TrackDetailsIndex>(x => x
|
||||
.Script(s => s
|
||||
.Source("ctx.op = 'delete'")
|
||||
)
|
||||
var r = await Context.DeleteByQueryAsync<TrackDetailsIndex>(x => x
|
||||
.Conflicts(Conflicts.Proceed)
|
||||
.Query(
|
||||
q =>
|
||||
q.Terms(t => t.Field(f => f.OrderId).Terms(orderIds))
|
||||
|
||||
Loading…
Reference in New Issue
Block a user