From 18891c60ab1c06a4acc85d0ec54dee50d1b1a19f Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期一, 07 四月 2025 17:20:07 +0800 Subject: [PATCH] bug修改 --- finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java | 60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 57 insertions(+), 3 deletions(-) diff --git a/finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java b/finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java index 335f6db..fad5c66 100644 --- a/finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java +++ b/finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java @@ -1,19 +1,31 @@ package com.finance.system.service.impl; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.finance.common.basic.PageDTO; +import com.finance.common.core.domain.entity.SysUser; import com.finance.common.utils.BeanUtils; +import com.finance.common.utils.CollUtils; import com.finance.common.utils.DateUtils; import com.finance.common.utils.StringUtils; +import com.finance.system.constants.QuarterConstant; import com.finance.system.domain.TbQuestion; import com.finance.system.dto.QuestionDTO; import com.finance.system.dto.update.QuestionUpdDTO; import com.finance.system.mapper.TbQuestionMapper; import com.finance.system.query.QuestionQuery; +import com.finance.system.service.AsyncService; +import com.finance.system.service.ISysUserService; import com.finance.system.service.TbQuestionService; import com.finance.system.vo.QuestionVO; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.stream.Collectors; +import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; /** * <p> @@ -24,20 +36,31 @@ * @since 2024-03-13 */ @Service +@RequiredArgsConstructor public class TbQuestionServiceImpl extends ServiceImpl<TbQuestionMapper, TbQuestion> implements TbQuestionService { + private final ISysUserService sysUserService; + private final AsyncService asyncService; + @Override + @Transactional(rollbackFor = Exception.class) public void addQuestion(QuestionDTO dto) throws Exception { TbQuestion tbQuestion = BeanUtils.copyBean(dto, TbQuestion.class); - tbQuestion.setQuarter(DateUtils.getNowQuarter()); + tbQuestion.setType(dto.getType()); + String previousQuarter = DateUtils.getPreviousQuarter(); + previousQuarter = QuarterConstant.CURRENT_QUARTER; + tbQuestion.setQuarter(previousQuarter); this.save(tbQuestion); + asyncService.subtractScoreWithFixedRules(dto.getDeptAreaCode()); } @Override - public void editQuestion(QuestionUpdDTO dto) { + public void editQuestion(QuestionUpdDTO dto) throws Exception { TbQuestion tbQuestion = BeanUtils.copyBean(dto, TbQuestion.class); + tbQuestion.setType(dto.getType()); this.updateById(tbQuestion); + asyncService.subtractScoreWithFixedRules(dto.getDeptAreaCode()); } @Override @@ -48,6 +71,37 @@ .like(StringUtils.isNotBlank(dto.getTitle()), TbQuestion::getTitle, dto.getTitle()) .orderByDesc(TbQuestion::getCreateTime) .page(new Page<>(dto.getPageNum(), dto.getPageSize())); - return PageDTO.of(page, QuestionVO.class); + if (StringUtils.isEmpty(page.getRecords())) { + return PageDTO.empty(page.getTotal(), page.getPages()); + } + PageDTO<QuestionVO> questionVOPageDTO = PageDTO.of(page, QuestionVO.class); + Set<String> areaCodeSet = questionVOPageDTO.getList().stream() + .map(QuestionVO::getDeptAreaCode) + .collect(Collectors.toSet()); + if (CollUtils.isNotEmpty(areaCodeSet)) { + List<SysUser> sysUsers = sysUserService.list( + Wrappers.lambdaQuery(SysUser.class).in(SysUser::getAreaCode, areaCodeSet)); + Map<String, String> deptNameMap = sysUsers.stream() + .collect(Collectors.toMap(SysUser::getAreaCode, SysUser::getAreaName)); + if (CollUtils.isNotEmpty(deptNameMap)) { + for (QuestionVO questionVO : questionVOPageDTO.getList()) { + String deptName = deptNameMap.get(questionVO.getDeptAreaCode()); + questionVO.setDeptName(StringUtils.isNotBlank(deptName) ? deptName : ""); + } + } + } + + return questionVOPageDTO; + } + + @Override + public void delete(Long id) { + TbQuestion question = this.getById(id); + try { + asyncService.subtractScoreWithFixedRules(question.getDeptAreaCode()); + } catch (Exception e) { + throw new RuntimeException(e); + } + this.removeById(id); } } -- Gitblit v1.7.1