| | |
| | | // 获取当前用户 |
| | | Long userId = tokenService.getLoginUser().getUserId(); |
| | | Integer roleType = tokenService.getLoginUser().getUser().getRoleType(); |
| | | query.setRoleType(roleType); |
| | | if (roleType != 1){ |
| | | query.setUserId(userId); |
| | | if(roleType ==2){ |
| | |
| | | experimentDispatchTask.setDispatchId(dto.getId()); |
| | | }); |
| | | experimentDispatchTaskService.saveBatch(experimentDispatchTasks); |
| | | // MESSAGE 添加消息 |
| | | if(!dto.getStatus().equals(-1)){ |
| | | experimentDispatchParticipants.stream().filter(e->e.getRoleType().equals(4)).forEach(teamStaff -> { |
| | | noticeService.saveNotice(teamStaff.getUserId(), "您有【1】条【实验调度】等待确认", tokenService.getLoginUser().getUser().getNickName(),11); |
| | | }); |
| | | experimentDispatchParticipants.stream().filter(e->e.getRoleType().equals(5)).forEach(teamStaff -> { |
| | | noticeService.saveNotice(teamStaff.getUserId(), "您有【1】条【实验调度】等待确认", tokenService.getLoginUser().getUser().getNickName(),14); |
| | | }); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |