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

 	private ServiceConfigRepository serviceConfigRepository;
 	@Value("${delhivery.tracking.token}")
 	private String token;
-	private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "uday.singh@smartudkaan.com",
+	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",
-			"kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com" };
+			"kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com"};
-	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@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", "kuldeep.kumar@smartdukaan.com",
-			"niranjan.kala@smartdukaan.com" };
+			"niranjan.kala@smartdukaan.com"};
-	private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[] { "uday.singh@smartdukaan.com",
+	private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[]{"uday.singh@smartdukaan.com",
-			"kuldeep.kumar@smartdukaan.com" };
+			"kuldeep.kumar@smartdukaan.com"};
-	private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[] { "jyoti.rawat@smartdukaan.com",
+	private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[]{"jyoti.rawat@smartdukaan.com",
-			"sm@smartdukaan.com" };
+			"sm@smartdukaan.com"};
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
 	@Autowired
 	private ReporticoService reporticoService;
+			}
+		}
+	}
-	// Temporary Method
+	@Autowired
-	public void evaluateExcessSchemeOut() throws Exception {
-		Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
-		Map<Integer, Float> userAmountMap = new HashMap<>();
-		List<List<?>> rows = new ArrayList<>();
-		List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number",
-				"Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");
-		schemeRepository.selectAll().stream().forEach(x -> {
-			if (x.getType().equals(SchemeType.OUT)) {
-				List<SchemeInOut> sioList = schemeInOutRepository
-						.selectBySchemeIds(new HashSet<>(Arrays.asList(x.getId())));
-				if (x.getActiveTimestamp() != null) {
-					LocalDateTime endDateTime = x.getEndDateTime();
-					if (x.getExpireTimestamp() != null && x.getExpireTimestamp().isBefore(x.getEndDateTime())) {
-						endDateTime = x.getExpireTimestamp();
-					}
-					for (SchemeInOut sio : sioList) {
-						InventoryItem inventoryItem = null;
-						inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());
-						FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(
-								inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);
-						Optional<ScanRecord> record = scanRecordRepository
+	private ReporticoCacheTableRepository reporticoCacheTableRepository;
-								.selectByInventoryItemId(sio.getInventoryItemId()).stream()
-								.filter(y -> y.getType().equals(ScanType.SALE)).findFirst();
-						if (record.isPresent()) {
-							int fofoId = record.get().getFofoId();
-							if (record.get().getCreateTimestamp().isAfter(endDateTime)
-									|| record.get().getCreateTimestamp().isBefore(x.getStartDateTime())) {
-								if (!userAmountMap.containsKey(fofoId)) {
-									userAmountMap.put(fofoId, 0f);
-								}
-								userAmountMap.put(fofoId, sio.getAmount() + userAmountMap.get(fofoId));
-								try {
-									rows.add(Arrays.asList(x.getDescription(),
-											itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(),
-											userNameMap.get(fofoId), sio.getAmount(),
-											FormattingUtils.formatDate(sio.getCreateTimestamp()),
-											fofoOrder.getInvoiceNumber(),
-											FormattingUtils.formatDate(record.get().getCreateTimestamp()),
-											FormattingUtils.formatDate(x.getStartDateTime()),
-											FormattingUtils.formatDate(x.getEndDateTime()),
-											FormattingUtils.formatDate(x.getActiveTimestamp()),
-											FormattingUtils.formatDate(x.getExpireTimestamp())));
-								} catch (Exception e) {
-									e.printStackTrace();
-								}
-							}
-						}
-					}
-				}
-			}
-		});
-		userAmountMap.entrySet().stream()
-				.forEach(x -> LOGGER.info("{} to be deducted from {}({}) for wrongly disbursed due to technical error.",
-						x.getValue(), userNameMap.get(x.getKey())));
-		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
-		Utils.sendMailWithAttachment(googleMailSender,
-				new String[] { "amit.gupta@shop2020.in", "adeel.yazdani@smartdukaan.com" }, null,
-				"Partner Excess Amount", "PFA", "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));
-	}
 	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);
+		}
+	}
 	@Autowired
 	private PartnerStatsService partnerStatsService;
