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

 	@Value("${think.walnut.digital.recharge.auth.key}")
 	private String thinkWalnutDigitalRechargeAuthKey;
 	@Autowired
 	private PurchaseRepository purchaseRepository;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
 	@Autowired
 	private DailyRechargeRepository dailyRechargeRepository;
 	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
 	@Autowired
 	private TargetSlabService targetService;
 	@Value("${prod}")
 	private boolean prod;
 	@Autowired
 	private OrderRepository orderRepository;
 	@Autowired
 	private JavaMailSender mailSender;
 	@Autowired
 	private PartnerTargetRepository partnerTargetRepository;
 	@Autowired
 	@Qualifier(value = "googleMailSender")
 	private JavaMailSender googleMailSender;
 	@Autowired
 	private InventoryService inventoryService;
 	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 	public void generateDailyRecharge() {
 		List<RechargeProviderCreditWalletHistory> allCreditHistory = rechargeProviderCreditWalletHistoryRepository
 		Utils.sendMailWithAttachment(googleMailSender, "adeel.yazdani@smartdukaan.com",
 				new String[] { "amandeep.singh@smartdukaan.com", "tarun.verma@smartdukaan.com",
 						"kamini.sharma@smartdukaan.com", "dhruv.kathpal@smartdukaan.com" },
 				"Partner Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+	}
-	private  void sendMailWithAttachments(String[] email,String[] ccEmails,String body,String subject,String attachment,InputStream is) throws MessagingException, ProfitMandiBusinessException, IOException
+	private void sendMailWithAttachments(String[] email, String[] ccEmails, String body, String subject,
-	{
+			Map<String, InputStream> inputStreams)
+			throws MessagingException, ProfitMandiBusinessException, IOException {
 		MimeMessage message = mailSender.createMimeMessage();
-    	MimeMessageHelper helper = new MimeMessageHelper(message,true,CharEncoding.UTF_8);
+		MimeMessageHelper helper = new MimeMessageHelper(message, true, CharEncoding.UTF_8);
-    	helper.setSubject(subject);
+		helper.setSubject(subject);
-    	helper.setText(body);
+		helper.setText(body);
-    	if(ccEmails !=null)
+		if (ccEmails != null) {
-    	{
-    	helper.setCc(ccEmails);
+			helper.setCc(ccEmails);
-    	}
+		}
+		for (String attachment : inputStreams.keySet()) {
-    	helper.addAttachment(attachment+LocalDate.now()+".xlsx",new ByteArrayResource(IOUtils.toByteArray(is)));
+			helper.addAttachment(attachment + LocalDate.now() + ".xlsx",
+					new ByteArrayResource(IOUtils.toByteArray(inputStreams.get(attachment))));
+		}
-    	helper.setTo(email);
+		helper.setTo(email);
-    	InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
+		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
-    	helper.setFrom(senderAddress);
+		helper.setFrom(senderAddress);
-    	mailSender.send(message);
+		mailSender.send(message);
+	}
-	public void sendMailToSalesHeadAboutTargetAndSales(SaleHeadDetails salesHeadDetail) throws MessagingException, ProfitMandiBusinessException, IOException
+	public void sendMailToSalesHeadAboutTargetAndSales(SaleHeadDetails salesHeadDetail)
-	{
+			throws MessagingException, ProfitMandiBusinessException, IOException {
-		List<PartnerTargetDetails> partnerTargetDetails=partnerTargetRepository.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
+		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
+				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
+		Map<String, InputStream> inputStreams = new HashMap<>();
-		for(PartnerTargetDetails partnerTargetDetail:partnerTargetDetails)
+		for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {
+			InputStream is = targetService.getDailySaleReportVsTargetForSaleHead(partnerTargetDetail,
+					salesHeadDetail.getName());
-		{
-			InputStream is=targetService.getDailySaleReportVsTargetForSaleHead(partnerTargetDetail,salesHeadDetail.getName());
+			inputStreams.put(partnerTargetDetail.getTargetName(), is);
+		}
+		String[] ccEmails = null;
-			//String[] ccEmails={"Tarun.verma@smartdukaan.com","Kamini.sharma@smartdukaan.com","chaitnaya.vats@smartdukaan.com","dhruv.kathpal@smartdukaan.com"};
+		// ccEmails={"Tarun.verma@smartdukaan.com","Kamini.sharma@smartdukaan.com","chaitnaya.vats@smartdukaan.com","dhruv.kathpal@smartdukaan.com"};
-			String[] ccEmails= null;
-			String subject="Daily Sales Report "+partnerTargetDetail.getTargetName();
+		String subject = "Daily Sales Report ";
-			String message = MessageFormat.format("{0} Sale Target summary for {1}",partnerTargetDetail.getTargetName(),LocalDate.now());
+		String message = MessageFormat.format("Sale Target summary for {0}", LocalDate.now());
-			LOGGER.info("message"+message);
+		LOGGER.info("message" + message);
-			if(salesHeadDetail.getName().equals("Kamal"))
+		if (salesHeadDetail.getName().equals("Kamal")) {
-			{
-				LOGGER.info("salesHeadDetail.getName()"+salesHeadDetail.getName());
+			LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
-				String[] to= {salesHeadDetail.getEmail(),"mohinder.mutreja@smartdukaan.com"};
+			String[] to = { salesHeadDetail.getEmail(), "mohinder.mutreja@smartdukaan.com" };
-				this.sendMailWithAttachments(to, ccEmails,message, subject,partnerTargetDetail.getTargetName(),is);
+			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
-			}
-			else
+		} else {
-			{
-				LOGGER.info("salesHeadDetail.getName()"+salesHeadDetail.getName());
+			LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
-			String[] to= {salesHeadDetail.getEmail()};
+			String[] to = { salesHeadDetail.getEmail() };
-			this.sendMailWithAttachments(to, ccEmails,message,subject,partnerTargetDetail.getTargetName(),is);
+			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
-			}
+		}
+	}
+	public void sendMailToPartnerAboutTargetAndSales()
-	public void sendMailToPartnerAboutTargetAndSales() throws ProfitMandiBusinessException, MessagingException, IOException
+			throws ProfitMandiBusinessException, MessagingException, IOException {
-	{
+		List<Integer> fofoIds = targetService.getfofoIdsFromfofoStore();
+		Map<String, InputStream> inputStreams = new HashMap<>();
+		Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = retailerService
+				.getFofoRetailers(new ArrayList<>(fofoIds));
-		List<PartnerTargetDetails> partnerTargetDetails=partnerTargetRepository.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
+		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
+				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
+		for (Integer fofoId : fofoIds) {
-		for(PartnerTargetDetails partnerTargetDetail:partnerTargetDetails)
+			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {
-		{
-			Map<Integer, Float> foFoIdsAndTargetValues=targetService.getAllTargetValues(partnerTargetDetail.getId());
+				Map<Integer, Float> foFoIdsAndTargetValues = targetService
-			Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = retailerService.getFofoRetailers(new ArrayList<>(foFoIdsAndTargetValues.keySet()));
+						.getAllTargetValues(partnerTargetDetail.getId());
-			for(Integer fofoId:foFoIdsAndTargetValues.keySet())
+				if(foFoIdsAndTargetValues.get(fofoId)==null)
-			{
+				{
+					continue;
+				}
 				InputStream is=targetService.getDailySaleReportVsTargetForPartner(fofoId, partnerTargetDetail);
-				LOGGER.info("fofoId"+fofoId);
-				String[] email= {"govind.kumar@shop2020.in"};
-				LOGGER.info(fofoIdsAndCustomRetailer.get(fofoId).getEmail());
-				String subject="Daily Sales Report "+" "+partnerTargetDetail.getTargetName();
+				inputStreams.put(partnerTargetDetail.getTargetName(),is);
-				String message = MessageFormat.format("{0} Sale Target summary for {1}",partnerTargetDetail.getTargetName(),LocalDate.now());
-				LOGGER.info(message);
-				this.sendMailWithAttachments(email, null,message, subject, partnerTargetDetail.getTargetName(),is);
+			}
+			LOGGER.info("fofoId"+fofoId);
+			String[] email= {"govind.kumar@shop2020.in"};
+			LOGGER.info(fofoIdsAndCustomRetailer.get(fofoId).getEmail());
+			String subject="Daily Sales Report";
+			String message = MessageFormat.format("Sale Target summary for {0}",LocalDate.now());
+			LOGGER.info(message);
+			this.sendMailWithAttachments(email, null,message, subject,inputStreams);
+		}
+	}
+}

Subversion Repositories SmartDukaan

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