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/TSamplingRecordController.java | 62 ++++++++++++++++++++++--------- 1 files changed, 44 insertions(+), 18 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSamplingRecordController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSamplingRecordController.java index 75fdb63..5fb30dd 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSamplingRecordController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSamplingRecordController.java @@ -82,12 +82,30 @@ 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); + 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(samplingRecordService.pageList(query)); @@ -288,13 +306,17 @@ public R<Boolean> batchSendSamples(@RequestBody String param) { BatchSendSamplesDTO batchSendSamplesDTO = JSON.parseObject(param, BatchSendSamplesDTO.class); Long userId = tokenService.getLoginUser().getUserId(); + List<String> ids = batchSendSamplesDTO.getRecordOperationId(); // 批量送样 - samplingRecordOperationService.update(Wrappers.lambdaUpdate(TSamplingRecordOperation.class) - .eq(TSamplingRecordOperation::getId, batchSendSamplesDTO.getRecordOperationId()) - .set(TSamplingRecordOperation::getStatus, 2) - .set(TSamplingRecordOperation::getSendSign, batchSendSamplesDTO.getSendSign()) - .set(TSamplingRecordOperation::getSendTime, LocalDateTime.now()) - .set(TSamplingRecordOperation::getSendPersonId, userId)); + List<TSamplingRecordOperation> samplingRecordOperations = samplingRecordOperationService.list(Wrappers.lambdaQuery(TSamplingRecordOperation.class) + .in(TSamplingRecordOperation::getId, ids)); + for (TSamplingRecordOperation samplingRecordOperation : samplingRecordOperations) { + samplingRecordOperation.setStatus(2); + samplingRecordOperation.setSendPersonId(userId); + samplingRecordOperation.setSendSign(samplingRecordOperation.getSendSign()); + samplingRecordOperation.setSendTime(LocalDateTime.now()); + } + samplingRecordOperationService.updateBatchById(samplingRecordOperations); return R.ok(); } @@ -308,13 +330,17 @@ public R<Boolean> batchCollectSamples(@RequestBody String param) { BatchCollectSamplesDTO batchCollectSamplesDTO = JSON.parseObject(param, BatchCollectSamplesDTO.class); Long userId = tokenService.getLoginUser().getUserId(); + List<String> ids = batchCollectSamplesDTO.getRecordOperationId(); // 批量送样 - samplingRecordOperationService.update(Wrappers.lambdaUpdate(TSamplingRecordOperation.class) - .eq(TSamplingRecordOperation::getId, batchCollectSamplesDTO.getRecordOperationId()) - .set(TSamplingRecordOperation::getStatus, 3) - .set(TSamplingRecordOperation::getReceiptsSign, batchCollectSamplesDTO.getReceiptsSign()) - .set(TSamplingRecordOperation::getReceiptsTime, LocalDateTime.now()) - .set(TSamplingRecordOperation::getReceiptsPersonId, userId)); + List<TSamplingRecordOperation> samplingRecordOperations = samplingRecordOperationService.list(Wrappers.lambdaQuery(TSamplingRecordOperation.class) + .in(TSamplingRecordOperation::getId, ids)); + for (TSamplingRecordOperation samplingRecordOperation : samplingRecordOperations) { + samplingRecordOperation.setStatus(3); + samplingRecordOperation.setSendPersonId(userId); + samplingRecordOperation.setSendSign(samplingRecordOperation.getReceiptsSign()); + samplingRecordOperation.setSendTime(LocalDateTime.now()); + } + samplingRecordOperationService.updateBatchById(samplingRecordOperations); return R.ok(); } -- Gitblit v1.7.1