Skip to content

Commit

Permalink
✨增加分表测试
Browse files Browse the repository at this point in the history
  • Loading branch information
@LemonNoCry
LemonNoCry committed Dec 31, 2024
1 parent bdb7ca1 commit 0960f8e
Showing 1 changed file with 182 additions and 140 deletions.
322 changes: 182 additions & 140 deletions Blog.Core.Api/Controllers/SplitDemoController.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,91 +5,174 @@
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using System.Linq.Expressions;
using Blog.Core.Controllers;
using SqlSugar;

namespace Blog.Core.Api.Controllers
namespace Blog.Core.Api.Controllers;

/// <summary>
/// 分表demo
/// </summary>
[Route("api/[controller]/[action]")]
[ApiController]
[Authorize(Permissions.Name)]
public class SplitDemoController : BaseApiController
{
readonly ISplitDemoServices splitDemoServices;
readonly IUnitOfWorkManage unitOfWorkManage;
private readonly ISqlSugarClient _db;

public SplitDemoController(ISplitDemoServices _splitDemoServices, IUnitOfWorkManage _unitOfWorkManage, ISqlSugarClient db)
{
splitDemoServices = _splitDemoServices;
unitOfWorkManage = _unitOfWorkManage;
_db = db;
}

/// <summary>
/// 分页获取数据
/// </summary>
/// <param name="beginTime"></param>
/// <param name="endTime"></param>
/// <param name="page"></param>
/// <param name="key"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
[HttpGet]
[AllowAnonymous]
public async Task<MessageModel<PageModel<SplitDemo>>> Get(DateTime beginTime, DateTime endTime, int page = 1, string key = "",
int pageSize = 10)
{
if (string.IsNullOrEmpty(key) || string.IsNullOrWhiteSpace(key))
{
key = "";
}

Expression<Func<SplitDemo, bool>> whereExpression = a => (a.Name != null && a.Name.Contains(key));
var data = await splitDemoServices.QueryPageSplit(whereExpression, beginTime, endTime, page, pageSize, " Id desc ");
return MessageModel<PageModel<SplitDemo>>.Message(data.dataCount >= 0, "获取成功", data);
}

[HttpGet]
[AllowAnonymous]
public async Task<MessageModel<List<SplitDemo>>> GetSpilt()
{
var data = await _db.Queryable<SplitDemo>().AS("SplitDemo_20241231").ToListAsync();
return Success(data);
}

/// <summary>
/// 分表demo
/// 根据ID获取信息
/// </summary>
[Route("api/[controller]/[action]")]
[ApiController]
[Authorize(Permissions.Name)]
public class SplitDemoController : ControllerBase
/// <param name="id"></param>
/// <returns></returns>
[HttpGet]
[AllowAnonymous]
public async Task<MessageModel<SplitDemo>> GetById(long id)
{
readonly ISplitDemoServices splitDemoServices;
readonly IUnitOfWorkManage unitOfWorkManage;
public SplitDemoController(ISplitDemoServices _splitDemoServices, IUnitOfWorkManage _unitOfWorkManage)
var data = new MessageModel<string>();
var model = await splitDemoServices.QueryByIdSplit(id);
if (model != null)
{
return MessageModel<SplitDemo>.Success("获取成功", model);
}
else
{
splitDemoServices = _splitDemoServices;
unitOfWorkManage = _unitOfWorkManage;
return MessageModel<SplitDemo>.Fail("获取失败");
}
}

/// <summary>
/// 分页获取数据
/// </summary>
/// <param name="beginTime"></param>
/// <param name="endTime"></param>
/// <param name="page"></param>
/// <param name="key"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
[HttpGet]
[AllowAnonymous]
public async Task<MessageModel<PageModel<SplitDemo>>> Get(DateTime beginTime, DateTime endTime, int page = 1, string key = "", int pageSize = 10)
[HttpPost]
[AllowAnonymous]
public async Task<MessageModel> GenTestData()
{
//帮我生成一个月数据
for (int i = 0; i < 30; i++)
{
if (string.IsNullOrEmpty(key) || string.IsNullOrWhiteSpace(key))
await splitDemoServices.AddSplit(new SplitDemo()
{
key = "";
}
Expression<Func<SplitDemo, bool>> whereExpression = a => (a.Name != null && a.Name.Contains(key));
var data = await splitDemoServices.QueryPageSplit(whereExpression, beginTime, endTime, page, pageSize, " Id desc ");
return MessageModel<PageModel<SplitDemo>>.Message(data.dataCount >= 0, "获取成功", data);
Name = "测试数据" + i,
CreateTime = DateTime.Now.AddDays(-i)
});
}

/// <summary>
/// 根据ID获取信息
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[HttpGet]
[AllowAnonymous]
public async Task<MessageModel<SplitDemo>> GetById(long id)
return Success();
}

[HttpPost]
[AllowAnonymous]
public async Task<MessageModel> InitTable()
{
_db.MappingTables.Add("SplitDemo","SplitDemo_20241231");
_db.CodeFirst.InitTables<SplitDemo>();
await Task.Delay(1);
return Success();
}