+	// Temporary Method
+	public void evaluateExcessSchemeOut() throws Exception {
+		Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
+		Map<Integer, Float> userAmountMap = new HashMap<>();
+		List<List<?>> rows = new ArrayList<>();
+		List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number",
+				"Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");
+		schemeRepository.selectAll().stream().forEach(x -> {
+			if (x.getType().equals(SchemeType.OUT)) {
+				List<SchemeInOut> sioList = schemeInOutRepository
+						.selectBySchemeIds(new HashSet<>(Arrays.asList(x.getId())));
+				if (x.getActiveTimestamp() != null) {
+					LocalDateTime endDateTime = x.getEndDateTime();
+					if (x.getExpireTimestamp() != null && x.getExpireTimestamp().isBefore(x.getEndDateTime())) {
+						endDateTime = x.getExpireTimestamp();
+					}
+					for (SchemeInOut sio : sioList) {
+						InventoryItem inventoryItem = null;
+						inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());
+						FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(
+								inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);
-	private ReporticoCacheTableRepository reporticoCacheTableRepository;
+						Optional<ScanRecord> record = scanRecordRepository
+								.selectByInventoryItemId(sio.getInventoryItemId()).stream()
+								.filter(y -> y.getType().equals(ScanType.SALE)).findFirst();
+						if (record.isPresent()) {
+							int fofoId = record.get().getFofoId();
+							if (record.get().getCreateTimestamp().isAfter(endDateTime)
+									|| record.get().getCreateTimestamp().isBefore(x.getStartDateTime())) {
+								if (!userAmountMap.containsKey(fofoId)) {
+									userAmountMap.put(fofoId, 0f);
+								}
+								userAmountMap.put(fofoId, sio.getAmount() + userAmountMap.get(fofoId));
+								try {
+									rows.add(Arrays.asList(x.getDescription(),
+											itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(),
+											userNameMap.get(fofoId), sio.getAmount(),
+											FormattingUtils.formatDate(sio.getCreateTimestamp()),
+											fofoOrder.getInvoiceNumber(),
+											FormattingUtils.formatDate(record.get().getCreateTimestamp()),
+											FormattingUtils.formatDate(x.getStartDateTime()),
+											FormattingUtils.formatDate(x.getEndDateTime()),
+											FormattingUtils.formatDate(x.getActiveTimestamp()),
+											FormattingUtils.formatDate(x.getExpireTimestamp())));
+								} catch (Exception e) {
+									e.printStackTrace();
+								}
+							}
+						}
+					}
+				}
+			}
+		});
+		userAmountMap.entrySet().stream()
+				.forEach(x -> LOGGER.info("{} to be deducted from {}({}) for wrongly disbursed due to technical error.",
+						x.getValue(), userNameMap.get(x.getKey())));
+		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
+		Utils.sendMailWithAttachment(googleMailSender,
+				new String[]{"amit.gupta@shop2020.in", "adeel.yazdani@smartdukaan.com"}, null,
+				"Partner Excess Amount", "PFA", "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));
+	}
 	public void fetchParnterStats() throws Exception {
 		Map<Integer, PartnerDetailModel> partnerStats = partnerStatsService.getAllPartnerStats();
 		ObjectOutputStream oos = null;
 		FileOutputStream fout = null;
+		}
 		ReporticoCacheTable rct = reporticoCacheTableRepository.selectByTableName("partnerStat");
 		if (rct == null) {
 			rct = new ReporticoCacheTable();
 			rct.setTableName("partnerStat");
+			rct.setLastCreatedTimestamp(LocalDateTime.now());
+			reporticoCacheTableRepository.persist(rct);
+		} else {
+			rct.setLastCreatedTimestamp(LocalDateTime.now());
+		}
-		rct.setLastCreatedTimestamp(LocalDateTime.now());
-		reporticoCacheTableRepository.persist(rct);
+	}
 	private class SaleRoles {
 		private List<String> l1;
 			InputStreamSource isr3 = reporticoService.getReportInputStreamSource(ReporticoProject.FOCO,
 					"focostockreport.xml", params);
 			Attachment attache = new Attachment(
 					"Franchise-stock-report" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv", isr3);
 			System.out.println(storeGuyEntry.getValue());
-			Utils.sendMailWithAttachments(googleMailSender, new String[] { storeGuyEntry.getKey() }, null,
+			Utils.sendMailWithAttachments(googleMailSender, new String[]{storeGuyEntry.getKey()}, null,
 					"Franchise Stock Report", "PFA", attache);
+		}
+	}
 				String body = String.format(
 						"Dear %s,\n Pls note that you haven't punched your attendance by 10:30am%s. You have been marked absent for half the day.\n\nRegards\nHR Team",
 						authUser.getFullName(),
 						(employeeAttendanceOptional == null || employeeAttendanceOptional.orElse(null) == null) ? ""
 								: "(Punched at "
-										+ FormattingUtils.format(employeeAttendanceOptional.get().getCreateTimestamp())
+								+ FormattingUtils.format(employeeAttendanceOptional.get().getCreateTimestamp())
-										+ ")");
+								+ ")");
-				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() },
+				Utils.sendMailWithAttachments(googleMailSender, new String[]{authUser.getEmailId()},
-						new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert", body);
+						new String[]{"jyoti.rawat@smartdukaan.com"}, "Attendance Alert", body);
+			}
+		}
+	}
+					}
+				}
+			}
 			if (body != null) {
-				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() },
+				Utils.sendMailWithAttachments(googleMailSender, new String[]{authUser.getEmailId()},
-						new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert", body);
+						new String[]{"jyoti.rawat@smartdukaan.com"}, "Attendance Alert", body);
+			}
+		}
 		this.sendMailToHR();
 					fofoStore.setActive(true);
 					fofoStoreRepository.persist(fofoStore);
 					LOGGER.info("inserted into InActiveFofoStore successfully");
