FastApi 1.0.42

FastApi

介绍

.net core快速api，支持静态方法，自定义过滤器，自定义参数等等

软件架构

软件架构说明

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();

var fastApp = new FastApp(app);

//过滤器
fastApp.AddFilter(new FastFilter
{
    ExecuteAsync = async ctx =>
    {
        //string token = ctx.HttpContext.Request.Headers["token"];
        //if (string.IsNullOrEmpty(token))
        //{
        //    throw new Exception("授权失败");
        //}
        ctx.UserData.Add("user", new LoginUser() { Name = "李四" });
        ctx.UserData.Add("aa", "用户自定义数据");
    }
});

//响应数据前
fastApp.OnBeforeResponseAsync += (fastCtx) =>
{
    var result = new { code = 0, data = fastCtx.ResponseData, msg = "" };
    return fastCtx.HttpContext.Response.WriteAsJsonAsync(result, fastApp.JsonOptions);
};

//响应结束后
fastApp.OnAfterResponseAsync += async (fastCtx, ex, cancelReq) =>
{
    var route = fastCtx.Module.RouteName + fastCtx.Action.RouteName;
    Console.WriteLine($"OnAfterResponseAsync，{route}==>方法执行时间：{fastCtx.ExecuteTime}ms，序列化执行时间：{fastCtx.JsonSerialTime}ms");

    if (ex != null)
    {
        if (!cancelReq) //浏览器没有取消操作,响应错误信息
        {
            var result = new { code = -1, data = null as string, msg = ex.Message };
            await fastCtx.HttpContext.Response.WriteAsJsonAsync(result, fastApp.JsonOptions);
        }
        Console.WriteLine($"OnAfterResponseAsync，{route}==>发生异常:{ex.Message}" + ex.StackTrace);
    }
};

//响应视图
fastApp.OnViewAsync += async (fastCtx, view) =>
{
    var template = Engine.LoadTemplate(AppDomain.CurrentDomain.BaseDirectory + view.ViewPath);
    template.Set("Model", view.ViewData, view.ViewData.GetType());
    var html = await template.RenderAsync();
    await fastCtx.HttpContext.Response.WriteAsync(html);
};

//添加自定义参数
fastApp.AddParams(typeof(LoginUser), new FastParamCreator
{
    Create = ctx =>
    {
        return ctx.UserData["user"];
    }
});

fastApp.AddParams(typeof(ILifetimeScope), new FastParamCreator
{
    Create = ctx =>
    {
        return AutofacHelper.GetScope();
    },
    DisposeValueAsync = (ctx, obj) =>
    {
        var scope = (ILifetimeScope)obj;
        return scope.DisposeAsync();
    }
});

fastApp.AddParams(typeof(DistributedTransaction), new FastParamCreator
{
    Create = ctx =>
    {
        var tran = new DistributedTransaction();
        return tran;
    },
    //DisposeAsync = async (ctx, obj) =>
    //{
    //    var tran = (DistributedTransaction)obj;
    //    await tran.DisposeAsync();
    //},
    CommitAsync = (ctx, obj) =>
    {
        var tran = (DistributedTransaction)obj;
        return tran.CommitAsync();
    },
    RollbackAsync = (ctx, obj) =>
    {
        var tran = (DistributedTransaction)obj;
        return tran.RollbackAsync();
    }
});

//添加路由
fastApp.AddRoute("home", typeof(HomeModule));
fastApp.AddRoute("test", typeof(TestModule));
fastApp.AddRoute(typeof(StudentModule).Assembly);

[FastRoute("student")]
public class StudentModule
{
	
	DistributedTransaction _tran;
	//构造函数
	public StudentModule(DistributedTransaction tran)
	{
		_tran = tran;
	}

	public string index(ILifetimeScope scope)
	{
		return "student index";
	}
	
	//static method 静态方法
	public static string index2()
	{
		return "this is static method";
	}

	public string Add(IFastHttp http)
	{
		return http.GetQuery("name") + http.UserData["aa"];
	}

	[FastRedirect]
	public string baidu()
	{
		return "https://www.baidu.com";
	}

	[FastCustomer]
	public async Task Down(IFastHttp http)
	{
		await http.WriteFileAsync(new byte[] { 1, 23, 4, 4 }, "下载的文件.zip");
	}

