This commit is contained in:
李鹏军 2024-03-18 09:44:42 +08:00
parent df509216b3
commit f39cd3421c
34 changed files with 766 additions and 257 deletions

View File

@ -15,6 +15,16 @@ public class TrackPushConfigDto
public class TrackPushContentConfigDto
{
/// <summary>
/// 是否自动推送
/// </summary>
public bool IsAutoPush { get; set; }
/// <summary>
/// 是否支持更新
/// </summary>
public bool IsCanUpdate { get; set; }
/// <summary>
/// 服务商code
/// </summary>

View File

@ -0,0 +1,32 @@
namespace SJZY.Track.Application.Contract.Dtos.TrackPull;
public class TrackRefreshAttach
{
public TrackRefreshAttach(int serviceProviderId, string serviceProviderCode, int subSystemId, int orderType)
{
ServiceProviderId = serviceProviderId;
ServiceProviderCode = serviceProviderCode;
SubSystemId = subSystemId;
OrderType = orderType;
}
/// <summary>
/// 服务商id
/// </summary>
public int ServiceProviderId { get; set; }
/// <summary>
/// 服务商code
/// </summary>
public string ServiceProviderCode { get; set; }
/// <summary>
/// 订单类型(主数据枚举TrackOrderType)
/// </summary>
public int OrderType { get; set; }
/// <summary>
/// 子系统id
/// </summary>
public int SubSystemId { get; set; }
}

View File

@ -1,16 +0,0 @@
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
namespace SJZY.Track.Application.Contract.Dtos.TrackPull;
public class TrackRefreshDto : OrderNoInfo
{
/// <summary>
/// 服务商id
/// </summary>
public int ServiceProviderId { get; set; }
/// <summary>
/// 子系统id
/// </summary>
public int SubSystemId { get; set; }
}

View File

@ -0,0 +1,24 @@
namespace SJZY.Track.Application.Contract.Events;
public class TrackPushAfterUpdateOrderEvent
{
/// <summary>
/// 订单Id
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 轨迹内容id
/// </summary>
public int TrackContentId { get; set; }
/// <summary>
/// 是否成功
/// </summary>
public bool IsSuccess { get; set; }
/// <summary>
/// 最新描述
/// </summary>
public string? Message { get; set; }
}

View File

@ -0,0 +1,74 @@
namespace SJZY.Track.Application.Contract.Events;
public class TrackPushEvent
{
/// <summary>
/// 操作类型
/// </summary>
public OptionType OptionType { get; set; } = OptionType.新增;
/// <summary>
/// 服务商code
/// </summary>
public string ServiceProviderCode { get; set; } = null!;
/// <summary>
/// 订单id
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 订单号
/// </summary>
public string OrderNo { get; set; } = null!;
/// <summary>
/// 轨迹内容id
/// </summary>
public int TrackContentId { get; set; }
/// <summary>
/// 轨迹发生地
/// </summary>
public string TrackPlace { get; set; } = null!;
/// <summary>
/// 轨迹发生时间
/// </summary>
public DateTime TrackTime { get; set; }
/// <summary>
/// 轨迹发生时区
/// </summary>
public float TrackTimeZone { get; set; }
/// <summary>
/// 轨迹代码参数值
/// </summary>
public string? TrackContentCodeValue { get; set; }
/// <summary>
/// 轨迹内容参数值
/// </summary>
public string? TrackContentValue { get; set; }
/// <summary>
/// 轨迹内容英文参数值
/// </summary>
public string? TrackEnContentValue { get; set; }
/// <summary>
/// 轨迹状态参数值
/// </summary>
public string? TrackStatusValue { get; set; }
/// <summary>
/// 扩展字段参数值
/// </summary>
public string? ExpandFieldsValue { get; set; }
/// <summary>
/// 推送人
/// </summary>
public string? PushMan { get; set; }
}

View File

@ -1,6 +1,6 @@
namespace SJZY.Track.Application.Contract.Events;
public class UpdateOrderTrackEvent
public class TrackUpsertAfterUpdateOrderEvent
{
/// <summary>
/// 订单Id

View File

@ -9,6 +9,11 @@ public class TrackUpsertEvent : UpsertTrackInput
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 订单是否完成
/// </summary>
public bool IsCompleted { get; set; }
/// <summary>
/// 客户id
/// </summary>

View File

@ -2,6 +2,7 @@
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Consts;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.EventHandlers;

View File

@ -3,6 +3,7 @@ using SJZY.Expand.ABP.Core.Logger;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Consts;
using SJZY.Track.Domain.Queries;
using Volo.Abp.DependencyInjection;
@ -63,12 +64,12 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
{
var track = await _trackDetailsRepository.GetLatestAsync(@event.OrderId);
var updateOrderEvent = track == default
? new UpdateOrderTrackEvent
? new TrackUpsertAfterUpdateOrderEvent
{
OrderId = @event.OrderId,
IsDelete = true
}
: new UpdateOrderTrackEvent
: new TrackUpsertAfterUpdateOrderEvent
{
OrderId = @event.OrderId,
IsCompleted = track.IsCompleted,
@ -79,7 +80,7 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
TrackTimeZone = track.TrackTimeZone,
IsDelete = true
};
await _capPublisher.PublishAsync(GlobalConst.UpdateOrderTrackSubscribe, updateOrderEvent);
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertAfterUpdateOrderSubscribe, updateOrderEvent);
}
// 根据订单关联关系异步向下刷

View File

@ -0,0 +1,36 @@
using DotNetCore.CAP;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Consts;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.EventHandlers;
public class TrackPushAfterUpdateOrderEventHandler : ITransientDependency, ICapSubscribe
{
private readonly IOrderRepository _orderRepository;
public TrackPushAfterUpdateOrderEventHandler(IOrderRepository orderRepository)
{
_orderRepository = orderRepository;
}
[CapSubscribe(GlobalConst.TrackPushAfterUpdateOrderSubscribe)]
public async Task ConsumerAsync(TrackPushAfterUpdateOrderEvent @event)
{
var order = await _orderRepository.GetFirstAsync(x => x.Id == @event.OrderId);
if (order == default) return;
// 异常:最近一条推送是失败
// 预警:添加一条推送距离现在超过12h
// if (!@event.IsSuccess)
// {
// order.QuestionType = TrackPushProblemType.Error;
// }
await _orderRepository.UpdateColumnAsync(order, x => new
{
x.LatestPushTrackContentId, x.QuestionType
});
}
}

View File

@ -0,0 +1,123 @@
using DotNetCore.CAP;
using SJZY.InterfaceRelay.Application.Contracts;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
using SJZY.Track.Domain.Consts;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Http.Client.DynamicProxying;
namespace SJZY.Track.Application.EventHandlers;
public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
{
private readonly IHttpClientProxy<IInterfaceForwardServiceV2> _httpClientProxy;
private readonly ITrackPushRecordsRepository _trackPushRecordsRepository;
private readonly ICapPublisher _capPublisher;
public TrackPushEventHandler(IHttpClientProxy<IInterfaceForwardServiceV2> httpClientProxy,
ITrackPushRecordsRepository trackPushRecordsRepository, ICapPublisher capPublisher)
{
_httpClientProxy = httpClientProxy;
_trackPushRecordsRepository = trackPushRecordsRepository;
_capPublisher = capPublisher;
}
[CapSubscribe(GlobalConst.TrackPushSubscribe)]
public async Task ConsumerAsync(TrackPushEvent @event)
{
switch (@event.OptionType)
{
case OptionType.无:
break;
case OptionType.新增:
await PushAddAsync(@event);
break;
case OptionType.删除:
break;
case OptionType.修改:
await PushUpdateAsync(@event);
break;
default:
throw new ArgumentOutOfRangeException();
}
}
private async Task PushAddAsync(TrackPushEvent @event)
{
var data = new
{
orderNo = @event.OrderNo,
data = new[]
{
new
{
// 推真实的发生地和发生时间(时间是计算后的)
location = @event.TrackPlace,
date = @event.TrackTime,
timeZone = @event.TrackTimeZone,
description = @event.TrackEnContentValue,
description_cn = @event.TrackContentValue,
code = @event.TrackContentCodeValue,
status = @event.TrackStatusValue,
extra = @event.ExpandFieldsValue
}
}
};
var res = await _httpClientProxy.Service.ForwardWithSubscribeAsync(InterfaceRelayConst.PushTrackInterfaceCode,
@event.ServiceProviderCode, data);
var isSuccess = res.Code == InterfaceRelayConst.SuccessCode;
// 写推送日志
await _trackPushRecordsRepository.AddAsync(new TrackPushRecordIndex
{
IndexName = $"{GlobalConst.TrackPushRecordsIndex}-{DateTime.Now:yyyy.MM.dd}",
RequestId = res.RequestId,
OptionType = OptionType.新增,
TrackPlace = @event.TrackPlace,
TrackTime = @event.TrackTime,
TrackTimeZone = @event.TrackTimeZone,
IsSuccess = isSuccess,
CreateUser = @event.PushMan ?? "系统",
CreateTime = DateTime.Now
});
// 更新订单主表
await _capPublisher.PublishAsync(GlobalConst.TrackPushAfterUpdateOrderSubscribe,
new TrackPushAfterUpdateOrderEvent
{
OrderId = @event.OrderId,
TrackContentId = @event.TrackContentId,
IsSuccess = isSuccess,
Message = res.Msg
});
}
private async Task PushUpdateAsync(TrackPushEvent @event)
{
var data = new
{
orderNo = @event.OrderNo,
data = new[]
{
new
{
// 推真实的发生地和发生时间
location = @event.TrackPlace,
date = @event.TrackTime,
timeZone = @event.TrackTimeZone,
description = @event.TrackEnContentValue,
description_cn = @event.TrackContentValue,
code = @event.TrackContentCodeValue,
status = @event.TrackStatusValue,
extra = @event.ExpandFieldsValue
}
}
};
await _httpClientProxy.Service.ForwardWithSubscribeAsync(InterfaceRelayConst.TrackUpdateInterfaceCode,
@event.ServiceProviderCode, data);
}
}

View File

@ -9,6 +9,7 @@ using SJZY.Track.Application.Contract.Dtos.TrackPull;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Application.Contract.Services;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Consts;
using SJZY.Track.Domain.Enums;
using Volo.Abp.DependencyInjection;
@ -31,12 +32,10 @@ public class TrackRefreshEventHandler : ITransientDependency, ICapSubscribe
[CapSubscribe(GlobalConst.TrackRefreshSubscribe)]
public async Task ConsumerAsync(InterfaceRelayForwardReplayEvent @event)
{
// tips:attach返回的是服务商id,必有
var refreshDto = JsonConvert.DeserializeObject<List<TrackRefreshDto>>(@event.RequestParams)?.FirstOrDefault();
if (refreshDto is null) return;
var config =
await _trackPullCacheService.GetPullParamWithContentConfigAsync(refreshDto.SubSystemId,
refreshDto.ServiceProviderId);
var attach = JsonConvert.DeserializeObject<TrackRefreshAttach>(@event.Attach);
if (attach is null) return;
var config = await _trackPullCacheService.GetPullParamWithContentConfigAsync(attach.SubSystemId,
attach.ServiceProviderId);
var data = JObject.Parse(@event.Data.ToString()!);
var orderToken = data[config.ParamConfig.OrderPath];
@ -44,12 +43,12 @@ public class TrackRefreshEventHandler : ITransientDependency, ICapSubscribe
{
foreach (var token in orderTokens)
{
await HandleOrderAsync(token, config, refreshDto.OrderType);
await HandleOrderAsync(token, config, attach.OrderType);
}
}
else if (orderToken is JObject)
{
await HandleOrderAsync(orderToken, config, refreshDto.OrderType);
await HandleOrderAsync(orderToken, config, attach.OrderType);
}
}

View File

@ -1,21 +1,22 @@
using DotNetCore.CAP;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Consts;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.EventHandlers;
public class UpdateOrderTrackEventHandler : ITransientDependency, ICapSubscribe
public class TrackUpsertAfterUpdateOrderEventHandler : ITransientDependency, ICapSubscribe
{
private readonly IOrderRepository _orderRepository;
public UpdateOrderTrackEventHandler(IOrderRepository orderRepository)
public TrackUpsertAfterUpdateOrderEventHandler(IOrderRepository orderRepository)
{
_orderRepository = orderRepository;
}
[CapSubscribe(GlobalConst.UpdateOrderTrackSubscribe)]
public async Task ConsumerAsync(UpdateOrderTrackEvent @event)
[CapSubscribe(GlobalConst.TrackUpsertAfterUpdateOrderSubscribe)]
public async Task ConsumerAsync(TrackUpsertAfterUpdateOrderEvent @event)
{
var order = await _orderRepository.GetFirstAsync(x => x.Id == @event.OrderId);
if (order == default) return;
@ -37,14 +38,20 @@ public class UpdateOrderTrackEventHandler : ITransientDependency, ICapSubscribe
// 删除引发的回退更新
if (order.LatestTrackTime != null &&
order.LatestTrackTime.Value.Subtract(TimeSpan.FromHours(order.LatestTrackTimeZone ?? 0)) ==
@event.TrackTime.Subtract(TimeSpan.FromHours(@event.TrackTimeZone))) return;
@event.TrackTime.Subtract(TimeSpan.FromHours(@event.TrackTimeZone)) ==
order.LatestTrackTime.Value.Subtract(TimeSpan.FromHours(order.LatestTrackTimeZone ?? 0)))
{
return;
}
}
else // upsert引发的更新
{
if (order.LatestTrackTime != null &&
order.LatestTrackTime.Value.Subtract(TimeSpan.FromHours(order.LatestTrackTimeZone ?? 0)) >
@event.TrackTime.Subtract(TimeSpan.FromHours(@event.TrackTimeZone))) return;
@event.TrackTime.Subtract(TimeSpan.FromHours(@event.TrackTimeZone)) <
order.LatestTrackTime.Value.Subtract(TimeSpan.FromHours(order.LatestTrackTimeZone ?? 0)))
{
return;
}
}
order.IsCompleted = @event.IsCompleted;

