using System.Linq.Dynamic.Core; using CMS.Plugin.HIAWms.Domain.WmsStores; using CMS.Plugin.HIAWms.EntityFrameworkCore.Extensions; using Microsoft.EntityFrameworkCore; using Volo.Abp.Domain.Repositories.EntityFrameworkCore; using Volo.Abp.EntityFrameworkCore; using Volo.Abp.Specifications; namespace CMS.Plugin.HIAWms.EntityFrameworkCore.Repositories; /// public class EfCoreWmsStoreRepository : EfCoreRepository, IWmsStoreRepository { /// /// Initializes a new instance of the class. /// /// The database context provider. public EfCoreWmsStoreRepository(IDbContextProvider dbContextProvider) : base(dbContextProvider) { } /// public virtual async Task FindByNameAsync(string storeCode, CancellationToken cancellationToken = default) { return await (await GetDbSetAsync()) .IncludeDetails() .Where(x => !x.IsDeleted) .OrderBy(t => t.Sort) .FirstOrDefaultAsync(t => t.StoreCode == storeCode, GetCancellationToken(cancellationToken)); } /// public async Task NameExistAsync(string storeCode, Guid? id = null) { return await (await GetDbSetAsync()).WhereIf(id.HasValue, p => p.Id != id).Where(x => !x.IsDeleted).AnyAsync(x => x.StoreCode == storeCode); } /// public async Task GetMaxSortAsync() { var hasAny = await (await GetQueryableAsync()) .Where(x => !x.IsDeleted).AnyAsync(); if (!hasAny) { return 1; } var sort = await (await GetQueryableAsync()) .Where(x => !x.IsDeleted).MaxAsync(x => x.Sort); return sort + 1; } /// public async Task> GetListAsync(WmsStore? store, string sorting = null, int maxResultCount = int.MaxValue, int skipCount = 0, string filter = null, Specification specification = null, bool includeDetails = false, CancellationToken cancellationToken = default) { specification ??= new WmsStoreSpecification(); return await (await GetDbSetAsync()) .IncludeDetails(includeDetails) .Where(specification.ToExpression()) .Where(x => !x.IsDeleted) .WhereIf(!filter.IsNullOrWhiteSpace(), u => u.StoreCode.Contains(filter)) .WhereIf(!string.IsNullOrEmpty(store.StoreCode),u=>u.StoreCode.Contains(store.StoreCode)) .WhereIf(!string.IsNullOrEmpty(store.StoreName),u=>u.StoreName.Contains(store.StoreName)) .OrderBy(sorting.IsNullOrEmpty() ? nameof(WmsStore.Sort) : sorting) .PageBy(skipCount, maxResultCount) .ToListAsync(GetCancellationToken(cancellationToken)); } /// /// ²éѯ²Ö¿âÁбí /// /// /// public async Task> GetListForSelectAsync( CancellationToken cancellationToken = default) { return await (await GetDbSetAsync()) .Where(x=>!x.IsDeleted) .ToListAsync(GetCancellationToken(cancellationToken)); } /// public async Task GetCountAsync(WmsStore? store, string filter = null, Specification specification = null, CancellationToken cancellationToken = default) { specification ??= new WmsStoreSpecification(); return await (await GetQueryableAsync()) .Where(specification.ToExpression()) .Where(x => !x.IsDeleted) .WhereIf(!filter.IsNullOrWhiteSpace(), u => u.StoreCode.Contains(filter)) .WhereIf(!string.IsNullOrEmpty(store.StoreCode), u => u.StoreCode.Contains(store.StoreCode)) .WhereIf(!string.IsNullOrEmpty(store.StoreName), u => u.StoreName.Contains(store.StoreName)) .CountAsync(cancellationToken: GetCancellationToken(cancellationToken)); } /// public override async Task> WithDetailsAsync() { return (await GetQueryableAsync()) .Where(x => !x.IsDeleted).IncludeDetails(); } }