Merge branch 'S03-轨迹中台优化项' into dev

This commit is contained in:
moyongzhen 2024-04-22 14:43:02 +08:00
commit fca855b69c
6 changed files with 36 additions and 22 deletions

13
.idea/.idea.SJZY.Track.Api/.idea/.gitignore generated vendored Normal file
View File

@ -0,0 +1,13 @@
# Default ignored files
/shelf/
/workspace.xml
# Rider ignored files
/projectSettingsUpdater.xml
/.idea.SJZY.Track.Api.iml
/modules.xml
/contentModel.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

View File

@ -60,9 +60,9 @@
/// </summary> /// </summary>
public List<int>? SelectIds { get; set; } public List<int>? SelectIds { get; set; }
///// <summary> /// <summary>
///// 关键字 /// 关键字
///// </summary> /// </summary>
//public string Keywords { get; set; } public string? Keywords { get; set; }
} }
} }

View File

@ -57,12 +57,12 @@ public class CapFilter : SubscribeFilter
/// <returns></returns> /// <returns></returns>
public override Task OnSubscribeExecutedAsync(ExecutedContext context) public override Task OnSubscribeExecutedAsync(ExecutedContext context)
{ {
context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime); // context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime);
context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName); // context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName);
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); // context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId); // context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId);
//
BuildLog(receiveTime!, receiveName!, arguments!, false, messageId!); // BuildLog(receiveTime!, receiveName!, arguments!, false, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -86,11 +86,11 @@ public class CapFilter : SubscribeFilter
LogHelper.Error($"cap-msg-id:{messageId}\n{context.Exception}"); LogHelper.Error($"cap-msg-id:{messageId}\n{context.Exception}");
context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime); // context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime);
context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName); // context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName);
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); // context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
//
BuildLog(receiveTime!, receiveName!, arguments, true, messageId!); // BuildLog(receiveTime!, receiveName!, arguments, true, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }

View File

@ -18,10 +18,10 @@ namespace SJZY.Track.Domain.Dtos.TrackFlags
/// </summary> /// </summary>
public List<int>? SelectIds { get; set; } public List<int>? SelectIds { get; set; }
///// <summary> /// <summary>
///// 关键字 /// 关键字
///// </summary> /// </summary>
//public string Keywords { get; set; } public string? Keywords { get; set; }
} }
public class GetTrackFlagListVO public class GetTrackFlagListVO

View File

@ -8,7 +8,7 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="SJZY.Expand.ABP.Core" Version="7.7.1" /> <PackageReference Include="SJZY.Expand.ABP.Core" Version="7.7.5"/>
<PackageReference Include="SJZY.Expand.ElasticSearch" Version="7.0.17" /> <PackageReference Include="SJZY.Expand.ElasticSearch" Version="7.0.17" />
</ItemGroup> </ItemGroup>

View File

@ -46,8 +46,9 @@ public class TrackFlagRepository : BasicRepository<TrackFlagEntity>, ITrackFlagR
.LeftJoin<VUserEntity>((a, b, c) => a.CreateUserId == c.Id && c.IsDeleted == false) .LeftJoin<VUserEntity>((a, b, c) => a.CreateUserId == c.Id && c.IsDeleted == false)
.LeftJoin<VUserEntity>((a, b, c, d) => a.UpdateUserId == d.Id && d.IsDeleted == false) .LeftJoin<VUserEntity>((a, b, c, d) => a.UpdateUserId == d.Id && d.IsDeleted == false)
.WhereIF(input.SubSystemId > 0, (a, b, c, d) => a.SubSystemId == input.SubSystemId) .WhereIF(input.SubSystemId > 0, (a, b, c, d) => a.SubSystemId == input.SubSystemId)
.WhereIF(!input.Keywords.IsNullOrWhiteSpace(), (a, b, c, d) => SqlFunc.Contains(a.Code, input.Keywords))
.OrderByIF(input.SelectIds.IsNullOrEmpty(), (a, b, c, d) => a.CreateTime, OrderByType.Desc) .OrderByIF(input.SelectIds.IsNullOrEmpty(), (a, b, c, d) => a.CreateTime, OrderByType.Desc)
.OrderByIF(!input.SelectIds.IsNullOrEmpty(), (a, b, c, d) => SqlFunc.IIF(input.SelectIds.Contains(a.Id), SqlFunc.DateAdd(SqlFunc.GetDate(), 1), a.CreateTime), OrderByType.Desc) .OrderByIF(!input.SelectIds.IsNullOrEmpty(), (a, b, c, d) => SqlFunc.IIF(input.SelectIds!.Contains(a.Id), SqlFunc.DateAdd(SqlFunc.GetDate(), 1), a.CreateTime), OrderByType.Desc)
.Select((a, b, c, d) => new GetTrackFlagListVO .Select((a, b, c, d) => new GetTrackFlagListVO
{ {
Id = a.Id, Id = a.Id,