diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectRelatedPersonnelController.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectRelatedPersonnelController.java index 01ba398e6..0aea7c9e9 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectRelatedPersonnelController.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectRelatedPersonnelController.java @@ -7,6 +7,7 @@ import com.jero.common.system.base.controller.JeroController; import com.jero.modules.project.entity.ProjectRelatedPersonnel; import com.jero.modules.project.service.IProjectRelatedPersonnelService; import com.jero.modules.project.util.ExcelLangUtils; +import com.jero.modules.system.entity.SysUser; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; @@ -197,4 +198,17 @@ public class ProjectRelatedPersonnelController extends JeroController objectMap = this.projectRelatedPersonnelService.queryPersonByProjectId(projectId, dutyTerritory); return Result.OK(objectMap); } + + /** + * 通过projectId查询认证工程师 + * + * @return + */ + @AutoLog(value = "项目库-相关人员维护表-根据projectId查询认证工程师") + @ApiOperation(value="项目库-相关人员维护表-根据projectId查询认证工程师", notes="项目库-相关人员维护表-根据projectId查询认证工程师") + @GetMapping(value = "/queryCertificationEngineer") + public Result queryCertificationEngineer(@RequestParam(name="projectId",required=true) String projectId){ + List certificationEngineerList = projectRelatedPersonnelService.queryCertificationEngineer(projectId); + return Result.OK(certificationEngineerList); + } } diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/IProjectRelatedPersonnelService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/IProjectRelatedPersonnelService.java index 3cb185df3..f4cccaab2 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/IProjectRelatedPersonnelService.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/IProjectRelatedPersonnelService.java @@ -3,6 +3,7 @@ package com.jero.modules.project.service; import com.baomidou.mybatisplus.extension.service.IService; import com.jero.common.api.vo.Result; import com.jero.modules.project.entity.ProjectRelatedPersonnel; +import com.jero.modules.system.entity.SysUser; import org.springframework.web.servlet.ModelAndView; import javax.servlet.http.HttpServletRequest; @@ -85,4 +86,5 @@ public interface IProjectRelatedPersonnelService extends IService queryCertificationEngineer(String projectId); } diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/impl/ProjectRelatedPersonnelServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/impl/ProjectRelatedPersonnelServiceImpl.java index 065e57268..81d4990ce 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/impl/ProjectRelatedPersonnelServiceImpl.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/impl/ProjectRelatedPersonnelServiceImpl.java @@ -759,4 +759,29 @@ public class ProjectRelatedPersonnelServiceImpl extends ServiceImpl queryCertificationEngineer(String projectId) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + List list = list(queryWrapper.eq("project_id",projectId)); + + List certificationEngineerList = list.stream().map(e -> e.getCertificationEngineer()).collect(Collectors.toList()); + + StringBuilder userIdBuilder=new StringBuilder(); + List certificationEngineerUsers = new ArrayList<>(); + if(CollectionUtils.isNotEmpty(certificationEngineerList)){ + for(String certificationEngineerId :certificationEngineerList){ + if(StringUtils.isNotBlank(certificationEngineerId)) { + userIdBuilder.append(certificationEngineerId).append(","); + } + } + String userId = userIdBuilder.substring(0, userIdBuilder.toString().length() - 1); + List userIdList = Arrays.asList(userId.split(",")); + userIdList.stream().distinct().collect(Collectors.toList()); + QueryWrapper userqueryWrapper = new QueryWrapper<>(); + userqueryWrapper.in("id ", userIdList); + certificationEngineerUsers = sysUserMapper.selectList(userqueryWrapper); + } + return certificationEngineerUsers; + } }