-				}
-				else {
+				} else {
 					fofoStore.setActive(false);
 					fofoStore.setActiveTimeStamp(null);
 					fofoStoreRepository.persist(fofoStore);
 					LOGGER.info("inserted into InActiveFofoStore successfully");
+				}
 				rolledbackSios.stream()
 						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getReference(), x.getStoreCode(),
 								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))
 						.collect(Collectors.toList()));
-		Utils.sendMailWithAttachments(googleMailSender, new String[] { "amit.gupta@shop2020.in" }, null,
+		Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null,
 				"Partner Excess Amount Scheme In", "PFA",
-				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
+				new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
-						new Attachment("SchemeInRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
+						new Attachment("SchemeInRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});
 		throw new Exception();
+	}
 				rolledbackSios.stream()
 						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(),
 								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))
 						.collect(Collectors.toList()));
-		Utils.sendMailWithAttachments(googleMailSender, new String[] { "amit.gupta@shop2020.in" }, null,
+		Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null,
 				"Partner Excess Amount Scheme Out", "PFA",
-				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
+				new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
-						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
+						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});
 		throw new Exception();
+	}
 	public void dryRunSchemeOutReco1() throws Exception {
 		});
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
 				Arrays.asList("User Id", "Reference Type", "Reference", "Amount", "Description", "Timestamp"),
 				userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getReferenceType(),
-						x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))
+								x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))
 						.collect(Collectors.toList()));
 		ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(
 				Arrays.asList("Scheme ID", "SchemeType", "Store Code", "Serial Number", "Amount", "Created",
 						"Rolledback"),
 						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(),
 								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))
 						.collect(Collectors.toList()));
 		Utils.sendMailWithAttachments(googleMailSender,
-				new String[] { "amit.gupta@shop2020.in", "neeraj.gupta@smartdukaan.com" }, null,
+				new String[]{"amit.gupta@shop2020.in", "neeraj.gupta@smartdukaan.com"}, null,
 				"Partner Excess Amount", "PFA",
-				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
+				new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
-						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
+						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});
 		throw new Exception();
+	}
 		String timeString = "Today %s";
 		// Send yesterday's report
 		/*
 		 * if (now.getHour() < 13) { timeString = "Yesterday %s"; from =
 		 * now.minusDays(1).; now = from.with(LocalTime.MAX);
 		 *
 		 * }
 		 */
 		List<Integer> fofoIds = null;
 		if (fofoIdInt == null) {
 			fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId())
 			notificationService.sendNotification(sendNotificationModel);
+		}
 		// String saleReport = this.getDailySalesReportHtml(partnerSalesHeadersMap,
 		// saleTargetReportModelMap);
 		String statewiseSaleReport = this.getStateWiseSales(saleTargetReportModelMap, partnerSalesHeadersMap);
