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

 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
+import javax.activation.DataSource;
 import javax.mail.MessagingException;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import org.apache.commons.codec.CharEncoding;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.apache.poi.EncryptedDocumentException;
+import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
+import org.apache.poi.ss.usermodel.Workbook;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.io.ByteArrayResource;
 import org.springframework.mail.javamail.JavaMailSender;
 						"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,
-			Map<String, InputStream> inputStreams)
+			InputStream is)
 			throws MessagingException, ProfitMandiBusinessException, IOException {
 		MimeMessage message = mailSender.createMimeMessage();
 		MimeMessageHelper helper = new MimeMessageHelper(message, true, CharEncoding.UTF_8);
 		helper.setSubject(subject);
 		helper.setText(body);
 		if (ccEmails != null) {
 			helper.setCc(ccEmails);
+		}
-		for (String attachment : inputStreams.keySet()) {
+		helper.addAttachment("DailySaleTargetReports_"+LocalDate.now()+".xls",new ByteArrayResource(IOUtils.toByteArray(is)));
-			helper.addAttachment(attachment + LocalDate.now() + ".xlsx",
+		helper.setTo(email);
-					new ByteArrayResource(IOUtils.toByteArray(inputStreams.get(attachment))));
+		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
+		helper.setFrom(senderAddress);
+		mailSender.send(message);
-		}
+	}
+	private void sendMailWithAttachmentsForPartners(String email, String body, String subject,
+			InputStream is)
+			throws MessagingException, ProfitMandiBusinessException, IOException {
+		MimeMessage message = mailSender.createMimeMessage();
+		MimeMessageHelper helper = new MimeMessageHelper(message, true, CharEncoding.UTF_8);
+		helper.setSubject(subject);
+		helper.setText(body);
+		helper.addAttachment("DailySaleTargetReports_"+LocalDate.now()+".xls",new ByteArrayResource(IOUtils.toByteArray(is)));
 		helper.setTo(email);
 		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
 		helper.setFrom(senderAddress);
 		mailSender.send(message);
+	}
 		LOGGER.info("message" + message);
 		if (salesHeadDetail.getName().equals("Kamal")) {
 			LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
 			String[] to = { salesHeadDetail.getEmail(), "mohinder.mutreja@smartdukaan.com" };
-			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
+			//this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
 		} else {
 			LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
 			String[] to = { salesHeadDetail.getEmail() };
-			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
+			//this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
+		}
+	}
 	public void sendMailToPartnerAboutTargetAndSales()
-			throws ProfitMandiBusinessException, MessagingException, IOException {
+			throws ProfitMandiBusinessException, MessagingException, IOException, EncryptedDocumentException, InvalidFormatException {
 		List<Integer> fofoIds = targetService.getfofoIdsFromfofoStore();
 		Map<String, InputStream> inputStreams = new HashMap<>();
 		Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = retailerService
 				.getFofoRetailers(new ArrayList<>(fofoIds));
+		List<InputStream> input=new ArrayList<>();
 		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
 				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
 		for (Integer fofoId : fofoIds) {
-			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {
-				Map<Integer, Float> foFoIdsAndTargetValues = targetService
-						.getAllTargetValues(partnerTargetDetail.getId());
-				if(foFoIdsAndTargetValues.get(fofoId)==null)
-				{
-					continue;
-				}
-				InputStream is=targetService.getDailySaleReportVsTargetForPartner(fofoId, partnerTargetDetail);
+			InputStream is=targetService.getDailySaleReportVsTargetForPartner(fofoId,partnerTargetDetails);
-				inputStreams.put(partnerTargetDetail.getTargetName(),is);
-			}
 			LOGGER.info("fofoId"+fofoId);
-			String[] email= {"govind.kumar@shop2020.in"};
+			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);
+			this.sendMailWithAttachmentsForPartners(email, message, subject, is);
+		}
+	}
+}

Subversion Repositories SmartDukaan

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