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

 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 import com.spice.profitmandi.dao.repository.inventory.WarehouseRepository;
 import com.spice.profitmandi.dao.repository.transaction.*;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
+import com.spice.profitmandi.dao.service.solr.FofoSolr;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.PartnerStatsService;
 import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 	@Autowired
 	private MandiiService mandiiService;
 	@Autowired
 	CreditAccountRepository creditAccountRepository;
+	@Autowired
+	private FofoSolr fofoSolr;
 	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 	private String FCM_URL = "https://fcm.googleapis.com/fcm/send";
 	private String FCM_API_KEY = "AAAASAjNcn4:APA91bG6fWRIgYJI0L9gCjP5ynaXz2hJHYKtD9dfH7Depdv31Nd9APJwhx-OPkAJ1WSz4BGNYG8lHThLFSjDGFxIwUZv241YcAJEGDLgt86mxq9FXJe-yBRu-S0_ZwHqmX-QaVKl5F_A";
 		 * subject); this.sendMailOfHtmlFormat("amit.gupta@smartdukaan.com",
 		 * statewiseSaleReport, cc, "Statewise" + subject);
 		 */
+	}
 	public void checkRazorPayPaymentStatus() throws Exception {
 		List<PendingOrder> pendingOrder = pendingOrderRepository
 				.selectAllByStatus(com.spice.profitmandi.dao.enumuration.transaction.OrderStatus.PENDING);
 		for (PendingOrder po : pendingOrder) {
 						if (!emailRowsMap.containsKey(y.getKey())) {
 							emailRowsMap.put(y.getKey(), new ArrayList<>());
+						}
 						List<List<? extends Serializable>> fms = x.getValue().stream()
 								.map(r -> Arrays.asList(r.getStoreCode(), r.getStoreName(), r.getBrandName(),
-										r.getModelName(), r.getModelNumber(), r.getDp(), r.getWarehouseName(), r.getStateManager(),
+										r.getModelName(), r.getModelNumber(), r.getDp(), r.getWarehouseName(),
-										r.getTerritoryManager(), r.getPendingIndentQty(), r.getGrnStockQty(),
+										r.getStateManager(), r.getTerritoryManager(), r.getPendingIndentQty(),
-										r.getShortageQty(), r.getAvailability()))
+										r.getGrnStockQty(), r.getShortageQty(), r.getAvailability()))
 								.collect(Collectors.toList());
 						emailRowsMap.get(y.getKey()).addAll(fms);
+					}
 				});
 			});
