From 6ae35089a05b58dc31c243b9bb4f6a80b20c3a7b Mon Sep 17 00:00:00 2001 From: xuhy <3313886187@qq.com> Date: 星期五, 23 五月 2025 17:44:42 +0800 Subject: [PATCH] 修改接口 --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java | 89 +++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 87 insertions(+), 2 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java index 92d8b8e..fef862b 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java @@ -51,8 +51,9 @@ private final TExperimentDispatchService experimentDispatchService; private final TProjectProposalService projectProposalService; private final TExperimentDispatchGroupService experimentDispatchGroupService; + private final TProjectTeamStaffService projectTeamStaffService; @Autowired - public TExperimentSchemeController(TExperimentSchemeService experimentSchemeService, TokenService tokenService, ISysUserService sysUserService, SysUserMapper sysUserMapper, TExperimentSchemePersonService experimentSchemePersonService, TExperimentDispatchParticipantsService experimentDispatchParticipantsService, TExperimentDispatchService experimentDispatchService, TProjectProposalService projectProposalService, TExperimentDispatchGroupService experimentDispatchGroupService) { + public TExperimentSchemeController(TExperimentSchemeService experimentSchemeService, TokenService tokenService, ISysUserService sysUserService, SysUserMapper sysUserMapper, TExperimentSchemePersonService experimentSchemePersonService, TExperimentDispatchParticipantsService experimentDispatchParticipantsService, TExperimentDispatchService experimentDispatchService, TProjectProposalService projectProposalService, TExperimentDispatchGroupService experimentDispatchGroupService, TProjectTeamStaffService projectTeamStaffService) { this.experimentSchemeService = experimentSchemeService; this.tokenService = tokenService; this.sysUserService = sysUserService; @@ -62,6 +63,7 @@ this.experimentDispatchService = experimentDispatchService; this.projectProposalService = projectProposalService; this.experimentDispatchGroupService = experimentDispatchGroupService; + this.projectTeamStaffService = projectTeamStaffService; } /** @@ -72,7 +74,61 @@ @PostMapping(value = "/api/t-experiment-scheme/pageList") public R<PageInfo<TExperimentSchemeVO>> pageList(@RequestBody String param) { TExperimentSchemeQuery query = JSON.parseObject(param, TExperimentSchemeQuery.class); + // 获取当前用户 + Long userId = tokenService.getLoginUser().getUserId(); + Integer roleType = tokenService.getLoginUser().getUser().getRoleType(); + if (roleType != 1){ + query.setUserId(userId); + if(roleType ==2){ + // 查询项目组 + TProjectTeamStaff projectTeamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class) + .eq(TProjectTeamStaff::getUserId, userId)); + // 查询项目的工艺工程师id + TProjectTeamStaff teamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class) + .eq(TProjectTeamStaff::getTeamId, projectTeamStaff.getTeamId()) + .eq(TProjectTeamStaff::getRoleType, 3) + .last("LIMIT 1")); + // 查询实验参与人员 + List<TExperimentDispatchParticipants> experimentDispatchParticipants = experimentDispatchParticipantsService.list(Wrappers.lambdaQuery(TExperimentDispatchParticipants.class) + .eq(TExperimentDispatchParticipants::getUserId, teamStaff.getUserId())); + if(!CollectionUtils.isEmpty(experimentDispatchParticipants)){ + List<String> dispatchIds = experimentDispatchParticipants.stream().map(TExperimentDispatchParticipants::getDispatchId).distinct().collect(Collectors.toList()); + query.setDispatchIds(dispatchIds); + } + }else { + // 查询实验参与人员 + List<TExperimentDispatchParticipants> experimentDispatchParticipants = experimentDispatchParticipantsService.list(Wrappers.lambdaQuery(TExperimentDispatchParticipants.class) + .eq(TExperimentDispatchParticipants::getUserId, userId)); + if (!CollectionUtils.isEmpty(experimentDispatchParticipants)) { + List<String> dispatchIds = experimentDispatchParticipants.stream().map(TExperimentDispatchParticipants::getDispatchId).distinct().collect(Collectors.toList()); + query.setDispatchIds(dispatchIds); + } + } + } return R.ok(experimentSchemeService.pageList(query)); + } + /** + * 获取实验方案管理列表-中止审批列表 + */ + //@PreAuthorize("@ss.hasPermi('system:testMethodConfirmSheet:list')") + @ApiOperation(value = "获取实验方案分页列表-中止审批列表",response = TExperimentSchemeQuery.class) + @PostMapping(value = "/api/t-experiment-scheme/auditPageList") + public R<PageInfo<TExperimentSchemeVO>> auditPageList(@RequestBody String param) { + TExperimentSchemeQuery query = JSON.parseObject(param, TExperimentSchemeQuery.class); + // 获取当前用户 + Long userId = tokenService.getLoginUser().getUserId(); + Integer roleType = tokenService.getLoginUser().getUser().getRoleType(); + if (roleType != 1){ + query.setUserId(userId); + // 查询实验参与人员 + List<TExperimentDispatchParticipants> experimentDispatchParticipants = experimentDispatchParticipantsService.list(Wrappers.lambdaQuery(TExperimentDispatchParticipants.class) + .eq(TExperimentDispatchParticipants::getUserId, userId)); + if(!CollectionUtils.isEmpty(experimentDispatchParticipants)){ + List<String> dispatchIds = experimentDispatchParticipants.stream().map(TExperimentDispatchParticipants::getDispatchId).distinct().collect(Collectors.toList()); + query.setDispatchIds(dispatchIds); + } + } + return R.ok(experimentSchemeService.auditPageList(query)); } /** @@ -148,6 +204,20 @@ } /** + * 修改实验方案 + */ + //@PreAuthorize("@ss.hasPermi('system:testMethodConfirmSheet:edit')") + @Log(title = "实验方案信息-修改实验方案-实验员提交", businessType = BusinessType.UPDATE) + @ApiOperation(value = "修改实验方案-实验员提交") + @PostMapping(value = "/api/t-experiment-scheme/updateTester") + public R<Boolean> updateTester(@RequestBody String param) { + TExperimentSchemeDTO dto = JSON.parseObject(param,TExperimentSchemeDTO.class); + dto.setStatus(6); + experimentSchemeService.updateById(dto); + return R.ok(); + } + + /** * 查看实验方案详情 */ //@PreAuthorize("@ss.hasPermi('system:testMethodConfirmSheet:detail')") @@ -165,6 +235,7 @@ TProjectProposal projectProposal = projectProposalService.getById(experimentDispatch.getProposalId()); if(Objects.nonNull(projectProposal)){ experimentDispatch.setProjectName(projectProposal.getProjectName()); + experimentDispatch.setProjectCode(projectProposal.getProjectCode()); } } experimentSchemeVO.setExperimentDispatch(experimentDispatch); @@ -177,7 +248,21 @@ // 获取实验人员 List<TExperimentSchemePerson> experimentSchemePersons = experimentSchemePersonService.list(Wrappers.lambdaQuery(TExperimentSchemePerson.class) .eq(TExperimentSchemePerson::getSchemeId, id)); + List<Long> userIds = experimentSchemePersons.stream().map(TExperimentSchemePerson::getUserId).collect(Collectors.toList()); + List<SysUser> sysUsers = sysUserMapper.selectUserByIds(userIds); + sysUsers.forEach(sysUser -> { + experimentSchemePersons.stream().filter(experimentSchemePerson -> experimentSchemePerson.getUserId().equals(sysUser.getUserId())).forEach(experimentSchemePerson -> { + experimentSchemePerson.setNickName(sysUser.getNickName()); + experimentSchemePerson.setAvatar(sysUser.getAvatar()); + }); + }); experimentSchemeVO.setExperimentSchemePersons(experimentSchemePersons); + + // 查询审核人姓名 + SysUser sysUser = sysUserService.selectUserById(experimentScheme.getAuditPersonId()); + if(Objects.nonNull(sysUser)){ + experimentSchemeVO.setAuditPersonName(sysUser.getNickName()); + } return R.ok(experimentSchemeVO); } @@ -213,7 +298,7 @@ */ //@PreAuthorize("@ss.hasPermi('system:testMethodConfirmSheet:sign')") @Log(title = "实验方案信息-申请中止实验", businessType = BusinessType.UPDATE) - @ApiOperation(value = "申请中止实验") + @ApiOperation(value = "申请中止实验",response = ApplicationTerminationDTO.class) @PostMapping(value = "/api/t-experiment-scheme/applicationTermination") public R<Boolean> applicationTermination(@RequestBody String param) { ApplicationTerminationDTO applicationTerminationDTO = JSON.parseObject(param, ApplicationTerminationDTO.class); -- Gitblit v1.7.1