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

 import java.util.Set;
 import java.util.stream.Collectors;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.hibernate.loader.plan.exec.process.internal.CollectionReturnReader;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Component;
 import com.spice.profitmandi.common.enumuration.ItemType;
 	@Autowired
 	private RoleManager roleManager;
 	@Autowired
 	private RetailerRepository retailerRepository;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private RetailerSchemeRepository retailerSchemeRepository;
 			return;
+		}
 		if (scheme.isRetailerAll()) {
 			for (InventoryItem inventoryItem : completedInventoryItems) {
 				float cashback = this.createSchemeInOut(scheme, inventoryItem);
+				if (cashback > 0) {
-				walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
+					walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
-						WalletReferenceType.SCHEME_IN,
+							WalletReferenceType.SCHEME_IN,
-						"Added SCHEME_IN for item " + itemStringMap.get(inventoryItem.getItemId())
+							"Added SCHEME_IN for item " + itemStringMap.get(inventoryItem.getItemId())
-								+ " against invoiceNumber " + inventoryItem.getPurchase().getPurchaseReference(),
+									+ " against invoiceNumber " + inventoryItem.getPurchase().getPurchaseReference(),
-						cashback);
+							cashback);
+				}
+			}
 		} else {
 			List<Integer> retailerIds = retailerSchemeRepository.selectRetailerIdsBySchemeId(scheme.getId());
 			for (InventoryItem inventoryItem : completedInventoryItems) {
 				if (retailerIds.contains(inventoryItem.getFofoId())) {
 					float cashback = this.createSchemeInOut(scheme, inventoryItem);
+					if (cashback > 0) {
-					walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
+						walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
-							WalletReferenceType.SCHEME_IN,
+								WalletReferenceType.SCHEME_IN,
-							"Added SCHEME_IN for item " + itemStringMap.get(inventoryItem.getItemId())
+								"Added SCHEME_IN for item " + itemStringMap.get(inventoryItem.getItemId())
+										+ " against invoiceNumber "
-									+ " against invoiceNumber " + inventoryItem.getPurchase().getPurchaseReference(),
+										+ inventoryItem.getPurchase().getPurchaseReference(),
-							cashback);
+								cashback);
+					}
+				}
+			}
+		}
+	}
 				itemIds, false);
 		if (scheme.isRetailerAll()) {
 			for (InventoryItem inventoryItem : completedInventoryItems) {
 				float cashback = this.createSchemeInOut(scheme, inventoryItem);
+				if (cashback > 0) {
-				walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
+					walletService.addAmountToWallet(inventoryItem.getFofoId(), inventoryItem.getPurchaseId(),
-						WalletReferenceType.SCHEME_OUT, "Added for SCHEME_OUT", cashback);
+							WalletReferenceType.SCHEME_OUT, "Added for SCHEME_OUT", cashback);
+				}
+			}
 		} else {
 			List<Integer> retailerIds = retailerSchemeRepository.selectRetailerIdsBySchemeId(scheme.getId());
 			for (InventoryItem inventoryItem : completedInventoryItems) {
 				if (retailerIds.contains(inventoryItem.getFofoId())) {
 					float cashback = this.createSchemeInOut(scheme, inventoryItem);
+					if (cashback > 0) {
-					walletService.addAmountToWallet(inventoryItem.getFofoId(),
+						walletService.addAmountToWallet(inventoryItem.getFofoId(),
-							inventoryItemIdFofoOrderIdMap.get(inventoryItem.getId()), WalletReferenceType.SCHEME_OUT,
+								inventoryItemIdFofoOrderIdMap.get(inventoryItem.getId()),
-							"Added for SCHEME_OUT", cashback);
+								WalletReferenceType.SCHEME_OUT, "Added for SCHEME_OUT", cashback);
+					}
+				}
+			}
+		}
+	}
+			}
+		}
+	}
 	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
-		SchemeInOut schemeInOut = schemeInOutRepository.selectByScheme(scheme.getId(), inventoryItem.getId());
+		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByScheme(scheme.getId(), inventoryItem.getId());
 		float amount = 0;
