WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java

 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
 import org.hibernate.query.Query;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Component;
 import com.spice.profitmandi.common.enumuration.ItemType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 	@Autowired
 	private SessionFactory sessionFactory;
 	@Autowired
 	private SchemeRepository schemeRepository;
 	@Autowired
 	private PriceDropRepository priceDropRepository;
 	@Autowired
 	private RoleManager roleManager;
 		PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(retailerId,
 				purchase.getCreateTimestamp().toLocalDate());
 		LOGGER.info("purchase is completed = {}", (purchase.getCompleteTimestamp() != null));
 		if (purchase.getCompleteTimestamp() != null) {
 			List<Scheme> schemes = schemeRepository.selectActiveAll(SchemeType.IN, partnerType,
-					purchase.getCompleteTimestamp());
+					purchase.getCompleteTimestamp(), false);
 			float totalCashback = 0;
 			if (schemes.isEmpty()) {
 				return;
+			}
 			List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchaseId);
+				}
+			}
 			LOGGER.info("Items count for purchase id {} is {}", purchaseId, itemsCount);
 			if (itemsCount > 0) {
-				walletService.addAmountToWallet(retailerId, purchaseId, WalletReferenceType.SCHEME_IN,
+				walletService.addAmountToWallet(
-						"Added for SCHEME IN against invoice " + purchase.getPurchaseReference() + " (total "
+						retailerId, purchaseId, WalletReferenceType.SCHEME_IN, "Added for SCHEME IN against invoice "
-								+ itemsCount + " pcs)",
+								+ purchase.getPurchaseReference() + " (total " + itemsCount + " pcs)",
 						totalCashback, purchase.getCreateTimestamp());
 				LOGGER.info("Added Rs.{} for SCHEME IN against invoice {} total pcs({}) {}", totalCashback,
 						purchase.getPurchaseReference(), itemsCount);
 				purchase.setCashback(purchase.getCashback() + totalCashback);
 				purchaseRepository.persist(purchase);
 	// We are maintaining price drop after grn
 	private float getAmount(InventoryItem inventoryItem, Scheme scheme) {
 		float amount = 0;
 		float dpForCalc = 0;
 		float taxableSellingPrice = 0;
+		// float totalTaxRate = inventoryItem.getIgstRate() +
-		//float totalTaxRate = inventoryItem.getIgstRate() + inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
+		// inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
-		//Hardcoding it to 18%
+		// Hardcoding it to 18%
 		float totalTaxRate = 18f;
+		// float totalTaxRate = inventoryItem.getIgstRate() +
-		//float totalTaxRate = inventoryItem.getIgstRate() + inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
+		// inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
 		if (scheme.getAmountType() == AmountType.PERCENTAGE) {
 			if (scheme.getType().equals(SchemeType.IN)) {
 				dpForCalc = inventoryItem.getUnitPrice() - inventoryItem.getPriceDropAmount();
 			} else {
 				try {
 					dpForCalc = Math.min(inventoryItem.getUnitPrice() - inventoryItem.getPriceDropAmount(),
 							tagListingRepository.selectByItemId(inventoryItem.getItemId()).getSellingPrice());
 				} catch (Exception e) {
 					LOGGER.info("Could not find tag Listing entry in {}", inventoryItem.getItemId());
 					e.printStackTrace();
+				}
 		float totalCashback = 0;
 		int count = 0;
 		Set<Scheme> allFixedSchemes = schemeRepository
-				.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp()).stream()
+				.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp(), false).stream()
 				.filter(scheme -> scheme.getAmountType().equals(AmountType.FIXED)).collect(Collectors.toSet());
 		for (InventoryItem inventoryItem : inventoryItems) {
 			float itemCashback = 0;
 			Purchase purchase = purchaseRepository.selectByIdAndFofoId(inventoryItem.getPurchaseId(), retailerId);
 			List<Scheme> schemes = null;
 			if (purchase.getCompleteTimestamp() == null) {
 				continue;
+			}
 			if (purchase.getCompleteTimestamp().isAfter(LocalDate.of(2019, 9, 1).atStartOfDay())) {
-				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp());
+				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp(),
+						false);
 			} else {
-				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType,
+				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType, purchase.getCompleteTimestamp(),
-						purchase.getCompleteTimestamp());
+						false);
+			}
 			Set<Scheme> schemesSet = schemes.stream().filter(x -> x.getAmountType().equals(AmountType.PERCENTAGE))
 					.collect(Collectors.toSet());
 			schemesSet.addAll(allFixedSchemes);
 			schemesSet = schemesSet.stream().filter(x -> schemeIds.contains(x.getId())).collect(Collectors.toSet());
 		if (amountToRollback > 0) {
 			int inventoryItemId = inventoryItemIds.get(0);
 			InventoryItem ii = inventoryItemRepository.selectById(inventoryItemId);
 			Purchase p = purchaseRepository.selectById(ii.getPurchaseId());
 			Integer fofoId = ii.getFofoId();
-			//TODO//
+			// TODO//
 			walletService.rollbackAmountFromWallet(fofoId, amountToRollback, rollbackReference,
 					WalletReferenceType.SCHEME_IN, rollbackReason, LocalDateTime.now());
+		}
+	}
+				}
+			}
 			int fofoId = inventoryItems.get(0).getFofoId();
 			if (amountToDebit > 0) {
 				walletService.addAmountToWallet(fofoId, purchaseId, WalletReferenceType.SCHEME_IN,
-						MessageFormat.format(reversalReason, purchaseInventoryItemList.size()),
+						MessageFormat.format(reversalReason, purchaseInventoryItemList.size()), -amountToDebit,
-						-amountToDebit, priceDrop.getAffectedOn());
+						priceDrop.getAffectedOn());
+			}
 			if (amountToCredit > 0) {
 				walletService.addAmountToWallet(fofoId, purchaseId, WalletReferenceType.SCHEME_IN,
-						MessageFormat.format(reversalReason, purchaseInventoryItemList.size()),
+						MessageFormat.format(reversalReason, purchaseInventoryItemList.size()), amountToCredit,
-						amountToCredit, priceDrop.getAffectedOn());
+						priceDrop.getAffectedOn());
+			}
+		}
+	}
 	@Override
