| Line 252... |
Line 252... |
| 252 |
// ByteArrayInputStream(htmlContent.getBytes()));
|
252 |
// ByteArrayInputStream(htmlContent.getBytes()));
|
| 253 |
|
253 |
|
| 254 |
this.uploadFile(fileStreamsMap);
|
254 |
this.uploadFile(fileStreamsMap);
|
| 255 |
if (createOfferRequest.getPartnerCriteria().getRegionIds().size() > 0
|
255 |
if (createOfferRequest.getPartnerCriteria().getRegionIds().size() > 0
|
| 256 |
|| createOfferRequest.getPartnerCriteria().getFofoIds().size() > 0
|
256 |
|| createOfferRequest.getPartnerCriteria().getFofoIds().size() > 0
|
| 257 |
|| createOfferRequest.getPartnerCriteria().getRegionIds().size() > 0) {
|
257 |
|| createOfferRequest.getPartnerCriteria().getRegionIds().size() > 0 ||
|
| - |
|
258 |
createOfferRequest.getPartnerCriteria().getExcludeFofoIds().size() > 0) {
|
| 258 |
List<Integer> fofoIds = offersMap.entrySet().stream().filter(x -> x.getValue().contains(offer))
|
259 |
List<Integer> fofoIds = offersMap.entrySet().stream().filter(x -> x.getValue().contains(offer))
|
| 259 |
.map(x -> x.getKey()).collect(Collectors.toList());
|
260 |
.map(x -> x.getKey()).collect(Collectors.toList());
|
| 260 |
List<Integer> userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds);
|
261 |
List<Integer> userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds);
|
| 261 |
sendNotificationModel.setUserIds(userIds);
|
262 |
sendNotificationModel.setUserIds(userIds);
|
| 262 |
notificationService.sendNotification(sendNotificationModel);
|
263 |
notificationService.sendNotification(sendNotificationModel);
|
| 263 |
} else {
|
264 |
} else {
|
| - |
|
265 |
|
| 264 |
notificationService.sendNotificationToAll(sendNotificationModel);
|
266 |
notificationService.sendNotificationToAll(sendNotificationModel);
|
| 265 |
}
|
267 |
}
|
| 266 |
|
268 |
|
| 267 |
}
|
269 |
}
|
| 268 |
|
270 |
|