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

 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
 import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.mail.MessagingException;
 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.PartnerDailyInvestment;
+import com.spice.profitmandi.dao.entity.fofo.PartnerProblem;
 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.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.Address;
 import com.spice.profitmandi.dao.repository.dtr.FranchiseeVisitRepository;
 import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
+import com.spice.profitmandi.dao.repository.dtr.PartnerProblemRepository;
 import com.spice.profitmandi.dao.repository.dtr.PushNotificationRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
 import com.spice.profitmandi.dao.repository.dtr.RefferalRepository;
 	@Value("${oxigen.recharge.enquiry.url}")
 	private String oxigenRechargeEnquiryUrl;
 	@Autowired
 	private RegionRepository regionRepository;
 	private static final DateTimeFormatter leadTimeFormatter = DateTimeFormatter.ofPattern("d LLL, hh:mm a");
 	@Autowired
 	private PartnerRegionRepository partnerRegionRepository;
 	private SchemeService schemeService;
 	private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "uday.singh@smartudkaan.com",
 			"adeel.yazdani@smartdukaan.com", "kamini.sharma@smartdukaan.com", "mohinder.mutreja@smartdukaan.com",
 			"ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com", "hemant.kaura@smartdukaan.com",
-			"rajat.gupta@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",
+			"rajat.gupta@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com" };
-			"manish.gupta@smartdukaan.com" };
 	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",
-			"tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com",
+			"tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",
-			"kuldeep.kumar@smartdukaan.com", "niranjan.kala@smartdukaan.com" };
+			"niranjan.kala@smartdukaan.com" };
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
 	@Autowired
 	private ReporticoService reporticoService;
 	private TicketRepository ticketRepository;
 	@Autowired
 	private RefferalRepository refferalRepository;
+	@Autowired
+	private PartnerProblemRepository partnerProblemRepository;
 	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";
 				LOGGER.info("Could not check status for Request {}", rechargeTransaction.getRequestId());
+			}
+		}
 		LOGGER.info("Reconcile recharge ran successfully");
+	}
 	public void processActivation() throws Exception {
 		schemeService.processActivation();
+	}
 	// TemporaryMethod
 	public void processScheme(int offset, boolean dryRun) throws Exception {
 		LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);
 		LocalDateTime endDate = startDate.plusDays(30);
 		processScheme(startDate, endDate, dryRun);