View File

@ -1,10 +1,12 @@
using DotNetCore.CAP;
using System.Diagnostics;
using DotNetCore.CAP;
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.Queries;
using SJZY.UserCenter.HttpApi.Services;
using Volo.Abp.DependencyInjection;
@ -57,15 +59,52 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
@event.TrackCode = mapCode;
}
await UpsertTrackAsync(@event);
}
private async Task UpsertTrackAsync(TrackUpsertEvent @event)
{
// 不存在则新增轨迹,存在则更新
var track = await _trackDetailsRepository.GetFirstOrDefaultAsync(@event.OrderId, @event.TrackCode);
var orderIsCompleted = false;
// step1、upsert es轨迹
await UpsertTrackAsync(track, @event);
Debug.Assert(track != null, nameof(track) + " != null");
// step2、触发轨迹推送事件(异步)
await HandleTrackPushAsync(@event, track);
// step3、触发订单主表更新事件(异步)
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertAfterUpdateOrderSubscribe,
new TrackUpsertAfterUpdateOrderEvent
{
OrderId = track.OrderId,
IsCompleted = track.IsCompleted,
TrackCode = track.TrackCode,
TrackContent = track.TrackContent,
TrackEnContent = track.TrackEnContent,
TrackPlace = track.TrackPlace,
TrackTime = track.TrackTime,
TrackTimeZone = track.TrackTimeZone
});
// step4、根据订单关联关系异步向下刷(异步)
var linkedOrders = await _orderRepository.GetLinkedOrdersAsync(@event.OrderId);
foreach (var linkedOrder in linkedOrders)
{
var nextEvent = @event.DeepCopy();
nextEvent.OrderId = linkedOrder.OrderId;
nextEvent.OrderType = linkedOrder.OrderType;
nextEvent.OrderNo = linkedOrder.OrderNo;
nextEvent.SubSystemId = linkedOrder.SubSystemId;
nextEvent.LatestPushTrackContentId = linkedOrder.LatestPushTrackContentId;
nextEvent.CustomId = linkedOrder.CustomId;
nextEvent.UpSubSystemId = @event.SubSystemId;
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, nextEvent);
}
}
/// <summary>
/// 不存在则新增轨迹,存在则更新
/// </summary>
/// <param name="track"></param>
/// <param name="event"></param>
private async Task UpsertTrackAsync(TrackDetailsIndex? track, TrackUpsertEvent @event)
{
if (track == default)
{
//todo:可以优化
@ -73,12 +112,10 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
var trackContent = await _provideQueries.MatchTrackContentAsync(@event.OrderId, @event.TrackCode);
if (trackContent == default)
{
//throw new BusinessException(message: $"订单:{@event.OrderNo} 所绑定的模板,没有一条内容可以匹配轨迹代码:{@event.TrackCode}");
// 订单所绑定的模板,没有一条内容可以匹配发生的轨迹
return;
}
orderIsCompleted = trackContent.IsCompleted;
track = new TrackDetailsIndex
{
IndexName = $"{GlobalConst.TrackIndex}-{DateTime.Now:yyyy.MM.dd}",
@ -89,7 +126,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
TrackCode = @event.TrackCode,
TrackContent = trackContent.Content,
TrackContentId = trackContent.Id,
IsCompleted = orderIsCompleted,
IsCompleted = trackContent.IsCompleted,
TrackEnContent = trackContent.EnContent,
TrackPlace = @event.TrackPlace,
TrackTime = @event.TrackTime!.Value,
@ -108,44 +145,47 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
track.UpdateTime = DateTime.Now;
}
// upsert es轨迹
await _trackDetailsRepository.UpsertAsync(track);
}
// 触发轨迹推送事件
var content = await _trackPushCacheService.InferNextPushContentOrNullAsync(
/// <summary>
/// 处理轨迹自动推送
/// </summary>
/// <param name="event"></param>
/// <param name="track"></param>
private async Task HandleTrackPushAsync(TrackUpsertEvent @event, TrackDetailsIndex track)
{
var config = await _trackPushCacheService.InferNextPushContentOrNullAsync(
@event.SubSystemId, @event.CustomId, @event.LatestPushTrackContentId);
if (content != default && content.TrackContentId == track.TrackContentId &&
content.OrderType == @event.OrderType)
{
//await PushTrack(content);
}
// 触发订单主表更新事件
await _capPublisher.PublishAsync(GlobalConst.UpdateOrderTrackSubscribe, new UpdateOrderTrackEvent
if (config == null || !config.IsAutoPush) return;
// 当前发生的轨迹就是要推送的
if (config.TrackContentId == track.TrackContentId && config.OrderType == @event.OrderType)
{
OrderId = track.OrderId,
IsCompleted = orderIsCompleted,
TrackCode = track.TrackCode,
TrackContent = track.TrackContent,
TrackEnContent = track.TrackEnContent,
var trackPushEvent = new TrackPushEvent
{
ServiceProviderCode = config.ServiceProviderCode,
OrderNo = track.OrderNo,
TrackContentId = config.TrackContentId,
TrackPlace = track.TrackPlace,
TrackTime = track.TrackTime,
TrackTimeZone = track.TrackTimeZone
});
TrackTime = track.TrackTime.AddHours(config.TrackTimeZone ?? track.TrackTimeZone - track.TrackTimeZone),
TrackTimeZone = (float)(config.TrackTimeZone ?? track.TrackTimeZone),
TrackContentCodeValue = config.TrackContentCodeValue,
TrackContentValue = config.TrackContentValue,
TrackEnContentValue = config.TrackEnContentValue,
TrackStatusValue = config.TrackStatusValue,
ExpandFieldsValue = config.ExpandFieldsValue
};
// 根据订单关联关系异步向下刷
var linkedOrders = await _orderRepository.GetLinkedOrdersAsync(@event.OrderId);
foreach (var linkedOrder in linkedOrders)
// 推送更新
if (!track.Id.IsNullOrWhiteSpace())
{
var nextEvent = @event.DeepCopy();
nextEvent.OrderId = linkedOrder.OrderId;
nextEvent.OrderType = linkedOrder.OrderType;
nextEvent.OrderNo = linkedOrder.OrderNo;
nextEvent.SubSystemId = linkedOrder.SubSystemId;
nextEvent.LatestPushTrackContentId = linkedOrder.LatestPushTrackContentId;
nextEvent.CustomId = linkedOrder.CustomId;
nextEvent.UpSubSystemId = @event.SubSystemId;
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, nextEvent);
trackPushEvent.OptionType = OptionType.修改;
if (!config.IsCanUpdate) return;
}
await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
}
}
}

