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.time.YearMonth;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Predicate;
-import javax.persistence.criteria.Root;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-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.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SchemeModel;
+import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
-import com.spice.profitmandi.dao.entity.catalog.RetailerScheme;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
-import com.spice.profitmandi.dao.entity.fofo.ActivatedImei;
-import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
-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.*;
-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.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.ActivatedImeiRepository;
-import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
-import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
-import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
-import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
-import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
-import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
+import com.spice.profitmandi.dao.repository.fofo.*;
-import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
-import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
-import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
+import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.PurchaseService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.WalletReferenceType;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+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 javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+import java.text.MessageFormat;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.YearMonth;
+import java.util.*;
+import java.util.stream.Collectors;
 @Component
 public class SchemeServiceImpl implements SchemeService {
 	private static final Logger LOGGER = LogManager.getLogger(SchemeServiceImpl.class);
 	@Autowired
 	private RoleManager roleManager;
 	@Autowired
 	private RetailerRepository retailerRepository;
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private SchemeInOutRepository schemeInOutRepository;
 		scheme.setEndDateTime(createSchemeRequest.getEndDate());
 		scheme.setCreatedBy(creatorId);
 		scheme.setCashback(createSchemeRequest.isCashback());
 		return scheme;
+	}
 	private void validateItemIds(CreateSchemeRequest createSchemeRequest) throws ProfitMandiBusinessException {
 		if (createSchemeRequest.getItemIds() == null || createSchemeRequest.getItemIds().isEmpty()) {
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.ITEM_ID, createSchemeRequest.getItemIds(),
 					"SCHM_1003");
 		Map<Integer, String> itemStringMap = this.toItemStringMap(items);
 		this.addItemIdsToSchemes(schemeItems, schemeIdSchemeMap, itemStringMap);
 		return this.toSchemeModels(schemeIdSchemeMap);
+	}
-	private void addItemIdsToSchemes(List<SchemeItem> schemeItems, Map<Integer, Scheme> schemeIdSchemeMap,
-			Map<Integer, String> itemStringMap) {
+	@Autowired
-		for (SchemeItem schemeItem : schemeItems) {
-			schemeIdSchemeMap.get(schemeItem.getSchemeId()).getItemStringMap().put(schemeItem.getItemId(),
-					itemStringMap.get(schemeItem.getItemId()));
+	NotificationService notificationService;
-		}
-	}
 	private List<SchemeModel> toSchemeModels(Map<Integer, Scheme> schemeIdSchemeMap) {
 		List<SchemeModel> schemeModels = new ArrayList<>();
 		for (Map.Entry<Integer, Scheme> schemeIdSchemeEntry : schemeIdSchemeMap.entrySet()) {
 			schemeModels.add(this.toSchemeModel(schemeIdSchemeEntry.getValue()));
 		schemeModel.setItemStringMap(scheme.getItemStringMap());
 		schemeModel.setRetailerIds(scheme.getRetailerIds());
 		return schemeModel;
+	}
+	private void addItemIdsToSchemes(List<SchemeItem> schemeItems, Map<Integer, Scheme> schemeIdSchemeMap,
+									 Map<Integer, String> itemStringMap) {
+		for (SchemeItem schemeItem : schemeItems) {
+			schemeIdSchemeMap.get(schemeItem.getSchemeId()).getItemStringMap().put(schemeItem.getItemId(),
+					itemStringMap.get(schemeItem.getItemId()));
+		}
+	}
 	@Override
 	public void activeSchemeById(int schemeId) throws ProfitMandiBusinessException {
 		Scheme scheme = schemeRepository.selectById(schemeId);
 		if (scheme.getActiveTimestamp() != null) {
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.ACTIVE_TIMESTAMP, scheme.getActiveTimestamp(),
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.EXPIRE_TIMESTAMP, scheme.getExpireTimestamp(),
 					"SCHM_1006");
+		}
 		scheme.setActiveTimestamp(LocalDateTime.now());
 		schemeRepository.persist(scheme);
+		this.sendSchemeNotification(scheme);
 		/*
 		 * if (scheme.getType() == SchemeType.IN) {
 		 * this.processPreviousPurchases(scheme); } else if (scheme.getType() ==
 		 * SchemeType.OUT) { this.processPreviousSales(scheme); }
 		 */
+	}
+	private void sendSchemeNotification(Scheme scheme) throws ProfitMandiBusinessException {
+		if (scheme.getType().equals(SchemeType.ACTIVATION)) {
+			SendNotificationModel sendNotificationModel = new SendNotificationModel();
+			List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(new HashSet<>(scheme.getId()));
+			Set<Integer> itemIds = schemeItems.stream().map(x -> x.getItemId()).collect(Collectors.toSet());
+			List<String> itemDescriptions = itemRepository.selectByIds(itemIds).stream().map(x -> x.getItemDescriptionNoColor()).distinct().collect(Collectors.toList());
+			String title = "Activation scheme of Rs." + FormattingUtils.formatDecimal(scheme.getAmount()) + " for " + String.join(", ", itemDescriptions);
+			String message = "Duration from - " + FormattingUtils.formatDateMonth(scheme.getStartDateTime()) + " - " + FormattingUtils.formatDateMonth(scheme.getEndDateTime());
+			sendNotificationModel.setCampaignName("activationscheme");
+			sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/scheme/" + scheme.getId());
+			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
+			sendNotificationModel.setMessage(message);
+			sendNotificationModel.setTitle(title);
+			sendNotificationModel.setMessageType(MessageType.scheme);
+			notificationService.sendNotificationToAll(sendNotificationModel);
+		}
+	}
 	@Override
 	public void expireSchemeById(int schemeId, LocalDateTime expiryTime) throws ProfitMandiBusinessException {
 		Scheme scheme = schemeRepository.selectById(schemeId);
 		if (scheme == null || scheme.getActiveTimestamp() == null) {
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.ACTIVE_TIMESTAMP, scheme.getActiveTimestamp(),
+		}
 		return itemIdSchemesMap;
+	}
 	private Map<InventoryItem, Set<Scheme>> toInventoryItemSchemesMap(List<Scheme> schemes,
-			List<InventoryItem> inventoryItems) {
+																	  List<InventoryItem> inventoryItems) {
 		Set<Integer> schemeIds = new HashSet<>();
 		for (Scheme scheme : schemes) {
 			schemeIds.add(scheme.getId());
+		}
 		Set<Integer> itemIds = this.inventoryItemsToItemIds(inventoryItems);
 					purchase.getPurchaseReference(), itemsCount);
 			purchase.setCashback(purchase.getCashback() + totalCashback);
 			purchaseRepository.persist(purchase);