	//原始输出
	[FastCustomer]
	public void Jd(IFastHttp http)
	{
		http.Redirect("https://www.jd.com");
	}
	
	//清除过滤器
	[FastFilterClear]
	public string Add2([FastForm] string a)
	{
		return "你好2" + a;
	}
}

//swagger

<ItemGroup Condition="'$(Configuration)'=='Debug'">
	<PackageReference Include="FastApi.Swag" Version="1.0.29" />
</ItemGroup>

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();
var fastApp = new FastApp(app);

fastApp.AddRoute("home", typeof(HomeModule));

#if DEBUG
            var fastSwag = new FastApi.Swag.FastSwag(fastApp.FastModuleDict);
            fastSwag.AddApiKey("token");
            //fastSwag.AddJwtBearer();
			//fastSwag.AddLogin("/login/gettoken", "['data']"); //auto login
            fastSwag.OnCreateDocument += (doc) =>
            {
                doc.Info.Title = "API接口信息";
                doc.Info.Description = "这是对接口信息的描述11";
            };

            //fastSwag.OnResponse += (baseSchema) =>
            //{
            //    var schema = new NJsonSchema.JsonSchema();
            //    schema.Type = NJsonSchema.JsonObjectType.Object;
            //    schema.Properties.Add("code", new NJsonSchema.JsonSchemaProperty { Type = NJsonSchema.JsonObjectType.Integer });
            //    schema.Properties.Add("msg", new NJsonSchema.JsonSchemaProperty { Type = NJsonSchema.JsonObjectType.String });
            //    var dataPro = new NJsonSchema.JsonSchemaProperty();
            //    if (baseSchema.Example != null)
            //    {
            //        dataPro.ActualSchema.Example = baseSchema.Example;
            //    }
            //    else
            //    {
            //        //dataPro.AdditionalPropertiesSchema = baseSchema.ActualSchema;
            //    }
            //    schema.Properties.Add("data", dataPro);
            //    return schema;
            //};

            fastSwag.CreateApiJsonFile($@"{Environment.CurrentDirectory}\wwwroot\swagger");

            Console.WriteLine("Swagger文档生成成功!");
#endif


 public class HomeModule
 {
	readonly DistributedTransaction tran;
	ILifetimeScope scope0;

	public HomeModule(DistributedTransaction tran, ILifetimeScope scope0)
	{
		 this.tran = tran;
		 this.scope0 = scope0;
	}

	/// <summary>
	/// 添加接口
	/// </summary>
	/// <param name="a">名字</param>
	/// <returns></returns>
	/// <remarks>
	/// 这是对接口的描述111
	/// 换行的描述2222
	/// </remarks>
	/// <swag-res>{code:0,data:{},msg:""}</swag-res>
	[FastCustomer]
	public static string Add(string a)
	{
		return "你好" + a;
	}

	/// <summary>
	/// 自定义body
	/// </summary>
	/// <param name="a"></param>
	/// <returns></returns>
	/// <swag-body>{name:"里斯",sex:1}</swag-body>
	/// <swag-res>{code:0,data:{},msg:""}</swag-res>
	[FastFilterClear]
	public string Add2([FastBody] string a)
	{
		return "你好2" + a;
	}

	/// <summary>
	/// 删除
	/// </summary>
	/// <param name="id"></param>
	/// <returns></returns>
	/// <exception cref="Exception"></exception>
	/// <swag-query>
	///     id.string.true@这是个id
	///     name.string.true@名字 
	///     sex.string.false@性别 
	/// </swag-query>
	/// <swag-form>
	///     addrss.string.true@地址
	///     phone.string@手机 
	///     fileName.file.true@文件
	/// </swag-form>
	public async Task<string> Del(int id)
	{
		 throw new Exception("发生异常，删除失败了");
		 return "删除" + id;
	}
}

//FastFlurl create RestHelper.cs file
FastFlurl.CreateClassFile($"{Environment.CurrentDirectory}/../TestRest", "TestRest", "RestHelper", fastApp.FastModuleDict, FastFlurlLevel.ObjectType);

//now you can use RestHelper.cs class file to request api
var client = new RestHelper("http://localhost:5212");
var a = await client.Home_Add<string>(new { a = "Lili" });
Console.WriteLine(a);