-			List<String> headers = Arrays.asList("Store Code", "Store Name", "Brand", "Model Name", "Model Number", "DP",
+			List<String> headers = Arrays.asList("Store Code", "Store Name", "Brand", "Model Name", "Model Number",
-					"Warehouse Name", "State Manager", "Territory Manager", "Pending Indent", "InStock", "Shortage Qty",
+					"DP", "Warehouse Name", "State Manager", "Territory Manager", "Pending Indent", "InStock",
-					"Availability");
+					"Shortage Qty", "Availability");
 			emailRowsMap.entrySet().forEach(entry -> {
 				ByteArrayOutputStream baos = null;
 				try {
 					baos = FileUtil.getCSVByteStream(headers, entry.getValue());
 		List<Integer> assignTo = Arrays.asList(15, 9, 54, 53);
 		Map<Integer, AuthUser> assignAuthUserMap = authRepository.selectAllAuthUserByIds(assignTo).stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
-		List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com");
+		List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com",
+				"sm@smartdukaan.com");
 		LOGGER.info("partnerProblem" + partnerProblems);
 		StringBuilder sb = new StringBuilder();
 		sb.append("<htl><body>");
 		sb.append(
 				"<p>Number against MTD or Investment are the count of days the MTD is low VS LMTD OR Investment is below 75%.</p><br/><p>These partners needs immediate attention.</p><br/><table style='border:1px solid black';cellspacing=0>");
 	@Autowired
 	FofoPaymentRepository fofoPaymentRepository;
 	@Autowired
 	CCAvenuePaymentService ccAvenuePaymentService;
 	public void settleCCAvePayments() throws Exception {
+		List<FofoPayment> fofoPayments = fofoPaymentRepository
-		List<FofoPayment> fofoPayments = fofoPaymentRepository.selectAllByGatewayStatus(Gateway.CCAVENUE, PaymentStatus.INIT).stream()
+				.selectAllByGatewayStatus(Gateway.CCAVENUE, PaymentStatus.INIT).stream()
-				.filter(x->x.getCreateTimestamp().isBefore(LocalDateTime.now().minusMinutes(30l))).collect(Collectors.toList());
+				.filter(x -> x.getCreateTimestamp().isBefore(LocalDateTime.now().minusMinutes(30l)))
+				.collect(Collectors.toList());
 		for (FofoPayment fofoPayment : fofoPayments) {
 			ccAvenuePaymentService.updatePayment(fofoPayment);
+		}
+	}
+	/*
-	/*public void getCCAvenuePendingOrderStatus(int pendingOrderId) {
+	 * public void getCCAvenuePendingOrderStatus(int pendingOrderId) { PendingOrder
-		PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderId);
+	 * pendingOrder = pendingOrderRepository.selectById(pendingOrderId);
-		ccAvenuePaymentService.getPaymentStatusMap(pendingOrder);
+	 * ccAvenuePaymentService.getPaymentStatusMap(pendingOrder); }
-	}*/
+	 */
 	private void calculateInterest(Loan loan, Map<LoanReferenceType, Double> loanStatusAmount, int loanStatementId)
 			throws ProfitMandiBusinessException {
 		LoanStatement loanStatement = loanStatementRepository.selectById(loanStatementId);
+		}
+	}
+	@Autowired
+	private WebListingRepository webListingRepository;
+	@Autowired
+	private WebProductListingRepository webProductListingRepository;
+	public void pushDataToSolr() throws Exception {
+		fofoSolr.pushData();
+	}
+	public void getBestSeller() throws ProfitMandiBusinessException {
+		WebListing webListing = webListingRepository.selectByUrl("partner-best-sellers");
+		List<WebProductListing> webProductListings = webProductListingRepository
+				.selectAllByWebListingId(webListing.getId());
+		List<Integer> catalogItemIds = orderRepository.selectAllOrderWeight(LocalDateTime.now().minusDays(30),
+				LocalDateTime.now(), OrderStatus.DELIVERY_SUCCESS);
+		LOGGER.info("catalogItemIds {}", catalogItemIds);
+		if (!catalogItemIds.isEmpty()) {
+			webProductListingRepository.deleteByEqual(webListing.getId());
+			int count = 0;
+			for (Integer catalogItemId : catalogItemIds) {
+				WebProductListing webProductListing = new WebProductListing();
+				webProductListing.setEntityId(catalogItemId);
+				webProductListing.setWebListingId(webListing.getId());
+				webProductListing.setRank(count + 1);
+				webProductListingRepository.persist(webProductListing);
+			}
+		}
+	}
+	public void getPriceDrop() throws ProfitMandiBusinessException {
+		WebListing webListing = webListingRepository.selectByUrl("partner-price-drop");
+		List<WebProductListing> webProductListings = webProductListingRepository
+				.selectAllByWebListingId(webListing.getId());
+		List<Integer> catalogItemIds = priceDropRepository
+				.selectAllByDatesBetweenSortByDate(LocalDateTime.now().minusDays(30), LocalDateTime.now()).stream()
+				.map(x -> x.getCatalogItemId()).collect(Collectors.toList());
+		LOGGER.info("catalogItemIds {}", catalogItemIds);
+		if (!catalogItemIds.isEmpty()) {
+			webProductListingRepository.deleteByEqual(webListing.getId());
+			int count = 0;
+			for (Integer catalogItemId : catalogItemIds) {
+				WebProductListing webProductListing = new WebProductListing();
+				webProductListing.setEntityId(catalogItemId);
+				webProductListing.setWebListingId(webListing.getId());
+				webProductListing.setRank(count + 1);
+				webProductListingRepository.persist(webProductListing);
+			}
+		}
+	}
+}
 // 2284'

Subversion Repositories SmartDukaan

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