Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4d0f8e20a6 | ||
|
|
b5e4d57772 | ||
|
|
239cd8bcbb | ||
|
|
62ddd6698e | ||
|
|
b2a6e5f40f | ||
|
|
801f698dcf | ||
|
|
9c939426ba | ||
|
|
e45cc4d28d | ||
|
|
6023cf2eb0 | ||
|
|
63dcd0f13f | ||
|
|
22704590f5 | ||
|
|
98907ba5af |
@@ -1,4 +1,4 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.AspNetCore.Mvc;
|
||||||
using Microsoft.AspNetCore.Mvc.Filters;
|
using Microsoft.AspNetCore.Mvc.Filters;
|
||||||
@@ -19,13 +19,16 @@ namespace SimApi.Attributes
|
|||||||
//默认是user登录类型
|
//默认是user登录类型
|
||||||
public SimApiAuthAttribute()
|
public SimApiAuthAttribute()
|
||||||
{
|
{
|
||||||
Types = new[] { "user" };
|
Types = new[]
|
||||||
|
{
|
||||||
|
"user"
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
//只检测一种用户类型的快捷方式
|
//只检测一种用户类型的快捷方式
|
||||||
public SimApiAuthAttribute(string type)
|
public SimApiAuthAttribute(string type)
|
||||||
{
|
{
|
||||||
Types = new[] { type };
|
Types = type.Split(",");
|
||||||
}
|
}
|
||||||
|
|
||||||
//设定特定类型的检测
|
//设定特定类型的检测
|
||||||
@@ -37,7 +40,10 @@ namespace SimApi.Attributes
|
|||||||
//只检测一种用户类型的快捷方式
|
//只检测一种用户类型的快捷方式
|
||||||
public SimApiAuthAttribute(string type, string url)
|
public SimApiAuthAttribute(string type, string url)
|
||||||
{
|
{
|
||||||
Types = new[] { type };
|
Types = new[]
|
||||||
|
{
|
||||||
|
type
|
||||||
|
};
|
||||||
new HttpPostAttribute(url);
|
new HttpPostAttribute(url);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -50,10 +56,10 @@ namespace SimApi.Attributes
|
|||||||
throw new SimApiException(401);
|
throw new SimApiException(401);
|
||||||
}
|
}
|
||||||
//检测用户类型
|
//检测用户类型
|
||||||
if (Types.Intersect(loginInfo.Type).Count() == 0)
|
if (!Types.Intersect(loginInfo.Type).Any())
|
||||||
{
|
{
|
||||||
throw new SimApiException(403);
|
throw new SimApiException(403);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1,39 +1,23 @@
|
|||||||
using System;
|
namespace SimApi.Communications
|
||||||
|
|
||||||
namespace SimApi.Communications
|
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 只有ID的请求
|
/// 只有ID的请求
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class SimApiIdOnlyRequest
|
public record SimApiIdOnlyRequest(int Id);
|
||||||
{
|
|
||||||
public int Id { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 只有ID的请求(字符串)
|
/// 只有ID的请求(字符串)
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class SimApiStringIdOnlyRequest
|
public record SimApiStringIdOnlyRequest(string Id);
|
||||||
{
|
|
||||||
public string Id { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 动态类型单字段请求
|
/// 动态类型单字段请求
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <typeparam name="T"></typeparam>
|
/// <typeparam name="T"></typeparam>
|
||||||
public class SimApiOneFieldRequest<T>
|
public record SimApiOneFieldRequest<T>(T Data);
|
||||||
{
|
|
||||||
public T Data { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 基础分页请求
|
/// 基础分页请求
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class SimApiBasePageRequest
|
public record SimApiBasePageRequest(int Page, int Count);
|
||||||
{
|
|
||||||
public int Page { get; set; }
|
|
||||||
|
|
||||||
public int Count { get; set; }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@@ -7,82 +7,38 @@ namespace SimApi.Communications
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 基础相应
|
/// 基础相应
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class SimApiBaseResponse
|
public record SimApiBaseResponse(int Code = 200, string Message = "成功")
|
||||||
{
|
{
|
||||||
/// <summary>
|
|
||||||
/// 错误代码
|
|
||||||
/// </summary>
|
|
||||||
public int Code { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 错误描述
|
|
||||||
/// </summary>
|
|
||||||
public string Message { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 默认错误代码对应提示信息
|
/// 默认错误代码对应提示信息
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private readonly Dictionary<int, string> MsgBox = new Dictionary<int, string>()
|
private static readonly Dictionary<int, string> MsgBox = new()
|
||||||
{
|
{
|
||||||
{200, "成功"},
|
{
|
||||||
{204, "没有数据"},
|
200, "成功"
|
||||||
{400, "参数错误"},
|
},
|
||||||
{401, "需要登录"},
|
{
|
||||||
{403, "无权访问"},
|
204, "没有数据"
|
||||||
{404, "接口不存在"},
|
},
|
||||||
{500, "服务器错误"}
|
{
|
||||||
|
400, "参数错误"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
401, "需要登录"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
403, "无权访问"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
404, "接口不存在"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
500, "服务器错误"
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
/// <summary>
|
public SimApiBaseResponse(int code) : this(code, MsgBox.ContainsKey(code) ? MsgBox[code] : "未知错误")
|
||||||
/// 返回一个成功的空结果
|
|
||||||
/// </summary>
|
|
||||||
public SimApiBaseResponse()
|
|
||||||
{
|
{
|
||||||
SetCode(200);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 返回指定代码的描述
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="code">错误代码</param>
|
|
||||||
public SimApiBaseResponse(int code)
|
|
||||||
{
|
|
||||||
SetCode(code);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 返回指定代码的结果,并自定义提示信息
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="code">错误代码</param>
|
|
||||||
/// <param name="message">错误信息</param>
|
|
||||||
public SimApiBaseResponse(int code, string message)
|
|
||||||
{
|
|
||||||
SetCodeMsg(code, message);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 设置响应结果的错误代码
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="code">错误代码</param>
|
|
||||||
public void SetCode(int code)
|
|
||||||
{
|
|
||||||
Code = code;
|
|
||||||
Message = MsgBox.ContainsKey(code) ? MsgBox[code] : "未知错误";
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 设置响应结果的错误代码和错误描述
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="code">错误代码</param>
|
|
||||||
/// <param name="message">错误描述</param>
|
|
||||||
public void SetCodeMsg(int code, string message)
|
|
||||||
{
|
|
||||||
SetCode(code);
|
|
||||||
if (!string.IsNullOrEmpty(message))
|
|
||||||
{
|
|
||||||
Message = message;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -95,7 +51,10 @@ namespace SimApi.Communications
|
|||||||
{
|
{
|
||||||
IgnoreReadOnlyProperties = true,
|
IgnoreReadOnlyProperties = true,
|
||||||
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
|
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
|
||||||
Converters = {new JsonStringEnumConverter()}
|
Converters =
|
||||||
|
{
|
||||||
|
new JsonStringEnumConverter()
|
||||||
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -104,32 +63,14 @@ namespace SimApi.Communications
|
|||||||
/// 动态内容分页
|
/// 动态内容分页
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <typeparam name="T"></typeparam>
|
/// <typeparam name="T"></typeparam>
|
||||||
public class SimApiBasePageResponse<T> : SimApiBaseResponse
|
public record SimApiBasePageResponse<T>
|
||||||
{
|
(T List, int Page = 1, int Count = 1, int Total = 1, int Code = 200,
|
||||||
/// <summary>
|
string Message = "成功") : SimApiBaseResponse(Code, Message);
|
||||||
/// 动态内容列表
|
|
||||||
/// </summary>
|
|
||||||
public T List { get; set; }
|
|
||||||
|
|
||||||
//当前页码
|
|
||||||
public int Page { get; set; }
|
|
||||||
|
|
||||||
//每页条数
|
|
||||||
public int Count { get; set; }
|
|
||||||
|
|
||||||
//总计条数
|
|
||||||
public int Total { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 动态Data返回
|
/// 动态Data返回
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <typeparam name="T"></typeparam>
|
/// <typeparam name="T"></typeparam>
|
||||||
public class SimApiBaseResponse<T> : SimApiBaseResponse
|
public record SimApiBaseResponse<T>(T Data, int Code = 200, string Message = "成功") : SimApiBaseResponse(Code,
|
||||||
{
|
Message);
|
||||||
/// <summary>
|
|
||||||
/// 动态内容列表
|
|
||||||
/// </summary>
|
|
||||||
public T Data { get; set; }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@@ -1,16 +1,7 @@
|
|||||||
using System;
|
namespace SimApi.Communications
|
||||||
|
|
||||||
namespace SimApi.Communications
|
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 登录信息中间件
|
/// 登录信息中间件
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class SimApiLoginItem
|
public record SimApiLoginItem(string Id, string[] Type);
|
||||||
{
|
|
||||||
//登录用户的ID
|
|
||||||
public string Id { get; set; }
|
|
||||||
|
|
||||||
//登录用户来源
|
|
||||||
public string[] Type { get; set; }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@@ -4,15 +4,62 @@ namespace SimApi.Configs
|
|||||||
{
|
{
|
||||||
public class SimApiOptions
|
public class SimApiOptions
|
||||||
{
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 启用全部Cors,对于开发前后分离的时候很有用。
|
||||||
|
/// default: true
|
||||||
|
/// </summary>
|
||||||
public bool EnableCors { get; set; } = true;
|
public bool EnableCors { get; set; } = true;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 启用SimapiAuth,一个简单的基于Header Token的认证方式。
|
||||||
|
/// default: false
|
||||||
|
/// </summary>
|
||||||
public bool EnableSimApiAuth { get; set; } = false;
|
public bool EnableSimApiAuth { get; set; } = false;
|
||||||
public bool EnableSimApiDoc { get; set; } = true;
|
|
||||||
|
/// <summary>
|
||||||
|
/// 启用在线文档,启用后 访问 /swagger 可以查看对应的api文档。
|
||||||
|
/// default: false
|
||||||
|
/// </summary>
|
||||||
|
public bool EnableSimApiDoc { get; set; } = false;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 启用异常拦截,启用后,所有的异常将被通过json反馈。
|
||||||
|
/// default: true
|
||||||
|
/// </summary>
|
||||||
public bool EnableSimApiException { get; set; } = true;
|
public bool EnableSimApiException { get; set; } = true;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 开启S3兼容的存储系统。
|
||||||
|
/// default: false
|
||||||
|
/// </summary>
|
||||||
public bool EnableSimApiStorage { get; set; } = false;
|
public bool EnableSimApiStorage { get; set; } = false;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 开启ForwardHeaders,开启后可以透传负载均衡的Headers
|
||||||
|
/// default: true
|
||||||
|
/// </summary>
|
||||||
public bool EnableForwardHeaders { get; set; } = true;
|
public bool EnableForwardHeaders { get; set; } = true;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 将所有的url都格式化为小写字母
|
||||||
|
/// default: true
|
||||||
|
/// </summary>
|
||||||
public bool EnableLowerUrl { get; set; } = true;
|
public bool EnableLowerUrl { get; set; } = true;
|
||||||
public bool EnableLogger { get; set; } = true;
|
|
||||||
|
/// <summary>
|
||||||
|
/// 启用格式化的 Console Logger
|
||||||
|
/// default: false
|
||||||
|
/// </summary>
|
||||||
|
public bool EnableLogger { get; set; } = false;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Swagger文档相关配置,需要启用 EnableSimApiDoc
|
||||||
|
/// </summary>
|
||||||
public SimApiDocOptions SimApiDocOptions { get; set; } = new SimApiDocOptions();
|
public SimApiDocOptions SimApiDocOptions { get; set; } = new SimApiDocOptions();
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// S3兼容的存储系统配置,需要启用 EnableSimApiStorage
|
||||||
|
/// </summary>
|
||||||
public SimApiStorageOptions SimApiStorageOptions { get; set; } = new SimApiStorageOptions();
|
public SimApiStorageOptions SimApiStorageOptions { get; set; } = new SimApiStorageOptions();
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -2,10 +2,23 @@ namespace SimApi.Configs
|
|||||||
{
|
{
|
||||||
public class SimApiStorageOptions
|
public class SimApiStorageOptions
|
||||||
{
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// S3 服务器入口地址
|
||||||
|
/// </summary>
|
||||||
public string Endpoint { get; set; }
|
public string Endpoint { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// S3 服务器文件访问地址
|
||||||
|
/// </summary>
|
||||||
public string ServeUrl { get; set; }
|
public string ServeUrl { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// S3服务 Bucket
|
||||||
|
/// </summary>
|
||||||
public string Bucket { get; set; }
|
public string Bucket { get; set; }
|
||||||
|
|
||||||
public string AccessKey { get; set; }
|
public string AccessKey { get; set; }
|
||||||
|
|
||||||
public string SecretKey { get; set; }
|
public string SecretKey { get; set; }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -29,13 +29,11 @@ namespace SimApi.Controllers
|
|||||||
{
|
{
|
||||||
if (!context.ModelState.IsValid)
|
if (!context.ModelState.IsValid)
|
||||||
{
|
{
|
||||||
foreach (var item in context.ModelState.Values)
|
foreach (var item in context.ModelState.Values.Where(item =>
|
||||||
|
item.ValidationState == ModelValidationState.Invalid))
|
||||||
{
|
{
|
||||||
if (item.ValidationState == ModelValidationState.Invalid)
|
Error(400, item.Errors.First().ErrorMessage);
|
||||||
{
|
break;
|
||||||
Error(400, item.Errors.First().ErrorMessage);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -83,7 +81,7 @@ namespace SimApi.Controllers
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
protected SimApiBaseResponse<string> UploadFile()
|
protected SimApiBaseResponse<string> UploadFile()
|
||||||
{
|
{
|
||||||
return new SimApiBaseResponse<string>();
|
return new SimApiBaseResponse<string>(null);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -25,9 +25,7 @@ namespace SimApi.Controllers
|
|||||||
[ApiExplorerSettings(IgnoreApi = true)]
|
[ApiExplorerSettings(IgnoreApi = true)]
|
||||||
public SimApiBaseResponse ExceptionHandler(int code)
|
public SimApiBaseResponse ExceptionHandler(int code)
|
||||||
{
|
{
|
||||||
var response = new SimApiBaseResponse();
|
return new SimApiBaseResponse(code);
|
||||||
response.SetCode(code);
|
|
||||||
return response;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -38,10 +36,7 @@ namespace SimApi.Controllers
|
|||||||
public SimApiBaseResponse<string> CheckLogin()
|
public SimApiBaseResponse<string> CheckLogin()
|
||||||
{
|
{
|
||||||
ErrorWhenNull(LoginInfo, 401);
|
ErrorWhenNull(LoginInfo, 401);
|
||||||
return new SimApiBaseResponse<string>
|
return new SimApiBaseResponse<string>(LoginInfo.Id);
|
||||||
{
|
|
||||||
Data = LoginInfo.Id
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
+7
-12
@@ -25,7 +25,10 @@ namespace SimApi.Helpers
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public string Login(string id, string type = "user", string token = null)
|
public string Login(string id, string type = "user", string token = null)
|
||||||
{
|
{
|
||||||
return Login(id, new[] { type }, token);
|
return Login(id, new[]
|
||||||
|
{
|
||||||
|
type
|
||||||
|
}, token);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -36,15 +39,8 @@ namespace SimApi.Helpers
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public string Login(string id, string[] type, string uuid = null)
|
public string Login(string id, string[] type, string uuid = null)
|
||||||
{
|
{
|
||||||
if (uuid == null)
|
uuid ??= Guid.NewGuid().ToString();
|
||||||
{
|
var loginItem = new SimApiLoginItem(id, type);
|
||||||
uuid = Guid.NewGuid().ToString();
|
|
||||||
}
|
|
||||||
var loginItem = new SimApiLoginItem
|
|
||||||
{
|
|
||||||
Id = id,
|
|
||||||
Type = type
|
|
||||||
};
|
|
||||||
Cache.SetString(uuid, JsonSerializer.Serialize(loginItem));
|
Cache.SetString(uuid, JsonSerializer.Serialize(loginItem));
|
||||||
return uuid;
|
return uuid;
|
||||||
}
|
}
|
||||||
@@ -60,6 +56,5 @@ namespace SimApi.Helpers
|
|||||||
Cache.Remove(uuid);
|
Cache.Remove(uuid);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
+27
-24
@@ -15,7 +15,7 @@ namespace SimApi.Helpers
|
|||||||
|
|
||||||
private string ServeUrl { get; }
|
private string ServeUrl { get; }
|
||||||
|
|
||||||
private string Bucket { get; }
|
public string Bucket { get; }
|
||||||
|
|
||||||
private IHttpContextAccessor HttpContextAccessor { get; }
|
private IHttpContextAccessor HttpContextAccessor { get; }
|
||||||
|
|
||||||
@@ -49,40 +49,43 @@ namespace SimApi.Helpers
|
|||||||
}
|
}
|
||||||
Mc = mcb.Build();
|
Mc = mcb.Build();
|
||||||
|
|
||||||
bool found = Mc.BucketExistsAsync(new BucketExistsArgs().WithBucket(Bucket)).Result;
|
var found = Mc.BucketExistsAsync(new BucketExistsArgs().WithBucket(Bucket)).Result;
|
||||||
if (!found)
|
if (!found)
|
||||||
{
|
{
|
||||||
Mc.MakeBucketAsync(new MakeBucketArgs().WithBucket(Bucket)).Wait();
|
Mc.MakeBucketAsync(new MakeBucketArgs().WithBucket(Bucket)).Wait();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 获取上传的URL
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="path"></param>
|
||||||
|
/// <param name="expire"></param>
|
||||||
|
/// <returns></returns>
|
||||||
public string GetUploadUrl(string path, int expire = 7200)
|
public string GetUploadUrl(string path, int expire = 7200)
|
||||||
{
|
{
|
||||||
try
|
return Mc.PresignedPutObjectAsync(new PresignedPutObjectArgs().WithBucket(Bucket)
|
||||||
{
|
.WithObject(path).WithExpiry(expire)).Result;
|
||||||
return Mc.PresignedPutObjectAsync(new PresignedPutObjectArgs().WithBucket(Bucket)
|
|
||||||
.WithObject(path).WithExpiry(expire)).Result;
|
|
||||||
}
|
|
||||||
catch (MinioException e)
|
|
||||||
{
|
|
||||||
Console.WriteLine("Error occurred: " + e);
|
|
||||||
return e.Message;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public string UploadFile(string path, Stream stream,string contentType = "image/png")
|
/// <summary>
|
||||||
|
/// 获取下载的URL
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="path"></param>
|
||||||
|
/// <param name="expire"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public string GetDownloadUrl(string path, int expire = 600)
|
||||||
{
|
{
|
||||||
try
|
return Mc.PresignedGetObjectAsync(new PresignedGetObjectArgs().WithBucket(Bucket).WithObject(path)
|
||||||
{
|
.WithExpiry(expire)).Result;
|
||||||
Mc.PutObjectAsync(new PutObjectArgs().WithBucket(Bucket).WithObject(path).
|
}
|
||||||
WithObjectSize(stream.Length).WithStreamData(stream).WithContentType(contentType)).Wait();
|
|
||||||
return null;
|
|
||||||
}
|
public string UploadFile(string path, Stream stream, string contentType = "image/png")
|
||||||
catch (MinioException e)
|
{
|
||||||
{
|
Mc.PutObjectAsync(new PutObjectArgs().WithBucket(Bucket).WithObject(path).WithObjectSize(stream.Length)
|
||||||
Console.WriteLine("Error occurred: " + e);
|
.WithStreamData(stream).WithContentType(contentType)).Wait();
|
||||||
return e.Message;
|
return null;
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public string FullUrl(string path)
|
public string FullUrl(string path)
|
||||||
|
|||||||
+16
-9
@@ -10,6 +10,22 @@ namespace SimApi.Helpers
|
|||||||
{
|
{
|
||||||
public static class SimApiUtil
|
public static class SimApiUtil
|
||||||
{
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 当前CST时间
|
||||||
|
/// </summary>
|
||||||
|
public static DateTime CstNow
|
||||||
|
{
|
||||||
|
get => DateTime.UtcNow.AddHours(8);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 当前秒级时间戳
|
||||||
|
/// </summary>
|
||||||
|
public static double TimestampNow
|
||||||
|
{
|
||||||
|
get => (DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds;
|
||||||
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 检测手机号是否正确
|
/// 检测手机号是否正确
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -53,14 +69,5 @@ namespace SimApi.Helpers
|
|||||||
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
|
Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// 获取 CST 当前时间
|
|
||||||
/// </summary>
|
|
||||||
/// <returns></returns>
|
|
||||||
public static DateTime GetCstNow()
|
|
||||||
{
|
|
||||||
return DateTime.UtcNow.AddHours(8);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1,5 +1,6 @@
|
|||||||
using System;
|
using System;
|
||||||
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Logging;
|
||||||
|
using SimApi.Helpers;
|
||||||
|
|
||||||
namespace SimApi.Logger
|
namespace SimApi.Logger
|
||||||
{
|
{
|
||||||
@@ -30,7 +31,7 @@ namespace SimApi.Logger
|
|||||||
_ => defautColor
|
_ => defautColor
|
||||||
};
|
};
|
||||||
Console.WriteLine(
|
Console.WriteLine(
|
||||||
$"[ {Name} ][ {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff")} ][ {logLevel.ToString()} ]");
|
$"[ {Name} ][ {SimApiUtil.CstNow.ToString("yyyy-MM-dd HH:mm:ss:ffff")} ][ {logLevel.ToString()} ]");
|
||||||
Console.ForegroundColor = defautColor;
|
Console.ForegroundColor = defautColor;
|
||||||
Console.WriteLine($"{state}");
|
Console.WriteLine($"{state}");
|
||||||
if (exception != null)
|
if (exception != null)
|
||||||
|
|||||||
@@ -14,6 +14,7 @@ namespace SimApi.Middlewares
|
|||||||
public class SimApiExceptionMiddleware
|
public class SimApiExceptionMiddleware
|
||||||
{
|
{
|
||||||
private RequestDelegate Next { get; }
|
private RequestDelegate Next { get; }
|
||||||
|
|
||||||
private ILogger<SimApiExceptionMiddleware> Log { get; }
|
private ILogger<SimApiExceptionMiddleware> Log { get; }
|
||||||
|
|
||||||
public SimApiExceptionMiddleware(RequestDelegate next, ILogger<SimApiExceptionMiddleware> log)
|
public SimApiExceptionMiddleware(RequestDelegate next, ILogger<SimApiExceptionMiddleware> log)
|
||||||
@@ -35,7 +36,10 @@ namespace SimApi.Middlewares
|
|||||||
await Next(context);
|
await Next(context);
|
||||||
if (context.Response.StatusCode != 200)
|
if (context.Response.StatusCode != 200)
|
||||||
{
|
{
|
||||||
if (!new[] {301, 302}.Contains(context.Response.StatusCode))
|
if (!new[]
|
||||||
|
{
|
||||||
|
301, 302
|
||||||
|
}.Contains(context.Response.StatusCode))
|
||||||
{
|
{
|
||||||
throw new SimApiException(context.Response.StatusCode);
|
throw new SimApiException(context.Response.StatusCode);
|
||||||
}
|
}
|
||||||
@@ -43,14 +47,9 @@ namespace SimApi.Middlewares
|
|||||||
}
|
}
|
||||||
catch (SimApiException ex)
|
catch (SimApiException ex)
|
||||||
{
|
{
|
||||||
if (string.IsNullOrEmpty(ex.Message))
|
response = string.IsNullOrEmpty(ex.Message)
|
||||||
{
|
? new SimApiBaseResponse(ex.Code)
|
||||||
response.SetCode(ex.Code);
|
: new SimApiBaseResponse(ex.Code, ex.Message);
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
response.SetCodeMsg(ex.Code, ex.Message);
|
|
||||||
}
|
|
||||||
|
|
||||||
ErrorResponse(context, response);
|
ErrorResponse(context, response);
|
||||||
}
|
}
|
||||||
@@ -58,7 +57,7 @@ namespace SimApi.Middlewares
|
|||||||
{
|
{
|
||||||
Log.LogError(ex.Message);
|
Log.LogError(ex.Message);
|
||||||
Log.LogError(ex.StackTrace);
|
Log.LogError(ex.StackTrace);
|
||||||
response.SetCodeMsg(500, ex.Message);
|
response = new SimApiBaseResponse(500, ex.Message);
|
||||||
ErrorResponse(context, response);
|
ErrorResponse(context, response);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -70,9 +69,12 @@ namespace SimApi.Middlewares
|
|||||||
/// <param name="response"></param>
|
/// <param name="response"></param>
|
||||||
private void ErrorResponse(HttpContext context, SimApiBaseResponse response)
|
private void ErrorResponse(HttpContext context, SimApiBaseResponse response)
|
||||||
{
|
{
|
||||||
context.Response.StatusCode = 200;
|
if (!context.Response.HasStarted)
|
||||||
context.Response.Headers.Add("Content-Type", "application/json");
|
{
|
||||||
context.Response.WriteAsync(response.ToString());
|
context.Response.StatusCode = 200;
|
||||||
|
context.Response.Headers.Add("Content-Type", "application/json");
|
||||||
|
context.Response.WriteAsync(response.ToString());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
+39
-24
@@ -1,33 +1,43 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using System.Text.Json;
|
using System.Text.Json;
|
||||||
|
using SimApi.Helpers;
|
||||||
|
|
||||||
namespace SimApi.Models
|
namespace SimApi.Models
|
||||||
{
|
{
|
||||||
public class SimApiBaseModel
|
public class SimApiBaseModel
|
||||||
{
|
{
|
||||||
protected virtual string[] MapperIgnoreField { get; set; } = {"Id", "CreatedAt", "UpdatedAt"};
|
protected virtual string[] MapperIgnoreField { get; set; } =
|
||||||
|
{
|
||||||
|
"Id", "CreatedAt", "UpdatedAt"
|
||||||
|
};
|
||||||
|
|
||||||
protected virtual string UpdatedTimeField { get; set; } = "UpdatedAt";
|
protected virtual string UpdatedTimeField { get; set; } = "UpdatedAt";
|
||||||
|
|
||||||
public void MapData<TS>(TS source, bool mapAll = false)
|
public void MapData<TS>(TS source, bool mapAll = false)
|
||||||
{
|
{
|
||||||
//获取要赋值的源数据不为null的项目
|
//获取要赋值的源数据不为null的项目
|
||||||
var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
|
var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
|
||||||
.Select(x => new {x.Name, x.PropertyType})
|
.Select(x => new
|
||||||
|
{
|
||||||
|
x.Name,
|
||||||
|
x.PropertyType
|
||||||
|
})
|
||||||
.ToDictionary(x => x.Name, x => x.PropertyType);
|
.ToDictionary(x => x.Name, x => x.PropertyType);
|
||||||
|
|
||||||
//获取目标对象的属性信息
|
//获取目标对象的属性信息
|
||||||
var targetProps = GetType().GetProperties().Select(x => new {x.Name, x.PropertyType})
|
var targetProps = GetType().GetProperties().Select(x => new
|
||||||
.ToDictionary(x => x.Name, x => x.PropertyType);
|
|
||||||
foreach (var sp in sourceProps)
|
|
||||||
{
|
|
||||||
//检查源对象不为空的属性是否在目标对象中存在
|
|
||||||
if (targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
|
|
||||||
(!MapperIgnoreField.Contains(sp.Key) || mapAll))
|
|
||||||
{
|
{
|
||||||
GetType().GetProperty(sp.Key)?
|
x.Name,
|
||||||
.SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
|
x.PropertyType
|
||||||
}
|
})
|
||||||
|
.ToDictionary(x => x.Name, x => x.PropertyType);
|
||||||
|
foreach (var sp in sourceProps.Where(sp =>
|
||||||
|
targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
|
||||||
|
(!MapperIgnoreField.Contains(sp.Key) || mapAll)))
|
||||||
|
{
|
||||||
|
GetType().GetProperty(sp.Key)?
|
||||||
|
.SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateTime();
|
UpdateTime();
|
||||||
@@ -37,21 +47,26 @@ namespace SimApi.Models
|
|||||||
{
|
{
|
||||||
//获取要赋值的源数据不为null的项目
|
//获取要赋值的源数据不为null的项目
|
||||||
var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
|
var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
|
||||||
.Select(x => new {x.Name, x.PropertyType})
|
.Select(x => new
|
||||||
|
{
|
||||||
|
x.Name,
|
||||||
|
x.PropertyType
|
||||||
|
})
|
||||||
.ToDictionary(x => x.Name, x => x.PropertyType);
|
.ToDictionary(x => x.Name, x => x.PropertyType);
|
||||||
|
|
||||||
//获取目标对象的属性信息
|
//获取目标对象的属性信息
|
||||||
var targetProps = GetType().GetProperties().Select(x => new {x.Name, x.PropertyType})
|
var targetProps = GetType().GetProperties().Select(x => new
|
||||||
.ToDictionary(x => x.Name, x => x.PropertyType);
|
|
||||||
foreach (var sp in sourceProps)
|
|
||||||
{
|
|
||||||
//检查源对象不为空的属性是否在目标对象中存在
|
|
||||||
if (targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
|
|
||||||
mapFields.Contains(sp.Key))
|
|
||||||
{
|
{
|
||||||
GetType().GetProperty(sp.Key)?
|
x.Name,
|
||||||
.SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
|
x.PropertyType
|
||||||
}
|
})
|
||||||
|
.ToDictionary(x => x.Name, x => x.PropertyType);
|
||||||
|
foreach (var sp in sourceProps.Where(sp =>
|
||||||
|
targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
|
||||||
|
mapFields.Contains(sp.Key)))
|
||||||
|
{
|
||||||
|
GetType().GetProperty(sp.Key)?
|
||||||
|
.SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateTime();
|
UpdateTime();
|
||||||
@@ -63,7 +78,7 @@ namespace SimApi.Models
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public void UpdateTime()
|
public void UpdateTime()
|
||||||
{
|
{
|
||||||
GetType().GetProperty(UpdatedTimeField)?.SetValue(this, DateTime.Now);
|
GetType().GetProperty(UpdatedTimeField)?.SetValue(this, SimApiUtil.CstNow);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
+4
-4
@@ -14,7 +14,7 @@
|
|||||||
<SynchReleaseVersion>false</SynchReleaseVersion>
|
<SynchReleaseVersion>false</SynchReleaseVersion>
|
||||||
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
|
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
|
||||||
<PackageVersion>5.0.2</PackageVersion>
|
<PackageVersion>5.0.2</PackageVersion>
|
||||||
<TargetFramework>net6.0</TargetFramework>
|
<TargetFrameworks>net6.0;net7.0</TargetFrameworks>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
@@ -27,9 +27,9 @@
|
|||||||
<Folder Include="Configurations\" />
|
<Folder Include="Configurations\" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="Minio" Version="4.0.2" />
|
<PackageReference Include="Minio" Version="4.0.7" />
|
||||||
<PackageReference Include="Swashbuckle.AspNetCore.Annotations" Version="6.3.1" />
|
<PackageReference Include="Swashbuckle.AspNetCore.Annotations" Version="6.5.0" />
|
||||||
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.3.1" />
|
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.5.0" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ProjectExtensions>
|
<ProjectExtensions>
|
||||||
<MonoDevelop>
|
<MonoDevelop>
|
||||||
|
|||||||
+9
-7
@@ -22,7 +22,14 @@ namespace SimApi
|
|||||||
{
|
{
|
||||||
var simApiOptions = new SimApiOptions();
|
var simApiOptions = new SimApiOptions();
|
||||||
options?.Invoke(simApiOptions);
|
options?.Invoke(simApiOptions);
|
||||||
|
if (simApiOptions.EnableLogger)
|
||||||
|
{
|
||||||
|
builder.AddLogging(logger =>
|
||||||
|
{
|
||||||
|
logger.ClearProviders();
|
||||||
|
logger.AddProvider(new SimApiLoggerProvider());
|
||||||
|
});
|
||||||
|
}
|
||||||
// 是否使用 AUTH
|
// 是否使用 AUTH
|
||||||
if (simApiOptions.EnableSimApiAuth)
|
if (simApiOptions.EnableSimApiAuth)
|
||||||
{
|
{
|
||||||
@@ -190,13 +197,8 @@ namespace SimApi
|
|||||||
public static IApplicationBuilder UseSimApi(this IApplicationBuilder builder)
|
public static IApplicationBuilder UseSimApi(this IApplicationBuilder builder)
|
||||||
{
|
{
|
||||||
var options = builder.ApplicationServices.GetRequiredService<SimApiOptions>();
|
var options = builder.ApplicationServices.GetRequiredService<SimApiOptions>();
|
||||||
if (options.EnableLogger)
|
|
||||||
{
|
|
||||||
builder.ApplicationServices.GetRequiredService<ILoggerFactory>()
|
|
||||||
.AddProvider(new SimApiLoggerProvider());
|
|
||||||
}
|
|
||||||
|
|
||||||
var logger = builder.ApplicationServices.GetRequiredService<ILogger<SimApiLogger>>();
|
var logger = builder.ApplicationServices.GetRequiredService<ILogger<SimApiOptions>>();
|
||||||
|
|
||||||
if (options.EnableForwardHeaders)
|
if (options.EnableForwardHeaders)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user