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

 package com.spice.profitmandi.dao.service;
+import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Bid;
 import com.spice.profitmandi.dao.entity.catalog.Liquidation;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.catalog.BidRepository;
 import com.spice.profitmandi.dao.repository.catalog.LiquidationRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
+import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.AuthService;
 import com.spice.profitmandi.service.NotificationService;
+import com.spice.profitmandi.service.whatsapp.WhatsappMessageType;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
+import java.time.LocalDateTime;
-import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
+import java.util.Map;
+import static java.util.stream.Collectors.toList;
 @Component
 public class BidServiceImpl implements BidService {
     private static final Logger LOGGER = LogManager.getLogger(BidServiceImpl.class);
     @Autowired
     BidRepository bidRepository;
     @Autowired
     LiquidationRepository liquidationRepository;
     @Autowired
     NotificationService notificationService;
+    @Autowired
+    private UserAccountRepository userAccountRepository;
+    @Autowired
+    private FofoStoreRepository fofoStoreRepository;
     @Override
     public void sendMailToRBM(double netAmountInHand, double totalPayableAmount, int fofoId) throws Exception {
         User user = userRepository.selectById(fofoId);
         int rbmId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, fofoId);
     @Override
     public void sendSummaryMailToUserAndManagers(int userId, List<Bid> bids, Liquidation liquidation) throws Exception {
         String content = this.generateContent(bids, liquidation, ProfitMandiConstants.BID_ENUM.CLOSED);
         AuthUser authUser = authRepository.selectById(userId);
-        //String[] emailTo = {"vikas.jangra@smartdukaan.com"};
         String[] emailTo = {authUser.getEmailId(), "vikas.jangra@smartdukaan.com"};
         String[] ccTo = authService.getAllManagers(userId).stream().map(AuthUser::getEmailId).toArray(String[]::new);
         String subject = "Liquidation Report";
         String message = "Dear Team,\n\n"
         LOGGER.info("mailMessage: {}",message);
         Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
+    }
     @Override
-    public void notifyPartner(int userId, Bid bid, ProfitMandiConstants.BID_ENUM status) throws Exception {
+    public void notifyPartner(int fofoId, Bid bid, ProfitMandiConstants.BID_ENUM status) throws Exception {
-        User user = userRepository.selectById(userId);
+        User user = userRepository.selectById(fofoId);
         List<Bid> topBid = bidRepository.selectBidByLiquidationId(bid.getLiquidationId());
         String message = this.generateWhatsAppBidMessage(user.getName(), bid, topBid.get(0).getBiddingAmount(), status);
+        this.sendPushNotification(message, "Bid Update!", Arrays.asList(fofoId));
-        String mobile = user.getMobileNumber();
+        //String mobile = user.getMobileNumber();
-        notificationService.sendWhatsappMessage(message, "Bid Update!", mobile);
+        //notificationService.sendWhatsappMessage(message, "Bid Update!", mobile);
+    }
+    @Override
+    public void biddingLiveNotification(String message, String mediaURL) throws Exception {
+        this.sendPushNotification(message, "Bidding Live Now!", Collections.emptyList());
+        //List<String> mobiles = Arrays.asList("7619985051","8529003611","7082253510","7903840919","9667014826");
+        if (mediaURL == null){
+            notificationService.sendWhatsappMessage(message,null, "8529003611");
+        } else {
+            notificationService.sendWhatsappMediaMessage(message,"8529003611", mediaURL,"whatsapp.jpeg", WhatsappMessageType.IMAGE);
+        }
+    }
+    @Override
+    public void sendPushNotification(String message, String title, List<Integer> fofoIds) throws Exception {
+        SendNotificationModel sendNotificationModel = new SendNotificationModel();
+        sendNotificationModel.setCampaignName(title);
+        sendNotificationModel.setMessage(message);
+        sendNotificationModel.setType("url");
+        sendNotificationModel.setTitle(title);
+        sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/clearance");
+        sendNotificationModel.setExpiresat(LocalDateTime.now().plusHours(6));
+        sendNotificationModel.setMessageType(MessageType.notification);
+        List<Integer> userIds;
+        if (fofoIds.size() > 0) {
+            userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds); //Arrays.asList(171912487)
+        } else {
+            fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x->x.getId()).collect(toList());
+            userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds);
+        }
+        sendNotificationModel.setUserIds(userIds);
+        notificationService.sendNotification(sendNotificationModel);
+    }
     private String generateContent(List<Bid> bids, Liquidation liquidation, ProfitMandiConstants.BID_ENUM status){
         StringBuilder sb = new StringBuilder();
         sb.append("<h4>Bidding Summary</h3>");
         String bidAmount = String.format("%.2f", bidData.getBiddingAmount());
         String message = "";
         if (status.equals(ProfitMandiConstants.BID_ENUM.CLOSED)) {
-            message = "Congratulations! %s,"+ "\n"+
+            message = "Congratulations! %s,\n"+
                     "\n"+
-                    "Your bid for %s has been confirmed!\n" +
+                    "Your bid for %s has been confirmed!\n"+
                     "\n"+
-                    "Bid Details:\n" +
+                    "Bid Details:\n"+
-                    "* Bid Amount: ₹%s\n" +
+                    "Bid Amount: Rs. %s\n"+
-                    "* Quantity: %s\n" +
+                    "Quantity: %s\n"+
-                    "* Bid Time: %s\n" +
+                    "Bid Time: %s\n"+
                     "\n"+
                     "Thank you for participating. We'll dispatch your order soon.";
             message = String.format(message, fofoName, bidData.getItemName(), bidAmount, bidData.getQuantity(), bidTime);
+        }
         else if (status.equals(ProfitMandiConstants.BID_ENUM.CANCELLED)) {
-            message = "Hi %s,"+ "\n"+
+            message = "Hi %s,\n"+
                     "\n"+
-                    "We regret to inform you that your bid for %s was not selected this time.\n" +
+                    "We regret to inform you that your bid for %s was not selected this time.\n"+
                     "\n"+
-                    "Bid Details:\n" +
+                    "Bid Details:\n"+
-                    "* Bid Amount: ₹%s\n" +
+                    "Bid Amount: Rs. %s\n"+
-                    "* Quantity: %s\n" +
+                    "Quantity: %s\n"+
-                    "* Bid Time: %s\n" +
+                    "Bid Time: %s\n"+
-                    "* Qualified Bid Amount: ₹%s\n" +
                     "\n"+
+                    "Qualified Bid Amount: ₹%s\n"+
                     "Thank you for your participation. Stay tuned for more opportunities!";
             message = String.format(message, fofoName, bidData.getItemName(), bidAmount, bidData.getQuantity(), bidTime, String.format("%.2f", topBidAmount));
+        }
         else if (status.equals(ProfitMandiConstants.BID_ENUM.PENDING)) {
-            message = "Hi %s,"+ "\n"+
+            message = "Hi %s,\n"+
                     "\n"+
-                    "Your bid for %s has been placed successfully!\n" +
+                    "Your bid for %s has been placed successfully.\n"+
                     "\n"+
-                    "Bid Details:\n" +
+                    "Bid Details:\n"+
-                    "* Bid Amount: ₹%s\n" +
+                    "Bid Amount: Rs. %s\n"+
-                    "* Quantity: %s\n" +
+                    "Quantity: %s\n"+
-                    "* Bid Time: %s\n" +
+                    "Time: %s\n"+
                     "\n"+
-                    "We'll keep you updated. You'll be notified once the bidding period ends.";
+                    "We will keep you updated. You will be notified once the bidding period ends.";
-            message = String.format(message, fofoName, bidData.getItemName(), bidAmount, bidData.getQuantity(), bidTime);
+            message = String.format(message, fofoName.trim(), bidData.getItemName().trim(), bidAmount, bidData.getQuantity(), bidTime);
+        }
         else if (status.equals(ProfitMandiConstants.BID_ENUM.UPDATE)) {
-            message = "Hi %s,"+ "\n"+
+            message = "Hi %s,\n"+
-                    "\n"+
-                    "A higher bid has been placed for %s. Don't miss your chance!\n" +
+                    "A higher bid has been placed for %s. Don't miss your chance!\n"+
                     "\n"+
-                    "Your Bid Details:\n" +
+                    "Your Bid Details:\n"+
-                    "* Bid Amount: ₹%s\n" +
+                    "Bid Amount: Rs. %s\n"+
-                    "* Quantity: %s\n" +
+                    "Quantity: %s\n"+
-                    "* Bid Time: %s\n" +
+                    "Bid Time: %s\n"+
                     "\n"+
-                    "Another user has placed a higher bid of ₹%s.\n" +
+                    "Another user has placed a higher bid of %s.\n"+
                     "Update your bid before the bidding ends to stay ahead in the race!";
             message = String.format(message, fofoName, bidData.getItemName(), bidAmount, bidData.getQuantity(), bidTime, String.format("%.2f", topBidAmount));
+        }
         return message;

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/service/BidServiceImpl.java – Rev 34492 → 34545