-		if (schemeInOut == null || schemeInOut.getRolledBackTimestamp() != null) {
+		if (schemeInOuts.stream().filter(x -> x.getRolledBackTimestamp() != null).collect(Collectors.toList())
+				.size() == 0) {
-			schemeInOut = new SchemeInOut();
+			SchemeInOut schemeInOut = new SchemeInOut();
 			amount = this.getAmount(inventoryItem, scheme);
 			schemeInOut.setSchemeId(scheme.getId());
 			schemeInOut.setInventoryItemId(inventoryItem.getId());
 			schemeInOut.setAmount(amount);
 			schemeInOutRepository.persist(schemeInOut);
 	private float getAmount(InventoryItem inventoryItem, Scheme scheme) {
 		float amount = 0;
 		float totalTaxRate = inventoryItem.getIgstRate() + inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
 		if (scheme.getAmountType() == AmountType.PERCENTAGE) {
-			if(scheme.getType().equals(SchemeType.IN)) {
+			if (scheme.getType().equals(SchemeType.IN)) {
 				amount = inventoryItem.getUnitPrice() - inventoryItem.getPriceDropAmount();
 			} else {
 				try {
 					amount = tagListingRepository.selectByItemId(inventoryItem.getItemId()).getSellingPrice();
-				} catch(Exception e) {
+				} catch (Exception e) {
 					LOGGER.info("Could not find tag Listing entry in {}", inventoryItem.getItemId());
 					e.printStackTrace();
+				}
+			}
 			float taxableSellingPrice = amount / (1 + totalTaxRate / 100);
 			InventoryItem ii = inventoryItemsMap.get(schemeInOut.getInventoryItemId());
 			Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
 			if (scheme.getAmountType().equals(AmountType.FIXED)) {
 				continue;
+			}
-			if(schemeInOut.getRolledBackTimestamp() == null) {
+			if (schemeInOut.getRolledBackTimestamp() == null) {
 				float newAmount = getAmount(ii, scheme);
-				if(schemeInOut.getAmount() - newAmount >= 0.01f) {
+				if (schemeInOut.getAmount() - newAmount >= 0.01f) {
 					schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
 					schemeInOutRepository.persist(schemeInOut);
 					SchemeInOut sioNew = new SchemeInOut();
 					sioNew.setAmount(newAmount);
 					sioNew.setInventoryItemId(schemeInOut.getInventoryItemId());
 					sioNew.setSchemeId(schemeInOut.getSchemeId());
 					schemeInOutRepository.persist(sioNew);
 					amountToCredit += sioNew.getAmount();
 					amountToDebit += schemeInOut.getAmount();
+				}
+			}
+		}
 		int fofoId = inventoryItems.get(0).getFofoId();
 		if (amountToDebit > 0) {
 			walletService.addAmountToWallet(fofoId, reversalReference, WalletReferenceType.PRICE_DROP, reversalReason,
 					-amountToDebit);
+		}
 		if (amountToCredit > 0) {
-		walletService.addAmountToWallet(fofoId, reversalReference, WalletReferenceType.PRICE_DROP, reversalReason,
+			walletService.addAmountToWallet(fofoId, reversalReference, WalletReferenceType.PRICE_DROP, reversalReason,
-				amountToCredit);
+					amountToCredit);
+		}
+	}
 	@Override
-	public void reverseSchemes(List<InventoryItem> inventoryItems, int reversalReference, String reversalReason, SchemeType schemeType) throws ProfitMandiBusinessException{
+	public void reverseSchemes(List<InventoryItem> inventoryItems, int reversalReference, String reversalReason,
+			SchemeType schemeType) throws ProfitMandiBusinessException {
 		Map<Integer, InventoryItem> inventoryItemsMap = inventoryItems.stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(inventoryItemsMap.keySet());
 		List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
 		float amount = 0;
 		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, schemeIds.size()).stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		for (SchemeInOut schemeInOut : schemeInOuts) {
 			Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
-			if(scheme.getType().equals(schemeType)) {
+			if (scheme.getType().equals(schemeType)) {
-				if(schemeInOut.getRolledBackTimestamp() == null) {
+				if (schemeInOut.getRolledBackTimestamp() == null) {
 					schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
 					schemeInOutRepository.persist(schemeInOut);
 					amount += schemeInOut.getAmount();
+				}
+			}
+		}
 		int fofoId = inventoryItems.get(0).getFofoId();
-		WalletReferenceType walletReferenceType = schemeType.equals(SchemeType.OUT)?WalletReferenceType.SCHEME_OUT:WalletReferenceType.SCHEME_IN;
+		WalletReferenceType walletReferenceType = schemeType.equals(SchemeType.OUT) ? WalletReferenceType.SCHEME_OUT
+				: WalletReferenceType.SCHEME_IN;
-		if(amount > 0) {
+		if (amount > 0) {
-			walletService.rollbackAmountFromWallet(fofoId, amount, reversalReference, walletReferenceType, reversalReason);
+			walletService.rollbackAmountFromWallet(fofoId, amount, reversalReference, walletReferenceType,
+					reversalReason);
+		}
+	}
+	@Override
+	public void updateSchmesForModel(int catalogId) throws ProfitMandiBusinessException {
+		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);
+		Map<Integer, Scheme> schemes = schemeRepository
+				.selectAllByItemIds(items.stream().map(x -> x.getId()).collect(Collectors.toList()));
+	}
+}

Subversion Repositories SmartDukaan

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