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

Merge branch 'S06' into test

Browse Source
This commit is contained in:
hardstylewyl 2024-12-19 15:03:38 +08:00
commit 0177444856
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/SJZY.Track.Application/CAP/EventHandlers/TrackPushEventHandler.cs
View File

@ -4,6 +4,7 @@ using Microsoft.Extensions.Options;
using Newtonsoft.Json; using Newtonsoft.Json;
using SJZY.Expand.ABP.Core.PublicMethords; using SJZY.Expand.ABP.Core.PublicMethords;
using SJZY.InterfaceRelay.Application.Contracts; using SJZY.InterfaceRelay.Application.Contracts;
using SJZY.OTel;
using SJZY.Track.Application.Contract.Dtos.TrackPush; using SJZY.Track.Application.Contract.Dtos.TrackPush;
using SJZY.Track.Application.Contract.Events; using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Application.Contract.Services; using SJZY.Track.Application.Contract.Services;
@ -380,11 +381,14 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
/// <returns></returns> /// <returns></returns>
private async Task<List<string>> GetExtraParamNamesAsync(string subSystemCode) private async Task<List<string>> GetExtraParamNamesAsync(string subSystemCode)
{ {
using var span = ActivityHelper.CreateSpanActivity("开始请求接口通，接口结构");
using (Track2InterfaceRelaySubSystemContext.Use( using (Track2InterfaceRelaySubSystemContext.Use(
new Track2InterfaceRelaySubSystemContext(subSystemCode))) new Track2InterfaceRelaySubSystemContext(subSystemCode)))
{ {
var res = await _httpClientProxy.Service.GetSystemInterfaceByIdAsync(_options.CurrentValue.PushTrackInterfaceCode, _options.CurrentValue.PushTrackInterfaceId); var res = await _httpClientProxy.Service.GetSystemInterfaceByIdAsync(_options.CurrentValue.PushTrackInterfaceCode, _options.CurrentValue.PushTrackInterfaceId);
if (res == null) return new List<string>(); if (res == null) return new List<string>();
span.SetTag("request-GetSystemInterfaceByIdAsync", $"{subSystemCode},{_options.CurrentValue.PushTrackInterfaceCode},{_options.CurrentValue.PushTrackInterfaceId}");
span.SetTag("response-GetSystemInterfaceByIdAsync", res.ToJson());
return res.InParameterList return res.InParameterList
.Where(x => x.Alias.StartsWith(_options.CurrentValue.PushTrackItemParamAliasPrefix)) .Where(x => x.Alias.StartsWith(_options.CurrentValue.PushTrackItemParamAliasPrefix))
.Select(x => x.Name) .Select(x => x.Name)