Добавил слой Infrastructure

2026-04-28 15:52:19 +03:00
parent 25d617639c
commit df0e30a1ae
32 changed files with 4139 additions and 0 deletions
@@ -0,0 +1,98 @@
+using Microsoft.EntityFrameworkCore;
+using UniVerse.Application.DTOs.Common;
+using UniVerse.Application.DTOs.Reviews;
+using UniVerse.Application.Interfaces;
+using UniVerse.Application.Mappings;
+using UniVerse.Domain.Entities;
+using UniVerse.Domain.Enums;
+using UniVerse.Domain.Exceptions;
+using UniVerse.Infrastructure.Data;
+
+namespace UniVerse.Infrastructure.Services;
+
+public class ReviewService : IReviewService
+{
+    private readonly AppDbContext _db;
+    public ReviewService(AppDbContext db) => _db = db;
+
+    private IQueryable<Review> BaseQuery() => _db.Reviews
+        .Include(r => r.Lecture).Include(r => r.User);
+
+    public async Task<ReviewDto> CreateAsync(int userId, CreateReviewRequest req)
+    {
+        _ = await _db.Lectures.FindAsync(req.LectureId) ?? throw new NotFoundException("Lecture", req.LectureId);
+        if (await _db.Reviews.AnyAsync(r => r.LectureId == req.LectureId && r.UserId == userId))
+            throw new ConflictException("You already reviewed this lecture.");
+        var review = new Review
+        {
+            LectureId = req.LectureId, UserId = userId,
+            Rating = req.Rating, Text = req.Text,
+            LlmStatus = ReviewLlmStatus.Pending
+        };
+        _db.Reviews.Add(review);
+        await _db.SaveChangesAsync();
+        var full = await BaseQuery().FirstAsync(r => r.Id == review.Id);
+        return full.ToDto();
+    }
+
+    public async Task<ReviewDto> GetByIdAsync(int id)
+    {
+        var review = await BaseQuery().FirstOrDefaultAsync(r => r.Id == id)
+            ?? throw new NotFoundException("Review", id);
+        return review.ToDto();
+    }
+
+    public async Task<ReviewDto> UpdateAsync(int id, int userId, UpdateReviewRequest req)
+    {
+        var review = await _db.Reviews.FindAsync(id) ?? throw new NotFoundException("Review", id);
+        if (review.UserId != userId) throw new ForbiddenException();
+        review.Rating = req.Rating; review.Text = req.Text;
+        review.LlmStatus = ReviewLlmStatus.Pending;
+        review.UpdatedAt = DateTime.UtcNow;
+        await _db.SaveChangesAsync();
+        return await GetByIdAsync(id);
+    }
+
+    public async Task DeleteAsync(int id, int userId, bool isAdmin = false)
+    {
+        var review = await _db.Reviews.FindAsync(id) ?? throw new NotFoundException("Review", id);
+        if (review.UserId != userId && !isAdmin) throw new ForbiddenException();
+        _db.Reviews.Remove(review);
+        await _db.SaveChangesAsync();
+    }
+
+    public async Task<PagedResult<ReviewDto>> GetByLectureAsync(int lectureId, PaginationRequest pagination)
+    {
+        var query = BaseQuery().Where(r => r.LectureId == lectureId);
+        var total = await query.CountAsync();
+        var items = await query.OrderByDescending(r => r.CreatedAt)
+            .Skip((pagination.Page - 1) * pagination.PageSize).Take(pagination.PageSize).ToListAsync();
+        return PagedResult<ReviewDto>.Create(items.Select(r => r.ToDto()).ToList(), total, pagination.Page, pagination.PageSize);
+    }
+
+    public async Task<PagedResult<ReviewDto>> GetByUserAsync(int userId, PaginationRequest pagination)
+    {
+        var query = BaseQuery().Where(r => r.UserId == userId);
+        var total = await query.CountAsync();
+        var items = await query.OrderByDescending(r => r.CreatedAt)
+            .Skip((pagination.Page - 1) * pagination.PageSize).Take(pagination.PageSize).ToListAsync();
+        return PagedResult<ReviewDto>.Create(items.Select(r => r.ToDto()).ToList(), total, pagination.Page, pagination.PageSize);
+    }
+
+    public async Task<PagedResult<ReviewDto>> GetPendingAsync(PaginationRequest pagination)
+    {
+        var query = BaseQuery().Where(r => r.LlmStatus == ReviewLlmStatus.Pending);
+        var total = await query.CountAsync();
+        var items = await query.OrderBy(r => r.CreatedAt)
+            .Skip((pagination.Page - 1) * pagination.PageSize).Take(pagination.PageSize).ToListAsync();
+        return PagedResult<ReviewDto>.Create(items.Select(r => r.ToDto()).ToList(), total, pagination.Page, pagination.PageSize);
+    }
+
+    public async Task ReanalyzeAsync(int id)
+    {
+        var review = await _db.Reviews.FindAsync(id) ?? throw new NotFoundException("Review", id);
+        review.LlmStatus = ReviewLlmStatus.Pending;
+        review.UpdatedAt = DateTime.UtcNow;
+        await _db.SaveChangesAsync();
+    }
+}