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

 package com.spice.profitmandi.service;
-import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-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.Value;
-import org.springframework.stereotype.Component;
 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.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
-import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
-import com.spice.profitmandi.dao.entity.dtr.Optin;
-import com.spice.profitmandi.dao.entity.dtr.PushNotifications;
-import com.spice.profitmandi.dao.entity.dtr.User;
+import com.spice.profitmandi.dao.entity.dtr.*;
-import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
 import com.spice.profitmandi.dao.entity.user.Device;
+import com.spice.profitmandi.dao.entity.whatsapp.WhatsappMessage;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.repository.catalog.DeviceRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
-import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
-import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
-import com.spice.profitmandi.dao.repository.dtr.OptinRepository;
+import com.spice.profitmandi.dao.repository.dtr.*;
-import com.spice.profitmandi.dao.repository.dtr.PushNotificationRepository;
-import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
-import com.spice.profitmandi.dao.repository.dtr.UserCampaignRepository;
+import com.spice.profitmandi.dao.repository.whatsapp.WhatsappMessageRepository;
-import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.service.user.RetailerService;
+import com.spice.profitmandi.service.whatsapp.WhatsappMessageService;
+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.Value;
+import org.springframework.stereotype.Component;
+import java.time.LocalDateTime;
+import java.util.*;
+import java.util.stream.Collectors;
 @Component
 public class NotificationServiceImpl implements NotificationService {
     private static final Logger LOGGER = LogManager.getLogger(NotificationService.class);
     @Autowired
     private RestClient restClient;
     @Value("${prod}")
     private boolean isProd;
+    @Autowired
+    private WhatsappMessageRepository messageRepository;
+    @Autowired
+    private WhatsappMessageService whatsappMessageService;
     @Override
     public void sendNotification(SendNotificationModel sendNotificationModel) throws ProfitMandiBusinessException {
         SimpleCampaignParams scp = new SimpleCampaignParams();
         scp.setMessage(sendNotificationModel.getMessage());
         if (sendNotificationModel.getUserIds() != null && sendNotificationModel.getUserIds().size() > 0) {
             userIds.addAll(sendNotificationModel.getUserIds());
+        }
         if (sendNotificationModel.getStateIds() != null && sendNotificationModel.getStateIds().size() > 0) {
-            userIds.addAll(fofoStoreRepository.selectByWarehouseIds(sendNotificationModel.getStateIds()).stream().map(x -> x.getId()).collect(Collectors.toList()));
+            userIds.addAll(fofoStoreRepository.selectByWarehouseIds(sendNotificationModel.getStateIds()).stream()
+                    .map(x -> x.getId()).collect(Collectors.toList()));
+        }
         LOGGER.info("userIds" + userIds);
         for (Integer userId : userIds) {
             uc.setUserId(userId);
             uc.setPushTimestamp(LocalDateTime.now());
             userCampaignRepository.persist(uc);
+        }
-        List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(new ArrayList<>(userIds), LocalDateTime.now().minusMonths(3), LocalDateTime.now());
+        List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(new ArrayList<>(userIds),
+                LocalDateTime.now().minusMonths(3), LocalDateTime.now());
         LOGGER.info("devices" + devices);
         pushNotification(nc.getId(), devices);
+    }
         authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY));
         authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES));
         List<String> emailIds = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());
         emailIds.add("devkinandan.lal@smartdukaan.com");
         List<User> systemUsers = dtrUserRepository.selectAllByEmailIds(emailIds);
+        sendNotificationModel.getUserIds()
-        sendNotificationModel.getUserIds().addAll(systemUsers.stream().map(x -> x.getId()).collect(Collectors.toList()));
+                .addAll(systemUsers.stream().map(x -> x.getId()).collect(Collectors.toList()));
         this.sendNotification(sendNotificationModel);
+    }
     @Override
-    public void sendNotification(int fofoId, String campaignName, MessageType messageType, String title, String message) throws ProfitMandiBusinessException {
+    public void sendNotification(int fofoId, String campaignName, MessageType messageType, String title, String message)
+            throws ProfitMandiBusinessException {
         SendNotificationModel sendNotificationModel = this.getDefaultNotificationModel();
         sendNotificationModel.setCampaignName(campaignName);
         sendNotificationModel.setMessageType(messageType);
         sendNotificationModel.setTitle(title);
         sendNotificationModel.setMessage(message);
+        }
+    }
     @Override
