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

 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.CreateSchemeRequest;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
+import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.service.NotificationService;
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.END_DATE, createSchemeRequest.getEndDate(),
 					"SCHM_VE_1004");
+		}
+	}
-	private Scheme toScheme(int creatorId, CreateSchemeRequest createSchemeRequest) {
-		Scheme scheme = new Scheme();
+	@Autowired
-		scheme.setName(createSchemeRequest.getName());
+	StateGstRateRepository stateGstRateRepository;
-		scheme.setDescription(createSchemeRequest.getDescription());
-		scheme.setType(createSchemeRequest.getType());
-		scheme.setAmountType(createSchemeRequest.getAmountType());
-		scheme.setAmount(createSchemeRequest.getAmount());
-		scheme.setPartnerType(createSchemeRequest.getPartnerType());
-		scheme.setStartDateTime(createSchemeRequest.getStartDate());
-		scheme.setEndDateTime(createSchemeRequest.getEndDate());
-		scheme.setCreatedBy(creatorId);
-		scheme.setCashback(createSchemeRequest.isCashback());
-		return scheme;
-	}
 	private void validateItemIds(CreateSchemeRequest createSchemeRequest) throws ProfitMandiBusinessException {
 		if (createSchemeRequest.getCatalogIds() == null || createSchemeRequest.getCatalogIds().isEmpty()) {
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.ITEM_ID, createSchemeRequest.getCatalogIds(),
 			purchase.setCashback(purchase.getCashback() + totalCashback);
 			purchaseRepository.persist(purchase);
+		}
+	}
+	private Scheme toScheme(int creatorId, CreateSchemeRequest createSchemeRequest) {
+		Scheme scheme = new Scheme();
+		scheme.setName(createSchemeRequest.getName());
+		scheme.setDescription(createSchemeRequest.getDescription());
+		scheme.setType(createSchemeRequest.getType());
+		scheme.setAmountType(createSchemeRequest.getAmountType());
+		scheme.setAmount(createSchemeRequest.getAmount());
+		scheme.setPartnerType(createSchemeRequest.getPartnerType());
+		scheme.setStartDateTime(createSchemeRequest.getStartDate());
+		scheme.setEndDateTime(createSchemeRequest.getEndDate());
+		scheme.setCreatedBy(creatorId);
+		scheme.setCashback(createSchemeRequest.isCashback());
+		scheme.setBasePlusGstCalc(createSchemeRequest.isBasePluseGstCalc());
+		return scheme;
+	}
 	//Only in and activation margins are allowed to be rolled out more than twice
-	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
+	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) throws ProfitMandiBusinessException {
 		LOGGER.info("Scheme === {}", scheme);
 		if ((scheme.getId() == 411 || scheme.getId() == 612) && inventoryItem.getCreateTimestamp().isAfter(LocalDate.of(2021, 12, 1).atStartOfDay())) {
 			return 0;
+		}
 		List<SchemeInOut> sios = schemeInOutRepository.selectAllByType(scheme.getType(), inventoryItem.getId());
+		}
 		return actualCredit;
+	}
 	// We are maintaining price drop after grn
