From 3e456f3e812ead6a19e80cfbdbf86ae0263d50b9 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期五, 12 七月 2024 22:39:45 +0800
Subject: [PATCH] 完成7.4迭代内容，通过冒烟测试
---
finance-system/src/main/java/com/finance/system/service/impl/TbQuestionServiceImpl.java | 41 ++++++++++++++++++++++++++++++++++++++++-
1 files changed, 40 insertions(+), 1 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..a99170e 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,9 +1,12 @@
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.domain.TbQuestion;
@@ -11,9 +14,17 @@
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,19 +35,27 @@
* @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.setType(dto.getType());
tbQuestion.setQuarter(DateUtils.getNowQuarter());
this.save(tbQuestion);
+ asyncService.subtractScoreWithFixedRules(dto.getDeptAreaCode());
}
@Override
public void editQuestion(QuestionUpdDTO dto) {
TbQuestion tbQuestion = BeanUtils.copyBean(dto, TbQuestion.class);
+ tbQuestion.setType(dto.getType());
this.updateById(tbQuestion);
}
@@ -48,6 +67,26 @@
.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;
}
}
--
Gitblit v1.7.1