Subversion Repositories SmartDukaan

Rev

Rev 29231 | Rev 29240 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 29231 Rev 29239
Line 478... Line 478...
478 
			purchaseRepository.persist(purchase);
 478 
			purchaseRepository.persist(purchase);
479 
		}
 479 
		}
480 
	}
 480 
	}
481 
 
 481 
 
482 
	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
 482 
	private float createSchemeInOut(Scheme scheme, InventoryItem inventoryItem) {
- 
 
 483 
		LOGGER.info("Scheme === {}", scheme);
483 
		List<SchemeInOut> sios = schemeInOutRepository.selectAllByType(scheme.getType(), inventoryItem.getId());
 484 
		List<SchemeInOut> sios = schemeInOutRepository.selectAllByType(scheme.getType(), inventoryItem.getId());
484 
		float actualCredit = 0;
 485 
		float actualCredit = 0;
485 
		if (sios.stream().filter(x -> x.getRolledBackTimestamp() == null && x.getSchemeId() == scheme.getId())
 486 
		if (sios.stream().filter(x -> x.getRolledBackTimestamp() == null && x.getSchemeId() == scheme.getId())
486 
				.collect(Collectors.toList()).size() == 0) {
 487 
				.collect(Collectors.toList()).size() == 0) {
487
488
Line 624... Line 625...
624 
				Set<Integer> schemeIds = new HashSet<>(
 625 
				Set<Integer> schemeIds = new HashSet<>(
625 
						schemeItemRepository.selectSchemeIdByItemId(inventoryItem.getItemId()));
 626 
						schemeItemRepository.selectSchemeIdByItemId(inventoryItem.getItemId()));
626 
				List<Scheme> itemActiveSchemes = allActiveSchemes.stream().filter(x -> schemeIds.contains(x.getId()))
 627 
				List<Scheme> itemActiveSchemes = allActiveSchemes.stream().filter(x -> schemeIds.contains(x.getId()))
627 
						.collect(Collectors.toList());
 628 
						.collect(Collectors.toList());
628 
				for (Scheme scheme : itemActiveSchemes) {
 629 
				for (Scheme scheme : itemActiveSchemes) {
- 
 
 630 
					LOGGER.info("Scheme ==== {}", scheme);
629 
					itemCashback += this.createSchemeInOut(scheme, inventoryItem);
 631 
					itemCashback += this.createSchemeInOut(scheme, inventoryItem);
630 
				}
 632 
				}
- 
 
 633 
				LOGGER.info("itemCashback", itemCashback);
631 
				if (itemCashback > 0) {
 634 
				if (itemCashback > 0) {
632 
					count++;
 635 
					count++;
633 
					totalCashback += itemCashback;
 636 
					totalCashback += itemCashback;
634 
				}
 637 
				}
635 
			}
 638 
			}