Subversion Repositories SmartDukaan

Rev

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

Rev 24716 Rev 24717
Line 211... Line 211...
211
 
211
 
212
	public void migratePurchase() throws Exception{
212
	public void migratePurchase() throws Exception{
213
		List<Purchase> purchases = purchaseRepository.selectPurchaseAllPurchasesLessThanZero();
213
		List<Purchase> purchases = purchaseRepository.selectPurchaseAllPurchasesLessThanZero();
214
		System.out.printf("Total Purchases count is %s", purchases.size());
214
		System.out.printf("Total Purchases count is %s", purchases.size());
215
		for (Purchase purchase : purchases) {
215
		for (Purchase purchase : purchases) {
-
 
216
			System.out.printf("Got purchase id %d\n", purchase.getId());
216
			List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchase.getId());
217
			List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchase.getId());
217
			Map<Integer, List<InventoryItem>> itemIdInventoryMap = inventoryItems.stream()
218
			Map<Integer, List<InventoryItem>> itemIdInventoryMap = inventoryItems.stream()
218
					.collect(Collectors.groupingBy(InventoryItem::getItemId));
219
					.collect(Collectors.groupingBy(InventoryItem::getItemId));
219
			List<Order> orders = orderRepository.selectByAirwayBillOrInvoiceNumber(purchase.getPurchaseReference(),
220
			List<Order> orders = orderRepository.selectByAirwayBillOrInvoiceNumber(purchase.getPurchaseReference(),
220
					purchase.getFofoId());
221
					purchase.getFofoId());
Line 245... Line 246...
245
											.selectByItemIdAndFofoId(itemQtyEntry.getKey(), purchase.getFofoId());
246
											.selectByItemIdAndFofoId(itemQtyEntry.getKey(), purchase.getFofoId());
246
									if (cis.getAvailability() - quantityToReduce >= 0) {
247
									if (cis.getAvailability() - quantityToReduce >= 0) {
247
										scanRecordRepository.delete(scanRecords.get(0));
248
										scanRecordRepository.delete(scanRecords.get(0));
248
										genericRepository.delete(ii);
249
										genericRepository.delete(ii);
249
										cis.setAvailability(cis.getAvailability() - quantityToReduce);
250
										cis.setAvailability(cis.getAvailability() - quantityToReduce);
-
 
251
										purchase.setUnfullfilledNonSerializedQuantity(purchase.getUnfullfilledNonSerializedQuantity() + quantityToReduce);
250
										LOGGER.info("Rectified {}, {}, {}, {}, {}, {}, {}",
252
										LOGGER.info("Rectified {}, {}, {}, {}, {}, {}, {}",
251
												purchase.getPurchaseReference(), ii.getId(), ii.getItemId(),
253
												purchase.getPurchaseReference(), ii.getId(), ii.getItemId(),
252
												ii.getInitialQuantity(), ii.getGoodQuantity(), ii.getBadQuantity(),
254
												ii.getInitialQuantity(), ii.getGoodQuantity(), ii.getBadQuantity(),
253
												quantityToReduce);
255
												quantityToReduce);
254
										break;
256
										break;