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",
			"mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@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",
			"tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",
			"niranjan.kala@smartdukaan.com" };
 
	private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[] { "uday.singh@smartdukaan.com",
			"kuldeep.kumar@smartdukaan.com" };
 
	private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[] { "sm@smartdukaan.com",
			"sm@smartdukaan.com" };
 
	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
 
	@Autowired
	private ReporticoService reporticoService;

 
		List<FofoStore> stores = fofoStoreRepository.selectActiveStores();
		for (FofoStore store : stores) {
			int fofoId = store.getId();
 
			PartnerType startOfPreviousMonthPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId,
					startOfPreviousMonth);
			PartnerType todayPartnerType = partnerTypeChangeService.getTypeOnMonth(fofoId,
					YearMonth.from(startOfPreviousMonth.atStartOfDay()));
			if (!startOfPreviousMonthPartnerType.nextPartnerTypes().contains(todayPartnerType)) {
				continue;
			}

 
			}
		}
		if (upgradedCount > 0) {
			sendMailHtmlFormat(
					new String[] { "amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com",
							"neeraj.gupta@smartdukaan.com" },
					sb.toString(), null, "Few Partners Category have been Upgraded");
		} else {
			sendMailHtmlFormat(
					new String[] { "amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com",
							"neeraj.gupta@smartdukaan.com" },
					sb.toString(), null, "No partners Category have been upgraded today");
		}
	}
 
	@Autowired

				.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 {

		} else {
			rct.setLastCreatedTimestamp(LocalDateTime.now());
		}
	}
 
 
	public void processPriceDrop() throws Exception {
		List<PriceDrop> priceDrops = priceDropRepository.selectAllByDatesBetween(LocalDateTime.now(),
				LocalDateTime.now().minusYears(1));
		for (PriceDrop priceDrop : priceDrops) {
			if (priceDrop.getDropAmount() > 0) {
				priceDropService.processPriceDrop(priceDrop.getId(), true);
			}
		}

		if (sendTo == null) {
			for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
				List<List<?>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRowsMap.get(x))
						.filter(x -> x != null).collect(Collectors.toList());
				ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
				String[] sendToArray = new String[] { storeGuyEntry.getKey() };
				Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
						fileName, new ByteArrayResource(baos.toByteArray()));
			}
			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
					"neeraj.gupta@smartdukaan.com", "amit.gupta@shop2020.in", "manish.gupta@smartdukaan.com",

			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,
					"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())
										+ ")");
 
				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() },
						new String[] { "sm@smartdukaan.com" }, "Attendance Alert", body);
 
			}
		}
 
	}

					}
				}
 
			}
			if (body != null) {
				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() },
						new String[] { "sm@smartdukaan.com" }, "Attendance Alert", body);
			}
		}
 
		this.sendMailToHR();
 

				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,
				"Partner Excess Amount Scheme In", "PFA",
				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.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,
				"Partner Excess Amount Scheme Out", "PFA",
				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.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()))
						.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,
				"Partner Excess Amount", "PFA",
				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
 
		throw new Exception();
 
	}
 

			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", "niranjan.kala@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() };
						}
						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 {
		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()) {

				try {
					baos = FileUtil.getCSVByteStream(headers, entry.getValue());
				} catch (Exception e2) {
					e2.printStackTrace();
				}
				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" };
			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.L2) == null ? "N/A"
							: authUserMap.get(EscalationType.L2).getFirstName())
					+ "</td>");
 
			sb.append("</tr>");
		}
		sb.append("</tbody></table><br><br>");

				for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping()
						.entrySet()) {
					List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
							.map(x -> partnerCollectionRemarksMap.get(x)).filter(x -> x != null)
							.collect(Collectors.toList());
					String subject = "UNCONTACTABLE PARTNERS";
					String messageText = this.getMessageForUncontacblePartner(filteredRows);
 
					MimeMessage message = mailSender.createMimeMessage();
					MimeMessageHelper helper = new MimeMessageHelper(message, true);
					String[] email = new String[] { storeGuyEntry.getKey() };
 
					helper.setSubject(subject);
					helper.setText(messageText, true);
					helper.setTo(email);
					InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com",

Subversion Repositories SmartDukaan

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

Rev 30644		Rev 30752
Line 236...		Line 236...
236	`private ServiceConfigRepository serviceConfigRepository;`	236	`private ServiceConfigRepository serviceConfigRepository;`
237		237
238	`@Value("${delhivery.tracking.token}")`	238	`@Value("${delhivery.tracking.token}")`
239	`private String token;`	239	`private String token;`
240		240
241	`private static final String[] STOCK_AGEING_MAIL_LIST = new String[]{"uday.singh@smartudkaan.com",`	241	`private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "uday.singh@smartudkaan.com",`
242	`"mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com",`	242	`"mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com",`
243	`"kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com"};`	243	`"kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com" };`
244		244
245	`private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[]{"kamini.sharma@smartdukaan.com",`	245	`private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",`
246	`"tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",`	246	`"tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",`
247	`"niranjan.kala@smartdukaan.com"};`	247	`"niranjan.kala@smartdukaan.com" };`
248		248
249	`private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[]{"uday.singh@smartdukaan.com",`	249	`private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[] { "uday.singh@smartdukaan.com",`
250	`"kuldeep.kumar@smartdukaan.com"};`	250	`"kuldeep.kumar@smartdukaan.com" };`
251		251
252	`private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[]{"sm@smartdukaan.com",`	252	`private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[] { "sm@smartdukaan.com",`
253	`"sm@smartdukaan.com"};`	253	`"sm@smartdukaan.com" };`
254		254
255	`private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);`	255	`private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);`
256		256
257	`@Autowired`	257	`@Autowired`
258	`private ReporticoService reporticoService;`	258	`private ReporticoService reporticoService;`
Line 676...		Line 676...
676		676
677	`List<FofoStore> stores = fofoStoreRepository.selectActiveStores();`	677	`List<FofoStore> stores = fofoStoreRepository.selectActiveStores();`
678	`for (FofoStore store : stores) {`	678	`for (FofoStore store : stores) {`
679	`int fofoId = store.getId();`	679	`int fofoId = store.getId();`
680		680
681	`PartnerType startOfPreviousMonthPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId, startOfPreviousMonth);`	681	`PartnerType startOfPreviousMonthPartnerType = partnerTypeChangeService.getTypeOnDate(fofoId,`
-		682	`startOfPreviousMonth);`
682	`PartnerType todayPartnerType = partnerTypeChangeService.getTypeOnMonth(fofoId,`	683	`PartnerType todayPartnerType = partnerTypeChangeService.getTypeOnMonth(fofoId,`
683	`YearMonth.from(startOfPreviousMonth.atStartOfDay()));`	684	`YearMonth.from(startOfPreviousMonth.atStartOfDay()));`
684	`if (!startOfPreviousMonthPartnerType.nextPartnerTypes().contains(todayPartnerType)) {`	685	`if (!startOfPreviousMonthPartnerType.nextPartnerTypes().contains(todayPartnerType)) {`
685	`continue;`	686	`continue;`
686	`}`	687	`}`
Line 726...		Line 727...
726		727
727	`}`	728	`}`