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

 import java.util.stream.Collectors;
 import javax.mail.MessagingException;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
+import javax.xml.bind.DatatypeConverter;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.springframework.transaction.annotation.Transactional;
 import com.google.common.collect.Lists;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
-import com.mongodb.connection.Stream;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.enumuration.RechargeStatus;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.FocusedModelShortageModel;
 import com.spice.profitmandi.common.model.GstRate;
+import com.spice.profitmandi.common.model.PdfModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.RechargeCredential;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
+import com.spice.profitmandi.common.util.PdfUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.util.Utils.Attachment;
 import com.spice.profitmandi.dao.Interface.Campaign;
 import com.spice.profitmandi.dao.convertor.LocalDateTimeJsonConverter;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.dtr.DailyRecharge;
+import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
-import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
 import com.spice.profitmandi.dao.entity.dtr.PushNotifications;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProvider;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
-import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.fofo.ActivityType;
 import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
 import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.Refferal;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
-import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
-import com.spice.profitmandi.service.slab.TargetSlabService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.OrderStatus;
 	private DailyRechargeRepository dailyRechargeRepository;
 	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
-	@Autowired
-	private TargetSlabService targetService;
 	@Value("${prod}")
 	private boolean prod;
 	@Autowired
 	private StateGstRateRepository stateGstRateRepository;
 	public void sendPartnerInvestmentDetails() throws Exception {
 		this.sendPartnerInvestmentDetails(null);
+	}
-	public void sendTargetVsSalesReport(List<String> sendTo) throws Exception {
-		if (sendTo == null) {
-			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
-					"amit.gupta@shop2020.in", "hemant.kaura@smartdukaan.com", "amit.babu@smartdukaan.com",
-					"manish.gupta@smartdukaan.com");
-		}
-		Map<Integer, List<Serializable>> partnerSalesTargetRowsMap = targetService.getDailySaleReportVsTarget();
-		Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
-		List<String> headers = Arrays.asList("Code", "Firm Name", "State Manager", "Teritory Manager",
-				"Current Category", "Target Value", "Target Achieved", "Achived Percentage", "Remaining Target",
-				"Today's Target", "Today's achievement");
-		List<List<?>> rows = new ArrayList<>();
-		Map<Integer, List<? extends Serializable>> partnerRowMap = new HashMap<>();
-		for (Map.Entry<Integer, List<Serializable>> partnerSalesTargetRowEntry : partnerSalesTargetRowsMap.entrySet()) {
-			FofoReportingModel fofoReportingModel = partnerIdSalesHeadersMap.get(partnerSalesTargetRowEntry.getKey());
-			if (fofoReportingModel == null) {
-				LOGGER.warn("Could not find headers for partner ID - {}", partnerSalesTargetRowEntry.getKey());
-				continue;
-			}
-			List<Serializable> row = Arrays.asList(fofoReportingModel.getCode(), fofoReportingModel.getBusinessName(),
-					fofoReportingModel.getRegionalManager(), fofoReportingModel.getTerritoryManager());
-			row.addAll(partnerSalesTargetRowEntry.getValue());
-			partnerRowMap.put(partnerSalesTargetRowEntry.getKey(), row);
-			rows.add(row);
-		}
-		String fileName = "TargetVsSales-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
-		Map<String, Set<String>> storeGuysMap = csService.getAuthUserPartnerEmailMapping();
-		for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {
-			if (storeGuyEntry.getValue().size() == 0)
-				continue;
-			List<List<?>> storeGuyRows = storeGuyEntry.getValue().stream().filter(x -> partnerRowMap.containsKey(x))
-					.map(x -> partnerRowMap.get(x)).collect(Collectors.toList());
-			ByteArrayOutputStream authUserStream = FileUtil.getCSVByteStream(headers, storeGuyRows);
-			Attachment attache = new Attachment(fileName, new ByteArrayResource(authUserStream.toByteArray()));
-			System.out.println(storeGuyEntry.getValue());
-			Utils.sendMailWithAttachments(googleMailSender, new String[] { storeGuyEntry.getKey() }, null,
-					"Franchise Stock Report", "PFA", attache);
-		}
-		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
-		String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
-		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Target vs Sales Summary", "PFA", fileName,
-				new ByteArrayResource(baos.toByteArray()));
-	}
 	public void sendAgeingReport(String... sendTo) throws Exception {
 		InputStreamSource isr = reporticoService.getReportInputStreamSource(ReporticoProject.WAREHOUSENEW,
 				"itemstockageing.xml");
 		InputStreamSource isr1 = reporticoService.getReportInputStreamSource(ReporticoProject.FOCO,
 				insurancePolicyRepository.selectQtyGroupByRetailerId(LocalDateTime.MIN, LocalDateTime.MAX));
 		LOGGER.info("SmartPhone Amount Summary --- {}",
 				fofoOrderItemRepository.selectSumAmountGroupByRetailer(LocalDateTime.MIN, LocalDateTime.MAX, 0, true));
 		LOGGER.info("Smartphone Qty Summary --- {}",
 				fofoOrderItemRepository.selectQtyGroupByRetailer(LocalDateTime.MIN, LocalDateTime.MAX, 0, true));
+		List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectAllByProviderId(3, Optional.of(false));
-		// LOGGER.info("{}", toffeeService.getAuthToken());
+		for(InsurancePolicy insurancePolicy : insurancePolicies) {
-		/*
-		 * LOGGER.info("{}", toffeeService.getProducts()); // LOGGER.info("{}",
+			String invoiceNumber = insurancePolicy.getInvoiceNumber();
-		 * toffeeService.getPincodes("36103000PR")); PremiumCalculationRequestModel pcrm
+			FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
-		 * = new PremiumCalculationRequestModel(); pcrm.setProductDetails("36103000PR");
+			PdfModel pdfModel = orderService.getInvoicePdfModel(fofoOrder.getId());
-		 * // pcrm.setProductDetails("36103000PR");
+			java.io.ByteArrayOutputStream byteArrayOutputStream = new java.io.ByteArrayOutputStream();
-		 * pcrm.setDurations(Arrays.asList("3 Months", "6 Months", "1 Year"));
+			PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
+			String pdfInvoiceString = "data:application/pdf;base64," + DatatypeConverter.printHexBinary(byteArrayOutputStream.toByteArray());
+			boolean attached = toffeeService.attachInvoice(insurancePolicy.getPolicyNumber().split("#")[1], pdfInvoiceString);
-		 * pcrm.setSumInsured("15000");
+			if(attached) {
-		 * System.out.println(toffeeService.getPremiumCalculation(pcrm));
+				insurancePolicy.setPosted(true);
-		 */
+			}
+		}
+	}
 	public void schemeRollback(List<String> schemeIds) throws Exception {
 		List<Integer> schemeIdsInt = schemeIds.stream().map(x -> Integer.parseInt(x)).collect(Collectors.toList());
 		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIdsInt, 0, schemeIds.size()).stream()

Subversion Repositories SmartDukaan

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