| Line 134... |
Line 134... |
| 134 |
thinkWalnutDigitalRechargeEnquiryCredential.setRechargePassword(thinkWalnutDigitalRechargeEnquiryPassword);
|
134 |
thinkWalnutDigitalRechargeEnquiryCredential.setRechargePassword(thinkWalnutDigitalRechargeEnquiryPassword);
|
| 135 |
thinkWalnutDigitalRechargeEnquiryCredential.setRechargeAuthKey(thinkWalnutDigitalRechargeAuthKey);
|
135 |
thinkWalnutDigitalRechargeEnquiryCredential.setRechargeAuthKey(thinkWalnutDigitalRechargeAuthKey);
|
| 136 |
Map<String, RechargeStatus> requestRechargeStatusChanged = new HashMap<>();
|
136 |
Map<String, RechargeStatus> requestRechargeStatusChanged = new HashMap<>();
|
| 137 |
List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllBetweenTimestamp(nonSuccessRechargeStatuses,fromDate, toDate);
|
137 |
List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllBetweenTimestamp(nonSuccessRechargeStatuses,fromDate, toDate);
|
| 138 |
for(RechargeTransaction rechargeTransaction : rechargeTransactions) {
|
138 |
for(RechargeTransaction rechargeTransaction : rechargeTransactions) {
|
| - |
|
139 |
try {
|
| 139 |
int providerId = rechargeTransaction.getProviderId();
|
140 |
int providerId = rechargeTransaction.getProviderId();
|
| 140 |
if(providerId==1) {
|
141 |
if(providerId==1) {
|
| 141 |
oxigenRechargeProviderService.doCheckStatusRequest(oxigenRechargeEnquiryUrl, oxigenRechargeAuthKey, rechargeTransaction);
|
142 |
oxigenRechargeProviderService.doCheckStatusRequest(oxigenRechargeEnquiryUrl, oxigenRechargeAuthKey, rechargeTransaction);
|
| 142 |
} else if(providerId==2) {
|
143 |
} else if(providerId==2) {
|
| 143 |
thinkWalnutDigitalRechargeProviderService.doCheckStatusRequest(thinkWalnutDigitalRechargeEnquiryCredential, rechargeTransaction);
|
144 |
thinkWalnutDigitalRechargeProviderService.doCheckStatusRequest(thinkWalnutDigitalRechargeEnquiryCredential, rechargeTransaction);
|
| 144 |
}
|
145 |
}
|
| 145 |
if(rechargeTransaction.getStatus().equals(RechargeStatus.SUCCESS) || rechargeTransaction.getStatus().equals(RechargeStatus.FAILED)) {
|
146 |
if(rechargeTransaction.getStatus().equals(RechargeStatus.SUCCESS) || rechargeTransaction.getStatus().equals(RechargeStatus.FAILED)) {
|
| 146 |
requestRechargeStatusChanged.put(rechargeTransaction.getRequestId(), rechargeTransaction.getStatus());
|
147 |
requestRechargeStatusChanged.put(rechargeTransaction.getRequestId(), rechargeTransaction.getStatus());
|
| - |
|
148 |
}
|
| - |
|
149 |
} catch (Exception e) {
|
| - |
|
150 |
LOGGER.info("Could not check status for Request {}", rechargeTransaction.getRequestId());
|
| 147 |
}
|
151 |
}
|
| 148 |
}
|
152 |
}
|
| 149 |
model.addAttribute("response", mvcResponseSender.createResponseString(requestRechargeStatusChanged));
|
153 |
model.addAttribute("response", mvcResponseSender.createResponseString(requestRechargeStatusChanged));
|
| 150 |
return "response";
|
154 |
return "response";
|
| 151 |
}
|
155 |
}
|