feat:开发

sunpengfei

2025-08-14 b5c75c9edf9c13a8bd4ba2f0596a1ceaf2563c6b

 FlexJobApi.Core/Utils/ResourceUtils/ResourceUtils.cs

@@ -38,22 +38,6 @@
    public static class ResourceUtils
    {
        /// <summary>
        /// 发送HTTP请求
        /// </summary>
        /// <typeparam name="TRequest"></typeparam>
        /// <typeparam name="TResponse"></typeparam>
        /// <param name="request"></param>
        /// <param name="provider"></param>
        /// <returns></returns>
        public static Task<TResponse> SendHttpAsync<TRequest, TResponse>(
            TRequest request,
            IResourceHttpProvider provider = null)
            where TRequest : class, new()
        {
            return App.GetRequiredService<ResourceHttpUtils>().SendHttpAsync<TRequest, TResponse>(request, provider);
        }

        /// <summary>
        /// 生成动态控制器
        /// </summary>
        public static async Task BuildDynamicControllersAsync()
@@ -94,7 +78,9 @@
                    model.RouteArea = resourceService.RouteArea;
                    model.Route = $"/api/{resourceService.RouteArea ?? "main"}/{controller}/{model.ActionName}";
                    model.Method =
                        request.BaseType?.IsGenericType == true && request.BaseType.GetGenericTypeDefinition() == typeof(PagedListQuery<,>)
                        resourceAttribute.Method.HasValue
                        ? resourceAttribute.Method.Value
                        : request.BaseType?.IsGenericType == true && request.BaseType.GetGenericTypeDefinition() == typeof(PagedListQuery<,>)
                        ? EnumResourceMethod.Post
                        : new List<string> { "Post", "Add", "Create", "Insert", "Submit" }.Any(it => request.Name.StartsWith(it, StringComparison.OrdinalIgnoreCase))
                        ? EnumResourceMethod.Post
@@ -105,6 +91,7 @@
                        : new List<string> { "Delete", "Remove ", "Clear" }.Any(it => request.Name.StartsWith(it, StringComparison.OrdinalIgnoreCase))
                        ? EnumResourceMethod.Delete
                        : EnumResourceMethod.Post;
                    model.FileUpload = resourceAttribute.FileUpload;
                    model.Code = requestXmlDoc?.Name;
                    model.Name = $"{model.ControllerSummary}-{model.ActionSummary}";
                    model.AllowAnonymous = resourceAttribute.AllowAnonymous;
@@ -173,8 +160,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);
            }

@@ -189,7 +175,21 @@
        public static void DynamicControllersHotPlug(List<Resource> resources, IDynamicApiRuntimeChangeProvider provider = null)
        {
            provider = provider ?? App.GetRequiredService<IDynamicApiRuntimeChangeProvider>();
            foreach (var resource in resources)
            var controllers = resources
                .GroupBy(it => new
                {
                    it.ApplicationName,
                    it.Controller,
                    it.ControllerSummary,
                    it.RouteArea
                })
                .Select(it => new
                {
                    it.Key,
                    Actions = it.ToList()
                })
                .ToList();
            foreach (var controller in controllers)
            {
                var code = $@"
using FlexJobApi.Core;
@@ -203,40 +203,70 @@
using System.Collections.Generic;
using System.ComponentModel;

namespace {resource.ApplicationName}.{resource.Controller}.{resource.ActionName}Request

namespace {controller.Key.ApplicationName}.{controller.Key.Controller}
{{
    /// <summary>
    /// {resource.ControllerSummary}
    /// {controller.Key.ControllerSummary}
    /// </summary>
    [Route(""api/{resource.RouteArea}/[controller]"")]
    public class {resource.Controller}AppService(IMediator mediator) : IDynamicApiController
    [Route(""api/{controller.Key.RouteArea}/[controller]"")]
    public class {controller.Key.Controller}AppService(IMediator mediator) : IDynamicApiController
    {{
        private readonly IMediator mediator = mediator;
        private readonly IMediator mediator = mediator;";

                foreach (var action in controller.Actions)
                {
                    var result = action.ResponseTypeName.IsNull() ? "Task" : $"Task<{action.ResponseTypeName}>";
                    code += @$"

        /// <summary>
        /// {resource.ActionSummary}
        /// {action.ActionSummary}
        /// </summary>
        /// <param name=""request""></param>
        /// <returns></returns>";
                if (resource.AllowAnonymous)
                {
                    code += $@"
                    if (action.AllowAnonymous)
                    {
                        code += $@"
        [AllowAnonymous]";
                }
                code += $@"
        [Http{resource.Method}]
        public Task<{resource.ResponseTypeName}> {resource.ActionName}({resource.RequestTypeName} request)
                    }
                    code += $@"
        [Http{action.Method}]";
                    if (action.FileUpload)
                    {
                        code += @"
        [Consumes(""multipart/form-data"")]";
                    }
                    code += @$"
        public {result} {action.ActionName}(";
                    if (action.FileUpload)
                    {
                        code += "[FromForm] ";
                    }
                    code += $@"{action.RequestTypeName} request)
        {{
            return mediator.Send(request);
        }}
        }}";
                }

    }}
}}
                code += @"
    }
}
";
                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;
                    foreach (var action in controller.Actions)
                    {
                        action.DynamicAssemblyName = dynamicAssemblyName;
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine(code);
                    throw;
                }
            }

        }