+	}
 	public void processSchemeOut(List<String> invoiceNumbers) throws Exception {
-		for(String invoiceNumber : invoiceNumbers) {
+		for (String invoiceNumber : invoiceNumbers) {
-			System.out.println("Invoice Number - " +  invoiceNumber);
+			System.out.println("Invoice Number - " + invoiceNumber);
 			FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
 			schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
+		}
+	}
 	public void processSchemeIn(List<String> invoiceNumbers) throws Exception {
-		for(String invoiceNumber : invoiceNumbers) {
+		for (String invoiceNumber : invoiceNumbers) {
-			System.out.println("Invoice Number - " +  invoiceNumber);
+			System.out.println("Invoice Number - " + invoiceNumber);
 			Purchase purchase = purchaseRepository.selectByPurchaseReference(invoiceNumber);
 			schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
+		}
+	}
+			}
 		} catch (Exception e) {
 			e.printStackTrace();
 			throw e;
+		}
-		List<UserWalletHistory> uwhs = userWalletHistoryRepository.selectAllByDateType(LocalDate.now().atStartOfDay(), endDate,
+		List<UserWalletHistory> uwhs = userWalletHistoryRepository.selectAllByDateType(LocalDate.now().atStartOfDay(),
-				Arrays.asList(WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));
+				endDate, Arrays.asList(WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));
 		System.out.println("Amount\tReference\tReferenceType\tTimestamp\tDescription");
 		for (UserWalletHistory uwh : uwhs) {
 			System.out.println(String.format("%d\t%d\t%s\t%s\t%s", uwh.getAmount(), uwh.getReference(),
 					uwh.getReferenceType(), uwh.getTimestamp().toString(), uwh.getDescription()));
+		}
+			}
+		}
+	}
 	public void attachToffeeInvoices() throws Exception {
+		/*
-		/*LOGGER.info("Insurance Sum Summary --- {}",
+		 * LOGGER.info("Insurance Sum Summary --- {}",
-				insurancePolicyRepository.selectAmountSumGroupByRetailerId(LocalDateTime.MIN, LocalDateTime.MAX));
+		 * insurancePolicyRepository.selectAmountSumGroupByRetailerId(LocalDateTime.MIN,
-		LOGGER.info("Insurance Qty Summary --- {}",
+		 * LocalDateTime.MAX)); LOGGER.info("Insurance Qty Summary --- {}",
-				insurancePolicyRepository.selectQtyGroupByRetailerId(LocalDateTime.MIN, LocalDateTime.MAX));
+		 * insurancePolicyRepository.selectQtyGroupByRetailerId(LocalDateTime.MIN,
-		LOGGER.info("SmartPhone Amount Summary --- {}",
+		 * LocalDateTime.MAX)); LOGGER.info("SmartPhone Amount Summary --- {}",
-				fofoOrderItemRepository.selectSumAmountGroupByRetailer(LocalDateTime.MIN, LocalDateTime.MAX, 0, true));
+		 * fofoOrderItemRepository.selectSumAmountGroupByRetailer(LocalDateTime.MIN,
-		LOGGER.info("Smartphone Qty Summary --- {}",
+		 * LocalDateTime.MAX, 0, true)); LOGGER.info("Smartphone Qty Summary --- {}",
-				fofoOrderItemRepository.selectQtyGroupByRetailer(LocalDateTime.MIN, LocalDateTime.MAX, 0, true));*/
+		 * fofoOrderItemRepository.selectQtyGroupByRetailer(LocalDateTime.MIN,
+		 * LocalDateTime.MAX, 0, true));
+		 */
-		List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectAllByProviderId(3, Optional.of(false));
+		List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectAllByProviderId(3,
+				Optional.of(false));
-		for(InsurancePolicy insurancePolicy : insurancePolicies) {
+		for (InsurancePolicy insurancePolicy : insurancePolicies) {
 			String invoiceNumber = insurancePolicy.getInvoiceNumber();
 			FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
 			PdfModel pdfModel = orderService.getInvoicePdfModel(fofoOrder.getId());
 			java.io.ByteArrayOutputStream byteArrayOutputStream = new java.io.ByteArrayOutputStream();
 			PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
+			String pdfInvoiceString = "data:application/pdf;base64,"
-			String pdfInvoiceString = "data:application/pdf;base64," + Base64.getEncoder().encodeToString(byteArrayOutputStream.toByteArray());
+					+ Base64.getEncoder().encodeToString(byteArrayOutputStream.toByteArray());
-			boolean attached = toffeeService.attachInvoice(insurancePolicy.getPolicyNumber().split("#")[1], pdfInvoiceString);
+			boolean attached = toffeeService.attachInvoice(insurancePolicy.getPolicyNumber().split("#")[1],
+					pdfInvoiceString);
-			if(attached) {
+			if (attached) {
 				insurancePolicy.setPosted(true);
+			}
+		}
+	}
 		return sb.toString();
+	}
 	public void reverseWallet() throws Exception {
 		LocalDate localDate = LocalDate.of(2020, 10, 28);
-		List<UserWalletHistory> uwhList = userWalletHistoryRepository.selectAllByDateType(localDate.atStartOfDay(), localDate.plusDays(1).atStartOfDay(),
+		List<UserWalletHistory> uwhList = userWalletHistoryRepository.selectAllByDateType(localDate.atStartOfDay(),
+				localDate.plusDays(1).atStartOfDay(),
 				Arrays.asList(WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));
 		for (UserWalletHistory uwh : uwhList) {
-			if(uwh.getBusinessTimestamp().getMonth().equals(Month.SEPTEMBER)) {
+			if (uwh.getBusinessTimestamp().getMonth().equals(Month.SEPTEMBER)) {
 				UserWallet uw = userWalletRepository.selectById(uwh.getWalletId());
-				//LOGGER.info("UWH - {}", uwh);
+				// LOGGER.info("UWH - {}", uwh);
-				//amount  += uwh.getAmount();
+				// amount += uwh.getAmount();
-				//System.out.println("Amount is - " + amount);
+				// System.out.println("Amount is - " + amount);
+				// walletService.rollbackAmountFromWallet(uw.getUserId(), uwh.getAmount(),
-				//walletService.rollbackAmountFromWallet(uw.getUserId(), uwh.getAmount(), uwh.getReference(), uwh.getReferenceType(), "Margin reversal for error prone run", uwh.getBusinessTimestamp());
+				// uwh.getReference(), uwh.getReferenceType(), "Margin reversal for error prone
+				// run", uwh.getBusinessTimestamp());
 				int orderId = uwh.getReference();
 				FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(orderId);
 				int inventoryItemId = 0;
-				//fofoOrderRepository.delete(fofoOrder);
+				// fofoOrderRepository.delete(fofoOrder);
 				List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
+				/*
+				 * List<PaymentOptionTransaction> paymentOptionTransactions =
-				/*List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository.selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
+				 * paymentOptionTransactionRepository.selectByReferenceIdAndType(fofoOrder.getId
+				 * (), PaymentOptionReferenceType.ORDER); for(PaymentOptionTransaction
-				for(PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
+				 * paymentOptionTransaction : paymentOptionTransactions) {
-					//paymentOptionTransactionRepository.delete(paymentOptionTransaction);
+				 * //paymentOptionTransactionRepository.delete(paymentOptionTransaction); }
-				}*/
+				 */
-				for(FofoOrderItem foi : fofoOrderItems) {
+				for (FofoOrderItem foi : fofoOrderItems) {
-					//fofoOrderItemRepository.delete(foi);
+					// fofoOrderItemRepository.delete(foi);
 					List<FofoLineItem> flis = fofoLineItemRepository.selectByFofoOrderItemId(foi.getId());
-					for(FofoLineItem fli : flis) {
+					for (FofoLineItem fli : flis) {
-						//fofoLineItemRepository.delete(fli);
+						// fofoLineItemRepository.delete(fli);
 						inventoryItemId = fli.getInventoryItemId();
+					}
+				}
-				List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(java.util.stream.Stream.of(inventoryItemId).collect(Collectors.toSet()));
+				List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(
+						java.util.stream.Stream.of(inventoryItemId).collect(Collectors.toSet()));
-				for(SchemeInOut sio : schemeInOuts) {
+				for (SchemeInOut sio : schemeInOuts) {
-					if(sio.getCreateTimestamp().toLocalDate().equals(localDate)) {
+					if (sio.getCreateTimestamp().toLocalDate().equals(localDate)) {
 						LOGGER.info("SIO - {}", sio);
 						sio.setRolledBackTimestamp(LocalDateTime.now());
+					}
+				}
+			}
+		}
+	}
+	public void partnerProblemAlert() throws Exception {
+		LocalDateTime curDate = LocalDate.now().atStartOfDay();
+		Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
+				curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
+		Map<Integer, Double> mtdSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1),
+				curDate.with(LocalTime.MAX), 0, false);
+		Map<Integer, PartnerDailyInvestment> pdi = partnerDailyInvestmentRepository.selectAll(LocalDate.now()).stream()
+				.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
+		for (Entry<Integer, Double> ls : lmtdSale.entrySet()) {
+			double lmtdTwentyPercentSale = ls.getValue() * 0.2;
+			double mtdSale = mtdSales.get(ls.getKey());
+			double totalSixtyPercentInvestment = pdi.get(ls.getKey()).getTotalInvestment() * 0.6;
+			double stockInvestment = pdi.get(ls.getKey()).getInStockAmount();
+			boolean Investmentvalue = partnerInvestmentService.isInvestmentBelow(ls.getKey(), 25);
+			PartnerProblem partnerProblem = partnerProblemRepository.selectByFofoId(ls.getKey());
+			if (partnerProblem != null) {
+				partnerProblem = new PartnerProblem();
+				partnerProblem.setFofoId(ls.getKey());
+				if (mtdSale < lmtdTwentyPercentSale) {
+					partnerProblem.setMtd(1);
+				}
+				if (Investmentvalue) {
+					partnerProblem.setInvestment(1);
+				}
+				if (stockInvestment < totalSixtyPercentInvestment) {
+					partnerProblem.setInvestment(1);
+				}
+				partnerProblemRepository.persist(partnerProblem);
+			} else {
+				if (mtdSale < lmtdTwentyPercentSale) {
+					partnerProblem.setMtd(partnerProblem.getMtd() + 1);
+				} else {
+					partnerProblem.setMtd(0);
+				}
+				if (Investmentvalue) {
+					partnerProblem.setInvestment(partnerProblem.getInvestment() + 1);
+				} else {
+					partnerProblem.setInvestment(0);
+				}
+				if (stockInvestment < totalSixtyPercentInvestment) {
+					partnerProblem.setStockInvestment(partnerProblem.getStockInvestment() + 1);
+				} else {
+					partnerProblem.setStockInvestment(0);
+				}
+			}
+		}
+		Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
+		List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com",
+				"hemant.kaura@smartdukaan.com", "niranjan.kala@smartdukaan.com", "sm@smartdukaan.com ");
+		List<PartnerProblem> partnerProblems = partnerProblemRepository.selectAll().stream()
+				.filter(x -> x.getMtd() + x.getInvestment() + x.getStockInvestment() > 0).collect(Collectors.toList());
+		StringBuilder sb = new StringBuilder();
+		sb.append("<html><body>");
+		sb.append("<p>Partner Problem Alert!:</p><br/><table style='border:1px solid black';cellspacing=0>");
+		sb.append("<tbody>\n" + "	    <tr>"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner Name</th>"
+				+ "                         <th style='border:1px solid black;padding: 5px'>Assign TO</th>"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Mtd</th>"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Investment</th>"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Stock</th>"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Manager</th>"
+				+ "	    				</tr>");
+		for (PartnerProblem pp : partnerProblems) {
+			int value = pp.getFofoId() % 5;
+			Map<EscalationType, AuthUser> authUserMap = csService.getAuthUserAndEsclationByPartnerId(pp.getFofoId());
+			sb.append("<tr>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>"
+					+ customRetailers.get(pp.getFofoId()).getBusinessName() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + sendTo.get(value) + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + pp.getMtd() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + pp.getInvestment() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + pp.getStockInvestment() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + authUserMap.get(EscalationType.L1)
+					+ authUserMap.get(EscalationType.L2) + "</td>");
+			sb.append("</tr>");
+		}
+		sb.append("</tbody></table><br><br>");
+		String subject = "Partner Problem Alert!";
+		MimeMessage message = mailSender.createMimeMessage();
+		MimeMessageHelper helper = new MimeMessageHelper(message, true);
+		String[] email = sendTo.toArray(new String[sendTo.size()]);
+		helper.setSubject(subject);
+		helper.setText(sb.toString(), true);
+		helper.setTo("tejbeer.kaur@shop2020.in");
+		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
+		helper.setFrom(senderAddress);
+		mailSender.send(message);
+	}
+}
 //2284

Subversion Repositories SmartDukaan

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