| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional |
| | | public CommonResult saveAnnualMaintenanceService(AnnualMaintenanceService annualMaintenanceService) { |
| | | List<AnnualMaintenanceServiceContent> annualMaintenanceServiceContentList = annualMaintenanceService.getAnnualMaintenanceServiceContentList(); |
| | | List<AnnualMaintenanceServiceUser> annualMaintenanceServiceUserList = annualMaintenanceService.getAnnualMaintenanceServiceUserList(); |
| | |
| | | List<AnnualMaintenanceServiceUser> addUser = annualMaintenanceServiceUserList.stream() |
| | | .filter(user -> null == user.getId()) |
| | | .collect(Collectors.toList()); |
| | | addUser.forEach(user -> { |
| | | user.setCreateBy(SecurityUtils.getUsername()); |
| | | user.setCreateTime(LocalDateTime.now()); |
| | | user.setAnnualMaintenanceServiceId(serviceId); |
| | | }); |
| | | int i = annualMaintenanceServiceUserMapper.batchInsert(addUser); |
| | | if (i <= 0) { |
| | | throw new RuntimeException("保存失败"); |
| | | if (ObjectUtil.isNotEmpty(addUser)){ |
| | | addUser.forEach(user -> { |
| | | user.setCreateBy(SecurityUtils.getUsername()); |
| | | user.setCreateTime(LocalDateTime.now()); |
| | | user.setAnnualMaintenanceServiceId(serviceId); |
| | | }); |
| | | int i = annualMaintenanceServiceUserMapper.batchInsert(addUser); |
| | | if (i <= 0) { |
| | | throw new RuntimeException("保存失败"); |
| | | } |
| | | } |
| | | |
| | | |
| | | List<AnnualMaintenanceServiceUser> updateUser = annualMaintenanceServiceUserList.stream() |
| | | .filter(user -> null != user.getId()) |
| | | .collect(Collectors.toList()); |
| | | updateUser.forEach(user -> { |
| | | user.setUpdateBy(SecurityUtils.getUsername()); |
| | | user.setUpdateTime(LocalDateTime.now()); |
| | | }); |
| | | int update = annualMaintenanceServiceUserMapper.batchUpdate(updateUser); |
| | | if (update <= 0) { |
| | | throw new RuntimeException("保存失败"); |
| | | if (ObjectUtil.isNotEmpty(updateUser)){ |
| | | updateUser.forEach(user -> { |
| | | user.setUpdateBy(SecurityUtils.getUsername()); |
| | | user.setUpdateTime(LocalDateTime.now()); |
| | | }); |
| | | int update = annualMaintenanceServiceUserMapper.batchUpdate(updateUser); |
| | | if (update <= 0) { |
| | | throw new RuntimeException("保存失败"); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | private void checkUser(List<AnnualMaintenanceServiceUser> annualMaintenanceServiceUserList) { |
| | |
| | | if (ObjectUtil.isEmpty(filteredUsers3)) { |
| | | throw new RuntimeException("请填写二级保养操作人员"); |
| | | } |
| | | Set<Long> userIdSet3 = filteredUsers.stream() |
| | | Set<Long> userIdSet3 = filteredUsers3.stream() |
| | | .map(AnnualMaintenanceServiceUser::getUserId) |
| | | .collect(Collectors.toSet()); |
| | | if (userIdSet3.size() != filteredUsers3.size()) { |
| | |
| | | if (ObjectUtil.isEmpty(filteredUsers4)) { |
| | | throw new RuntimeException("请填写二级保养检查人员"); |
| | | } |
| | | Set<Long> userIdSet4 = filteredUsers2.stream() |
| | | Set<Long> userIdSet4 = filteredUsers4.stream() |
| | | .map(AnnualMaintenanceServiceUser::getUserId) |
| | | .collect(Collectors.toSet()); |
| | | if (userIdSet4.size() != filteredUsers4.size()) { |