From 0a48616045ddce1562584543a0e89e5144051fde Mon Sep 17 00:00:00 2001 From: Codex Assistant <codex@example.com> Date: 星期日, 05 十月 2025 14:52:44 +0800 Subject: [PATCH] 报名审核 --- backend/src/main/java/com/rongyichuang/judge/service/JudgeService.java | 116 ++++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 104 insertions(+), 12 deletions(-) diff --git a/backend/src/main/java/com/rongyichuang/judge/service/JudgeService.java b/backend/src/main/java/com/rongyichuang/judge/service/JudgeService.java index f078372..c4d82ec 100644 --- a/backend/src/main/java/com/rongyichuang/judge/service/JudgeService.java +++ b/backend/src/main/java/com/rongyichuang/judge/service/JudgeService.java @@ -2,6 +2,7 @@ import com.rongyichuang.judge.dto.request.JudgeInput; import com.rongyichuang.judge.dto.response.JudgeResponse; +import com.rongyichuang.judge.dto.response.JudgeStatsResponse; import com.rongyichuang.judge.entity.Judge; import com.rongyichuang.tag.entity.Tag; import com.rongyichuang.judge.repository.JudgeRepository; @@ -12,13 +13,15 @@ import com.rongyichuang.common.service.MediaService; import com.rongyichuang.common.exception.BusinessException; import com.rongyichuang.common.enums.MediaTargetType; +import com.rongyichuang.common.util.UserContextUtil; import com.rongyichuang.tag.repository.TagRepository; import com.rongyichuang.user.service.UserService; import com.rongyichuang.user.entity.User; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.data.domain.Sort; -import org.springframework.data.domain.Sort; +import org.springframework.jdbc.core.JdbcTemplate; +import java.util.Optional; import org.springframework.beans.factory.annotation.Value; import org.springframework.util.StringUtils; import org.slf4j.Logger; @@ -39,18 +42,23 @@ private final MediaRepository mediaRepository; private final MediaService mediaService; private final UserService userService; + private final JdbcTemplate jdbcTemplate; + private final UserContextUtil userContextUtil; - @Value("${app.media-url:${app.media.url:}}") + @Value("${app.media-url}") private String mediaBaseUrl; public JudgeService(JudgeRepository judgeRepository, TagRepository tagRepository, MediaRepository mediaRepository, MediaService mediaService, - UserService userService) { + UserService userService, JdbcTemplate jdbcTemplate, + UserContextUtil userContextUtil) { this.judgeRepository = judgeRepository; this.tagRepository = tagRepository; this.mediaRepository = mediaRepository; this.mediaService = mediaService; this.userService = userService; + this.jdbcTemplate = jdbcTemplate; + this.userContextUtil = userContextUtil; } public List<JudgeResponse> findAll() { @@ -69,6 +77,71 @@ return judgeRepository.findById(id) .map(this::convertToResponse) .orElse(null); + } + + /** + * 鏍规嵁鐢ㄦ埛ID鑾峰彇璇勫淇℃伅 + */ + public Judge findByUserId(Long userId) { + Optional<Judge> judge = judgeRepository.findByUserId(userId); + return judge.orElse(null); + } + + /** + * 鑾峰彇褰撳墠璇勫鐨勭粺璁℃暟鎹� + */ + public JudgeStatsResponse getJudgeStats() { + log.info("鑾峰彇璇勫缁熻鏁版嵁"); + + Long currentJudgeId = userContextUtil.getCurrentJudgeId(); + if (currentJudgeId == null) { + throw new RuntimeException("褰撳墠鐢ㄦ埛涓嶆槸璇勫锛屾棤娉曟煡璇㈣瘎瀹$粺璁�"); + } + + // 鏌ヨ鎴戞湭璇勫鐨勬暟閲� + String unReviewedSql = "SELECT COUNT(*) FROM t_activity_player ap " + + "WHERE EXISTS (" + + " SELECT 1 FROM t_activity_judge aj " + + " WHERE ap.activity_id = aj.activity_id " + + " AND ap.stage_id = aj.stage_id " + + " AND aj.judge_id = ? " + + ") " + + "AND NOT EXISTS (" + + " SELECT 1 FROM t_activity_player_rating apr " + + " WHERE ap.id = apr.activity_player_id " + + " AND apr.judge_id = ? " + + " AND apr.state = 1 " + + ") " + + "AND ap.state = 1"; + Integer unReviewedCount = jdbcTemplate.queryForObject(unReviewedSql, Integer.class, currentJudgeId, currentJudgeId); + + // 鏌ヨ鎴戝凡璇勫鐨勬暟閲� + String reviewedSql = "SELECT COUNT(*) FROM t_activity_player ap " + + "WHERE EXISTS (" + + " SELECT 1 FROM t_activity_judge aj " + + " WHERE ap.activity_id = aj.activity_id " + + " AND ap.stage_id = aj.stage_id " + + " AND aj.judge_id = ? " + + ") " + + "AND EXISTS (" + + " SELECT 1 FROM t_activity_player_rating apr " + + " WHERE ap.id = apr.activity_player_id " + + " AND apr.judge_id = ? " + + " AND apr.state = 1 " + + ") " + + "AND ap.state = 1"; + Integer reviewedCount = jdbcTemplate.queryForObject(reviewedSql, Integer.class, currentJudgeId, currentJudgeId); + + // 璁$畻鎬绘暟 + Integer totalCount = (unReviewedCount != null ? unReviewedCount : 0) + (reviewedCount != null ? reviewedCount : 0); + + log.info("璇勫缁熻鏁版嵁 - 寰呰瘎瀹�: {}, 宸茶瘎瀹�: {}, 鎬绘暟: {}", unReviewedCount, reviewedCount, totalCount); + + return new JudgeStatsResponse( + unReviewedCount != null ? unReviewedCount : 0, + reviewedCount != null ? reviewedCount : 0, + totalCount + ); } @Transactional @@ -201,15 +274,31 @@ * 淇濆瓨濯掍綋淇℃伅 */ public MediaResponse saveMediaInfo(MediaInput input) { - Media media = mediaService.saveMedia( - input.getName(), - input.getPath(), - input.getFileSize(), - input.getFileExt(), - input.getMediaType(), - input.getTargetType(), - input.getTargetId() - ); + Media media; + + // 濡傛灉鏈夌缉鐣ュ浘璺緞锛屼娇鐢ㄦ敮鎸佺缉鐣ュ浘鐨勬柟娉� + if (input.getThumbPath() != null && !input.getThumbPath().trim().isEmpty()) { + media = mediaService.saveMedia( + input.getName(), + input.getPath(), + input.getFileSize(), + input.getFileExt(), + input.getMediaType(), + input.getTargetType(), + input.getTargetId(), + input.getThumbPath() + ); + } else { + media = mediaService.saveMedia( + input.getName(), + input.getPath(), + input.getFileSize(), + input.getFileExt(), + input.getMediaType(), + input.getTargetType(), + input.getTargetId() + ); + } MediaResponse response = new MediaResponse(); response.setId(media.getId()); @@ -220,6 +309,9 @@ response.setMediaType(media.getMediaType()); response.setTargetType(media.getTargetType()); response.setTargetId(media.getTargetId()); + response.setThumbPath(media.getThumbPath()); + response.setDuration(media.getDuration()); + response.setDescription(media.getDescription()); return response; } -- Gitblit v1.8.0