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

 package com.spice.profitmandi.service.user;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.hash.Hashing;
+import com.google.gson.Gson;
 import com.spice.profitmandi.common.enumuration.ActivationType;
 import com.spice.profitmandi.common.enumuration.FofoType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.*;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.dao.model.LastMonthCreditedIncomeModel;
 import com.spice.profitmandi.dao.repository.dtr.*;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
+import com.spice.profitmandi.dao.repository.trialOnboarding.TrialFormRepository;
 import com.spice.profitmandi.dao.repository.user.*;
 import com.spice.profitmandi.service.PostOfficeService;
 import com.spice.profitmandi.service.catalog.BrandsService;
 import in.shop2020.model.v1.user.CartStatus;
 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.Qualifier;
 import org.springframework.cache.annotation.Cacheable;
+import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
 import java.nio.charset.StandardCharsets;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 @Component
 public class RetailerServiceImpl implements RetailerService {
     private static final Logger LOGGER = LogManager.getLogger(RetailerServiceImpl.class);
+    private static final String[] TRIAL_CODE_CREATION_AUDIENCE = new String[]{"amit.gupta@smartdukaan.com"};
+    //private static final String [] TRIAL_CODE_CREATION_AUDIENCE = new String[]{};
     @Autowired
     private RetailerRepository retailerRepository;
     @Autowired
     @Autowired
     private Mongo mongoClient;
     @Autowired
+    Gson gson;
+    @Autowired
     private UserRepository userRepository;
+    @Autowired
+    ObjectMapper objectMapper;
     @Autowired
     private CartRepository cartRepository;
     @Autowired
     @Autowired
     private CounterRepository counterRepository;
     @Autowired
     private StateRepository stateRepository;
+    @Autowired
+    private TrialFormRepository trialFormRepository;
     @Autowired
     @Qualifier("userUserRepository")
     private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
     @Autowired
     PartnerTypeChangeService partnerTypeChangeService;
     @Autowired
     BrandsService brandsService;
+    @Autowired
+    private JavaMailSender googleMailSender;
     @Override
     public Map<String, Object> getByEmailIdOrMobileNumber(String emailIdOrMobileNumber) throws ProfitMandiBusinessException {
         User user = null;
         int fofoId = Utils.SYSTEM_PARTNER_ID;
+            }
+        }
         Map<String, Object> map = new HashMap<>();
         map.put("stateNames", stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
+        LOGGER.info("user - {}", user);
         if (user != null) {
             List<UserRole> userRoles = userRoleRepository.selectByUserId(user.getId());
             Role role = roleRepository.selectByName(RoleType.FOFO.toString());
                     LOGGER.error("Retailer Registered Address not found");
+                }
             } catch (ProfitMandiBusinessException profitMandiBusinessException) {
                 LOGGER.error("Retailer not found in user_account");
+            }
+        } else {
+            try {
+                TrialForm trialForm = trialFormRepository.selectByEmailOrMobile(emailIdOrMobileNumber);
+                map.put("trialForm", gson.toJson(trialForm));
+            } catch (Exception e) {
+                LOGGER.error("Retailer not found in user_account");
+            }
+        }
         return map;
+    }
             fofoStore.setCounterSize(updateRetailerRequest.getCountersize());
             fofoStore.setMinimumInvestment(updateRetailerRequest.getMinInvestment());
             fofoStore.setCounterPotential(updateRetailerRequest.getCounterPotential());
             fofoStore.setWarehouseId(updateRetailerRequest.getWarehouseId());
+            //Check for Trial users here
             int nextStoreCodeInt = fofoStoreRepository.selectLatestStore().getCodeInt() + 1;
             String fofoStoreCode = StringUtils.generateFofoStoreSequence(
                     districtMaster.getStateShortName() + districtMaster.getShortName(), nextStoreCodeInt);
+            TrialForm trialForm = trialFormRepository.selectByEmailOrMobile(updateRetailerRequest.getUserMobileNumber());
+            if (trialForm != null) {
+                fofoStoreCode = "T-" + fofoStoreCode;
+                fofoStore.setTrial(true);
+                fofoStore.setTrialStart(LocalDate.now());
+                fofoStore.setTrialEnd(LocalDate.now().plusDays(31));
+                trialForm.setStatus(ProfitMandiConstants.Status.APPROVED);
+                //TODO:Amit G, Send store code notification to retailer.
+            }
             fofoStore.setCode(fofoStoreCode);
             fofoStore.setCodeInt(nextStoreCodeInt);
             fofoStore.setBagsLastCredited(LocalDateTime.now());
             if (retailerAddress.getName().contains(ProfitMandiConstants.COMPANY_NAME) || retailerAddress.getName().contains(ProfitMandiConstants.COMPANY_SHORT_NAME)) {
                 fofoStore.setInternal(true);
                 pinPartner.setPincode(retailerAddress.getPinCode());
                 pincodePartnerRepository.perist(pinPartner);
+            }
+        }
+        if (fofoStore.isTrial()) {
+            this.sendTrialStoreCreationMail(fofoStore, updateRetailerRequest);
+        }
         return fofoStore;
+    }
+    private void sendTrialStoreCreationMail(FofoStore fofoStore, UpdateRetailerRequest updateRetailerRequest) {
+        try {
+            String subject = String.format("Trial Store Created - %s");
+            String message = new StringBuffer("New Trial Store Created. Please align for Training and Engagement. Assign ABMs and RBMs and BMs")
+                    .append(String.format("Address - %s, %s\n", updateRetailerRequest.getAddress().getLine1(), updateRetailerRequest.getAddress().getLine2()))
+                    .append(String.format("City - %s, ", updateRetailerRequest.getAddress().getCity()))
+                    .append(String.format("Pincode - %s, ", updateRetailerRequest.getAddress().getPinCode()))
+                    .append(String.format("State - %s", updateRetailerRequest.getAddress().getState())).toString();
+            LOGGER.info("message" + message);
+            //String [] mailTo = {"tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "kamini.sharma@smartdukaan.com"}
+            String[] mailTo = {"amit.gupta@smartdukaan.com"};
+            Utils.sendMailWithAttachments(googleMailSender, new String[]{}, null, subject, message);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
     @Override
     public FofoStore createFofoStoreCodeByUserId(int userId, String districtName, String
             stateName, UpdateRetailerRequest updateRetailerRequest) throws ProfitMandiBusinessException {
         User user = userRepository.selectById(userId);
         // = userAccountRepository.selectRetailerIdByUserId(user.getId());

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/user/RetailerServiceImpl.java – Rev 35203 → 35289