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

Merge branch 'S03-轨迹中台' into dev

Browse Source
This commit is contained in:
李鹏军 2024-04-01 18:17:01 +08:00
commit 7d4a1183ae
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Application/EventHandlers/CAPFilter.cs
View File

@ -24,6 +24,12 @@ public class CapFilter : SubscribeFilter
if (context.DeliverMessage.Headers["cap-msg-name"]!.EndsWith(GlobalConst.TrackRefreshSubscribe))
return Task.CompletedTask;
// 本地调试不做幂等
if (System.Diagnostics.Debugger.IsAttached)
{
return Task.CompletedTask;
}
var argumentJsonStr = context.Arguments.ToJson();
context.DeliverMessage.Headers["sjzy-arguments"] = argumentJsonStr;

6
src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
View File

@ -48,8 +48,6 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
var log = new TrackPushRecordIndex
{
IndexName = $"{GlobalConst.TrackPushRecordsIndex}-{DateTime.Now:yyyy.MM.dd}",
RequestId = res.RequestId,
Message = res.Msg,
OptionType = @event.OptionType.ToString(),
OrderId = @event.OrderId,
TrackStatus = @event.TrackStatus,
@ -183,6 +181,8 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
log.PushContent = body.ToJson();
log.IsSuccess = res.Code == InterfaceRelayConst.SuccessCode;
log.RequestId = res.RequestId;
log.Message = res.Msg;
}
private async Task DoUpdateAsync(TrackPushEvent @event,
@ -215,5 +215,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
log.PushContent = data.ToJson();
log.IsSuccess = res.Code == InterfaceRelayConst.SuccessCode;
log.RequestId = res.RequestId;
log.Message = res.Msg;
}
}