+		}
+	}
 	//Only in and activation margins are allowed to be rolled out more than twice
 	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
 		LOGGER.info("Scheme === {}", scheme);
-		if((scheme.getId() == 411 || scheme.getId()==612) && inventoryItem.getCreateTimestamp().isAfter(LocalDate.of(2021, 12, 1).atStartOfDay())) {
+		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());
 		float actualCredit = 0;
 		if (sios.stream().filter(x -> x.getRolledBackTimestamp() == null && x.getSchemeId() == scheme.getId())
 				.collect(Collectors.toList()).size() == 0) {
-			sios = sios.stream().filter(x->x.getRolledBackTimestamp()==null).collect(Collectors.toList());
+			sios = sios.stream().filter(x -> x.getRolledBackTimestamp() == null).collect(Collectors.toList());
 			//Rejected Scheme for types INVESTMENT and ACTIVATION are considered rolledback only if the item billing is cancelled.
 			float amountCredited = (float) sios.stream().mapToDouble(e -> e.getAmount()).sum();
 			LOGGER.info("SIOS ===== {}", sios);
 			float amountToCredit = this.getAmount(inventoryItem, scheme);
 			//Activation and in scheme
-			if (!scheme.getType().equals(SchemeType.IN)  && !scheme.getType().equals(SchemeType.ACTIVATION) && sios.size() > 0) {
+			if (!scheme.getType().equals(SchemeType.IN) && !scheme.getType().equals(SchemeType.ACTIVATION) && sios.size() > 0) {
-				if(sios.size() > 1) {
+				if (sios.size() > 1) {
 					LOGGER.info("SAMESCHEMETYPE has already been credited twice for inventoryItem - {}", inventoryItem.getId());
 					return 0;
+				}
-				if(amountToCredit > amountCredited + 1f) {
+				if (amountToCredit > amountCredited + 1f) {
 					for (SchemeInOut sio : sios) {
 						sio.setRolledBackTimestamp(LocalDateTime.now());
 						sio.setStatus(SchemePayoutStatus.REJECTED);
 						sio.setStatusDescription("Partner Category upgraded, new entry added");
+					}
+				}
 			} else {
 				actualCredit = amountToCredit;
+			}
 			LOGGER.info("Actual Credit ==== {}", actualCredit);
 			SchemeInOut schemeInOut = new SchemeInOut();
 			schemeInOut.setSchemeId(scheme.getId());
 			schemeInOut.setInventoryItemId(inventoryItem.getId());
 			schemeInOut.setAmount(amountToCredit);
 			schemeInOutRepository.persist(schemeInOut);
+	}
 	@Override
 	// Always being called from cancel order/bad return means no SCHEME IN is considered
 	public void reverseSchemes(List<InventoryItem> inventoryItems, int reversalReference, String reversalReason,
-			List<SchemeType> schemeTypes) throws ProfitMandiBusinessException {
+							   List<SchemeType> schemeTypes) throws ProfitMandiBusinessException {
 		Map<Integer, InventoryItem> inventoryItemsMap = inventoryItems.stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		LOGGER.info("inventoryItems" + inventoryItems);
 		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(inventoryItemsMap.keySet());
+		}
 		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);
+				: WalletReferenceType.INVESTMENT_PAYOUT);
 		if (amountToRollback > 0) {
 			// Mark appropriate reference of rollback investment margin
 			if (schemeTypes.contains(SchemeType.INVESTMENT)) {
 				reversalReference = Integer
 						.parseInt(FormattingUtils.getYearMonth(schemeInOuts.get(0).getCreditTimestamp().minusMonths(1)));
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		if (cashbackSchemesMap.size() > 0) {
 			List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(cashbackSchemesMap.keySet());
 			schemeItems.stream().forEach(x -> {
 				float cashbackAmount = cashbackSchemesMap.get(x.getSchemeId()).getAmount();
-				if(!itemCashbackMap.containsKey(x.getItemId())) {
+				if (!itemCashbackMap.containsKey(x.getItemId())) {
 					itemCashbackMap.put(x.getItemId(), cashbackAmount);
 				} else {
 					itemCashbackMap.put(x.getItemId(), itemCashbackMap.get(x.getItemId()) + cashbackAmount);
+				}
 			});
+		}
 		// A107FD Model needs to removed
 		itemCashbackMap.remove(30211);
 	 * @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 itemId,
-			boolean isAdmin, int offset, int limit) throws ProfitMandiBusinessException {
+												  boolean isAdmin, int offset, int limit) throws ProfitMandiBusinessException {
 		Session session = sessionFactory.getCurrentSession();
 		CriteriaBuilder cb = session.getCriteriaBuilder();
 		CriteriaQuery<Scheme> query = cb.createQuery(Scheme.class);
 		Root<Scheme> scheme = query.from(Scheme.class);
 		List<PartnerType> pt = new ArrayList<>();

Subversion Repositories SmartDukaan

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