View File

@ -2,6 +2,7 @@
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Domain.Aggregates.OrderAggregate;
using SJZY.Track.Domain.Consts;
using SJZY.Track.Domain.Queries;
namespace SJZY.Track.Application.Services.ProvideServices;

View File

@ -1,9 +1,11 @@
using Microsoft.AspNetCore.Authorization;
using Newtonsoft.Json;
using SJZY.Expand.ABP.Core;
using SJZY.InterfaceRelay.Application.Contracts;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Dtos.TrackPull;
using SJZY.Track.Application.Contract.Services;
using SJZY.Track.Domain.Consts;
using SJZY.Track.Domain.Queries;
using Volo.Abp.Http.Client.DynamicProxying;
@ -40,27 +42,27 @@ public class TrackPullService : ApplicationService
// todo:罚时?
input.OrderNos = input.OrderNos.Where(x => !x.IsNullOrWhiteSpace()).Distinct().ToList(); // 单号去重、去空
// 这里没有区分订单类型,就算的不同类型的单一起刷新了也无所谓
// tips:这里没有区分订单类型,就算的不同类型的单一起刷新了也无所谓
var orders = await _provideQueries.FindOrderWithServiceProviderAsync(input.OrderNos);
if (orders.Count == 0)
{
throw new BusinessException(message: "一个拉取配置都不存在");
// tips:可能是没有配置、或者所有单都刷完了、或者单不存在
throw new BusinessException(message: "一个能更新的都没有");
}
foreach (var group in orders.GroupBy(x => x.ServiceProviderCode))
foreach (var group in orders.GroupBy(x =>
new TrackRefreshAttach(x.ServiceProviderId, x.ServiceProviderCode, x.SubSystemId, x.OrderType)))
{
var data = group.Select(x => new TrackRefreshDto
var data = group.Select(x => new
{
OrderType = x.OrderType,
OrderNo = x.OrderNo,
ServiceProviderId = x.ServiceProviderId,
SubSystemId = x.SubSystemId
x.OrderNo
}).ToList();
// 批量获取轨迹
await _httpClientProxy.Service.BatchForwardThenPushToQueueAsync(
"A012", group.Key, data, GlobalConst.TrackRefreshSubscribe);
"A012", group.Key.ServiceProviderCode, data,
GlobalConst.TrackRefreshSubscribe, JsonConvert.SerializeObject(group.Key));
}
return true;
@ -85,19 +87,19 @@ public class TrackPullService : ApplicationService
var orders = await _provideQueries.FindOrderWithServiceProviderAsync(config.ServiceProviderId);
foreach (var group in orders.GroupBy(x => x.ServiceProviderCode))
foreach (var group in orders.GroupBy(x =>
new TrackRefreshAttach(x.ServiceProviderId, x.ServiceProviderCode, x.SubSystemId,
x.OrderType)))
{
var data = group.Select(x => new TrackRefreshDto
var data = group.Select(x => new
{
OrderType = x.OrderType,
OrderNo = x.OrderNo,
ServiceProviderId = x.ServiceProviderId,
SubSystemId = x.SubSystemId
x.OrderNo
}).ToList();
// 批量获取轨迹
await _httpClientProxy.Service.BatchForwardThenPushToQueueAsync(
"A012", group.Key, data, GlobalConst.TrackRefreshSubscribe);
InterfaceRelayConst.GetTrackInterfaceCode, group.Key.ServiceProviderCode, data,
GlobalConst.TrackRefreshSubscribe, JsonConvert.SerializeObject(group.Key));
}
await RedisHelper.Client.SetExAsync(redisKey, config.PullInterval * 60, 1);

