Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.model.ImeiDropSummaryModel;

import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;

	@Autowired

	PriceDropRepository priceDropRepository;

	@Autowired

	PriceDropIMEIRepository priceDropIMEIRepository;

	public void fixPriceDrop() throws ProfitMandiBusinessException {

		List<Integer> priceDropIds = Arrays.asList(609, 610, 611, 648, 649, 650, 651, 653, 667, 691, 692, 693, 695, 696, 697, 698);

		//List<Integer> priceDropIds = Arrays.asList(609, 610, 611, 648, 649, 650, 651, 653, 667, 691, 692, 693, 695, 696, 697, 698);

		for (int priceDropId : priceDropIds) {

			PriceDrop pd = priceDropRepository.selectById(priceDropId);

			LOGGER.info("Price Drop ---- {}", pd);

			List<ImeiDropSummaryModel> actualList = priceDropService.getAllSerialNumbersByAffectedDate(pd.getAffectedOn(), pd.getCatalogItemId());

			Map<String, ImeiDropSummaryModel> actualMap = actualList.stream().collect(Collectors.toMap(x -> x.getSerialNumber(), x -> x));

			List<PriceDropIMEI> priceDropIMEIs = priceDropIMEIRepository.selectByPriceDropId(pd.getId());

			Map<String, PriceDropIMEI> oldImeisMap = priceDropIMEIs.stream().collect(Collectors.toMap(x -> x.getImei(), x -> x));

			for (Map.Entry<String, PriceDropIMEI> entry : oldImeisMap.entrySet()) {

				String imei = entry.getKey();

				if (!actualMap.containsKey(imei)) {

					//This imei is invalid and need to be checked

					if (!entry.getValue().getStatus().equals(PriceDropImeiStatus.REJECTED)) {

						if (entry.getValue().getStatus().equals(PriceDropImeiStatus.PENDING)) {

							LOGGER.info("Invalid pending imei -- {} should be deleted", imei);

						} else if (entry.getValue().getStatus().equals(PriceDropImeiStatus.APPROVED)) {

							LOGGER.info("Invalid approved imei -- {} should be reversed", imei);

						}

						//These values should either be rejected or rolledBack

						LOGGER.info("Should be rejected or rolledBack -- Imei --- {}, Status --- {}", imei, entry.getValue().getStatus());

					} else {

						//Rejections can be ignored

					}

				} else {

					if (entry.getValue().getStatus().equals(PriceDropImeiStatus.REJECTED)) {

						LOGGER.info("Valid but rejected imeis should be retried, marked pending --- {}", imei);

						//entry.getValue().setStatus(PriceDropImeiStatus.PENDING);

					}

				}

			}

			for (Map.Entry<String, ImeiDropSummaryModel> entry : actualMap.entrySet()) {

				ImeiDropSummaryModel imeiDropSummaryModel = entry.getValue();

				String imei = entry.getKey();

				if (!oldImeisMap.containsKey(imei)) {

					//this imei should be added for processing in pending state

					PriceDropIMEI priceDropIMEI = new PriceDropIMEI();

					priceDropIMEI.setPriceDropId(priceDropId);

					priceDropIMEI.setStatus(PriceDropImeiStatus.PENDING);

					priceDropIMEI.setImei(imei);

					priceDropIMEI.setPartnerId(imeiDropSummaryModel.getRetailerId());

					priceDropIMEI.setUpdateTimestamp(LocalDateTime.now());

					//priceDropIMEIRepository.persist(priceDropIMEI);

					LOGGER.info("These imeis are added and were missing earlier --- {}", imei);

				}

			}

		}

	}