feat: 轨迹映射-新增拉取界面增加字段：触发拉取节点

src/SJZY.Track.Application.Contract/Dtos/TrackPull/TrackPullParamConfigDto.cs

@@ -46,4 +46,9 @@ public class TrackPullParamConfigDto
     /// 轨迹明细数组路径
     /// </summary>
     public string TrackDetailsPath { get; set; } = null!;
+    
+    /// <summary>
+    /// 轨迹内容代码
+    /// </summary>
+    public string? TrackContentCode { get; set; }
 }

src/SJZY.Track.Application.Contract/Events/OrderIdentifier.cs

@@ -7,4 +7,6 @@ public struct OrderIdentifier
     public int OrderType { get; set; }
 
     public int CustomId { get; set; }
+    
+    public bool IsTrigger { get; set; }
 }

src/SJZY.Track.Application.Contract/Events/TrackChangeAfterUpdateOrderEvent.cs

@@ -41,4 +41,9 @@ public class TrackChangeAfterUpdateOrderEvent
     /// 轨迹时区
     /// </summary>
     public float TrackTimeZone { get; set; }
+
+    /// <summary>
+    /// 根据配置规则，标记拉取时需要的订单Id
+    /// </summary>
+    public int[] TriggerPullOrderIds { get; set; } = Array.Empty<int>();
 }

src/SJZY.Track.Application/CAP/EventHandlers/PullChangeBottomLineUpdateOrderEventHandler.cs

@@ -6,6 +6,9 @@ using Volo.Abp.DependencyInjection;
 
 namespace SJZY.Track.Application.CAP.EventHandlers;
 
+/// <summary>
+/// 拉去轨迹后，执行了兜底操作还是失败的标记操作
+/// </summary>
 public class PullChangeBottomLineUpdateOrderEventHandler :ITransientDependency, ICapSubscribe
 {
     private readonly IOrderRepository _orderRepository;
@@ -18,6 +21,6 @@ public class PullChangeBottomLineUpdateOrderEventHandler :ITransientDependency,
     [CapSubscribe(GlobalConst.PullChangeBottomLineUpdateOrderSubscribe)]
     public async Task ConsumerAsync(PullChangeBottomLineUpdateOrderEvent @event)
     {
-        await _orderRepository.UpdateBatchIdsAsync(@event.OrderIds, @event.DeficiencyTagValue);
+        var rows =await _orderRepository.UpdateBatchIdsAsync(@event.OrderIds, @event.DeficiencyTagValue);
     }
 }

src/SJZY.Track.Application/CAP/EventHandlers/TrackChangeAfterUpdateOrderEventHandler.cs

@@ -28,6 +28,7 @@ public class TrackChangeAfterUpdateOrderEventHandler : ITransientDependency, ICa
         if (orders.Count == 0) return;
 
         var updateOrders = new List<OrderEntity>();
+        
         foreach (var order in orders)
         {
             if (order.LatestTrackContent != @event.TrackContent)
@@ -45,6 +46,12 @@ public class TrackChangeAfterUpdateOrderEventHandler : ITransientDependency, ICa
                 order.IsCompleted = @event.IsCompleted;
             }
 
+            // 触发拉取节点
+            if (@event.TriggerPullOrderIds.Contains(order.Id))
+            {
+                order.IsTriggerPull = 1;
+            }
+
             order.LatestTrackContent = @event.TrackContent;
             order.LatestTrackEnContent = @event.TrackEnContent;
             order.LatestTrackPlace = @event.TrackPlace;

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

@@ -2,11 +2,14 @@
 using SJZY.Expand.ABP.Core.Logger;
 using SJZY.Expand.ABP.Core.PublicMethords;
 using SJZY.Track.Application.Contract.Events;
+using SJZY.Track.Application.Contract.Services;
 using SJZY.Track.Domain.Aggregates.OrderAggregate;
 using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
 using SJZY.Track.Domain.Consts;
+using SJZY.Track.Domain.Dtos.Order;
 using SJZY.Track.Domain.Queries;
 using Volo.Abp.DependencyInjection;
+using OrderIdentifier = SJZY.Track.Application.Contract.Events.OrderIdentifier;
 
 namespace SJZY.Track.Application.CAP.EventHandlers;
 
@@ -16,14 +19,16 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
     private readonly IProvideQueries _provideQueries;
     private readonly ITrackDetailsRepository _trackDetailsRepository;
     private readonly ICapPublisher _capPublisher;
