| Line 909... |
Line 909... |
| 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 |
for (SchemeInOut sio : sios) {
|
911 |
for (SchemeInOut sio : sios) {
|
| 912 |
String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
|
912 |
String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
|
| 913 |
.getSerialNumber();
|
913 |
.getSerialNumber();
|
| 914 |
if (!serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId())) {
|
914 |
if (!serialSchemeConsidered.contains(serialNumber + String.valueOf(sio.getSchemeId()))) {
|
| 915 |
LOGGER.info("Checking serialSchemeConsidered.contains(serialNumber + \",\" + sio.getSchemeId()) -- {}",
|
- |
|
| 916 |
serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId()));
|
- |
|
| 917 |
serialSchemeConsidered.add(serialNumber + "," + sio.getSchemeId());
|
915 |
serialSchemeConsidered.add(serialNumber + String.valueOf(sio.getSchemeId()));
|
| 918 |
continue;
|
916 |
continue;
|
| 919 |
}
|
917 |
}
|
| 920 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
918 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
| 921 |
amountToRollback += sio.getAmount();
|
919 |
amountToRollback += sio.getAmount();
|
| 922 |
sio.setSchemeType(SchemeType.OUT);
|
920 |
sio.setSchemeType(SchemeType.OUT);
|