From af412772ab7a4c14ba58385bacb273577abdf15e Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期五, 05 九月 2025 14:23:59 +0800
Subject: [PATCH] Merge branch 'master' of http://120.26.58.240:8888/r/ApiFlexJob
---
FlexJobApi.CommonServer.Application/LogRecords/Commands/ResendResourceCommandHandler.cs | 17 ++++++++++++++++-
1 files changed, 16 insertions(+), 1 deletions(-)
diff --git a/FlexJobApi.CommonServer.Application/LogRecords/Commands/ResendResourceCommandHandler.cs b/FlexJobApi.CommonServer.Application/LogRecords/Commands/ResendResourceCommandHandler.cs
index 80a8d77..396b1bb 100644
--- a/FlexJobApi.CommonServer.Application/LogRecords/Commands/ResendResourceCommandHandler.cs
+++ b/FlexJobApi.CommonServer.Application/LogRecords/Commands/ResendResourceCommandHandler.cs
@@ -7,6 +7,7 @@
using System;
using System.Collections.Generic;
using System.Linq;
+using System.Net;
using System.Text;
using System.Threading.Tasks;
@@ -38,6 +39,7 @@
{
it.Method,
it.Path,
+ it.RequestHeaders,
it.Request,
it.CreatedUserId
})
@@ -60,7 +62,20 @@
})
.request
.ToJson();
- var result = await paramters.SendHttpAsync(resource.ServiceName, resource.Route, resource.Method);
+ string? accessToken = null, refreshToken = null;
+ if (log.RequestHeaders.IsNotNull())
+ {
+ var headers = log.RequestHeaders.JsonTo<Dictionary<string, List<string>>>();
+ if (headers.ContainsKey("Authorization"))
+ {
+ accessToken = headers["Authorization"].FirstOrDefault();
+ }
+ if (headers.ContainsKey("X-Authorization"))
+ {
+ refreshToken = headers["X-Authorization"].FirstOrDefault();
+ }
+ }
+ var result = await paramters.SendHttpAsync(resource.ServiceName, resource.Route, resource.Method, accessToken: accessToken, refreshToken: refreshToken);
return result;
}
}
--
Gitblit v1.9.1