From 1a2e22a27627b40689257442cc5a46598c634f8e Mon Sep 17 00:00:00 2001 From: xuhy <3313886187@qq.com> Date: 星期五, 23 五月 2025 14:16:28 +0800 Subject: [PATCH] 测评接口完成,添加数据权限 --- ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTesterWorkEvaluateServiceImpl.java | 79 +++++++++++++++++++++++++++++++++++++-- 1 files changed, 74 insertions(+), 5 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTesterWorkEvaluateServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTesterWorkEvaluateServiceImpl.java index 8c39ec8..a1865e0 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTesterWorkEvaluateServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTesterWorkEvaluateServiceImpl.java @@ -1,19 +1,20 @@ package com.ruoyi.system.service.impl; -import java.time.LocalDateTime; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.documents4j.api.IFileConsumer; import com.ruoyi.common.basic.PageInfo; import com.ruoyi.common.core.domain.entity.SysUser; +import com.ruoyi.system.mapper.SysUserMapper; +import com.ruoyi.system.mapper.TExperimentDispatchParticipantsMapper; import com.ruoyi.system.mapper.TResultWorkEvaluateMapper; -import com.ruoyi.system.model.TProjectTeamStaff; +import com.ruoyi.system.model.TExperimentDispatchParticipants; import com.ruoyi.system.model.TResultWorkEvaluate; +import com.ruoyi.system.query.ResultEvaluateChemistTesterQuery; import com.ruoyi.system.query.TResultWorkEvaluateQuery; import com.ruoyi.system.service.TResultWorkEvaluateService; -import com.ruoyi.system.vo.TProjectTeamVO; +import com.ruoyi.system.vo.ResultEvaluateChemistTesterVO; import com.ruoyi.system.vo.TResultWorkEvaluateVO; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; @@ -30,6 +31,11 @@ */ @Service public class TTesterWorkEvaluateServiceImpl extends ServiceImpl<TResultWorkEvaluateMapper, TResultWorkEvaluate> implements TResultWorkEvaluateService { + + @Autowired + private SysUserMapper sysUserMapper; + @Autowired + private TExperimentDispatchParticipantsMapper experimentDispatchParticipantsMapper; @Override public PageInfo<TResultWorkEvaluateVO> pageList(TResultWorkEvaluateQuery query) { @@ -216,4 +222,67 @@ pageInfo.setRecords(list); return pageInfo; } + + @Override + public PageInfo<TResultWorkEvaluateVO> chemistEvaluateList(TResultWorkEvaluateQuery query) { + PageInfo<TResultWorkEvaluateVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize()); + List<TResultWorkEvaluateVO> list = this.baseMapper.chemistEvaluateList(query,pageInfo); + pageInfo.setRecords(list); + return pageInfo; + } + @Override + public PageInfo<TResultWorkEvaluateVO> testerEvaluateList(TResultWorkEvaluateQuery query) { + PageInfo<TResultWorkEvaluateVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize()); + List<TResultWorkEvaluateVO> list = this.baseMapper.testerEvaluateList(query,pageInfo); + pageInfo.setRecords(list); + return pageInfo; + } + + @Override + public PageInfo<ResultEvaluateChemistTesterVO> getEvaluateChemistPageList(ResultEvaluateChemistTesterQuery query) { + PageInfo<ResultEvaluateChemistTesterVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize()); + List<ResultEvaluateChemistTesterVO> list = this.baseMapper.getEvaluateChemistPageList(query,pageInfo); + if(!CollectionUtils.isEmpty(list)){ + // 查询工艺工程师的名称 + List<String> dispatchIds = list.stream().map(ResultEvaluateChemistTesterVO::getDispatchId).collect(Collectors.toList()); + List<TExperimentDispatchParticipants> experimentDispatchParticipants = experimentDispatchParticipantsMapper.selectList(new LambdaQueryWrapper<TExperimentDispatchParticipants>() + .in(TExperimentDispatchParticipants::getDispatchId, dispatchIds) + .eq(TExperimentDispatchParticipants::getRoleType, 3)); + List<Long> userIds = experimentDispatchParticipants.stream().map(TExperimentDispatchParticipants::getUserId).collect(Collectors.toList()); + if(!CollectionUtils.isEmpty(userIds)){ + List<SysUser> sysUsers = sysUserMapper.selectUserByIds(userIds); + for (ResultEvaluateChemistTesterVO resultEvaluateChemistTesterVO : list) { + sysUsers.stream().filter(sysUser -> sysUser.getUserId().equals(resultEvaluateChemistTesterVO.getParticipantsId())).findFirst().ifPresent(sysUser -> { + resultEvaluateChemistTesterVO.setProcessEngineerName(sysUser.getNickName()); + }); + } + } + } + pageInfo.setRecords(list); + return pageInfo; + } + + @Override + public PageInfo<ResultEvaluateChemistTesterVO> getEvaluateTesterPageList(ResultEvaluateChemistTesterQuery query) { + PageInfo<ResultEvaluateChemistTesterVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize()); + List<ResultEvaluateChemistTesterVO> list = this.baseMapper.getEvaluateTesterPageList(query,pageInfo); + if(!CollectionUtils.isEmpty(list)){ + // 查询工艺工程师的名称 + List<String> dispatchIds = list.stream().map(ResultEvaluateChemistTesterVO::getDispatchId).collect(Collectors.toList()); + List<TExperimentDispatchParticipants> experimentDispatchParticipants = experimentDispatchParticipantsMapper.selectList(new LambdaQueryWrapper<TExperimentDispatchParticipants>() + .in(TExperimentDispatchParticipants::getDispatchId, dispatchIds) + .eq(TExperimentDispatchParticipants::getRoleType, 3)); + List<Long> userIds = experimentDispatchParticipants.stream().map(TExperimentDispatchParticipants::getUserId).collect(Collectors.toList()); + if(!CollectionUtils.isEmpty(userIds)){ + List<SysUser> sysUsers = sysUserMapper.selectUserByIds(userIds); + for (ResultEvaluateChemistTesterVO resultEvaluateChemistTesterVO : list) { + sysUsers.stream().filter(sysUser -> sysUser.getUserId().equals(resultEvaluateChemistTesterVO.getParticipantsId())).findFirst().ifPresent(sysUser -> { + resultEvaluateChemistTesterVO.setProcessEngineerName(sysUser.getNickName()); + }); + } + } + } + pageInfo.setRecords(list); + return pageInfo; + } } -- Gitblit v1.7.1