-		String cc[] = { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "amit.babu@smartdukaan.com",
+		String cc[] = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "amit.babu@smartdukaan.com",
-				"niranjan.kala@smartdukaan.com", "up.singh@smartdukaan.com", "sm@smartdukaan.com" };
+				"niranjan.kala@smartdukaan.com", "up.singh@smartdukaan.com", "sm@smartdukaan.com"};
 		String subject = String.format("Sale till %s", String.format(timeString, now.format(timeFormatter)));
 		// this.sendMailOfHtmlFomat("amit.gupta@smartukaan.com", saleReport, cc,
 		// subject);
 		this.sendMailOfHtmlFormat("amit.gupta@smartdukaan.com", statewiseSaleReport, cc, "Statewise" + subject);
 						CustomRetailer customRetailer = retailerService.getFofoRetailer(po.getFofoId());
 						Customer customer = customerRepository.selectById(po.getCustomerId());
 						String[] customerEmail = null;
 						if (customer.getEmailId() != null) {
-							customerEmail = new String[] { customer.getEmailId() };
+							customerEmail = new String[]{customer.getEmailId()};
+						}
 						List<String> bccTo = Arrays.asList("kamini.sharma@smartdukaan.com",
 								"tarun.verma@smartdukaan.com", "niranjan.kala@smartdukaan.com", "sm@smartdukaan.com",
 								"tejbeer.kaur@shop2020.in", customRetailer.getEmail());
 						List<String> authUserEmails = csService.getAuthUserByPartnerId(customRetailer.getPartnerId());
+		}
+	}
 	private String getStateWiseSales(Map<Integer, SaleTargetReportModel> saleTargetReportModelMap,
-			Map<Integer, FofoReportingModel> partnerSalesHeadersMap) throws Exception {
+									 Map<Integer, FofoReportingModel> partnerSalesHeadersMap) throws Exception {
 		List<FofoStore> stores = fofoStoreRepository.selectActiveStores();
 		Map<String, List<Integer>> stateMap = stores.stream().collect(Collectors
 				.groupingBy(x -> x.getCode().substring(0, 2), Collectors.mapping(x -> x.getId(), Collectors.toList())));
 		List<List<Serializable>> stateWiseSales = new ArrayList<>();
 		for (Map.Entry<String, List<Integer>> stateMapEntry : stateMap.entrySet()) {
+			}
 			/*
 			 * if (!focusedModelShortageList.isEmpty()) { String subject = "Stock Alert";
 			 * String messageText = this.getMessage(focusedModelShortageList);
 			 *
 			 * this.sendMailWithAttachments(subject, messageText,
 			 * customRetailer.getEmail()); String notificationMessage =
 			 * this.getNotificationMessage(focusedModelShortageList);
 			 *
 			 * LOGGER.info("notificationMessage" + notificationMessage);
 			 *
 			 * SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			 * sendNotificationModel.setCampaignName("Stock Alert");
 			 * sendNotificationModel.setTitle("Alert");
 			 * sendNotificationModel.setMessage(notificationMessage);
 			 * sendNotificationModel.setType("url"); sendNotificationModel.setUrl(
 			 * sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
 			 * sendNotificationModel.setMessageType(MessageType.notification); int userId =
 			 * userAccountRepository.selectUserIdByRetailerId(fofoId);
 			 * sendNotificationModel.setUserIds(Arrays.asList(userId));
 			 * notificationService.sendNotification(sendNotificationModel);
 			 *
 			 * }
 			 */
+		}
 		if (!focusedModelShortageReportMap.isEmpty()) {
 				try {
 					baos = FileUtil.getCSVByteStream(headers, entry.getValue());
 				} catch (Exception e2) {
 					e2.printStackTrace();
+				}
-				String[] sendToArray = new String[] {
+				String[] sendToArray = new String[]{
 						entry.getKey()
 				};
 			String subject = "Referral Request";
 			String messageText = this.getMessageForReferral(referrals);
 			MimeMessage message = mailSender.createMimeMessage();
 			MimeMessageHelper helper = new MimeMessageHelper(message, true);
-			String[] email = { "kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com" };
+			String[] email = {"kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com"};
 			helper.setSubject(subject);
 			helper.setText(messageText, true);
 			helper.setTo(email);
 			InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
 			helper.setFrom(senderAddress);
 			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) == null ? "N/A"
-							: authUserMap.get(EscalationType.L1).getFirstName())
+					: authUserMap.get(EscalationType.L1).getFirstName())
 					+ " ," + (authUserMap.get(EscalationType.L2) == null ? "N/A"
-							: authUserMap.get(EscalationType.L2).getFirstName())
+					: authUserMap.get(EscalationType.L2).getFirstName())
 					+ "</td>");
 			sb.append("</tr>");
+		}
 		sb.append("</tbody></table><br><br>");

Subversion Repositories SmartDukaan

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