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

临时提交

Browse Source
This commit is contained in:
李鹏军 2024-03-01 17:49:20 +08:00
parent 3921f00e4b
commit 545efbeaf3
22 changed files with 284 additions and 127 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Application.Contract/Dtos/ProvideServices/TrackUpsertEvent.cs
View File

@ -1,6 +0,0 @@
namespace SJZY.Track.Application.Contract.Dtos.ProvideServices;
public class TrackUpsertEvent
{
public int Order { get; set; }
}

4
src/SJZY.Track.Application.Contract/Dtos/ProvideServices/UpsertTrackInput.cs
View File

@ -5,12 +5,12 @@ public class UpsertTrackInput : OrderNoInfo
/// <summary>
/// 轨迹内容代码
/// </summary>
public string TrackCode { get; set; }
public string TrackCode { get; set; } = null!;
/// <summary>
/// 轨迹发生地
/// </summary>
public string TrackPlace { get; set; }
public string TrackPlace { get; set; } = null!;
/// <summary>
/// 轨迹发生时间

19
src/SJZY.Track.Application.Contract/Events/TrackUpsertEvent.cs
View File

@ -1,6 +1,21 @@
namespace SJZY.Track.Application.Contract.Events;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
public class TrackUpsertEvent
namespace SJZY.Track.Application.Contract.Events;
public class TrackUpsertEvent : UpsertTrackInput
{
/// <summary>
/// 订单id
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 子系统id
/// </summary>
public int SubSystemId { get; set; }
/// <summary>
/// 上游子系统id
/// </summary>
public int UpSubSystemId { get; set; }
}

13
src/SJZY.Track.Application/AutoMapper/TrackAutoMapperProfile.cs Normal file
View File

@ -0,0 +1,13 @@
using AutoMapper;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Events;
namespace SJZY.Track.Application.AutoMapper;
public class TrackAutoMapperProfile:Profile
{
public TrackAutoMapperProfile()
{
CreateMap<UpsertTrackInput, TrackUpsertEvent>(MemberList.None);
}
}

108
src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs Normal file
View File

@ -0,0 +1,108 @@
using DotNetCore.CAP;
using SJZY.Expand.ABP.Core.PublicMethords;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Queries;
using SJZY.UserCenter.HttpApi.Services;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.EventHandlers;
public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
{
private readonly IOrderRepository _orderRepository;
private readonly ITrackQueries _trackQueries;
private readonly ITrackDetailsRepository _trackDetailsRepository;
private readonly ICapPublisher _capPublisher;
public TrackUpsertEventHandler(IOrderRepository orderRepository, ICapPublisher capPublisher,
ITrackQueries trackQueries, ITrackDetailsRepository trackDetailsRepository)
{
_orderRepository = orderRepository;
_capPublisher = capPublisher;
_trackQueries = trackQueries;
_trackDetailsRepository = trackDetailsRepository;
}
[NonAction]
[CapSubscribe(GlobalConst.TrackUpsertSubscribe)]
public async Task ConsumerAsync(TrackUpsertEvent @event)
{
// 不同子系统需要做内容映射
if (@event.UpSubSystemId != @event.SubSystemId)
{
var mapCode = await _trackQueries.MapTrackContentCodeAsync(@event.UpSubSystemId, @event.SubSystemId, @event.TrackCode);
if (mapCode == default)
{
throw new BusinessException(message: "订单跨子系统，未配置内容映射，请联系管理员");
}
@event.TrackCode = mapCode;
}
await UpsertTrackAsync(@event);
}
internal async Task UpsertTrackAsync(TrackUpsertEvent @event)
{
// 不存在则新增轨迹，存在则更新
var track = await _trackDetailsRepository.GetFirstOrDefaultAsync(@event.OrderId, @event.TrackCode);
var isPush = false; // 推送只做新增的，更新和删除的不做先
if (track == default)
{
// 根据轨迹code在订单模板内容中寻找匹配的
var trackContent = await _trackQueries.MatchTrackContentAsync(@event.OrderId, @event.TrackCode);
if (trackContent == default)
{
throw new BusinessException(message: $"订单：{@event.OrderNo} 所绑定的模板，没有一条内容可以匹配轨迹代码：{@event.TrackCode}");
}
track = new TrackDetailsIndex
{
OrderId = @event.OrderId,
OrderNo = @event.OrderNo,
OrderType = @event.OrderType,
TrackStatus = trackContent.Status,
TrackCode = @event.TrackCode,
TrackContent = trackContent.Content,
TrackEnContent = trackContent.EnContent,
TrackPlace = @event.TrackPlace,
TrackTime = @event.TrackTime,
TraceTimeZone = @event.TraceTimeZone,
CreateUserId = CurrentUserRequest.CurrentUser.UserId,
CreateTime = DateTime.Now
};
isPush = true;
}
else
{
track.TrackPlace = @event.TrackPlace;
track.TrackTime = @event.TrackTime;
track.TraceTimeZone = @event.TraceTimeZone;
track.UpdateUserId = CurrentUserRequest.CurrentUser.UserId;
track.UpdateTime = DateTime.Now;
}
await _trackDetailsRepository.UpsertAsync(track);
// 根据订单关联关系异步向下刷
var linkedOrders = await _orderRepository.GetLinkedOrdersAsync(@event.OrderId);
foreach (var linkedOrder in linkedOrders)
{
var nextEvent = @event.DeepCopy();
nextEvent.OrderId = linkedOrder.OrderId;
nextEvent.SubSystemId = linkedOrder.SubSystemId;
nextEvent.UpSubSystemId = @event.SubSystemId;
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, nextEvent);
}
if (isPush)
{
//await PushTrack();
}
}
}

