| Line 906... |
Line 906... |
| 906 |
new ArrayList<String>(inventorySerialNumberMap.values()))
|
906 |
new ArrayList<String>(inventorySerialNumberMap.values()))
|
| 907 |
.stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
|
907 |
.stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
|
| 908 |
.collect(Collectors.toList());
|
908 |
.collect(Collectors.toList());
|
| 909 |
LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());
|
909 |
LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());
|
| 910 |
UserWalletHistory uwh = new UserWalletHistory();
|
910 |
UserWalletHistory uwh = new UserWalletHistory();
|
| 911 |
List<String> toBerolledBack = new ArrayList<>();
|
- |
|
| 912 |
for (SchemeInOut sio : sios) {
|
911 |
for (SchemeInOut sio : sios) {
|
| 913 |
String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
|
912 |
String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
|
| 914 |
.getSerialNumber();
|
913 |
.getSerialNumber();
|
| 915 |
if (!serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId())) {
|
914 |
if (!serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId())) {
|
| - |
|
915 |
LOGGER.info("Checking serialSchemeConsidered.contains(serialNumber + \",\" + sio.getSchemeId()) -- {}",
|
| - |
|
916 |
serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId()));
|
| 916 |
serialSchemeConsidered.add(serialNumber + "," + sio.getSchemeId());
|
917 |
serialSchemeConsidered.add(serialNumber + "," + sio.getSchemeId());
|
| 917 |
continue;
|
918 |
continue;
|
| 918 |
}
|
919 |
}
|
| 919 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
920 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
| 920 |
amountToRollback += sio.getAmount();
|
921 |
amountToRollback += sio.getAmount();
|