backend/src/main/java/nju/seec/helper/service/impl/CourseServiceImpl.java

package nju.seec.helper.service.impl;

import nju.seec.helper.dao.ChooseDAO;
import nju.seec.helper.dao.CourseDAO;
import nju.seec.helper.dto.ChooseDTO;
import nju.seec.helper.dto.CourseDTO;
import nju.seec.helper.dto.LoginUser;
import nju.seec.helper.entity.Choose;
import nju.seec.helper.entity.Course;
import nju.seec.helper.service.CourseService;
import nju.seec.helper.service.util.AuthUtils;
import nju.seec.helper.service.util.RefreshUtils;
import nju.seec.helper.util.EncryptUtils;
import nju.seec.helper.util.enums.ExceptionType;
import nju.seec.helper.util.exception.HelperException;
import nju.seec.helper.vo.CourseVO;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * @author cst
 */
@Service
public class CourseServiceImpl implements CourseService {
    private final CourseDAO courseDAO;
    private final ChooseDAO chooseDAO;

    private final RefreshUtils refreshUtils;

    public CourseServiceImpl(CourseDAO courseDAO, ChooseDAO chooseDAO, RefreshUtils refreshUtils) {
        this.courseDAO = courseDAO;
        this.chooseDAO = chooseDAO;
        this.refreshUtils = refreshUtils;
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public CourseVO createCourse(LoginUser teacher, CourseDTO courseDTO) {
        // 检查
        checkSameCourseName(0, teacher.getId(), courseDTO.getName());

        Course course = new Course()
                .setTeacherId(teacher.getId())
                .setTeacherName(teacher.getName())
                .setName(courseDTO.getName())
                .setBio(courseDTO.getBio())
                .setCode(EncryptUtils.encode(courseDTO.getCode()));
        course = courseDAO.save(course);
        return new CourseVO(course);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public CourseVO modifyCourse(LoginUser user, CourseDTO courseDTO) {
        Course course = courseDAO.findCourseById(courseDTO.getId());

        // 检查
        AuthUtils.checkDataAuth(user.getId(), course.getTeacherId(), "您无权修改该课程");
        checkSameCourseName(course.getId(), user.getId(), courseDTO.getName());

        course.setName(courseDTO.getName())
                .setBio(courseDTO.getBio())
                .setCode(EncryptUtils.encode(courseDTO.getCode()));
        course = courseDAO.save(course);
        refreshUtils.refreshCourse(course);
        return new CourseVO(course);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public void removeCourse(LoginUser user, Integer courseId) {
        Course course = courseDAO.findCourseById(courseId);
        AuthUtils.checkDataAuth(user.getId(), course.getTeacherId(), "您无权删除该课程");

        course.setDeleteAt(System.currentTimeMillis());
        courseDAO.save(course);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public void chooseCourse(LoginUser student, ChooseDTO chooseDTO) {
        Integer studentId = student.getId();
        if (chooseDAO.existsByStudentIdAndCourseId(studentId, chooseDTO.getCourseId())) {
            throw HelperException.of(ExceptionType.CONFLICT, "您已选课");
        }

        Course course = courseDAO.findCourseById(chooseDTO.getCourseId());

        if (!course.getCode().equals(EncryptUtils.encode(chooseDTO.getCode()))) {
            throw HelperException.of(ExceptionType.NOT_FOUND, "选课码错误");
        }

        Choose choose = new Choose()
                .setCourseId(chooseDTO.getCourseId())
                .setStudentId(studentId);
        chooseDAO.save(choose);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public void quitCourse(LoginUser user, Integer courseId) {
        Choose choose = chooseDAO.findByStudentIdAndCourseId(user.getId(), courseId)
                .orElseThrow(() -> HelperException.of(ExceptionType.NOT_FOUND, "找不到选课信息"));
        chooseDAO.deleteById(choose.getId());
    }

    @Transactional(readOnly = true)
    @Override
    public Page<CourseVO> getCourses(String key, Pageable pageable) {
        return courseDAO.findByKey(key, pageable).map(CourseVO::new);
    }

    @Transactional(readOnly = true)
    @Override
    public Page<CourseVO> teacherGetCourses(LoginUser teacher, String key, Pageable pageable) {
        return courseDAO.findByTeacherIdAndKey(teacher.getId(), key, pageable).map(CourseVO::new);
    }

    @Transactional(readOnly = true)
    @Override
    public Page<CourseVO> studentGetCourses(LoginUser student, String key, Pageable pageable) {
        return courseDAO
                .findByIdsAndKey(
                        chooseDAO.findCourseIdsByStudentId(student.getId()),
                        key,
                        pageable)
                .map(CourseVO::new);
    }

    @Transactional(readOnly = true)
    @Override
    public String getCourseCode(LoginUser user, Integer courseId) {
        Course course = courseDAO.findCourseById(courseId);
        AuthUtils.checkDataAuth(user.getId(), course.getTeacherId(), "您无权查看该课程选课码");

        return EncryptUtils.decode(course.getCode());
    }

    @Transactional(readOnly = true)
    @Override
    public CourseVO getOneCourse(Integer courseId) {
        return new CourseVO(courseDAO.findCourseById(courseId));
    }

    /**
     * 检查同名课程
     */
    private void checkSameCourseName(Integer courseId, Integer teacherId, String name) {
        if (courseDAO.existsByTeacherIdAndName(courseId, teacherId, name)) {
            throw HelperException.of(ExceptionType.CONFLICT, "该课程名已使用");
        }
    }
}