WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTypeChange;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
+import com.spice.profitmandi.dao.entity.inventory.SaholicCIS;
+import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 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.repository.user.UserRepository;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.InventoryService;
+import com.spice.profitmandi.service.inventory.SaholicInventoryService;
 import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 	@Autowired
 	private CsService csService;
 	@Autowired
+	private SaholicInventoryService saholicInventoryService;
+	@Autowired
 	private InsurancePolicyRepository insurancePolicyRepository;
 	@Autowired
 	private ToffeeService toffeeService;
 			for (Map.Entry<Integer, Optional<Integer>> entry : focusedCatalogIdAndQtyMap.entrySet()) {
 				int minQty = entry.getValue().get();
 				int inStockQty = 0;
 				int processingQty = 0;
 				int grnPendingQty = 0;
+				int allColorNetAvailability = 0;
 				if (processingOrderMap != null) {
 					processingQty = (processingOrderMap.get(entry.getKey()) == null) ? 0
 							: processingOrderMap.get(entry.getKey());
+				}
 				if (totalQty < minQty) {
 					int shortageQty = minQty - totalQty;
 					List<Item> item = itemRepository.selectAllByCatalogItemId(entry.getKey());
+					Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
+					Map<Integer, List<SaholicCIS>> itemAvailabilityMap = saholicInventoryService.getSaholicStock()
+							.get(warehouseMap.get(customRetailer.getWarehouseId()));
+					Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = saholicInventoryService
+							.getSaholicPOItems().get(warehouseMap.get(customRetailer.getWarehouseId()));
+					for (Item it : item) {
+						List<SaholicCIS> currentAvailability = itemAvailabilityMap.get(it.getId());
+						List<SaholicPOItem> poItemAvailability = poItemAvailabilityMap.get(it.getId());
+						if (currentAvailability != null) {
+							allColorNetAvailability += currentAvailability.stream()
+									.collect(Collectors.summingInt(SaholicCIS::getNetavailability));
+						}
+						if (poItemAvailability != null) {
+							allColorNetAvailability += poItemAvailability.stream()
+									.collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty));
+						}
+					}
 					FocusedModelShortageModel fm = new FocusedModelShortageModel();
 					fm.setFofoId(fofoId);
 					fm.setStoreName(customRetailer.getBusinessName());
+					fm.setBrandName(item.get(0).getBrand());
+					fm.setModelName(item.get(0).getModelName());
-					fm.setItemName(item.get(0).getBrand() + item.get(0).getModelNumber() + item.get(0).getModelName());
+					fm.setModelNumber(item.get(0).getModelNumber());
 					fm.setShortageQty(shortageQty);
+					fm.setWarehouseName(warehouseMap.get(customRetailer.getWarehouseId()));
+					// fm.setItemName(item.get(0).getBrand() + item.get(0).getModelNumber() +
+					// item.get(0).getModelName());
+					fm.setAvailabitiy(allColorNetAvailability);
 					focusedModelShortageList.add(fm);
+				}
+			}
+			/*
-			if (!focusedModelShortageList.isEmpty()) {
+			 * if (!focusedModelShortageList.isEmpty()) { String subject = "Stock Alert";
-				String subject = "Stock Alert";
-				String messageText = this.getMessage(focusedModelShortageList);
+			 * String messageText = this.getMessage(focusedModelShortageList);
+			 *
-				this.sendMailWithAttachments(subject, messageText, customRetailer.getEmail());
+			 * this.sendMailWithAttachments(subject, messageText,
+			 * customRetailer.getEmail()); String notificationMessage =
-				String notificationMessage = this.getNotificationMessage(focusedModelShortageList);
+			 * this.getNotificationMessage(focusedModelShortageList);
+			 *
-				LOGGER.info("notificationMessage" + notificationMessage);
+			 * LOGGER.info("notificationMessage" + notificationMessage);
+			 *
-				SendNotificationModel sendNotificationModel = new SendNotificationModel();
+			 * SendNotificationModel sendNotificationModel = new SendNotificationModel();
-				sendNotificationModel.setCampaignName("Stock Alert");
+			 * sendNotificationModel.setCampaignName("Stock Alert");
-				sendNotificationModel.setTitle("Alert");
+			 * sendNotificationModel.setTitle("Alert");
-				sendNotificationModel.setMessage(notificationMessage);
+			 * sendNotificationModel.setMessage(notificationMessage);
-				sendNotificationModel.setType("url");
+			 * sendNotificationModel.setType("url"); sendNotificationModel.setUrl(
-				sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
+			 * "https://app.smartdukaan.com/pages/home/notifications");
-				sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
+			 * sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
-				sendNotificationModel.setMessageType(MessageType.notification);
+			 * sendNotificationModel.setMessageType(MessageType.notification); int userId =
-				int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
+			 * userAccountRepository.selectUserIdByRetailerId(fofoId);
-				sendNotificationModel.setUserIds(Arrays.asList(userId));
+			 * sendNotificationModel.setUserIds(Arrays.asList(userId));
-				notificationService.sendNotification(sendNotificationModel);
+			 * notificationService.sendNotification(sendNotificationModel);
+			 *
-			}
+			 * }
+			 */
+		}
 		if (!focusedModelShortageReportMap.isEmpty()) {
 			String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 			Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
 			Map<String, List<List<?>>> emailRowsMap = new HashMap<>();
 					if (y.getValue().contains(x.getKey())) {
 						if (!emailRowsMap.containsKey(y.getKey())) {
 							emailRowsMap.put(y.getKey(), new ArrayList<>());
+						}
-						List<List<? extends Serializable>> fms = x.getValue().stream().map(r -> Arrays
+						List<List<? extends Serializable>> fms = x.getValue().stream()
+								.map(r -> Arrays.asList(r.getStoreCode(), r.getStoreName(), r.getBrandName(),
-								.asList(r.getFofoId(), r.getStoreName(), r.getItemName(), r.getShortageQty()))
+										r.getModelName(), r.getModelNumber(), r.getShortageQty()))
 								.collect(Collectors.toList());
 						emailRowsMap.get(y.getKey()).addAll(fms);
+					}
 				});
 			});
-			List<String> headers = Arrays.asList("Partner Id", "Partner Name", "Model Name", "Shortage Qty");
+			List<String> headers = Arrays.asList("Partner Code", "Partner Name", "Brand", "Model Name", "Model Number",
+					"Shortage Qty");
 			emailRowsMap.entrySet().forEach(entry -> {
 				ByteArrayOutputStream baos = null;
 				try {
 					baos = FileUtil.getCSVByteStream(headers, entry.getValue());
 				} catch (Exception e2) {
 					e2.printStackTrace();
+				}
-				String[] sendToArray = new String[] { entry.getKey() };
+				String[] sendToArray = new String[] {
+						// entry.getKey()
+						"tejbeer.kaur@shop2020.in" };
 				try {
 					Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Stock Alert", "PFA", fileName,
 							new ByteArrayResource(baos.toByteArray()));
 				} catch (Exception e1) { // TODO Auto-generated catch block
 					e1.printStackTrace();

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 27206 → 27208