| Line 43... |
Line 43... |
| 43 |
@Override
|
43 |
@Override
|
| 44 |
public void addAmountToWallet(int retailerId, int referenceId, WalletReferenceType referenceType,
|
44 |
public void addAmountToWallet(int retailerId, int referenceId, WalletReferenceType referenceType,
|
| 45 |
String description, float amount) throws ProfitMandiBusinessException {
|
45 |
String description, float amount) throws ProfitMandiBusinessException {
|
| 46 |
if (amount == 0)
|
46 |
if (amount == 0)
|
| 47 |
return;
|
47 |
return;
|
| 48 |
UserWallet userWallet = userWalletRepository.selectById(retailerId);
|
48 |
UserWallet userWallet = userWalletRepository.selectByRetailerId(retailerId);
|
| 49 |
//userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
49 |
//userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
| 50 |
userWallet.setAmount(userWallet.getAmount() + Math.round(amount));
|
50 |
userWallet.setAmount(userWallet.getAmount() + Math.round(amount));
|
| 51 |
userWalletRepository.persist(userWallet);
|
51 |
userWalletRepository.persist(userWallet);
|
| 52 |
this.createUserWalletHistory(Math.round(amount), userWallet.getId(), referenceId, referenceType, description);
|
52 |
this.createUserWalletHistory(Math.round(amount), userWallet.getId(), referenceId, referenceType, description);
|
| 53 |
}
|
53 |
}
|
| Line 71... |
Line 71... |
| 71 |
this.createUserWalletHistory(-Math.round(amount), userWallet.getId(), referenceId, referenceType, description);
|
71 |
this.createUserWalletHistory(-Math.round(amount), userWallet.getId(), referenceId, referenceType, description);
|
| 72 |
}
|
72 |
}
|
| 73 |
|
73 |
|
| 74 |
@Override
|
74 |
@Override
|
| 75 |
public void rollbackAmountFromWallet(int retailerId, float amountToRollback, int rollbackReference,
|
75 |
public void rollbackAmountFromWallet(int retailerId, float amountToRollback, int rollbackReference,
|
| 76 |
WalletReferenceType walletReferenceType, String rollbackReason) {
|
76 |
WalletReferenceType walletReferenceType, String rollbackReason) throws Exception{
|
| 77 |
|
77 |
|
| 78 |
if (amountToRollback == 0)
|
78 |
if (amountToRollback == 0)
|
| 79 |
return;
|
79 |
return;
|
| 80 |
UserWallet userWallet = userWalletRepository.selectById(retailerId);
|
80 |
UserWallet userWallet = userWalletRepository.selectByRetailerId(retailerId);
|
| 81 |
//userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
81 |
//userWallet = userWalletRepository.selectByIdForUpdate(userWallet.getId());
|
| 82 |
userWallet.setAmount(userWallet.getAmount() - Math.round(amountToRollback));
|
82 |
userWallet.setAmount(userWallet.getAmount() - Math.round(amountToRollback));
|
| 83 |
userWalletRepository.persist(userWallet);
|
83 |
userWalletRepository.persist(userWallet);
|
| 84 |
this.createUserWalletHistory(-Math.round(amountToRollback), userWallet.getId(), rollbackReference,
|
84 |
this.createUserWalletHistory(-Math.round(amountToRollback), userWallet.getId(), rollbackReference,
|
| 85 |
walletReferenceType, rollbackReason);
|
85 |
walletReferenceType, rollbackReason);
|