package com.tcm.training.admin.live.service;
|
|
import cn.idev.excel.FastExcel;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.tcm.training.admin.common.DateTimes;
|
import com.tcm.training.admin.common.PageResponse;
|
import com.tcm.training.admin.common.PhoneMasker;
|
import com.tcm.training.admin.live.entity.LiveSession;
|
import com.tcm.training.admin.live.excel.LiveReserveExportRow;
|
import com.tcm.training.admin.live.excel.LiveWatchExportRow;
|
import com.tcm.training.admin.live.mapper.LiveCourseMapper;
|
import com.tcm.training.admin.live.mapper.LiveReserveMapper;
|
import com.tcm.training.admin.live.mapper.LiveSessionMapper;
|
import com.tcm.training.admin.live.mapper.LiveSessionQuizRecordMapper;
|
import com.tcm.training.admin.live.mapper.LiveWatchRecordMapper;
|
import com.tcm.training.admin.live.vo.LiveQuizItemVO;
|
import com.tcm.training.admin.live.vo.LiveQuizRow;
|
import com.tcm.training.admin.live.vo.LiveReserveItemVO;
|
import com.tcm.training.admin.live.vo.LiveReservePageVO;
|
import com.tcm.training.admin.live.vo.LiveReserveRow;
|
import com.tcm.training.admin.live.vo.LiveReserveSummaryRow;
|
import com.tcm.training.admin.live.vo.LiveReserveSummaryVO;
|
import com.tcm.training.admin.live.vo.LiveWatchItemVO;
|
import com.tcm.training.admin.live.vo.LiveWatchPageVO;
|
import com.tcm.training.admin.live.vo.LiveWatchRow;
|
import com.tcm.training.admin.live.vo.LiveWatchSummaryRow;
|
import com.tcm.training.admin.live.vo.LiveWatchSummaryVO;
|
import com.tcm.training.admin.live.vo.UserVO;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.net.URLEncoder;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class LiveRecordAppService {
|
|
private final LiveCourseMapper liveCourseMapper;
|
private final LiveSessionMapper liveSessionMapper;
|
private final LiveReserveMapper liveReserveMapper;
|
private final LiveWatchRecordMapper liveWatchRecordMapper;
|
private final LiveSessionQuizRecordMapper liveSessionQuizRecordMapper;
|
|
public LiveRecordAppService(LiveCourseMapper liveCourseMapper,
|
LiveSessionMapper liveSessionMapper,
|
LiveReserveMapper liveReserveMapper,
|
LiveWatchRecordMapper liveWatchRecordMapper,
|
LiveSessionQuizRecordMapper liveSessionQuizRecordMapper) {
|
this.liveCourseMapper = liveCourseMapper;
|
this.liveSessionMapper = liveSessionMapper;
|
this.liveReserveMapper = liveReserveMapper;
|
this.liveWatchRecordMapper = liveWatchRecordMapper;
|
this.liveSessionQuizRecordMapper = liveSessionQuizRecordMapper;
|
}
|
|
public PageResponse<LiveReserveItemVO> pageReserves(Long courseId, Long sessionId, int page, int pageSize, String keyword, Integer isCancel) {
|
requireSession(courseId, sessionId);
|
|
IPage<LiveReserveRow> p = liveReserveMapper.selectReservePage(new Page<LiveReserveRow>(page, pageSize),
|
courseId, sessionId, keyword, isCancel);
|
|
return PageResponse.of(toReserveItems(p.getRecords()), p.getTotal(), p.getCurrent(), p.getSize());
|
}
|
|
public LiveReservePageVO pageGlobalReserves(int page,
|
int pageSize,
|
Long courseId,
|
Long sessionId,
|
String phone,
|
String courseName,
|
Integer liveStatus,
|
Integer hasWatched,
|
LocalDateTime reserveFrom,
|
LocalDateTime reserveTo) {
|
IPage<LiveReserveRow> result = liveReserveMapper.selectGlobalReservePage(
|
new Page<LiveReserveRow>(page, pageSize),
|
courseId,
|
sessionId,
|
trimToNull(phone),
|
trimToNull(courseName),
|
liveStatus,
|
hasWatched,
|
reserveFrom,
|
reserveTo
|
);
|
LiveReservePageVO vo = new LiveReservePageVO();
|
vo.setList(toReserveItems(result.getRecords()));
|
vo.setTotal(result.getTotal());
|
vo.setPage(result.getCurrent());
|
vo.setPageSize(result.getSize());
|
vo.setSummary(buildReserveSummary(courseId, sessionId, phone, courseName, liveStatus, hasWatched, reserveFrom, reserveTo));
|
return vo;
|
}
|
|
public void exportGlobalReserves(HttpServletResponse response,
|
Long courseId,
|
Long sessionId,
|
String phone,
|
String courseName,
|
Integer liveStatus,
|
Integer hasWatched,
|
LocalDateTime reserveFrom,
|
LocalDateTime reserveTo) throws IOException {
|
response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
|
response.setCharacterEncoding("utf-8");
|
String filename = URLEncoder.encode("直播预约记录", "UTF-8").replace("+", "%20");
|
response.setHeader("Content-Disposition", "attachment;filename*=utf-8''" + filename + ".xlsx");
|
|
List<LiveReserveRow> rows = liveReserveMapper.selectGlobalReserveList(
|
courseId,
|
sessionId,
|
trimToNull(phone),
|
trimToNull(courseName),
|
liveStatus,
|
hasWatched,
|
reserveFrom,
|
reserveTo
|
);
|
List<LiveReserveExportRow> exports = new ArrayList<LiveReserveExportRow>();
|
for (int i = 0; i < rows.size(); i++) {
|
LiveReserveRow row = rows.get(i);
|
LiveReserveExportRow export = new LiveReserveExportRow();
|
export.setSerialNo(i + 1);
|
export.setNickname(defaultText(row.getUserNickname()));
|
export.setPhone(PhoneMasker.mask(row.getUserPhone()));
|
export.setCourseTitle(defaultText(row.getCourseTitle()));
|
export.setCategoryName(defaultText(row.getCategoryName()));
|
export.setStartTime(formatMinute(row.getStartTime()));
|
export.setLiveStatus(liveStatusText(row.getLiveStatus()));
|
export.setReserveTime(DateTimes.format(row.getReserveTime()));
|
export.setHasWatched(boolText(row.getHasWatched()));
|
exports.add(export);
|
}
|
FastExcel.write(response.getOutputStream(), LiveReserveExportRow.class)
|
.sheet("直播预约记录")
|
.doWrite(exports);
|
}
|
|
public PageResponse<LiveWatchItemVO> pageWatchRecords(Long courseId, Long sessionId, int page, int pageSize, String keyword, Integer isCompleted, Integer isEffective) {
|
requireSession(courseId, sessionId);
|
|
IPage<LiveWatchRow> p = liveWatchRecordMapper.selectWatchPage(new Page<LiveWatchRow>(page, pageSize),
|
courseId, sessionId, keyword, isCompleted, isEffective);
|
|
return PageResponse.of(toWatchItems(p.getRecords()), p.getTotal(), p.getCurrent(), p.getSize());
|
}
|
|
public LiveWatchPageVO pageGlobalWatchRecords(int page,
|
int pageSize,
|
Long courseId,
|
Long sessionId,
|
String regionCode,
|
String clinicName,
|
String phone,
|
String courseName,
|
Integer hasReserve,
|
Integer isCompleted,
|
Integer isEffective,
|
LocalDateTime watchFrom,
|
LocalDateTime watchTo) {
|
IPage<LiveWatchRow> result = liveWatchRecordMapper.selectGlobalWatchPage(
|
new Page<LiveWatchRow>(page, pageSize),
|
courseId,
|
sessionId,
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(phone),
|
trimToNull(courseName),
|
hasReserve,
|
isCompleted,
|
isEffective,
|
watchFrom,
|
watchTo
|
);
|
LiveWatchPageVO vo = new LiveWatchPageVO();
|
vo.setList(toWatchItems(result.getRecords()));
|
vo.setTotal(result.getTotal());
|
vo.setPage(result.getCurrent());
|
vo.setPageSize(result.getSize());
|
vo.setSummary(buildWatchSummary(courseId, sessionId, regionCode, clinicName, phone, courseName, hasReserve, isCompleted, isEffective, watchFrom, watchTo));
|
return vo;
|
}
|
|
public void exportGlobalWatchRecords(HttpServletResponse response,
|
Long courseId,
|
Long sessionId,
|
String regionCode,
|
String clinicName,
|
String phone,
|
String courseName,
|
Integer hasReserve,
|
Integer isCompleted,
|
Integer isEffective,
|
LocalDateTime watchFrom,
|
LocalDateTime watchTo) throws IOException {
|
response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
|
response.setCharacterEncoding("utf-8");
|
String filename = URLEncoder.encode("直播观看记录", "UTF-8").replace("+", "%20");
|
response.setHeader("Content-Disposition", "attachment;filename*=utf-8''" + filename + ".xlsx");
|
|
List<LiveWatchRow> rows = liveWatchRecordMapper.selectGlobalWatchList(
|
courseId,
|
sessionId,
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(phone),
|
trimToNull(courseName),
|
hasReserve,
|
isCompleted,
|
isEffective,
|
watchFrom,
|
watchTo
|
);
|
List<LiveWatchExportRow> exports = new ArrayList<LiveWatchExportRow>();
|
for (int i = 0; i < rows.size(); i++) {
|
LiveWatchRow row = rows.get(i);
|
LiveWatchExportRow export = new LiveWatchExportRow();
|
export.setSerialNo(i + 1);
|
export.setNickname(defaultText(row.getUserNickname()));
|
export.setPhone(PhoneMasker.mask(row.getUserPhone()));
|
export.setClinicName(defaultText(row.getClinicName()));
|
export.setClinicArea(defaultText(row.getClinicArea()));
|
export.setCourseTitle(defaultText(row.getCourseTitle()));
|
export.setCategoryName(defaultText(row.getCategoryName()));
|
export.setStartTime(formatMinute(row.getStartTime()));
|
export.setHasReserve(boolText(row.getHasReserve()));
|
export.setWatchTime(DateTimes.format(row.getWatchStart()));
|
export.setIsCompleted(boolText(row.getIsCompleted()));
|
exports.add(export);
|
}
|
FastExcel.write(response.getOutputStream(), LiveWatchExportRow.class)
|
.sheet("直播观看记录")
|
.doWrite(exports);
|
}
|
|
public PageResponse<LiveQuizItemVO> pageQuizRecords(Long courseId, Long sessionId, int page, int pageSize, String keyword, Integer isCorrect) {
|
requireSession(courseId, sessionId);
|
|
IPage<LiveQuizRow> p = liveSessionQuizRecordMapper.selectQuizPage(new Page<LiveQuizRow>(page, pageSize),
|
sessionId, keyword, isCorrect);
|
|
List<LiveQuizItemVO> list = new ArrayList<LiveQuizItemVO>();
|
for (LiveQuizRow r : p.getRecords()) {
|
LiveQuizItemVO vo = new LiveQuizItemVO();
|
vo.setId(r.getId());
|
vo.setUser(new UserVO(r.getUserId(), r.getUserNickname(), PhoneMasker.mask(r.getUserPhone()), null));
|
vo.setQuestionSort(r.getQuestionSort());
|
vo.setStem(r.getStem());
|
vo.setChosenOption(r.getChosenOption());
|
vo.setCorrectOption(r.getCorrectOption());
|
vo.setIsCorrect(r.getIsCorrect());
|
vo.setPointsEarned(r.getPointsEarned());
|
vo.setAnsweredAt(r.getAnsweredAt());
|
list.add(vo);
|
}
|
|
return PageResponse.of(list, p.getTotal(), p.getCurrent(), p.getSize());
|
}
|
|
private void requireSession(Long courseId, Long sessionId) {
|
if (liveCourseMapper.selectById(courseId) == null) {
|
throw new IllegalArgumentException("课程不存在");
|
}
|
LiveSession s = liveSessionMapper.selectById(sessionId);
|
if (s == null) {
|
throw new IllegalArgumentException("场次不存在");
|
}
|
if (!courseId.equals(s.getLiveCourseId())) {
|
throw new IllegalArgumentException("场次不属于该课程");
|
}
|
}
|
|
private List<LiveReserveItemVO> toReserveItems(List<LiveReserveRow> rows) {
|
List<LiveReserveItemVO> list = new ArrayList<LiveReserveItemVO>();
|
for (LiveReserveRow row : rows) {
|
LiveReserveItemVO vo = new LiveReserveItemVO();
|
vo.setId(row.getId());
|
vo.setCourseId(row.getCourseId());
|
vo.setSessionId(row.getSessionId());
|
vo.setUser(new UserVO(row.getUserId(), row.getUserNickname(), PhoneMasker.mask(row.getUserPhone()), row.getUserAvatar()));
|
vo.setCourseTitle(row.getCourseTitle());
|
vo.setCategoryName(row.getCategoryName());
|
vo.setStartTime(row.getStartTime());
|
vo.setLiveStatus(row.getLiveStatus());
|
vo.setReserveTime(row.getReserveTime());
|
vo.setIsCancel(row.getIsCancel());
|
vo.setHasWatched(row.getHasWatched());
|
list.add(vo);
|
}
|
return list;
|
}
|
|
private List<LiveWatchItemVO> toWatchItems(List<LiveWatchRow> rows) {
|
List<LiveWatchItemVO> list = new ArrayList<LiveWatchItemVO>();
|
for (LiveWatchRow row : rows) {
|
LiveWatchItemVO vo = new LiveWatchItemVO();
|
vo.setId(row.getId());
|
vo.setCourseId(row.getCourseId());
|
vo.setSessionId(row.getSessionId());
|
vo.setUser(new UserVO(row.getUserId(), row.getUserNickname(), PhoneMasker.mask(row.getUserPhone()), row.getUserAvatar()));
|
vo.setClinicName(row.getClinicName());
|
vo.setClinicArea(row.getClinicArea());
|
vo.setCourseTitle(row.getCourseTitle());
|
vo.setCategoryName(row.getCategoryName());
|
vo.setStartTime(row.getStartTime());
|
vo.setHasReserve(row.getHasReserve());
|
vo.setWatchStart(row.getWatchStart());
|
vo.setWatchEnd(row.getWatchEnd());
|
vo.setDurationSeconds(row.getDurationSeconds());
|
vo.setIsCompleted(row.getIsCompleted());
|
vo.setIsEffective(row.getIsEffective());
|
list.add(vo);
|
}
|
return list;
|
}
|
|
private LiveReserveSummaryVO buildReserveSummary(Long courseId,
|
Long sessionId,
|
String phone,
|
String courseName,
|
Integer liveStatus,
|
Integer hasWatched,
|
LocalDateTime reserveFrom,
|
LocalDateTime reserveTo) {
|
LiveReserveSummaryRow row = liveReserveMapper.selectGlobalReserveSummary(
|
courseId,
|
sessionId,
|
trimToNull(phone),
|
trimToNull(courseName),
|
liveStatus,
|
hasWatched,
|
reserveFrom,
|
reserveTo
|
);
|
LiveReserveSummaryVO vo = new LiveReserveSummaryVO();
|
long reserveTotal = row == null || row.getReserveTotal() == null ? 0L : row.getReserveTotal();
|
long watchedTotal = row == null || row.getWatchedTotal() == null ? 0L : row.getWatchedTotal();
|
vo.setReserveTotal(reserveTotal);
|
vo.setWatchedTotal(watchedTotal);
|
vo.setReserveConversionRate(percent(watchedTotal, reserveTotal));
|
return vo;
|
}
|
|
private LiveWatchSummaryVO buildWatchSummary(Long courseId,
|
Long sessionId,
|
String regionCode,
|
String clinicName,
|
String phone,
|
String courseName,
|
Integer hasReserve,
|
Integer isCompleted,
|
Integer isEffective,
|
LocalDateTime watchFrom,
|
LocalDateTime watchTo) {
|
LiveWatchSummaryRow row = liveWatchRecordMapper.selectGlobalWatchSummary(
|
courseId,
|
sessionId,
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(phone),
|
trimToNull(courseName),
|
hasReserve,
|
isCompleted,
|
isEffective,
|
watchFrom,
|
watchTo
|
);
|
LiveWatchSummaryVO vo = new LiveWatchSummaryVO();
|
long watchUserTotal = row == null || row.getWatchUserTotal() == null ? 0L : row.getWatchUserTotal();
|
long completedUserTotal = row == null || row.getCompletedUserTotal() == null ? 0L : row.getCompletedUserTotal();
|
long effectiveUserTotal = row == null || row.getEffectiveUserTotal() == null ? 0L : row.getEffectiveUserTotal();
|
vo.setWatchUserTotal(watchUserTotal);
|
vo.setCompletedUserTotal(completedUserTotal);
|
vo.setEffectiveUserTotal(effectiveUserTotal);
|
vo.setCompletionRate(percent(completedUserTotal, watchUserTotal));
|
vo.setEffectiveWatchRate(percent(effectiveUserTotal, watchUserTotal));
|
return vo;
|
}
|
|
private BigDecimal percent(long numerator, long denominator) {
|
if (denominator <= 0) {
|
return BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP);
|
}
|
return BigDecimal.valueOf(numerator)
|
.multiply(BigDecimal.valueOf(100))
|
.divide(BigDecimal.valueOf(denominator), 2, RoundingMode.HALF_UP);
|
}
|
|
private String trimToNull(String value) {
|
if (value == null) {
|
return null;
|
}
|
String trimmed = value.trim();
|
return trimmed.isEmpty() ? null : trimmed;
|
}
|
|
private String defaultText(String value) {
|
return value == null || value.trim().isEmpty() ? "-" : value;
|
}
|
|
private String boolText(Integer value) {
|
return value != null && value == 1 ? "是" : "否";
|
}
|
|
private String liveStatusText(Integer value) {
|
if (value == null) {
|
return "-";
|
}
|
if (value == 1) {
|
return "直播中";
|
}
|
if (value == 2) {
|
return "已结束";
|
}
|
return "未开始";
|
}
|
|
private String formatMinute(LocalDateTime value) {
|
if (value == null) {
|
return "-";
|
}
|
String text = DateTimes.format(value);
|
return text == null || text.length() < 16 ? defaultText(text) : text.substring(0, 16);
|
}
|
}
|