+    private readonly ITrackPullCacheService _trackPullCacheService;
 
     public TrackUpsertEventHandler(IOrderRepository orderRepository, ICapPublisher capPublisher,
-        IProvideQueries provideQueries, ITrackDetailsRepository trackDetailsRepository)
+        IProvideQueries provideQueries, ITrackDetailsRepository trackDetailsRepository, ITrackPullCacheService trackPullCacheService)
     {
         _orderRepository = orderRepository;
         _capPublisher = capPublisher;
         _provideQueries = provideQueries;
         _trackDetailsRepository = trackDetailsRepository;
+        _trackPullCacheService = trackPullCacheService;
     }
 
     [CapSubscribe(GlobalConst.TrackUpsertSubscribe, Group = GlobalConst.TrackUpsertSubscribe)]
@@ -100,7 +105,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             }
         }
     }
-
+    
     private async Task HandleTrackAsync(TrackUpsertEvent @event, List<int> canNextOrderIds)
     {
         var content = await _provideQueries.GetTrackContentAsync(@event.SubSystemId, @event.TrackCode);
@@ -114,7 +119,9 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
         var trackContents = await _provideQueries.MatchTrackContentAsync(newOrderIds, @event.TrackCode);
 
         var insertTracks = new List<TrackDetailsIndex>();
+        var triggerPullOrder = new List<int>();
 
+        var providerDic=await GetProviderDic(orderIds);
         foreach (var order in @event.OrderIdentifiers)
         {
             var track = tracks.FirstOrDefault(x => x.OrderId == order.OrderId);
@@ -170,13 +177,24 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             }
 
             canNextOrderIds.Add(order.OrderId);
+            
+            if(!providerDic.TryGetValue(order.OrderId,out var provider))
+                continue;
+            
+            var config =
+                await _trackPullCacheService.GetPullParamWithContentConfigAsync(provider.SubSystemId,
+                    provider.ServiceProviderId);
+            if (config!=null && config.ParamConfig!=null && config.ParamConfig.TrackContentCode == @event.TrackCode)
+            {
+                triggerPullOrder.Add(order.OrderId);
+            }
         }
 
         if (canNextOrderIds.Count == 0) return;
 
         // 批量add to es
         await _trackDetailsRepository.AddManyAsync(insertTracks);
-
+        
         // 触发订单主表更新事件（异步）
         await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
             new TrackChangeAfterUpdateOrderEvent
@@ -188,7 +206,8 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
                 TrackStatusId = content.TrackStatusId,
                 TrackPlace = @event.TrackPlace,
                 TrackTime = @event.TrackTime,
-                TrackTimeZone = @event.TrackTimeZone
+                TrackTimeZone = @event.TrackTimeZone,
+                TriggerPullOrderIds = triggerPullOrder.ToArray()
             });
 
         // 触发轨迹推送事件（异步）
@@ -215,4 +234,17 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
         }
     }
+    
+    /// <summary>
+    /// 获取服务商字典
+    /// </summary>
+    /// <param name="orderIds"></param>
+    /// <returns></returns>
+    private async Task<Dictionary<int, OrderTransportDto>> GetProviderDic(int[] orderIds)
+    {
+        var providerList = await _provideQueries.FindOrderWithServiceProviderAsync(orderIds);
+        return providerList.GroupBy(val => val.OrderId)
+            .ToDictionary(val => val.Key, val => val.First());
+    }
+    
 }

src/SJZY.Track.Domain/Aggregates/OrderAggregate/OrderEntity.cs

@@ -167,7 +167,13 @@ public class OrderEntity : IFullAuditedBasicEntitys, IAggregateRoot
     /// </summary>
     [SugarColumn(ColumnName = "ArrivalProvince")]
     public string? ArrivalProvince { get; set; }
-
+    
+    /// <summary>
+    /// 是否触发拉取，1表示触发
+    /// </summary>
+    [SugarColumn(ColumnName = "IsTriggerPull")]
+    public short? IsTriggerPull { get; set; }
+    
     [SugarColumn(IsIgnore = true)] public List<OrderFlightEntity> OrderFlights { get; set; }
     [SugarColumn(IsIgnore = true)] public List<OrderTemplateEntity> OrderTemplates { get; set; }
 

src/SJZY.Track.Domain/Aggregates/TrackPullAggregate/TrackPushPullParamsConfigEntity.cs

@@ -89,4 +89,10 @@ public class TrackPushPullParamsConfigEntity : IFullAuditedBasicEntitys, IEntity
     /// </summary>
     [SugarColumn(ColumnName = "ExpandFieldsName")]
     public string? ExpandFieldsName { get; set; }
+    
+    /// <summary>
+    /// 轨迹内容代码
+    /// </summary>
+    [SugarColumn(ColumnName = "TrackContentCode")]
+    public string? TrackContentCode { get; set; }
 }

