Rev 25759 | Rev 25806 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
package com.smartdukaan.cron.scheduled;import java.io.IOException;import java.io.Serializable;import java.sql.Timestamp;import java.time.LocalDate;import java.time.LocalDateTime;import java.time.LocalTime;import java.time.ZoneOffset;import java.time.format.DateTimeFormatter;import java.time.temporal.ChronoUnit;import java.util.ArrayList;import java.util.Arrays;import java.util.Collections;import java.util.HashMap;import java.util.HashSet;import java.util.List;import java.util.Map;import java.util.Optional;import java.util.Set;import java.util.stream.Collectors;import javax.mail.MessagingException;import javax.mail.internet.InternetAddress;import javax.mail.internet.MimeMessage;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.apache.http.entity.StringEntity;import org.apache.http.impl.client.CloseableHttpClient;import org.apache.http.impl.client.HttpClients;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.json.JSONObject;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.core.io.InputStreamSource;import org.springframework.mail.javamail.JavaMailSender;import org.springframework.mail.javamail.MimeMessageHelper;import org.springframework.stereotype.Component;import org.springframework.transaction.annotation.Transactional;import com.google.common.collect.Lists;import com.google.gson.Gson;import com.google.gson.GsonBuilder;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.ProfitMandiConstants;import com.spice.profitmandi.common.model.RechargeCredential;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.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.dtr.DailyRecharge;import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;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.UserCampaign;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.fofo.FofoStore;import com.spice.profitmandi.dao.entity.fofo.InventoryItem;import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;import com.spice.profitmandi.dao.entity.fofo.Purchase;import com.spice.profitmandi.dao.entity.fofo.ScanRecord;import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;import com.spice.profitmandi.dao.entity.transaction.PriceDrop;import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;import com.spice.profitmandi.dao.entity.transaction.UserWallet;import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;import com.spice.profitmandi.dao.entity.user.Address;import com.spice.profitmandi.dao.entity.user.Device;import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;import com.spice.profitmandi.dao.enumuration.cs.EscalationType;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.dao.repository.auth.AuthRepository;import com.spice.profitmandi.dao.repository.catalog.DeviceRepository;import com.spice.profitmandi.dao.repository.catalog.FocusedModelRepository;import com.spice.profitmandi.dao.repository.catalog.ItemRepository;import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;import com.spice.profitmandi.dao.repository.cs.CsService;import com.spice.profitmandi.dao.repository.cs.PositionRepository;import com.spice.profitmandi.dao.repository.dtr.DailyRechargeRepository;import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;import com.spice.profitmandi.dao.repository.dtr.Mongo;import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;import com.spice.profitmandi.dao.repository.dtr.PushNotificationRepository;import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;import com.spice.profitmandi.dao.repository.dtr.UserCampaignRepository;import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;import com.spice.profitmandi.dao.repository.transaction.OrderRepository;import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;import com.spice.profitmandi.dao.repository.user.AddressRepository;import com.spice.profitmandi.dao.repository.user.UserRepository;import com.spice.profitmandi.service.PartnerInvestmentService;import com.spice.profitmandi.service.integrations.toffee.ToffeeService;import com.spice.profitmandi.service.integrations.toffee.model.PremiumCalculationRequestModel;import com.spice.profitmandi.service.inventory.InventoryService;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;import in.shop2020.model.v1.order.WalletReferenceType;;@Component@Transactional(rollbackFor = Throwable.class)public class ScheduledTasks {@Value("${oxigen.recharge.transaction.url}")private String oxigenRechargeTransactionUrl;@Value("${oxigen.recharge.enquiry.url}")private String oxigenRechargeEnquiryUrl;@Autowiredprivate PartnerTypeChangeService partnerTypeChangeService;@Autowiredprivate AuthRepository authRepository;@Autowiredprivate PriceDropService priceDropService;@Autowiredprivate CsService csService;@Autowiredprivate ToffeeService toffeeService;@Value("${oxigen.recharge.auth.key}")private String oxigenRechargeAuthKey;@Value("${oxigen.recharge.validation.url}")private String oxigenRechargeValidationUrl;@Value("${oxigen.recharge.validation.auth.key}")private String oxigenRechargeValidationAuthKey;@Value("${think.walnut.digital.recharge.transaction.mobile.url}")private String thinkWalnutDigitalRechargeTransactionMobileUrl;@Value("${think.walnut.digital.recharge.transaction.dth.url}")private String thinkWalnutDigitalRechargeTransactionDthUrl;@Value("${think.walnut.digital.recharge.enquiry.url}")private String thinkWalnutDigitalRechargeEnquiryUrl;@Value("${think.walnut.digital.recharge.balance.url}")private String thinkWalnutDigitalRechargeBalanceUrl;@Value("${think.walnut.digital.recharge.username}")private String thinkWalnutDigitalRechargeUserName;@Value("${think.walnut.digital.recharge.password}")private String thinkWalnutDigitalRechargePassword;@Value("${think.walnut.digital.recharge.auth.key}")private String thinkWalnutDigitalRechargeAuthKey;@Autowiredprivate PurchaseRepository purchaseRepository;@Autowiredprivate PriceDropIMEIRepository priceDropIMEIRepository;@AutowiredPriceDropRepository priceDropRepository;@Autowiredprivate SchemeService schemeService;private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "amod.sen@smartdukaan.com","adeel.yazdani@smartdukaan.com", "manoj.singh@smartdukaan.com", "kamini.sharma@smartdukaan.com","mohinder.mutreja@smartdukaan.com", " ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com","chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com" };private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com","tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com" };private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);@Autowiredprivate ReporticoService reporticoService;@Autowiredprivate PartnerInvestmentService partnerInvestmentService;@Autowiredprivate PositionRepository positionRepository;@Autowiredprivate FofoOrderItemRepository fofoOrderItemRepository;@Autowiredprivate PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;@Autowiredprivate SchemeInOutRepository schemeInOutRepository;@Autowiredprivate RechargeTransactionRepository rechargeTransactionRepository;@Autowiredprivate CustomerAddressRepository customerAddressRepository;@Autowiredprivate RechargeProviderCreditWalletHistoryRepository rechargeProviderCreditWalletHistoryRepository;@Autowiredprivate FofoLineItemRepository fofoLineItemRepository;@Autowiredprivate FofoOrderRepository fofoOrderRepository;@Autowiredprivate UserWalletHistoryRepository userWalletHistoryRepository;@Autowiredprivate UserWalletRepository userWalletRepository;@Autowiredprivate InventoryItemRepository inventoryItemRepository;@Autowiredprivate WalletService walletService;@Autowiredprivate ThinkWalnutDigitalRechargeProviderService thinkWalnutDigitalRechargeProviderService;@Autowiredprivate OxigenRechargeProviderService oxigenRechargeProviderService;@Autowiredprivate RechargeProviderRepository rechargeProviderRepository;@Autowiredprivate ScanRecordRepository scanRecordRepository;@Autowiredprivate DailyRechargeRepository dailyRechargeRepository;@Autowiredprivate FofoStoreRepository fofoStoreRepository;@Autowiredprivate TargetSlabService targetService;@Value("${prod}")private boolean prod;@Autowiredprivate RetailerService retailerService;@Autowiredprivate TransactionService transactionService;@Autowiredprivate ItemRepository itemRepository;@Autowiredprivate OrderRepository orderRepository;@Autowiredprivate OrderService orderService;@Autowiredprivate SchemeRepository schemeRepository;@Autowiredprivate JavaMailSender mailSender;@Autowiredprivate PartnerTargetRepository partnerTargetRepository;@Autowired@Qualifier(value = "googleMailSender")private JavaMailSender googleMailSender;@Autowiredprivate InventoryService inventoryService;@Autowiredprivate AddressRepository addressRepository;@Autowiredprivate RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;@Autowiredprivate Mongo mongoClient;@Autowiredprivate DeviceRepository deviceRepository;@Autowiredprivate PushNotificationRepository pushNotificationRepository;@Autowiredprivate NotificationCampaignRepository notificationCampaignRepository;@Autowiredprivate CurrentInventorySnapshotRepository currentInventorySnapshotRepository;@Autowiredprivate FocusedModelRepository focusedModelRepository;@Autowiredprivate UserAccountRepository userAccountRepository;@Autowiredprivate UserRepository userRepository;@Autowiredprivate UserCampaignRepository userCampaignRepository;@Autowiredprivate Gson gson;private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);private String FCM_URL = "https://fcm.googleapis.com/fcm/send";private String FCM_API_KEY = "AAAASAjNcn4:APA91bG6fWRIgYJI0L9gCjP5ynaXz2hJHYKtD9dfH7Depdv31Nd9APJwhx-OPkAJ1WSz4BGNYG8lHThLFSjDGFxIwUZv241YcAJEGDLgt86mxq9FXJe-yBRu-S0_ZwHqmX-QaVKl5F_A";public void generateDailyRecharge() {List<RechargeProviderCreditWalletHistory> allCreditHistory = rechargeProviderCreditWalletHistoryRepository.selectAll(0, 2000);List<RechargeProvider> rechargeProviders = rechargeProviderRepository.selectAll();rechargeProviders.stream().forEach(x -> x.setAmount(0));rechargeProviders.stream().forEach(x -> {Map<LocalDate, List<RechargeProviderCreditWalletHistory>> dateWiseProviderCreditsMap = allCreditHistory.stream().filter(z -> z.getProviderId() == x.getId()).collect(Collectors.groupingBy(x1 -> x1.getReceiveTimestamp().toLocalDate()));LOGGER.info("dateWiseProviderCreditsMap -- {}", dateWiseProviderCreditsMap);LocalDate endDate = LocalDate.now().plusDays(1);float previousDayClosing = 0;LocalDate date = LocalDate.of(2018, 4, 6);while (date.isBefore(endDate)) {List<RechargeTransaction> dateWiseRechargeTransactions = rechargeTransactionRepository.selectAllBetweenTimestamp(Arrays.asList(RechargeStatus.values()), date.atStartOfDay(),date.plusDays(1).atStartOfDay());List<RechargeTransaction> successfulTransactions = dateWiseRechargeTransactions.stream().filter(y -> y.getStatus().equals(RechargeStatus.SUCCESS)).collect(Collectors.toList());float dailyAmount = 0;float totalCommission = 0;for (RechargeTransaction rechargeTransaction : successfulTransactions) {if (rechargeTransaction.getProviderId() == x.getId()) {dailyAmount += rechargeTransaction.getAmount();totalCommission += rechargeTransaction.getCommission();}}List<RechargeProviderCreditWalletHistory> rechargeHistoryList = dateWiseProviderCreditsMap.get(date);float dailyWalletRecharge = 0;if (rechargeHistoryList != null) {for (RechargeProviderCreditWalletHistory rechargeProviderCreditWalletHistory : rechargeHistoryList) {if (rechargeProviderCreditWalletHistory.getProviderId() == x.getId()) {dailyWalletRecharge += rechargeProviderCreditWalletHistory.getAmount();}}}if (dailyAmount > 0 || dailyWalletRecharge > 0) {DailyRecharge dailyRecharge = null;try {dailyRecharge = dailyRechargeRepository.selectByProviderIdAndCreateDate(x.getId(), date);} catch (Exception e) {LOGGER.info("Could not find Recharge entry");}if (dailyRecharge == null) {dailyRecharge = new DailyRecharge();dailyRecharge.setCreateDate(date);}dailyRecharge.setOpeningBalance(previousDayClosing);dailyRecharge.setProviderId(x.getId());dailyRecharge.setWalletRechargeAmount(dailyWalletRecharge);dailyRecharge.setTotalAmount(dailyAmount);dailyRecharge.setTotalCommission(totalCommission);float closingBalance = dailyRecharge.getOpeningBalance() + dailyWalletRecharge - dailyAmount;dailyRecharge.setClosingBalance(closingBalance);dailyRechargeRepository.persist(dailyRecharge);x.setAmount(x.getAmount() + dailyRecharge.getClosingBalance() - dailyRecharge.getOpeningBalance());previousDayClosing = dailyRecharge.getClosingBalance();}date = date.plusDays(1);}rechargeProviderRepository.persist(x);});LOGGER.info("finished generating daily recharge");}public void reconcileRecharge() throws Exception {LocalDateTime fromDate = LocalDateTime.now().truncatedTo(ChronoUnit.DAYS).minusDays(30);LocalDateTime toDate = LocalDateTime.now().truncatedTo(ChronoUnit.DAYS);List<RechargeStatus> nonSuccessRechargeStatuses = new ArrayList<>(Arrays.asList(RechargeStatus.values()));LOGGER.info("nonSuccessRechargeStatuses {} ", nonSuccessRechargeStatuses);nonSuccessRechargeStatuses.remove(RechargeStatus.SUCCESS);nonSuccessRechargeStatuses.remove(RechargeStatus.FAILED);RechargeCredential thinkWalnutDigitalRechargeEnquiryCredential = new RechargeCredential();thinkWalnutDigitalRechargeEnquiryCredential.setRechargeUrl(thinkWalnutDigitalRechargeEnquiryUrl);thinkWalnutDigitalRechargeEnquiryCredential.setRechargeUserName(thinkWalnutDigitalRechargeUserName);thinkWalnutDigitalRechargeEnquiryCredential.setRechargePassword(thinkWalnutDigitalRechargePassword);thinkWalnutDigitalRechargeEnquiryCredential.setRechargeAuthKey(thinkWalnutDigitalRechargeAuthKey);Map<String, RechargeStatus> requestRechargeStatusChanged = new HashMap<>();List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllBetweenTimestamp(nonSuccessRechargeStatuses, fromDate, toDate);for (RechargeTransaction rechargeTransaction : rechargeTransactions) {try {int providerId = rechargeTransaction.getProviderId();if (providerId == 1) {oxigenRechargeProviderService.doCheckStatusRequest(oxigenRechargeEnquiryUrl, oxigenRechargeAuthKey,rechargeTransaction);} else if (providerId == 2) {thinkWalnutDigitalRechargeProviderService.doCheckStatusRequest(thinkWalnutDigitalRechargeEnquiryCredential, rechargeTransaction);}if (rechargeTransaction.getStatus().equals(RechargeStatus.SUCCESS)|| rechargeTransaction.getStatus().equals(RechargeStatus.FAILED)) {requestRechargeStatusChanged.put(rechargeTransaction.getRequestId(),rechargeTransaction.getStatus());}} catch (Exception e) {LOGGER.info("Could not check status for Request {}", rechargeTransaction.getRequestId());}}LOGGER.info("Reconcile recharge ran successfully");}// TemporaryMethodpublic void migrateInvoice() {List<FofoOrder> fofoOrders = fofoOrderRepository.selectFromSaleDate(LocalDateTime.now().minusDays(3));Map<Integer, List<FofoOrder>> partnerOrdersMap = new HashMap<>();partnerOrdersMap = fofoOrders.stream().collect(Collectors.groupingBy(FofoOrder::getFofoId, Collectors.toList()));for (List<FofoOrder> orderList : partnerOrdersMap.values()) {int sequence = 0;String prefix = "";List<FofoOrder> sortedList = orderList.stream().sorted((x1, x2) -> x1.getId() - x2.getId()).collect(Collectors.toList());for (FofoOrder order : sortedList) {LOGGER.info("Order Id is {}, partner Id is {}", order.getId(), order.getFofoId());if (!order.getInvoiceNumber().contains("SEC")) {sequence = Integer.parseInt(order.getInvoiceNumber().split("/")[1]);prefix = order.getInvoiceNumber().split("/")[0];} else {sequence += 1;String invoiceNumber = prefix + "/" + sequence;order.setInvoiceNumber(invoiceNumber);fofoOrderRepository.persist(order);}}}}// Temporary Methodpublic void evaluateExcessSchemeOut() throws Exception {Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();Map<Integer, Float> userAmountMap = new HashMap<>();List<List<? extends Serializable>> rows = new ArrayList<>();List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number","Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");schemeRepository.selectAll().stream().forEach(x -> {if (x.getType().equals(SchemeType.OUT)) {List<SchemeInOut> sioList = schemeInOutRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(x.getId())));if (x.getActiveTimestamp() != null) {LocalDateTime endDateTime = x.getEndDateTime();if (x.getExpireTimestamp() != null && x.getExpireTimestamp().isBefore(x.getEndDateTime())) {endDateTime = x.getExpireTimestamp();}for (SchemeInOut sio : sioList) {InventoryItem inventoryItem = null;inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);Optional<ScanRecord> record = scanRecordRepository.selectByInventoryItemId(sio.getInventoryItemId()).stream().filter(y -> y.getType().equals(ScanType.SALE)).findFirst();if (record.isPresent()) {int fofoId = record.get().getFofoId();if (record.get().getCreateTimestamp().isAfter(endDateTime)|| record.get().getCreateTimestamp().isBefore(x.getStartDateTime())) {if (!userAmountMap.containsKey(fofoId)) {userAmountMap.put(fofoId, 0f);}userAmountMap.put(fofoId, sio.getAmount() + userAmountMap.get(fofoId));try {rows.add(Arrays.asList(x.getDescription(),itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(),userNameMap.get(fofoId), sio.getAmount(),FormattingUtils.formatDate(sio.getCreateTimestamp()),fofoOrder.getInvoiceNumber(),FormattingUtils.formatDate(record.get().getCreateTimestamp()),FormattingUtils.formatDate(x.getStartDateTime()),FormattingUtils.formatDate(x.getEndDateTime()),FormattingUtils.formatDate(x.getActiveTimestamp()),FormattingUtils.formatDate(x.getExpireTimestamp())));} catch (Exception e) {e.printStackTrace();}}}}}}});userAmountMap.entrySet().stream().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 processScheme(int offset, boolean dryRun) throws Exception {LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);LocalDateTime endDate = startDate.plusDays(30);processScheme(startDate, endDate, dryRun);}public void processScheme(int offset, int durationDays, boolean dryRun) throws Exception {LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);LocalDateTime endDate = startDate.plusDays(durationDays);processScheme(startDate, endDate, dryRun);}public void processScheme(boolean dryRun) throws Exception {LocalDateTime fromDate = LocalDateTime.now().minusDays(30);processScheme(fromDate, LocalDateTime.now(), dryRun);}public void processScheme(LocalDateTime startDate, LocalDateTime endDate, boolean dryRun) throws Exception {LOGGER.info("Started execution at {}", LocalDateTime.now());System.out.println("InventoryId\tSerialNumber\tItem Id\tScheme Id\tScheme Name\tScheme Type\tAmount Type\tDP\tTaxable\tScheme Amount\tAmount Paid");try {List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);for (Purchase purchase : purchases) {schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());}List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);for (FofoOrder fofoOrder : fofoOrders) {schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());}} catch (Exception e) {e.printStackTrace();throw e;}List<UserWalletHistory> uwhs = userWalletHistoryRepository.selectAllByDateType(startDate, endDate,Arrays.asList(WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));System.out.println("Amount\tReference\tReferenceType\tTimestamp\tDescription");for (UserWalletHistory uwh : uwhs) {System.out.println(String.format("%d\t%d\t%s\t%s\t%s", uwh.getAmount(), uwh.getReference(),uwh.getReferenceType(), uwh.getTimestamp().toString(), uwh.getDescription()));}LOGGER.info("Schemes process successfully.");if (dryRun) {throw new Exception();}}public void processRechargeCashback() throws Throwable {LocalDateTime cashbackTime = LocalDateTime.now();int referenceId = (int) Timestamp.valueOf(cashbackTime).getTime() / 1000;List<RechargeTransaction> pendingTransactions = rechargeTransactionRepository.getPendingCashBackRehargeTransactions();Map<Object, Double> totalRetailerCashbacks = pendingTransactions.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingDouble(x -> x.getCommission())));for (Map.Entry<Object, Double> totalRetailerCashback : totalRetailerCashbacks.entrySet()) {int retailerId = (Integer) totalRetailerCashback.getKey();float amount = totalRetailerCashback.getValue().floatValue();if (Math.round(amount) > 0) {walletService.addAmountToWallet(retailerId, referenceId, WalletReferenceType.CASHBACK,"Recharge Cashback", Math.round(amount));}}for (RechargeTransaction rt : pendingTransactions) {rt.setCashbackTimestamp(cashbackTime);rt.setCashbackReference(referenceId);rechargeTransactionRepository.persist(rt);}LOGGER.info("Cashbacks for Recharge processed Successfully");}private class SaleRoles {private List<String> l1;private List<String> l2;public SaleRoles() {l1 = new ArrayList<>();l2 = new ArrayList<>();}public List<String> getL1() {return l1;}public void setL1(List<String> l1) {this.l1 = l1;}public List<String> getL2() {return l2;}public void setL2(List<String> l2) {this.l2 = l2;}}public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {if (sendTo == null) {sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com","amit.gupta@shop2020.in", "amod.sen@smartdukaan.com");}LocalDate yesterDay = LocalDate.now().minusDays(1);List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "State Manager", "Teritory/Team Lead","Wallet Amount", "In Stock Amount", "Return In Transit Stock", "Unbilled Amount", "Grn Pending Amount","Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty");List<List<? extends Serializable>> rows = new ArrayList<>();Map<String, List<? extends Serializable>> partnerRow = new HashMap<>();Map<String, SaleRoles> partnerEmailSalesMap = this.getPartnerEmailSalesMap();for (FofoStore fofoStore : fofoStores) {PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoStore.getId(),1);partnerDailyInvestment.setDate(yesterDay);try {partnerDailyInvestmentRepository.persist(partnerDailyInvestment);} catch (Exception e) {// ignore the exceptions during persist}CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());if (retailer == null || partnerEmailSalesMap.get(retailer.getEmail()) == null) {LOGGER.info("Could not find retailer with retailer Id {}", fofoStore.getId());continue;}List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(),"SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]+", ""),StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(), ", "),StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(), ", "),partnerDailyInvestment.getWalletAmount(), partnerDailyInvestment.getInStockAmount(), 0,partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty());partnerRow.put(retailer.getEmail(), row);rows.add(row);}String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRow.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()));}ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",fileName, new ByteArrayResource(baos.toByteArray()));}private Map<String, SaleRoles> getPartnerEmailSalesMap() {Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();List<Position> positions = positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));Map<Integer, List<CustomRetailer>> positionIdRetailerMap = csService.getPositionCustomRetailerMap(positions);for (Position position : positions) {List<CustomRetailer> crList = positionIdRetailerMap.get(position.getId());if (crList == null)continue;for (CustomRetailer cr : crList) {if (!partnerEmailSalesMap.containsKey(cr.getEmail())) {partnerEmailSalesMap.put(cr.getEmail(), new SaleRoles());}SaleRoles saleRoles = partnerEmailSalesMap.get(cr.getEmail());AuthUser authUser = authUsersMap.get(position.getAuthUserId());String name = authUser.getFirstName() + " " + authUser.getLastName();if (position.getEscalationType().equals(EscalationType.L1)) {saleRoles.getL1().add(name);} else if (position.getEscalationType().equals(EscalationType.L2)) {saleRoles.getL2().add(name);}}}return partnerEmailSalesMap;}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", "amod.sen@smartdukaan.com");}List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now().minusDays(1));Map<String, List<? extends Serializable>> partnerSalesTargetRowsMap = new HashMap<>();for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {partnerSalesTargetRowsMap.putAll(targetService.getDailySaleReportVsTarget(partnerTargetDetail));}Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(new ArrayList<>(fofoStoresMap.keySet()));Map<String, CustomRetailer> customRetailerEmailMap = customRetailerMap.values().stream().collect(Collectors.toMap(x -> x.getEmail(), x -> x));Map<String, SaleRoles> partnerEmailSalesMap = this.getPartnerEmailSalesMap();List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "Current Category", "State Manager","Teritory Manager", "Team Leader", "Targeted Category", "Targeted Value", "Target Achieved","Achived Percentage", "Remaining Target", "Today's Target", "Today's achievement");List<List<? extends Serializable>> rows = new ArrayList<>();Map<String, List<Serializable>> partnerRowMap = new HashMap<>();for (Map.Entry<String, List<? extends Serializable>> partnerSalesTargetRowEntry : partnerSalesTargetRowsMap.entrySet()) {CustomRetailer retailer = customRetailerEmailMap.get(partnerSalesTargetRowEntry.getKey());FofoStore fofoStore = fofoStoresMap.get(retailer.getPartnerId());Serializable code = fofoStore.getCode();Serializable storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");Serializable businessName = retailer.getBusinessName();try {Serializable stateManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(),", ");Serializable territoryManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(),", ");List<Serializable> row = new ArrayList<>(Arrays.asList(code, businessName, storeName, stateManager, territoryManager));if (partnerSalesTargetRowsMap.get(retailer.getEmail()) != null) {row.addAll(partnerSalesTargetRowsMap.get(retailer.getEmail()));partnerRowMap.put(retailer.getEmail(), row);rows.add(row);}} catch (Exception e) {LOGGER.warn("Could not find partner with email - {}", retailer.getEmail());}}String fileName = "TargetVsSales-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRowMap.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, "Target vs Sales Summary", "PFA",fileName, new ByteArrayResource(baos.toByteArray()));}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,"ItemwiseOverallPendingIndent.xml");Attachment attachment = new Attachment("ageing-report-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr);Attachment attachment1 = new Attachment("pending-indent-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr1);Utils.sendMailWithAttachments(googleMailSender, STOCK_AGEING_MAIL_LIST, null, "Stock Ageing Report", "PFA",attachment);Utils.sendMailWithAttachments(googleMailSender, ITEMWISE_PENDING_INDENT_MAIL_LIST, null,"Itemwise Pending indent", "PFA", attachment1);// Reports to be sent to mapped partnersMap<String, Set<String>> storeGuysMap = csService.getAuthUserPartnerEmailMapping();for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {Map<String, String> params = new HashMap<>();if (storeGuyEntry.getValue().size() == 0)continue;params.put("MANUAL_email", String.join(",", storeGuyEntry.getValue()));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);}}public void sendAgeingReport() throws Exception {sendAgeingReport("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com","chaitnaya.vats@smartdukaan.com");}public void moveImeisToPriceDropImeis() throws Exception {List<PriceDrop> priceDrops = priceDropRepository.selectAll();for (PriceDrop priceDrop : priceDrops) {priceDropService.priceDropStatus(priceDrop.getId());}}public void walletmismatch() throws Exception {LocalDate curDate = LocalDate.now();List<PartnerDailyInvestment> pdis = partnerDailyInvestmentRepository.selectAll(curDate.minusDays(2));System.out.println(pdis.size());for (PartnerDailyInvestment pdi : pdis) {int fofoId = pdi.getFofoId();for (PartnerDailyInvestment investment : Lists.reverse(partnerDailyInvestmentRepository.selectAll(fofoId, null, null))) {float statementAmount = walletService.getOpeningTill(fofoId,investment.getDate().plusDays(1).atTime(LocalTime.of(4, 0)));CustomRetailer retailer = retailerService.getFofoRetailer(fofoId);LOGGER.info("{}\t{}\t{}\t{}\t{}", fofoId, retailer.getBusinessName(), retailer.getMobileNumber(),investment.getDate().toString(), investment.getWalletAmount(), statementAmount);}}}public void gst() throws Exception {List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(LocalDate.of(2019, 1, 26).atStartOfDay(),LocalDate.of(2019, 1, 27).atTime(LocalTime.MAX));for (FofoOrder fofoOrder : fofoOrders) {int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(fofoOrder.getFofoId());Address retailerAddress = addressRepository.selectById(retailerAddressId);CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());Integer stateId = null;if (customerAddress.getState().equals(retailerAddress.getState())) {try {stateId = Long.valueOf(Utils.getStateInfo(customerAddress.getState()).getId()).intValue();} catch (Exception e) {LOGGER.error("Unable to get state rates");}}Map<Integer, GstRate> itemIdStateTaxRateMap = null;Map<Integer, Float> itemIdIgstTaxRateMap = null;List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());Set<Integer> itemIds = fofoOrderItems.stream().map(x -> x.getItemId()).collect(Collectors.toSet());if (stateId != null) {itemIdStateTaxRateMap = Utils.getStateTaxRate(new ArrayList<>(itemIds), stateId);} else {itemIdIgstTaxRateMap = Utils.getIgstTaxRate(new ArrayList<>(itemIds));}for (FofoOrderItem foi : fofoOrderItems) {if (stateId == null) {foi.setIgstRate(itemIdIgstTaxRateMap.get(foi.getItemId()));} else {foi.setCgstRate(itemIdStateTaxRateMap.get(foi.getItemId()).getCgstRate());foi.setSgstRate(itemIdStateTaxRateMap.get(foi.getItemId()).getSgstRate());}fofoOrderItemRepository.persist(foi);}}}public void schemewalletmismatch() {LocalDate dateToReconcile = LocalDate.of(2018, 4, 1);while (dateToReconcile.isBefore(LocalDate.now())) {reconcileSchemes(dateToReconcile);// reconcileOrders(dateTime);// reconcileRecharges(dateTime);dateToReconcile = dateToReconcile.plusDays(1);}}private void reconcileSchemes(LocalDate date) {LocalDateTime startDate = date.atStartOfDay();LocalDateTime endDate = startDate.plusDays(1);List<SchemeInOut> siosCreated = schemeInOutRepository.selectAllByCreateDate(startDate, endDate);List<SchemeInOut> siosRefunded = schemeInOutRepository.selectAllByRefundDate(startDate, endDate);double totalSchemeDisbursed = siosCreated.stream().mapToDouble(x -> x.getAmount()).sum();double totalSchemeRolledback = siosRefunded.stream().mapToDouble(x -> x.getAmount()).sum();double netSchemeDisbursed = totalSchemeDisbursed - totalSchemeRolledback;List<WalletReferenceType> walletReferenceTypes = Arrays.asList(WalletReferenceType.SCHEME_IN,WalletReferenceType.SCHEME_OUT);List<UserWalletHistory> history = userWalletHistoryRepository.selectAllByDateType(startDate, endDate,walletReferenceTypes);double schemeAmountWalletTotal = history.stream().mapToDouble(x -> x.getAmount()).sum();if (Math.abs(netSchemeDisbursed - schemeAmountWalletTotal) > 10d) {LOGGER.info("Scheme Amount mismatched for Date {}", date);Map<Integer, Double> inventoryItemSchemeIO = siosCreated.stream().collect(Collectors.groupingBy(x -> x.getInventoryItemId(), Collectors.summingDouble(SchemeInOut::getAmount)));Map<Integer, Double> userSchemeMap = inventoryItemRepository.selectByIds(inventoryItemSchemeIO.keySet()).stream().collect(Collectors.groupingBy(x -> x.getFofoId(),Collectors.summingDouble(x -> inventoryItemSchemeIO.get(x.getId()))));Map<Integer, Double> inventoryItemSchemeIORefunded = siosRefunded.stream().collect(Collectors.groupingBy(x -> x.getInventoryItemId(), Collectors.summingDouble(SchemeInOut::getAmount)));Map<Integer, Double> userSchemeRefundedMap = inventoryItemRepository.selectByIds(inventoryItemSchemeIORefunded.keySet()).stream().collect(Collectors.groupingBy(x -> x.getFofoId(),Collectors.summingDouble(x -> inventoryItemSchemeIORefunded.get(x.getId()))));Map<Integer, Double> finalUserSchemeAmountMap = new HashMap<>();for (Map.Entry<Integer, Double> schemeAmount : userSchemeMap.entrySet()) {}for (Map.Entry<Integer, Double> schemeAmount : userSchemeRefundedMap.entrySet()) {if (!finalUserSchemeAmountMap.containsKey(schemeAmount.getKey())) {finalUserSchemeAmountMap.put(schemeAmount.getKey(), schemeAmount.getValue());} else {finalUserSchemeAmountMap.put(schemeAmount.getKey(),finalUserSchemeAmountMap.get(schemeAmount.getKey()) + schemeAmount.getValue());}}Map<Integer, Integer> userWalletMap = userWalletRepository.selectByRetailerIds(finalUserSchemeAmountMap.keySet()).stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));Map<Integer, Double> walletAmountMap = history.stream().collect(Collectors.groupingBy(UserWalletHistory::getWalletId, Collectors.summingDouble((UserWalletHistory::getAmount))));for (Map.Entry<Integer, Double> userAmount : walletAmountMap.entrySet()) {double diff = Math.abs(finalUserSchemeAmountMap.get(userAmount.getKey()) - userAmount.getValue());if (diff > 5) {LOGGER.info("Partner scheme mismatched for Userid {}", userWalletMap.get(userAmount.getKey()));}}}}public void dryRunSchemeReco() throws Exception {Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));List<UserWalletHistory> userWalletHistory = new ArrayList<>();List<SchemeInOut> rolledbackSios = new ArrayList<>();Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));Set<String> serialNumbersConsidered = new HashSet<>();LocalDateTime startDate = LocalDate.of(2018, 3, 1).atStartOfDay();LocalDateTime endDate = LocalDate.now().atStartOfDay();List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);Map<Integer, String> storeNameMap = fofoStoreRepository.getStoresMap();purchases.stream().forEach(purchase -> {float amountToRollback = 0;String description = "Adjustment of Duplicate Scheme for Purchase Invoice "+ purchase.getPurchaseReference();Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId()).stream().filter(ii -> ii.getSerialNumber() != null).collect(Collectors.toMap(InventoryItem::getId, InventoryItem::getSerialNumber));if (inventorySerialNumberMap.size() > 0) {for (Map.Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {String serialNumber = inventorySerialNumberEntry.getValue();int inventoryItemId = inventorySerialNumberEntry.getKey();if (serialNumbersConsidered.contains(serialNumber)) {// This will rollback scheme for differenct orders for same serialList<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN)).collect(Collectors.toList());Collections.reverse(sios);for (SchemeInOut sio : sios) {sio.setRolledBackTimestamp(LocalDateTime.now());amountToRollback += sio.getAmount();// sio.setSchemeType(SchemeType.OUT);sio.setSerialNumber(serialNumber);rolledbackSios.add(sio);}description = description.concat(" " + serialNumber + " ");} else {serialNumbersConsidered.add(serialNumber);List<Integer> schemesConsidered = new ArrayList<>();List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN)).collect(Collectors.toList());Collections.reverse(sios);for (SchemeInOut sio : sios) {if (!schemesConsidered.contains(sio.getSchemeId())) {schemesConsidered.add(sio.getSchemeId());continue;}sio.setRolledBackTimestamp(LocalDateTime.now());amountToRollback += sio.getAmount();// sio.setSchemeType(SchemeType.OUT);sio.setSerialNumber(serialNumber);sio.setStoreCode(storeNameMap.get(purchase.getFofoId()));sio.setReference(purchase.getId());rolledbackSios.add(sio);}}}}if (amountToRollback > 0) {// Address address =// addressRepository.selectAllByRetailerId(purchase.getFofoId(), 0, 10).get(0);UserWalletHistory uwh = new UserWalletHistory();uwh.setAmount(Math.round(amountToRollback));uwh.setDescription(description);uwh.setTimestamp(LocalDateTime.now());uwh.setReferenceType(WalletReferenceType.SCHEME_IN);uwh.setReference(purchase.getId());uwh.setWalletId(userWalletMap.get(purchase.getFofoId()));uwh.setFofoId(purchase.getFofoId());uwh.setStoreCode(storeNameMap.get(purchase.getFofoId()));userWalletHistory.add(uwh);}});ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("User Id", "Store Code", "Reference Type", "Reference", "Amount", "Description","Timestamp"),userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(),x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(Arrays.asList("Scheme ID", "SchemeType", "Reference", "Store Code", "Serial Number", "Amount","Created", "Rolledback"),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();}public void dryRunOutSchemeReco() throws Exception {List<UserWalletHistory> userWalletHistory = new ArrayList<>();List<SchemeInOut> rolledbackSios = new ArrayList<>();Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));LocalDateTime startDate = LocalDate.of(2019, 5, 1).atStartOfDay();LocalDateTime endDate = LocalDate.now().atStartOfDay();List<FofoOrder> allOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);// Collections.reverse(allOrders);// List<FofoOrder> allOrders =// List<FofoOrder> allOrders =// Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("UPGZ019/25"));Set<String> serialNumbersConsidered = new HashSet<>();allOrders.stream().forEach(fofoOrder -> {String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();Map<Integer, String> inventorySerialNumberMap = new HashMap<>();float amountToRollback = 0;List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());orderItems.forEach(x -> {inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null).collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));});if (inventorySerialNumberMap.size() > 0) {for (Map.Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {String serialNumber = inventorySerialNumberEntry.getValue();int inventoryItemId = inventorySerialNumberEntry.getKey();if (serialNumbersConsidered.contains(serialNumber)) {// This will rollback scheme for differenct orders for same serialList<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());Collections.reverse(sios);for (SchemeInOut sio : sios) {sio.setRolledBackTimestamp(LocalDateTime.now());amountToRollback += sio.getAmount();// sio.setSchemeType(SchemeType.OUT);sio.setSerialNumber(serialNumber);sio.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);sio.setReference(fofoOrder.getId());rolledbackSios.add(sio);}description = description.concat(" " + serialNumber + " ");} else {serialNumbersConsidered.add(serialNumber);List<Integer> schemesConsidered = new ArrayList<>();List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());Collections.reverse(sios);for (SchemeInOut sio : sios) {if (!schemesConsidered.contains(sio.getSchemeId())) {schemesConsidered.add(sio.getSchemeId());continue;}sio.setRolledBackTimestamp(LocalDateTime.now());amountToRollback += sio.getAmount();// sio.setSchemeType(SchemeType.OUT);sio.setReference(fofoOrder.getId());sio.setSerialNumber(serialNumber);sio.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);rolledbackSios.add(sio);}}}}if (amountToRollback > 0) {UserWalletHistory uwh = new UserWalletHistory();uwh.setAmount(Math.round(amountToRollback));uwh.setDescription(description);uwh.setTimestamp(LocalDateTime.now());uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);uwh.setReference(fofoOrder.getId());uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));uwh.setFofoId(fofoOrder.getFofoId());uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);userWalletHistory.add(uwh);}});ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("Wallet Id", "Store Code", "Reference Type", "Reference", "Amount", "Description","Timestamp"),userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), 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"),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 {List<Integer> references = Arrays.asList(6744, 7347, 8320, 8891, 9124, 9217, 9263, 9379);List<UserWalletHistory> userWalletHistory = new ArrayList<>();List<SchemeInOut> rolledbackSios = new ArrayList<>();Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));references.stream().forEach(reference -> {FofoOrder fofoOrder = null;try {fofoOrder = fofoOrderRepository.selectByOrderId(reference);} catch (Exception e) {}String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();Map<Integer, String> inventorySerialNumberMap = new HashMap<>();float amountToRollback = 0;List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());orderItems.forEach(x -> {inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null).collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));});if (inventorySerialNumberMap.size() > 0) {List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());UserWalletHistory uwh = new UserWalletHistory();Map<Integer, List<SchemeInOut>> inventoryIdSouts = sios.stream().collect(Collectors.groupingBy(SchemeInOut::getInventoryItemId, Collectors.toList()));for (Map.Entry<Integer, List<SchemeInOut>> inventorySioEntry : inventoryIdSouts.entrySet()) {List<SchemeInOut> outList = inventorySioEntry.getValue();if (outList.size() > 1) {}}uwh.setAmount(Math.round(amountToRollback));uwh.setDescription(description);uwh.setTimestamp(LocalDateTime.now());uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);uwh.setReference(fofoOrder.getId());uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));uwh.setFofoId(fofoOrder.getFofoId());uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);userWalletHistory.add(uwh);}});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"),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", "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();}public void sendDailySalesReportNotificationToPartner(Integer fofoIdInt)throws ProfitMandiBusinessException, MessagingException, IOException {LocalDateTime now = LocalDateTime.now();LocalDateTime from = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), 00, 00);Map<Integer, Double> salesByFofoIdMap = new HashMap<>();List<Integer> fofoIds = null;if (fofoIdInt == null) {fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId()).collect(Collectors.toList());} else {fofoIds = Arrays.asList(fofoIdInt);}List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository.selectAllGeEqAndLeEqStartDateAndEndDate(now);DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h a");Map<Integer, Float> dailyTarget = new HashMap<>();for (Integer fofoId : fofoIds) {Map<Integer, Float> dailyAverageSale = null;double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBrtweenDate(fofoId, from, now);for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {Map<Integer, Float> targetValues = targetService.getTargetValueByFofoIdAndTargetId(fofoId,partnerTargetDetail.getId());if (targetValues.size() == 0) {continue;} else {List<Integer> partnerIds = new ArrayList<>();partnerIds.add(fofoId);dailyAverageSale = targetService.getDailyAverageSaleForCurrentForSingleFofoIdAndBrand(partnerIds,targetValues, partnerTargetDetail.getStartDate(), partnerTargetDetail.getEndDate(),partnerTargetDetail.getBrandName());dailyTarget.put(fofoId, dailyAverageSale.get(fofoId));break;}}NotificationCampaigns notification = new NotificationCampaigns();notification.setName("Daily Sales");notification.setTitle("Daily Sale Update");if (dailyAverageSale != null && dailyAverageSale.get(fofoId) != null) {notification.setMessage(String.format("Rs.%.0f till %s. Today's Target is Rs.%.0f", sale,now.format(timeFormatter), dailyAverageSale.get(fofoId)));} else {notification.setMessage(String.format("Rs.%.0f till %s", sale, now.format(timeFormatter)));}// notification.setMessage("Your sale is "+salesbyfofoId.get(fofoId));notification.setType("url");notification.setUrl("http://app.profitmandi.com/pages/home/notifications");LOGGER.info("UserID" + userAccountRepository.selectUserIdByRetailerId(fofoId));notification.setSql("SELECT distinct d1.user_id from devices d1 left join devices d2 on"+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "+ " where d2.id is null and d1.user_id = "+ userAccountRepository.selectUserIdByRetailerId(fofoId));LOGGER.info("SELECT distinct d1.user_id from devices d1 left join devices d2 on"+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "+ " where d2.id is null and d1.user_id = "+ userAccountRepository.selectUserIdByRetailerId(fofoId));notification.setExpiresat(LocalDateTime.now().plusDays(1).toEpochSecond(ZoneOffset.UTC) * 1000);notification.setStatus("active");notification.setSmsprocessed(0);notification.setNotification_processed(0);notification.setNotification_type("GENERAL_NOTIFICATION");mongoClient.persistNotificationCmpInfo(notification);salesByFofoIdMap.put(fofoId, sale);LOGGER.info(sale);}String saleReport = this.getDailySalesReportByPartnerId(salesByFofoIdMap, dailyTarget);LOGGER.info(saleReport);String cc[] = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com","chaitnaya.vats@smartdukaan.com", "adeel.yazdani@smartdukaan.com", "mohinder.mutreja@smartdukaan.com" };String subject = "sale report till" + " " + now.format(timeFormatter);this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc, subject);}public String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap, Map<Integer, Float> dailyTarget)throws ProfitMandiBusinessException {StringBuilder sb = new StringBuilder();sb.append("<html><body><p>Sale Report:</p><br/><table style='border:1px solid black ;padding: 5px';>");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'>Daily Target</th>\n"+ " <th style='border:1px solid black;padding: 5px'>Sale</th>\n"+ " </tr>");for (Integer fofoId : salesByFofoIdMap.keySet()) {try {String PartnerName = retailerService.getFofoRetailer(fofoId).getBusinessName();sb.append("<tr>");sb.append("<td style='border:1px solid black;padding: 5px'>" + PartnerName + "</td>");if (dailyTarget != null && dailyTarget.get(fofoId) != null) {sb.append("<td style='border:1px solid black;padding: 5px'>" + dailyTarget.get(fofoId) + "</td>");} else {sb.append("<td style='border:1px solid black;padding: 5px'>" + 0.0 + "</td>");}sb.append("<td style='border:1px solid black;padding: 5px'>" + salesByFofoIdMap.get(fofoId) + "</td>");sb.append("</tr>");} catch (Exception e) {e.printStackTrace();}}sb.append("</tbody></table></body></html>");return sb.toString();}private void sendMailOfHtmlFomat(String email, String body, String cc[], String subject)throws MessagingException, ProfitMandiBusinessException, IOException {MimeMessage message = mailSender.createMimeMessage();MimeMessageHelper helper = new MimeMessageHelper(message);helper.setSubject(subject);helper.setText(body, true);helper.setTo(email);if (cc != null) {helper.setCc(cc);}InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");helper.setFrom(senderAddress);mailSender.send(message);}public void sendNotification() throws Exception {List<PushNotifications> pushNotifications = pushNotificationRepository.selectAllByTimestamp();if (!pushNotifications.isEmpty()) {for (PushNotifications pushNotification : pushNotifications) {Device device = deviceRepository.selectById(pushNotification.getDeviceId());NotificationCampaign notificationCampaign = notificationCampaignRepository.selectById(pushNotification.getNotificationCampaignid());Gson gson = new GsonBuilder().setPrettyPrinting().serializeNulls().registerTypeAdapter(LocalDateTime.class, new LocalDateTimeJsonConverter()).create();SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),SimpleCampaignParams.class);Campaign campaign = new SimpleCampaign(scp);String result_url = campaign.getUrl() + "&user_id=" + device.getUser_id();JSONObject json = new JSONObject();json.put("to", device.getFcmId());JSONObject jsonObj = new JSONObject();jsonObj.put("message", campaign.getMessage());jsonObj.put("title", campaign.getTitle());jsonObj.put("type", campaign.getType());jsonObj.put("url", result_url);jsonObj.put("time_to_live", campaign.getExpireTimestamp());jsonObj.put("image", campaign.getImageUrl());jsonObj.put("largeIcon", "large_icon");jsonObj.put("smallIcon", "small_icon");jsonObj.put("vibrate", 1);jsonObj.put("pid", pushNotification.getId());jsonObj.put("sound", 1);jsonObj.put("priority", "high");json.put("data", jsonObj);try {CloseableHttpClient client = HttpClients.createDefault();HttpPost httpPost = new HttpPost(FCM_URL);httpPost.setHeader("Content-Type", "application/json; utf-8");httpPost.setHeader("authorization", "key=" + FCM_API_KEY);StringEntity entity = new StringEntity(json.toString());httpPost.setEntity(entity);CloseableHttpResponse response = client.execute(httpPost);LOGGER.info("response" + response);if (response.getStatusLine().getStatusCode() == 200) {pushNotification.setSentTimestamp(LocalDateTime.now());} else {pushNotification.setSentTimestamp(LocalDateTime.of(1970, 1, 1, 00, 00));LOGGER.info("message" + "not sent");}} catch (Exception e) {e.printStackTrace();LOGGER.info("message" + "not sent");}}}}public void grouping() throws Exception {DateTimeFormatter dtf = DateTimeFormatter.ofPattern("MM-dd-yyyy hh:mm");List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository.selectByStatus(PriceDropImeiStatus.APPROVED);System.out.println(String.join("\t",Arrays.asList("IMEI", "ItemId", "Brand", "Model Name", "Model Number", "Franchise Id", "Franchise Name","Grn On", "Price Dropped On", "Approved On", "Returned On", "Price Drop Paid", "Is Doa")));Map<Integer, CustomRetailer> retailersMap = retailerService.getFofoRetailers();for (PriceDropIMEI priceDropIMEI : priceDropImeis) {if (priceDropIMEI.getPartnerId() == 0)continue;HashSet<String> imeis = new HashSet<>();PriceDrop priceDrop = priceDropRepository.selectById(priceDropIMEI.getPriceDropId());imeis.add(priceDropIMEI.getImei());List<InventoryItem> inventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(priceDropIMEI.getPartnerId(), imeis, false);if (inventoryItems.size() == 0) {LOGGER.info("Need to investigate partnerId - {} imeis - {}", priceDropIMEI.getPartnerId(), imeis);continue;}InventoryItem inventoryItem = inventoryItems.get(0);CustomRetailer customRetailer = retailersMap.get(inventoryItem.getFofoId());if (inventoryItem.getLastScanType().equals(ScanType.DOA_OUT)|| inventoryItem.getLastScanType().equals(ScanType.PURCHASE_RET)) {// check if pricedrop has been rolled outList<UserWalletHistory> uwh = walletService.getAllByReference(inventoryItem.getFofoId(),priceDropIMEI.getPriceDropId(), WalletReferenceType.PRICE_DROP);if (uwh.size() > 0) {Item item = itemRepository.selectById(inventoryItem.getItemId());System.out.println(String.join("\t",Arrays.asList(priceDropIMEI.getImei(), inventoryItem.getItemId() + "", item.getBrand(),item.getModelName(), item.getModelNumber(), inventoryItem.getFofoId() + "",customRetailer.getBusinessName(), inventoryItem.getCreateTimestamp().format(dtf),priceDrop.getAffectedOn().format(dtf),priceDropIMEI.getUpdateTimestamp().format(dtf),inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getPartnerPayout() + "",inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));}}}/** for (FofoStore fofoStore : fofoStoreRepository.selectAll()) {* LOGGER.info("{}, {}", fofoStore.getId(),* partnerTypeChangeService.getTypeOnDate(fofoStore.getId(),* LocalDate.now().plusDays(1))); UserWallet userWallet =* userWalletRepository.selectByRetailerId(fofoStore.getId());* if(userWallet==null) continue;* System.out.printf("Store Code %s, Wallet amount %d, Sum amount %f%n",* fofoStore.getCode(), userWallet.getAmount(),* walletService.getWalletAmount(fofoStore.getId())); }*//** for (Map.Entry<String, Set<String>> storeGuyEntry :* csService.getAuthUserPartnerEmailMapping().entrySet()) {* System.out.println(storeGuyEntry.getKey() + " = " +* storeGuyEntry.getValue()); }*/}public void testToffee() throws Exception {//LOGGER.info("{}", toffeeService.getAuthToken());LOGGER.info("{}", toffeeService.getProducts());//LOGGER.info("{}", toffeeService.getPincodes("36103000PR"));PremiumCalculationRequestModel pcrm = new PremiumCalculationRequestModel();pcrm.setProductDetails("36103000PR");//pcrm.setProductDetails("36103000PR");pcrm.setDurations(Arrays.asList("3 Months", "6 Months", "1 Year"));pcrm.setSumInsured("15000");System.out.println(toffeeService.getPremiumCalculation(pcrm));}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().collect(Collectors.toMap(x -> x.getId(), x -> x));List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectBySchemeIds(new HashSet<>(schemeIdsInt));for (SchemeInOut sio : schemeInOuts) {Scheme scheme = schemesMap.get(sio.getSchemeId());if (scheme.getType().equals(SchemeType.IN)) {} else if (scheme.getType().equals(SchemeType.OUT)) {InventoryItem inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());List<ScanRecord> sr = scanRecordRepository.selectByInventoryItemId(sio.getInventoryItemId());ScanRecord scanRecord = sr.stream().filter(x -> x.getType().equals(ScanType.SALE)).max((x1, x2) -> x1.getCreateTimestamp().compareTo(x2.getCreateTimestamp())).get();if (scanRecord.getCreateTimestamp().isAfter(scheme.getEndDateTime())|| scanRecord.getCreateTimestamp().isBefore(scheme.getStartDateTime())) {sio.setRolledBackTimestamp(LocalDateTime.now());FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(scanRecord.getOrderId());String rollbackReason = "Scheme reversed for "+ itemRepository.selectById(inventoryItem.getItemId()).getItemDescription() + "/Inv - "+ fofoOrder.getInvoiceNumber();walletService.rollbackAmountFromWallet(scanRecord.getFofoId(), sio.getAmount(),scanRecord.getOrderId(), WalletReferenceType.SCHEME_OUT, rollbackReason);System.out.printf("Amount %f,SchemeId %d,Reason %s\n", sio.getAmount(), sio.getSchemeId(),rollbackReason);}}}// throw new Exception();}public void checkfocusedModelInPartnerStock() throws Exception {List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId()).collect(Collectors.toList());Map<Integer, List<FocusedModelShortageModel>> focusedModelShortageReportMap = new HashMap<>();for (Integer fofoId : fofoIds) {if (!focusedModelShortageReportMap.containsKey(fofoId)) {focusedModelShortageReportMap.put(fofoId, new ArrayList<>());}CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);Map<Integer, Integer> processingOrderMap = null;Map<Integer, Integer> catalogIdAndQtyMap = null;Map<Integer, Integer> grnPendingOrdersMap = null;Map<Integer, Integer> currentInventorySnapshot = currentInventorySnapshotRepository.selectByFofoId(fofoId).stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));if (!currentInventorySnapshot.isEmpty()) {catalogIdAndQtyMap = itemRepository.selectByIds(currentInventorySnapshot.keySet()).stream().collect(Collectors.groupingBy(x -> x.getCatalogItemId(),Collectors.summingInt(x -> currentInventorySnapshot.get(x.getId()))));}Map<Integer, Integer> grnPendingOrders = orderRepository.selectPendingGrnOrders(fofoId).stream().collect(Collectors.groupingBy(x -> x.getLineItem().getItemId(),Collectors.summingInt(x -> x.getLineItem().getQuantity())));if (!grnPendingOrders.isEmpty()) {grnPendingOrdersMap = itemRepository.selectByIds(grnPendingOrders.keySet()).stream().collect(Collectors.groupingBy(x -> x.getCatalogItemId(),Collectors.summingInt(x -> grnPendingOrders.get(x.getId()))));}Map<Integer, Integer> processingOrder = orderRepository.selectOrders(fofoId, orderStatusList).stream().collect(Collectors.groupingBy(x -> x.getLineItem().getItemId(),Collectors.summingInt(x -> x.getLineItem().getQuantity())));if (!processingOrder.isEmpty()) {processingOrderMap = itemRepository.selectByIds(processingOrder.keySet()).stream().collect(Collectors.groupingBy(x -> x.getCatalogItemId(),Collectors.summingInt(x -> processingOrder.get(x.getId()))));}Map<Integer, Integer> focusedCatalogIdAndQtyMap = focusedModelRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x.getMinimumQty()));LOGGER.info("focusedCatalogIdAndQtyMap" + focusedCatalogIdAndQtyMap);for (Map.Entry<Integer, Integer> entry : focusedCatalogIdAndQtyMap.entrySet()) {int inStockQty = 0;int processingQty = 0;int grnPendingQty = 0;if (processingOrderMap != null) {processingQty = (processingOrderMap.get(entry.getKey()) == null) ? 0: processingOrderMap.get(entry.getKey());}if (grnPendingOrdersMap != null) {grnPendingQty = (grnPendingOrdersMap.get(entry.getKey()) == null) ? 0: grnPendingOrdersMap.get(entry.getKey());}if (catalogIdAndQtyMap != null) {inStockQty = (catalogIdAndQtyMap.get(entry.getKey()) == null) ? 0: catalogIdAndQtyMap.get(entry.getKey());}int totalQty = processingQty + grnPendingQty + inStockQty;if (totalQty < entry.getValue()) {int shortageQty = entry.getValue() - totalQty;List<Item> item = itemRepository.selectAllByCatalogItemId(entry.getKey());FocusedModelShortageModel fm = new FocusedModelShortageModel();fm.setFofoId(fofoId);fm.setStoreName(customRetailer.getBusinessName());fm.setItemName(item.get(0).getBrand() + item.get(0).getModelNumber() + item.get(0).getModelName());fm.setShortageQty(shortageQty);focusedModelShortageReportMap.get(fofoId).add(fm);}}List<FocusedModelShortageModel> focusedModelShortageModel = focusedModelShortageReportMap.get(fofoId);if (!focusedModelShortageModel.isEmpty()) {String subject = "Stock Alert";String messageText = this.getMessage(focusedModelShortageModel);this.sendMailWithAttachments(subject, messageText, customRetailer.getEmail());String notificationMessage = this.getNotificationMessage(focusedModelShortageModel);LOGGER.info("notificationMessage" + notificationMessage);SimpleCampaignParams scp = new SimpleCampaignParams();scp.setTitle("Alert");scp.setType("url");scp.setUrl("http://app.smartdukaan.com/pages/home/notifications");scp.setMessage(notificationMessage);scp.setExpireTimestamp(LocalDateTime.now().plusDays(2));SimpleCampaign sc = new SimpleCampaign(scp);sc.setSimpleCampaignParams(scp);LOGGER.info("scp" + scp);NotificationCampaign nc = new NotificationCampaign();nc.setName("Stock Alert");nc.setImplementationType("SimpleCampaign");nc.setImplementationParams(gson.toJson(scp));nc.setCreatedTimestamp(LocalDateTime.now());nc.setMessageType(MessageType.notification);notificationCampaignRepository.persist(nc);LOGGER.info("nc" + nc);LOGGER.info("fofoID" + fofoId);int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);LOGGER.info("userId" + userId);UserCampaign uc = new UserCampaign();uc.setCampaignId(nc.getId());uc.setUserId(userId);uc.setPushTimestamp(LocalDateTime.now());userCampaignRepository.persist(uc);List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(userId,LocalDateTime.now().minusMonths(3), LocalDateTime.now());pushNotification(nc.getId(), devices);}}if(!focusedModelShortageReportMap.isEmpty()) {String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();Map<String, List<List<? extends Serializable>>> emailRowsMap = new HashMap<>();focusedModelShortageReportMap.entrySet().forEach(x -> {storeGuyMap.entrySet().forEach(y -> {if (y.getValue().contains(x.getKey())) {if (!emailRowsMap.containsKey(y.getKey())) {emailRowsMap.put(y.getKey(), new ArrayList<>());}List<List<? extends Serializable>> fms = x.getValue().stream().map(r -> Arrays.asList(r.getFofoId(), r.getStoreName(), r.getItemName(), r.getShortageQty())).collect(Collectors.toList());emailRowsMap.get(y.getKey()).addAll(fms);}});});List<String> headers = Arrays.asList("Partner Id", "Partner Name", "Model Name", "Shortage Qty");emailRowsMap.entrySet().forEach(e -> {ByteArrayOutputStream baos = null;try {baos = FileUtil.getCSVByteStream(headers, e.getValue());} catch (Exception e2) {// TODO Auto-generated catch blocke2.printStackTrace();}String[] sendToArray = new String[] { e.getKey() };try {LOGGER.info("email" + e.getKey());LOGGER.info("list" + e.getValue());Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Stock Alert", "PFA", fileName,new ByteArrayResource(baos.toByteArray()));} catch (Exception e1) {// TODO Auto-generated catch blocke1.printStackTrace();}});}}private String getNotificationMessage(List<FocusedModelShortageModel> focusedModelShortageModel) {StringBuilder sb = new StringBuilder();sb.append("Focused Model Shortage in Your Stock : \n");for (FocusedModelShortageModel entry : focusedModelShortageModel) {sb.append(entry.getItemName() + "-" + entry.getShortageQty());sb.append(String.format("%n", ""));}return sb.toString();}public void pushNotification(int cid, List<Device> devices) {for (Device device : devices) {PushNotifications pn = new PushNotifications();pn.setNotificationCampaignid(cid);pn.setDeviceId(device.getId());pn.setUserId(device.getUser_id());pushNotificationRepository.persist(pn);}}private void sendMailWithAttachments(String subject, String messageText, String email) throws Exception {MimeMessage message = mailSender.createMimeMessage();MimeMessageHelper helper = new MimeMessageHelper(message, true);helper.setSubject(subject);helper.setText(messageText, true);helper.setTo(email);InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");helper.setFrom(senderAddress);mailSender.send(message);}private String getMessage(List<FocusedModelShortageModel> focusedModelShortageModel) {StringBuilder sb = new StringBuilder();sb.append("<html><body><p>Alert</p><p>Focused Model Shortage in Your Stock:-</p>"+ "<br/><table style='border:1px solid black ;padding: 5px';>");sb.append("<tbody>\n" + " <tr>\n"+ " <th style='border:1px solid black;padding: 5px'>Item</th>\n"+ " <th style='border:1px solid black;padding: 5px'>Shortage Qty</th>\n"+ " </tr>");for (FocusedModelShortageModel entry : focusedModelShortageModel) {sb.append("<tr>");sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getItemName() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getShortageQty() + "</td>");sb.append("</tr>");}sb.append("</tbody></table></body></html>");return sb.toString();}}