-    public void sendNotification(int fofoId, String campaignName, MessageType messageType, String title, String message, String url) throws ProfitMandiBusinessException {
+    public void sendNotification(int fofoId, String campaignName, MessageType messageType, String title, String message,
+                                 String url) throws ProfitMandiBusinessException {
         SendNotificationModel sendNotificationModel = this.getDefaultNotificationModel();
         sendNotificationModel.setCampaignName(campaignName);
         sendNotificationModel.setMessageType(messageType);
         sendNotificationModel.setTitle(title);
         sendNotificationModel.setMessage(message);
         sendNotificationModel.setUrl(url);
         this.sendNotification(sendNotificationModel);
+    }
     @Override
-    public void sendWhatsappMessage(String message, String title, String mobile) throws Exception {
+    public void sendWhatsappMessage(String message, String title, String mobile)
+            throws Exception {
+        boolean sentMessage = this.isWhatMessageSend(mobile);
+        if (sentMessage) {
-        this.sendWhatsappMessage(message, title, mobile, null, null);
+            this.sendWhatsappMessage(message, title, mobile, null, null);
+        }
+    }
     @Override
-    public void sendWhatsappMediaMessage(String message, String mobile, String mediaUrl, String fileName) throws Exception {
+    public void sendWhatsappMediaMessage(String message, String mobile, String mediaUrl, String fileName)
+            throws Exception {
+        boolean sentMessage = this.isWhatMessageSend(mobile);
+        if (sentMessage) {
-        this.sendWhatsappMessage(message, null, mobile, mediaUrl, fileName);
+            this.sendWhatsappMessage(message, null, mobile, mediaUrl, fileName);
+        }
+    }
     @Override
     public void optIn(String phoneNumber) throws Exception {
         Map<String, String> requestheaders = new HashMap<>();
         requestParams.put("channel", "WHATSAPP");
         String response = restClient.get("https://media.smsgupshup.com/GatewayAPI/rest", requestParams, requestheaders);
         LOGGER.info("response" + response);
+    }
-    private void sendWhatsappMessage(String message, String title, String mobile, String mediaUrl, String fileName) throws Exception {
+    private void sendWhatsappMessage(String message, String title, String mobile, String mediaUrl, String fileName)
+            throws Exception {
         String sendTo = null;
         if (mobile.length() != 10) {
             return;
         } else {
             sendTo = 91 + mobile;
         requestParams.put("send_to", sendTo);
         requestParams.put("v", "1.1");
         requestParams.put("format", "json");
         requestParams.put("auth_scheme", "plain");
         if (mediaUrl == null) {
-            requestParams.put("method", "SENDMESSAGE");
+        requestParams.put("method", "SENDMESSAGE");
             /*requestParams.put("msg_type", "HSM");
             requestParams.put("msg", message);
             requestParams.put("isTemplate", "true");
             requestParams.put("header", title);*/
             //} else if(isProd && mediaUrl !=null) {
             requestParams.put("msg_type", "DOCUMENT");
             requestParams.put("caption", message);
             //requestParams.put("msg", message);
             requestParams.put("media_url", mediaUrl);
             requestParams.put("filename", fileName);
+            String response =
-            String response = restClient.post("https://media.smsgupshup.com/GatewayAPI/rest", requestParams, requestheaders);
+                    restClient.post("https://media.smsgupshup.com/GatewayAPI/rest",
+                            requestParams,
+                            requestheaders);
             LOGGER.info("response" + response);
             JSONObject jsonObject = new JSONObject(response);
-            LOGGER.info("jsonObject" + jsonObject);
-            JSONObject jo = (JSONObject) jsonObject.get("response");
-            LOGGER.info("jo" + jo);
-            String externalId = jo.getString("id");
+            JSONObject whatsappResponse = (JSONObject) jsonObject.get("response");
-            LOGGER.info("externalId" + externalId);
+            String externalId = whatsappResponse.getString("id");
+            String phone = whatsappResponse.getString("phone");
+            WhatsappMessage whatsappMessage = new WhatsappMessage();
+            whatsappMessage.setCreatedTimestamp(LocalDateTime.now());
+            whatsappMessage.setExternalId(externalId);
+            whatsappMessage.setDestAddr(phone);
+            messageRepository.persist(whatsappMessage);
+        }
+    }
+    @Override
+    public boolean isWhatMessageSend(String mobile) {
+        String destAddr = "91" + mobile;
+        boolean isSent = true;
+        List<WhatsappMessage> whatsappMessages = messageRepository.selectByDestAddr(destAddr);
+        if (!whatsappMessages.isEmpty()) {
+            long failedCount = whatsappMessages.stream().filter(x -> x.getFailed().equals("FAILED")).collect(Collectors.counting());
+            if (failedCount >= 2) {
+                isSent = false;
+            }
+        }
+        return isSent;
+    }
+}

Subversion Repositories SmartDukaan

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