ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'S02-轨迹中台第二部分' into test

Browse Source
This commit is contained in:
李鹏军 2024-03-19 15:27:14 +08:00
commit 095d5d6501
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/SJZY.Track.Application/EventHandlers/TrackDeleteEventHandler.cs
View File

@ -62,7 +62,8 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
if (isOk) if (isOk)
{ {
// 触发订单主表更新事件 // 触发订单主表更新事件
await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe, await _capPublisher.PublishDelayAsync(TimeSpan.FromSeconds(3),
GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
new TrackChangeAfterUpdateOrderEvent new TrackChangeAfterUpdateOrderEvent
{ {
OrderId = @event.OrderId, OrderId = @event.OrderId,

1
src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
View File

@ -165,7 +165,6 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
q.Term(t => t.OrderId, orderId) q.Term(t => t.OrderId, orderId)
&& q.Term(t => t.IsCanDelete, true) && q.Term(t => t.IsCanDelete, true)
&& q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes))) && q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
.WaitForActiveShards("all")
//.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见 //.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
); );