/// <summary>
/// 添加一条测试数据
/// </summary>
/// <param name="splitDemo"></param>
/// <returns></returns>
[HttpPost]
[AllowAnonymous]
public async Task<MessageModel<string>> Post([FromBody] SplitDemo splitDemo)
{
var data = new MessageModel<string>();
//unitOfWorkManage.BeginTran();
var id = (await splitDemoServices.AddSplit(splitDemo));
data.success = (id == null ? false : true);
try
{
var data = new MessageModel<string>();
var model = await splitDemoServices.QueryByIdSplit(id);
if (model != null)
if (data.success)
{
return MessageModel<SplitDemo>.Success("获取成功", model);
data.response = id.FirstOrDefault().ToString();
data.msg = "添加成功";
}
else
{
return MessageModel<SplitDemo>.Fail("获取失败");
data.msg = "添加失败";
}
}
catch (Exception)
{
throw;
}
finally
{
//if (data.success)
// unitOfWorkManage.CommitTran();
//else
// unitOfWorkManage.RollbackTran();
}

return data;
}

/// <summary>
/// 添加一条测试数据
/// </summary>
/// <param name="splitDemo"></param>
/// <returns></returns>
[HttpPost]
[AllowAnonymous]
public async Task<MessageModel<string>> Post([FromBody] SplitDemo splitDemo)
/// <summary>
/// 修改一条测试数据
/// </summary>
/// <param name="splitDemo"></param>
/// <returns></returns>
[HttpPut]
[AllowAnonymous]
public async Task<MessageModel<string>> Put([FromBody] SplitDemo splitDemo)
{
var data = new MessageModel<string>();
if (splitDemo != null && splitDemo.Id > 0)
{
var data = new MessageModel<string>();
//unitOfWorkManage.BeginTran();
var id = (await splitDemoServices.AddSplit(splitDemo));
data.success = (id == null ? false : true);
unitOfWorkManage.BeginTran();
data.success = await splitDemoServices.UpdateSplit(splitDemo, splitDemo.CreateTime);
try
{
if (data.success)
{
data.response = id.FirstOrDefault().ToString();
data.msg = "添加成功";
data.msg = "修改成功";
data.response = splitDemo?.Id.ObjToString();
}
else
{
data.msg = "添加失败";
data.msg = "修改失败";
}
}
catch (Exception)
Expand All @@ -98,102 +181,61 @@ public async Task<MessageModel<string>> Post([FromBody] SplitDemo splitDemo)
}
finally
{
//if (data.success)
// unitOfWorkManage.CommitTran();
//else
// unitOfWorkManage.RollbackTran();
if (data.success)
unitOfWorkManage.CommitTran();
else
unitOfWorkManage.RollbackTran();
}
return data;
}

/// <summary>
/// 修改一条测试数据
/// </summary>
/// <param name="splitDemo"></param>
/// <returns></returns>
[HttpPut]
[AllowAnonymous]
public async Task<MessageModel<string>> Put([FromBody] SplitDemo splitDemo)
return data;
}

/// <summary>
/// 根据id删除数据
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[HttpDelete]
[AllowAnonymous]
public async Task<MessageModel<string>> Delete(long id)
{
var data = new MessageModel<string>();

var model = await splitDemoServices.QueryByIdSplit(id);
if (model != null)
{
var data = new MessageModel<string>();
if (splitDemo != null && splitDemo.Id > 0)
unitOfWorkManage.BeginTran();
data.success = await splitDemoServices.DeleteSplit(model, model.CreateTime);
try
{
unitOfWorkManage.BeginTran();
data.success = await splitDemoServices.UpdateSplit(splitDemo, splitDemo.CreateTime);
try
{
if (data.success)
{
data.msg = "修改成功";
data.response = splitDemo?.Id.ObjToString();
}
else
{
data.msg = "修改失败";
}
}
catch (Exception)
data.response = id.ObjToString();
if (data.success)
{
throw;
data.msg = "删除成功";
}
finally
else
{
if (data.success)
unitOfWorkManage.CommitTran();
else
unitOfWorkManage.RollbackTran();
data.msg = "删除失败";
}
}
return data;
}

/// <summary>
/// 根据id删除数据
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[HttpDelete]
[AllowAnonymous]
public async Task<MessageModel<string>> Delete(long id)
{
var data = new MessageModel<string>();

var model = await splitDemoServices.QueryByIdSplit(id);
if (model != null)
catch (Exception)
{
unitOfWorkManage.BeginTran();
data.success = await splitDemoServices.DeleteSplit(model,model.CreateTime);
try
{
data.response = id.ObjToString();
if (data.success)
{
data.msg = "删除成功";
}
else
{
data.msg = "删除失败";
}

}
catch (Exception)
{
throw;
}
finally
{
if (data.success)
unitOfWorkManage.CommitTran();
else
unitOfWorkManage.RollbackTran();
}
throw;
}
else
finally
{
data.msg = "不存在";
if (data.success)
unitOfWorkManage.CommitTran();
else
unitOfWorkManage.RollbackTran();
}
return data;

}
else
{
data.msg = "不存在";
}

return data;
}
}
}

0 comments on commit 0960f8e

Please sign in to comment.