WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java

 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
-import java.util.stream.Collector;
 import java.util.stream.Collectors;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.entity.inventory.SaholicInventorySnapshot;
 import com.spice.profitmandi.dao.entity.transaction.HdfcPayment;
 import com.spice.profitmandi.dao.entity.transaction.LineItem;
 import com.spice.profitmandi.dao.entity.transaction.LineItemImei;
+import com.spice.profitmandi.dao.entity.transaction.ManualPaymentType;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.transaction.SellerWarehouse;
 import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseScan;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
+import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.ContentPojo;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.MediaPojo;
 import com.spice.profitmandi.dao.repository.GenericRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.catalog.ManualPaymentRequestRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class RunOnceTasks {
 	private static final Logger LOGGER = LogManager.getLogger(RunOnceTasks.class);
 	@Autowired
 	private LineItemRepository lineItemRepository;
 	@Autowired
 	@Autowired
 	private CsService csService;
 	@Autowired
+	private ManualPaymentRequestRepository manualPaymentRequestRepository;
+	@Autowired
 	private OfferRepository offerRepository;
 	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private Gson gson;
 	@Autowired
 	private PaymentOptionTransactionRepository paymentOptionTransactionRepository;
 	@Autowired
 	private SamsungIMEIActivationService samsungActivationService;
 	@Autowired
 	private SchemeInOutRepository schemeInOutRepository;
 	@Autowired
 	private DebitNoteRepository debitNoteRepository;
 	@Autowired
 	private OfferService offerService;
 	@Autowired
 	private GenericRepository genericRepository;
 	public void createDummyInvoices() {
 		List<WarehouseInventoryItem> lavaInventoryItems = warehouseInventoryItemRepository.getSerialNumbers("Lava",
 				LocalDate.of(2020, Month.SEPTEMBER, 1).atStartOfDay(), LocalDateTime.now());
 		LOGGER.info("Lava Inventory Size is {}", lavaInventoryItems.size());
+	}
 	public void createOffers(int offerId) throws Exception {
 		Map<List<Integer>, List<Integer>> targetMap = new HashMap<>();
-		targetMap.put(Arrays.asList(175138805,175138733,175138821,175138886,175138853,175138799),Arrays.asList(300000,330000,375000));
+		targetMap.put(Arrays.asList(175138805, 175138733, 175138821, 175138886, 175138853, 175138799),
+				Arrays.asList(300000, 330000, 375000));
-		targetMap.put(Arrays.asList(175138895,175138877,175138854,175138857,175138870,175138862,175138873),Arrays.asList(350000,400000,450000));
+		targetMap.put(Arrays.asList(175138895, 175138877, 175138854, 175138857, 175138870, 175138862, 175138873),
+				Arrays.asList(350000, 400000, 450000));
-		targetMap.put(Arrays.asList(175138878),Arrays.asList(380000,418000,475000));
+		targetMap.put(Arrays.asList(175138878), Arrays.asList(380000, 418000, 475000));
+		targetMap.put(Arrays.asList(175138922, 175138833, 175138893, 175138939, 175138832, 175138949, 175138882,
+				175138876, 175138834, 175138930, 175138911, 175138522, 175138871, 175138934, 175138900, 4149607,
+				175138835, 175138941, 175138917, 175138855, 175138825, 175138896, 175138866, 175138174, 175138887,
+				175138816, 175138892, 175135376, 175138918, 175138845, 175138946, 175138920, 175138903, 175138813,
+				175138901, 175138899, 175136389, 175138913, 175138919, 175138923, 175138926, 175138950, 175138953,
-		targetMap.put(Arrays.asList(175138922,175138833,175138893,175138939,175138832,175138949,175138882,175138876,175138834,175138930,175138911,175138522,175138871,175138934,175138900,4149607,175138835,175138941,175138917,175138855,175138825,175138896,175138866,175138174,175138887,175138816,175138892,175135376,175138918,175138845,175138946,175138920,175138903,175138813,175138901,175138899,175136389,175138913,175138919,175138923,175138926,175138950,175138953,175138954,175138955),Arrays.asList(400000,500000,600000));
+				175138954, 175138955), Arrays.asList(400000, 500000, 600000));
-		targetMap.put(Arrays.asList(175138839),Arrays.asList(412000,453200,515000));
+		targetMap.put(Arrays.asList(175138839), Arrays.asList(412000, 453200, 515000));
-		targetMap.put(Arrays.asList(175138716),Arrays.asList(450000,495000,562500));
+		targetMap.put(Arrays.asList(175138716), Arrays.asList(450000, 495000, 562500));
-		targetMap.put(Arrays.asList(175138812),Arrays.asList(465000,511500,581250));
+		targetMap.put(Arrays.asList(175138812), Arrays.asList(465000, 511500, 581250));
-		targetMap.put(Arrays.asList(175138859,175138906,175138874,175138940,175138916,175136207,175138851,175138844,175138929),Arrays.asList(500000,600000,700000));
+		targetMap.put(Arrays.asList(175138859, 175138906, 175138874, 175138940, 175138916, 175136207, 175138851,
+				175138844, 175138929), Arrays.asList(500000, 600000, 700000));
-		targetMap.put(Arrays.asList(175138804,175138910),Arrays.asList(550000,600000,650000));
+		targetMap.put(Arrays.asList(175138804, 175138910), Arrays.asList(550000, 600000, 650000));
-		targetMap.put(Arrays.asList(175127215,175138879),Arrays.asList(555000,610500,693750));
+		targetMap.put(Arrays.asList(175127215, 175138879), Arrays.asList(555000, 610500, 693750));
+		targetMap.put(
-		targetMap.put(Arrays.asList(175138869,175138902,175138909,175138914,175138824,157112773,175138897,175138801),Arrays.asList(600000,730000,840000));
+				Arrays.asList(175138869, 175138902, 175138909, 175138914, 175138824, 157112773, 175138897, 175138801),
+				Arrays.asList(600000, 730000, 840000));
-		targetMap.put(Arrays.asList(172157716),Arrays.asList(616000,677600,770000));
+		targetMap.put(Arrays.asList(172157716), Arrays.asList(616000, 677600, 770000));
-		targetMap.put(Arrays.asList(175138674,175138840),Arrays.asList(650000,715000,812500));
+		targetMap.put(Arrays.asList(175138674, 175138840), Arrays.asList(650000, 715000, 812500));
-		targetMap.put(Arrays.asList(175138936,175138952,175138907,156232687,175138856,175138836,175138942),Arrays.asList(700000,800000,900000));
+		targetMap.put(Arrays.asList(175138936, 175138952, 175138907, 156232687, 175138856, 175138836, 175138942),
+				Arrays.asList(700000, 800000, 900000));
-		targetMap.put(Arrays.asList(175138868),Arrays.asList(775000,852500,968750));
+		targetMap.put(Arrays.asList(175138868), Arrays.asList(775000, 852500, 968750));
-		targetMap.put(Arrays.asList(175138820),Arrays.asList(780000,850000,1050000));
+		targetMap.put(Arrays.asList(175138820), Arrays.asList(780000, 850000, 1050000));
-		targetMap.put(Arrays.asList(175138864,175138863,175138867,175138823,175135227),Arrays.asList(800000,900000,1000000));
+		targetMap.put(Arrays.asList(175138864, 175138863, 175138867, 175138823, 175135227),
+				Arrays.asList(800000, 900000, 1000000));
-		targetMap.put(Arrays.asList(175138408),Arrays.asList(850000,900000,950000));
+		targetMap.put(Arrays.asList(175138408), Arrays.asList(850000, 900000, 950000));
-		targetMap.put(Arrays.asList(175135923,175138888),Arrays.asList(900000,990000,1125000));
+		targetMap.put(Arrays.asList(175135923, 175138888), Arrays.asList(900000, 990000, 1125000));
-		targetMap.put(Arrays.asList(175138908),Arrays.asList(1000000,1200000,1350000));
+		targetMap.put(Arrays.asList(175138908), Arrays.asList(1000000, 1200000, 1350000));
-		targetMap.put(Arrays.asList(175138843),Arrays.asList(1100000,1200000,1350000));
+		targetMap.put(Arrays.asList(175138843), Arrays.asList(1100000, 1200000, 1350000));
-		targetMap.put(Arrays.asList(175138827),Arrays.asList(1150000,1265000,1437500));
+		targetMap.put(Arrays.asList(175138827), Arrays.asList(1150000, 1265000, 1437500));
-		targetMap.put(Arrays.asList(175138883,175135707),Arrays.asList(1200000,1300000,1400000));
+		targetMap.put(Arrays.asList(175138883, 175135707), Arrays.asList(1200000, 1300000, 1400000));
-		targetMap.put(Arrays.asList(175138814,175138829),Arrays.asList(1300000,1500000,1650000));
+		targetMap.put(Arrays.asList(175138814, 175138829), Arrays.asList(1300000, 1500000, 1650000));
-		targetMap.put(Arrays.asList(175138842,175138875),Arrays.asList(1500000,1650000,1800000));
+		targetMap.put(Arrays.asList(175138842, 175138875), Arrays.asList(1500000, 1650000, 1800000));
-		targetMap.put(Arrays.asList(175138541),Arrays.asList(1600000,1700000,1850000));
+		targetMap.put(Arrays.asList(175138541), Arrays.asList(1600000, 1700000, 1850000));
-		targetMap.put(Arrays.asList(175138372),Arrays.asList(1890000,2079000,2362500));
+		targetMap.put(Arrays.asList(175138372), Arrays.asList(1890000, 2079000, 2362500));
-		targetMap.put(Arrays.asList(175138885),Arrays.asList(2100000,2400000,2600000));
+		targetMap.put(Arrays.asList(175138885), Arrays.asList(2100000, 2400000, 2600000));
 		CreateOfferRequest createOfferRequest = offerService.getOffer(offerId);
-		for(Map.Entry<List<Integer>, List<Integer>> targetEntry : targetMap.entrySet()) {
+		for (Map.Entry<List<Integer>, List<Integer>> targetEntry : targetMap.entrySet()) {
 			List<Integer> targets = targetEntry.getValue();
 			createOfferRequest.getPartnerCriteria().setFofoIds(targetEntry.getKey());
 			int counter = 0;
-			for(com.spice.profitmandi.dao.model.TargetSlab targetSlab : createOfferRequest.getTargetSlabs()) {
+			for (com.spice.profitmandi.dao.model.TargetSlab targetSlab : createOfferRequest.getTargetSlabs()) {
 				targetSlab.setOnwardsAmount(targets.get(counter));
 				counter++;
+			}
 			offerService.addOfferService(createOfferRequest);
+		}
+	}
 	@Autowired
 	private WarehouseScanRepository warehouseScanRepository;
 	@Autowired
 	private WarehouseInventoryService warehouseInventoryService;
 	public void fixScans() {
 		Map<Integer, Integer> inventoryOrderMap = new HashMap<>();
-		inventoryOrderMap.put(348795,1628598);
+		inventoryOrderMap.put(348795, 1628598);
-		inventoryOrderMap.put(348796,1628599);
+		inventoryOrderMap.put(348796, 1628599);
-		inventoryOrderMap.put(329854,1628600);
+		inventoryOrderMap.put(329854, 1628600);
-		inventoryOrderMap.put(334197,1628602);
+		inventoryOrderMap.put(334197, 1628602);
-		inventoryOrderMap.put(330110,1628603);
+		inventoryOrderMap.put(330110, 1628603);
-		inventoryOrderMap.put(330111,1628604);
+		inventoryOrderMap.put(330111, 1628604);
-		inventoryOrderMap.put(332843,1628605);
+		inventoryOrderMap.put(332843, 1628605);
-		inventoryOrderMap.put(338067,1628606);
+		inventoryOrderMap.put(338067, 1628606);
-		inventoryOrderMap.put(338974,1628609);
+		inventoryOrderMap.put(338974, 1628609);
-		inventoryOrderMap.put(338975,1628610);
+		inventoryOrderMap.put(338975, 1628610);
-		inventoryOrderMap.put(338971,1628612);
+		inventoryOrderMap.put(338971, 1628612);
-		inventoryOrderMap.put(338588,1628615);
+		inventoryOrderMap.put(338588, 1628615);
-		inventoryOrderMap.put(368205,1631619);
+		inventoryOrderMap.put(368205, 1631619);
-		inventoryOrderMap.put(368206,1631620);
+		inventoryOrderMap.put(368206, 1631620);
-		inventoryOrderMap.put(368207,1631621);
+		inventoryOrderMap.put(368207, 1631621);
-		inventoryOrderMap.put(368208,1631622);
+		inventoryOrderMap.put(368208, 1631622);
-		inventoryOrderMap.put(368209,1631623);
+		inventoryOrderMap.put(368209, 1631623);
-		inventoryOrderMap.put(368211,1631625);
+		inventoryOrderMap.put(368211, 1631625);
-		inventoryOrderMap.put(368213,1631627);
+		inventoryOrderMap.put(368213, 1631627);
-		inventoryOrderMap.put(368214,1631628);
+		inventoryOrderMap.put(368214, 1631628);
-		inventoryOrderMap.put(368203,1631629);
+		inventoryOrderMap.put(368203, 1631629);
-		inventoryOrderMap.put(368216,1631630);
+		inventoryOrderMap.put(368216, 1631630);
-		inventoryOrderMap.put(368217,1631631);
+		inventoryOrderMap.put(368217, 1631631);
-		inventoryOrderMap.put(368218,1631632);
+		inventoryOrderMap.put(368218, 1631632);
-		inventoryOrderMap.put(368219,1631633);
+		inventoryOrderMap.put(368219, 1631633);
-		inventoryOrderMap.put(368222,1631635);
+		inventoryOrderMap.put(368222, 1631635);
+		List<WarehouseScan> scans = warehouseScanRepository
-		List<WarehouseScan> scans = warehouseScanRepository.selectAllByInventoryItemIds(new ArrayList<>(inventoryOrderMap.keySet()));
+				.selectAllByInventoryItemIds(new ArrayList<>(inventoryOrderMap.keySet()));
-		Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream().collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
+		Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream()
+				.collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
-		for(Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
+		for (Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
 			int inventoryItemId = mapEntry.getKey();
+			List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(
-			List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(x->x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId))).collect(Collectors.toList());
+					x -> x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId)))
+					.collect(Collectors.toList());
 			WarehouseScan duplicateScan = duplicateScans.stream().skip(1).findFirst().get();
 			warehouseScanRepository.delete(duplicateScan);
 			warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());
+		}
+	}
 	public void fixOffer() throws Exception {
-		List<Integer> offerIds = Arrays.asList(228, 241,242, 243,244, 253);
+		List<Integer> offerIds = Arrays.asList(228, 241, 242, 243, 244, 253);
-		List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().filter(x->x.getWarehouseId()==7678).map(x->x.getId()).collect(Collectors.toList());
+		List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.getWarehouseId() == 7678)
+				.map(x -> x.getId()).collect(Collectors.toList());
 		LOGGER.info("UP West Partner Ids - {}", fofoIds);
