yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat 单独导出接口

Browse Source
This commit is contained in:
liguoyang
2025-04-18 13:45:10 +08:00
parent 61bf7e67e0
commit 4f9cd67fea
3 changed files with 82 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
Src/Dlhis.Canteen/Order/Controllers/BalancesController.cs
View File

@@ -36,6 +36,19 @@ public class BalancesController : ControllerBase
return await _balanceService.GetPageAsync(request);
}
/// <summary>
/// 数据导出
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
[HttpGet("export")]
[IgnoreTenant]
public async Task<List<BalanceRecordResponse>> GetPageToExportAsync([FromQuery] BalanceRecordPageRequest request)
{
return await _balanceService.GetPageToExportAsync(request);
}
/// <summary>
/// 修补餐补明细
/// </summary>

2
Src/Dlhis.Canteen/Order/Services/IBalanceService.cs
View File

@@ -8,6 +8,8 @@ public interface IBalanceService : IScopeDependency
{
Task<Pagination<BalanceRecordResponse>> GetPageAsync(BalanceRecordPageRequest request);
Task<List<BalanceRecordResponse>> GetPageToExportAsync(BalanceRecordPageRequest request);
Task<Pagination<BalanceRecordDeviceResponse>> GetPageByDeviceUniqueNoAsync(BalanceRecordPageByDeviceUniqueNoRequest request);
Task<BalanceRecordUserResultResponse> GetPageByUserAsync(BalanceRecordUserPageRequest request);

64
Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs
View File

@@ -57,20 +57,18 @@ public class BalanceService : IBalanceService
var page = await _dbContext.Queryable<BalanceRecordEntity>()
.LeftJoin<DepartmentEntity>((record, department) => record.DepartmentNo == department.No)
.LeftJoin<BusinessPlaceEntity>((record, department, bPlace) => record.BusinessPlaceCode == bPlace.Code)
.LeftJoin<CanteenOrderEntity>((record, department, bPlace, order) => record.No == order.No)
.WhereIF(request.Factory.IsPresent(), record => record.TenantId == request.Factory)
.WhereIF(request.SearchDateTimePeriod.HasValue(), record => record.CostDate >= request.SearchDateTimePeriod.Start && record.CostDate <= request.SearchDateTimePeriod.End)
.WhereIF(request.Factory.IsPresent(), record => record.TenantId == request.Factory)
.WhereIF(request.Type.HasValue, record => record.Type == request.Type)
.WhereIF(request.ShiftTypes.IsPresent(), record => request.ShiftTypes.Contains(record.ShiftType))
.WhereIF(request.UserCode.IsPresent(), record => record.UserCode == request.UserCode)
.WhereIF(request.UserName.IsPresent(), record => record.Name == request.UserName)
.WhereIF(request.FromFactory.IsPresent(), record => record.OriginTenantId == request.FromFactory)
.OrderBy(record => record.CreateTime, OrderByType.Desc)
.Select((record, department, bPlace, order) => new BalanceRecordResponse
.Select((record, department, bPlace) => new BalanceRecordResponse
{
Id = record.Id,
No = record.No,
IsOffline = order.IsOffline,
Amount = record.Amount,
CostDate = record.CostDate,
CostId = record.CostId,
@@ -111,6 +109,64 @@ public class BalanceService : IBalanceService
return page;
}
/// <inheritdoc />
public async Task<List<BalanceRecordResponse>> GetPageToExportAsync(BalanceRecordPageRequest request)
{
var rows = await _dbContext.Queryable<BalanceRecordEntity>()
.LeftJoin<DepartmentEntity>((record, department) => record.DepartmentNo == department.No)
.LeftJoin<BusinessPlaceEntity>((record, department, bPlace) => record.BusinessPlaceCode == bPlace.Code)
.WhereIF(request.SearchDateTimePeriod.HasValue(), record => record.CostDate >= request.SearchDateTimePeriod.Start && record.CostDate <= request.SearchDateTimePeriod.End)
.WhereIF(request.Factory.IsPresent(), record => record.TenantId == request.Factory)
.WhereIF(request.Type.HasValue, record => record.Type == request.Type)
.WhereIF(request.ShiftTypes.IsPresent(), record => request.ShiftTypes.Contains(record.ShiftType))
.WhereIF(request.UserCode.IsPresent(), record => record.UserCode == request.UserCode)
.WhereIF(request.UserName.IsPresent(), record => record.Name == request.UserName)
.WhereIF(request.FromFactory.IsPresent(), record => record.OriginTenantId == request.FromFactory)
.OrderBy(record => record.CreateTime, OrderByType.Desc)
.Select((record, department, bPlace) => new BalanceRecordResponse
{
Id = record.Id,
No = record.No,
Amount = record.Amount,
CostDate = record.CostDate,
CostId = record.CostId,
DepartmentNo = record.DepartmentNo,
DeviceInfo = record.DeviceUniqueNo,
UserNo = record.UserNo,
UserCode = record.UserCode,
Type = record.Type,
Status = record.Status,
Source = record.Source,
OriginTenantId = record.OriginTenantId,
Name = record.Name,
DepartmentName = department.Name,
BusinessPlaceName = bPlace.Name,
CostDateTime = record.CostDateTime,
Factory = record.TenantId,
ShiftType = record.ShiftType,
Remark = record.Remark,
Werks = record.Werks
})
.ToListAsync();
try
{
var tenants = await _tenantApi.GetTenantsInternalAsync();
rows.ForEach(item =>
{
item.OriginTenantId = tenants.FirstOrDefault(x => x.Code == item.OriginTenantId)?.Name;
item.Factory = tenants.FirstOrDefault(x => x.Code == item.Factory)?.Name;
});
}
catch (Exception)
{
//ignore
}
return rows;
}
public async Task RefundAsync(string no)
{
var cache = App.GetServiceProvider().GetService<RedisCache>();