From 37fe2cc6c007dae986ece6346408d6541078baa9 Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期三, 13 八月 2025 10:45:02 +0800
Subject: [PATCH] feat:开发
---
FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs | 108 +++++++++---------------------------------------------
1 files changed, 18 insertions(+), 90 deletions(-)
diff --git a/FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs b/FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs
index 9b51203..139d6ff 100644
--- a/FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs
+++ b/FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs
@@ -13,6 +13,7 @@
using Microsoft.AspNetCore.Mvc.Controllers;
using Microsoft.AspNetCore.Routing;
using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Caching.Distributed;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
@@ -36,87 +37,6 @@
/// </summary>
public static class ResourceUtils
{
- /// <summary>
- /// 鍙戦�丠TTP璇锋眰
- /// </summary>
- /// <typeparam name="TRequest"></typeparam>
- /// <typeparam name="TResponse"></typeparam>
- /// <param name="request"></param>
- /// <returns></returns>
- public static async Task<TResponse> SendHttpAsync<TRequest, TResponse>(TRequest request)
- where TRequest : class, new()
- {
- var requestTypeFullName = typeof(TRequest).FullName;
- var resource = await Db.GetRepository<Resource>().AsQueryable().AsNoTracking()
- .Where(it => !it.IsExpired && it.RequestTypeFullName == requestTypeFullName)
- .FirstOrDefaultAsync();
- var domain = await GetHealthyServiceDomain(resource);
- var httpRemoteService = App.GetRequiredService<IHttpRemoteService>();
- var token = App.HttpContext.Request.Headers["Authorization"].ToString();
- var refreshToken = App.HttpContext.Request.Headers["X-Authorization"].ToString();
- TResponse response;
- switch (resource.Method)
- {
- case EnumResourceMethod.Get:
- response = await httpRemoteService.GetAsAsync<TResponse>(
- $"{domain}{resource.Route}",
- it =>
- it.WithQueryParameters(request)
- .AddAuthentication(new AuthenticationHeaderValue("Authorization", token))
- .AddAuthentication(new AuthenticationHeaderValue("X-Authorization", refreshToken)));
- break;
- case EnumResourceMethod.Post:
- response = await httpRemoteService.PostAsAsync<TResponse>(
- $"{domain}{resource.Route}",
- it =>
- it.SetJsonContent(request)
- .WithHeader("Authorization", token)
- .WithHeader("X-Authorization", refreshToken));
- break;
- case EnumResourceMethod.Put:
- response = await httpRemoteService.PutAsAsync<TResponse>(
- $"{domain}{resource.Route}",
- it =>
- it.SetJsonContent(request)
- .AddAuthentication(new AuthenticationHeaderValue("Authorization", token))
- .AddAuthentication(new AuthenticationHeaderValue("X-Authorization", refreshToken)));
- break;
- case EnumResourceMethod.Delete:
- response = await httpRemoteService.DeleteAsAsync<TResponse>(
- $"{domain}{resource.Route}",
- it =>
- it.SetJsonContent(request)
- .AddAuthentication(new AuthenticationHeaderValue("Authorization", token))
- .AddAuthentication(new AuthenticationHeaderValue("X-Authorization", refreshToken)));
- break;
- default:
- throw Oops.Oh(EnumErrorCodeType.s400, $"涓嶆敮鎸佽姹傛柟寮弡resource.Method}");
- }
- return response;
- }
-
- /// <summary>
- /// 鑾峰彇鍋ュ悍鏈嶅姟鍩熷悕
- /// </summary>
- /// <param name="resource"></param>
- /// <returns></returns>
- public static async Task<string> GetHealthyServiceDomain(Resource resource)
- {
- var client = App.GetRequiredService<IConsulClient>();
- var queryResult = await client.Health.Service(resource.ServiceName, null, true);
- if (queryResult.StatusCode != System.Net.HttpStatusCode.OK)
- throw Oops.Oh(EnumErrorCodeType.s404, $"寰湇鍔resource.Service}");
-
- var domains = queryResult.Response
- .Select(s => $"http://{s.Service.Address}:{s.Service.Port}")
- .ToList();
- if (domains.IsNull())
- throw Oops.Oh(EnumErrorCodeType.s404, $"寰湇鍔resource.Service}");
- // 杞閫夋嫨瀹炰緥
- int randomIndex = new Random().Next(domains.Count);
- return domains[randomIndex];
- }
-
/// <summary>
/// 鐢熸垚鍔ㄦ�佹帶鍒跺櫒
/// </summary>
@@ -181,9 +101,9 @@
model.ResponseTypeName = responseType.GetCSharpFriendlyName();
model.ResponseTypeFullName = responseType.FullName;
}
-
-
models.Add(model);
+
+ await App.GetRequiredService<IDistributedCache>().SetStringAsync($"ResourceModel|{model.RequestTypeFullName}", model.ToJson());
}
}
@@ -237,8 +157,7 @@
var expiredResources = resources.Where(it => !models.Any(m => m.Route == it.Route && m.Method == it.Method)).ToList();
foreach (var expiredResource in expiredResources)
{
- //expiredResource.IsExpired = true;
- //await rep.UpdateAsync(expiredResource);
+ resources.Remove(expiredResource);
await rep.DeleteAsync(expiredResource);
}
@@ -287,9 +206,10 @@
code += $@"
[AllowAnonymous]";
}
+ var result = resource.ResponseTypeName.IsNull() ? "Task" : $"Task<{resource.ResponseTypeName}>";
code += $@"
[Http{resource.Method}]
- public Task<{resource.ResponseTypeName}> {resource.ActionName}({resource.RequestTypeName} request)
+ public {result} {resource.ActionName}({resource.RequestTypeName} request)
{{
return mediator.Send(request);
}}
@@ -297,10 +217,18 @@
}}
}}
";
- var dynamicAssembly = App.CompileCSharpClassCode(code);
- provider.AddAssembliesWithNotifyChanges(dynamicAssembly);
- var dynamicAssemblyName = dynamicAssembly.GetName().Name;
- resource.DynamicAssemblyName = dynamicAssemblyName;
+ try
+ {
+ var dynamicAssembly = App.CompileCSharpClassCode(code);
+ provider.AddAssembliesWithNotifyChanges(dynamicAssembly);
+ var dynamicAssemblyName = dynamicAssembly.GetName().Name;
+ resource.DynamicAssemblyName = dynamicAssemblyName;
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine(code);
+ throw;
+ }
}
}
--
Gitblit v1.9.1