-		for(int offerId : offerIds) {
+		for (int offerId : offerIds) {
-			Offer offer =  offerRepository.selectById(offerId);
+			Offer offer = offerRepository.selectById(offerId);
 			PartnerCriteria partnerCriteria = gson.fromJson(offer.getPartnerCriteria(), PartnerCriteria.class);
 			LOGGER.info("Offer Partner Ids - {}", partnerCriteria.getFofoIds());
 			for (Integer fofoId : fofoIds) {
-				if(partnerCriteria.getFofoIds().contains(fofoId)) {
+				if (partnerCriteria.getFofoIds().contains(fofoId)) {
-					//This shoud be removed
+					// This shoud be removed
+					LOGGER.info("This shoud be removed FofoStore Code - {}",
-					LOGGER.info("This shoud be removed FofoStore Code - {}", fofoStoreRepository.selectByRetailerId(fofoId).getCode());
+							fofoStoreRepository.selectByRetailerId(fofoId).getCode());
 					partnerCriteria.getFofoIds().remove(fofoId);
+				}
+			}
 			offer.setPartnerCriteria(gson.toJson(partnerCriteria));
+		}
+	}
 	public void reverseMaa() throws Exception {
+		Purchase purchase = purchaseRepository.selectById(28877);
-		Set<Integer> inventoryItemIds = inventoryItemRepository.selectByPurchaseId(28877).stream().map(x->x.getId()).collect(Collectors.toSet());
+		Set<Integer> inventoryItemIds = inventoryItemRepository.selectByPurchaseId(28877).stream().map(x -> x.getId())
+				.collect(Collectors.toSet());
-			double totalAmount = schemeInOutRepository.selectByInventoryItemIds(inventoryItemIds).stream().filter(x->x.getRolledBackTimestamp()!=null || x.getStatusDescription().contains("investment"))
+		double totalAmount = schemeInOutRepository.selectByInventoryItemIds(inventoryItemIds).stream()
+				.filter(x -> x.getRolledBackTimestamp() == null || x.getStatusDescription().contains("investment"))
+				.map(x -> {
-					//.map(x->x.setRolledBackTimestamp(null))
+					x.setRolledBackTimestamp(LocalDateTime.now());
+					x.setStatus(SchemePayoutStatus.REJECTED);
+					x.setStatusDescription("Invoice-NSLCK3350 was cancelled, hence all schemes were rolled back");
+					return x;
+				})
-					.collect(Collectors.summingDouble(x->x.getAmount()));
+				.collect(Collectors.summingDouble(x -> x.getAmount()));
+		WalletReferenceType walletReferenceType = WalletReferenceType.OTHERS;
+		ManualPaymentType paymentType = manualPaymentRequestRepository.selectByReferenceType(walletReferenceType);
+		if (paymentType == null) {
+			paymentType = new ManualPaymentType();
+			paymentType.setReferenceType(walletReferenceType);
+			manualPaymentRequestRepository.persist(paymentType);
+		}
+		paymentType.setCounter(paymentType.getCounter() + 1);
+		int reference = paymentType.getCounter();
+		walletService.consumeAmountFromWallet(purchase.getFofoId(), (int)totalAmount, WalletReferenceType.OTHERS, ACCOUNT_ID, reference, LocalDateTime.now());
-			LOGGER.info("Total Deduction is around Rs. {}", totalAmount);
+		LOGGER.info("Total Deduction is around Rs. {}", totalAmount);
+	}
+}
 //7015845171

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java – Rev 28623 → 28624