-	private float getAmount(InventoryItem inventoryItem, Scheme scheme) {
+	private float getAmount(InventoryItem inventoryItem, Scheme scheme) throws ProfitMandiBusinessException {
 		float amount = 0;
 		float dpForCalc = 0;
 		float taxableSellingPrice = 0;
-		// float totalTaxRate = inventoryItem.getIgstRate() +
-		// inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
-		// Hardcoding it to 18%
-		float totalTaxRate = 18f;
-		// float totalTaxRate = inventoryItem.getIgstRate() +
+		float totalTaxRate = stateGstRateRepository.getTotalTaxRate(inventoryItem.getItemId());
-		// inventoryItem.getSgstRate() + inventoryItem.getCgstRate();
 		if (scheme.getAmountType() == AmountType.PERCENTAGE) {
 			if (scheme.getType().equals(SchemeType.IN)) {
 				dpForCalc = inventoryItem.getUnitPrice() - inventoryItem.getPriceDropAmount();
 			} else {
 				try {
 					inventoryItem.getSerialNumber(), inventoryItem.getItemId(), scheme.getId(), scheme.getName(),
 					scheme.getType(), scheme.getAmountType(), scheme.getPartnerType(), dpForCalc, taxableSellingPrice,
 					scheme.getAmount(), amount));
 		} else {
 			amount = scheme.getAmount();
+			if (scheme.isBasePlusGstCalc()) {
+				amount = this.getReversalAmount(scheme, inventoryItem);
+			}
 			System.out.println(String.format("%d\t%s\t%d\t%d\t%s\t%s\t%s\t%s\t%f\t%f\t%d\t%f", inventoryItem.getId(),
 					inventoryItem.getSerialNumber(), inventoryItem.getItemId(), scheme.getId(), scheme.getName(),
 					scheme.getType(), scheme.getAmountType(), scheme.getPartnerType(), dpForCalc, taxableSellingPrice,
 , amount));
+		}
 		return amount;
+	}
+	//Specifically for SchemeReversal
+	private float getReversalAmount(Scheme scheme, InventoryItem inventoryItem) {
+		float amount = scheme.getAmount();
+		if (scheme.isBasePlusGstCalc()) {
+			amount = (float) (amount / 1.18);
+		}
+		List<SchemeInOut> sios = schemeInOutRepository.selectAll(inventoryItem.getId());
+		sios = sios.stream().filter(x -> x.getRolledBackTimestamp() == null).collect(Collectors.toList());
+		List<Integer> schemeIds = sios.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
+		List<Scheme> schemes = schemeRepository.selectBySchemeIds(schemeIds);
+		float totalPaidPercentage = schemes.stream().filter(x -> x.getAmountType().equals(AmountType.PERCENTAGE)).map(x -> x.getAmount()).collect(Collectors.summingDouble(x -> x)).floatValue();
+		return totalPaidPercentage;
+	}
 	@Override
-	public void processSchemeOut(int fofoOrderId, int retailerId) throws ProfitMandiBusinessException {
+	public float processSchemeOut(int fofoOrderId, int retailerId) throws ProfitMandiBusinessException {
+		float totalCashback = 0;
 		FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(retailerId, fofoOrderId);
 		// Process only if order is not cancelled
 		if (fofoOrder.getCancelledTimestamp() == null) {
 			// PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(retailerId,
 			// fofoOrder.getCreateTimestamp().toLocalDate());
 					.collect(Collectors.toSet());
 			Set<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIds).stream()
 					.filter(x -> x.getSerialNumber() != null && !x.getSerialNumber().equals(""))
 					.collect(Collectors.toSet());
 			if (inventoryItems.size() == 0) {
-				return;
+				return 0;
+			}
 			Set<Integer> itemIds = inventoryItems.stream().map(x -> x.getItemId()).collect(Collectors.toSet());
 			// Remove Items that are eol now.
 			Set<Integer> itemIdsSet = tagListingRepository.selectByItemIdsAndTagIds(itemIds, tagIds).stream()
 			// Only consider inventory items that were not returned
 			inventoryItems = inventoryItems.stream().filter(x -> itemIdsSet.contains(x.getItemId()))
 					.collect(Collectors.toSet());
 			if (inventoryItems.size() == 0) {
-				return;
+				return 0;
+			}
-			float totalCashback = 0;
 			int count = 0;
 			List<SchemeType> allOutSchemeTypes = new ArrayList<>();
 			allOutSchemeTypes.addAll(Arrays.asList(SchemeType.ACTIVATION, SchemeType.INVESTMENT));
 			allOutSchemeTypes.addAll(OUT_SCHEME_TYPES);
+			allOutSchemeTypes.add(SchemeType.SPECIAL_SUPPORT);
 			List<Scheme> allActiveSchemes = schemeRepository.selectActiveAll(allOutSchemeTypes, partnerType,
 					fofoOrder.getCreateTimestamp(), false);
 			for (InventoryItem inventoryItem : inventoryItems) {
 				float itemCashback = 0;
 				Set<Integer> schemeIds = new HashSet<>(
 						schemeItemRepository.selectSchemeIdByCatalogId(inventoryItem.getItem().getCatalogItemId()));
 				List<Scheme> itemActiveSchemes = allActiveSchemes.stream().filter(x -> schemeIds.contains(x.getId()))
 						.collect(Collectors.toList());
+				List<Scheme> supportSchemes = itemActiveSchemes.stream().filter(x -> x.getType().equals(SchemeType.SPECIAL_SUPPORT)).collect(Collectors.toList());
+				itemActiveSchemes = itemActiveSchemes.stream().filter(x -> !x.getType().equals(SchemeType.SPECIAL_SUPPORT)).collect(Collectors.toList());
 				for (Scheme scheme : itemActiveSchemes) {
 					LOGGER.info("Scheme ==== {}", scheme);
 					itemCashback += this.createSchemeInOut(scheme, inventoryItem);
+				}
+				if (supportSchemes.size() > 0) {
+					this.processSpecialSupport(fofoOrder, supportSchemes, inventoryItem, partnerType, fofoOrder.getCreateTimestamp());
+				}
 				LOGGER.info("itemCashback ==== {}", itemCashback);
 				if (itemCashback > 0) {
 					count++;
 					totalCashback += itemCashback;
+				}
 			if (count > 0) {
 				walletService.addAmountToWallet(
 						retailerId, fofoOrderId, WalletReferenceType.SCHEME_OUT, "Sales margin for invoice number "
 								+ fofoOrder.getInvoiceNumber() + ". Total " + count + " pc(s)",
 						totalCashback, fofoOrder.getCreateTimestamp());
-				fofoOrder.setCashback(totalCashback);
+				fofoOrder.setCashback(totalCashback + fofoOrder.getCashback());
+			}
+		}
+		return totalCashback;
+	}
+	private void processSpecialSupport(FofoOrder fofoOrder, List<Scheme> supportSchemes, InventoryItem inventoryItem, PartnerType partnerType, LocalDateTime saleDate) throws ProfitMandiBusinessException {
+		int catalogId = inventoryItem.getItem().getCatalogItemId();
+		float totalMargin = this.selectPercentageScheme(partnerType, saleDate.toLocalDate(), catalogId, false, 0, 0).stream().collect(Collectors.summingDouble(x -> x.getAmount())).floatValue();
+		LOGGER.info("total percentage margin - {}", totalMargin);
+		float totalTaxRate = 0;
+		for (Scheme scheme : supportSchemes) {
+			if (scheme.isBasePlusGstCalc()) {
+				totalTaxRate = stateGstRateRepository.getTotalTaxRate(inventoryItem.getItemId());
+			}
+			float amountToCredit = scheme.getAmount() * (1 - totalMargin / (100 + totalTaxRate));
+			List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByScheme(scheme.getId(), inventoryItem.getId());
+			SchemeInOut schemeInOut = schemeInOuts.stream().filter(x -> x.getRolledBackTimestamp() == null).findFirst().orElse(null);
+			if (schemeInOut == null) {
+				schemeInOut = new SchemeInOut();
+				schemeInOut.setSchemeId(scheme.getId());
+				schemeInOut.setInventoryItemId(inventoryItem.getId());
+				schemeInOut.setCreateTimestamp(LocalDateTime.now());
+				schemeInOut.setAmount(amountToCredit);
+				schemeInOut.setStatus(SchemePayoutStatus.PENDING);
+				schemeInOut.setStatusDescription("Special support, Activation pending for IMEI#" + inventoryItem.getSerialNumber());
+				schemeInOutRepository.persist(schemeInOut);
+			} else if (Double.valueOf(schemeInOut.getAmount()).intValue() != Double.valueOf(amountToCredit).intValue()) {
+				schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+				schemeInOut.setStatusDescription("Special support changed due to update in total margin");
+				schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
+				SchemeInOut schemeInOutNew = new SchemeInOut();
+				schemeInOutNew.setInventoryItemId(inventoryItem.getId());
+				schemeInOutNew.setSchemeId(scheme.getId());
+				schemeInOutNew.setCreateTimestamp(LocalDateTime.now());
+				schemeInOutNew.setAmount(amountToCredit);
+				if (schemeInOut.getStatus().equals(SchemePayoutStatus.CREDITED)) {
+					schemeInOutNew.setStatus(SchemePayoutStatus.PENDING);
+					schemeInOutNew.setStatusDescription("Special support, Activation pending for IMEI#" + inventoryItem.getSerialNumber());
+					schemeInOutRepository.persist(schemeInOutNew);
+				} else {
+					schemeInOutNew.setStatus(SchemePayoutStatus.CREDITED);
+					schemeInOutNew.setStatusDescription("Special support credited");
+					schemeInOutRepository.persist(schemeInOutNew);
+					walletService.addAmountToWallet(inventoryItem.getFofoId(), fofoOrder.getId(), WalletReferenceType.SPECIAL_SUPPORT,
+							"Special support adjusted against overall margin gains for Imei - " + inventoryItem.getSerialNumber(), amountToCredit - schemeInOut.getAmount(),
+							fofoOrder.getCreateTimestamp());
+				}
+			}
+		}
+	}
 	@Override
 	public void rollbackSchemes(List<Integer> inventoryItemIds, int rollbackReference, String rollbackReason)
 			throws Exception {
+		}
 		int fofoId = inventoryItems.get(0).getFofoId();
 		WalletReferenceType walletReferenceType = schemeTypes.containsAll(SchemeService.OUT_SCHEME_TYPES)
 				? WalletReferenceType.SCHEME_OUT
 				: (schemeTypes.contains(SchemeType.ACTIVATION) ? WalletReferenceType.ACTIVATION_SCHEME
-				: WalletReferenceType.INVESTMENT_PAYOUT);
+				: (schemeTypes.contains(SchemeType.SPECIAL_SUPPORT)) ? WalletReferenceType.SPECIAL_SUPPORT : WalletReferenceType.INVESTMENT_PAYOUT);
 		if (amountToRollback > 0) {
 			// Mark appropriate reference of rollback investment margin
 			if (schemeTypes.contains(SchemeType.INVESTMENT)) {
 				reversalReference = Integer
 						.parseInt(FormattingUtils.getYearMonth(schemeTypeMap.get(SchemeType.INVESTMENT).getCreditTimestamp().minusMonths(1)));
 		itemCashbackMap.remove(30213);
 		itemCashbackMap.remove(30756);
 		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 ->
-	 * x.getId()).collect(Collectors.toList()));
-	 *
-	 * }
-	 */
 	@Override
 	public List<Scheme> selectSchemeByPartnerType(PartnerType partnerType, LocalDate onDate, int catalogId,
 												  boolean isAdmin, int offset, int limit) throws ProfitMandiBusinessException {
 		Session session = sessionFactory.getCurrentSession();
 		if (!isAdmin) {
 			andPredicates.add(cb.isNotNull(scheme.get("activeTimestamp")));
+		}
 		query.where(cb.and(andPredicates.toArray(new Predicate[0])));
 		query.orderBy(cb.desc(cb.function("isnull", Boolean.class, scheme.get("expireTimestamp"))));
+		if (limit == 0) {
+			return session.createQuery(query).setFirstResult(offset).getResultList();
+		}
 		return session.createQuery(query).setFirstResult(offset).setMaxResults(limit).getResultList();
+	}
 	@Override