+		}
 		int fofoId = inventoryItems.get(0).getFofoId();
 		WalletReferenceType walletReferenceType = schemeType.equals(SchemeType.OUT) ? WalletReferenceType.SCHEME_OUT
 				: WalletReferenceType.SCHEME_IN;
 		if (amount > 0) {
-			//TODO//
+			// TODO//
 			walletService.rollbackAmountFromWallet(fofoId, amount, reversalReference, walletReferenceType,
 					reversalReason, LocalDateTime.now());
+		}
+	}
 		Query<Double> query = session.createQuery(criteriaQuery);
 		return query.getSingleResult() + ProfitMandiConstants.SCHEME_INVESTMENT_MARGIN;
+	}
+	@Override
+	@Cacheable(value = "itemSchemeCashback", cacheManager = "timeoutCacheManager")
+	public Map<Integer, Float> getItemSchemeCashBack() {
+		Map<Integer, Float> itemCashbackMap = new HashMap<>();
+		Map<Integer, Scheme> cashbackSchemesMap = schemeRepository
+				.selectActiveAll(SchemeType.OUT, PartnerType.ALL, LocalDateTime.now(), true).stream()
+				.filter(x -> x.getAmountType().equals(AmountType.FIXED))
+				.collect(Collectors.toMap(x -> x.getId(), x -> x));
+		List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(cashbackSchemesMap.keySet());
+		schemeItems.stream().forEach(x -> {
+			itemCashbackMap.put(x.getItemId(), cashbackSchemesMap.get(x.getItemId()).getAmount());
+		});
+		return itemCashbackMap;
+	}
 	/*
 	 * @Override public void updateSchmesForModel(int catalogId) throws
 	 * ProfitMandiBusinessException { List<Item> items =
 	 * itemRepository.selectAllByCatalogItemId(catalogId); Map<Integer, Scheme>
 	 * schemes = schemeRepository .selectAllByItemIds(items.stream().map(x ->

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java – Rev 26679 → 26684