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

 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.stereotype.Component;
 import com.spice.profitmandi.common.enumuration.ItemType;
 	@Autowired
 	private ScanRecordRepository scanRecordRepository;
 	@Autowired
+	private SessionFactory sessionFactory;
+	@Autowired
 	private SchemeRepository schemeRepository;
 	@Autowired
 	private RoleManager roleManager;
 			throw new ProfitMandiBusinessException(
 					ProfitMandiConstants.START_DATE + ", " + ProfitMandiConstants.END_DATE,
 					scheme.getStartDateTime() + ", " + scheme.getEndDateTime(), "SCHM_VE_1005");
+		}
-		//this.validateItemIds(createSchemeRequest);
+		// this.validateItemIds(createSchemeRequest);
 		schemeRepository.persist(scheme);
 		for (int itemId : createSchemeRequest.getItemIds()) {
 			SchemeItem schemeItem = new SchemeItem();
 			schemeItem.setSchemeId(scheme.getId());
 			schemeItem.setItemId(itemId);
 			float totalCashback = 0;
 			if (schemes.isEmpty()) {
 				return;
+			}
 			List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchaseId);
-			//Only consider inventory items that were not returned
+			// Only consider inventory items that were not returned
 			inventoryItems = inventoryItems.stream().filter(x -> !x.getLastScanType().equals(ScanType.PURCHASE_RET_BAD)
 					&& !x.getLastScanType().equals(ScanType.PURCHASE_RET)).collect(Collectors.toList());
 			LOGGER.info(inventoryItems);
 			if (inventoryItems.size() == 0)
 				return;
+			}
 			taxableSellingPrice = dpForCalc / (1 + totalTaxRate / 100);
 			amount = taxableSellingPrice * scheme.getAmount() / 100;
 			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%f\t%f", inventoryItem.getId(),
 					inventoryItem.getSerialNumber(), inventoryItem.getItemId(), scheme.getId(), scheme.getName(),
-					scheme.getType(), scheme.getAmountType(), scheme.getPartnerType(), dpForCalc, taxableSellingPrice, scheme.getAmount(),
+					scheme.getType(), scheme.getAmountType(), scheme.getPartnerType(), dpForCalc, taxableSellingPrice,
-					amount));
+					scheme.getAmount(), amount));
 		} else {
 			amount = scheme.getAmount();
 			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, 0, amount));
+					scheme.getType(), scheme.getAmountType(), scheme.getPartnerType(), dpForCalc, taxableSellingPrice,
+, amount));
+		}
 		return amount;
+	}
 			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) {
+			if (purchase.getCompleteTimestamp() == null) {
 				continue;
+			}
 			if (purchase.getCompleteTimestamp().isAfter(LocalDate.of(2019, 9, 1).atStartOfDay())) {
 				schemes = schemeRepository.selectActiveAll(SchemeType.OUT, partnerType, fofoOrder.getCreateTimestamp());
 			} else {
 		return schemes;
+	}
 	@Override
 	public void reverseSchemes(List<InventoryItem> inventoryItems, int priceDropId, String reversalReason)
-			throws Exception {
+			throws ProfitMandiBusinessException {
 		Map<Integer, List<InventoryItem>> purchaseInventoryListMap = inventoryItems.stream()
 				.collect(Collectors.groupingBy(InventoryItem::getPurchaseId, Collectors.toList()));
 		for (Map.Entry<Integer, List<InventoryItem>> purchaseEntry : purchaseInventoryListMap.entrySet()) {
 			float amountToCredit = 0;
 			walletService.rollbackAmountFromWallet(fofoId, amount, reversalReference, walletReferenceType,
 					reversalReason);
+		}
+	}
+	@Override
+	public double getTotalMargin(int itemId, PartnerType partnerType, LocalDateTime dateTime) {
+		Session session = sessionFactory.getCurrentSession();
+		CriteriaBuilder cb = session.getCriteriaBuilder();
+		CriteriaQuery<Double> criteriaQuery = cb.createQuery(Double.class);
+		Root<SchemeItem> schemeItem = criteriaQuery.from(SchemeItem.class);
+		Root<Scheme> scheme = criteriaQuery.from(Scheme.class);
+		Predicate schemePredicate = cb.equal(scheme.get(ProfitMandiConstants.AMOUNT_TYPE), AmountType.PERCENTAGE);
+		Predicate lessThanPredicate = cb.lessThanOrEqualTo(scheme.get(ProfitMandiConstants.END_DATE_TIME), dateTime);
+		Predicate greaterThanPredicate = cb.greaterThanOrEqualTo(scheme.get(ProfitMandiConstants.START_DATE_TIME),
+				dateTime);
+		Predicate joinPredicate = cb.equal(scheme.get("id"), schemeItem.get("schemeId"));
+		Predicate schemeItemPredicate = cb.equal(schemeItem.get(ProfitMandiConstants.ITEM_ID), itemId);
+		criteriaQuery.select(cb.sum(scheme.get(ProfitMandiConstants.AMOUNT))).where(schemePredicate, lessThanPredicate,
+				greaterThanPredicate, schemeItemPredicate, joinPredicate);
+		Query<Double> query = session.createQuery(criteriaQuery);
+		return query.getSingleResult() + ProfitMandiConstants.SCHEME_INVESTMENT_MARGIN;
+	}
 	/*
 	 * @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 26296 → 26332