diff --git a/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs b/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
index 7b0901e1..08969864 100644
--- a/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
+++ b/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
@@ -71,6 +71,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
track = new TrackDetailsIndex
{
+ IndexName = $"{GlobalConst.TrackIndex}-{DateTime.Now:yyyy.MM.dd}",
OrderId = @event.OrderId,
OrderNo = @event.OrderNo,
OrderType = @event.OrderType,
diff --git a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs
index 0004343c..b885e11b 100644
--- a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs
+++ b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs
@@ -16,6 +16,11 @@ public class TrackDetailsIndex : IdBaseIndex
///
public string OrderNo { get; set; } = null!;
+ ///
+ /// 索引名称
+ ///
+ public string IndexName { get; set; } = null!;
+
///
/// 订单类型(主数据枚举TrackOrderType)
///
diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
index 71779e5d..a0e6cead 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
@@ -1,8 +1,6 @@
using Nest;
using SJZY.Expand.ABP.Core.Logger;
-using SJZY.Expand.ABP.Core.PublicMethords;
using SJZY.Expand.ElasticSearch.Services;
-using SJZY.Track.Domain;
using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
using SJZY.Track.Domain.Dtos.TrackDetails;
@@ -25,9 +23,9 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract f.IsDeleted, false)
)
);
-
- var res= r.Documents.FirstOrDefault();
- if (r.Hits.FirstOrDefault() != default && res != default)
+
+ var res = r.Documents.FirstOrDefault();
+ if (res != default && r.Hits.FirstOrDefault() != default)
{
res.Id = r.Hits.FirstOrDefault()!.Id;
}
@@ -37,26 +35,30 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract request
+ .Index(index.IndexName)
+ );
+
+ if (!r.IsValid)
{
- // 按天写入es
- await Context.IndexAsync(index, request => request
- .Index($"{GlobalConst.TrackIndex}-{DateTime.Now:yyyy.MM.dd}")
- );
- }
- else
- {
- await Context.UpdateAsync(index.Id, u => u
- .Doc(index)
- //.Refresh(Refresh.True) // 可选:立即刷新索引使更改立即可见
- );
+ LogHelper.Error($"轨迹数据新增失败,原因:{r.DebugInformation}。");
}
}
- catch (Exception ex)
+ else
{
- LogHelper.Error($"轨迹数据新增/修改失败,原因:{ex.Message}。\n{index.ToJson()}");
+ var r = await Context.UpdateAsync(index.Id, u => u
+ .Index(index.IndexName)
+ .Doc(index)
+ //.Refresh(Refresh.True) // 可选:立即刷新索引使更改立即可见
+ );
+
+ if (!r.IsValid)
+ {
+ LogHelper.Error($"轨迹数据更新失败,原因:{r.DebugInformation}。");
+ }
}
}