修改轨迹推送

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

@@ -1,8 +1,10 @@
 using Microsoft.Extensions.Localization;
+using SJZY.Expand.ABP.Core;
 using SJZY.Expand.ABP.Core.Localization;
 using SJZY.Expand.ABP.Core.PublicMethords;
 using SJZY.Track.Application.Contract.Dtos.TrackPush;
 using SJZY.Track.Application.Localization;
+using SJZY.Track.Domain.Aggregates.DemoAggregate;
 using SJZY.Track.Domain.Aggregates.TrackPullAggregate;
 using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
 using SJZY.Track.Domain.Aggregates.TrackTemplateAggregate;
@@ -66,7 +68,7 @@ public class TrackPushService : ApplicationService, ITransientDependency
     /// <param name="id"></param>
     /// <returns></returns>
     [HttpGet("GetDetail")]
-    public async Task<GetTrackPushConfigDetailOutputVO?> GetDetailAsync(int id)
+    public async Task<GetTrackPushConfigDetailOutputVO> GetDetailAsync(int id)
     {
         var res = await _trackPushConfigRepository.GetDetailAsync(id);
         if (res is null) return null;
@@ -126,6 +128,8 @@ public class TrackPushService : ApplicationService, ITransientDependency
                         trackPushParamsEntity.PullOrPushConfigId = id;
                         await _trackPullConfigRepository.InsertParamsAsync(trackPushParamsEntity);
 
+                        if (input.IsAutoPush) await RedisHelper.Client.SAddAsync(GlobalConst.AutoPushRosterRedisKey, input.CustomId);
+
                         ts.Complete();
                     }
                 }
@@ -135,6 +139,8 @@ public class TrackPushService : ApplicationService, ITransientDependency
                 {
                     var oldTrackPushEntity = await _trackPushConfigRepository.GetFirstAsync(x => x.Id == input.Id) ?? throw new BusinessException(message: _stringLocalizer["NotFindData"]);
 
+                    int oldCustomId = oldTrackPushEntity.CustomId;
+
                     var oldTrackPushParamsEntity =
                         await _trackPullConfigRepository.GetParamsSingleAsync(x =>
                             x.PullOrPushConfigId == input.Id && x.IsPush);
@@ -147,22 +153,30 @@ public class TrackPushService : ApplicationService, ITransientDependency
                         await _trackPushConfigRepository.UpdateAsync(oldTrackPushEntity);
                         await _trackPullConfigRepository.UpdateParamsAsync(oldTrackPushParamsEntity);
 
+                        await RedisHelper.Client.SRemAsync(GlobalConst.AutoPushRosterRedisKey, oldCustomId);
+                        if (input.IsAutoPush) await RedisHelper.Client.SAddAsync(GlobalConst.AutoPushRosterRedisKey, input.CustomId);
+
                         ts.Complete();
                     }
                 }
                 break;
 
             case OptionTypeNoNull.删除:
-                using (var ts = TransactionScopeHelper.Create())
                 {
-                    await _trackPushConfigRepository.SoftDeleteAsync(x => x.Id == input.Id);
+                    var oldTrackPushEntity = await _trackPushConfigRepository.GetFirstAsync(x => x.Id == input.Id) ?? throw new BusinessException(message: _stringLocalizer["NotFindData"]);
-                    await _trackPullConfigRepository.SoftDeleteParamsAsync(x =>
-                        x.PullOrPushConfigId == input.Id && x.IsPush);
-                    await _trackPushConfigRepository.SoftDeleteContentAsync(x => x.TrackPushConfigId == input.Id);
 
-                    ts.Complete();
+                    using (var ts = TransactionScopeHelper.Create())
+                    {
+                        await _trackPushConfigRepository.SoftDeleteAsync(x => x.Id == input.Id);
+                        await _trackPullConfigRepository.SoftDeleteParamsAsync(x =>
+                            x.PullOrPushConfigId == input.Id && x.IsPush);
+                        await _trackPushConfigRepository.SoftDeleteContentAsync(x => x.TrackPushConfigId == input.Id);
+
+                        await RedisHelper.Client.SRemAsync(GlobalConst.AutoPushRosterRedisKey, oldTrackPushEntity.CustomId);
+
+                        ts.Complete();
+                    }
                 }
-
                 break;
 
             default:

src/SJZY.Track.Domain/Dtos/TrackPush/GetTrackPushConfigDetailOutputVO.cs

@@ -91,6 +91,11 @@ public class GetTrackPushConfigDetailOutputVO
     /// </summary>
     public string TrackTemplateId { get; set; }
 
+    /// <summary>
+    /// 轨迹模板ids
+    /// </summary>
+    public List<int> TrackTemplateIds { get; set; }
+
     /// <summary>
     /// 推送轨迹发生时间
     /// </summary>

src/SJZY.Track.Domain/GlobalConst.cs

@@ -6,9 +6,14 @@ public class GlobalConst
     /// 轨迹明细es索引名称
     /// </summary>
     public const string TrackIndex = "sjzy_track_details";
-    
+
     /// <summary>
     /// 轨迹新增/更新cap订阅名称
     /// </summary>
     public const string TrackUpsertSubscribe = "SJZY.Track.Upsert";
+
+    /// <summary>
+    /// 自动推送名单RedisKey
+    /// </summary>
+    public const string AutoPushRosterRedisKey = "AutoPushRoster";
 }

src/SJZY.Track.Repository/Repositories/TrackPushConfigRepository.cs

@@ -68,6 +68,7 @@ public class TrackPushConfigRepository : BasicRepository<TrackPushConfigEntity>,
                 CustomName = externalSubject.Abbreviation,
                 ServiceProvider = service.Name,
             }, true)
+            .Mapper(x => { x.TrackTemplateIds = x.TrackTemplateId.Split(',').Select(int.Parse).ToList(); })
             .SingleAsync();
     }