Merge remote-tracking branch 'origin/dev_1.1.0' into dev_1.1.0
# Conflicts: # pms-business/src/main/resources/mapper/business/examine/ExamineTaskMapper.xmldev_1.1.0
commit
fe71d980b8
|
@ -71,6 +71,7 @@ public class ExamineDetailController extends BaseController {
|
||||||
if (dto.getExamineId() == null) {
|
if (dto.getExamineId() == null) {
|
||||||
Assert.notNull(dto.getUserId(), "用户ID不能为空");
|
Assert.notNull(dto.getUserId(), "用户ID不能为空");
|
||||||
ExamineUser examineUser = examineUserService.queryByTaskIdAndUserId(dto.getExamineTaskId(), dto.getUserId());
|
ExamineUser examineUser = examineUserService.queryByTaskIdAndUserId(dto.getExamineTaskId(), dto.getUserId());
|
||||||
|
Assert.notNull(examineUser, "考核人员不存在");
|
||||||
dto.setExamineId(examineUser.getId());
|
dto.setExamineId(examineUser.getId());
|
||||||
}
|
}
|
||||||
Assert.notNull(dto.getExamineId(), "考核ID不能为空");
|
Assert.notNull(dto.getExamineId(), "考核ID不能为空");
|
||||||
|
|
|
@ -13,8 +13,9 @@ import tech.unissense.pms.business.examine.detail.mapper.ExamineDetailMapper;
|
||||||
import tech.unissense.pms.business.examine.detail.service.ExamineDetailService;
|
import tech.unissense.pms.business.examine.detail.service.ExamineDetailService;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import tech.unissense.pms.business.examine.detail.vo.ExamineConfigDetailVo;
|
import tech.unissense.pms.business.examine.detail.vo.ExamineConfigDetailVo;
|
||||||
|
import tech.unissense.pms.business.examine.task.domain.ExamineTask;
|
||||||
|
import tech.unissense.pms.business.examine.task.mapper.ExamineTaskMapper;
|
||||||
import tech.unissense.pms.business.examine.user.mapper.ExamineUserMapper;
|
import tech.unissense.pms.business.examine.user.mapper.ExamineUserMapper;
|
||||||
import tech.unissense.pms.business.examine.user.service.impl.ExamineUserServiceImpl;
|
|
||||||
import tech.unissense.pms.business.work.logger.service.IWorkLoggerService;
|
import tech.unissense.pms.business.work.logger.service.IWorkLoggerService;
|
||||||
import tech.unissense.pms.common.utils.bean.BeanUtils;
|
import tech.unissense.pms.common.utils.bean.BeanUtils;
|
||||||
import tech.unissense.pms.system.service.ISysDictDataService;
|
import tech.unissense.pms.system.service.ISysDictDataService;
|
||||||
|
@ -45,6 +46,8 @@ public class ExamineDetailServiceImpl implements ExamineDetailService {
|
||||||
private IWorkLoggerService workLoggerService;
|
private IWorkLoggerService workLoggerService;
|
||||||
@Autowired
|
@Autowired
|
||||||
private ISysDictDataService sysDictDataService;
|
private ISysDictDataService sysDictDataService;
|
||||||
|
@Autowired
|
||||||
|
private ExamineTaskMapper examineTaskMapper;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 通过ID查询单条数据
|
* 通过ID查询单条数据
|
||||||
|
@ -144,8 +147,9 @@ public class ExamineDetailServiceImpl implements ExamineDetailService {
|
||||||
examineConfigQueryDto.setReviewType(typeEnum.getType());
|
examineConfigQueryDto.setReviewType(typeEnum.getType());
|
||||||
}
|
}
|
||||||
List<ExamineConfig> configList = configMapper.list(examineConfigQueryDto);
|
List<ExamineConfig> configList = configMapper.list(examineConfigQueryDto);
|
||||||
|
ExamineTask examineTask = examineTaskMapper.queryById(taskId);
|
||||||
//系统核算单独处理
|
//系统核算单独处理
|
||||||
dealSystemBusinessAccount(examineList, configList);
|
dealSystemBusinessAccount(examineList, configList,examineTask);
|
||||||
Map<Integer, ExamineConfig> configMap = configList.stream().collect(Collectors.toMap(ExamineConfig::getId, Function.identity()));
|
Map<Integer, ExamineConfig> configMap = configList.stream().collect(Collectors.toMap(ExamineConfig::getId, Function.identity()));
|
||||||
Map<Integer, BigDecimal> scoreMap = new HashMap<>();
|
Map<Integer, BigDecimal> scoreMap = new HashMap<>();
|
||||||
for (ExamineDetail detail : examineList) {
|
for (ExamineDetail detail : examineList) {
|
||||||
|
@ -168,12 +172,12 @@ public class ExamineDetailServiceImpl implements ExamineDetailService {
|
||||||
return scoreMap;
|
return scoreMap;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void dealSystemBusinessAccount(List<ExamineDetail> examineList, List<ExamineConfig> configList) {
|
private void dealSystemBusinessAccount(List<ExamineDetail> examineList, List<ExamineConfig> configList, ExamineTask examineTask) {
|
||||||
Map<Integer, ExamineConfig> systemExamineConfigMap = configList.stream().filter(item ->
|
Map<Integer, ExamineConfig> systemExamineConfigMap = configList.stream().filter(item ->
|
||||||
ReviewTypeEnum.SYSTEM.getType().equals(item.getReviewType())).collect(Collectors.toMap(ExamineConfig::getId, Function.identity()));
|
ReviewTypeEnum.SYSTEM.getType().equals(item.getReviewType())).collect(Collectors.toMap(ExamineConfig::getId, Function.identity()));
|
||||||
//如有系统核算才处理
|
//如有系统核算才处理
|
||||||
if (CollUtil.isNotEmpty(systemExamineConfigMap)) {
|
if (CollUtil.isNotEmpty(systemExamineConfigMap)) {
|
||||||
String workDay = sysDictDataService.selectDictLabel("pms_work_day", "2024");
|
String workDay = sysDictDataService.selectDictLabel("pms_work_day", examineTask.getYear().toString());
|
||||||
workDay = StrUtil.isNotEmpty(workDay) ? workDay : "251";
|
workDay = StrUtil.isNotEmpty(workDay) ? workDay : "251";
|
||||||
BigDecimal configWorkDay = new BigDecimal(workDay);
|
BigDecimal configWorkDay = new BigDecimal(workDay);
|
||||||
List<ExamineDetail> collect = examineList.stream().filter(item -> systemExamineConfigMap.containsKey(item.getConfigId())).collect(Collectors.toList());
|
List<ExamineDetail> collect = examineList.stream().filter(item -> systemExamineConfigMap.containsKey(item.getConfigId())).collect(Collectors.toList());
|
||||||
|
|
|
@ -26,5 +26,7 @@ public interface ExamineTaskMapper {
|
||||||
void deleteTask(Integer id);
|
void deleteTask(Integer id);
|
||||||
|
|
||||||
List<ExamineTask> listTask(TaskQueryDto queryDto);
|
List<ExamineTask> listTask(TaskQueryDto queryDto);
|
||||||
|
|
||||||
|
ExamineTask queryById(Integer taskId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -39,8 +39,7 @@
|
||||||
</if>
|
</if>
|
||||||
</where>
|
</where>
|
||||||
</select>
|
</select>
|
||||||
|
<select id="listTask" resultMap="ExamineTaskMap">
|
||||||
<select id="listTask" resultType="ExamineTask">
|
|
||||||
select distinct t1.id,t1.task_name, t1.people_number, t1.people_number_detail, t1.task_status, t1.create_time, t1.end_time
|
select distinct t1.id,t1.task_name, t1.people_number, t1.people_number_detail, t1.task_status, t1.create_time, t1.end_time
|
||||||
from pms_examine_task t1
|
from pms_examine_task t1
|
||||||
left join pms_examine_user t2 on t1.id = t2.task_id
|
left join pms_examine_user t2 on t1.id = t2.task_id
|
||||||
|
@ -52,11 +51,18 @@
|
||||||
<if test="taskStatus != null">
|
<if test="taskStatus != null">
|
||||||
AND task_status = #{taskStatus}
|
AND task_status = #{taskStatus}
|
||||||
</if>
|
</if>
|
||||||
|
<if test="year != null">
|
||||||
|
AND year = #{year}
|
||||||
|
</if>
|
||||||
<!-- 数据范围过滤 -->
|
<!-- 数据范围过滤 -->
|
||||||
${params.dataScope}
|
${params.dataScope}
|
||||||
</where>
|
</where>
|
||||||
|
|
||||||
</select>
|
</select>
|
||||||
|
<select id="queryById" resultMap="ExamineTaskMap">
|
||||||
|
SELECT * FROM pms_examine_task
|
||||||
|
WHERE id = #{id}
|
||||||
|
</select>
|
||||||
|
|
||||||
<update id="updateTask">
|
<update id="updateTask">
|
||||||
UPDATE pms_examine_task
|
UPDATE pms_examine_task
|
||||||
|
|
Loading…
Reference in New Issue