docs: 完善sqlsugar文档

This commit is contained in:
yubaolee
2025-05-08 14:54:03 +08:00
parent 6ae0c4b9b2
commit 6ef7c91896
4 changed files with 156 additions and 121 deletions

View File

@@ -6,9 +6,7 @@ using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
using OpenAuth.Repository.Domain;
using SqlSugar;
namespace OpenAuth.App
{
public class WmsInboundOrderDtblApp : SqlSugarBaseApp<WmsInboundOrderDtbl>
@@ -18,13 +16,11 @@ namespace OpenAuth.App
/// </summary>
public async Task<TableData> Load(QueryWmsInboundOrderDtblListReq request)
{
var loginContext = _auth.GetCurrentUser();
if (loginContext == null)
{
throw new CommonException("登录已过期", Define.INVALID_TOKEN);
}
var properties = loginContext.GetTableColumns("WmsInboundOrderDtbl");
if (properties == null || properties.Count == 0)
{
@@ -36,12 +32,10 @@ namespace OpenAuth.App
{
objs = objs.Where(u => u.OrderId == request.InboundOrderId);
}
if (!string.IsNullOrEmpty(request.key))
{
objs = objs.Where(u => u.GoodsId.Contains(request.key));
}
var propertyStr = string.Join(',', properties.Select(u => u.ColumnName));
result.columnFields = properties;
result.data = objs.OrderBy(u => u.Id)
@@ -50,17 +44,9 @@ namespace OpenAuth.App
result.count = await objs.CountAsync();
return result;
}
public void Add(AddOrUpdateWmsInboundOrderDtblReq req)
public void Add(AddOrUpdateWmsInboundOrderDtblReq request)
{
SugarClient.Ado.BeginTran();
AddNoSave(req);
SugarClient.Ado.CommitTran();
}
public void AddNoSave(AddOrUpdateWmsInboundOrderDtblReq req)
{
var obj = req.MapTo<WmsInboundOrderDtbl>();
var obj = request.MapTo<WmsInboundOrderDtbl>();
//todo:补充或调整自己需要的字段
obj.CreateTime = DateTime.Now;
var user = _auth.GetCurrentUser().User;
@@ -69,36 +55,33 @@ namespace OpenAuth.App
obj.CreateUserName = user.Name;
SugarClient.Insertable(obj).ExecuteCommand();
}
public void Update(AddOrUpdateWmsInboundOrderDtblReq obj)
public void Update(AddOrUpdateWmsInboundOrderDtblReq request)
{
var user = _auth.GetCurrentUser().User;
Repository.Update(u => new WmsInboundOrderDtbl
{
Price = obj.Price,
PriceNoTax = obj.PriceNoTax,
InStockStatus = obj.InStockStatus,
AsnStatus = obj.AsnStatus,
GoodsId = obj.GoodsId,
GoodsBatch = obj.GoodsBatch,
QualityFlg = obj.QualityFlg,
OrderNum = obj.OrderNum,
InNum = obj.InNum,
LeaveNum = obj.LeaveNum,
HoldNum = obj.HoldNum,
ProdDate = obj.ProdDate,
ExpireDate = obj.ExpireDate,
TaxRate = obj.TaxRate,
OwnerId = obj.OwnerId,
Remark = obj.Remark,
Price = request.Price,
PriceNoTax = request.PriceNoTax,
InStockStatus = request.InStockStatus,
AsnStatus = request.AsnStatus,
GoodsId = request.GoodsId,
GoodsBatch = request.GoodsBatch,
QualityFlg = request.QualityFlg,
OrderNum = request.OrderNum,
InNum = request.InNum,
LeaveNum = request.LeaveNum,
HoldNum = request.HoldNum,
ProdDate = request.ProdDate,
ExpireDate = request.ExpireDate,
TaxRate = request.TaxRate,
OwnerId = request.OwnerId,
Remark = request.Remark,
UpdateTime = DateTime.Now,
UpdateUserId = user.Id,
UpdateUserName = user.Name
//todo:补充或调整自己需要的字段
}, u => u.Id == obj.Id);
}, u => u.Id == request.Id);
}
public WmsInboundOrderDtblApp(ISqlSugarClient client, IAuth auth) : base(client, auth)
{
}

View File