9
src/SJZY.Track.Application/Services/ProvideServices/TrackCustomer.cs
View File

@ -1,9 +0,0 @@
using DotNetCore.CAP;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.Services.ProvideServices;
public class TrackCustomer : ITransientDependency, ICapSubscribe
{
public const string CapSubscribe = "SJZY.Track.Upsert";
}

10
src/SJZY.Track.Application/Services/ProvideServices/TrackPushService.cs Normal file
View File

@ -0,0 +1,10 @@
namespace SJZY.Track.Application.Services.ProvideServices;
/// <summary>
/// 轨迹推送服务
/// </summary>
[ApiExplorerSettings(GroupName = "提供接口")]
public class TrackPushService: ApplicationService
{
}

79
src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs
View File

@ -1,9 +1,7 @@
using DotNetCore.CAP;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Application.EventHandlers;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Queries;
using SJZY.UserCenter.HttpApi.Services;
namespace SJZY.Track.Application.Services.ProvideServices;
@ -14,17 +12,12 @@ namespace SJZY.Track.Application.Services.ProvideServices;
public class TrackService : ApplicationService
{
private readonly IOrderRepository _orderRepository;
private readonly ITrackDetailsRepository _trackDetailsRepository;
private readonly ITrackQueries _trackQueries;
private readonly ICapPublisher _capPublisher;
private readonly TrackUpsertEventHandler _trackUpsertEventHandler;
public TrackService(ITrackQueries trackQueries, IOrderRepository orderRepository,
ITrackDetailsRepository trackDetailsRepository, ICapPublisher capPublisher)
public TrackService(IOrderRepository orderRepository, TrackUpsertEventHandler trackUpsertEventHandler)
{
_trackQueries = trackQueries;
_orderRepository = orderRepository;
_trackDetailsRepository = trackDetailsRepository;
_capPublisher = capPublisher;
_trackUpsertEventHandler = trackUpsertEventHandler;
}
/// <summary>
@ -36,59 +29,21 @@ public class TrackService : ApplicationService
[HttpPost("Track/Upsert")]
public async Task<bool> UpsertTrackAsync(UpsertTrackInput input)
{
var orderId = await _orderRepository.GetFirstAsync(x =>
x.OrderType == input.OrderType && x.OrderNo == input.OrderNo, x => x.Id);
if (orderId == default)
var order = await _orderRepository.GetFirstAsync(x =>
x.OrderType == input.OrderType && x.OrderNo == input.OrderNo, x => new
{
x.Id, x.SubSystemId, x.IsPushCompleted
});
if (order == default)
{
throw new BusinessException(message: $"订单：{input.OrderNo}不存在");
}
// 不存在则新增轨迹，存在则更新
var track = await _trackDetailsRepository.GetFirstOrDefaultAsync(orderId, input.TrackCode);
if (track == default)
{
var trackContent = await _trackQueries.MatchTrackContentAsync(orderId, input.TrackCode);
if (trackContent == default)
{
throw new BusinessException(message: $"订单：{input.OrderNo} 所绑定的模板，没有一条内容可以匹配轨迹代码：{input.TrackCode}");
}
track = new TrackDetailsIndex
{
OrderId = orderId,
OrderNo = input.OrderNo,
OrderType = input.OrderType,
TrackStatus = trackContent.Status,
TrackCode = input.TrackCode,
TrackContent = trackContent.Content,
TrackEnContent = trackContent.EnContent,
TrackPlace = input.TrackPlace,
TrackTime = input.TrackTime,
TraceTimeZone = input.TraceTimeZone,
CreateUserId = CurrentUserRequest.CurrentUser.UserId,
CreateTime = DateTime.Now
};
await _trackDetailsRepository.CreateAsync(track);
}
else
{
track.UpdateUserId = CurrentUserRequest.CurrentUser.UserId;
track.UpdateTime = DateTime.Now;
track.TrackPlace = input.TrackPlace;
track.TrackTime = input.TrackTime;
track.TraceTimeZone = input.TraceTimeZone;
await _trackDetailsRepository.UpdateAsync(track);
}
// 根据订单关联关系向下刷，不同子系统还需要做内容映射
var linkedOrderIds = await _orderRepository.GetLinkedOrderIdsAsync(orderId);
if (linkedOrderIds.Count > 0)
{
await _capPublisher.PublishAsync(TrackCustomer.CapSubscribe, new TrackUpsertEvent { });
}
// 推送
// 新增/更新轨迹
var @event = ObjectMapper.Map<UpsertTrackInput, TrackUpsertEvent>(input);
@event.OrderId = order.Id;
@event.SubSystemId = order.SubSystemId;
await _trackUpsertEventHandler.UpsertTrackAsync(@event);
return true;
}
}

