| Line 278... |
Line 278... |
| 278 |
LOGGER.info("Could not check status for Request {}", rechargeTransaction.getRequestId());
|
278 |
LOGGER.info("Could not check status for Request {}", rechargeTransaction.getRequestId());
|
| 279 |
}
|
279 |
}
|
| 280 |
}
|
280 |
}
|
| 281 |
LOGGER.info("Reconcile recharge ran successfully");
|
281 |
LOGGER.info("Reconcile recharge ran successfully");
|
| 282 |
}
|
282 |
}
|
| - |
|
283 |
|
| - |
|
284 |
//TemporaryMethod
|
| - |
|
285 |
public void migrateInvoice() {
|
| - |
|
286 |
List<FofoOrder> fofoOrders = fofoOrderRepository.selectFromSaleDate(LocalDateTime.now().minusDays(3));
|
| - |
|
287 |
Map<Integer, List<FofoOrder>> partnerOrdersMap = new HashMap<>();
|
| - |
|
288 |
partnerOrdersMap = fofoOrders.stream().collect(Collectors.groupingBy(FofoOrder::getFofoId, Collectors.toList()));
|
| - |
|
289 |
for (List<FofoOrder> orderList : partnerOrdersMap.values()) {
|
| - |
|
290 |
orderList.stream().sorted((x1,x2)->x1.getId()-x2.getId()).forEach(x-> LOGGER.info("Order Id is {}", x.getId()));
|
| - |
|
291 |
}
|
| - |
|
292 |
}
|
| 283 |
|
293 |
|
| 284 |
public void processScheme() throws Exception {
|
294 |
public void processScheme() throws Exception {
|
| 285 |
LocalDateTime fromDate = LocalDateTime.now().minusDays(15);
|
295 |
LocalDateTime fromDate = LocalDateTime.now().minusDays(15);
|
| 286 |
LOGGER.info("Started execution at {}", LocalDateTime.now());
|
296 |
LOGGER.info("Started execution at {}", LocalDateTime.now());
|
| 287 |
List<Purchase> purchases = purchaseRepository.selectFromPurchaseCompleteDate(fromDate);
|
297 |
List<Purchase> purchases = purchaseRepository.selectFromPurchaseCompleteDate(fromDate);
|