View File

@ -1,9 +1,11 @@
using SJZY.InterfaceRelay.Application.Contracts;
using DotNetCore.CAP;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
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 Volo.Abp.Http.Client.DynamicProxying;
using SJZY.Track.Domain.Consts;
using SJZY.UserCenter.HttpApi.Services;
namespace SJZY.Track.Application.Services.ProvideServices;
@ -17,16 +19,17 @@ public class TrackPushService : ApplicationService
private readonly ITrackDetailsRepository _trackDetailsRepository;
private readonly IOrderRepository _orderRepository;
private readonly ITrackPushCacheService _pushCacheService;
private readonly IHttpClientProxy<IInterfaceForwardServiceV2> _httpClientProxy;
private readonly ICapPublisher _capPublisher;
public TrackPushService(
IHttpClientProxy<IInterfaceForwardServiceV2> httpClientProxy, ITrackPushCacheService pushCacheService,
ITrackDetailsRepository trackDetailsRepository, IOrderRepository orderRepository)
public TrackPushService(ITrackPushCacheService pushCacheService,
ITrackDetailsRepository trackDetailsRepository
, IOrderRepository orderRepository
, ICapPublisher capPublisher)
{
_httpClientProxy = httpClientProxy;
_pushCacheService = pushCacheService;
_trackDetailsRepository = trackDetailsRepository;
_orderRepository = orderRepository;
_capPublisher = capPublisher;
}
/// <summary>
@ -35,11 +38,10 @@ public class TrackPushService : ApplicationService
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("Track/Push")]
public async Task<bool> PushTrackAsync(PushTrackInput input)
public async Task<string> PushTrackAsync(PushTrackInput input)
{
input.OrderNos = input.OrderNos.Where(x => !x.IsNullOrWhiteSpace()).Distinct().ToList(); // 单号去重、去空
var orders = await _orderRepository.GetListAsync(x =>
x.OrderType == input.OrderType && input.OrderNos.Contains(x.OrderNo), x => new
{
@ -53,6 +55,13 @@ public class TrackPushService : ApplicationService
var tracks = await _trackDetailsRepository.GetListAsync(input.OrderType, input.OrderNos, input.TrackCode);
if (tracks.Count == 0)
{
throw new BusinessException(message: "一个能推的轨迹都不存在");
}
var res = 0;
foreach (var order in orders)
{
// 如果没有轨迹,就不需要推
@ -64,30 +73,27 @@ public class TrackPushService : ApplicationService
await _pushCacheService.GetPushContentConfigAsync(order.SubSystemId, order.CustomId,
track.TrackContentId);
var data = new
var trackPushEvent = new TrackPushEvent
{
order.OrderNo,
data = new[]
{
new
{
// 推真实的发生地和发生时间
location = track.TrackPlace,
date = track.TrackTime.AddHours(config.TrackTimeZone ??
ServiceProviderCode = config.ServiceProviderCode,
OrderNo = order.OrderNo,
TrackPlace = track.TrackPlace,
TrackTime = track.TrackTime.AddHours(config.TrackTimeZone ??
track.TrackTimeZone - track.TrackTimeZone),
timeZone = config.TrackTimeZone ?? track.TrackTimeZone,
description = config.TrackEnContentValue,
description_cn = config.TrackContentValue,
code = config.TrackContentCodeValue,
status = config.TrackStatusValue,
extra = config.ExpandFieldsValue
}
}
TrackTimeZone = (float)(config.TrackTimeZone ?? track.TrackTimeZone),
TrackContentCodeValue = config.TrackContentCodeValue,
TrackContentValue = config.TrackContentValue,
TrackEnContentValue = config.TrackEnContentValue,
TrackStatusValue = config.TrackStatusValue,
ExpandFieldsValue = config.ExpandFieldsValue,
PushMan = CurrentUserRequest.CurrentUser.Name,
};
await _httpClientProxy.Service.ForwardWithSubscribeAsync("A024", config.ServiceProviderCode, data);
await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
res++;
}
return true;
return $"即将推送轨迹代码{input.TrackCode}给{res}个订单";
}
}

View File

@ -4,6 +4,7 @@ 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.Queries;
namespace SJZY.Track.Application.Services.ProvideServices;
@ -41,7 +42,7 @@ public partial class TrackService : ApplicationService, ITrackService
var order = await _orderRepository.GetFirstAsync(x =>
x.OrderType == input.OrderType && x.OrderNo == input.OrderNo, x => new
{
x.Id, x.SubSystemId, x.LatestPushTrackContentId, x.CustomId
x.Id, x.SubSystemId, x.LatestPushTrackContentId, x.CustomId, x.IsCompleted
});
if (order == default)
{
@ -54,6 +55,7 @@ public partial class TrackService : ApplicationService, ITrackService
@event.SubSystemId = order.SubSystemId;
@event.LatestPushTrackContentId = order.LatestPushTrackContentId;
@event.CustomId = order.CustomId;
@event.IsCompleted = order.IsCompleted;
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, @event);
return true;
}

View File

@ -3,12 +3,12 @@ using SJZY.Expand.ABP.Core;
using SJZY.Track.Application.Contract.Dtos.TrackPull;
using SJZY.Track.Application.Contract.Services;
using SJZY.Track.Domain.Aggregates.TrackPullAggregate;
using SJZY.Track.Domain.Consts;
using SJZY.Track.Domain.Dtos.TrackPull;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.Services.TrackPull;
public class TrackPullCacheService : ApplicationService, ITrackPullCacheService, ITransientDependency
public class TrackPullCacheService : ApplicationService, ITrackPullCacheService
{
private readonly ITrackPullConfigRepository _trackPullConfigRepository;

View File

@ -9,7 +9,6 @@ using SJZY.Track.Domain.Aggregates.TrackPullAggregate;
using SJZY.Track.Domain.Dtos.Common;
using SJZY.Track.Domain.Dtos.TrackPull;
using SqlSugar;
using Volo.Abp.DependencyInjection;
namespace SJZY.Track.Application.Services.TrackPull;
@ -18,7 +17,7 @@ namespace SJZY.Track.Application.Services.TrackPull;
/// </summary>
[ApiExplorerSettings(GroupName = "轨迹拉取")]
[Route("/Track/PullConfig")]
public class TrackPullService : ApplicationService, ITransientDependency
public class TrackPullService : ApplicationService
{
private readonly IStringLocalizer<TrackLocalizationResource> _stringLocalizer;
private readonly ITrackPullConfigRepository _trackPullConfigRepository;
@ -102,9 +101,10 @@ public class TrackPullService : ApplicationService, ITransientDependency
case OptionTypeNoNull.新增:
{
var trackPullEntity = ObjectMapper.Map<EditTrackPullConfigInput, TrackPullConfigEntity>(input);
var trackPullParamsEntity = ObjectMapper.Map<EditTrackPullConfigInput, TrackPushPullParamsConfigEntity>(input);
var trackPullParamsEntity =
ObjectMapper.Map<EditTrackPullConfigInput, TrackPushPullParamsConfigEntity>(input);
int id = 0;
int id;
using (var ts = TransactionScopeHelper.Create())
{
@ -122,9 +122,12 @@ public class TrackPullService : ApplicationService, ITransientDependency
case OptionTypeNoNull.修改:
{
var oldTrackPullEntity = await _trackPullConfigRepository.GetFirstAsync(x => x.Id == input.Id) ?? throw new BusinessException(message: _stringLocalizer["NotFindData"]);
var oldTrackPullEntity = await _trackPullConfigRepository.GetFirstAsync(x => x.Id == input.Id) ??
throw new BusinessException(message: _stringLocalizer["NotFindData"]);
var oldTrackPullParamsEntity = await _trackPullConfigRepository.GetParamsSingleAsync(x => x.PullOrPushConfigId == input.Id && !x.IsPush);
var oldTrackPullParamsEntity =
await _trackPullConfigRepository.GetParamsSingleAsync(x =>
x.PullOrPushConfigId == input.Id && !x.IsPush);
ObjectMapper.Map(input, oldTrackPullEntity);
ObjectMapper.Map(input, oldTrackPullParamsEntity);
@ -145,7 +148,8 @@ public class TrackPullService : ApplicationService, ITransientDependency
using (var ts = TransactionScopeHelper.Create())
{
await _trackPullConfigRepository.SoftDeleteAsync(x => x.Id == input.Id);
await _trackPullConfigRepository.SoftDeleteParamsAsync(x => x.PullOrPushConfigId == input.Id && !x.IsPush);
await _trackPullConfigRepository.SoftDeleteParamsAsync(x =>
x.PullOrPushConfigId == input.Id && !x.IsPush);
await _trackPullConfigRepository.SoftDeleteContentAsync(x => x.TrackPullConfigId == input.Id);
ts.Complete();
@ -171,21 +175,32 @@ public class TrackPullService : ApplicationService, ITransientDependency
{
if (input.Options != OptionTypeNoNull.删除)
{
Expression<Func<TrackPullContentConfigEntity, bool>> isContentAnyExp = x => x.TrackPullConfigId == input.TrackPullConfigId;
Expression<Func<TrackPullContentConfigEntity, bool>> isContentAnyExp = x =>
x.TrackPullConfigId == input.TrackPullConfigId;
if (input.Options == OptionTypeNoNull.修改) isContentAnyExp = isContentAnyExp.And(x => x.Id != input.Id);
if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x => x.TrackContentId == input.TrackContentId)))
if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x =>
x.TrackContentId == input.TrackContentId)))
throw new BusinessException(message: _stringLocalizer["IsTrackPullContentAny"]);
else if (!input.TrackContentCodeValue.IsNullOrWhiteSpace() && await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x => x.TrackContentCodeValue == input.TrackContentCodeValue)))
else if (!input.TrackContentCodeValue.IsNullOrWhiteSpace() &&
await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x =>
x.TrackContentCodeValue == input.TrackContentCodeValue)))
throw new BusinessException(message: _stringLocalizer["IsTrackPullContentCodeValueAny"]);
else if (!input.TrackStatusValue.IsNullOrWhiteSpace() && await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x => x.TrackStatusValue == input.TrackStatusValue)))
else if (!input.TrackStatusValue.IsNullOrWhiteSpace() &&
await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x =>
x.TrackStatusValue == input.TrackStatusValue)))
throw new BusinessException(message: _stringLocalizer["IsTrackPullContentStatusValueAny"]);
else if (!input.TrackContentValue.IsNullOrWhiteSpace() && await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x => x.TrackContentValue == input.TrackContentValue)))
else if (!input.TrackContentValue.IsNullOrWhiteSpace() &&
await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x =>
x.TrackContentValue == input.TrackContentValue)))
throw new BusinessException(message: _stringLocalizer["IsTrackPullContentValueAny"]);
else if (!input.TrackKeywords.IsNullOrEmpty())
{
Expression<Func<TrackPullContentConfigEntity, bool>> trackKeywordExp = _ => false;
input.TrackKeywords!.ForEach(item => { trackKeywordExp = trackKeywordExp.Or(x => SqlFunc.SplitIn(x.TrackKeyword, item)); });
input.TrackKeywords!.ForEach(item =>
{
trackKeywordExp = trackKeywordExp.Or(x => SqlFunc.SplitIn(x.TrackKeyword, item));
});
if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(trackKeywordExp)))
throw new BusinessException(message: _stringLocalizer["IsTrackPullContentKeywordsAny"]);