4
src/SJZY.Track.Domain/Aggregates/OrderAggregate/IOrderRepository.cs
View File

@ -38,11 +38,11 @@ public interface IOrderRepository : IBasicRepository<OrderEntity>
#region 订单关联
/// <summary>
/// 根据订单id，获取关联的订单id集合
/// 根据订单id，获取关联的订单集合
/// </summary>
/// <param name="orderId"></param>
/// <returns></returns>
Task<List<int>> GetLinkedOrderIdsAsync(int orderId);
Task<List<LinkedOrderVO>> GetLinkedOrdersAsync(int orderId);
/// <summary>
/// 关联订单

6
src/SJZY.Track.Domain/Aggregates/OrderAggregate/OrderEntity.cs
View File

@ -42,6 +42,12 @@ public class OrderEntity : IFullAuditedBasicEntitys, IAggregateRoot
[SugarColumn(ColumnName = "IsCompleted")]
public bool IsCompleted { get; set; }
/// <summary>
/// 订单是否推送完成（异步维护）
/// </summary>
[SugarColumn(ColumnName = "IsPushCompleted")]
public bool IsPushCompleted { get; set; }
/// <summary>
/// 最新轨迹内容（异步维护）
/// </summary>

30
src/SJZY.Track.Domain/Aggregates/TrackContentAggregate/TrackContentMapEntity.cs
View File

@ -13,14 +13,38 @@ public class TrackContentMapEntity : IFullAuditedBasicEntitys, IEntity
public int Id { get; set; }
/// <summary>
/// 映射轨迹内容id
/// 源子系统id
/// </summary>
[SugarColumn(ColumnName = "MapTrackContentId")]
public int MapTrackContentId { get; set; }
[SugarColumn(ColumnName = "SubSystemId")]
public int SubSystemId { get; set; }
/// <summary>
/// 源轨迹内容id
/// </summary>
[SugarColumn(ColumnName = "TrackContentId")]
public int TrackContentId { get; set; }
/// <summary>
/// 源轨迹内容code
/// </summary>
[SugarColumn(ColumnName = "TrackContentCode")]
public string TrackContentCode { get; set; } = null!;
/// <summary>
/// 映射子系统id
/// </summary>
[SugarColumn(ColumnName = "MapSubSystemId")]
public int MapSubSystemId { get; set; }
/// <summary>
/// 映射轨迹内容id
/// </summary>
[SugarColumn(ColumnName = "MapTrackContentId")]
public int MapTrackContentId { get; set; }
/// <summary>
/// 映射轨迹内容code
/// </summary>
[SugarColumn(ColumnName = "MapTrackContentCode")]
public string MapTrackContentCode { get; set; } = null!;
}

