sunpengfei
7 天以前 8ffda541b48cbf619f8493196da4fb44d4f3ddc5
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;
        }
    }