136 lines
4.5 KiB
C#
136 lines
4.5 KiB
C#
using Furion.FriendlyException;
|
||
using Microsoft.Extensions.Logging;
|
||
using YD_Event.Application.Points.Dtos;
|
||
using YD_Event.Core.Entities;
|
||
|
||
namespace YD_Event.Application.Points;
|
||
|
||
/// <summary>
|
||
/// 积分规则管理
|
||
/// </summary>
|
||
public class PointsRuleService : BaseService<PointsRule>, ITransient
|
||
{
|
||
private readonly ISqlSugarRepository<PointsRule> _repository;
|
||
private readonly ISqlSugarRepository<PointsRuleDetail> _detailRepository;
|
||
private readonly ISqlSugarRepository<PointsRecord> _pointsRecordRepository;
|
||
private readonly IIdGenerator _idGenerator;
|
||
private readonly Microsoft.Extensions.Logging.ILogger<PointsRuleService> _logger;
|
||
|
||
public PointsRuleService(ISqlSugarRepository<PointsRule> repository,
|
||
ISqlSugarRepository<PointsRuleDetail> detailRepository,
|
||
ISqlSugarRepository<PointsRecord> pointsRecordRepository,
|
||
IIdGenerator idGenerator,
|
||
Microsoft.Extensions.Logging.ILogger<PointsRuleService> logger) : base(repository)
|
||
{
|
||
_repository = repository;
|
||
_detailRepository = detailRepository;
|
||
_pointsRecordRepository = pointsRecordRepository;
|
||
_idGenerator = idGenerator;
|
||
_logger = logger;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 积分规则分页查询
|
||
/// </summary>
|
||
[DisplayName("积分规则分页查询")]
|
||
[HttpGet]
|
||
public async Task<PageResult<PointsRule>> Page([FromQuery] PointsRuleQueryInput input)
|
||
{
|
||
return await _repository.AsQueryable()
|
||
.WhereIF(!string.IsNullOrWhiteSpace(input.RuleName), x => x.RuleName.Contains(input.RuleName))
|
||
.OrderByDescending(x => x.CreatedTime)
|
||
.ToPagedListAsync(input);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加积分规则
|
||
/// </summary>
|
||
[DisplayName("添加积分规则")]
|
||
[HttpPost("add")]
|
||
[UnitOfWork]
|
||
public async Task Add(AddPointsRuleInput input)
|
||
{
|
||
var entity = input.Adapt<PointsRule>();
|
||
entity.Id = _idGenerator.NextId();
|
||
|
||
await _repository.InsertAsync(entity);
|
||
|
||
if (input.Details != null && input.Details.Any())
|
||
{
|
||
var details = input.Details.Adapt<List<PointsRuleDetail>>();
|
||
details.ForEach(x =>
|
||
{
|
||
x.PointsRuleId = entity.Id;
|
||
x.Id = _idGenerator.NextId();
|
||
});
|
||
await _detailRepository.InsertRangeAsync(details);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新积分规则
|
||
/// </summary>
|
||
[DisplayName("更新积分规则")]
|
||
[HttpPut("edit")]
|
||
[UnitOfWork]
|
||
public async Task Update(UpdatePointsRuleInput input)
|
||
{
|
||
var entity = await _repository.GetByIdAsync(input.Id);
|
||
if (entity == null) throw Oops.Bah("规则不存在");
|
||
|
||
input.Adapt(entity);
|
||
await _repository.UpdateAsync(entity);
|
||
|
||
// Update details: Delete old, Insert new
|
||
await _detailRepository.DeleteAsync(x => x.PointsRuleId == entity.Id);
|
||
|
||
if (input.Details != null && input.Details.Any())
|
||
{
|
||
var details = input.Details.Adapt<List<PointsRuleDetail>>();
|
||
details.ForEach(x =>
|
||
{
|
||
x.PointsRuleId = entity.Id;
|
||
x.Id = _idGenerator.NextId();
|
||
});
|
||
await _detailRepository.InsertRangeAsync(details);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 删除积分规则
|
||
/// </summary>
|
||
[DisplayName("删除积分规则")]
|
||
[HttpPost("delete")]
|
||
[UnitOfWork]
|
||
public async Task Delete([FromBody] List<long> ids)
|
||
{
|
||
_logger.LogInformation("开始删除积分规则：规则ID列表={Ids}", string.Join(",", ids ?? new List<long>()));
|
||
|
||
if (ids == null || !ids.Any())
|
||
{
|
||
_logger.LogWarning("删除积分规则失败：未选择积分规则");
|
||
return;
|
||
}
|
||
|
||
// 执行删除
|
||
await _repository.DeleteAsync(x => ids.Contains(x.Id));
|
||
await _detailRepository.DeleteAsync(x => ids.Contains(x.PointsRuleId));
|
||
|
||
_logger.LogInformation("删除积分规则成功：规则ID列表={Ids}", string.Join(",", ids));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取积分规则详情
|
||
/// </summary>
|
||
[DisplayName("获取积分规则详情")]
|
||
[HttpGet("detail")]
|
||
public async Task<PointsRule> Detail([FromQuery] long id)
|
||
{
|
||
var entity = await _repository.GetByIdAsync(id);
|
||
if (entity == null) throw Oops.Bah("规则不存在");
|
||
|
||
entity.Details = await _detailRepository.AsQueryable().Where(x => x.PointsRuleId == id).ToListAsync();
|
||
return entity;
|
||
}
|
||
}
|