4
src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsRepository.cs
View File

@ -6,9 +6,7 @@ public interface ITrackDetailsRepository
{
Task<TrackDetailsIndex?> GetFirstOrDefaultAsync(int orderId, string inputTrackCode);
Task UpdateAsync(TrackDetailsIndex index);
Task CreateAsync(TrackDetailsIndex index);
Task UpsertAsync(TrackDetailsIndex index);
Task<List<TrackDetailsIndex>> GetListAsync(int orderType, List<string> orderNos);

22
src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs
View File

@ -3,11 +3,9 @@ using SJZY.Expand.ElasticSearch;
namespace SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
[ElasticsearchType(RelationName = IndexName)]
[ElasticsearchType(RelationName = GlobalConst.TrackIndex)]
public class TrackDetailsIndex : IdBaseIndex
{
public const string IndexName = "sjzy_track_details";
/// <summary>
/// 订单Id
/// </summary>
@ -16,7 +14,7 @@ public class TrackDetailsIndex : IdBaseIndex
/// <summary>
/// 订单号
/// </summary>
public string OrderNo { get; set; }
public string OrderNo { get; set; } = null!;
/// <summary>
/// 订单类型（主数据枚举TrackOrderType）
@ -26,42 +24,42 @@ public class TrackDetailsIndex : IdBaseIndex
/// <summary>
/// 轨迹状态
/// </summary>
public string TrackStatus { get; set; }
public string TrackStatus { get; set; } = null!;
/// <summary>
/// 原轨迹状态
/// </summary>
public string OriginTrackStatus { get; set; }
public string? OriginTrackStatus { get; set; }
/// <summary>
/// 轨迹内容代码
/// </summary>
public string TrackCode { get; set; }
public string TrackCode { get; set; } = null!;
/// <summary>
/// 轨迹内容
/// </summary>
public string TrackContent { get; set; }
public string TrackContent { get; set; } = null!;
/// <summary>
/// 原轨迹内容
/// </summary>
public string OriginTrackContent { get; set; }
public string? OriginTrackContent { get; set; }
/// <summary>
/// 原轨迹报文
/// </summary>
public string OriginTrackData { get; set; }
public string? OriginTrackData { get; set; }
/// <summary>
/// 轨迹内容英文
/// </summary>
public string TrackEnContent { get; set; }
public string TrackEnContent { get; set; } = null!;
/// <summary>
/// 轨迹发生地
/// </summary>
public string TrackPlace { get; set; }
public string? TrackPlace { get; set; }
/// <summary>
/// 轨迹发生时间

14
src/SJZY.Track.Domain/Dtos/Order/LinkedOrderVO.cs Normal file
View File

@ -0,0 +1,14 @@
namespace SJZY.Track.Domain.Dtos.Order;
public class LinkedOrderVO
{
/// <summary>
/// 关联订单id
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 子系统id
/// </summary>
public int SubSystemId { get; set; }
}

6
src/SJZY.Track.Domain/Dtos/TrackDetails/MatchTrackContentDto.cs
View File

@ -5,15 +5,15 @@ public class MatchTrackContentDto
/// <summary>
/// 轨迹内容
/// </summary>
public string Content { get; set; }
public string Content { get; set; } = null!;
/// <summary>
/// 轨迹内容英文
/// </summary>
public string EnContent { get; set; }
public string EnContent { get; set; } = null!;
/// <summary>
/// 轨迹状态
/// </summary>
public string Status { get; set; }
public string Status { get; set; } = null!;
}

14
src/SJZY.Track.Domain/GlobalConst.cs Normal file
View File

@ -0,0 +1,14 @@
namespace SJZY.Track.Domain;
public class GlobalConst
{
/// <summary>
/// 轨迹明细es索引名称
/// </summary>
public const string TrackIndex = "sjzy_track_details";
/// <summary>
/// 轨迹新增/更新cap订阅名称
/// </summary>
public const string TrackUpsertSubscribe = "SJZY.Track.Upsert";
}

9
src/SJZY.Track.Domain/Queries/ITrackQueries.cs
View File

@ -31,4 +31,13 @@ public interface ITrackQueries
/// <param name="code">轨迹代码</param>
/// <returns></returns>
Task<MatchTrackContentDto?> MatchTrackContentAsync(int orderId, string code);
/// <summary>
/// 根据子系统内容映射，得到映射后的轨迹code
/// </summary>
/// <param name="upSubSystemId"></param>
/// <param name="subSystemId"></param>
/// <param name="trackCode"></param>
/// <returns></returns>
Task<string?> MapTrackContentCodeAsync(int upSubSystemId, int subSystemId, string trackCode);
}

