Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.model.TargetSlab;

import com.spice.profitmandi.service.offers.ItemCriteria;

	@Autowired

	OfferTargetSlabRepository offerTargetSlabRepository;

	@Autowired

	ItemCriteriaRepository itemCriteriaRepository;

	public void createOfferCriteria() throws Exception {

		Map<Integer, List<Integer>> map = new HashMap<>();

		map.put(31960, Arrays.asList(57, 69));

		map.put(32844, Arrays.asList(57, 69));

		map.put(31964, Arrays.asList(65, 78));

		map.put(33493, Arrays.asList(70, 84));

		map.put(32847, Arrays.asList(65, 78));

		map.put(32623, Arrays.asList(72, 86));

		map.put(31972, Arrays.asList(74, 88));

		map.put(33495, Arrays.asList(78, 93));

		map.put(32699, Arrays.asList(78, 93));

		map.put(31967, Arrays.asList(78, 93));

		map.put(33424, Arrays.asList(86, 103));

		map.put(33441, Arrays.asList(94, 113));

		map.put(33491, Arrays.asList(102, 123));

		map.put(32664, Arrays.asList(94, 112));

		map.put(33430, Arrays.asList(159, 181));

		map.put(33381, Arrays.asList(172, 195));

		map.put(33484, Arrays.asList(184, 209));

		map.put(32698, Arrays.asList(171, 194));

		map.put(32665, Arrays.asList(171, 194));

		map.put(33428, Arrays.asList(146, 166));

		map.put(33499, Arrays.asList(196, 223));

		map.put(33427, Arrays.asList(184, 208));

		map.put(33385, Arrays.asList(203, 230));

		map.put(33373, Arrays.asList(196, 222));

		map.put(33429, Arrays.asList(171, 193));

		map.put(33387, Arrays.asList(215, 244));

		map.put(33432, Arrays.asList(208, 236));

		map.put(32546, Arrays.asList(196, 222));

		map.put(33389, Arrays.asList(227, 257));

		map.put(33498, Arrays.asList(233, 264));

		map.put(33496, Arrays.asList(202, 229));

		map.put(32088, Arrays.asList(233, 264));

		map.put(33377, Arrays.asList(233, 264));

		map.put(33395, Arrays.asList(327, 392));

		map.put(33393, Arrays.asList(344, 413));

		map.put(32277, Arrays.asList(360, 432));

		map.put(33397, Arrays.asList(377, 452));

		map.put(32305, Arrays.asList(393, 472));

		map.put(33492, Arrays.asList(409, 491));

		map.put(33399, Arrays.asList(409, 491));

		map.put(33405, Arrays.asList(442, 531));

		map.put(33403, Arrays.asList(442, 531));

		map.put(32854, Arrays.asList(442, 531));

		map.put(32155, Arrays.asList(458, 550));

		map.put(32151, Arrays.asList(458, 550));

		map.put(33407, Arrays.asList(475, 570));

		map.put(32855, Arrays.asList(475, 570));

		map.put(33409, Arrays.asList(655, 786));

		map.put(33411, Arrays.asList(688, 825));

		map.put(32687, Arrays.asList(688, 825));

		map.put(33413, Arrays.asList(720, 865));

		map.put(33415, Arrays.asList(1032, 1238));

		map.put(33417, Arrays.asList(1097, 1316));

		Offer offer = offerRepository.selectById(1099);

		List<TargetSlab> targetSlabs = offerTargetSlabRepository.getByOfferId(offer.getId());

		ItemCriteria itemCriteria = targetSlabs.get(0).getItemCriteriaPayouts().get(0).getItemCriteria();

		Map<List<Integer>, List<Integer>> payoutModelsMap = map.entrySet().stream().map(x ->

		{

			try {

				int catalogId = itemRepository.selectById(x.getKey()).getCatalogItemId();

				return new AbstractMap.SimpleEntry<>(catalogId, x.getValue());

			} catch (Exception e) {

				return new AbstractMap.SimpleEntry<>(0, new ArrayList());

			}

		}).collect(Collectors.groupingBy(x -> x.getValue(), Collectors.mapping(x -> x.getKey(), Collectors.toList())));

		payoutModelsMap.entrySet().stream().forEach(x ->

		{

			itemCriteria.setCatalogIds(x.getValue());

			com.spice.profitmandi.dao.entity.catalog.ItemCriteria itemCriteria1 = new com.spice.profitmandi.dao.entity.catalog.ItemCriteria();

			itemCriteria1.setCriteria(gson.toJson(itemCriteria));

			itemCriteriaRepository.persist(itemCriteria1);

			com.spice.profitmandi.dao.entity.catalog.TargetSlab ts = new com.spice.profitmandi.dao.entity.catalog.TargetSlab();

			ts.setOfferId(offer.getId());

			ts.setAmountType(targetSlabs.get(0).getItemCriteriaPayouts().get(0).getAmountType());

			ts.setPayoutTarget(25);

			ts.setItemCriteriaId(itemCriteria1.getId());

			ts.setPayoutValue(x.getKey().get(0));

			offerTargetSlabRepository.persist(ts);

			com.spice.profitmandi.dao.entity.catalog.TargetSlab ts1 = new com.spice.profitmandi.dao.entity.catalog.TargetSlab();

			ts1.setOfferId(offer.getId());

			ts1.setAmountType(targetSlabs.get(0).getItemCriteriaPayouts().get(0).getAmountType());

			ts1.setPayoutTarget(100);

			ts1.setItemCriteriaId(itemCriteria1.getId());

			ts1.setPayoutValue(x.getKey().get(1));

			offerTargetSlabRepository.persist(ts1);

		});

	}

				partnerDailyInvestment.setActivatedGrnPendingAmount(investment.getActivatedGrnPendingAmount());