package com.tcm.training.admin.live.service;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.tcm.training.admin.common.Jsons;
|
import com.tcm.training.admin.common.PageResponse;
|
import com.tcm.training.admin.live.dto.LiveCourseStatusRequest;
|
import com.tcm.training.admin.live.dto.LiveCourseUpsertRequest;
|
import com.tcm.training.admin.live.dto.LiveCoursePasswordRequest;
|
import com.tcm.training.admin.live.dto.LiveCoursePasswordVerifyRequest;
|
import com.tcm.training.admin.live.entity.Expert;
|
import com.tcm.training.admin.live.entity.LiveCourse;
|
import com.tcm.training.admin.live.entity.LiveSession;
|
import com.tcm.training.admin.live.entity.LiveSessionQuestion;
|
import com.tcm.training.admin.live.mapper.ExpertMapper;
|
import com.tcm.training.admin.live.mapper.LiveCourseMapper;
|
import com.tcm.training.admin.live.mapper.LiveSessionMapper;
|
import com.tcm.training.admin.live.mapper.LiveSessionQuestionMapper;
|
import com.tcm.training.admin.live.vo.ExpertVO;
|
import com.tcm.training.admin.live.vo.LiveCourseDetailVO;
|
import com.tcm.training.admin.live.vo.LiveCourseListItemVO;
|
import com.tcm.training.admin.live.vo.LiveCourseListRow;
|
import com.tcm.training.admin.live.vo.LiveCourseDetailRow;
|
import com.tcm.training.admin.live.vo.LiveCourseStatusVO;
|
import org.springframework.stereotype.Service;
|
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class LiveCourseAppService {
|
|
private static final int LIVE_ROOM_PASSWORD_TYPE = 1;
|
|
private final LiveCourseMapper liveCourseMapper;
|
private final ExpertMapper expertMapper;
|
private final LiveSessionMapper liveSessionMapper;
|
private final LiveSessionQuestionMapper liveSessionQuestionMapper;
|
private final BCryptPasswordEncoder passwordEncoder;
|
|
public LiveCourseAppService(LiveCourseMapper liveCourseMapper,
|
ExpertMapper expertMapper,
|
LiveSessionMapper liveSessionMapper,
|
LiveSessionQuestionMapper liveSessionQuestionMapper,
|
BCryptPasswordEncoder passwordEncoder) {
|
this.liveCourseMapper = liveCourseMapper;
|
this.expertMapper = expertMapper;
|
this.liveSessionMapper = liveSessionMapper;
|
this.liveSessionQuestionMapper = liveSessionQuestionMapper;
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public PageResponse<LiveCourseListItemVO> page(int page, int pageSize, String keyword, Long expertId, Integer status, Integer liveStatus) {
|
IPage<LiveCourseListRow> p = liveCourseMapper.selectCoursePage(new Page<LiveCourseListRow>(page, pageSize),
|
keyword, expertId, status, liveStatus);
|
|
List<LiveCourseListItemVO> list = new ArrayList<LiveCourseListItemVO>();
|
for (LiveCourseListRow row : p.getRecords()) {
|
LiveCourseListItemVO vo = new LiveCourseListItemVO();
|
vo.setId(row.getId());
|
vo.setTitle(row.getTitle());
|
vo.setLevel(row.getLevel());
|
vo.setExpert(new ExpertVO(row.getExpertId(), row.getExpertName(), row.getExpertAvatar()));
|
vo.setCoverImg(row.getCoverImg());
|
vo.setReserveCount(row.getReserveCount() == null ? 0L : row.getReserveCount());
|
vo.setWatchCount(row.getWatchCount() == null ? 0L : row.getWatchCount());
|
vo.setQuizPoints(row.getQuizPoints());
|
vo.setStartTime(row.getStartTime());
|
vo.setLiveStatus(row.getLiveStatus());
|
vo.setStatus(row.getStatus());
|
vo.setCreatedAt(row.getCreatedAt());
|
list.add(vo);
|
}
|
|
return PageResponse.of(list, p.getTotal(), p.getCurrent(), p.getSize());
|
}
|
|
@Transactional
|
public LiveCourseDetailVO create(LiveCourseUpsertRequest req) {
|
throw new IllegalArgumentException("直播课程为初始化数据，禁止新增");
|
/*
|
validateExpert(req.getExpertId());
|
|
LiveCourse course = new LiveCourse();
|
course.setTitle(req.getTitle());
|
course.setLevel(req.getLevel());
|
course.setExpertId(req.getExpertId());
|
course.setCoverImg(req.getCoverImg());
|
course.setBannerImgs(req.getBannerImgs());
|
course.setIntro(req.getIntro());
|
course.setTargetUsers(req.getTargetUsers());
|
course.setQuizDelayMinutes(req.getQuizDelayMinutes());
|
course.setQuizPoints(req.getQuizPoints());
|
course.setStatus(req.getStatus());
|
liveCourseMapper.insert(course);
|
|
return detail(course.getId());
|
*/
|
}
|
|
public LiveCourseDetailVO detail(Long id) {
|
LiveCourseDetailRow row = liveCourseMapper.selectCourseDetail(id);
|
if (row == null) {
|
throw new IllegalArgumentException("课程不存在");
|
}
|
|
LiveCourseDetailVO vo = new LiveCourseDetailVO();
|
vo.setId(row.getId());
|
vo.setTitle(row.getTitle());
|
vo.setLevel(row.getLevel());
|
vo.setExpert(new ExpertVO(row.getExpertId(), row.getExpertName(), row.getExpertAvatar()));
|
vo.setCoverImg(row.getCoverImg());
|
vo.setBannerImgs(Jsons.parseStringList(row.getBannerImgs()));
|
vo.setIntro(row.getIntro());
|
vo.setTargetUsers(row.getTargetUsers());
|
vo.setQuizDelayMinutes(row.getQuizDelayMinutes());
|
vo.setQuizPoints(row.getQuizPoints());
|
vo.setStartTime(row.getStartTime());
|
vo.setVideoUrl(row.getVideoUrl());
|
vo.setLiveStatus(row.getLiveStatus());
|
vo.setStatus(row.getStatus());
|
vo.setReserveCount(row.getReserveCount() == null ? 0L : row.getReserveCount());
|
vo.setWatchCount(row.getWatchCount() == null ? 0L : row.getWatchCount());
|
vo.setCreatedAt(row.getCreatedAt());
|
vo.setUpdatedAt(row.getUpdatedAt());
|
return vo;
|
}
|
|
@Transactional
|
public LiveCourseDetailVO update(Long id, LiveCourseUpsertRequest req) {
|
validateExpert(req.getExpertId());
|
|
LiveCourse course = liveCourseMapper.selectById(id);
|
if (course == null) {
|
throw new IllegalArgumentException("课程不存在");
|
}
|
|
course.setTitle(req.getTitle());
|
course.setLevel(req.getLevel());
|
course.setExpertId(req.getExpertId());
|
course.setCoverImg(req.getCoverImg());
|
course.setBannerImgs(req.getBannerImgs());
|
course.setIntro(req.getIntro());
|
course.setTargetUsers(req.getTargetUsers());
|
course.setQuizDelayMinutes(req.getQuizDelayMinutes());
|
course.setQuizPoints(req.getQuizPoints());
|
course.setStatus(req.getStatus());
|
liveCourseMapper.updateById(course);
|
|
return detail(id);
|
}
|
|
@Transactional
|
public LiveCourseStatusVO patchStatus(Long id, LiveCourseStatusRequest req) {
|
LiveCourse course = liveCourseMapper.selectById(id);
|
if (course == null) {
|
throw new IllegalArgumentException("课程不存在");
|
}
|
course.setStatus(req.getStatus());
|
liveCourseMapper.updateById(course);
|
return new LiveCourseStatusVO(id, req.getStatus());
|
}
|
|
@Transactional
|
public void updatePassword(Long id, LiveCoursePasswordRequest req) {
|
String password = req.getPassword();
|
if (StrUtil.isNotBlank(password)) {
|
if (password.length() != 6) {
|
throw new IllegalArgumentException("直播间密码必须是6个字符");
|
}
|
}
|
LiveCourse course = liveCourseMapper.selectById(id);
|
if (course == null) {
|
throw new IllegalArgumentException("课程不存在");
|
}
|
if (StrUtil.isNotBlank(password)) {
|
course.setPassword(passwordEncoder.encode(req.getPassword()));
|
} else {
|
course.setPassword(null);
|
}
|
liveCourseMapper.updateById(course);
|
}
|
|
public boolean verifyPassword(LiveCoursePasswordVerifyRequest req) {
|
if (req.getType() != LIVE_ROOM_PASSWORD_TYPE) {
|
throw new IllegalArgumentException("不支持的密码类型");
|
}
|
LiveCourse course = liveCourseMapper.selectOne(new LambdaQueryWrapper<LiveCourse>()
|
.isNotNull(LiveCourse::getPassword)
|
.orderByAsc(LiveCourse::getId)
|
.last("limit 1"));
|
return course != null
|
&& course.getPassword() != null
|
&& !course.getPassword().isEmpty()
|
&& passwordEncoder.matches(req.getPassword(), course.getPassword());
|
}
|
|
@Transactional
|
public void delete(Long id) {
|
throw new IllegalArgumentException("直播课程为初始化数据，禁止删除");
|
}
|
|
private void validateExpert(Long expertId) {
|
Expert expert = expertMapper.selectById(expertId);
|
if (expert == null) {
|
throw new IllegalArgumentException("授课专家不存在");
|
}
|
if (expert.getStatus() != null && expert.getStatus() != 1) {
|
throw new IllegalArgumentException("授课专家已禁用");
|
}
|
}
|
|
}
|
