772 lines
37 KiB
C#
772 lines
37 KiB
C#
using Dlhis.Canteen.Order.Request;
|
|
using Dlhis.Canteen.Order.Response;
|
|
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Canteen.Entities;
|
|
using Dlhis.Entity.Canteen.Enums;
|
|
using Dlhis.Entity.Device.Entities;
|
|
using Dlhis.Entity.Device.Enums;
|
|
using Kurisu.AspNetCore.UnifyResultAndValidation;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.DataAccess.Dto;
|
|
using Kurisu.Core.DataAccess.Entity;
|
|
using Kurisu.Core.User.Abstractions;
|
|
using Kurisu.SqlSugar.Attributes;
|
|
using Kurisu.SqlSugar.Extensions;
|
|
using Kurisu.SqlSugar.Services;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using SqlSugar;
|
|
using System.Globalization;
|
|
|
|
namespace Dlhis.Canteen.Order.Services.Implements;
|
|
|
|
public class BalanceService : IBalanceService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ICurrentUser _currentUser;
|
|
private readonly ILogger<BalanceService> _logger;
|
|
|
|
public BalanceService(IDbContext dbContext, ICurrentUser currentUser, ILogger<BalanceService> logger)
|
|
{
|
|
_dbContext = dbContext;
|
|
_currentUser = currentUser;
|
|
_logger = logger;
|
|
}
|
|
|
|
public async Task<Pagination<BalanceRecordResponse>> GetPageAsync(BalanceRecordPageRequest request)
|
|
{
|
|
var page = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
|
|
.LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
|
|
.LeftJoin<BusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<BusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
|
.LeftJoin<BasicTypeEntity>((record, ga, department, bplace, bshift, type) => record.BusinessShiftCode.ToString() == type.Code)
|
|
.WhereIF(request.SearchDateTimePeriod?.Start.HasValue == true, record => record.CostDate >= request.SearchDateTimePeriod.Start)
|
|
.WhereIF(request.SearchDateTimePeriod?.End.HasValue == true, record => record.CostDate <= request.SearchDateTimePeriod.End)
|
|
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
|
.Select((record, ga, department, bplace, bshift, type) => 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 = type.Display,
|
|
CostDateTime = record.CreateTime // todo
|
|
})
|
|
.ToPageListAsync(request);
|
|
|
|
return page;
|
|
}
|
|
/// <summary>
|
|
/// 根据成本中心
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public async Task<Pagination<BalanceRecordCostIdResponse>> RecordByCostIdAsync(BalanceRecordPageByCostIdRequest request)
|
|
{
|
|
var shiftCodeDict = await GetShiftCode();
|
|
|
|
var paeginfos = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.WhereIF(!request.UserCode.IsEmpty(), record => record.UserCode == request.UserCode)
|
|
.WhereIF(!request.DepartmentNo.IsEmpty(), record => record.DepartmentNo == request.DepartmentNo)
|
|
.WhereIF(!request.OriginTenantId.IsEmpty(), record => record.OriginTenantId == request.OriginTenantId)
|
|
.WhereIF(!request.CostId.IsEmpty(), record => record.CostId == request.CostId)
|
|
.WhereIF(request.StartDatetime.HasValue, record => record.CostDateTime >= request.StartDatetime)
|
|
.WhereIF(request.EndDatetime.HasValue, record => record.CostDateTime <= request.EndDatetime)
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out)
|
|
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
|
.ToListAsync();
|
|
|
|
var lst = new List<BalanceRecordCostIdResponse>();
|
|
foreach (var costIdGroup in paeginfos.GroupBy(record => record.CostId))
|
|
{
|
|
//每个costID
|
|
var obj = new BalanceRecordCostIdResponse
|
|
{
|
|
CostId = costIdGroup.Key
|
|
};
|
|
|
|
// 所有人次
|
|
var BreakfastNumberOfPeople = costIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]);
|
|
|
|
var LunchNumberOfPeople = costIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]);
|
|
|
|
var DinnerNumberOfPeople = costIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]);
|
|
|
|
var LateNightNumberOfPeople = costIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]);
|
|
// 每个餐次人数
|
|
obj.BreakfastNumberOfPeople = costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LunchNumberOfPeople = costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.DinnerNumberOfPeople = costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LateNightNumberOfPeople = costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Select(x => x.UserNo).Distinct().Count();
|
|
|
|
//餐次金额
|
|
obj.BreakfastAmount = Math.Abs(costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Sum(x => x.Amount));
|
|
obj.LunchAmount = Math.Abs(costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Sum(x => x.Amount));
|
|
obj.DinnerAmount = Math.Abs(costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Sum(x => x.Amount));
|
|
obj.LateNightAmount = Math.Abs(costIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Sum(x => x.Amount));
|
|
|
|
|
|
// 每个餐次单价
|
|
obj.BreakfastPrice = BreakfastNumberOfPeople == 0 ? 0 : Math.Round(obj.BreakfastAmount / BreakfastNumberOfPeople, 2);
|
|
obj.LunchPrice = LunchNumberOfPeople == 0 ? 0 : Math.Round(obj.LunchAmount / LunchNumberOfPeople, 2);
|
|
obj.DinnerPrice = DinnerNumberOfPeople == 0 ? 0 : Math.Round(obj.DinnerAmount / DinnerNumberOfPeople, 2);
|
|
obj.LateNightPrice = LateNightNumberOfPeople == 0 ? 0 : Math.Round(obj.LateNightAmount / LateNightNumberOfPeople, 2);
|
|
|
|
// 总人数 总金额
|
|
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
|
obj.TotalAmount = obj.BreakfastAmount + obj.LunchAmount + obj.DinnerAmount + obj.LateNightAmount;
|
|
|
|
lst.Add(obj);
|
|
}
|
|
|
|
// 分页操作
|
|
var startIndex = (request.PageIndex - 1) * request.PageSize;
|
|
var pagedData = lst.Skip(startIndex).Take(request.PageSize).ToList();
|
|
|
|
var pagination = new Pagination<BalanceRecordCostIdResponse>
|
|
{
|
|
PageIndex = request.PageIndex,
|
|
PageSize = request.PageSize,
|
|
Total = lst.Count, // 使用原始列表的总数进行分页
|
|
Data = pagedData
|
|
};
|
|
|
|
return pagination;
|
|
}
|
|
|
|
/// <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<BusinessPlaceEntity>((record, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<BusinessShiftEntity>((record, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
|
.LeftJoin<BasicTypeEntity>((record, department, bplace, bshift, type) => record.BusinessShiftCode.ToString() == type.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, type) => 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 = type.Display,
|
|
CostDateTime = record.CreateTime // todo
|
|
})
|
|
.ToPageListAsync(request);
|
|
|
|
return paeginfo;
|
|
}
|
|
/// <summary>
|
|
/// 消费汇总 根据部门号
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public async Task<Pagination<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)
|
|
.WhereIF(!request.CostId.IsEmpty(), record => record.CostId == request.CostId)
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out)
|
|
.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,
|
|
OriginTenantId = ""
|
|
};
|
|
// 所有人次
|
|
var BreakfastNumberOfPeople = departmentGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]);
|
|
|
|
var LunchNumberOfPeople = departmentGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]);
|
|
|
|
var DinnerNumberOfPeople = departmentGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]);
|
|
|
|
var LateNightNumberOfPeople = departmentGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]);
|
|
//每个餐次人数
|
|
obj.BreakfastNumberOfPeople = departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LunchNumberOfPeople = departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.DinnerNumberOfPeople = departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LateNightNumberOfPeople = departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Select(x => x.UserNo).Distinct().Count();
|
|
|
|
//餐次金额
|
|
obj.BreakfastAmount = Math.Abs(departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Sum(x => x.Amount));
|
|
obj.LunchAmount = Math.Abs(departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Sum(x => x.Amount));
|
|
obj.DinnerAmount = Math.Abs(departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Sum(x => x.Amount));
|
|
obj.LateNightAmount = Math.Abs(departmentGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Sum(x => x.Amount));
|
|
|
|
// 每个餐次单价
|
|
obj.BreakfastPrice = BreakfastNumberOfPeople == 0 ? 0 : Math.Round(obj.BreakfastAmount / BreakfastNumberOfPeople, 2);
|
|
obj.LunchPrice = LunchNumberOfPeople == 0 ? 0 : Math.Round(obj.LunchAmount / LunchNumberOfPeople, 2);
|
|
obj.DinnerPrice = DinnerNumberOfPeople == 0 ? 0 : Math.Round(obj.DinnerAmount / DinnerNumberOfPeople, 2);
|
|
obj.LateNightPrice = LateNightNumberOfPeople == 0 ? 0 : Math.Round(obj.LateNightAmount / LateNightNumberOfPeople, 2);
|
|
|
|
// 总人数 总金额
|
|
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
|
obj.TotalAmount = obj.BreakfastAmount + obj.LunchAmount + obj.DinnerAmount + obj.LateNightAmount;
|
|
lst.Add(obj);
|
|
}
|
|
|
|
// 分页操作
|
|
var startIndex = (request.PageIndex - 1) * request.PageSize;
|
|
var pagedData = lst.Skip(startIndex).Take(request.PageSize).ToList();
|
|
|
|
var pagination = new Pagination<BalanceRecordSummaryRespones>
|
|
{
|
|
PageIndex = request.PageIndex,
|
|
PageSize = request.PageSize,
|
|
Total = lst.Count, // 使用原始列表的总数进行分页
|
|
Data = pagedData
|
|
};
|
|
|
|
return pagination;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 消费汇总 根据人事范围
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public async Task<Pagination<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)
|
|
.WhereIF(!request.CostId.IsEmpty(), record => record.CostId == request.CostId)
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out)
|
|
.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 = ""
|
|
};
|
|
|
|
// 所有人次
|
|
var BreakfastNumberOfPeople = originTenantIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]);
|
|
|
|
var LunchNumberOfPeople = originTenantIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]);
|
|
|
|
var DinnerNumberOfPeople = originTenantIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]);
|
|
|
|
var LateNightNumberOfPeople = originTenantIdGroup.Count(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]);
|
|
//每个餐次人数
|
|
obj.BreakfastNumberOfPeople = originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LunchNumberOfPeople = originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.DinnerNumberOfPeople = originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LateNightNumberOfPeople = originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Select(x => x.UserNo).Distinct().Count();
|
|
|
|
//餐次金额
|
|
obj.BreakfastAmount = Math.Abs(originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Sum(x => x.Amount));
|
|
obj.LunchAmount = Math.Abs(originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Sum(x => x.Amount));
|
|
obj.DinnerAmount = Math.Abs(originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Sum(x => x.Amount));
|
|
obj.LateNightAmount = Math.Abs(originTenantIdGroup.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Sum(x => x.Amount));
|
|
|
|
|
|
// 每个餐次单价
|
|
obj.BreakfastPrice = BreakfastNumberOfPeople == 0 ? 0 : Math.Round(obj.BreakfastAmount / BreakfastNumberOfPeople, 2);
|
|
obj.LunchPrice = LunchNumberOfPeople == 0 ? 0 : Math.Round(obj.LunchAmount / LunchNumberOfPeople, 2);
|
|
obj.DinnerPrice = DinnerNumberOfPeople == 0 ? 0 : Math.Round(obj.DinnerAmount / DinnerNumberOfPeople, 2);
|
|
obj.LateNightPrice = LateNightNumberOfPeople == 0 ? 0 : Math.Round(obj.LateNightAmount / LateNightNumberOfPeople, 2);
|
|
|
|
// 总人数 总金额
|
|
obj.TotalNumberOfPeople = obj.BreakfastNumberOfPeople + obj.LunchNumberOfPeople + obj.DinnerNumberOfPeople + obj.LateNightNumberOfPeople;
|
|
obj.TotalAmount = obj.BreakfastAmount + obj.LunchAmount + obj.DinnerAmount + obj.LateNightAmount;
|
|
lst.Add(obj);
|
|
}
|
|
// 分页操作
|
|
var startIndex = (request.PageIndex - 1) * request.PageSize;
|
|
var pagedData = lst.Skip(startIndex).Take(request.PageSize).ToList();
|
|
|
|
var pagination = new Pagination<BalanceRecordSummaryRespones>
|
|
{
|
|
PageIndex = request.PageIndex,
|
|
PageSize = request.PageSize,
|
|
Total = lst.Count, // 使用原始列表的总数进行分页
|
|
Data = pagedData
|
|
};
|
|
|
|
return pagination;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 用餐分析
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public async Task<Pagination<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)
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out)
|
|
.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)),
|
|
};
|
|
|
|
//每个餐次人数
|
|
obj.BreakfastNumberOfPeople = first.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Breakfast"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LunchNumberOfPeople = first.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Lunch"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.DinnerNumberOfPeople = first.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["Dinner"]).Select(x => x.UserNo).Distinct().Count();
|
|
obj.LateNightNumberOfPeople = first.Where(x => x.BusinessShiftCode.ToString() == shiftCodeDict["LateNight"]).Select(x => x.UserNo).Distinct().Count();
|
|
lst.Add(obj);
|
|
}
|
|
// 分页操作
|
|
var startIndex = (request.PageIndex - 1) * request.PageSize;
|
|
var pagedData = lst.Skip(startIndex).Take(request.PageSize).ToList();
|
|
|
|
var pagination = new Pagination<BalanceRecordAnalysisRespones>
|
|
{
|
|
PageIndex = request.PageIndex,
|
|
PageSize = request.PageSize,
|
|
Total = lst.Count, // 使用原始列表的总数进行分页
|
|
Data = pagedData
|
|
};
|
|
|
|
return pagination;
|
|
}
|
|
|
|
|
|
|
|
public async Task<Pagination<BalanceRecordResponse>> GetPageByDeviceUniqueNoAsync(BalanceRecordPageByDeviceUniqueNoRequest request)
|
|
{
|
|
var now = DateTime.Now;
|
|
var start = DateTime.Today;
|
|
var end = new DateTime(now.Year, now.Month, now.Day, 23, 59, 59);
|
|
|
|
if (request.SearchDate.HasValue)
|
|
{
|
|
now = request.SearchDate.Value;
|
|
start = new DateTime(now.Year, now.Month, now.Day);
|
|
end = new DateTime(now.Year, now.Month, now.Day, 23, 59, 59);
|
|
}
|
|
|
|
var device = await _dbContext.Queryable<DeviceEntity>()
|
|
.Where(x => x.UniqueNo == request.DeviceUniqueNo || x.Code == Guid.Parse(request.DeviceUniqueNo))
|
|
.FirstAsync();
|
|
|
|
if (device == null)
|
|
{
|
|
return new Pagination<BalanceRecordResponse>()
|
|
{
|
|
Data = new List<BalanceRecordResponse>()
|
|
};
|
|
}
|
|
|
|
var page = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
|
|
.LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
|
|
.LeftJoin<BusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<BusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
|
.LeftJoin<BasicTypeEntity>((record, ga, department, bplace, bshift, type) => record.BusinessShiftCode.ToString() == type.Code)
|
|
.WhereIF(request.SearchDate.HasValue, record => record.CostDate >= start)
|
|
.WhereIF(request.SearchDate.HasValue, record => record.CostDate <= end)
|
|
.Where(record => record.TenantId == device.TenantId && (record.DeviceInfo == device.Code.ToString() || record.DeviceInfo == device.UniqueNo))
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out && record.Status == BalanceRecordStatusEnumType.Valid)
|
|
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
|
.Select((record, ga, department, bplace, bshift, type) => 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 = type.Display,
|
|
CostDateTime = record.CostDateTime
|
|
}).ToPageListAsync(request);
|
|
|
|
//消费总金额
|
|
var sum = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.WhereIF(request.SearchDate.HasValue, record => record.CostDate >= start)
|
|
.WhereIF(request.SearchDate.HasValue, record => record.CostDate <= end)
|
|
.Where(record => record.TenantId == device.TenantId || (record.DeviceInfo == device.Code.ToString() || record.DeviceInfo == device.UniqueNo))
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out && record.Status == BalanceRecordStatusEnumType.Valid)
|
|
.SumAsync(record => SqlFunc.Abs(SqlFunc.IsNull(record.Amount, 0)));
|
|
|
|
page.Data.ForEach(x => x.Sum = sum);
|
|
|
|
return page;
|
|
}
|
|
|
|
public async Task<Pagination<BalanceRecordUserResponse>> GetPageByUserAsync(BalanceRecordUserPageRequest request)
|
|
{
|
|
//当前用户
|
|
var userId = _currentUser.GetIntSubjectId();
|
|
|
|
var page = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
|
|
.LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
|
|
.LeftJoin<BusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<BusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
|
|
.LeftJoin<BasicTypeEntity>((record, ga, department, bplace, bshift, type) => record.BusinessShiftCode.ToString() == type.Code)
|
|
.WhereIF(request.SearchDateTimePeriod?.Start.HasValue == true, record => record.CostDate >= request.SearchDateTimePeriod.Start)
|
|
.WhereIF(request.SearchDateTimePeriod?.End.HasValue == true, record => record.CostDate <= request.SearchDateTimePeriod.End)
|
|
.Where((record, ga) => ga.IdentityUserId == userId)
|
|
.OrderBy(record => record.CreateTime, OrderByType.Desc)
|
|
.Select((record, ga, department, bplace, bshift, type) => new BalanceRecordUserResponse
|
|
{
|
|
Id = record.Id,
|
|
Amount = record.Amount,
|
|
Type = record.Type,
|
|
Status = record.Status,
|
|
Source = record.Source,
|
|
No = record.No,
|
|
BusinessPlaceName = bplace.Name,
|
|
BusinessShiftName = type.Display,
|
|
CostDateTime = record.CreateTime // todo
|
|
})
|
|
.ToPageListAsync(request);
|
|
|
|
return page;
|
|
}
|
|
|
|
[Transactional]
|
|
public async Task ObsoluteAsync(BalanceRecordObsoluteRequest request)
|
|
{
|
|
var balanceRecord = await _dbContext.Queryable<BalanceRecordEntity>().Where(x => x.Id == request.Id).SingleAsync();
|
|
balanceRecord.ThrowIfNull("记录不存在");
|
|
|
|
(balanceRecord.Type != BalanceRecordTypeEnumType.Out).ThrowIfTrue("非消费记录,无法操作");
|
|
|
|
balanceRecord.Status = BalanceRecordStatusEnumType.Obsolute;
|
|
balanceRecord.Remark = request.Reason;
|
|
|
|
|
|
await ContinueUpdateAsync(async () =>
|
|
{
|
|
//重算金额
|
|
var canteenUser = await _dbContext.Queryable<CanteenUserEntity>().Where(x => x.UserNo == balanceRecord.UserNo).SingleAsync();
|
|
|
|
//金额 +
|
|
canteenUser.Balance += Math.Abs(balanceRecord.Amount);
|
|
|
|
var effect = await _dbContext.Updateable<CanteenUserEntity>()
|
|
.SetColumns(x => x.Balance == canteenUser.Balance)
|
|
.SetColumns(x => x.Version == x.Version + 1)
|
|
.Where(x => x.UserNo == balanceRecord.UserNo && x.Version == canteenUser.Version)
|
|
.ExecuteCommandAsync();
|
|
|
|
if (effect <= 0) throw new VersionExceptions("更新版本冲突");
|
|
|
|
await _dbContext.UpdateAsync(balanceRecord);
|
|
|
|
}, 5);
|
|
}
|
|
|
|
public async Task<ConsumeNumberResponse> GetConsumeNumberAsync()
|
|
{
|
|
var devices = await _dbContext.Queryable<DeviceEntity>()
|
|
.Where(x => x.Type == DeviceTypeEnumType.Meal)
|
|
.ToListAsync();
|
|
|
|
var offCount = devices.Where(x => x.Enable == false).Count();
|
|
|
|
var places = await _dbContext.Queryable<BusinessPlaceEntity>()
|
|
.ToListAsync();
|
|
|
|
var time = DateTime.Now.ToString("yyyy-MM-dd");
|
|
//所有消费数据
|
|
var bs = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.Where(x => x.Type == BalanceRecordTypeEnumType.Out)
|
|
.ToListAsync();
|
|
//可消费人数
|
|
var consumerable = bs.Select(x => x.UserCode).Distinct().Count();
|
|
|
|
//当日消费数据
|
|
var monthbs = bs
|
|
.Where(x => x.CostDateTime.ToString("yyyy-MM-dd") == time);
|
|
//当日消费额
|
|
var monthlySpending = monthbs.Sum(x => x.Amount);
|
|
//当日消费人数
|
|
var monthlyCount = monthbs.Select(x => x.UserCode).Distinct().Count();
|
|
|
|
//消费走势
|
|
var months = await GetConsumptionTrendsAsync(ConsumptionTrendEnumType.Month);
|
|
var days = await GetConsumptionTrendsAsync(ConsumptionTrendEnumType.Day);
|
|
|
|
var res = new ConsumeNumberResponse
|
|
{
|
|
Total = devices.Count(),
|
|
OffNumber = offCount,
|
|
PlaceNumber = places.Count(),
|
|
ConsumerableNumber = consumerable,
|
|
DailyNumber = monthlyCount != 0 ? Math.Abs((int)Math.Ceiling(monthlySpending / monthlyCount)) : 0,
|
|
Days = days,
|
|
Months = months
|
|
};
|
|
return res;
|
|
|
|
}
|
|
private async Task<List<ConsumptionTrendResponse>> GetConsumptionTrendsAsync(ConsumptionTrendEnumType type)
|
|
{
|
|
var bs = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.Where(x => x.Type == BalanceRecordTypeEnumType.Out)
|
|
.ToListAsync();
|
|
//消费总额
|
|
var totalAmount = Math.Round(Math.Abs(bs.Sum(x => x.Amount)), 2);
|
|
|
|
var list = new List<ConsumptionTrendResponse>();
|
|
if (type == ConsumptionTrendEnumType.Month)
|
|
{
|
|
//月与总额对比
|
|
var months = GetMonthsOfYear();
|
|
|
|
foreach (var month in months)
|
|
{
|
|
var currentAmount = Math.Round(Math.Abs(bs.Where(x => x.CostDateTime.ToString("yyyy-MM") == month)
|
|
.Sum(x => x.Amount)), 2);
|
|
|
|
var res = new ConsumptionTrendResponse
|
|
{
|
|
DateTime = month,
|
|
CurrentAmount = currentAmount,
|
|
TotalAmount = totalAmount
|
|
};
|
|
list.Add(res);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
//日与总额对比
|
|
var days = GetDaysOfMonth();
|
|
|
|
foreach (var day in days)
|
|
{
|
|
var currentAmount = Math.Round(Math.Abs(bs.Where(x => x.CostDateTime.ToString("yyyy-MM-dd") == day)
|
|
.Sum(x => x.Amount)), 2);
|
|
|
|
var res = new ConsumptionTrendResponse
|
|
{
|
|
DateTime = day,
|
|
CurrentAmount = currentAmount,
|
|
TotalAmount = totalAmount
|
|
};
|
|
list.Add(res);
|
|
}
|
|
}
|
|
return list;
|
|
}
|
|
|
|
|
|
public async Task<Pagination<OaEMealVoucherResponse>> GetOaEMealVoucherAsync(OaEMealVoucherRequest request)
|
|
{
|
|
var page = await _dbContext.Queryable<OaEMealVoucherEntity>()
|
|
.Where(x => x.UserCode == request.UserCode)
|
|
.Select<OaEMealVoucherResponse>()
|
|
.ToPageListAsync(request);
|
|
return page;
|
|
}
|
|
|
|
public async Task<Pagination<OaEMealVoucherDetailResponse>> GetOaEMealVoucherDetailAsync(OaEMealVoucherDetailRequest request)
|
|
{
|
|
var page = await _dbContext.Queryable<OaEMealVoucherDetailEntity>()
|
|
.Where(x => x.VoucherId == request.OaEMealVoucherId)
|
|
.Select<OaEMealVoucherDetailResponse>()
|
|
.ToPageListAsync(request);
|
|
|
|
return page;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取当前年所有月
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private List<string> GetMonthsOfYear()
|
|
{
|
|
List<string> months = new List<string>();
|
|
// 获取当前年份
|
|
int year = DateTime.Now.Year;
|
|
// 遍历12个月份并添加到列表中
|
|
for (int month = 1; month <= 12; month++)
|
|
{
|
|
DateTime monthDate = new DateTime(year, month, 1);
|
|
months.Add(monthDate.ToString("yyyy-MM"));
|
|
}
|
|
return months;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取当前月所有天
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private List<string> GetDaysOfMonth()
|
|
{
|
|
List<string> days = new List<string>();
|
|
|
|
// 获取当前年份和月份
|
|
int year = DateTime.Now.Year;
|
|
int month = DateTime.Now.Month;
|
|
|
|
// 获取当前月份的第一天和最后一天
|
|
DateTime firstDayOfMonth = new DateTime(year, month, 1);
|
|
DateTime lastDayOfMonth = firstDayOfMonth.AddMonths(1).AddDays(-1);
|
|
|
|
// 遍历当前月的所有日期并添加到列表中
|
|
for (DateTime date = firstDayOfMonth; date <= lastDayOfMonth; date = date.AddDays(1))
|
|
{
|
|
days.Add(date.ToString("yyyy-MM-dd"));
|
|
}
|
|
|
|
return days;
|
|
}
|
|
|
|
|
|
//************************************************************** help methods ******************************************************************
|
|
|
|
private async Task ContinueUpdateAsync(Func<Task> func, int retry)
|
|
{
|
|
for (int i = 0; i < retry; i++)
|
|
{
|
|
try
|
|
{
|
|
await func();
|
|
return;
|
|
}
|
|
catch (Exception ex) when (ex is VersionExceptions)
|
|
{
|
|
_logger.LogWarning(ex, ex.Message);
|
|
}
|
|
catch (Exception)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
throw new UserFriendlyException("操作失败,请重试");
|
|
}
|
|
|
|
[IgnoreTenant]
|
|
public async Task<Dictionary<string, string>> GetShiftCode()
|
|
{
|
|
|
|
_dbContext.Client.QueryFilter.ClearAndBackup<ITenantId>();
|
|
try
|
|
{
|
|
var shiftCodeDict = new Dictionary<string, string>();
|
|
|
|
var shifts = await _dbContext.Queryable<BusinessShiftEntity>().ToListAsync();
|
|
//guid
|
|
var breakfastCode = shifts.Where(x => x.CustomCode == "shift-breakfast").Select(x => x.Code).First().ToString();
|
|
|
|
var lunchCode = shifts.Where(x => x.CustomCode == "shift-lunch").Select(x => x.Code).First().ToString();
|
|
|
|
var dinnerCode = shifts.Where(x => x.CustomCode == "shift-dinner").Select(x => x.Code).First().ToString();
|
|
|
|
var lateNightCode = shifts.Where(x => x.CustomCode == "shift-midnightsnack").Select(x => x.Code).First().ToString();
|
|
|
|
shiftCodeDict.Add("Breakfast", breakfastCode.ToString());
|
|
shiftCodeDict.Add("Lunch", lunchCode.ToString());
|
|
shiftCodeDict.Add("Dinner", dinnerCode.ToString());
|
|
shiftCodeDict.Add("LateNight", lateNightCode.ToString());
|
|
|
|
return shiftCodeDict;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, $"生成{DeviceTaskEnumType.UploadRecord.GetDescription()}任务失败:" + ex.Message);
|
|
return null;
|
|
}
|
|
finally
|
|
{
|
|
_dbContext.Client.QueryFilter.Restore();
|
|
}
|
|
|
|
}
|
|
}
|