Method consumePart

api/src/main/java/com/grash/service/PartService.java:137–194

(Long id, double quantity, WorkOrder workOrder, Locale locale, boolean deleteConsumption)

    }

    @Transactional
    public void consumePart(Long id, double quantity, WorkOrder workOrder, Locale locale, boolean deleteConsumption) {
        Part part = findById(id).get();
        if (part.isNonStock()) return;
        double previousQuantity = part.getQuantity();
        part.setQuantity(part.getQuantity() - quantity);
        if (part.getQuantity() < 0)
            throw new CustomException("There is not enough of this part", HttpStatus.NOT_ACCEPTABLE);
        if (quantity <= 0) {
            PartConsumption partConsumption =
                    Collections.max(partConsumptionService.findByWorkOrderAndPart(workOrder.getId(), part.getId()),
                            new AuditComparator());
            if (deleteConsumption || quantity == 0d) {
                partConsumptionService.delete(partConsumption.getId());
            } else {
                partConsumption.setQuantity(partConsumption.getQuantity() + quantity);
                partRepository.save(part);
                partConsumptionService.save(partConsumption);
            }
        } else {
            String message = messageSource.getMessage("notification_part_low", new Object[]{part.getName()}, locale);
            if (part.getQuantity() < part.getMinQuantity() && licenseService.hasEntitlement(LicenseEntitlement.LOW_STOCK_ALERTS)) {
                Map<Long, User> uniqueUsersMap = new TreeMap<>();
                Stream.concat(
                        userService.findWorkersByCompany(part.getCompany().getId())
                                .stream()
                                .filter(user -> user.getRole().getViewPermissions().contains(PermissionEntity.SETTINGS)),
                        part.getAssignedTo().stream()
                ).forEach(user -> {
                    if (user.isEnabled()) uniqueUsersMap.put(user.getId(), user);
                });

                notificationService.createMultiple(uniqueUsersMap.values().stream().map(user ->
                        new Notification(message, user, NotificationType.PART, part.getId())
                ).collect(Collectors.toList()), true, message);

                Map<String, Object> mailVariables = new HashMap<String, Object>() {{
                    put("partName", part.getName());
                    put("partLink", frontendUrl + "/app/inventory/parts/" + part.getId());
                }};
                if (!uniqueUsersMap.isEmpty()) {
                    mailServiceFactory.getMailService().sendMessageUsingThymeleafTemplate(
                            uniqueUsersMap.values().stream().map(User::getEmail).toArray(String[]::new),
                            messageSource.getMessage("low_stock", null, locale),
                            mailVariables,
                            "low-stock.html",
                            locale,
                            null
                    );
                }
            }
            partConsumptionService.create(new PartConsumption(part, workOrder, quantity));
            partRepository.save(part);

        }
        dispatchPartQuantityChangeWebhook(part, previousQuantity, part.getQuantity(), workOrder,
                workOrder.getCompany());
    }