Subversion Repositories SmartDukaan

Rev

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

Rev 31920 Rev 31923
Line 27... Line 27...
27 
import com.spice.profitmandi.dao.model.CreateOfferRequest;
 27 
import com.spice.profitmandi.dao.model.CreateOfferRequest;
28 
import com.spice.profitmandi.dao.model.ItemCriteriaPayout;
 28 
import com.spice.profitmandi.dao.model.ItemCriteriaPayout;
29 
import com.spice.profitmandi.dao.model.OfferRowModel;
 29 
import com.spice.profitmandi.dao.model.OfferRowModel;
30 
import com.spice.profitmandi.dao.repository.catalog.*;
 30 
import com.spice.profitmandi.dao.repository.catalog.*;
31 
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
 31 
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
32 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 - 
 
33 
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 32 
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
34 
import com.spice.profitmandi.dao.repository.fofo.OfferPayoutRepository;
 33 
import com.spice.profitmandi.dao.repository.fofo.OfferPayoutRepository;
35 
import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 34 
import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
36 
import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 35 
import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
37 
import com.spice.profitmandi.dao.repository.warehouse.WarehouseScanRepository;
 36 
import com.spice.profitmandi.dao.repository.warehouse.WarehouseScanRepository;
Line 623... Line 622...
623 
    public void processActivationtOffer(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
 622 
    public void processActivationtOffer(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
624 
        //List<OfferRowModel> offerRowModels = new ArrayList<>();
 623 
        //List<OfferRowModel> offerRowModels = new ArrayList<>();
625 
        List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByOfferId(createOfferRequest.getId());
 624 
        List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByOfferId(createOfferRequest.getId());
626 
        List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
 625 
        List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
627 
        Map<Integer, ItemCriteriaPayout> itemCriteriaPayoutMap = itemCriteriaPayouts.stream().collect(Collectors.toMap(x -> x.getItemCriteria().getId(), x -> x));
 626 
        Map<Integer, ItemCriteriaPayout> itemCriteriaPayoutMap = itemCriteriaPayouts.stream().collect(Collectors.toMap(x -> x.getItemCriteria().getId(), x -> x));
628 
 
 - 
 
- 
 
 627 
        LOGGER.info("itemCriteriaPayoutMap {}", itemCriteriaPayoutMap);
- 
 
 628 
        LOGGER.info("offerPayouts {}", offerPayouts);
629 
        Map<Integer, Map<Integer, Double>> fixedSlabCriteriaPartnerMap = offerPayouts.stream().filter(x -> itemCriteriaPayoutMap.get(x.getCriteriaId()).getAmountType().equals(AmountType.SLAB_FIXED))
 629 
        Map<Integer, Map<Integer, Double>> fixedSlabCriteriaPartnerMap = offerPayouts.stream().filter(x -> itemCriteriaPayoutMap.get(x.getCriteriaId()).getAmountType().equals(AmountType.SLAB_FIXED))
630 
                .collect(Collectors.groupingBy(x -> (int) x.getCriteriaId(), Collectors.groupingBy(x -> (int) x.getFofoId(), Collectors.summingDouble(x -> x.getSlabAmount()))));
 630 
                .collect(Collectors.groupingBy(x -> (int) x.getCriteriaId(), Collectors.groupingBy(x -> (int) x.getFofoId(), Collectors.summingDouble(x -> x.getSlabAmount()))));
631 
 
 631 
 
632 
 
 632 
 
633 
        Map<String, Double> serialNumberPaid = offerPayouts.stream().filter(x -> x.getRejectTimestamp() == null).collect(Collectors.groupingBy(x -> x.getSerialNumber(), Collectors.summingDouble(x -> x.getSlabAmount())));
 633 
        Map<String, Double> serialNumberPaid = offerPayouts.stream().filter(x -> x.getRejectTimestamp() == null).collect(Collectors.groupingBy(x -> x.getSerialNumber(), Collectors.summingDouble(x -> x.getSlabAmount())));