using AutoMapper; using Microsoft.EntityFrameworkCore; using Newtonsoft.Json; using System.Collections.Generic; using System.Security.Cryptography; using VOL.Entity.DomainModels.XinWei; using YD_XinWei.Api.Context; using YD_XinWei.Api.Services.Interface; using YD_XinWei.Api.SmartSportsEntitys; using YD_XinWei.Api.Utilities; using YD_XinWei.Commons.Dto.Common; using YD_XinWei.Commons.Dto.HomeWork; using YD_XinWei.Commons.Dto.Open; using YD_XinWei.Commons.Dto.School; using YD_XinWei.Commons; using YD_XinWei.Commons.Utils; using static Microsoft.EntityFrameworkCore.DbLoggerCategory; using Newtonsoft.Json.Linq; using VOL.Entity.Enum; namespace YD_XinWei.Api.Services.Impl { /// /// 服务实现 /// public class XinWeiService : IXinWeiService { public SmartSportsContext _sportsContext; private readonly IMapper _mapper; /// /// 构造 /// /// /// public XinWeiService(SmartSportsContext sportsContext, IMapper mapper) { _sportsContext = sportsContext; _mapper = mapper; } /// /// 获取设备信息 /// /// /// /// public async Task DeviceInfo(string deviceSerial) { var deviceInfo = await _sportsContext.XW_Device.FirstOrDefaultAsync(x => x.DeviceSerial == deviceSerial); var res = _mapper.Map(deviceInfo); return res; } /// /// 项目模式 /// /// public async Task> SportsModelTypeList() { var res = await _sportsContext.XW_ProjectMode.Select(x => new ProjectModeDto() { Id = x.Id, ProjectKind = x.ProjectKind, Name = x.Name }).ToListAsync(); return res; } /// /// 体育项目 /// /// 学校Id /// public async Task> OrgSportsProjectList(int orgId) { var res = await _sportsContext.XW_TestingProject.Where(x => x.OrgId == orgId).Select(x => new TestingProjectDto() { ProjectId = x.ProjectId, IsOpen = x.IsOpen, IsShow = x.IsShow, ProjectName = x.ProjectName }).ToListAsync(); return res; } /// /// 获取学生信息 /// /// 学校Id /// public async Task> MinimumOfStudentInfoList(int orgId) { string schoolCode = await _sportsContext.School.Where(x => x.Id == orgId).Select(x => x.SchoolCode).FirstAsync(); var res = await (from s in _sportsContext.Student join c in _sportsContext.Class on s.ClassId equals c.Id join g in _sportsContext.Grade on c.GradeId equals g.Id where s.SchoolCode == schoolCode select new StudentInfoDto() { Id = s.Id, OrgId = orgId, UserId = s.Id, StudentNo = s.StudentNo, Name = s.StudentName, Sex = s.Sex == 1 ? "男" : "女", ClassId = c.Id, GradeId = g.Id, RuleGradeId = g.Id, ClassName = c.ClassName, GradeName = g.GradeName, CardNo = new List() }).ToListAsync(); return res; } /// /// 获取名单列表 /// /// /// /// /// public async Task> SportsRosterList(int orgId, int userId = 0) { string schoolCode = await _sportsContext.School.Where(x => x.Id == orgId).Select(x => x.SchoolCode).FirstAsync(); var studentList = await _sportsContext.Student.Where(x => x.SchoolCode == schoolCode).ToListAsync(); var list = await (from c in _sportsContext.Class join g in _sportsContext.Grade on c.GradeId equals g.Id where c.SchoolCode == schoolCode select new SportsRosterDto() { Id = c.Id, OrgId = orgId, Name = c.ClassName, GradeId = g.Id, RuleGradeId = g.Id, GradeName = g.GradeName, Status = 1, Type = 1 }).ToListAsync(); foreach (var item in list) { var stuList = studentList.Where(x => x.ClassId == item.Id).ToList(); List sportList = new List(); foreach (var sport in stuList) { sportList.Add(new SportsRosterStudentDto() { Id = sport.Id, GroupName = item.Name, ClassId = item.Id, ClassName = item.Name, GradeId = item.GradeId, GradeName = item.GradeName, OrgId = orgId, Sex = sport.Sex, UserName = sport.StudentName, StudentNo = sport.StudentNo, UserId = sport.Id, GroupOrder = 1, RosterId = 1, }); } item.RosterGroupList.Add(new SportsRosterGroupDto() { GroupName = item.Name, RosterStudentList = sportList }); } return list; } /// /// 获取人脸信息 /// /// /// public async Task FaceListOfDevicePage(FaceListOfDeviceDto dto) { string schoolCode = await _sportsContext.School.Where(x => x.Id == dto.OrgId).Select(x => x.SchoolCode).FirstAsync(); var total = await _sportsContext.Student.CountAsync(x => x.SchoolCode == schoolCode && !string.IsNullOrWhiteSpace(x.Photo)); var list = await _sportsContext.Student .Where(x => x.SchoolCode == schoolCode && !string.IsNullOrWhiteSpace(x.Photo)) .Select(s => new DeviceUserFaceVo() { FaceId = s.StudentNo, FaceType = 1, FaceUrl = s.Photo, PersonId = s.StudentNo, UserId = s.Id }) .Skip((dto.PageNo - 1) * dto.PageSize) .Take(dto.PageSize) .ToListAsync(); return new FaceListOfDevicePageDto() { Total = total, PageNum = dto.PageNo, PageSize = dto.PageSize, Pages = (int)Math.Ceiling((double)total / dto.PageSize), List = list }; } /// /// 获取训练评分规则 /// /// 学校Id /// public async Task> ScoreRules(int orgId) { var scoreRules = await _sportsContext.HealthStandards.ToListAsync(); var projects = await _sportsContext.XW_TestingProject.ToListAsync(); var projectModels = await _sportsContext.XW_ProjectMode.ToListAsync(); var scoreRuleItemsByType = scoreRules .GroupBy(x => x.CategoryEnum) .ToDictionary(g => g.Key, g => g.ToList()); List res = new List(); foreach (var projectModel in projectModels) { var project = projects.FirstOrDefault(x => x.ProjectId == projectModel.ProjectKind); if (project == null) continue; // Skip if project doesn't exist var scoreRuleTypes = projectModel.CategoryEnum.Split(','); var scoreRuleItems = scoreRuleTypes.SelectMany(type => scoreRuleItemsByType.GetValueOrDefault(type, new List())).ToList(); var groupedItemsData = scoreRuleItems.GroupBy(x => x.GradeId).ToList(); foreach (var grouped in groupedItemsData) { var maleItems = grouped.Where(x => x.Sex == 1).ToList(); var femaleItems = grouped.Where(x => x.Sex == 2).ToList(); var maleMax = maleItems.DefaultIfEmpty().Max(x => x?.MaxValue ?? 0); var maleMin = maleItems.DefaultIfEmpty().Max(x => x?.MinValue ?? 0); var maleMaxScore = maleItems.DefaultIfEmpty().Max(x => x?.Score ?? 0); var femaleMax = femaleItems.DefaultIfEmpty().Max(x => x?.MaxValue ?? 0); var femaleMin = femaleItems.DefaultIfEmpty().Max(x => x?.MinValue ?? 0); var femaleMaxScore = femaleItems.DefaultIfEmpty().Max(x => x?.Score ?? 0); ScoreRuleDto scoreRuleDto = new ScoreRuleDto { GradeId = grouped.Key, OrgId = orgId, ProjectKind = project.ProjectId, ProjectName = project.ProjectName, ModelType = projectModel.Id, RuleType = 1, ProjectId = project.ProjectId, Items = grouped.Select(item => new ScoreRuleItemDto { Id = item.Id, Sex = item.Sex, Name = "1", Score = item.Score, Max = item.MaxValue, Min = item.MinValue }).ToList() }; scoreRuleDto.Pluses = new List { new ScoreRulePlusDto() { Id = grouped.FirstOrDefault()?.Id ?? 0, Sex = 1, Max = maleMax, Min = maleMin, MaxScore = maleMaxScore, Score = maleMaxScore }, new ScoreRulePlusDto() { Id = grouped.FirstOrDefault()?.Id ?? 0, Sex = 2, Max = femaleMax, Min = femaleMin, MaxScore = femaleMaxScore, Score = femaleMaxScore } }; scoreRuleDto.ScoreScopes = new List { new ScoreScope() { Gender = 1, MaxScore = maleMaxScore, MaxCount = maleMax }, new ScoreScope() { Gender = 2, MaxScore = femaleMaxScore, MaxCount = femaleMax } }; res.Add(scoreRuleDto); } } return res; } /// /// 新增训练 /// /// /// public async Task AddTrain(AddTrainDto dto) { var entity = _mapper.Map(dto); Console.WriteLine(JsonConvert.SerializeObject(entity)); if (entity != null) { try { await _sportsContext.XW_SportsTestData.AddAsync(entity); var res = _mapper.Map(entity); var sportsTestValueEntinys = await AddSportsTestValueEntity(dto); await _sportsContext.SportsTestValue.AddRangeAsync(sportsTestValueEntinys); await _sportsContext.SaveChangesAsync(); Console.WriteLine("新增成功"); return res; } catch (Exception e) { Console.WriteLine(e.Message + "/n" + e.InnerException); } } return null; } private async Task> AddSportsTestValueEntity(AddTrainDto dto) { var sportsTestValueEntinys = new List(); string schoolCode = await _sportsContext.School.Where(x => x.Id == dto.OrgId).Select(x => x.SchoolCode).FirstAsync(); var healthStandards = await _sportsContext.HealthStandards.ToListAsync(); var xwProject = await _sportsContext.XW_TestingProject.ToListAsync(); var nowTime = DateTime.Now; foreach (var data in dto.StudentList) { if (data.Achievement == 0) continue; var sportsTestValueEntity = new N_SportsTestValue(); var project = xwProject.Where(x => x.ProjectId == dto.ProjectId).FirstOrDefault(); string categoryEnum = project?.CategoryEnum ?? ""; var standard = healthStandards.Where(x => x.CategoryEnum.Equals(categoryEnum) && x.GradeId == data.GradeId && x.Sex == data.Sex && data.Achievement >= x.MinValue && data.Achievement < x.MaxValue ).FirstOrDefault(); if (standard != null) { sportsTestValueEntity.Score = standard.Score; sportsTestValueEntity.Rank = standard.Rank; } sportsTestValueEntity.SchoolCode = schoolCode; sportsTestValueEntity.Sex = (int)data.Sex; sportsTestValueEntity.DataSource = DataSource.XW; sportsTestValueEntity.CategoryValue = project?.CategoryValue ?? 0; sportsTestValueEntity.CategoryEnum = categoryEnum; sportsTestValueEntity.GradeId = data.GradeId; sportsTestValueEntity.GradeName = data.GradeName; sportsTestValueEntity.ClassId = data.ClassId; sportsTestValueEntity.ClassName = data.ClassName; sportsTestValueEntity.TeacherId = data.TeacherId ?? 0; sportsTestValueEntity.TeacherName = data.Teacher; sportsTestValueEntity.StudentNo = data.StudentNo; sportsTestValueEntity.StudentName = data.StudentName; sportsTestValueEntity.Value = data.Achievement ?? 0; sportsTestValueEntity.Creator = dto.OrgId ?? 0; sportsTestValueEntity.CreateDate = nowTime; sportsTestValueEntity.ScoreTime = Convert.ToDateTime(dto.StartTime); sportsTestValueEntity.AdditionalScore = (float)(data.PlusesScore ?? 0); SemesterDto semesterDto = new SemesterDto(); sportsTestValueEntity.Year = semesterDto.Year; sportsTestValueEntity.Semester = semesterDto.Semester; sportsTestValueEntity.IsDisplay = true; sportsTestValueEntinys.Add(sportsTestValueEntity); } return sportsTestValueEntinys; } /// /// 年级排名 /// /// /// /// /// public async Task GradeRankingGet(int studentId, int trainId) { var res = new GradeRankingVo(); var now = DateTime.UtcNow; var firstDayOfMonth = new DateTime(now.Year, now.Month, 1); var lastDayOfMonth = firstDayOfMonth.AddMonths(1).AddDays(-1); var studentResults = await _sportsContext.XW_TrainStudents.Where(x => x.XW_SportsTestDataId == trainId) .Select(x => new { x.GradeId, x.StudentId, x.StudentName, x.Rating, x.CreateTime, x.Score }).ToListAsync(); var student = studentResults.FirstOrDefault(x => x.StudentId == studentId); if (student == null) { return res; } var rankedResults = studentResults .Where(x => x.GradeId == student.GradeId && DateTime.TryParse(x.CreateTime, out var createTime) && createTime >= firstDayOfMonth && createTime <= lastDayOfMonth) .OrderByDescending(x => x.Score) .Select((x, index) => new { x.StudentId, Rank = index + 1 }) .ToList(); var studentRank = rankedResults.FirstOrDefault(x => x.StudentId == student.StudentId)?.Rank.ToString() ?? "无数据"; res.Rating = student.Rating.ToString() ?? "无数据"; res.MonthRanking = studentRank; return res; } /// /// 全部历史记录 /// /// /// public async Task HistoryGet(HistoryGetDto dto) { var res = new TrainHistoryResponseDto(); var trainList = await _sportsContext.XW_SportsTestData .Where(x => x.OrgId == dto.OrgId && x.ProjectKind == Convert.ToInt32(dto.ProjectKind) && x.ModelType == dto.ModelType) .ToListAsync(); if (trainList == null || !trainList.Any()) return res; var trainIds = trainList.Select(t => t.Id).ToList(); var query = _sportsContext.XW_TrainStudents .Where(x => trainIds.Contains(x.XW_SportsTestDataId)) .AsQueryable(); // 动态排序 if (!string.IsNullOrEmpty(dto.OrderByColumn)) { bool isAsc = dto.IsAsc?.ToLower() == "asc"; query = isAsc ? query.OrderBy(x => EF.Property(x, dto.OrderByColumn)) : query.OrderByDescending(x => EF.Property(x, dto.OrderByColumn)); } else { query = query.OrderByDescending(x => x.Id); // 默认排序 } var total = await query.CountAsync(); var list = await query .Skip((dto.PageNo - 1) * dto.PageSize) .Take(dto.PageSize) .Select(x => new TrainHistoryVo() { TrainStudentId = x.Id, ClassName = x.ClassName, CreateTime = x.CreateTime ?? "无数据", Achievement = x.Achievement.ToString() ?? "无数据", Rating = x.Rating.ToString() ?? "无数据", Score = x.Score.ToString() ?? "无数据", Sex = x.Sex == 1 ? "男" : "女", StudentName = x.StudentName, TouristFlag = false, DoubleFlag = false, }).OrderByDescending(x => x.CreateTime) .ToListAsync(); res.Total = total; res.Rows = list; return res; } /// /// 历史记录详细 /// /// /// public async Task TrainAnalysisHistoryDetail(HistoryDetailRequestDto dto) { var trainModel = await _sportsContext.XW_TrainStudents.Where(x => x.Id == dto.TrainStudentId).Select(x => new { x.XW_SportsTestDataId, x.StudentId }).FirstAsync(); var stuHeadUrl = await _sportsContext.Student.Where(x => x.Id == trainModel.StudentId).Select(x => x.Photo).FirstOrDefaultAsync(); var trainName = await _sportsContext.XW_SportsTestData.Where(x => x.Id == trainModel.XW_SportsTestDataId).Select(x => x.ProjectName).FirstOrDefaultAsync(); var now = DateTime.UtcNow; var firstDayOfMonth = new DateTime(now.Year, now.Month, 1); var lastDayOfMonth = firstDayOfMonth.AddMonths(1).AddDays(-1); var studentResults = await _sportsContext.XW_TrainStudents.Where(x => x.XW_SportsTestDataId == trainModel.XW_SportsTestDataId) .Select(x => new { x.GradeId, x.StudentId, x.StudentName, x.Rating, x.CreateTime, x.Score }).ToListAsync(); var student = studentResults.FirstOrDefault(x => x.StudentId == trainModel.StudentId); if (student == null) { return null; } var rankedResults = studentResults .Where(x => x.GradeId == student.GradeId && DateTime.TryParse(x.CreateTime, out var createTime) && createTime >= firstDayOfMonth && createTime <= lastDayOfMonth) .OrderByDescending(x => x.Score) .Select((x, index) => new { x.StudentId, Rank = index + 1 }) .ToList(); var studentRank = rankedResults.FirstOrDefault(x => x.StudentId == student.StudentId)?.Rank.ToString() ?? "无数据"; var res = await _sportsContext.XW_TrainStudents.Where(x => x.Id == dto.TrainStudentId).Include(x => x.TrainViolationsBO).Select(x => new TrainAnalusisVo() { Achievement = x.Achievement.ToString() ?? "无数据", ClassName = x.ClassName, GradeRanking = studentRank, HeadImgUrl = stuHeadUrl, ProjectName = trainName, Rating = x.Rating.ToString() ?? "无数据", Score = x.Score.ToString() ?? "无数据", Sex = x.Sex == 1 ? "男" : "女", StudentName = x.StudentName, Times = x.Times.ToString(), VideoRecord = x.VideoRecord, ViolationsNumber = x.TrainViolationsBO.Count(), TrainViolationsVo = x.TrainViolationsBO.Select(x => new TrainViolationsVo() { CreateTime = x.TrainTime, TrainTime = x.TrainTime, PicUrl = x.PicUrl, ViolationId = x.ViolationId, ViolationName = "", }).ToList(), }).FirstOrDefaultAsync(); return res; } /// /// 个人历史记录-历史成绩 /// /// /// public async Task HistoryPersonGet(HistoryPersonGetDto dto) { var trainList = await _sportsContext.XW_SportsTestData .Where(x => x.OrgId == dto.OrgId && x.ProjectKind == Convert.ToInt32(dto.ProjectKind) && x.ModelType == dto.ModelType) .ToListAsync(); var trainIds = trainList.Select(t => t.Id).ToList(); var studentResults = await _sportsContext.XW_TrainStudents.Where(x => trainIds.Contains(x.XW_SportsTestDataId)) .Select(x => new { x.Id, x.ClassName, x.StudentId, x.StudentName, x.GradeId, x.Sex, x.Score, x.CreateTime }).ToListAsync(); var student = studentResults.FirstOrDefault(x => x.StudentId == dto.StudentId); if (student == null) { return new TrainHistoryPersonVo(); } var rankedResults = studentResults.Where(x => x.GradeId == student.GradeId) .OrderByDescending(x => x.Score) .Select((x, index) => new { x, Rank = index + 1 }) .ToList(); var monthList = studentResults.Where(x => DateTime.TryParse(x.CreateTime, out var date) && date.Year == DateTime.Now.Year && date.Month == DateTime.Now.Month).ToList(); var monthRankedResults = studentResults.Where(x => x.GradeId == student.GradeId) .OrderByDescending(x => x.Score) .Select((x, index) => new { x, Rank = index + 1 }) .ToList(); var stuHeadUrl = await _sportsContext.Student.Where(x => x.Id == student.StudentId).Select(x => x.Photo).FirstOrDefaultAsync(); var res = new TrainHistoryPersonVo() { ClassName = student.ClassName, HeadImgUrl = stuHeadUrl, Sex = student.Sex == 1 ? "男" : "女", StudentName = student.StudentName, HistoryBestScore = studentResults.Max(x => x.Score)?.ToString() ?? "无数据", HistoryRanking = rankedResults.FirstOrDefault(x => x.x.Score == student.Score)?.Rank.ToString() ?? "-1", MonthBestScore = monthList.Max(x => x.Score)?.ToString() ?? "无数据", MonthRanking = monthRankedResults.FirstOrDefault(x => x.x.Score == student.Score)?.Rank.ToString() ?? "-1" }; return res; } /// /// 个人历史记录-记录列表 /// /// /// public async Task HistoryPersonListGet(HistoryPersonListDto dto) { var res = new TableDataPersonAnalysisVo(); var trainList = await _sportsContext.XW_SportsTestData .Where(x => x.OrgId == dto.OrgId && x.ProjectKind == Convert.ToInt32(dto.ProjectKind) && x.ModelType == dto.ModelType) .ToListAsync(); if (trainList == null || !trainList.Any()) return res; var trainIds = trainList.Select(t => t.Id).ToList(); var query = _sportsContext.XW_TrainStudents .Where(x => trainIds.Contains(x.XW_SportsTestDataId) && x.StudentId == dto.StudentId) .AsQueryable(); // 动态排序 if (!string.IsNullOrEmpty(dto.OrderByColumn)) { bool isAsc = dto.IsAsc?.ToLower() == "asc"; query = isAsc ? query.OrderBy(x => EF.Property(x, dto.OrderByColumn)) : query.OrderByDescending(x => EF.Property(x, dto.OrderByColumn)); } else { query = query.OrderByDescending(x => x.Id); // 默认排序 } var total = await query.CountAsync(); var list = await query .Skip((dto.PageNo - 1) * dto.PageSize) .Take(dto.PageSize) .Select(x => new PersonAnalysisVo() { TrainStudentId = x.Id, ClassName = x.ClassName, CreateTime = x.CreateTime ?? "无数据", Achievement = x.Achievement.ToString() ?? "无数据", Rating = x.Rating.ToString() ?? "无数据", Score = x.Score.ToString() ?? "无数据", Sex = x.Sex == 1 ? "男" : "女", StudentName = x.StudentName, DoubleFlag = false, }).OrderByDescending(x => x.CreateTime) .ToListAsync(); res.Total = total; res.Rows = list; return res; } /// /// 成绩榜-年级列表 /// /// /// public async Task> GetGradeListByOrg(int orgId) { string schoolCode = await _sportsContext.School.Where(x => x.Id == orgId).Select(x => x.SchoolCode).FirstAsync(); var res = await (from s in _sportsContext.SchoolAssocGrade join g in _sportsContext.Grade on s.GradeId equals g.Id where s.SchoolCode == schoolCode select new GradeVo() { GradeId = g.Id, GradeName = g.GradeName }).ToListAsync(); return res; } /// /// 成绩榜-年级列表 /// /// /// public async Task ScoreRanking(ScoreRankingDto dto) { var res = new ScoreRankingVo(); var trainList = await _sportsContext.XW_SportsTestData .Where(x => x.OrgId == dto.OrgId && x.ProjectKind == Convert.ToInt32(dto.ProjectKind) && x.ModelType == Convert.ToInt32(dto.ModelType)) .ToListAsync(); var trainIds = trainList.Select(t => t.Id).ToList(); var (startDate, endDate) = dto.Times switch { "1" => (DateTime.UtcNow.AddDays(-7), DateTime.UtcNow), // 本周 "2" => (DateTime.UtcNow.AddMonths(-1), DateTime.UtcNow), // 本月 "3" => (new DateTime(DateTime.UtcNow.Year, 9, 1), DateTime.UtcNow), // 本学期 _ => (DateTime.MinValue, DateTime.MaxValue) }; // 先从数据库查询基本数据(不带时间过滤) var rawResults = await _sportsContext.XW_TrainStudents .Where(x => trainIds.Contains(x.XW_SportsTestDataId) && x.GradeId == dto.GradeId) .Select(x => new { x.StudentName, x.ClassName, x.Achievement, x.CreateTime, x.Sex }) .ToListAsync(); // 先加载到内存 // 在内存中进行时间和性别过滤 var studentResults = rawResults .Where(x => DateTime.TryParse(x.CreateTime, out var date) && date >= startDate && date <= endDate) // 过滤时间 .Where(x => dto.Sex == "1" ? x.Sex == 1 : dto.Sex == "2" ? x.Sex == 2 : true) // 过滤性别 .Select(x => new RankingVo() { Name = x.StudentName, ClassName = x.ClassName, Achievement = x.Achievement.ToString() ?? "无数据" }).OrderByDescending(x => x.Achievement) .ToList(); res.Times = dto.Times; res.Lists = studentResults; return res; } } }