临时提交

src/SJZY.Track.Application.Contract/Services/ITrackPushCacheService.cs

@@ -9,6 +9,14 @@ public interface ITrackPushCacheService
     /// <returns></returns>
     Task<bool> IsPushAsync(int customId);
 
+    /// <summary>
+    /// 判断客户是否需要推送
+    /// </summary>
+    /// <param name="subSystemId"></param>
+    /// <param name="customId"></param>
+    /// <returns></returns>
+    Task<bool> IsPushAsync(int subSystemId, int customId);
+
     /// <summary>
     /// 更新缓存
     /// </summary>

src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs

@@ -99,7 +99,8 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             };
 
             // todo：推送只做新增的，更新和删除的不做先
-            if (!@event.IsPushCompleted && await _trackPushCacheService.IsPushAsync(@event.CustomId))
+            if (!@event.IsPushCompleted &&
+                await _trackPushCacheService.IsPushAsync(@event.SubSystemId, @event.CustomId))
             {
                 //await PushTrack();
             }

src/SJZY.Track.Application/Services/TrackPush/TrackPushCacheService.cs

@@ -32,6 +32,21 @@ public class TrackPushCacheService : ITrackPushCacheService, ITransientDependenc
         return (bool)isPush;
     }
 
+    public async Task<bool> IsPushAsync(int subSystemId, int customId)
+    {
+        var isPush =
+            await RedisHelper.Client.GetAsync<bool?>(RedisKey(customId));
+
+        if (isPush == null)
+        {
+            isPush = await _trackPushConfigQuery.GetFirstAsync(x => x.CustomId == customId,
+                x => x.IsAutoPush);
+            await RedisHelper.Client.SetAsync(RedisKey(customId), isPush);
+        }
+
+        return (bool)isPush;
+    }
+
     public async Task UpdateAsync(int customId, bool isPush)
     {
         await RedisHelper.Client.SetAsync(RedisKey(customId), isPush);