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

Merge remote-tracking branch 'origin/S03-轨迹中台优化项' into test

Browse Source
This commit is contained in:
dingenwen 2024-04-15 19:15:26 +08:00
commit 27e9b0b9ad
1 changed files with 3 additions and 3 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

@ -20,9 +20,9 @@ public class CapFilter : SubscribeFilter
{ {
context.DeliverMessage.Headers["sjzy-receive-time"] = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff"); context.DeliverMessage.Headers["sjzy-receive-time"] = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff");
// 轨迹增删改要做幂等 // 轨迹增改要做幂等
if (!context.DeliverMessage.Headers["cap-msg-name"] if (!context.DeliverMessage.Headers["cap-msg-name"]
.IsIn(GlobalConst.TrackUpsertSubscribe, GlobalConst.TrackDeleteSubscribe)) .IsIn(GlobalConst.TrackUpsertSubscribe))
return Task.CompletedTask; return Task.CompletedTask;
// 本地调试不做幂等 // 本地调试不做幂等
@ -44,7 +44,7 @@ public class CapFilter : SubscribeFilter
throw new BusinessException(ErrorCode, $"检测到重复消费,消费参数：{argumentJsonStr}"); throw new BusinessException(ErrorCode, $"检测到重复消费,消费参数：{argumentJsonStr}");
RedisHelper.Client.Set($"CapExcuteFilter:{hash}", 60 * 10, RedisHelper.Client.Set($"CapExcuteFilter:{hash}", 60 * 10,
TimeSpan.FromHours(1).Seconds); // 1h内不允许一模一样的参数重复消费 TimeSpan.FromMinutes(5).Seconds);
} }
} }