| Line 3672... |
Line 3672... |
| 3672 |
|
3672 |
|
| 3673 |
if (!partnerLastCollectionRemarkIds.isEmpty()) {
|
3673 |
if (!partnerLastCollectionRemarkIds.isEmpty()) {
|
| 3674 |
List<PartnerCollectionRemark> partnerCollectionRemarks = partnerCollectionRemarkRepository.selectByIds(partnerLastCollectionRemarkIds);
|
3674 |
List<PartnerCollectionRemark> partnerCollectionRemarks = partnerCollectionRemarkRepository.selectByIds(partnerLastCollectionRemarkIds);
|
| 3675 |
|
3675 |
|
| 3676 |
Map<Integer, PartnerCollectionRemark> rbmEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.RBM_L2_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
3676 |
Map<Integer, PartnerCollectionRemark> rbmEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.RBM_L2_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
| - |
|
3677 |
Map<Integer, PartnerCollectionRemark> rbmL3EscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.RBM_L3_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
| 3677 |
Map<Integer, PartnerCollectionRemark> salesEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.SALES_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
3678 |
Map<Integer, PartnerCollectionRemark> salesEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.SALES_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
| 3678 |
|
3679 |
|
| 3679 |
|
3680 |
|
| 3680 |
if (!rbmEscalatedRemarksMap.isEmpty()) {
|
3681 |
if (!rbmEscalatedRemarksMap.isEmpty()) {
|
| 3681 |
//
|
3682 |
//
|
| Line 3694... |
Line 3695... |
| 3694 |
helper.setTo(email);
|
3695 |
helper.setTo(email);
|
| 3695 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
3696 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
| 3696 |
helper.setFrom(senderAddress);
|
3697 |
helper.setFrom(senderAddress);
|
| 3697 |
mailSender.send(message);
|
3698 |
mailSender.send(message);
|
| 3698 |
|
3699 |
|
| - |
|
3700 |
}
|
| - |
|
3701 |
}
|
| - |
|
3702 |
if (!rbmL3EscalatedRemarksMap.isEmpty()) {
|
| - |
|
3703 |
//
|
| - |
|
3704 |
for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
|
| - |
|
3705 |
List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
|
| - |
|
3706 |
.map(x -> rbmL3EscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
|
| - |
|
3707 |
String subject = "Partners escalated to RBM-L3";
|
| - |
|
3708 |
String messageText = this.getMessageForRBMEscalatedPartners(filteredRows);
|
| - |
|
3709 |
|
| - |
|
3710 |
MimeMessage message = mailSender.createMimeMessage();
|
| - |
|
3711 |
MimeMessageHelper helper = new MimeMessageHelper(message, true);
|
| - |
|
3712 |
String[] email = new String[]{storeGuyEntry.getKey()};
|
| - |
|
3713 |
|
| - |
|
3714 |
helper.setSubject(subject);
|
| 3699 |
LOGGER.info("filteredRows {}", filteredRows);
|
3715 |
helper.setText(messageText, true);
|
| - |
|
3716 |
helper.setTo(email);
|
| - |
|
3717 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
| - |
|
3718 |
helper.setFrom(senderAddress);
|
| - |
|
3719 |
mailSender.send(message);
|
| 3700 |
|
3720 |
|
| 3701 |
}
|
3721 |
}
|
| 3702 |
}
|
3722 |
}
|
| 3703 |
if (!salesEscalatedRemarksMap.isEmpty()) {
|
3723 |
if (!salesEscalatedRemarksMap.isEmpty()) {
|
| 3704 |
//
|
3724 |
//
|
| Line 3717... |
Line 3737... |
| 3717 |
helper.setTo(email);
|
3737 |
helper.setTo(email);
|
| 3718 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
3738 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
| 3719 |
helper.setFrom(senderAddress);
|
3739 |
helper.setFrom(senderAddress);
|
| 3720 |
mailSender.send(message);
|
3740 |
mailSender.send(message);
|
| 3721 |
|
3741 |
|
| 3722 |
LOGGER.info("filteredRows {}", filteredRows);
|
- |
|
| 3723 |
|
- |
|
| 3724 |
}
|
3742 |
}
|
| 3725 |
}
|
3743 |
}
|
| 3726 |
|
3744 |
|
| 3727 |
}
|
3745 |
}
|
| 3728 |
}
|
3746 |
}
|