feat 消费记录查询
This commit is contained in:
cheche
@@ -1,6 +1,7 @@
|
||||
using Dlhis.Canteen.Order.Request;
|
||||
using Dlhis.Canteen.Order.Response;
|
||||
using Kurisu.Core.DataAccess.Dto;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
|
||||
namespace Dlhis.Canteen.Order.Services;
|
||||
|
||||
@@ -13,4 +14,14 @@ public interface IBalanceService : IScopeDependency
|
||||
Task<Pagination<BalanceRecordUserResponse>> GetPageByUserAsync(BalanceRecordUserPageRequest request);
|
||||
|
||||
Task ObsoluteAsync(BalanceRecordObsoluteRequest request);
|
||||
|
||||
Task<Pagination<BalanceRecordResponse>> RecordByCostIdAsync(BalanceRecordPageByCostIdRequest request);
|
||||
|
||||
Task<Pagination<BalanceRecordResponse>> RecordPageDetailsAsync(BalanceRecordPageDetailsRequest request);
|
||||
|
||||
Task<List<BalanceRecordSummaryRespones>> BalanceRecordSummaryByNoAsync(BalanceRecordSummaryRequest request);
|
||||
|
||||
Task<List<BalanceRecordSummaryRespones>> BalanceRecordSummaryByTidAsync(BalanceRecordSummaryRequest request);
|
||||
|
||||
Task<List<BalanceRecordAnalysisRespones>> BalanceRecordAnalysisAsync(BalanceRecordAnalysisRequest request);
|
||||
}
|
||||
|
||||
@@ -10,7 +10,11 @@ using Kurisu.Core.User.Abstractions;
|
||||
using Kurisu.SqlSugar.Attributes;
|
||||
using Kurisu.SqlSugar.Extensions;
|
||||
using Kurisu.SqlSugar.Services;
|
||||
using Mapster;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using SqlSugar;
|
||||
using System.Linq;
|
||||
using System.Numerics;
|
||||
|
||||
namespace Dlhis.Canteen.Order.Services.Implements;
|
||||
|
||||
@@ -67,6 +71,304 @@ public class BalanceService : IBalanceService
|
||||
|
||||
return page;
|
||||
}
|
||||
/// <summary>
|
||||
/// 根据成本中心
|
||||
/// </summary>
|
||||
/// <param name="request"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<Pagination<BalanceRecordResponse>> RecordByCostIdAsync(BalanceRecordPageByCostIdRequest request)
|
||||
{
|
||||
var pageinfo = await _dbContext.Queryable<BalanceRecordEntity>()
|
||||
.LeftJoin<DepartmentEntity>((record, department) => record.DepartmentNo == department.No)
|
||||
.LeftJoin<CanteenBusinessPlaceEntity>((record, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
||||
.LeftJoin<CanteenBusinessShiftEntity>((record, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
||||
.Where(record => record.CostId == request.CostId)
|
||||
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
||||
.Select((record, department, bplace, bshift) => new BalanceRecordResponse
|
||||
{
|
||||
Id = record.Id,
|
||||
Amount = record.Amount,
|
||||
BusinessPlaceCode = record.BusinessPlaceCode,
|
||||
BusinessShiftCode = record.BusinessShiftCode,
|
||||
CostDate = record.CostDate,
|
||||
CostId = record.CostId,
|
||||
DepartmentNo = record.DepartmentNo,
|
||||
DeviceInfo = record.DeviceInfo,
|
||||
IP = record.IP,
|
||||
UserNo = record.UserNo,
|
||||
UserCode = record.UserCode,
|
||||
Type = record.Type,
|
||||
SubsidiesFromMonth = record.SubsidiesFromMonth,
|
||||
Status = record.Status,
|
||||
Source = record.Source,
|
||||
No = record.No,
|
||||
IsCostCrossTenant = record.IsCostCrossTenant,
|
||||
OriginTenantId = record.OriginTenantId,
|
||||
Name = record.Name,
|
||||
DepartmentName = department.Name,
|
||||
BusinessPlaceName = bplace.Name,
|
||||
BusinessShiftName = bshift.Name,
|
||||
CostDateTime = record.CreateTime // todo
|
||||
})
|
||||
.ToPageListAsync(request);
|
||||
|
||||
return pageinfo;
|
||||
}
|
||||
/// <summary>
|
||||
/// 消费明细
|
||||
/// </summary>
|
||||
/// <param name="request"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<Pagination<BalanceRecordResponse>> RecordPageDetailsAsync(BalanceRecordPageDetailsRequest request)
|
||||
{
|
||||
var paeginfo = await _dbContext.Queryable<BalanceRecordEntity>()
|
||||
.LeftJoin<DepartmentEntity>((record, department) => record.DepartmentNo == department.No)
|
||||
.LeftJoin<CanteenBusinessPlaceEntity>((record, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
||||
.LeftJoin<CanteenBusinessShiftEntity>((record, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
||||
.WhereIF(!request.Name.IsEmpty(), record => record.Name == request.Name)
|
||||
.WhereIF(!request.DepartmentNo.IsEmpty(), record => record.DepartmentNo == request.DepartmentNo)
|
||||
.WhereIF(!request.UserCode.IsEmpty(), record => record.UserCode == request.UserCode)
|
||||
.WhereIF(request.Type.HasValue, record => record.Type == request.Type)
|
||||
.WhereIF(request.BusinessShiftCode.HasValue, record => record.BusinessShiftCode == request.BusinessShiftCode)
|
||||
.WhereIF(request.BusinessPlaceCode.HasValue, record => record.BusinessPlaceCode == request.BusinessPlaceCode)
|
||||
.WhereIF(request.StartDatetime.HasValue, record => record.CostDateTime >= request.StartDatetime)
|
||||
.WhereIF(request.EndDatetime.HasValue, record => record.CostDateTime <= request.EndDatetime)
|
||||
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
||||
.Select((record, department, bplace, bshift) => new BalanceRecordResponse
|
||||
{
|
||||
Id = record.Id,
|
||||
Amount = record.Amount,
|
||||
BusinessPlaceCode = record.BusinessPlaceCode,
|
||||
BusinessShiftCode = record.BusinessShiftCode,
|
||||
CostDate = record.CostDate,
|
||||
CostId = record.CostId,
|
||||
DepartmentNo = record.DepartmentNo,
|
||||
DeviceInfo = record.DeviceInfo,
|
||||
IP = record.IP,
|
||||
UserNo = record.UserNo,
|
||||
UserCode = record.UserCode,
|
||||
Type = record.Type,
|
||||
SubsidiesFromMonth = record.SubsidiesFromMonth,
|
||||
Status = record.Status,
|
||||
Source = record.Source,
|
||||
No = record.No,
|
||||
IsCostCrossTenant = record.IsCostCrossTenant,
|
||||
OriginTenantId = record.OriginTenantId,
|
||||
Name = record.Name,
|
||||
DepartmentName = department.Name,
|
||||
BusinessPlaceName = bplace.Name,
|
||||
BusinessShiftName = bshift.Name,
|
||||
CostDateTime = record.CreateTime // todo
|
||||
})
|
||||
.ToPageListAsync(request);
|
||||
|
||||
return paeginfo;
|
||||
}
|
||||
/// <summary>
|
||||
/// 消费汇总 根据部门号
|
||||
/// </summary>
|
||||
/// <param name="request"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<List<BalanceRecordSummaryRespones>> BalanceRecordSummaryByNoAsync(BalanceRecordSummaryRequest request)
|
||||
{
|
||||
|
||||
var shiftCodeDict = await GetShiftCode();
|
||||
|
||||
var paeginfos = await _dbContext.Queryable<BalanceRecordEntity>()
|
||||
.WhereIF(!request.DepartmentNo.IsEmpty(), record => record.DepartmentNo == request.DepartmentNo)
|
||||
.WhereIF(!request.UserCode.IsEmpty(), record => record.UserCode == request.UserCode)
|
||||
.WhereIF(!request.OriginTenantId.IsEmpty(), record => record.TenantId == request.OriginTenantId)
|
||||
.WhereIF(request.StartDatetime.HasValue, record => record.CostDateTime >= request.StartDatetime)
|
||||
.WhereIF(request.EndDatetime.HasValue, record => record.CostDateTime <= request.EndDatetime)
|
||||
.Where(record => record.CostId == request.CostId)
|
||||
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
||||
.ToListAsync();
|
||||
|
||||
var lst = new List<BalanceRecordSummaryRespones>();
|
||||
|
||||
foreach (var departmentGroup in paeginfos.GroupBy(record => record.DepartmentNo))
|
||||
{
|
||||
// 每个部门
|
||||
var obj = new BalanceRecordSummaryRespones
|
||||
{
|
||||
DepartmentNo = departmentGroup.Key,
|
||||
CostId = request.CostId
|
||||
};
|
||||
|
||||
// 在部门内部再次按照餐次分组
|
||||
foreach (var businessShiftGroup in departmentGroup.GroupBy(x => x.BusinessShiftCode))
|
||||
{
|
||||
// 每个餐次人数
|
||||
obj.BreakfastNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]);
|
||||
|
||||
obj.LunchNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]);
|
||||
|
||||
obj.DinnerNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]);
|
||||
|
||||
obj.LateNightNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]);
|
||||
|
||||
// 每个餐次单价
|
||||
obj.BreakfastPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.LunchPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.DinnerPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.LateNightPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).FirstOrDefault()?.Amount ?? 0;
|
||||
|
||||
// 每个餐次金额
|
||||
obj.BreakfastAmount = obj.BreakfastPrice * obj.BreakfastNumberOfPeople;
|
||||
obj.LunchAmount = obj.LunchNumberOfPeople * obj.LunchPrice;
|
||||
obj.DinnerAmount = obj.DinnerNumberOfPeople * obj.DinnerPrice;
|
||||
obj.LateNightAmount = obj.LateNightPrice * obj.LateNightNumberOfPeople;
|
||||
//obj.BreakfastAmount = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Sum(x => x.Amount);
|
||||
|
||||
//obj.LunchAmount = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Sum(x => x.Amount);
|
||||
|
||||
//obj.DinnerAmount = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Sum(x => x.Amount);
|
||||
|
||||
//obj.LateNightAmount = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Sum(x => x.Amount);
|
||||
|
||||
|
||||
|
||||
// 每个部门餐次中的 OriginTenantId
|
||||
obj.OriginTenantId = businessShiftGroup.FirstOrDefault()?.OriginTenantId;
|
||||
}
|
||||
|
||||
// 总人数 总金额
|
||||
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
||||
obj.TotalAmount = obj.BreakfastAmount + obj.LunchAmount + obj.DinnerAmount + obj.LateNightAmount;
|
||||
lst.Add(obj);
|
||||
}
|
||||
|
||||
return lst;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 消费汇总 根据人事范围
|
||||
/// </summary>
|
||||
/// <param name="request"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<List<BalanceRecordSummaryRespones>> BalanceRecordSummaryByTidAsync(BalanceRecordSummaryRequest request)
|
||||
{
|
||||
var shiftCodeDict = await GetShiftCode();
|
||||
|
||||
var paeginfos = await _dbContext.Queryable<BalanceRecordEntity>()
|
||||
.WhereIF(!request.DepartmentNo.IsEmpty(), record => record.DepartmentNo == request.DepartmentNo)
|
||||
.WhereIF(!request.UserCode.IsEmpty(), record => record.UserCode == request.UserCode)
|
||||
.WhereIF(!request.OriginTenantId.IsEmpty(), record => record.TenantId == request.OriginTenantId)
|
||||
.WhereIF(request.StartDatetime.HasValue, record => record.CostDateTime >= request.StartDatetime)
|
||||
.WhereIF(request.EndDatetime.HasValue, record => record.CostDateTime <= request.EndDatetime)
|
||||
.Where(record => record.CostId == request.CostId)
|
||||
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
||||
.ToListAsync();
|
||||
|
||||
var lst = new List<BalanceRecordSummaryRespones>();
|
||||
|
||||
foreach (var originTenantIdGroup in paeginfos.GroupBy(record => record.OriginTenantId))
|
||||
{
|
||||
// 每个人事范围
|
||||
var obj = new BalanceRecordSummaryRespones
|
||||
{
|
||||
OriginTenantId = originTenantIdGroup.Key,
|
||||
CostId = request.CostId,
|
||||
DepartmentNo = originTenantIdGroup.First().DepartmentNo
|
||||
};
|
||||
|
||||
// 在人事范围内部再次按照餐次分组
|
||||
foreach (var businessShiftGroup in originTenantIdGroup.GroupBy(x => x.BusinessShiftCode))
|
||||
{
|
||||
// 每个餐次人数
|
||||
obj.BreakfastNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]);
|
||||
|
||||
obj.LunchNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]);
|
||||
|
||||
obj.DinnerNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]);
|
||||
|
||||
obj.LateNightNumberOfPeople = businessShiftGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]);
|
||||
|
||||
// 每个餐次单价
|
||||
obj.BreakfastPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.LunchPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.DinnerPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).FirstOrDefault()?.Amount ?? 0;
|
||||
obj.LateNightPrice = businessShiftGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).FirstOrDefault()?.Amount ?? 0;
|
||||
|
||||
// 每个餐次金额
|
||||
obj.BreakfastAmount = obj.BreakfastPrice * obj.BreakfastNumberOfPeople;
|
||||
obj.LunchAmount = obj.LunchNumberOfPeople * obj.LunchPrice;
|
||||
obj.DinnerAmount = obj.DinnerNumberOfPeople * obj.DinnerPrice;
|
||||
obj.LateNightAmount = obj.LateNightPrice * obj.LateNightNumberOfPeople;
|
||||
|
||||
}
|
||||
|
||||
// 总人数 总金额
|
||||
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
||||
obj.TotalAmount = obj.BreakfastAmount + obj.LunchAmount + obj.DinnerAmount + obj.LateNightAmount;
|
||||
lst.Add(obj);
|
||||
}
|
||||
|
||||
return lst;
|
||||
}
|
||||
|
||||
private async Task<Dictionary<string, string>> GetShiftCode()
|
||||
{
|
||||
var list = await _dbContext.Queryable<CanteenBusinessShiftEntity>().ToListAsync();
|
||||
|
||||
var shiftCodeDict = new Dictionary<string, string>();
|
||||
|
||||
var breakfastCode = list.FirstOrDefault(x => x.Name == "早餐")?.Code.ToString();
|
||||
var lunchCode = list.FirstOrDefault(x => x.Name == "午餐")?.Code.ToString();
|
||||
var dinnerCode = list.FirstOrDefault(x => x.Name == "晚餐")?.Code.ToString();
|
||||
var lateNightCode = list.FirstOrDefault(x => x.Name == "宵夜")?.Code.ToString();
|
||||
|
||||
shiftCodeDict.Add("Breakfast", breakfastCode);
|
||||
shiftCodeDict.Add("Lunch", lunchCode);
|
||||
shiftCodeDict.Add("Dinner", dinnerCode);
|
||||
shiftCodeDict.Add("LateNight", lateNightCode);
|
||||
|
||||
return shiftCodeDict;
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 用餐分析
|
||||
/// </summary>
|
||||
/// <param name="request"></param>
|
||||
/// <returns></returns>
|
||||
public async Task<List<BalanceRecordAnalysisRespones>> BalanceRecordAnalysisAsync(BalanceRecordAnalysisRequest request)
|
||||
{
|
||||
var shiftCodeDict = await GetShiftCode();
|
||||
|
||||
|
||||
var pageinfo = await _dbContext.Queryable<BalanceRecordEntity>()
|
||||
.WhereIF(request.StartDatetime.HasValue, record => record.CostDateTime >= request.StartDatetime)
|
||||
.WhereIF(request.EndDatetime.HasValue, record => record.CostDateTime <= request.EndDatetime)
|
||||
.WhereIF(request.BusinessPlaceCode.HasValue, record => record.BusinessPlaceCode == request.BusinessPlaceCode).ToListAsync();
|
||||
|
||||
var lst = new List<BalanceRecordAnalysisRespones>();
|
||||
foreach (var first in pageinfo.GroupBy(record => record.CostDateTime.ToString("yyyy-MM-dd")))
|
||||
{
|
||||
var obj = new BalanceRecordAnalysisRespones()
|
||||
{
|
||||
CostDate = DateOnly.FromDateTime(Convert.ToDateTime(first.Key)),
|
||||
};
|
||||
foreach (var second in first.GroupBy(x=>x.BusinessShiftCode))
|
||||
{
|
||||
|
||||
obj.BreakfastNumberOfPeople=second.Count(x=>second.Key.ToString() == shiftCodeDict["Breakfast"]);
|
||||
|
||||
obj.LunchNumberOfPeople = second.Count(x => second.Key.ToString() == shiftCodeDict["Lunch"]);
|
||||
|
||||
obj.DinnerNumberOfPeople = second.Count(x => second.Key.ToString() == shiftCodeDict["Dinner"]);
|
||||
|
||||
obj.LateNightNumberOfPeople = second.Count(x => second.Key.ToString() == shiftCodeDict["LateNight"]);
|
||||
|
||||
}
|
||||
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
||||
lst.Add(obj);
|
||||
}
|
||||
return lst;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
[IgnoreTenant]
|
||||
public async Task<Pagination<BalanceRecordResponse>> GetPageByDeviceUniqueNoAsync(BalanceRecordPageByDeviceUniqueNoRequest request)
|
||||
|
||||
Reference in New Issue
Block a user