src/SJZY.Track.Domain/Dtos/Order/OrderTransportDto.cs

@@ -0,0 +1,10 @@
+namespace SJZY.Track.Domain.Dtos.Order;
+
+public class OrderTransportDto
+{
+    public int OrderId { get; set; }
+    
+    public int ServiceProviderId { get; set; }
+    
+    public int SubSystemId { get; set; }
+}

src/SJZY.Track.Domain/Dtos/TrackPull/GetTrackPullConfigDetailOutputVO.cs

@@ -78,4 +78,9 @@ public class GetTrackPullConfigDetailOutputVO
     /// 轨迹明细路径
     /// </summary>
     public string TrackDetailsPath { get; set; }
+    
+    /// <summary>
+    /// 轨迹内容代码
+    /// </summary>
+    public string? TrackContentCode { get; set; }
 }

src/SJZY.Track.Domain/Queries/IProvideQueries.cs

@@ -68,4 +68,11 @@ public interface IProvideQueries
         int pageSize = 1000);
 
     Task<TrackContentVO?> GetTrackContentAsync(int subSystemId, string trackCode);
+    
+    /// <summary>
+    /// 查找订单和服务商信息
+    /// </summary>
+    /// <param name="orderIds">订单id</param>
+    /// <returns>订单和服务商信息</returns>
+    Task<List<OrderTransportDto>> FindOrderWithServiceProviderAsync(int[] orderIds);
 }

src/SJZY.Track.Repository/Queries/ProvideQueries.cs

@@ -122,7 +122,7 @@ public class ProvideQueries : ISugarRepository, IProvideQueries,
         return await Context.Queryable<OrderEntity>()
             .RightJoin<OrderTemplateEntity>((a, b) => a.Id == b.OrderId)
             .LeftJoin<VServiceProviderEntity>((a, b, c) => b.ServiceProviderId == c.Id)
-            .Where((a, b) => b.ServiceProviderId == serviceProvider && !a.IsCompleted)
+            .Where((a, b) => b.ServiceProviderId == serviceProvider && !a.IsCompleted && a.IsTriggerPull==1)
             .Select((a, b, c) => new OrderWithServiceProviderVO
             {
                 OrderNo = a.OrderNo,
@@ -136,6 +136,20 @@ public class ProvideQueries : ISugarRepository, IProvideQueries,
             .Take(pageSize)
             .ToListAsync();
     }
+    
+    public async Task<List<OrderTransportDto>> FindOrderWithServiceProviderAsync(int[] orderIds)
+    {
+        return await Context.Queryable<OrderEntity>()
+            .InnerJoin<OrderTemplateEntity>((a, b) => a.Id == b.OrderId)
+            .Where((a, b) => orderIds.Contains( a.Id) && !a.IsCompleted)
+            .Select((a, b) => new OrderTransportDto
+            {
+                OrderId = a.Id,
+                ServiceProviderId = b.ServiceProviderId,
+                SubSystemId = a.SubSystemId
+            })
+            .ToListAsync();
+    }
 
     public async Task<TrackContentVO?> GetTrackContentAsync(int subSystemId, string trackCode)
     {

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

@@ -1,5 +1,6 @@
 using SJZY.Track.Domain;
 using SJZY.Track.Domain.Aggregates.OrderAggregate;
+using SJZY.Track.Domain.Consts;
 using SJZY.Track.Domain.Dtos.Order;
 
 namespace SJZY.Track.Repository.Repositories;
@@ -21,7 +22,9 @@ public class OrderRepository : BasicRepository<OrderEntity>, IOrderRepository, I
 
     public Task<int> UpdateBatchIdsAsync(List<int> ids, int newValue)
     {
-        return Context.Ado.ExecuteCommandAsync("UPDATE `t_order` SET `DeficiencyTag` = @newValue WHERE `Id` IN @ids", new { ids, newValue });
+        var idsString = string.Join(",", ids);
+        return Context.Ado.ExecuteCommandAsync(
+            $"UPDATE `t_order` SET `DeficiencyTag` = @newValue ,UpdateTime= current_timestamp WHERE `Id` IN ({idsString})", new { newValue });
     }
 
     public async Task UpdateOrderAsync(OrderEntity order)

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

@@ -72,7 +72,8 @@ public class TrackPullConfigRepository : BasicRepository<TrackPullConfigEntity>,
             {
                 Id = trackPull.Id,
                 SubSystem = system.CnName,
-                ServiceProvider = service.Name
+                ServiceProvider = service.Name,
+                TrackContentCode = paramsConfig.TrackContentCode
             }, true)
             .SingleAsync();
     }