| Line 241... |
Line 241... |
| 241 |
private WalletService walletService;
|
241 |
private WalletService walletService;
|
| 242 |
|
242 |
|
| 243 |
@Override
|
243 |
@Override
|
| 244 |
public void reverseAdditionalSelloutSchemes(int fofoId, List<InventoryItem> inventoryItems) throws ProfitMandiBusinessException {
|
244 |
public void reverseAdditionalSelloutSchemes(int fofoId, List<InventoryItem> inventoryItems) throws ProfitMandiBusinessException {
|
| 245 |
List<OfferPayout> offerPayouts = new ArrayList<>();
|
245 |
List<OfferPayout> offerPayouts = new ArrayList<>();
|
| - |
|
246 |
//As of now we are not handling non-serialised items
|
| - |
|
247 |
inventoryItems = inventoryItems.stream().filter(x -> x.getSerialNumber() != null).collect(Collectors.toList());
|
| 246 |
for (InventoryItem inventoryItem : inventoryItems) {
|
248 |
for (InventoryItem inventoryItem : inventoryItems) {
|
| 247 |
offerPayouts.addAll(offerPayoutRepository.selectAllBySerialNumber(inventoryItem.getFofoId(), inventoryItem.getSerialNumber())
|
249 |
offerPayouts.addAll(offerPayoutRepository.selectAllBySerialNumber(inventoryItem.getFofoId(), inventoryItem.getSerialNumber())
|
| 248 |
.stream()
|
250 |
.stream()
|
| 249 |
.filter(x -> x.getRejectTimestamp() != null)
|
251 |
.filter(x -> x.getRejectTimestamp() != null)
|
| 250 |
.collect(Collectors.toList()));
|
252 |
.collect(Collectors.toList()));
|