refactor：add websitemessageservice method and httpClientAuthorizationDelegatingHandler

Author: wzh425

src/BasicAbility/Masa.Contrib.BasicAbility.Mc/HttpClientAuthorizationDelegatingHandler.cs

@@ -0,0 +1,24 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the MIT License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.Contrib.BasicAbility.Mc;
+
+public class HttpClientAuthorizationDelegatingHandler : DelegatingHandler
+{
+    private readonly IHttpContextAccessor _httpContextAccessor;
+
+    public HttpClientAuthorizationDelegatingHandler(IHttpContextAccessor httpContextAccessor)
+    {
+        _httpContextAccessor = httpContextAccessor;
+    }
+
+    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
+    {
+        if (_httpContextAccessor.HttpContext != null)
+        {
+            var accessToken = await _httpContextAccessor.HttpContext.GetTokenAsync("access_token");
+            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", accessToken);
+        }
+        return await base.SendAsync(request, cancellationToken);
+    }
+}

src/BasicAbility/Masa.Contrib.BasicAbility.Mc/Service/WebsiteMessageService.cs

@@ -31,7 +31,7 @@ public async Task DeleteAsync(Guid id)
     public async Task<List<WebsiteMessageChannelModel>> GetChannelListAsync()
     {
         var requestUri = $"{_party}/GetChannelList";
-        return await _callerProvider.GetAsync<List<WebsiteMessageChannelModel>>(requestUri)??new();
+        return await _callerProvider.GetAsync<List<WebsiteMessageChannelModel>>(requestUri) ?? new();
     }
 
     public async Task<PaginatedListModel<WebsiteMessageModel>> GetListAsync(GetWebsiteMessageModel options)
@@ -57,4 +57,16 @@ public async Task SetAllReadAsync(ReadAllWebsiteMessageModel options)
         var requestUri = $"{_party}/SetAllRead";
         await _callerProvider.PostAsync(requestUri, options);
     }
+
+    public async Task SendCheckNotificationAsync()
+    {
+        var requestUri = $"{_party}/SendCheckNotification";
+        await _callerProvider.PostAsync(requestUri, null);
+    }
+
+    public async Task SendGetNotificationAsync(List<string> userIds)
+    {
+        var requestUri = $"{_party}/SendGetNotification";
+        await _callerProvider.PostAsync(requestUri, userIds);
+    }
 }

src/BasicAbility/Masa.Contrib.BasicAbility.Mc/ServiceCollectionExtensions.cs

@@ -12,13 +12,14 @@ public static IServiceCollection AddMcClient(this IServiceCollection services, s
             throw new ArgumentNullException(nameof(mcServiceBaseAddress));
         }
 
+        services.AddSingleton<IRequestMessage, JsonRequestMessage>();
         return services.AddMcClient(callerOptions =>
         {
             callerOptions.UseHttpClient(builder =>
             {
                 builder.Name = DEFAULT_CLIENT_NAME;
                 builder.Configure = opt => opt.BaseAddress = new Uri(mcServiceBaseAddress);
-            });
+            }).AddHttpMessageHandler<HttpClientAuthorizationDelegatingHandler>();
         });
     }
 
@@ -29,9 +30,11 @@ public static IServiceCollection AddMcClient(this IServiceCollection services, A
         if (services.Any(service => service.ServiceType == typeof(IMcClient)))
             return services;
 
-        services.AddCaller(callerOptions.Invoke);
+        services.AddHttpContextAccessor();
+        services.AddScoped<HttpClientAuthorizationDelegatingHandler>();
+        services.AddCaller(callerOptions);
 
-        services.AddSingleton<IMcClient>(serviceProvider =>
+        services.AddScoped<IMcClient>(serviceProvider =>
         {
             var callProvider = serviceProvider.GetRequiredService<ICallerFactory>().CreateClient(DEFAULT_CLIENT_NAME);
             var mcCaching = new McClient(callProvider);

src/BasicAbility/Masa.Contrib.BasicAbility.Mc/_Imports.cs

@@ -14,3 +14,5 @@
 global using System.Diagnostics.CodeAnalysis;
 global using System.Globalization;
 global using System.Reflection;
+global using Microsoft.AspNetCore.Http;
+global using Microsoft.AspNetCore.Authentication;