235 lines
11 KiB
C#
235 lines
11 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 Kurisu.AspNetCore.UnifyResultAndValidation;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.DataAccess.Dto;
|
|
using Kurisu.Core.User.Abstractions;
|
|
using Kurisu.SqlSugar.Attributes;
|
|
using Kurisu.SqlSugar.Extensions;
|
|
using Kurisu.SqlSugar.Services;
|
|
using SqlSugar;
|
|
|
|
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<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.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) => 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 page;
|
|
}
|
|
|
|
[IgnoreTenant]
|
|
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<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.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) => 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.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<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
|
|
.LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.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) => new BalanceRecordUserResponse
|
|
{
|
|
Id = record.Id,
|
|
Amount = record.Amount,
|
|
Type = record.Type,
|
|
Status = record.Status,
|
|
Source = record.Source,
|
|
No = record.No,
|
|
BusinessPlaceName = bplace.Name,
|
|
BusinessShiftName = bshift.Name,
|
|
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);
|
|
}
|
|
|
|
|
|
//************************************************************ 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("操作失败,请重试");
|
|
}
|
|
}
|