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

fix:修复批量新增推送记录缺失创建时间

Browse Source
This commit is contained in:
hardstylewyl 2025-04-15 16:57:37 +08:00
parent 3bbd633259
commit 24a80c7a50
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Repository/Repositories/TrackPushRecordEsRepository.cs
View File

@ -36,7 +36,11 @@ public class TrackPushRecordEsRepository : ElasticSearchContextAbstract<TrackPus
if (!records.Any()) return; if (!records.Any()) return;
// 按天写入es // 按天写入es
var indexName = $"{GlobalConst.TrackPushRecordIndex}-{DateTime.Now:yyyy.MM.dd}"; var indexName = $"{GlobalConst.TrackPushRecordIndex}-{DateTime.Now:yyyy.MM.dd}";
records.ForEach(x => x.IndexName = indexName); records.ForEach(x =>
{
x.IndexName = indexName;
x.CreateTime = DateTime.Now;
});
var r = await Context.IndexManyAsync(records, indexName); var r = await Context.IndexManyAsync(records, indexName);