| Line 880... |
Line 880... |
| 880 |
List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(inventoryItemsMap.keySet());
|
880 |
List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(inventoryItemsMap.keySet());
|
| 881 |
List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
|
881 |
List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
|
| 882 |
Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, schemeIds.size()).stream()
|
882 |
Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, schemeIds.size()).stream()
|
| 883 |
.collect(Collectors.toMap(x -> x.getId(), x -> x));
|
883 |
.collect(Collectors.toMap(x -> x.getId(), x -> x));
|
| 884 |
for (SchemeInOut schemeInOut : schemeInOuts) {
|
884 |
for (SchemeInOut schemeInOut : schemeInOuts) {
|
| - |
|
885 |
InventoryItem ii = inventoryItemsMap.get(schemeInOut.getInventoryItemId());
|
| 885 |
Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
|
886 |
Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
|
| 886 |
if(scheme.getAmountType().equals(AmountType.FIXED)) continue;
|
887 |
if(scheme.getAmountType().equals(AmountType.FIXED)) continue;
|
| 887 |
schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
|
888 |
schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
|
| 888 |
schemeInOutRepository.persist(schemeInOut);
|
889 |
schemeInOutRepository.persist(schemeInOut);
|
| 889 |
SchemeInOut sioNew = new SchemeInOut();
|
890 |
SchemeInOut sioNew = new SchemeInOut();
|
| 890 |
sioNew.setAmount(getAmount(inventoryItemsMap.get(schemeInOut.getInventoryItemId()),
|
891 |
sioNew.setAmount(getAmount(ii,scheme));
|
| 891 |
scheme));
|
- |
|
| 892 |
sioNew.setInventoryItemId(schemeInOut.getInventoryItemId());
|
892 |
sioNew.setInventoryItemId(schemeInOut.getInventoryItemId());
|
| 893 |
sioNew.setSchemeId(schemeInOut.getSchemeId());
|
893 |
sioNew.setSchemeId(schemeInOut.getSchemeId());
|
| 894 |
schemeInOutRepository.persist(sioNew);
|
894 |
schemeInOutRepository.persist(sioNew);
|
| 895 |
amountToRollback += schemeInOut.getAmount();
|
895 |
amountToRollback += schemeInOut.getAmount();
|
| 896 |
amountToCredit += sioNew.getAmount();
|
896 |
amountToCredit += sioNew.getAmount();
|