Subversion Repositories SmartDukaan

Rev

Rev 24555 | Rev 24564 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 24555 Rev 24561
Line 477... Line 477...
477 
		processScheme(fromDate, LocalDateTime.now());
 477 
		processScheme(fromDate, LocalDateTime.now());
478 
	}
 478 
	}
479 
 
 479 
 
480 
	public void processScheme(LocalDateTime startDate, LocalDateTime endDate) throws Exception {
 480 
	public void processScheme(LocalDateTime startDate, LocalDateTime endDate) throws Exception {
481 
		LOGGER.info("Started execution at {}", LocalDateTime.now());
 481 
		LOGGER.info("Started execution at {}", LocalDateTime.now());
- 
 
 482 
		try {
482 
		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);
 483 
		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);
483 
		for (Purchase purchase : purchases) {
 484 
		for (Purchase purchase : purchases) {
484 
			try {
 - 
 
485 
				schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
 485 
			schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
486 
			} catch (Exception e) {
 - 
 
487 
				LOGGER.error("Error while processing purchase {} for scheme In ", purchase.getId());
 - 
 
488 
				e.printStackTrace();
 - 
 
489 
 
 - 
 
490 
			}
 - 
 
491 
		}
 486 
		}
- 
 
 487 
 
492 
		List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
 488 
		List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
493 
		for (FofoOrder fofoOrder : fofoOrders) {
 489 
		for (FofoOrder fofoOrder : fofoOrders) {
494 
			try {
 - 
 
495 
				schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
 490 
			schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
- 
 
 491 
		}
496 
			} catch (Exception e) {
 492 
		}catch(Exception e) {
497 
				LOGGER.error("Error while processing sale order {} for scheme Out", fofoOrder.getId());
 493 
			e.printStackTrace();
498 
			}
 494 
			throw e;
499 
		}
 495 
		}
500 
		LOGGER.info("Schemes process successfully.");
 496 
		LOGGER.info("Schemes process successfully.");
501 
	}
 497 
	}
502 
 
 498 
 
503 
	public void processRechargeCashback() throws Throwable {
 499 
	public void processRechargeCashback() throws Throwable {
Line 679... Line 675...
679 
			for (PartnerDailyInvestment investment : Lists
 675 
			for (PartnerDailyInvestment investment : Lists
680 
					.reverse(partnerDailyInvestmentRepository.selectAll(fofoId, null, null))) {
 676 
					.reverse(partnerDailyInvestmentRepository.selectAll(fofoId, null, null))) {
681 
				float statementAmount = walletService.getOpeningTill(fofoId,
 677 
				float statementAmount = walletService.getOpeningTill(fofoId,
682 
						investment.getDate().plusDays(1).atTime(LocalTime.of(4, 0)));
 678 
						investment.getDate().plusDays(1).atTime(LocalTime.of(4, 0)));
683 
				CustomRetailer retailer = retailerService.getFofoRetailer(fofoId);
 679 
				CustomRetailer retailer = retailerService.getFofoRetailer(fofoId);
684 
				LOGGER.info("{}\t{}\t{}\t{}\t{}", fofoId, retailer.getBusinessName(),
 680 
				LOGGER.info("{}\t{}\t{}\t{}\t{}", fofoId, retailer.getBusinessName(), investment.getDate().toString(),
685 
						investment.getDate().toString(), investment.getWalletAmount(), statementAmount);
 681 
						investment.getWalletAmount(), statementAmount);
686 
 
 682 
 
687 
			}
 683 
			}
688 
		}
 684 
		}
689 
 
 685 
 
690 
	}
 686 
	}
Line 799... Line 795...
799 
			}
 795 
			}
800 
		}
 796 
		}
801 
 
 797 
 
802 
	}
 798 
	}
803 
 
 799 
 
- 
 
 800 
	/*
- 
 
 801 
	 * public void processSchemeForModel(String string) { pricingService
- 
 
 802 
	 *
- 
 
 803 
	 * }
- 
 
 804 
	 */
- 
 
 805 
 
804 
}
 806 
}