9
src/SJZY.Track.Repository/Queries/TrackQueries.cs
View File

@ -75,4 +75,13 @@ public class TrackQueries : ISugarRepository, ITrackQueries,
})
.FirstAsync();
}
public async Task<string?> MapTrackContentCodeAsync(int upSubSystemId, int subSystemId, string trackCode)
{
return await Context.Queryable<TrackContentMapEntity>()
.Where(x => x.SubSystemId == upSubSystemId && x.MapSubSystemId == subSystemId &&
x.TrackContentCode == trackCode)
.Select(x => x.MapTrackContentCode)
.FirstAsync();
}
}

8
src/SJZY.Track.Repository/Repositories/OrderRepository.cs
View File

@ -53,12 +53,16 @@ public class OrderRepository : BasicRepository<OrderEntity>, IOrderRepository, I
#region 订单关联
public async Task<List<int>> GetLinkedOrderIdsAsync(int orderId)
public async Task<List<LinkedOrderVO>> GetLinkedOrdersAsync(int orderId)
{
return await Context.Queryable<OrderEntity>()
.LeftJoin<OrderLinkEntity>((a, b) => a.Id == b.OrderId)
.Where(a => a.Id == orderId)
.Select((a, b) => b.LinkOrderId)
.Select((a, b) => new LinkedOrderVO
{
OrderId = b.LinkOrderId,
SubSystemId = a.SubSystemId
})
.ToListAsync();
}

15
src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
View File

@ -1,5 +1,6 @@
using Nest;
using SJZY.Expand.ElasticSearch.Services;
using SJZY.Track.Domain;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Dtos.TrackDetails;
@ -8,7 +9,7 @@ namespace SJZY.Track.Repository.Repositories;
internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetailsIndex>, ITrackDetailsRepository,
ITransientDependency
{
public string IndexName => $"{TrackDetailsIndex.IndexName}-{DateTime.Now:yyyy.MM.dd}";
public string IndexName => $"{GlobalConst.TrackIndex}-{DateTime.Now:yyyy.MM.dd}";
public TrackDetailsRepository(ConnectionFactory connectionFactory) : base(connectionFactory)
{
@ -17,7 +18,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
public async Task<TrackDetailsIndex?> GetFirstOrDefaultAsync(int orderId, string trackCode)
{
var r = await Context.SearchAsync<TrackDetailsIndex>(s => s
.Index($"{TrackDetailsIndex.IndexName}-{DateTime.Now:yyyy.MM.dd}")
.Index(IndexName)
.Query(q =>
q.Term(t => t.Field(f => f.OrderId).Value(orderId))
&& q.Term(t => t.Field(f => f.TrackCode).Value(trackCode))
@ -32,24 +33,18 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
return default;
}
public async Task UpdateAsync(TrackDetailsIndex index)
public async Task UpsertAsync(TrackDetailsIndex index)
{
var response = await Context.UpdateAsync<TrackDetailsIndex>(index.Id, u => u
.Index(IndexName)
.Doc(index)
.DocAsUpsert()
//.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
);
if (!response.IsValid)
throw new Exception($"数据修改失败，原因：{response.DebugInformation}");
}
public async Task CreateAsync(TrackDetailsIndex index)
{
var response = await Context.IndexAsync(index, request => request.Index(IndexName));
if (!response.IsValid)
throw new Exception($"数据添加失败，原因：{response.DebugInformation}");
}
public async Task<List<TrackDetailsIndex>> GetListAsync(int orderType, List<string> orderNos)
{
if (orderNos.Count < 1) return new List<TrackDetailsIndex>();