504 lines
16 KiB
C#
504 lines
16 KiB
C#
using AutoMapper;
|
||
using DouyinApi.Common;
|
||
using DouyinApi.Common.HttpContextUser;
|
||
using DouyinApi.Common.Https.HttpPolly;
|
||
using DouyinApi.Common.Option;
|
||
using DouyinApi.EventBus;
|
||
using DouyinApi.EventBus.EventHandling;
|
||
using DouyinApi.Extensions;
|
||
using DouyinApi.Filter;
|
||
using DouyinApi.IServices;
|
||
using DouyinApi.Model;
|
||
using DouyinApi.Model.Models;
|
||
using DouyinApi.Model.ViewModels;
|
||
using Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.Extensions.Options;
|
||
using RabbitMQ.Client;
|
||
using RabbitMQ.Client.Events;
|
||
using System.ComponentModel.DataAnnotations;
|
||
using System.Linq.Expressions;
|
||
using System.Text;
|
||
using DouyinApi.Common.Caches.Interface;
|
||
using DouyinApi.Common.Utility;
|
||
|
||
namespace DouyinApi.Controllers
|
||
{
|
||
/// <summary>
|
||
/// Values控制器
|
||
/// </summary>
|
||
[Route("api/[controller]/[action]")]
|
||
[ApiController]
|
||
//[Authorize]
|
||
//[Authorize(Roles = "Admin,Client")]
|
||
//[Authorize(Policy = "SystemOrAdmin")]
|
||
//[Authorize(PermissionNames.Permission)]
|
||
[Authorize]
|
||
public class ValuesController : BaseApiController
|
||
{
|
||
private IMapper _mapper;
|
||
private readonly IAdvertisementServices _advertisementServices;
|
||
private readonly Love _love;
|
||
private readonly IRoleModulePermissionServices _roleModulePermissionServices;
|
||
private readonly IUser _user;
|
||
private readonly IPasswordLibServices _passwordLibServices;
|
||
readonly IBlogArticleServices _blogArticleServices;
|
||
private readonly IHttpPollyHelper _httpPollyHelper;
|
||
private readonly IRabbitMQPersistentConnection _persistentConnection;
|
||
private readonly SeqOptions _seqOptions;
|
||
private readonly ICaching _cache;
|
||
|
||
public ValuesController(IBlogArticleServices blogArticleServices, IMapper mapper, IAdvertisementServices advertisementServices, Love love,
|
||
IRoleModulePermissionServices roleModulePermissionServices, IUser user, IPasswordLibServices passwordLibServices,
|
||
IHttpPollyHelper httpPollyHelper, IRabbitMQPersistentConnection persistentConnection, IOptions<SeqOptions> seqOptions, ICaching caching)
|
||
{
|
||
// 测试 Authorize 和 mapper
|
||
_mapper = mapper;
|
||
_advertisementServices = advertisementServices;
|
||
_love = love;
|
||
_roleModulePermissionServices = roleModulePermissionServices;
|
||
// 测试 Httpcontext
|
||
_user = user;
|
||
// 测试多库
|
||
_passwordLibServices = passwordLibServices;
|
||
// 测试AOP加载顺序，配合 return
|
||
_blogArticleServices = blogArticleServices;
|
||
// 测试redis消息队列
|
||
_blogArticleServices = blogArticleServices;
|
||
// httpPolly
|
||
_httpPollyHelper = httpPollyHelper;
|
||
_persistentConnection = persistentConnection;
|
||
_cache = caching;
|
||
_seqOptions = seqOptions.Value;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试Rabbit消息队列发送
|
||
/// </summary>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public IActionResult TestRabbitMqPublish()
|
||
{
|
||
if (!_persistentConnection.IsConnected)
|
||
{
|
||
_persistentConnection.TryConnect();
|
||
}
|
||
|
||
_persistentConnection.PublishMessage("Hello, RabbitMQ!", exchangeName: "blogcore", routingKey: "myRoutingKey");
|
||
return Ok();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试Rabbit消息队列订阅
|
||
/// </summary>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public IActionResult TestRabbitMqSubscribe()
|
||
{
|
||
if (!_persistentConnection.IsConnected)
|
||
{
|
||
_persistentConnection.TryConnect();
|
||
}
|
||
|
||
_persistentConnection.StartConsuming("myQueue");
|
||
return Ok();
|
||
}
|
||
|
||
private async Task<bool> Dealer(string exchange, string routingKey, byte[] msgBody, IDictionary<string, object> headers)
|
||
{
|
||
await Task.CompletedTask;
|
||
Console.WriteLine("我是消费者，这里消费了一条信息是：" + Encoding.UTF8.GetString(msgBody));
|
||
return true;
|
||
}
|
||
|
||
[HttpGet]
|
||
public MessageModel<List<ClaimDto>> MyClaims()
|
||
{
|
||
return new MessageModel<List<ClaimDto>>()
|
||
{
|
||
success = true,
|
||
response = (_user.GetClaimsIdentity().ToList()).Select(d =>
|
||
new ClaimDto
|
||
{
|
||
Type = d.Type,
|
||
Value = d.Value
|
||
}
|
||
).ToList()
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试SqlSugar二级缓存
|
||
/// 可设置过期时间
|
||
/// 或通过接口方式更新该数据，也会离开清除缓存
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task<BlogArticle> TestSqlsugarWithCache()
|
||
{
|
||
return await _blogArticleServices.QueryById("1", true);
|
||
}
|
||
|
||
/// <summary>
|
||
/// Get方法
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
// GET api/values
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task<MessageModel<ResponseEnum>> Get()
|
||
{
|
||
var data = new MessageModel<ResponseEnum>();
|
||
|
||
/*
|
||
* 测试 sql 查询
|
||
*/
|
||
var queryBySql =
|
||
await _blogArticleServices.QuerySql(
|
||
"SELECT bsubmitter,btitle,bcontent,bCreateTime FROM BlogArticle WHERE bID>5");
|
||
|
||
/*
|
||
* 测试按照指定列查询
|
||
*/
|
||
var queryByColums = await _blogArticleServices
|
||
.Query<BlogViewModels>(it => new BlogViewModels() { btitle = it.btitle });
|
||
|
||
/*
|
||
* 测试按照指定列查询带多条件和排序方法
|
||
*/
|
||
Expression<Func<BlogArticle, bool>> registerInfoWhere = a => a.btitle == "xxx" && a.bRemark == "XXX";
|
||
var queryByColumsByMultiTerms = await _blogArticleServices
|
||
.Query<BlogArticle>(it => new BlogArticle() { btitle = it.btitle }, registerInfoWhere, "bID Desc");
|
||
|
||
/*
|
||
* 测试 sql 更新
|
||
*
|
||
* 【SQL参数】：@bID:5
|
||
* @bsubmitter:laozhang619
|
||
* @IsDeleted:False
|
||
* 【SQL语句】：UPDATE `BlogArticle` SET
|
||
* `bsubmitter`=@bsubmitter,`IsDeleted`=@IsDeleted WHERE `bID`=@bID
|
||
*/
|
||
var updateSql = await _blogArticleServices.Update(new
|
||
{ bsubmitter = $"laozhang{DateTime.Now.Millisecond}", IsDeleted = false, bID = 5 });
|
||
|
||
|
||
// 测试 AOP 缓存
|
||
var blogArticles = await _blogArticleServices.GetBlogs();
|
||
|
||
|
||
// 测试多表联查
|
||
var roleModulePermissions = await _roleModulePermissionServices.QueryMuchTable();
|
||
|
||
|
||
// 测试多个异步执行时间
|
||
var roleModuleTask = _roleModulePermissionServices.Query();
|
||
var listTask = _advertisementServices.Query();
|
||
var ad = await roleModuleTask;
|
||
var list = await listTask;
|
||
|
||
|
||
// 测试service层返回异常
|
||
_advertisementServices.ReturnExp();
|
||
|
||
return data;
|
||
}
|
||
|
||
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task<MessageModel<List<BlogArticle>>> Test_Aop_Cache()
|
||
{
|
||
// 测试 AOP 缓存
|
||
var blogArticles = await _blogArticleServices.GetBlogs();
|
||
|
||
if (blogArticles.Any())
|
||
{
|
||
return Success(blogArticles);
|
||
}
|
||
|
||
return Failed<List<BlogArticle>>();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试Redis消息队列
|
||
/// </summary>
|
||
/// <param name="_redisBasketRepository"></param>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task RedisMq([FromServices] IRedisBasketRepository _redisBasketRepository)
|
||
{
|
||
var msg = $"这里是一条日志{DateTime.Now}";
|
||
await _redisBasketRepository.ListLeftPushAsync(RedisMqKey.Loging, msg);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试RabbitMQ事件总线
|
||
/// </summary>
|
||
/// <param name="_eventBus"></param>
|
||
/// <param name="blogId"></param>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public void EventBusTry([FromServices] IEventBus _eventBus, string blogId = "1")
|
||
{
|
||
var blogDeletedEvent = new BlogQueryIntegrationEvent(blogId);
|
||
|
||
_eventBus.Publish(blogDeletedEvent);
|
||
}
|
||
|
||
/// <summary>
|
||
/// Get(int id)方法
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
// GET api/values/5
|
||
[HttpGet("{id}")]
|
||
[AllowAnonymous]
|
||
[TypeFilter(typeof(UseServiceDIAttribute), Arguments = new object[] { "laozhang" })]
|
||
public ActionResult<string> Get(int id)
|
||
{
|
||
var loveu = _love.SayLoveU();
|
||
|
||
return "value";
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试参数是必填项
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[Route("/api/values/RequiredPara")]
|
||
public string RequiredP([Required] string id)
|
||
{
|
||
return id;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 通过 HttpContext 获取用户信息
|
||
/// </summary>
|
||
/// <param name="ClaimType">声明类型，默认 jti </param>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[Route("/api/values/UserInfo")]
|
||
public MessageModel<List<string>> GetUserInfo(string ClaimType = "jti")
|
||
{
|
||
var getUserInfoByToken = _user.GetUserInfoFromToken(ClaimType);
|
||
return new MessageModel<List<string>>()
|
||
{
|
||
success = _user.IsAuthenticated(),
|
||
msg = _user.IsAuthenticated() ? _user.Name.ObjToString() : "未登录",
|
||
response = _user.GetClaimValueByType(ClaimType)
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// to redirect by route template name.
|
||
/// </summary>
|
||
[HttpGet("/api/custom/go-destination")]
|
||
[AllowAnonymous]
|
||
public void Source()
|
||
{
|
||
var url = Url.RouteUrl("Destination_Route");
|
||
Response.Redirect(url);
|
||
}
|
||
|
||
/// <summary>
|
||
/// route with template name.
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet("/api/custom/destination", Name = "Destination_Route")]
|
||
[AllowAnonymous]
|
||
public string Destination()
|
||
{
|
||
return "555";
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 测试 post 一个对象 + 独立参数
|
||
/// </summary>
|
||
/// <param name="blogArticle">model实体类参数</param>
|
||
/// <param name="id">独立参数</param>
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public object Post([FromBody] BlogArticle blogArticle, int id)
|
||
{
|
||
return Ok(new { success = true, data = blogArticle, id = id });
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 测试 post 参数
|
||
/// </summary>
|
||
/// <param name="name"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public object TestPostPara(string name)
|
||
{
|
||
return Ok(new { success = true, name = name });
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试多库连接
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet("TestMutiDBAPI")]
|
||
[AllowAnonymous]
|
||
public async Task<object> TestMutiDBAPI()
|
||
{
|
||
// 从主库中，操作blogs
|
||
var blogs = await _blogArticleServices.Query(d => d.bID == 1);
|
||
var addBlog = await _blogArticleServices.Add(new BlogArticle() { });
|
||
|
||
// 从从库中，操作pwds
|
||
var pwds = await _passwordLibServices.Query(d => d.PLID > 0);
|
||
var addPwd = await _passwordLibServices.Add(new PasswordLib() { });
|
||
|
||
return new
|
||
{
|
||
blogs,
|
||
pwds
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试Fulent做参数校验
|
||
/// </summary>
|
||
/// <param name="param"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public async Task<string> FluentVaTest([FromBody] UserRegisterVo param)
|
||
{
|
||
await Task.CompletedTask;
|
||
return "Okay";
|
||
}
|
||
|
||
/// <summary>
|
||
/// Put方法
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="value"></param>
|
||
// PUT api/values/5
|
||
[HttpPut("{id}")]
|
||
public void Put(int id, [FromBody] string value)
|
||
{
|
||
}
|
||
|
||
/// <summary>
|
||
/// Delete方法
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
// DELETE api/values/5
|
||
[HttpDelete("{id}")]
|
||
public void Delete(int id)
|
||
{
|
||
}
|
||
|
||
#region Apollo 配置
|
||
|
||
/// <summary>
|
||
/// 测试接入Apollo获取配置信息
|
||
/// </summary>
|
||
[HttpGet("/apollo")]
|
||
[AllowAnonymous]
|
||
public async Task<IEnumerable<KeyValuePair<string, string>>> GetAllConfigByAppllo(
|
||
[FromServices] IConfiguration configuration)
|
||
{
|
||
return await Task.FromResult(configuration.AsEnumerable());
|
||
}
|
||
|
||
/// <summary>
|
||
/// 通过此处的key格式为 xx:xx:x
|
||
/// </summary>
|
||
[HttpGet("/apollo/{key}")]
|
||
[AllowAnonymous]
|
||
public async Task<string> GetConfigByAppllo(string key)
|
||
{
|
||
return await Task.FromResult(AppSettings.app(key));
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region HttpPolly
|
||
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public async Task<string> HttpPollyPost()
|
||
{
|
||
var response = await _httpPollyHelper.PostAsync(HttpEnum.LocalHost, "/api/ElasticDemo/EsSearchTest",
|
||
"{\"from\": 0,\"size\": 10,\"word\": \"非那雄安\"}");
|
||
|
||
return response;
|
||
}
|
||
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task<string> HttpPollyGet()
|
||
{
|
||
return await _httpPollyHelper.GetAsync(HttpEnum.LocalHost,
|
||
"/api/ElasticDemo/GetDetailInfo?esid=3130&esindex=chinacodex");
|
||
}
|
||
|
||
#endregion
|
||
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public string TestEnum(EnumDemoDto dto) => dto.Type.ToString();
|
||
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public string TestOption()
|
||
{
|
||
return _seqOptions.ToJson();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取雪花Id
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public long GetSnowflakeId()
|
||
{
|
||
return IdGeneratorUtility.NextId();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 测试缓存
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
[AllowAnonymous]
|
||
public async Task<MessageModel<string>> TestCacheAsync()
|
||
{
|
||
await _cache.SetAsync("test", "test", new TimeSpan(0, 10, 0));
|
||
|
||
var result = await _cache.GetAsync<string>("test");
|
||
if (!"test".Equals(result))
|
||
{
|
||
return Failed("缓存失败,值不一样");
|
||
}
|
||
|
||
var count = _cache.GetAllCacheKeys().Count;
|
||
if (count <= 0)
|
||
{
|
||
return Failed("缓存失败,数量不对");
|
||
}
|
||
|
||
return Success<string>("");
|
||
}
|
||
}
|
||
|
||
public class ClaimDto
|
||
{
|
||
public string Type { get; set; }
|
||
public string Value { get; set; }
|
||
}
|
||
} |