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

 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.io.ByteArrayResource;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
+import org.w3c.dom.stylesheets.LinkStyle;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.Utils;
+import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
+import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.entity.fofo.TargetSlab;
 import com.spice.profitmandi.dao.entity.inventory.SaholicInventorySnapshot;
 import com.spice.profitmandi.dao.entity.inventory.SaholicReservationInventorySnapshot;
 import com.spice.profitmandi.dao.entity.transaction.LineItem;
 import com.spice.profitmandi.dao.entity.transaction.LineItemImei;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.transaction.SellerWarehouse;
+import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.repository.GenericRepository;
+import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.DebitNoteRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
+import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.TargetSlabRepository;
 import com.spice.profitmandi.dao.repository.fofo.TargetSlabRepositoryImpl;
 import com.spice.profitmandi.dao.repository.inventory.SaholicInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.inventory.SaholicReservationInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 	// Service for Tertiary/Partner Orders
 	@Autowired
 	private OrderService orderService;
 	@Autowired
+	private SchemeRepository schemeRepository;
+	@Autowired
+	private SchemeItemRepository schemeItemRepository;
+	@Autowired
 	private ReturnOrderRepository returnOrderRepository;
 	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
 				targetSlabRepository.persist(x);
 			});
+		}
+	}
+	public void populateScheme() {
+		List<Integer> list05 = Arrays.asList(29093, 29094, 29095, 29096, 29097, 29098, 29099, 29101, 29102);
+		List<Integer> list10 = Arrays.asList(29187, 29188);
+		List<Integer> list13 = Arrays.asList(28095, 28097, 28098, 28101, 28102, 28104, 28106, 28107, 28108, 28227,
+, 28229, 28231, 29055, 29056, 29066, 29079);
+		List<Integer> list15 = Arrays.asList(20891, 27938, 27939, 27940, 27941, 27943, 27947, 27948, 27953, 27954,
+, 28220, 28467, 29020, 29033, 29034, 29035, 29592, 29886, 29890, 29891, 29941, 29942, 27445, 27958,
+, 27961);
+		List<Integer> list18 = Arrays.asList(28137, 28138, 28140, 28157, 28158, 28161, 28162, 28163, 28164, 28176,
+, 28178, 28199, 28200, 28208, 28209, 28210, 28211, 28215, 28216, 28217, 28230, 28380, 28381, 28382,
+, 28384, 28385, 28386, 28387, 28388, 28389, 28390, 28391, 28392, 28395, 28461, 28462, 28463, 28464,
+, 28466, 28488, 28489, 28490, 28491, 28564, 28565, 28762, 28773, 28871, 28872, 28873, 28874, 28880,
+, 28914, 28915, 28916, 28917, 28918, 28919, 28920, 29046, 29047, 29048, 29068, 29069, 29110, 29111,
+, 29113, 29114, 29115, 29116, 29117, 29207, 29208, 29217, 29218, 29225, 29474, 29475, 29476, 29477,
+, 29479, 29483, 29485, 29486, 29487, 29488, 29739, 29740, 29741, 29742, 29743, 29744, 29745, 29746,
+, 29748, 29749, 29753, 29756, 29757, 29758, 29760, 29761, 29762, 29763, 29764, 29765, 29766, 29767,
+, 29780, 29781, 29792, 29793, 29828, 29829, 29830, 29879, 29880, 29881, 29882, 29951);
+		List<Integer> list20 = Arrays.asList(27975, 27976, 28091, 28363, 29023, 29024, 29025);
+		List<Integer> list25 = Arrays.asList(28763, 28764, 28765, 29152, 29154, 29157, 29209, 29210, 29601, 29602,
+, 29721, 29722, 29723, 29725, 29726, 29727);
+		List<Integer> list30 = Arrays.asList(27962, 27963, 27964, 27965, 27966, 27968, 27969, 28328, 28362, 28566,
+, 28568, 28571, 28572, 29073, 29074, 29075, 29080, 29081, 29120, 29121, 29122, 29124, 29189, 29190,
+, 29192, 29193, 29194, 29196, 29197, 29198, 29199, 29515, 29516, 29517, 29675, 29676, 29677, 29678,
+, 29707, 29708, 29794, 29795, 29883, 29884, 29885, 29887, 29888, 29889, 29931, 29932, 29935, 29936,
+, 29938, 29939, 29940);
+		List<Integer> list35 = Arrays.asList(27996, 27998, 29067, 29071, 29643, 29644, 29945, 29946, 29987, 29052,
+, 29078, 29085, 29086, 29567, 29568, 29569, 29570, 29797, 29914, 29915, 29930, 28877, 28878, 29604,
+, 29606, 29775, 29776, 29777, 29778, 28862, 28863, 28864, 29026, 29103, 29104, 29105, 28979, 28980,
+, 28982, 28983, 29002, 29003, 29004, 29834, 29835, 29836, 29837, 29943);
+		List<Integer> list40 = Arrays.asList(29082, 29083, 28766, 28767, 28768, 28769, 28771);
+		List<Integer> list45 = Arrays.asList(28026, 28027, 28028, 29528, 29529, 29530, 29534, 29535, 29536, 29538,
+);
+		List<Integer> list55 = Arrays.asList(28010, 28011, 28015, 28016, 28019, 28240, 28469, 28470, 28471, 28569,
+, 28674, 28759, 28761, 28909, 28910, 28911, 28912, 28913, 29108, 29109, 29143, 29144, 29145, 29146,
+, 29212, 29213, 29214, 29482, 29511, 29512, 29521, 29525, 29526, 29527, 29574, 29575, 29576, 29611,
+, 29616, 29641, 29642, 29728, 29729, 29750, 29771, 29782, 29783, 29784, 29923, 29924, 29944, 29953,
+, 29994, 27977, 27978, 28092, 28325, 28326, 28327, 28486, 28487, 29148, 29149, 29150, 29151, 29384,
+, 29386, 29427, 29489, 29518, 29519, 29520, 29577, 29578, 29579, 29580, 29586, 29660, 29661, 29662,
+, 29769, 29770, 29790, 29791, 29796, 29928, 29929, 29947, 29948, 28093, 28094, 28556, 28557, 28673,
+, 28868, 28870, 29089, 29090, 29091, 29106, 29107);
+		List<Integer> list65 = Arrays.asList(28058, 28223, 28224, 28225, 28226, 28329, 29201, 29202, 29203, 29204,
+, 29206, 29466, 29467, 29468, 29469, 29470, 29471, 29472, 29573);
+		Map<Float, List<Integer>> m = new HashMap<>();
+		m.put(0.5f, list05);
+		m.put(1.0f, list10);
+		m.put(1.3f, list13);
+		m.put(1.5f, list15);
+		m.put(1.8f, list18);
+		m.put(2.0f, list20);
+		m.put(2.5f, list25);
+		m.put(3.0f, list30);
+		m.put(3.5f, list35);
+		m.put(4.0f, list40);
+		m.put(4.5f, list45);
+		m.put(5.5f, list55);
+		m.put(6.5f, list65);
+		for (Map.Entry<Float, List<Integer>> itemsListEntry : m.entrySet()) {
+			Scheme s1 = getScheme();
+			s1.setAmount(itemsListEntry.getKey());
+			schemeRepository.persist(s1);
+			for(Integer itemId : itemsListEntry.getValue()) {
+				SchemeItem schemeItem = new SchemeItem();
+				schemeItem.setItemId(itemId);
+				schemeItem.setSchemeId(s1.getId());
+				schemeItemRepository.persist(schemeItem);
+			}
+		}
+	}
+	private Scheme getScheme() {
+		Scheme s = new Scheme();
+		s.setName("List Price Margin");
+		s.setDescription("List Price Margin");
+		s.setRetailerAll(true);
+		s.setActiveTimestamp(null);
+		s.setStartDateTime(LocalDate.of(2019, 6, 1).atStartOfDay());
+		s.setEndDateTime(LocalDate.of(2019, 7, 1).atStartOfDay());
+		s.setAmountType(AmountType.PERCENTAGE);
+		s.setCreateTimestamp(LocalDateTime.now());
+		s.setExpireTimestamp(null);
+		s.setCreatedBy(175120474);
+		return s;
+	}
 	public void findMismatchesInIndent() throws Exception {
+		/*
-		/*List<SaholicInventorySnapshot> saholicInventorySnapshots = saholicInventorySnapshotRepository.selectAll();
+		 * List<SaholicInventorySnapshot> saholicInventorySnapshots =
+		 * saholicInventorySnapshotRepository.selectAll(); Map<Integer, Integer>
-		Map<Integer, Integer> itemReservedMap = saholicInventorySnapshots.stream().filter(x -> x.getReserved() > 0)
+		 * itemReservedMap = saholicInventorySnapshots.stream().filter(x ->
+		 * x.getReserved() > 0)
-				.collect(Collectors.groupingBy(SaholicInventorySnapshot::getItemId,
+		 * .collect(Collectors.groupingBy(SaholicInventorySnapshot::getItemId,
-						Collectors.summingInt(SaholicInventorySnapshot::getReserved)));
+		 * Collectors.summingInt(SaholicInventorySnapshot::getReserved)));
-		*/
+		 */
 		List<Order> allInProcessOrders = orderRepository.selectAllOrder(OrderStatus.SUBMITTED_FOR_PROCESSING);
-		/*Map<Integer, Integer> lineItemQtyMap = allInProcessOrders
-				.stream().collect(Collectors.groupingBy(y -> y.getLineItem().getItemId(),
-						Collectors.summingInt(y -> y.getLineItem().getQuantity())));*/
-/*		Map<Integer, Order> orderMap = allInProcessOrders.stream().collect(Collectors.toMap(Order::getId, x->x));
-		Map<Integer, List<Order>> itemOrdersMap = allInProcessOrders.stream()
-				.collect(Collectors.groupingBy(o->o.getLineItem().getItemId(), Collectors.toList()));
-*/
+		/*
+		 * Map<Integer, Integer> lineItemQtyMap = allInProcessOrders
+		 * .stream().collect(Collectors.groupingBy(y -> y.getLineItem().getItemId(),
+		 * Collectors.summingInt(y -> y.getLineItem().getQuantity())));
+		 */
+		/*
+		 * Map<Integer, Order> orderMap =
+		 * allInProcessOrders.stream().collect(Collectors.toMap(Order::getId, x->x));
+		 * Map<Integer, List<Order>> itemOrdersMap = allInProcessOrders.stream()
+		 * .collect(Collectors.groupingBy(o->o.getLineItem().getItemId(),
+		 * Collectors.toList()));
+		 */
-		Map<String, Integer> lineItemWhQtyMap = allInProcessOrders
+		Map<String, Integer> lineItemWhQtyMap = allInProcessOrders.stream()
-				.stream().collect(Collectors.groupingBy(y -> y.getLineItem().getItemId() + "-"+ y.getWarehouseId(),
+				.collect(Collectors.groupingBy(y -> y.getLineItem().getItemId() + "-" + y.getWarehouseId(),
 						Collectors.summingInt(y -> y.getLineItem().getQuantity())));
+		/*
-/*		itemReservedMap.forEach((itemId, reserved)->{
+		 * itemReservedMap.forEach((itemId, reserved)->{
-			if(lineItemQtyMap.containsKey(itemId)) {
+		 * if(lineItemQtyMap.containsKey(itemId)) { int orderedQty =
-				int orderedQty = lineItemQtyMap.get(itemId);
-				System.out.printf("%d\t%d\t%d\n",itemId, orderedQty, reserved);
+		 * lineItemQtyMap.get(itemId); System.out.printf("%d\t%d\t%d\n",itemId,
-			} else {
+		 * orderedQty, reserved); } else {
-				saholicInventorySnapshotRepository.removeAllReservations(itemId);
+		 * saholicInventorySnapshotRepository.removeAllReservations(itemId);
-				System.out.printf("%d\t%d\t%d\n",itemId, 0, reserved);
+		 * System.out.printf("%d\t%d\t%d\n",itemId, 0, reserved); } });
-			}
-		});*/
+		 */
-		lineItemWhQtyMap.forEach((key, value)->{
+		lineItemWhQtyMap.forEach((key, value) -> {
 			int itemId = Integer.parseInt(key.split("-")[0]);
 			int warehouseId = Integer.parseInt(key.split("-")[1]);
-			System.out.printf("%d\t%d\t%d\n",itemId, warehouseId, value);
+			System.out.printf("%d\t%d\t%d\n", itemId, warehouseId, value);
-			SaholicInventorySnapshot cis = saholicInventorySnapshotRepository.selectByWarehouseIdandItemId(warehouseId, itemId);
+			SaholicInventorySnapshot cis = saholicInventorySnapshotRepository.selectByWarehouseIdandItemId(warehouseId,
+					itemId);
-			if(cis==null) {
+			if (cis == null) {
 				cis = new SaholicInventorySnapshot();
 				cis.setItemId(itemId);
 				cis.setWarehouseId(warehouseId);
 				cis.setAvailability(0);
 				saholicInventorySnapshotRepository.persist(cis);
+			}
 			cis.setReserved(value);
 		});
 		/*
-		List<SaholicReservationInventorySnapshot> reservationInventorySnapshots = saholicReservationInventorySnapshotRepository.selectAll();
+		 * List<SaholicReservationInventorySnapshot> reservationInventorySnapshots =
+		 * saholicReservationInventorySnapshotRepository.selectAll(); Map<Integer,
-		Map<Integer, SaholicReservationInventorySnapshot> reservationInventorySnapshotsMap =reservationInventorySnapshots.stream()
+		 * SaholicReservationInventorySnapshot> reservationInventorySnapshotsMap
+		 * =reservationInventorySnapshots.stream()
-				.collect(Collectors.toMap(x->x.getOrderId(), x->x));
+		 * .collect(Collectors.toMap(x->x.getOrderId(), x->x));
+		 *
+		 * List<Integer> orderIds =
-		List<Integer> orderIds = reservationInventorySnapshots.stream().map(x->x.getOrderId()).collect(Collectors.toList());
+		 * reservationInventorySnapshots.stream().map(x->x.getOrderId()).collect(
+		 * Collectors.toList()); List<Order> orders =
-		List<Order> orders = orderRepository.selectByOrderIds(orderIds);
+		 * orderRepository.selectByOrderIds(orderIds);
-		orders.stream().filter(x->Arrays.asList(OrderStatus.PAYMENT_PENDING, OrderStatus.PAYMENT_FAILED).
+		 * orders.stream().filter(x->Arrays.asList(OrderStatus.PAYMENT_PENDING,
-				contains(x.getStatus())).forEach(x->{
+		 * OrderStatus.PAYMENT_FAILED). contains(x.getStatus())).forEach(x->{
-					SaholicReservationInventorySnapshot snapshot = reservationInventorySnapshotsMap.get(x.getId());
+		 * SaholicReservationInventorySnapshot snapshot =
-					try {
+		 * reservationInventorySnapshotsMap.get(x.getId()); try {
+		 * saholicInventorySnapshotRepository.reduceReservationCount(snapshot.getItemId(
-						saholicInventorySnapshotRepository.reduceReservationCount(snapshot.getItemId(), snapshot.getWarehouseId(), snapshot.getReserved(), snapshot.getOrderId());
+		 * ), snapshot.getWarehouseId(), snapshot.getReserved(), snapshot.getOrderId());
-						System.out.printf("%d Reduced by %d for Order Id %d\n",snapshot.getItemId(), snapshot.getReserved(), snapshot.getOrderId());
+		 * System.out.printf("%d Reduced by %d for Order Id %d\n",snapshot.getItemId(),
+		 * snapshot.getReserved(), snapshot.getOrderId()); }
-					} catch(ProfitMandiBusinessException e) {
+		 * catch(ProfitMandiBusinessException e) {
-						LOGGER.info("Problem whiile reducing count for Order Id - {}", snapshot.getOrderId());
+		 * LOGGER.info("Problem whiile reducing count for Order Id - {}",
-					}
+		 * snapshot.getOrderId()); } });
-				});*/
+		 */
-		//throw new Exception();
+		// throw new Exception();
+	}
+}

Subversion Repositories SmartDukaan

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