Subversion Repositories SmartDukaan

import javax.mail.internet.MimeMessage;

import javax.mail.internet.MimeMessage;

import org.apache.commons.codec.CharEncoding;

import org.apache.commons.codec.CharEncoding;

import org.apache.commons.io.IOUtils;

import org.apache.commons.io.IOUtils;

import org.apache.commons.io.output.ByteArrayOutputStream;

import org.apache.commons.io.output.ByteArrayOutputStream;

import org.apache.http.HttpResponse;

import org.apache.http.HttpResponse;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.apache.logging.log4j.Logger;

import org.apache.poi.EncryptedDocumentException;

import org.apache.poi.EncryptedDocumentException;

import org.apache.poi.openxml4j.exceptions.InvalidFormatException;

import org.apache.poi.openxml4j.exceptions.InvalidFormatException;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.core.io.ByteArrayResource;

import org.springframework.core.io.ByteArrayResource;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.mail.javamail.MimeMessageHelper;

import org.springframework.mail.javamail.MimeMessageHelper;

import org.springframework.stereotype.Component;

import org.springframework.stereotype.Component;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.transaction.annotation.Transactional;

	@Autowired

	@Autowired

	private PurchaseRepository purchaseRepository;

	private PurchaseRepository purchaseRepository;

	@Autowired

	@Autowired

	private SchemeService schemeService;

	private SchemeService schemeService;

	@Autowired

	@Autowired

	private ReporticoService reporticoService;

	private ReporticoService reporticoService;

	@Autowired

	@Autowired

	private PartnerInvestmentService partnerInvestmentService;

	private PartnerInvestmentService partnerInvestmentService;

	@Autowired

	@Autowired

	private TicketSubCategoryRepository ticketSubCategoryRepository;

	private TicketSubCategoryRepository ticketSubCategoryRepository;

	@Autowired

	@Autowired

	private Mongo mongoClient;

	private Mongo mongoClient;

	@Autowired

	@Autowired

	private UserAccountRepository userAccountRepository;

	private UserAccountRepository userAccountRepository;

	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);

	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);

			this.sendMailWithAttachmentsForPartners(fofoIdsAndCustomRetailer.get(fofoId).getEmail(), message, subject,

			this.sendMailWithAttachmentsForPartners(fofoIdsAndCustomRetailer.get(fofoId).getEmail(), message, subject,

					is);

					is);

		}

		}

	}

	}

	public void sendAgeingReport() throws Exception {

	public void sendAgeingReport() throws Exception {

		HttpResponse response = reporticoService.getReportFile(ReporticoProject.WAREHOUSENEW, "itemstockageing.xml");

		HttpResponse response = reporticoService.getReportFile(ReporticoProject.WAREHOUSENEW, "itemstockageing.xml");

		Utils.sendMailWithAttachments(googleMailSender, to, null, "Stock Aeging Report", "PFA", attachment);

		Utils.sendMailWithAttachments(googleMailSender, to, null, "Stock Aeging Report", "PFA", attachment);

	}

	}

	public void moveImeisToPriceDropImeis() throws Exception {

	public void moveImeisToPriceDropImeis() throws Exception {

		List<PriceDrop> priceDrops = priceDropRepository.selectAll();

		List<PriceDrop> priceDrops = priceDropRepository.selectAll();

		LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();

		LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();

		LocalDateTime endDate = LocalDate.now().atStartOfDay();

		LocalDateTime endDate = LocalDate.now().atStartOfDay();

		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);

		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);

		purchases.stream().forEach(purchase -> {

		purchases.stream().forEach(purchase -> {

			float amountToRollback = 0;

			float amountToRollback = 0;

			String description = "Adjustment of Duplicate Scheme for Purchase Invoice "

			String description = "Adjustment of Duplicate Scheme for Purchase Invoice "

					+ purchase.getPurchaseReference();

					+ purchase.getPurchaseReference();

			Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId())

			Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId())

					}

					}

				}

				}

			}

			}

			if (amountToRollback > 0) {

			if (amountToRollback > 0) {

				UserWalletHistory uwh = new UserWalletHistory();

				UserWalletHistory uwh = new UserWalletHistory();

				uwh.setAmount(Math.round(amountToRollback));

				uwh.setAmount(Math.round(amountToRollback));

				uwh.setDescription(description);

				uwh.setDescription(description);

				uwh.setTimestamp(LocalDateTime.now());

				uwh.setTimestamp(LocalDateTime.now());

				uwh.setReferenceType(WalletReferenceType.SCHEME_IN);

				uwh.setReferenceType(WalletReferenceType.SCHEME_IN);

						.map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(),

						.map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(),

								x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))

								x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))

						.collect(Collectors.toList()));

						.collect(Collectors.toList()));

		ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

		ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

				rolledbackSios.stream()

				rolledbackSios.stream()

						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getReference(), x.getStoreCode(),

						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getReference(), x.getStoreCode(),

								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))

								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))

						.collect(Collectors.toList()));

						.collect(Collectors.toList()));

		MimeMessage message = mailSender.createMimeMessage();

		MimeMessage message = mailSender.createMimeMessage();

		MimeMessageHelper helper = new MimeMessageHelper(message);

		MimeMessageHelper helper = new MimeMessageHelper(message);

		helper.setSubject(subject);

		helper.setSubject(subject);

		helper.setText(body, true);

		helper.setText(body, true);

		helper.setTo(email);

		helper.setTo(email);

		}

		}

		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");

		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");

		helper.setFrom(senderAddress);

		helper.setFrom(senderAddress);

		mailSender.send(message);

		mailSender.send(message);

	}

	}

		LocalDateTime from = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), 00, 00);

		LocalDateTime from = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), 00, 00);

		Map<Integer, Double> salesByFofoIdMap = new HashMap<>();

		Map<Integer, Double> salesByFofoIdMap = new HashMap<>();

		List<Integer> fofoIds = targetService.getfofoIdsFromfofoStore();

		List<Integer> fofoIds = targetService.getfofoIdsFromfofoStore();

		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository

		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository

				.selectAllGeEqAndLeEqStartDateAndEndDate(now);

				.selectAllGeEqAndLeEqStartDateAndEndDate(now);

		for (Integer fofoId : fofoIds) {

		for (Integer fofoId : fofoIds) {

			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBrtweenDate(fofoId, from, now);

			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBrtweenDate(fofoId, from, now);

			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {

			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {

				Map<Integer, Float> targetValues = targetService.getTargetValueByFofoIdAndTargetId(fofoId,

				Map<Integer, Float> targetValues = targetService.getTargetValueByFofoIdAndTargetId(fofoId,

						partnerTargetDetail.getId());

						partnerTargetDetail.getId());

				if (targetValues.size() == 0) {

				if (targetValues.size() == 0) {

					break;

					break;

				}

				}

			}

			}

			NotificationCampaigns notification = new NotificationCampaigns();

			NotificationCampaigns notification = new NotificationCampaigns();

			notification.setName("Today's Sale");

			notification.setName("Today's Sale");

			}

			}

			notification.setType("Url");

			notification.setType("Url");

			notification.setUrl("http://app.profitmandi.com/pages/home/dashboard");

			notification.setUrl("http://app.profitmandi.com/pages/home/dashboard");

			LOGGER.info("SELECT distinct d1.user_id from devices d1 left join devices d2 on"

			LOGGER.info("SELECT distinct d1.user_id from devices d1 left join devices d2 on"

			notification.setExpiresat(LocalDateTime.now().plusDays(1).toEpochSecond(ZoneOffset.UTC) * 1000);

			notification.setExpiresat(LocalDateTime.now().plusDays(1).toEpochSecond(ZoneOffset.UTC) * 1000);

			notification.setStatus("active");

			notification.setStatus("active");

			notification.setSmsprocessed(0);

			notification.setSmsprocessed(0);

			notification.setNotification_processed(0);

			notification.setNotification_processed(0);

			notification.setNotification_type("GENERAL_NOTIFICATION");

			notification.setNotification_type("GENERAL_NOTIFICATION");

			mongoClient.persistNotificationCmpInfo(notification);

			mongoClient.persistNotificationCmpInfo(notification);

			salesByFofoIdMap.put(fofoId, sale);

			salesByFofoIdMap.put(fofoId, sale);

			LOGGER.info(sale);

			LOGGER.info(sale);

		}

		}

		LOGGER.info(saleReport);

		LOGGER.info(saleReport);

		String cc[] = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com",

		String cc[] = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com",

		String subject = "sale report till" + " " + now.format(timeFormatter);

		String subject = "sale report till" + " " + now.format(timeFormatter);

		this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc, subject);

		this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc, subject);

	}

	}

			throws ProfitMandiBusinessException {

			throws ProfitMandiBusinessException {

		StringBuilder sb = new StringBuilder();

		StringBuilder sb = new StringBuilder();

		sb.append("<html><body><p>Sale Report:</p><br/><table style='border:1px solid black ;padding: 5px';>");

		sb.append("<html><body><p>Sale Report:</p><br/><table style='border:1px solid black ;padding: 5px';>");

		sb.append("<tbody>\n" + "	    				<tr>\n"

		sb.append("<tbody>\n" + "	    				<tr>\n"

				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"

				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"

				+ "	    				</tr>");

				+ "	    				</tr>");

		for (Integer fofoId : salesByFofoIdMap.keySet()) {

		for (Integer fofoId : salesByFofoIdMap.keySet()) {

			sb.append("<tr>");

			sb.append("<tr>");

			sb.append("<td style='border:1px solid black;padding: 5px'>"

			sb.append("<td style='border:1px solid black;padding: 5px'>"

					+ retailerService.getFofoRetailer(fofoId).getBusinessName() + "</td>");

					+ retailerService.getFofoRetailer(fofoId).getBusinessName() + "</td>");

			}

			}

			sb.append("<td style='border:1px solid black;padding: 5px'>" + salesByFofoIdMap.get(fofoId) + "</td>");

			sb.append("<td style='border:1px solid black;padding: 5px'>" + salesByFofoIdMap.get(fofoId) + "</td>");

			sb.append("</tr>");

			sb.append("</tr>");

		}

		}

		sb.append("</tbody></table></body></html>");

		sb.append("</tbody></table></body></html>");

		return sb.toString();

		return sb.toString();

	}

	}

}

}