Subversion Repositories SmartDukaan

    @Override

    public void activeSchemeByIds(List<Scheme> schemes) throws ProfitMandiBusinessException {

        if (schemes.size() > 0) {

            for (Scheme scheme : schemes) {

                if (scheme.getActiveTimestamp() != null || scheme.getExpireTimestamp() != null) {

                    continue;

                }

                scheme.setActiveTimestamp(LocalDateTime.now());

            }

            this.sendCombinedSchemesNotification(schemes);

        }

    }

    private void sendCombinedSchemesNotification(List<Scheme> schemes) throws ProfitMandiBusinessException {

        if (schemes == null || schemes.isEmpty()) return;

        SendNotificationModel sendNotificationModel = new SendNotificationModel();

        StringBuilder messageBuilder = new StringBuilder();

        StringBuilder titleBuilder = new StringBuilder();

        Set<Integer> allCatalogIds = new HashSet<>();

        for (Scheme scheme : schemes) {

            if (!ACTIVATION_SCHEME_TYPES.contains(scheme.getType())) {

                continue;

            }

            String schemeTypeLabel = "Activation scheme";

            if (scheme.getType().equals(SchemeType.SPECIAL_SUPPORT)) {

                schemeTypeLabel = "Special Support";

            }

            List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(Collections.singleton(scheme.getId()));

            Set<Integer> catalogIds = schemeItems.stream().map(SchemeItem::getCatalogId).collect(Collectors.toSet());

            allCatalogIds.addAll(catalogIds);

            List<String> itemBrand = itemRepository.selectAllByCatalogIds(catalogIds).stream()

                    .filter(Utils.distinctByKey(Item::getCatalogItemId))

                    .map(Item::getBrand)

                    .collect(Collectors.toList());

            List<String> itemDescriptions = itemRepository.selectAllByCatalogIds(catalogIds).stream()

                    .filter(Utils.distinctByKey(Item::getCatalogItemId))

                    .map(Item::getItemDescriptionNoColor)

                    .collect(Collectors.toList());

            // Title line

            titleBuilder.append(String.format("%s of Rs.%s for %s\n",

                    schemeTypeLabel,

                    FormattingUtils.formatDecimal(scheme.getAmount()),

                    itemBrand.get(0)));

            // Message details

            messageBuilder.append(String.format("On Selected Models: %s\n", String.join(", ", itemDescriptions)));

            messageBuilder.append(String.format("Duration from - %s to %s\n\n",

                FormattingUtils.formatDateMonth(scheme.getStartDateTime()),

                FormattingUtils.formatDateMonth(scheme.getEndDateTime())));

        }

        if (titleBuilder.length() == 0) return;

        sendNotificationModel.setCampaignName("activationscheme");

        sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

        sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));

        sendNotificationModel.setTitle(titleBuilder.toString().trim());

        sendNotificationModel.setMessage(messageBuilder.toString().trim());

        sendNotificationModel.setType("url");

        sendNotificationModel.setMessageType(MessageType.scheme);

        notificationService.sendNotificationToAll(sendNotificationModel);

    }