93 lines
3.7 KiB
C#
93 lines
3.7 KiB
C#
using FreeSql;
|
|
using F9WebAiTest.Application.Common;
|
|
using F9WebAiTest.Application.Dtos.SYS.Gongyingshangs;
|
|
using F9WebAiTest.Application.Interfaces.Repositories.SYS.Gongyingshangs;
|
|
using F9WebAiTest.Domain.Entities.SYS.Gongyingshangs;
|
|
using F9WebAiTest.Domain.Enums.SYS.Gongyingshangs;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.Gongyingshangs;
|
|
|
|
namespace F9WebAiTest.Infrastructure.FreeSqls.Repositories.SYS.Gongyingshangs;
|
|
|
|
internal class GongyingshangWriteRepository : F9RepositoryBase, IGongyingshangWriteRepository
|
|
{
|
|
public GongyingshangWriteRepository(IFreeSql fsql) : base(fsql) { }
|
|
|
|
public async Task<Gongyingshang> GetByIdAsync(long id, CancellationToken cancellationToken)
|
|
=> await Orm.Select<Gongyingshang>().Where(x => x.Id == id && x.DeletedAt == null).FirstAsync(cancellationToken);
|
|
|
|
public async Task<bool> AddAsync(Gongyingshang entity)
|
|
{
|
|
entity.CreatedAt = DateTime.Now;
|
|
return await Orm.Insert(entity).ExecuteAffrowsAsync() > 0;
|
|
}
|
|
|
|
public async Task<bool> UpdateAsync(Gongyingshang entity)
|
|
{
|
|
entity.UpdatedAt = DateTime.Now;
|
|
return await Orm.Update<Gongyingshang>().SetSource(entity).ExecuteAffrowsAsync() > 0;
|
|
}
|
|
|
|
public async Task<bool> SoftDeleteAsync(long id)
|
|
=> await Orm.Update<Gongyingshang>()
|
|
.Set(x => x.IsDeleted, true)
|
|
.Set(x => x.DeletedAt, DateTime.Now)
|
|
.Where(x => x.Id == id)
|
|
.ExecuteAffrowsAsync() > 0;
|
|
}
|
|
|
|
internal class GongyingshangReadRepository : F9RepositoryBase, IGongyingshangReadRepository
|
|
{
|
|
public GongyingshangReadRepository(IFreeSql fsql) : base(fsql) { }
|
|
|
|
public async Task<PageResult<GongyingshangReadDto_View>> GetPagedAsync(Gys_Type_Enum type, Gys_SaleType_Enum? saleType,
|
|
string keyword, int pageIndex, int pageSize)
|
|
{
|
|
if (pageIndex <= 0) pageIndex = 1;
|
|
if (pageSize <= 0) pageSize = 20;
|
|
|
|
var query = Orm.Select<Gongyingshang>().Where(x => x.DeletedAt == null && x.Type == type);
|
|
if (saleType.HasValue) query = query.Where(x => x.SaleType == saleType.Value);
|
|
|
|
if (!string.IsNullOrWhiteSpace(keyword))
|
|
{
|
|
var kw = keyword.Trim();
|
|
query = query.Where(x => x.Name.Contains(kw) || x.Pinyin.Contains(kw) || x.Lianxiren.Contains(kw)
|
|
|| x.Phone.Contains(kw) || x.Address.Contains(kw));
|
|
}
|
|
|
|
var total = await query.CountAsync();
|
|
var items = await query
|
|
.OrderBy(x => x.Name)
|
|
.Page(pageIndex, pageSize)
|
|
.ToListAsync(x => new GongyingshangReadDto_View(x.Id, x.Name, x.Type, "", x.BusinessGroup, "",
|
|
x.SaleType, "", x.Lianxiren, x.Phone, x.Address, x.Pinyin));
|
|
|
|
var list = items
|
|
.Select(x => x with
|
|
{
|
|
TypeName = x.Type.ToString(),
|
|
Grouname = x.Group.ToString(),
|
|
SaleTypeName = SaleTypeText(x.SaleType)
|
|
})
|
|
.ToList();
|
|
|
|
return new PageResult<GongyingshangReadDto_View>
|
|
{
|
|
Items = list,
|
|
Total = total,
|
|
PageIndex = pageIndex,
|
|
PageSize = pageSize
|
|
};
|
|
}
|
|
|
|
public async Task<GongyingshangDto_Edit> GetByIdForEditAsync(long id)
|
|
=> await Orm.Select<Gongyingshang>()
|
|
.Where(x => x.Id == id && x.DeletedAt == null)
|
|
.FirstAsync(x => new GongyingshangDto_Edit(x.Id, x.Name, x.Type, x.BusinessGroup, x.SaleType,
|
|
x.Lianxiren, x.Phone, x.Address, x.Pinyin));
|
|
|
|
/// <summary>销售类型显示文本（0 等非枚举值视为未设置）</summary>
|
|
internal static string SaleTypeText(Gys_SaleType_Enum saleType)
|
|
=> Enum.IsDefined(typeof(Gys_SaleType_Enum), saleType) ? saleType.ToString() : "未设置";
|
|
}
|