WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/NotificationServiceImpl.java

 package com.spice.profitmandi.service;
 import com.google.gson.Gson;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.fofo.Customer;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.whatsapp.WhatsappFlow;
 import com.spice.profitmandi.service.whatsapp.WhatsappMessageService;
 import com.spice.profitmandi.service.whatsapp.WhatsappMessageType;
 import com.spice.profitmandi.service.whatsapp.WhatsappNumbers;
-import com.spice.profitmandi.service.whatsapp.WhatsappProviderResolver;
+import com.spice.profitmandi.service.whatsapp.BotPenguinWhatsappService;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
     @Autowired
     private WhatsappMessageService whatsappMessageService;
     @Autowired
-    private WhatsappProviderResolver whatsappProviders;
+    private BotPenguinWhatsappService botPenguin;
     @Override
     public void sendNotification(SendNotificationModel sendNotificationModel) throws ProfitMandiBusinessException {
         SimpleCampaignParams scp = new SimpleCampaignParams();
         sendNotificationModel.setMessageType(messageType);
         sendNotificationModel.setUrl(url);
         this.sendNotification(sendNotificationModel);
+    }
-    @Override
-    public boolean sendWhatsappMessage(String message, String title, String mobile) throws Exception {
-        boolean isSend=false;
-        LOGGER.info("Is Prod - {}", isProd);
-        if (isProd) {
-            isSend=this.sendWhatsappMessage(WhatsappFlow.GENERIC, WhatsappMessageType.TEXT, message, title, mobile, null, null);
-        }
+    /**
-        return isSend;
+     * Invoice PDF, sent as the template's document header.
-    }
+     *
-    @Override
-    public void sendADLDWhatsappMessage(String mobile) throws Exception {
+     * <p>The upsell wording that used to be built here now lives in the approved template; only the
-        LOGGER.info("Is Prod - {}", isProd);
-        if (isProd) {
-            String message = "क्या आपने SmartDukaan Protect Plus Plan लिया है?\n\n" +
-                    "सिर्फ ₹199 से शुरू, पाएं अपने मोबाइल के लिए 1 साल की स्मार्ट सुरक्षा —\n" +
-                    "Liquid Damage Protection\n" +
-                    "Accidental Damage Protection\n" +
+     * recipient's name and the PDF link cross the wire.</p>
-                    "अपने फोन को महंगे रिपेयर खर्च से बचाएं।\n" +
-                    "अभी जानकारी लें और अपने फोन को सुरक्षित बनाएं!";
-            String title = "SmartDukaan से खरीदारी करने के लिए धन्यवाद!";
-            this.sendWhatsappMessage(WhatsappFlow.ADLD, WhatsappMessageType.TEXT, message, title, mobile, null, null);
-        }
-    }
+     */
     @Override
     public boolean sendWhatsappInvoice(int customerId, int fofoId, String invoiceNumber, String whatsAppNo) throws Exception {
-        boolean shouldSend = shouldSendWhatsappMessage(whatsAppNo);
+        if (!shouldSendWhatsappMessage(whatsAppNo)) {
-        if (!shouldSend) return false;
+            return false;
+        }
         Customer customer = customerRepository.selectById(customerId);
         String mobileNumber = (whatsAppNo != null && !whatsAppNo.isEmpty()) ? whatsAppNo : customer.getMobileNumber();
-        String message = "*SmartDukaan's One-Time Offer Unlocked!*\n" +
-                "Thank you for your purchase.\n" +
-                "\n" +
-                "Abhi-abhi naya phone liya hai...\n" +
-                "Par kya aapne uski poori suraksha li hai?\n" +
-                "SmartDukaan par sabse kam daam mein plans available hain:\n" +
-                "\n" +
-                "*Complete Protection Plan* (Accidental & Liquid Damage) - Starting ₹199\n" +
-                "\n" +
-                "*Extended 1 Year Warranty* - ₹199 se shuru\n" +
-                "\n" +
-                "Abhi store par iski jaankari lein.\n" +
-                "\n" +
-                "*Ye offer phone ki kharidari ke sirf 24 hours tak hi valid hai!*";
         String mediaUrl = "https://partners.smartdukaan.com/wa-invoice-send/"
                 + Base64.getMimeEncoder().encodeToString(invoiceNumber.getBytes(StandardCharsets.UTF_8)) + ".pdf";
         String fileName = "INV-" + invoiceNumber.replace("/", "-") + ".pdf";
         LOGGER.info("sendWhatsappInvoice: mobile={} mediaUrl={}", mobileNumber, mediaUrl);
-        // Goes straight to the provider rather than through sendWhatsappMediaMessage so the INVOICE flow
+        return botPenguin.send(WhatsappFlow.INVOICE, mobileNumber,
-        // is named: a template-first provider needs it to pick the approved invoice template.
+                Arrays.asList(customerName(customer), storeName(fofoId)), mediaUrl, fileName,
-        return this.sendWhatsappMessage(WhatsappFlow.INVOICE, WhatsappMessageType.DOCUMENT, message, null,
-                mobileNumber, mediaUrl, fileName);
+                WhatsappMessageType.DOCUMENT);
+    }
     @Override
-    public boolean sendWhatsappMediaMessage(String message, String mobile, String mediaUrl, String fileName, WhatsappMessageType whatsappMessageType) throws Exception {
+    public boolean sendPaymentLink(String mobile, String paymentLink) throws Exception {
-        boolean isSend=false;
+        return botPenguin.send(WhatsappFlow.PAYMENT_LINK, mobile,
-//        if (isProd) {
-//            isSend=this.sendWhatsappMessage(whatsappMessageType, message, null, mobile, mediaUrl, fileName);
+                Collections.singletonList(paymentLink), null, null, null);
-//        }
+    }
+    @Override
+    public boolean sendOfferAnnouncement(String mobile, String offerName, String schemeType, String startDate,
+                                         String endDate, String imageUrl) throws Exception {
+        return botPenguin.send(WhatsappFlow.OFFER, mobile,
-        isSend = this.sendWhatsappMessage(WhatsappFlow.GENERIC, whatsappMessageType, message, null, mobile, mediaUrl, fileName);
+                Arrays.asList(offerName, schemeType, startDate, endDate), imageUrl, null,
-        return isSend;
+                WhatsappMessageType.IMAGE);
+    }
-    /**
-     * Kept on this interface because cron calls it directly; it delegates to the active provider and is
-     * a no-op for providers with no opt-in concept.
-     */
     @Override
-    public void optIn(String phoneNumber) throws Exception {
+    public boolean sendBiddingLive(String mobile, List<String> lots, String mediaUrl) throws Exception {
+        int slots = ProfitMandiConstants.WHATSAPP_TEMPLATE.BIDDING_LIVE.getBodyParamCount();
+        if (lots.size() > slots) {
+            LOGGER.warn("sendBiddingLive: {} lots available but the template holds {}; dropping {}",
+                    lots.size(), slots, lots.subList(slots, lots.size()));
+        }
+        List<String> params = new ArrayList<>(lots.subList(0, Math.min(lots.size(), slots)));
+        // Meta rejects an empty parameter, so unused slots carry a dash rather than "".
-        whatsappProviders.active().optIn(phoneNumber);
+        while (params.size() < slots) {
+            params.add("-");
+        }
+        return botPenguin.send(WhatsappFlow.BIDDING_LIVE, mobile, params, mediaUrl, null,
+                WhatsappMessageType.IMAGE);
+    }
+    @Override
+    public boolean sendLoanDefaultAlert(String mobile, String name, String outstandingAmount) throws Exception {
+        LOGGER.info("Is Prod - {}", isProd);
+        if (!isProd) {
+            return false;
+        }
+        return botPenguin.send(WhatsappFlow.LOAN_ALERT, mobile,
+                Arrays.asList(name, outstandingAmount), null, null, null);
+    }
+    @Override
+    public boolean sendOrderDelivered(String mobile, String airwayBillNumber) throws Exception {
+        LOGGER.info("Is Prod - {}", isProd);
+        if (!isProd) {
+            return false;
+        }
+        return botPenguin.send(WhatsappFlow.ORDER_DELIVERED, mobile,
+                Collections.singletonList(airwayBillNumber), null, null, null);
+    }
+    @Override
-    private boolean sendWhatsappMessage(WhatsappFlow flow, WhatsappMessageType whatsappMessageType, String message,
+    public boolean sendADLDWhatsappMessage(String mobile, String invoiceNumber, String mediaUrl,
-                                        String title, String mobile, String mediaUrl, String fileName)
+                                           String fileName) throws Exception {
+        LOGGER.info("Is Prod - {}", isProd);
-            throws Exception {
+        if (!isProd) {
-        return whatsappProviders.active()
+            return false;
+        }
-                .sendBasic(flow, whatsappMessageType, message, title, mobile, mediaUrl, fileName);
+        return botPenguin.send(WhatsappFlow.ADLD, mobile, Collections.singletonList(invoiceNumber),
+                mediaUrl, fileName, WhatsappMessageType.DOCUMENT);
+    }
     @Override
     public boolean shouldSendWhatsappMessage(String mobile) {
-        // Normalised rather than concatenated: cpass and BotPenguin store the normalised MSISDN, so for
+        // Normalised rather than concatenated: BotPenguin stores the normalised MSISDN, so for anything
-        // anything that is not already a bare ten digits the old "91" + mobile key could never match a
+        // that is not already a bare ten digits the old "91" + mobile key could never match a stored row
-        // stored row and the throttle quietly never fired. Identical result for clean input.
+        // and the throttle quietly never fired. Identical result for clean input.
         String destAddr = WhatsappNumbers.toMsisdn(mobile);
         if (destAddr == null) {
             return true;
+        }
         boolean shouldSend = true;
+            }
+        }
         return shouldSend;
+    }
+    /**
+     * The store the purchase was made at, for the invoice template's second variable. Falls back to the
+     * brand name: an unknown partner id must not stop an invoice going out.
+     */
+    private String storeName(int fofoId) {
+        try {
+            CustomRetailer retailer = retailerService.getFofoRetailer(fofoId);
+            String businessName = retailer == null ? null : retailer.getBusinessName();
+            if (businessName != null && !businessName.trim().isEmpty()) {
+                return businessName.trim();
+            }
+        } catch (Exception e) {
+            LOGGER.warn("storeName: could not resolve fofoId {}", fofoId, e);
+        }
+        return "SmartDukaan";
+    }
+    /** Meta greets by name, so an empty first name would render "Hello ,". */
-    @Override
+    private static String customerName(Customer customer) {
-    public void sendPaymentWhatsappMessage(String mobile, String message) throws Exception {
+        String firstName = customer == null ? null : customer.getFirstName();
-        whatsappProviders.active().sendText(WhatsappFlow.PAYMENT_LINK, mobile, message);
+        return (firstName == null || firstName.trim().isEmpty()) ? "Customer" : firstName.trim();
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/NotificationServiceImpl.java – Rev 37388 → 37409