Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // sync card product status
- List<UserProduct> productToSync = subscriber.getProductList().stream()
- .filter(x -> (SvaStatus.ACTIVE.getValue().equals(x.getStatus())
- || SvaStatus.TO_BE_ACTIVATED.getValue().equals(x.getStatus())
- || SvaStatus.BLOCKED.getValue().equals(x.getStatus()))
- && ProductType.CARD_PRODUCT.getValue().equals(x.getType()))
- .collect(Collectors.toList());
- SvaProductManager productManager = SvaProductManager.getInstance();
- if (CollectionUtils.isNotEmpty(productToSync)) {
- for (UserProduct p : productToSync) {
- SvaProduct product = productManager.whereId(p.getId());
- LOGGER.info("Syncing card product " + p.getId());
- try {
- SyncCardStatusAction.syncCardStatusAction(subscriber, product);
- } catch (Exception e) {
- LOGGER.error("####### Impossibile syncCardStatus --> ", e);
- }
- }
- }
- // add user products
- List<UserProduct> userProducts = subscriber.getProductList().stream()
- .filter(x -> !SvaStatus.CLOSED.getValue().equals(x.getStatus())
- && !SvaStatus.REJECTED.getValue().equals(x.getStatus()))
- .collect(Collectors.toList());
- userOut.add("userProducts", new Gson().toJsonTree(userProducts));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement