| Line 92... |
Line 92... |
| 92 |
int walletAmount = walletService.getWalletAmount(retailerId);
|
92 |
int walletAmount = walletService.getWalletAmount(retailerId);
|
| 93 |
UserWallet userWallet = userWalletRepository.selectByRetailerId(retailerId);
|
93 |
UserWallet userWallet = userWalletRepository.selectByRetailerId(retailerId);
|
| 94 |
List<UserWalletHistory> uwh = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(rollbackReference, walletReferenceType)
|
94 |
List<UserWalletHistory> uwh = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(rollbackReference, walletReferenceType)
|
| 95 |
.stream().filter(x->x.getWalletId()==userWallet.getId()).collect(Collectors.toList());
|
95 |
.stream().filter(x->x.getWalletId()==userWallet.getId()).collect(Collectors.toList());
|
| 96 |
if(uwh.size() == 0) {
|
96 |
if(uwh.size() == 0) {
|
| 97 |
LOGGER.info("Retailer with id {} dont have valid reference and reference type {}",
|
97 |
LOGGER.info("Retailer with id {} dont have valid reference {} and reference type {}",
|
| 98 |
retailerId, rollbackReference, walletReferenceType);
|
98 |
retailerId, rollbackReference, walletReferenceType);
|
| 99 |
throw new ProfitMandiBusinessException("Retailer specific wallet entries doesn't exist", retailerId, "Nothing to rollback");
|
99 |
throw new ProfitMandiBusinessException("Retailer specific wallet entries doesn't exist", retailerId, "Nothing to rollback");
|
| 100 |
}
|
100 |
}
|
| 101 |
// userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
101 |
// userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
| 102 |
userWallet.setAmount(walletAmount - Math.round(amountToRollback));
|
102 |
userWallet.setAmount(walletAmount - Math.round(amountToRollback));
|