@@ -7,14 +7,11 @@ using OpenAuth.App.Request;
using OpenAuth.App.Response;
using OpenAuth.Repository.Domain;
using SqlSugar;
namespace OpenAuth.App
{
public class WmsInboundOrderTblApp : SqlSugarBaseApp<WmsInboundOrderTbl>
{
private WmsInboundOrderDtblApp _wmsInboundOrderDtblApp;
/// <summary>
/// 加载列表
/// </summary>
@@ -25,29 +22,22 @@ namespace OpenAuth.App
{
throw new CommonException("登录已过期", Define.INVALID_TOKEN);
}
var columns = loginContext.GetTableColumns("WmsInboundOrderTbl");
if (columns == null || columns.Count == 0)
{
throw new Exception("请在代码生成界面配置WmsInboundOrderTbl表的字段属性");
}
var result = new TableData();
result.columnFields = columns;
var objs = GetDataPrivilege("u");
if (!string.IsNullOrEmpty(request.key))
{
objs = objs.Where(u => u.Id.Contains(request.key));
}
if (!string.IsNullOrEmpty(request.sqlWhere))
{
objs = objs.Where(request.sqlWhere);
}
var propertyStr = string.Join(',', columns.Select(u => u.ColumnName));
result.data = objs.OrderBy(u => u.Id)
.Skip((request.page - 1) * request.limit)
@@ -55,88 +45,81 @@ namespace OpenAuth.App
result.count = await objs.CountAsync();
return result;
}
public void Add(AddOrUpdateWmsInboundOrderTblReq req)
public void Add(AddOrUpdateWmsInboundOrderTblReq request)
{
var obj = req.MapTo<WmsInboundOrderTbl>();
var obj = request.MapTo<WmsInboundOrderTbl>();
//todo:补充或调整自己需要的字段
obj.CreateTime = DateTime.Now;
var user = _auth.GetCurrentUser().User;
obj.CreateUserId = user.Id;
obj.CreateUserName = user.Name;
SugarClient.Ado.BeginTran();
SugarClient.Insertable(obj).ExecuteCommand();
if (req.WmsInboundOrderDtblReqs != null && req.WmsInboundOrderDtblReqs.Any())
if(obj.KeyIsNull()) //如果主键为空,则生成默认值
{
foreach (var detail in req.WmsInboundOrderDtblReqs)
{
detail.OrderId = obj.Id;
_wmsInboundOrderDtblApp.AddNoSave(detail);
}
obj.GenerateDefaultKeyVal();
}
SugarClient.Ado.CommitTran();
}
public void Update(AddOrUpdateWmsInboundOrderTblReq obj)
{
var user = _auth.GetCurrentUser().User;
SugarClient.Ado.BeginTran();
if (obj.WmsInboundOrderDtblReqs != null && obj.WmsInboundOrderDtblReqs.Any())
SugarClient.Insertable(obj).ExecuteCommand();
if (request.WmsInboundOrderDtblReqs != null && request.WmsInboundOrderDtblReqs.Any())
{
//id为空的添加
foreach (var detail in obj.WmsInboundOrderDtblReqs.Where(u => string.IsNullOrEmpty(u.Id)))
foreach (var detail in request.WmsInboundOrderDtblReqs)
{
detail.OrderId = obj.Id;
_wmsInboundOrderDtblApp.AddNoSave(detail);
_wmsInboundOrderDtblApp.Add(detail);
}
}
SugarClient.Ado.CommitTran();
}
public void Update(AddOrUpdateWmsInboundOrderTblReq request)
{
var user = _auth.GetCurrentUser().User;
SugarClient.Ado.BeginTran();
if (request.WmsInboundOrderDtblReqs != null && request.WmsInboundOrderDtblReqs.Any())
{
//id为空的添加
foreach (var detail in request.WmsInboundOrderDtblReqs.Where(u => string.IsNullOrEmpty(u.Id)))
{
detail.OrderId = request.Id;
_wmsInboundOrderDtblApp.Add(detail);
}
//id比数据库少的删除
var containids = obj.WmsInboundOrderDtblReqs.Select(u => u.Id)
var containids = request.WmsInboundOrderDtblReqs.Select(u => u.Id)
.Where(u => !string.IsNullOrEmpty(u)).ToList();
if (containids.Any())
{
SugarClient.Deleteable<WmsInboundOrderDtbl>(u => (!containids.Contains(u.Id)) && u.OrderId == obj.Id).ExecuteCommand();
SugarClient.Deleteable<WmsInboundOrderDtbl>(u => (!containids.Contains(u.Id)) && u.OrderId == request.Id).ExecuteCommand();
}
//更新id相同的
foreach (var detail in obj.WmsInboundOrderDtblReqs.Where(u => !string.IsNullOrEmpty(u.Id)))
foreach (var detail in request.WmsInboundOrderDtblReqs.Where(u => !string.IsNullOrEmpty(u.Id)))
{
_wmsInboundOrderDtblApp.Update(detail);
}
}
Repository.Update(u => new WmsInboundOrderTbl
{
ExternalNo = obj.ExternalNo,
ExternalType = obj.ExternalType,
Status = obj.Status,
OrderType = obj.OrderType,
GoodsType = obj.GoodsType,
PurchaseNo = obj.PurchaseNo,
StockId = obj.StockId,
OwnerId = obj.OwnerId,
ShipperId = obj.ShipperId,
SupplierId = obj.SupplierId,
ScheduledInboundTime = obj.ScheduledInboundTime,
Remark = obj.Remark,
Enable = obj.Enable,
TransferType = obj.TransferType,
InBondedArea = obj.InBondedArea,
ReturnBoxNum = obj.ReturnBoxNum,
ExternalNo = request.ExternalNo,
ExternalType = request.ExternalType,
Status = request.Status,
OrderType = request.OrderType,
GoodsType = request.GoodsType,
PurchaseNo = request.PurchaseNo,
StockId = request.StockId,
OwnerId = request.OwnerId,
ShipperId = request.ShipperId,
SupplierId = request.SupplierId,
ScheduledInboundTime = request.ScheduledInboundTime,
Remark = request.Remark,
Enable = request.Enable,
TransferType = request.TransferType,
InBondedArea = request.InBondedArea,
ReturnBoxNum = request.ReturnBoxNum,
UpdateTime = DateTime.Now,
UpdateUserId = user.Id,
UpdateUserName = user.Name
//todo:补充或调整自己需要的字段
}, u => u.Id == obj.Id);
}, u => u.Id == request.Id);
SugarClient.Ado.CommitTran();
}
public WmsInboundOrderTblApp(ISqlSugarClient client, IAuth auth,
WmsInboundOrderDtblApp wmsInboundOrderDtblApp) : base(client, auth)
{