From 2e551b21d7c55beb96f1b86d3fc21dc3ace005ae Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Mon, 22 Apr 2024 22:14:35 +0800
Subject: [PATCH] =?UTF-8?q?change=EF=BC=9A=E6=8E=A8=E9=80=81=E9=87=8D?=
 =?UTF-8?q?=E8=AF=95=E9=87=8D=E5=85=A5=E9=98=9F=E5=88=97+=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../EventHandlers/TrackPushEventHandler.cs           | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
index 55d0ed5e..ceed798d 100644
--- a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
+++ b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
@@ -105,22 +105,20 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
                 throw new ArgumentOutOfRangeException();
         }
 
+        // 往es 写推送日志
+        await _trackPushRecordsRepository.AddAsync(log);
+
         if (!log.IsSuccess)
         {
+            // 重试过程中不会去更新订单主表
             if (@event.RetryNum < 3)
             {
                 @event.RetryNum++;
-                // 1, 2, 4min
-                await _capPublisher.PublishDelayAsync(
-                    TimeSpan.FromSeconds((1 << @event.RetryNum - 1) * RandomHelper.GetRandom(30, 60)),
-                    GlobalConst.TrackPushSubscribe, @event);
+                await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, @event);
                 return;
             }
         }
 
-        // 往es 写推送日志
-        await _trackPushRecordsRepository.AddAsync(log);
-
         // 同步去更新订单主表
         await TrackPushAfterUpdateOrderAsync(new TrackPushAfterUpdateOrderDto
         {