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

 package com.spice.profitmandi.service.scheme;
 import java.text.MessageFormat;
-import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Collection;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.AbstractMap.SimpleEntry;
 import java.util.stream.Collectors;
 import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Predicate;
 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.CatalogIdAggregateValue;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SchemeModel;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
-import com.spice.profitmandi.dao.entity.catalog.Offer;
-import com.spice.profitmandi.dao.entity.catalog.OfferPartner;
 import com.spice.profitmandi.dao.entity.catalog.RetailerScheme;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
-import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 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.GenericRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
+		}
+	}
 	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
 		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByScheme(scheme.getId(), inventoryItem.getId());
-		float amount = 0;
+		float amountToCredit = 0;
 		if (schemeInOuts.stream().filter(x -> x.getRolledBackTimestamp() == null).collect(Collectors.toList())
 				.size() == 0) {
 			SchemeInOut schemeInOut = new SchemeInOut();
-			amount = this.getAmount(inventoryItem, scheme);
+			amountToCredit = this.getAmount(inventoryItem, scheme);
 			schemeInOut.setSchemeId(scheme.getId());
 			schemeInOut.setInventoryItemId(inventoryItem.getId());
-			schemeInOut.setAmount(amount);
+			schemeInOut.setAmount(amountToCredit);
+			if(scheme.getType().equals(SchemeType.ACTIVATION)) {
+				schemeInOut.setStatus(SchemePayoutStatus.PENDING);
+				schemeInOut.setStatusDescription("Activation pending for IMEI#" + inventoryItem.getSerialNumber());
+				return 0;
+			} else {
+				schemeInOut.setStatus(SchemePayoutStatus.CREDITED);
+				schemeInOut.setStatusDescription("Credited for sale of IMEI#" + inventoryItem.getSerialNumber());
+				schemeInOut.setCreditTimestamp(LocalDateTime.now());
+			}
 			schemeInOutRepository.persist(schemeInOut);
+		}
-		return amount;
+		return amountToCredit;
+	}
 	// We are maintaining price drop after grn
 	private float getAmount(InventoryItem inventoryItem, Scheme scheme) {
 		float amount = 0;
+		}
 		float totalCashback = 0;
 		int count = 0;
-		Set<Scheme> allFixedSchemes = schemeRepository
+		List<Scheme> allActiveSchemes = schemeRepository
-				.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp(), false).stream()
+				.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp(), false);
-				.filter(scheme -> scheme.getAmountType().equals(AmountType.FIXED)).collect(Collectors.toSet());
+		allActiveSchemes.addAll(schemeRepository.selectActiveAll(SchemeType.ACTIVATION, partnerType, fofoOrder.getCreateTimestamp(), false));
 		for (InventoryItem inventoryItem : inventoryItems) {
 			float itemCashback = 0;
 			Purchase purchase = purchaseRepository.selectByIdAndFofoId(inventoryItem.getPurchaseId(), retailerId);
 			Set<Integer> schemeIds = new HashSet<>(
 					schemeItemRepository.selectSchemeIdByItemId(inventoryItem.getItemId()));
-			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(),
-						false);
-			} else {
-				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType, 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());
+			allActiveSchemes = allActiveSchemes.stream().filter(x -> schemeIds.contains(x.getId())).collect(Collectors.toList());
-			for (Scheme scheme : schemesSet) {
+			for (Scheme scheme : allActiveSchemes) {
 				itemCashback += this.createSchemeInOut(scheme, inventoryItem);
+			}
 			if (itemCashback > 0) {
 				count++;
 				totalCashback += itemCashback;
 		float amountToRollback = 0;
 		List<SchemeInOut> schemes = schemeInOutRepository.selectByInventoryItemIds(inventoryItemIdSet);
 		for (SchemeInOut schemeInOut : schemes) {
 			if (schemeInOut.getRolledBackTimestamp() == null) {
 				schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
-				schemeInOutRepository.persist(schemeInOut);
+				if(schemeInOut.getStatus().equals(SchemePayoutStatus.CREDITED)) {
-				amountToRollback += schemeInOut.getAmount();
+					amountToRollback += schemeInOut.getAmount();
+				}
+				schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+				schemeInOut.setStatusDescription(rollbackReason);
+			}
+		}
 		if (amountToRollback > 0) {
 			int inventoryItemId = inventoryItemIds.get(0);
 			InventoryItem ii = inventoryItemRepository.selectById(inventoryItemId);
-			Purchase p = purchaseRepository.selectById(ii.getPurchaseId());
 			Integer fofoId = ii.getFofoId();
+			//Purchase p = purchaseRepository.selectById(ii.getPurchaseId());
 			// TODO//
 			walletService.rollbackAmountFromWallet(fofoId, amountToRollback, ii.getPurchaseId(),
 					WalletReferenceType.SCHEME_IN, rollbackReason, LocalDateTime.now());
+		}
+	}
 			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;
+		float amountToRollback = 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 (schemeInOut.getRolledBackTimestamp() == null) {
 					schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
-					schemeInOutRepository.persist(schemeInOut);
+					if(schemeInOut.getStatus().equals(SchemePayoutStatus.CREDITED)) {
-					amount += schemeInOut.getAmount();
+						amountToRollback += schemeInOut.getAmount();
+					}
+					schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+					schemeInOut.setStatusDescription(reversalReason);
+				}
+			}
+		}
 		int fofoId = inventoryItems.get(0).getFofoId();
 		WalletReferenceType walletReferenceType = schemeType.equals(SchemeType.OUT) ? WalletReferenceType.SCHEME_OUT
-				: WalletReferenceType.SCHEME_IN;
+				: schemeType.equals(SchemeType.IN) ? WalletReferenceType.SCHEME_IN : WalletReferenceType.ACTIVATION_SCHEME;
-		if (amount > 0) {
+		if (amountToRollback > 0) {
 			// TODO//
-			walletService.rollbackAmountFromWallet(fofoId, amount, reversalReference, walletReferenceType,
+			walletService.rollbackAmountFromWallet(fofoId, amountToRollback, reversalReference, walletReferenceType,
 					reversalReason, LocalDateTime.now());
+		}
+	}
 	@Override

Subversion Repositories SmartDukaan

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