320 lines
12 KiB
C#
320 lines
12 KiB
C#
using AutoMapper;
|
|
using Entities.Contracts;
|
|
using Entities.DTO;
|
|
using Entities.DTO.Class;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using SharedDATA.Api;
|
|
using TechHelper.Repository;
|
|
|
|
namespace TechHelper.Services.Beta
|
|
{
|
|
public class ClassService : IClassService
|
|
{
|
|
private readonly IUnitOfWork _work;
|
|
private readonly IMapper _mapper;
|
|
|
|
public ClassService(IUnitOfWork work, IMapper mapper)
|
|
{
|
|
_work = work;
|
|
_mapper = mapper;
|
|
}
|
|
|
|
public async Task<ApiResponse> GetAllAsync(QueryParameter query)
|
|
{
|
|
try
|
|
{
|
|
var repository = _work.GetRepository<Class>();
|
|
|
|
if (query.Search != null && !string.IsNullOrWhiteSpace(query.Search))
|
|
{
|
|
var classes = await repository.GetPagedListAsync(
|
|
predicate: c => c.ClassName.Contains(query.Search),
|
|
pageSize: query.PageSize,
|
|
pageIndex: query.PageIndex
|
|
);
|
|
var classDtosFiltered = _mapper.Map<IEnumerable<ClassDto>>(classes.Items);
|
|
return new ApiResponse(true, classDtosFiltered);
|
|
}
|
|
else
|
|
{
|
|
var classes = await repository.GetPagedListAsync(
|
|
pageSize: query.PageSize,
|
|
pageIndex: query.PageIndex
|
|
);
|
|
var classDtos = _mapper.Map<IEnumerable<ClassDto>>(classes.Items);
|
|
return new ApiResponse(true, classDtos);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"获取所有班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> GetAsync(Guid id)
|
|
{
|
|
try
|
|
{
|
|
var @class = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.Id == id,
|
|
include: i => i.Include(c => c.Grade).Include(c => c.HeadTeacher));
|
|
|
|
if (@class == null)
|
|
{
|
|
return new ApiResponse("班级未找到。");
|
|
}
|
|
|
|
var classDto = _mapper.Map<ClassDto>(@class);
|
|
return new ApiResponse(true, classDto);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"获取班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> AddAsync(ClassDto model)
|
|
{
|
|
try
|
|
{
|
|
// 检查是否已存在相同年级下的同名班级
|
|
var existingClass = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.GradeId == model.GradeId && (c.ClassName == model.ClassName || c.Index == model.Index));
|
|
|
|
if (existingClass != null)
|
|
{
|
|
return new ApiResponse($"在当前年级下，班级 '{model.ClassName}', 序号 '{model.Index}' 已存在。 请检查你的班级名称和序号, 如有问题请联系管理员.");
|
|
}
|
|
|
|
var @class = _mapper.Map<Class>(model);
|
|
await _work.GetRepository<Class>().InsertAsync(@class);
|
|
|
|
if (await _work.SaveChangesAsync() > 0)
|
|
{
|
|
return new ApiResponse(true, _mapper.Map<ClassDto>(@class));
|
|
}
|
|
return new ApiResponse("添加班级失败。");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"添加班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> UpdateAsync(ClassDto model)
|
|
{
|
|
try
|
|
{
|
|
var existingClass = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.Id == model.Id);
|
|
|
|
if (existingClass == null)
|
|
{
|
|
return new ApiResponse("班级未找到。");
|
|
}
|
|
|
|
_mapper.Map(model, existingClass);
|
|
_work.GetRepository<Class>().Update(existingClass);
|
|
|
|
if (await _work.SaveChangesAsync() > 0)
|
|
{
|
|
return new ApiResponse(true, _mapper.Map<ClassDto>(existingClass));
|
|
}
|
|
return new ApiResponse("更新班级失败。");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"更新班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> DeleteAsync(Guid id)
|
|
{
|
|
try
|
|
{
|
|
var existingClass = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.Id == id);
|
|
|
|
if (existingClass == null)
|
|
{
|
|
return new ApiResponse("班级未找到。");
|
|
}
|
|
|
|
_work.GetRepository<Class>().Delete(existingClass);
|
|
|
|
if (await _work.SaveChangesAsync() > 0)
|
|
{
|
|
return new ApiResponse(true, "班级删除成功。");
|
|
}
|
|
return new ApiResponse("删除班级失败。");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"删除班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> GetClassStudentsAsync(Guid classId)
|
|
{
|
|
try
|
|
{
|
|
var classEntity = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.Id == classId);
|
|
|
|
if (classEntity == null)
|
|
{
|
|
return new ApiResponse("班级未找到。");
|
|
}
|
|
|
|
var students = classEntity.Students
|
|
.Where(u => !u.IsDeleted)
|
|
.Select(u => u.User)
|
|
.ToList();
|
|
|
|
|
|
var StudentsDto = _mapper.Map<IEnumerable<UserListDto>>(students);
|
|
return new ApiResponse(true, StudentsDto);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"获取班级学生时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> ValidateClassRegistration(ClassValidDto user)
|
|
{
|
|
try
|
|
{
|
|
// 验证学校是否存在
|
|
var schoolRepository = _work.GetRepository<School>();
|
|
var school = await schoolRepository.GetFirstOrDefaultAsync(
|
|
predicate: s => s.SchoolName == user.SchoolName);
|
|
|
|
if (school == null)
|
|
{
|
|
return new ApiResponse("学校未找到。");
|
|
}
|
|
|
|
// 验证年级是否存在
|
|
var gradeRepository = _work.GetRepository<Grade>();
|
|
var grade = await gradeRepository.GetFirstOrDefaultAsync(
|
|
predicate: g => g.SchoolId == school.Id && g.GradeLevel == user.Grade);
|
|
|
|
if (grade == null)
|
|
{
|
|
return new ApiResponse("年级未找到。");
|
|
}
|
|
|
|
// 验证班级是否存在
|
|
var classRepository = _work.GetRepository<Class>();
|
|
var classEntity = await classRepository.GetFirstOrDefaultAsync(
|
|
predicate: c => c.GradeId == grade.Id && c.Index == user.Class && !c.IsDeleted);
|
|
|
|
if (classEntity == null)
|
|
{
|
|
return new ApiResponse("班级未找到。");
|
|
}
|
|
|
|
// 返回验证成功的班级信息
|
|
return new ApiResponse(true, classEntity.Id);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"验证班级信息时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> UserRegister(RegisterUserToClassDto user)
|
|
{
|
|
try
|
|
{
|
|
// 获取班级实体
|
|
var classRepository = _work.GetRepository<Class>();
|
|
var classEntity = await classRepository.GetFirstOrDefaultAsync(
|
|
predicate: c => c.Id == user.ClassId);
|
|
|
|
if (classEntity == null)
|
|
{
|
|
return new ApiResponse("检查你的班级输入,没有该班级。");
|
|
}
|
|
|
|
// 检查用户是否已经在该班级中
|
|
var existingClassUser = classEntity.ClassUsers.FirstOrDefault(u => u.UserId == user.UserId);
|
|
if (existingClassUser != null )
|
|
{
|
|
return new ApiResponse("用户已经在该班级中。");
|
|
}
|
|
|
|
await _work.GetRepository<ClassUser>().InsertAsync(
|
|
new ClassUser { ClassId = user.ClassId, UserId = user.UserId, EnrollmentDate = DateTime.Now });
|
|
|
|
if (await _work.SaveChangesAsync() > 0)
|
|
{
|
|
return new ApiResponse(true, "用户成功注册到班级。");
|
|
}
|
|
return new ApiResponse("用户注册到班级失败。");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"用户注册到班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
|
|
public async Task<ApiResponse> GetUserInjoinedClasses(Guid user)
|
|
{
|
|
try
|
|
{
|
|
var userInfo = await _work.GetRepository<User>().GetFirstOrDefaultAsync(predicate:
|
|
u => u.Id == user,include: i => i
|
|
.Include(u => u.UserInjoinedClass)
|
|
.ThenInclude(c => c.Class)
|
|
.ThenInclude(cs => cs.Grade));
|
|
var schoolName = userInfo.UserInjoinedClass.First().Class.Grade.School.SchoolName;
|
|
var userClassInfo = userInfo.UserInjoinedClass.Select(c => c.Class);
|
|
var userClassDto = userClassInfo.Select(c => new UserClassInfoDto(c.Id, c.Index, c.Grade.GradeLevel));
|
|
var result = new UserClassDetailInfoDto(userClassDto, schoolName);
|
|
return ApiResponse.Success(result: result);
|
|
}
|
|
catch(Exception ex)
|
|
{
|
|
return ApiResponse.Error($"获取用户班级信息时发生错误: {ex.Message}");
|
|
}
|
|
|
|
|
|
}
|
|
|
|
public Task<ApiResponse> GetUserClassRole(Guid id)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public async Task<ApiResponse> AdminAddAsync(ClassCreateDto model)
|
|
{
|
|
try
|
|
{
|
|
// 检查是否已存在相同年级下的同名班级
|
|
var existingClass = await _work.GetRepository<Class>().GetFirstOrDefaultAsync(
|
|
predicate: c => c.Grade.GradeLevel == model.Grade.GradeLevel && (c.ClassName == model.ClassName || c.Index == model.Index));
|
|
|
|
if (existingClass != null)
|
|
{
|
|
return new ApiResponse($"在当前年级下，班级 '{model.ClassName}', 序号 '{model.Index}' 已存在。 请检查你的班级名称和序号, 如有问题请联系管理员.");
|
|
}
|
|
|
|
var @class = _mapper.Map<Class>(model);
|
|
await _work.GetRepository<Class>().InsertAsync(@class);
|
|
|
|
if (await _work.SaveChangesAsync() > 0)
|
|
{
|
|
return new ApiResponse(true, _mapper.Map<ClassDto>(@class));
|
|
}
|
|
return new ApiResponse("添加班级失败。");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return new ApiResponse($"添加班级时发生错误: {ex.Message}");
|
|
}
|
|
}
|
|
}
|
|
}
|