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

 import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
+import com.spice.profitmandi.dao.entity.fofo.PartnerBrandService;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerProblem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.fofo.PendingOrder;
 import com.spice.profitmandi.dao.entity.fofo.PendingOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.RazorPay;
 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.inventory.State;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 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.Lead;
 import com.spice.profitmandi.dao.entity.user.Refferal;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
+import com.spice.profitmandi.dao.enumuration.fofo.PartnerStatusType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.fofo.PendingOrderService;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.RazorPayRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
+import com.spice.profitmandi.dao.repository.fofo.ServiceConfigRepository;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 import com.spice.profitmandi.dao.repository.inventory.WarehouseRepository;
 import com.spice.profitmandi.dao.repository.transaction.HdfcPaymentRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
+import com.spice.profitmandi.service.EmailService;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 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;
+import com.spice.profitmandi.service.serviceConfig.ServiceConfigService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.OrderStatus;
 	@Value("${oxigen.recharge.enquiry.url}")
 	private String oxigenRechargeEnquiryUrl;
 	@Autowired
 	private RegionRepository regionRepository;
 	@Autowired
 	private TecnoImeiActivation tecnoImeiActivation;
 	private static final DateTimeFormatter leadTimeFormatter = DateTimeFormatter.ofPattern("d LLL, hh:mm a");
 	private PartnerTypeChangeRepository partnerTypeChangeRepository;
 	@Autowired
 	private SchemeService schemeService;
+	@Autowired
+	private ServiceConfigRepository serviceConfigRepository;
 	@Value("${delhivery.tracking.token}")
 	private String token;
 	private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "uday.singh@smartudkaan.com",
 			"mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com",
 							inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
+	}
 	public void toffeeRollback() throws Exception {
 		toffeeService.cancelPolicyCopy("110143521986");
 		toffeeService.getOrderId("110143521986");
+	}
 				LOGGER.info("No region found for partner {}", fofoId);
 				continue;
+			}
 			Map<Integer, Optional<Integer>> focusedCatalogIdAndQtyMap = focusedModelRepository
 					.selectAllByRegionIds(regionIds).stream().collect(Collectors.groupingBy(FocusedModel::getCatalogId,
-							Collectors.mapping(FocusedModel::getMinimumQty, Collectors.maxBy(Integer::compareTo))));
+							Collectors.mapping(FocusedModel::getObsMinimumQty, Collectors.maxBy(Integer::compareTo))));
 			LOGGER.info("focusedCatalogIdAndQtyMap" + focusedCatalogIdAndQtyMap);
 			for (Map.Entry<Integer, Optional<Integer>> entry : focusedCatalogIdAndQtyMap.entrySet()) {
 				int minQty = entry.getValue().get();
 					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();
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
-	public void checkItelImeiActivation(LocalDate date,Integer day) {
+	public void checkItelImeiActivation(LocalDate date, Integer day) {
 		LOGGER.info("Hello - {}", "hhh");
 		try {
-			itelImeiActivationService.checkItelImeiActivation(date,day);
+			itelImeiActivationService.checkItelImeiActivation(date, day);
 		} catch (ProfitMandiBusinessException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
-	public void checkTecnoImeiActivation(LocalDate date,Integer day) {
+	public void checkTecnoImeiActivation(LocalDate date, Integer day) {
 		LOGGER.info("Hello - {}", "hhh");
 		try {
-			tecnoImeiActivation.checkTecnoImeiActivation(date,day);
+			tecnoImeiActivation.checkTecnoImeiActivation(date, day);
 		} catch (ProfitMandiBusinessException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
 	public void checkCancellationMargin() throws Exception {
 		LocalDateTime startDate = LocalDate.of(2021, 4, 1).atStartOfDay();
 		List<FofoOrder> fofoOrders = fofoOrderRepository.selectCancelledBetweenSaleDate(startDate, LocalDateTime.now());
 		LOGGER.info("Total Orders =  {}", fofoOrders.size());
 		for (FofoOrder fofoOrder : fofoOrders) {
+			}
+		}
+	}
+	public void financeServices() {
+		List<PartnerBrandService> pbs = serviceConfigRepository.selectByPartnerStatusType(PartnerStatusType.NOTWORKING);
+		if (!pbs.isEmpty()) {
+			Map<Integer, List<Integer>> fofoIdBrandServiceMap = pbs.stream().collect(Collectors.groupingBy(
+					x -> x.getFofoId(), Collectors.mapping(x -> x.getBrandServiceId(), Collectors.toList())));
+			serviceConfigRepository.selectAll();
+		}
+	}
+}
 //2284

Subversion Repositories SmartDukaan

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