View File

@ -3,11 +3,11 @@ using SJZY.Expand.ABP.Core;
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Services;
using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
using Volo.Abp.DependencyInjection;
using SJZY.Track.Domain.Consts;
namespace SJZY.Track.Application.Services.TrackPush;
public class TrackPushCacheService : ApplicationService, ITrackPushCacheService, ITransientDependency
public class TrackPushCacheService : ApplicationService, ITrackPushCacheService
{
private readonly ITrackPushConfigRepository _trackPushConfigRepository;

View File

@ -1,5 +1,6 @@
using Nest;
using SJZY.Expand.ElasticSearch;
using SJZY.Track.Domain.Consts;
namespace SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
@ -11,11 +12,6 @@ public class TrackDetailsIndex : IdBaseIndex
/// </summary>
public int OrderId { get; set; }
/// <summary>
/// 服务商code
/// </summary>
public string? ServiceProviderCode { get; set; }
/// <summary>
/// 订单号
/// </summary>
@ -36,11 +32,6 @@ public class TrackDetailsIndex : IdBaseIndex
/// </summary>
public string TrackStatus { get; set; } = null!;
/// <summary>
/// 原轨迹状态
/// </summary>
public string? OriginTrackStatus { get; set; }
/// <summary>
/// 轨迹内容代码
/// </summary>
@ -57,10 +48,15 @@ public class TrackDetailsIndex : IdBaseIndex
public int TrackContentId { get; set; }
/// <summary>
/// 是否意味着完成
/// 这条轨迹是否意味着完成(删除回退需要用到)
/// </summary>
public bool IsCompleted { get; set; }
/// <summary>
/// 原轨迹状态
/// </summary>
public string? OriginTrackStatus { get; set; }
/// <summary>
/// 原轨迹内容
/// </summary>

View File

@ -0,0 +1,11 @@
namespace SJZY.Track.Domain.Aggregates.TrackPushAggregate;
public interface ITrackPushRecordsRepository
{
/// <summary>
/// 添加推送记录
/// </summary>
/// <param name="index"></param>
/// <returns></returns>
Task AddAsync(TrackPushRecordIndex index);
}

View File

@ -0,0 +1,51 @@
using Nest;
using SJZY.Expand.ABP.Common.Enums;
using SJZY.Expand.ElasticSearch;
using SJZY.Track.Domain.Consts;
namespace SJZY.Track.Domain.Aggregates.TrackPushAggregate;
[ElasticsearchType(RelationName = GlobalConst.TrackPushRecordsIndex)]
public class TrackPushRecordIndex : IdBaseIndex
{
/// <summary>
/// 索引名称
/// </summary>
public string IndexName { get; set; } = null!;
/// <summary>
/// 接口通请求Id
/// </summary>
public Guid RequestId { get; set; }
/// <summary>
/// 操作类型
/// </summary>
public OptionType OptionType { get; set; }
/// <summary>
/// 轨迹发生地
/// </summary>
public string TrackPlace { get; set; } = null!;
/// <summary>
/// 轨迹发生时间
/// </summary>
public DateTime TrackTime { get; set; }
/// <summary>
/// 轨迹发生时区
/// </summary>
public float TrackTimeZone { get; set; }
/// <summary>
/// 是否成功
/// </summary>
public bool IsSuccess { get; set; }
/// <summary>创建人</summary>
public string? CreateUser { get; set; }
/// <summary>创建时间</summary>
public DateTime CreateTime { get; set; }
}

View File

@ -0,0 +1,14 @@
namespace SJZY.Track.Domain.Consts;
public partial class GlobalConst
{
/// <summary>
/// 轨迹明细 es索引名称(模板)
/// </summary>
public const string TrackIndex = "sjzy_track_details";
/// <summary>
/// 轨迹推送记录 es索引名称(模板)
/// </summary>
public const string TrackPushRecordsIndex = "sjzy_track_push_records";
}

View File

@ -0,0 +1,39 @@
namespace SJZY.Track.Domain.Consts;
public partial class GlobalConst
{
/// <summary>
/// 轨迹新增/更新
/// </summary>
public const string TrackUpsertSubscribe = "SJZY.Track.TrackUpsert";
/// <summary>
/// 轨迹删除
/// </summary>
public const string TrackDeleteSubscribe = "SJZY.Track.TrackDelete";
/// <summary>
/// 接口通批量轨迹刷新
/// </summary>
public const string TrackRefreshSubscribe = "SJZY.Track.TrackRefresh";
/// <summary>
/// 轨迹推送
/// </summary>
public const string TrackPushSubscribe = "SJZY.Track.TrackPush";
/// <summary>
/// 轨迹新增/更新后触发更新订单主表
/// </summary>
public const string TrackUpsertAfterUpdateOrderSubscribe = "SJZY.Track.TrackUpsertAfterUpdateOrder";
/// <summary>
/// 轨迹推送后触发更新订单主表
/// </summary>
public const string TrackPushAfterUpdateOrderSubscribe = "SJZY.Traack.TrackPushAfterUpdateOrder";
/// <summary>
/// 关联订单后补轨迹
/// </summary>
public const string OrderLinkAfterFillTrack = "SJZY.Track.OrderLinkAfterFillTrack";
}

View File

@ -0,0 +1,24 @@
namespace SJZY.Track.Domain.Consts;
public partial class GlobalConst
{
/// <summary>
/// 轨迹要推送的客户redis key前缀
/// </summary>
public const string TrackPushKeyPrefix = "TrackPush";
/// <summary>
/// 轨迹推送内容配置redis key前缀
/// </summary>
public const string TrackPushContentKeyPrefix = "TrackPushContent";
/// <summary>
/// 轨迹拉取配置信息redis key前缀
/// </summary>
public const string TrackPullKeyPrefix = "TrackPull";
/// <summary>
/// 轨迹拉取配置信息redis key前缀
/// </summary>
public const string TrackPullContentKeyPrefix = "TrackPullContent";
}

View File

@ -0,0 +1,27 @@
namespace SJZY.Track.Domain.Consts;
/// <summary>
/// 接口通常量
/// </summary>
public class InterfaceRelayConst
{
/// <summary>
/// 接口通成功代码
/// </summary>
public const string SuccessCode = "200";
/// <summary>
/// 获取轨迹接口代码
/// </summary>
public const string GetTrackInterfaceCode = "A012";
/// <summary>
/// 推送轨迹接口代码
/// </summary>
public const string PushTrackInterfaceCode = "A024";
/// <summary>
/// 更新轨迹接口代码
/// </summary>
public const string TrackUpdateInterfaceCode = "A040";
}

View File

@ -31,4 +31,9 @@ public class LinkedOrderVO
/// 客户id
/// </summary>
public int CustomId { get; set; }
/// <summary>
/// 订单是否完成
/// </summary>
public bool IsCompleted { get; set; }
}

