Subversion Repositories SmartDukaan

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.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.PushNotifications;
import com.spice.profitmandi.dao.entity.dtr.User;
import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
import com.spice.profitmandi.dao.entity.user.Device;
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.*;
import com.spice.profitmandi.service.user.RetailerService;

import org.apache.http.conn.HttpHostConnectException;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.*;
import java.util.stream.Collectors;

@Component
public class NotificationServiceImpl implements NotificationService {

        @Autowired
        UserCampaignRepository userCampaignRepository;

        @Autowired
        UserRepository dtrUserRepository;

        @Autowired
        UserAccountRepository userAccountRepository;

        @Autowired
        NotificationCampaignRepository notificationCampaignRepository;

        @Autowired
        DeviceRepository deviceRepository;

        @Autowired
        FofoStoreRepository fofoStoreRepository;

        @Autowired
        CsService csService;

        @Autowired
        RetailerService retailerService;

        @Autowired
        PushNotificationRepository pushNotificationRepository;

        @Autowired
        private Gson gson;

        @Autowired
        private RestClient restClient;

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

        @Override
        public void sendNotification(SendNotificationModel sendNotificationModel) throws ProfitMandiBusinessException {

                SimpleCampaignParams scp = new SimpleCampaignParams();
                scp.setMessage(sendNotificationModel.getMessage());
                scp.setTitle(sendNotificationModel.getTitle());
                scp.setImageUrl(sendNotificationModel.getImageUrl());
                scp.setType(sendNotificationModel.getType());
                scp.setUrl(sendNotificationModel.getUrl());
                scp.setShowImage(sendNotificationModel.getShowImage());
                scp.setExpireTimestamp(sendNotificationModel.getExpiresat());
                SimpleCampaign sc = new SimpleCampaign(scp);
                sc.setSimpleCampaignParams(scp);

                NotificationCampaign nc = new NotificationCampaign();
                nc.setName(sendNotificationModel.getCampaignName());
                nc.setImplementationType("SimpleCampaign");
                nc.setImplementationParams(gson.toJson(scp));
                nc.setMessageType(sendNotificationModel.getMessageType());
                nc.setDocumentId(sendNotificationModel.getDocumentId());
                nc.setCreatedTimestamp(LocalDateTime.now());
                notificationCampaignRepository.persist(nc);

                UserCampaign uc = null;

                Set<Integer> userIds = new HashSet<>();
                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()));
                }

                LOGGER.info("userIds" + userIds);

                for (Integer userId : userIds) {
                        uc = new UserCampaign();
                        uc.setCampaignId(nc.getId());
                        uc.setUserId(userId);
                        uc.setPushTimestamp(LocalDateTime.now());
                        userCampaignRepository.persist(uc);
                }

                List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(new ArrayList<>(userIds),
                                LocalDateTime.now().minusMonths(3), LocalDateTime.now());

                LOGGER.info("devices" + devices);
                pushNotification(nc.getId(), devices);

        }

        @Override
        public void sendNotificationToAll(SendNotificationModel sendNotificationModel) throws ProfitMandiBusinessException {
                sendNotificationModel.setUserIds(fofoStoreRepository.selectAllDtrUserIds());
                Set<AuthUser> authUsers = new HashSet<>(
                                csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));
                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()
                                .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 {
                SendNotificationModel sendNotificationModel = this.getDefaultNotificationModel();
                sendNotificationModel.setCampaignName(campaignName);
                sendNotificationModel.setMessageType(messageType);
                sendNotificationModel.setTitle(title);
                sendNotificationModel.setMessage(message);
                int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
                sendNotificationModel.setUserIds(Arrays.asList(userId));
                sendNotificationModel.setMessageType(MessageType.wallet);
                this.sendNotification(sendNotificationModel);
        }

        public SendNotificationModel getDefaultNotificationModel() {
                SendNotificationModel sendNotificationModel = new SendNotificationModel();
                sendNotificationModel.setType("url");
                sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
                sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
                sendNotificationModel.setMessageType(MessageType.notification);
                return sendNotificationModel;
        }

        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);
                }

        }

        @Override
        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);
                int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
                sendNotificationModel.setUserIds(Arrays.asList(userId));
                sendNotificationModel.setMessageType(messageType);
                sendNotificationModel.setUrl(url);
                this.sendNotification(sendNotificationModel);
        }

        @Override
        public void sendWhatsappMessage(String message, String title, String mobile)
                        throws HttpHostConnectException, ProfitMandiBusinessException {
                Map<String, String> requestheaders = new HashMap<>();
                requestheaders.put("Content-Type", "application/x-www-form-urlencoded");
                Map<String, String> requestParams = new HashMap<>();
                requestParams.put("userid", String.valueOf(2000215976));
                requestParams.put("password", "MFRd!BBL");
                requestParams.put("send_to", "919816068341");
                requestParams.put("auth_scheme", "plain");
                requestParams.put("v", "1.1");

                requestParams.put("format", "json");

                requestParams.put("msg_type", "HSM");

                requestParams.put("method", "SENDMESSAGE");

                requestParams.put("msg", message);

                requestParams.put("isTemplate", "true");
                requestParams.put("header", title);
                String response = restClient.post("https://media.smsgupshup.com/GatewayAPI/rest", requestParams,
                                requestheaders);
                LOGGER.info("response" + response);
        }

}