glz
028e3dfb34
1. 新增通用默认状态枚举 DefaultStatusEnum，替换原有分散的状态枚举 2. 重构用户体系：拆分 WxUser 独立表存储微信身份，Users 表改为角色子用户表并关联 WxUser 3. 重构勋章模块：新增系统/期刊勋章类型，调整 JournalId 为可空，新增勋章状态字段 4. 重构微信认证流程：基于 WxUser 生成 Token，支持多子用户管理 5. 清理冗余枚举文件，重构多处业务逻辑适配新的数据结构 6. 修复用户手机号关联逻辑，迁移手机号字段至 WxUser 表
290 lines
10 KiB
C#
290 lines
10 KiB
C#
using Microsoft.Extensions.Logging;
|
||
using Newtonsoft.Json;
|
||
using QYZH.InteractiveMagazine.IService;
|
||
|
||
using QYZH.InteractiveMagazine.Models.Common;
|
||
using QYZH.InteractiveMagazine.Models.Dto;
|
||
using QYZH.InteractiveMagazine.Models.Dto.CheckIn;
|
||
using QYZH.InteractiveMagazine.Models.Dto.Compensation;
|
||
using QYZH.InteractiveMagazine.Models.Dto.Points;
|
||
using QYZH.InteractiveMagazine.Models.Entity;
|
||
using QYZH.InteractiveMagazine.Models.Enum;
|
||
using QYZH.InteractiveMagazine.Repository;
|
||
using SqlSugar;
|
||
|
||
namespace QYZH.InteractiveMagazine.Service;
|
||
|
||
public class UsersService(
|
||
BaseRepository<Users> usersRepository,
|
||
ILogger<UsersService> _logger,
|
||
IPointsService pointsService,
|
||
ICheckInService checkInService,
|
||
ICompensationTaskService compensationTaskService,
|
||
IUserJournalService userJournalService,
|
||
IOperationLogService operationLogService) : BaseRepository<Users>, IUsersService
|
||
{
|
||
/// <summary>
|
||
/// 分页查询用户列表
|
||
/// </summary>
|
||
public async Task<BaseResponse<PageListModel<UsersOutput>>> GetListAsync(UsersQueryInput input)
|
||
{
|
||
var page = Queryable()
|
||
.WhereIF(!string.IsNullOrEmpty(input.WxUserId), u => u.WxUserId.ToString() == input.WxUserId)
|
||
.OrderBy(u => u.Id, OrderByType.Desc)
|
||
.ToPage<Users, UsersOutput>(input);
|
||
|
||
return BaseResponse<PageListModel<UsersOutput>>.Success(page);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取用户详情（包含积分记录、签到记录、补偿任务、期刊列表）
|
||
/// </summary>
|
||
public async Task<BaseResponse<UserDetailOutput>> GetDetailAsync(long id)
|
||
{
|
||
var user = await GetByIdAsync<UsersOutput>(u => u.Id == id);
|
||
if (user == null)
|
||
{
|
||
return BaseResponse<UserDetailOutput>.Fail("用户不存在");
|
||
}
|
||
|
||
// 并行查询关联数据
|
||
var pointsTask = GetPointsRecordsAsync(id);
|
||
var checkInTask = GetCheckInRecordsAsync(id);
|
||
var compensationTask = GetFailedCompensationTasksAsync(id);
|
||
var journalsTask = GetUserJournalsWithDetailAsync(id);
|
||
|
||
await Task.WhenAll(pointsTask, checkInTask, compensationTask, journalsTask);
|
||
|
||
return BaseResponse<UserDetailOutput>.Success(new UserDetailOutput
|
||
{
|
||
BasicInfo = user,
|
||
PointsRecords = await pointsTask,
|
||
CheckInRecords = await checkInTask,
|
||
FailedCompensationTasks = await compensationTask,
|
||
Journals = await journalsTask
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取用户积分记录（最近20条）
|
||
/// </summary>
|
||
private async Task<List<PointsRecordOutput>> GetPointsRecordsAsync(long userId)
|
||
{
|
||
try
|
||
{
|
||
var result = await pointsService.GetPointsRecordsAsync(new PointsRecordQueryInput
|
||
{
|
||
UserId = userId,
|
||
PageIndex = 1,
|
||
PageSize = 20
|
||
});
|
||
return result.Result ?? [];
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.LogWarning(ex, "获取用户积分记录失败，UserId: {UserId}", userId);
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取用户签到记录
|
||
/// </summary>
|
||
private async Task<List<CheckInRecordOutput>> GetCheckInRecordsAsync(long userId)
|
||
{
|
||
try
|
||
{
|
||
var info = await checkInService.GetCheckInInfoAsync(userId);
|
||
return info.RecentRecords ?? [];
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.LogWarning(ex, "获取用户签到记录失败，UserId: {UserId}", userId);
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取用户失败的补偿任务（需要手动处理）
|
||
/// </summary>
|
||
private async Task<List<CompensationTaskOutput>> GetFailedCompensationTasksAsync(long userId)
|
||
{
|
||
try
|
||
{
|
||
var tasks = await compensationTaskService.GetTasksAsync(new GetCompensationTasksInput
|
||
{
|
||
UserId = userId,
|
||
Status = CompensationTaskStatusEnum.Failed,
|
||
Limit = 20
|
||
});
|
||
return tasks;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.LogWarning(ex, "获取用户失败补偿任务失败，UserId: {UserId}", userId);
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取用户拥有的期刊列表（含期刊详情）
|
||
/// </summary>
|
||
private async Task<List<UserJournalItemOutput>> GetUserJournalsWithDetailAsync(long userId)
|
||
{
|
||
try
|
||
{
|
||
var userJournals = await Context.Queryable<UserJournal>()
|
||
.Where(uj => uj.UserId == userId && !uj.IsDeleted)
|
||
.OrderByDescending(uj => uj.CreatedAt)
|
||
.ToListAsync();
|
||
|
||
var result = new List<UserJournalItemOutput>();
|
||
foreach (var uj in userJournals)
|
||
{
|
||
var journal = await Context.Queryable<Journal>()
|
||
.Where(j => j.Id == uj.JournalId && !j.IsDeleted)
|
||
.FirstAsync();
|
||
|
||
if (journal != null)
|
||
{
|
||
result.Add(new UserJournalItemOutput
|
||
{
|
||
BindId = uj.Id,
|
||
JournalId = uj.JournalId,
|
||
JournalTitle = journal.Title,
|
||
CoverImageUrl = journal.CoverImageUrl,
|
||
Type = uj.Type.ToString(),
|
||
Status = uj.Status.ToString(),
|
||
CreatedAt = uj.CreatedAt
|
||
});
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.LogWarning(ex, "获取用户期刊列表失败，UserId: {UserId}", userId);
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新用户状态
|
||
/// </summary>
|
||
public async Task<BaseResponse> UpdateStatusAsync(long id)
|
||
{
|
||
var exists = await usersRepository.GetByIdAsync(id);
|
||
if (exists == null)
|
||
{
|
||
return BaseResponse.Fail("用户不存在");
|
||
}
|
||
var statusValue = exists.Status == (int)UserStatusEnum.Active ? UserStatusEnum.Disabled : UserStatusEnum.Active;
|
||
var result = await UpdateAsync(
|
||
u => new Users { Status = (int)statusValue },
|
||
u => u.Id == id
|
||
);
|
||
|
||
return result ? BaseResponse.Success() : BaseResponse.Fail("更新失败");
|
||
}
|
||
|
||
/// <summary>
|
||
/// 手动增加用户积分
|
||
/// </summary>
|
||
public async Task<ManualPointsOutput> ManualAddPointsAsync(long userId, ManualAddPointsInput input, long operatorId, string operatorName, string? ipAddress = null)
|
||
{
|
||
_logger.LogInformation("管理员手动增加积分，UserId: {UserId}, Amount: {Amount}, Operator: {Operator}",
|
||
userId, input.Amount, operatorName);
|
||
|
||
// 校验用户是否存在
|
||
var user = await Queryable().Where(u => u.Id == userId && !u.IsDeleted).FirstAsync();
|
||
if (user == null)
|
||
throw new BusinessException("用户不存在", 404);
|
||
|
||
// 调用积分服务增加积分
|
||
var result = await pointsService.AddPointsAsync(new AddPointsInput
|
||
{
|
||
UserId = userId,
|
||
Amount = input.Amount,
|
||
ChangeType = PointsChangeTypeEnum.ManualAdjust,
|
||
Description = $"管理员手动增加: {input.Reason}",
|
||
OperatorName = operatorName
|
||
});
|
||
|
||
// 记录操作日志
|
||
var detail = JsonConvert.SerializeObject(new
|
||
{
|
||
Amount = input.Amount,
|
||
Reason = input.Reason,
|
||
PreviousBalance = result.PreviousBalance,
|
||
NewBalance = result.NewBalance,
|
||
RecordId = result.RecordId
|
||
});
|
||
|
||
await operationLogService.LogAsync(
|
||
operatorId, operatorName,
|
||
OperationLogActionType.ManualAddPoints,
|
||
OperationLogTargetType.User,
|
||
userId, user.Name, detail, ipAddress);
|
||
|
||
return new ManualPointsOutput
|
||
{
|
||
RecordId = result.RecordId,
|
||
PreviousBalance = result.PreviousBalance,
|
||
NewBalance = result.NewBalance,
|
||
ChangeAmount = input.Amount,
|
||
OperatorName = operatorName,
|
||
OperatedAt = DateTime.Now
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// 手动扣除用户积分
|
||
/// </summary>
|
||
public async Task<ManualPointsOutput> ManualDeductPointsAsync(long userId, ManualDeductPointsInput input, long operatorId, string operatorName, string? ipAddress = null)
|
||
{
|
||
_logger.LogInformation("管理员手动扣除积分，UserId: {UserId}, Amount: {Amount}, Operator: {Operator}",
|
||
userId, input.Amount, operatorName);
|
||
|
||
// 校验用户是否存在
|
||
var user = await Queryable().Where(u => u.Id == userId && !u.IsDeleted).FirstAsync();
|
||
if (user == null)
|
||
throw new BusinessException("用户不存在", 404);
|
||
|
||
// 调用积分服务扣除积分
|
||
var result = await pointsService.DeductPointsAsync(new DeductPointsInput
|
||
{
|
||
UserId = userId,
|
||
Amount = input.Amount,
|
||
ChangeType = PointsChangeTypeEnum.ManualAdjust,
|
||
Description = $"管理员手动扣除: {input.Reason}",
|
||
OperatorName = operatorName
|
||
});
|
||
|
||
// 记录操作日志
|
||
var detail = JsonConvert.SerializeObject(new
|
||
{
|
||
Amount = input.Amount,
|
||
Reason = input.Reason,
|
||
PreviousBalance = result.PreviousBalance,
|
||
NewBalance = result.NewBalance,
|
||
RecordId = result.RecordId
|
||
});
|
||
|
||
await operationLogService.LogAsync(
|
||
operatorId, operatorName,
|
||
OperationLogActionType.ManualDeductPoints,
|
||
OperationLogTargetType.User,
|
||
userId, user.Name, detail, ipAddress);
|
||
|
||
return new ManualPointsOutput
|
||
{
|
||
RecordId = result.RecordId,
|
||
PreviousBalance = result.PreviousBalance,
|
||
NewBalance = result.NewBalance,
|
||
ChangeAmount = -input.Amount,
|
||
OperatorName = operatorName,
|
||
OperatedAt = DateTime.Now
|
||
};
|
||
}
|
||
}
|