View File

@ -1,8 +1,13 @@
namespace SJZY.Track.Domain.Enums;
[Flags]
public enum TrackProblemType
public enum TrackPushProblemType
{
/// <summary>
/// 没问题
/// </summary>
None = 0,
/// <summary>
/// 异常
/// </summary>

View File

@ -1,54 +0,0 @@
namespace SJZY.Track.Domain;
public class GlobalConst
{
/// <summary>
/// 轨迹明细 es索引名称
/// </summary>
public const string TrackIndex = "sjzy_track_details";
/// <summary>
/// 轨迹新增/更新 mq订阅名称
/// </summary>
public const string TrackUpsertSubscribe = "SJZY.Track.TrackUpsert";
/// <summary>
/// 轨迹删除 mq订阅名称
/// </summary>
public const string TrackDeleteSubscribe = "SJZY.Track.TrackDelete";
/// <summary>
/// 接口通批量轨迹刷新 mq订阅名称
/// </summary>
public const string TrackRefreshSubscribe = "SJZY.Track.TrackRefresh";
/// <summary>
/// 轨迹新增/更新后触发更新订单轨迹 mq订阅名称
/// </summary>
public const string UpdateOrderTrackSubscribe = "SJZY.Track.UpdateOrderTrack";
/// <summary>
/// 关联订单后补轨迹 mq订阅名称
/// </summary>
public const string OrderLinkAfterFillTrack = "SJZY.Track.OrderLinkAfterFillTrack";
/// <summary>
/// 轨迹要推送的客户redis key前缀
/// </summary>
public const string TrackPushKeyPrefix = "TrackPush";
/// <summary>
/// 轨迹推送内容配置redis key前缀
/// </summary>
public const string TrackPushContentKeyPrefix = "TrackPushContent";
/// <summary>
/// 轨迹拉取配置信息redis key前缀
/// </summary>
public const string TrackPullKeyPrefix = "TrackPull";
/// <summary>
/// 轨迹拉取配置信息redis key前缀
/// </summary>
public const string TrackPullContentKeyPrefix = "TrackPullContent";
}

View File

@ -113,7 +113,7 @@ public class ProvideQueries : ISugarRepository, IProvideQueries,
return await Context.Queryable<OrderEntity>()
.LeftJoin<OrderTemplateEntity>((a, b) => a.Id == b.OrderId)
.LeftJoin<VServiceProviderEntity>((a, b, c) => b.ServiceProviderId == c.Id)
.Where(a => orderNos.Contains(a.OrderNo))
.Where(a => !a.IsCompleted && orderNos.Contains(a.OrderNo))
.Select((a, b, c) => new OrderWithServiceProviderVO
{
OrderNo = a.OrderNo,

View File

@ -67,7 +67,8 @@ public class OrderRepository : BasicRepository<OrderEntity>, IOrderRepository, I
OrderNo = b.OrderNo,
SubSystemId = b.SubSystemId,
LatestPushTrackContentId = b.LatestPushTrackContentId,
CustomId = b.CustomId
CustomId = b.CustomId,
IsCompleted = b.IsCompleted
})
.ToListAsync();
}

View File

@ -0,0 +1,28 @@
using SJZY.Expand.ABP.Core.Logger;
using SJZY.Expand.ElasticSearch.Services;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
namespace SJZY.Track.Repository.Repositories;
public class TrackPushRecordsRepository : ElasticSearchContextAbstract<TrackDetailsIndex>, ITrackPushRecordsRepository,
ITransientDependency
{
public TrackPushRecordsRepository(ConnectionFactory connectionFactory) : base(connectionFactory)
{
}
public async Task AddAsync(TrackPushRecordIndex index)
{
// 按天写入es
var r = await Context.IndexAsync(index, request => request
.Index(index.IndexName)
//.Refresh(Refresh.True) // 可选:立即刷新索引使更改立即可见
);
if (!r.IsValid)
{
LogHelper.Error($"轨迹推送记录写入es失败,原因:{r.DebugInformation}。");
}
}
}