基于Java语言的sa-club上岸俱乐部设计源码

package com.xiaoshouwaliang.practice.server.service.Impl; import com.alibaba.fastjson.JSON; import com.alibaba.nacos.common.utils.CollectionUtils; import com.xiaoshouwaliang.practice.api.enums.*; import com.xiaoshouwaliang.practice.api.req.*; import com.xiaoshouwaliang.practice.api.vo.*; import com.xiaoshouwaliang.practice.server.dao.*; import com.xiaoshouwaliang.practice.server.entity.dto.*; import com.xiaoshouwaliang.practice.server.entity.po.*; import com.xiaoshouwaliang.practice.server.rpc.UserRpc; import com.xiaoshouwaliang.practice.server.service.PracticeDetailService; import com.xiaoshouwaliang.practice.server.utils.DateUtils; import com.xiaoshouwaliang.practice.server.utils.LoginUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; @Service @Slf4j public class PracticeDetailServiceImpl implements PracticeDetailService { @Resource private PracticeDetailDao practiceDetailDao; @Resource private PracticeSetDao practiceSetDao; @Resource private PracticeSetDetailDao practiceSetDetailDao; @Resource private PracticeDao practiceDao; @Resource private SubjectDao subjectDao; @Resource private SubjectRadioDao subjectRadioDao; @Resource private SubjectMultipleDao subjectMultipleDao; @Resource private SubjectJudgeDao subjectJudgeDao; @Resource private SubjectMappingDao subjectMappingDao; @Resource private SubjectLabelDao subjectLabelDao; @Resource private UserRpc userRpc; @Override @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED) public Boolean submit(SubmitPracticeDetailReq req) { PracticePO practicePO = new PracticePO(); Long practiceId = req.getPracticeId(); Long setId = req.getSetId(); practicePO.setSetId(setId); String timeUse = req.getTimeUse(); String hour = timeUse.substring(0, 2); String minute = timeUse.substring(2, 4); String second = timeUse.substring(4, 6); practicePO.setTimeUse(hour + ":" + minute + ":" + second); practicePO.setSubmitTime(DateUtils.parseStrToDate(req.getSubmitTime())); practicePO.setCompleteStatus(CompleteStatusEnum.COMPLETE.getCode()); practicePO.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); practicePO.setCreatedBy(LoginUtil.getLoginId()); practicePO.setCreatedTime(new Date()); //计算正确率 Integer correctCount = practiceDetailDao.selectCorrectCount(practiceId); List<PracticeSetDetailPO> practiceSetDetailPOS = practiceSetDetailDao.selectBySetId(setId); Integer totalCount = practiceSetDetailPOS.size(); BigDecimal correctRate = new BigDecimal(correctCount).divide(new BigDecimal(totalCount), 4, BigDecimal.ROUND_HALF_UP) .multiply(new BigDecimal("100.00")); practicePO.setCorrectRate(correctRate); PracticePO po = practiceDao.selectById(practiceId); if (Objects.isNull(po)) { practiceDao.insert(practicePO); } else { practicePO.setId(practiceId); practiceDao.update(practicePO); } practiceSetDao.updateHeat(setId); //补充剩余题目的记录 List<PracticeDetailPO> practiceDetailPOList = practiceDetailDao.selectByPracticeId(practiceId); List<PracticeSetDetailPO> minusList = practiceSetDetailPOS.stream() .filter(item -> !practiceDetailPOList.stream() .map(e -> e.getSubjectId()) .collect(Collectors.toList()) .contains(item.getSubjectId())) .collect(Collectors.toList()); if (log.isInfoEnabled()) { log.info("题目差集{}", JSON.toJSONString(minusList)); } if (CollectionUtils.isNotEmpty(minusList)) { minusList.forEach(e -> { PracticeDetailPO practiceDetailPO = new PracticeDetailPO(); practiceDetailPO.setPracticeId(practiceId); practiceDetailPO.setSubjectType(e.getSubjectType()); practiceDetailPO.setSubjectId(e.getSubjectId()); practiceDetailPO.setAnswerStatus(0); practiceDetailPO.setAnswerContent(""); practiceDetailPO.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); practiceDetailPO.setCreatedTime(new Date()); practiceDetailPO.setCreatedBy(LoginUtil.getLoginId()); practiceDetailDao.insertSingle(practiceDetailPO); }); } return true; } @Override @Transactional(rollbackFor = Exception.class) public Boolean submitSubject(SubmitSubjectDetailReq req) { String timeUse = req.getTimeUse(); if (timeUse.equals("0")) { timeUse = "000000"; } String hour = timeUse.substring(0, 2); String minute = timeUse.substring(2, 4); String second = timeUse.substring(4, 6); PracticePO practicePO = new PracticePO(); practicePO.setId(req.getPracticeId()); practicePO.setTimeUse(hour + ":" + minute + ":" + second); practicePO.setSubmitTime(new Date()); practiceDao.update(practicePO); PracticeDetailPO practiceDetailPO = new PracticeDetailPO(); practiceDetailPO.setPracticeId(req.getPracticeId()); practiceDetailPO.setSubjectId(req.getSubjectId()); practiceDetailPO.setSubjectType(req.getSubjectType()); String answerContent = ""; //排序答案 if (CollectionUtils.isNotEmpty(req.getAnswerContents())) { List<Integer> answerContents = req.getAnswerContents(); Collections.sort(answerContents); answerContent = StringUtils.join(answerContents, ","); } practiceDetailPO.setAnswerContent(answerContent); SubjectDTO subjectDTO = new SubjectDTO(); subjectDTO.setSubjectId(req.getSubjectId()); subjectDTO.setSubjectType(req.getSubjectType()); //获取正确答案，并判断答案是否正确 SubjectDetailDTO subjectDetail = getSubjectDetail(subjectDTO); StringBuffer correctAnswer = new StringBuffer(); if (req.getSubjectType().equals(SubjectInfoTypeEnum.JUDGE.getCode())) { Integer isCorrect = subjectDetail.getIsCorrect(); correctAnswer.append(isCorrect); } else { subjectDetail.getOptionList().forEach(e -> { if (Objects.equals(e.getIsCorrect(), 1)) { correctAnswer.append(e.getOptionType()).append(","); } }); if (correctAnswer.length() > 0) { correctAnswer.deleteCharAt(correctAnswer.length() - 1); } } if (Objects.equals(correctAnswer.toString(), answerContent)) { practiceDetailPO.setAnswerStatus(1); } else { practiceDetailPO.setAnswerStatus(0); } practiceDetailPO.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); practiceDetailPO.setCreatedBy(LoginUtil.getLoginId()); practiceDetailPO.setCreatedTime(new Date()); PracticeDetailPO existDetail = practiceDetailDao.selectDetail(req.getPracticeId(), req.getSubjectId(), LoginUtil.getLoginId()); if (Objects.isNull(existDetail)) { practiceDetailDao.insertSingle(practiceDetailPO); } else { practiceDetailPO.setId(existDetail.getId()); practiceDetailDao.update(practiceDetailPO); } return true; } public SubjectDetailDTO getSubjectDetail(SubjectDTO dto) { SubjectDetailD