+	public List<Scheme> selectPercentageScheme(PartnerType partnerType, LocalDate onDate, int catalogId,
+											   boolean isAdmin, int offset, int limit) throws ProfitMandiBusinessException {
+		List<Scheme> schemes = this.selectSchemeByPartnerType(partnerType, onDate, catalogId, isAdmin, offset, limit);
+		return schemes.stream().filter(x -> x.getAmountType().equals(AmountType.PERCENTAGE)).collect(Collectors.toList());
+	}
+	@Override
 	public void processActivation() throws ProfitMandiBusinessException {
 		List<SchemeInOut> pendingPayouts = schemeInOutRepository.selectAllPending();
 		List<Integer> schemeIds = new ArrayList<>();
 		Set<Integer> inventoryIds = new HashSet<>();
 		for (SchemeInOut pendingPayout : pendingPayouts) {
 			schemeIds.add(pendingPayout.getSchemeId());
+		}
 		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, 0).stream()
-				.filter(x -> x.getType().equals(SchemeType.ACTIVATION))
+				.filter(x -> x.getType().equals(SchemeType.ACTIVATION) || x.getType().equals(SchemeType.SPECIAL_SUPPORT))
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		pendingPayouts = pendingPayouts.stream().filter(x -> schemesMap.get(x.getSchemeId()) != null)
 				.collect(Collectors.toList());
 		for (SchemeInOut pendingPayout : pendingPayouts) {
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		Map<String, InventoryItem> serialNumberMap = inventoryItemMap.values().stream()
 				.collect(Collectors.toMap(x -> x.getSerialNumber(), x -> x));
 		List<ActivatedImei> activatedImeis = activatedImeiRepository
-				.selectBySerialNumbers(new ArrayList<>(serialNumberMap.keySet()));
+				.selectBySerialNumbers(new ArrayList<>(serialNumberMap.keySet())).stream().collect(Collectors.toList());
 		Map<String, ActivatedImei> activatedImeiMap = activatedImeis.stream()
 				.collect(Collectors.toMap(x -> x.getSerialNumber(), x -> x));
 		for (SchemeInOut pendingPayout : pendingPayouts) {
 			InventoryItem ii = inventoryItemMap.get(pendingPayout.getInventoryItemId());
 				int orderId = scanRecordRepository.selectByInventoryItemId(ii.getId()).stream()
 						.filter(x -> x.getOrderId() > 0)
 						.sorted(Comparator.comparing(ScanRecord::getCreateTimestamp).reversed()).findFirst().get()
 						.getOrderId();
 				FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(orderId);
+				if (scheme.getType().equals(SchemeType.ACTIVATION)) {
-				walletService.addAmountToWallet(fofoId, orderId, WalletReferenceType.ACTIVATION_SCHEME,
+					walletService.addAmountToWallet(fofoId, orderId, WalletReferenceType.ACTIVATION_SCHEME,
-						"Activation margin for Imei#" + serialNumber, pendingPayout.getAmount(),
+							"Activation margin for " + ii.getItem().getItemDescriptionNoColor() + ", Imei - " + serialNumber, pendingPayout.getAmount(),
+							fofoOrder.getCreateTimestamp());
+					pendingPayout.setStatusDescription("Activation margin credited");
+				} else {
+					walletService.addAmountToWallet(fofoId, orderId, WalletReferenceType.SPECIAL_SUPPORT,
+							"Special Support for " + ii.getItem().getItemDescriptionNoColor() + ", Imei - " + serialNumber, pendingPayout.getAmount(),
-						fofoOrder.getCreateTimestamp());
+							fofoOrder.getCreateTimestamp());
+					pendingPayout.setStatusDescription("Special support credited");
+				}
 				pendingPayout.setCreditTimestamp(LocalDateTime.now());
 				pendingPayout.setStatus(SchemePayoutStatus.CREDITED);
-				pendingPayout.setStatusDescription("Activation margin credited");
 			} else {
 				pendingPayout.setStatus(SchemePayoutStatus.REJECTED);
 				pendingPayout.setRolledBackTimestamp(LocalDateTime.now());
+				;
 				pendingPayout.setStatusDescription(

Subversion Repositories SmartDukaan

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