Subversion Repositories SmartDukaan

Rev

Rev 35170 | Rev 35257 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
21248 ashik.ali 1
package com.spice.profitmandi.web.controller;
2
 
26636 amit.gupta 3
import com.fasterxml.jackson.annotation.JsonProperty;
26646 amit.gupta 4
import com.fasterxml.jackson.databind.ObjectMapper;
21248 ashik.ali 5
import com.spice.profitmandi.common.ResponseCodeHolder;
6
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
30295 amit.gupta 7
import com.spice.profitmandi.common.model.*;
21282 ashik.ali 8
import com.spice.profitmandi.common.util.JWTUtil;
30295 amit.gupta 9
import com.spice.profitmandi.common.util.Utils;
21855 amit.gupta 10
import com.spice.profitmandi.common.web.client.RestClient;
21740 ashik.ali 11
import com.spice.profitmandi.common.web.util.ResponseSender;
25366 tejbeer 12
import com.spice.profitmandi.dao.entity.auth.AuthUser;
30295 amit.gupta 13
import com.spice.profitmandi.dao.entity.dtr.*;
29011 amit.gupta 14
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
15
import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
25622 amit.gupta 16
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
22355 ashik.ali 17
import com.spice.profitmandi.dao.entity.user.Address;
25458 tejbeer 18
import com.spice.profitmandi.dao.entity.user.Promoter;
19
import com.spice.profitmandi.dao.entity.user.Refferal;
25488 tejbeer 20
import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
21735 ashik.ali 21
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
29892 tejbeer 22
import com.spice.profitmandi.dao.enumuration.transaction.PartnerOnBoardingStatus;
25979 tejbeer 23
import com.spice.profitmandi.dao.model.CreateRefferalRequest;
25488 tejbeer 24
import com.spice.profitmandi.dao.model.DateRangeModel;
21643 ashik.ali 25
import com.spice.profitmandi.dao.model.UserCart;
25366 tejbeer 26
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
25619 amit.gupta 27
import com.spice.profitmandi.dao.repository.cs.CsService;
30295 amit.gupta 28
import com.spice.profitmandi.dao.repository.dtr.*;
25622 amit.gupta 29
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
22355 ashik.ali 30
import com.spice.profitmandi.dao.repository.user.AddressRepository;
25458 tejbeer 31
import com.spice.profitmandi.dao.repository.user.PromoterRepository;
24491 amit.gupta 32
import com.spice.profitmandi.service.AuthService;
23798 amit.gupta 33
import com.spice.profitmandi.service.authentication.RoleManager;
25366 tejbeer 34
import com.spice.profitmandi.service.user.RetailerService;
29011 amit.gupta 35
import com.spice.profitmandi.service.user.StoreTimelineTatService;
23787 amit.gupta 36
import com.spice.profitmandi.service.user.UserService;
26870 amit.gupta 37
import com.spice.profitmandi.web.controller.checkout.OrderController;
21469 amit.gupta 38
import com.spice.profitmandi.web.enumuration.UserStatus;
21277 ashik.ali 39
import com.spice.profitmandi.web.processor.GoogleLoginProcessor;
25488 tejbeer 40
import com.spice.profitmandi.web.req.RefferalEarning;
41
import com.spice.profitmandi.web.req.RefferalEarningModel;
21366 kshitij.so 42
import com.spice.profitmandi.web.req.UserRequest;
25366 tejbeer 43
import com.spice.profitmandi.web.res.Partner;
21469 amit.gupta 44
import io.swagger.annotations.ApiImplicitParam;
45
import io.swagger.annotations.ApiImplicitParams;
30295 amit.gupta 46
import org.apache.http.client.ClientProtocolException;
47
import org.apache.logging.log4j.LogManager;
48
import org.apache.logging.log4j.Logger;
49
import org.springframework.beans.factory.annotation.Autowired;
50
import org.springframework.beans.factory.annotation.Value;
51
import org.springframework.http.MediaType;
52
import org.springframework.http.ResponseEntity;
53
import org.springframework.mail.javamail.JavaMailSender;
54
import org.springframework.mail.javamail.MimeMessageHelper;
55
import org.springframework.stereotype.Controller;
56
import org.springframework.transaction.annotation.Transactional;
57
import org.springframework.web.bind.annotation.*;
21469 amit.gupta 58
 
30295 amit.gupta 59
import javax.mail.MessagingException;
60
import javax.mail.internet.InternetAddress;
61
import javax.mail.internet.MimeMessage;
62
import javax.servlet.http.HttpServletRequest;
63
import java.io.IOException;
64
import java.io.UnsupportedEncodingException;
65
import java.time.LocalDate;
66
import java.time.LocalDateTime;
67
import java.time.YearMonth;
68
import java.time.ZoneOffset;
69
import java.util.*;
70
import java.util.stream.Collectors;
71
 
21248 ashik.ali 72
/**
73
 * @author ashikali
74
 */
75
@Controller
25366 tejbeer 76
@Transactional(rollbackFor = Throwable.class)
21248 ashik.ali 77
public class UserController {
21469 amit.gupta 78
 
32458 amit.gupta 79
    @Autowired
80
    private ResponseSender<?> responseSender;
21469 amit.gupta 81
 
33792 ranu 82
    //Changed to 2000 as per policy
83
    private static final int PER_REFERRAL_EARNING=2000;
33194 amit.gupta 84
 
32458 amit.gupta 85
    private static final Logger LOGGER = LogManager.getLogger(UserController.class);
21469 amit.gupta 86
 
32458 amit.gupta 87
    @Value("${notifications.api.host}")
88
    private String nodeHost;
25366 tejbeer 89
 
32458 amit.gupta 90
    @Autowired
91
    private MobileAppSettingsRepository mobileAppSettingsRepository;
26636 amit.gupta 92
 
32458 amit.gupta 93
    @Value("${notifications.api.port}")
94
    private int nodePort;
21855 amit.gupta 95
 
32458 amit.gupta 96
    @Value("${admin.token}")
97
    private String validAdminToken;
21469 amit.gupta 98
 
32458 amit.gupta 99
    @Autowired
100
    private UserRepository userRepository;
25366 tejbeer 101
 
32458 amit.gupta 102
    @Autowired
103
    private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
21469 amit.gupta 104
 
32458 amit.gupta 105
    @Autowired
106
    private RetailerRepository retailerRepository;
21485 amit.gupta 107
 
32458 amit.gupta 108
    @Autowired
109
    private UserRoleRepository userRoleRepository;
21469 amit.gupta 110
 
32458 amit.gupta 111
    @Autowired
112
    private PartnerTypeChangeService partnerTypeChangeService;
25622 amit.gupta 113
 
32458 amit.gupta 114
    @Autowired
115
    private UserAccountRepository userAccountRepository;
25366 tejbeer 116
 
32458 amit.gupta 117
    @Autowired
118
    private AuthService authService;
25366 tejbeer 119
 
32458 amit.gupta 120
    @Autowired
121
    private AddressRepository addressRepository;
21469 amit.gupta 122
 
32458 amit.gupta 123
    @Autowired
124
    private GoogleLoginProcessor googleLoginProcessor;
21855 amit.gupta 125
 
32458 amit.gupta 126
    @Autowired
127
    private UserService userService;
25366 tejbeer 128
 
32458 amit.gupta 129
    @Autowired
130
    private CsService csService;
25619 amit.gupta 131
 
32458 amit.gupta 132
    @Autowired
133
    private RestClient restClient;
25366 tejbeer 134
 
32458 amit.gupta 135
    @Autowired
136
    private RoleManager roleManager;
25366 tejbeer 137
 
32458 amit.gupta 138
    @Autowired
139
    private RoleRepository roleRepository;
21469 amit.gupta 140
 
32458 amit.gupta 141
    @Autowired
142
    private AuthRepository authRepository;
26792 tejbeer 143
 
32458 amit.gupta 144
    @Autowired
145
    private ObjectMapper objectMapper;
26792 tejbeer 146
 
32458 amit.gupta 147
    @Autowired
148
    private RetailerService retailerService;
25366 tejbeer 149
 
32458 amit.gupta 150
    @Autowired
151
    private RefferalRepository refferalRepository;
25458 tejbeer 152
 
32458 amit.gupta 153
    @Autowired
154
    private PromoterRepository promoterRepository;
25458 tejbeer 155
 
32458 amit.gupta 156
    @Autowired
157
    JavaMailSender mailSender;
26792 tejbeer 158
 
32458 amit.gupta 159
    @RequestMapping(value = ProfitMandiConstants.URL_USER_GOOGLE_LOGIN, method = RequestMethod.POST)
34794 vikas.jang 160
    public ResponseEntity<?> googleLogin(HttpServletRequest request, @RequestBody GoogleLoginRequest loginRequest) throws Exception {
161
        String email = loginRequest.getEmail() != null ? loginRequest.getEmail() : googleLoginProcessor.process(loginRequest.getToken());
162
        return responseSender.ok(getAuthTokenMap(email, loginRequest));
32458 amit.gupta 163
    }
26636 amit.gupta 164
 
35170 vikas 165
    @RequestMapping(value = ProfitMandiConstants.URL_B2B_APP_VERSION, method = RequestMethod.GET)
35193 vikas 166
    public ResponseEntity<?> checkForUpdate(HttpServletRequest request, @RequestParam int version) {
35170 vikas 167
        Map<String, Object> responseMap = new HashMap<>();
168
        responseMap.put("appVersion", ProfitMandiConstants.B2B_APP_VERSION);
169
        responseMap.put("appUrl", ProfitMandiConstants.B2B_APP_URL);
35193 vikas 170
        if (version == ProfitMandiConstants.B2B_APP_VERSION) {
35170 vikas 171
            responseMap.put("updateAvailable", false);
172
        } else {
173
            responseMap.put("updateAvailable", true);
174
        }
175
        return responseSender.ok(responseMap);
176
    }
177
 
34794 vikas.jang 178
    private Map<String, Object> getAuthTokenMap(String email, GoogleLoginRequest loginRequest) throws Exception {
32458 amit.gupta 179
        String name = authService.getNameByEmailId(email);
30295 amit.gupta 180
 
32458 amit.gupta 181
        Map<String, Object> responseMap = new HashMap<>(2);
182
        LOGGER.info("User Name from getNameByEmailId({}) is {}", email, name);
183
        if (name != null) {
184
            User registeredUser = null;
185
            AuthUser authUser = authRepository.selectByGmailId(email);
34794 vikas.jang 186
            if (loginRequest.getPassword() != null) {
187
                registeredUser = userService.authenticate(email, loginRequest.getPassword());
188
            } else if (authUser != null) {
32458 amit.gupta 189
                registeredUser = userRepository.selectByEmailId(authUser.getEmailId());
190
            } else if (promoterRepository.selectMappedByEmailId(email) != null) {
191
                Promoter promoter = promoterRepository.selectMappedByEmailId(email);
192
                int userId = userAccountRepository.selectUserIdByRetailerId(promoter.getRetailerId());
193
                registeredUser = userRepository.selectById(userId);
194
            } else if (userRepository.isExistBySecondryEmailId(email)) {
195
                registeredUser = userRepository.selectBySecondryEmailId(email);
196
            }
197
            LOGGER.info("4");
198
            List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(registeredUser.getId());
199
            String[] roleTypes = new String[roleIds.size()];
200
            int index = 0;
201
            for (int roleId : roleIds) {
202
                roleTypes[index++] = String.valueOf(roleId);
203
            }
204
            int retailerId;
205
            try {
206
                retailerId = userAccountRepository.selectRetailerIdByUserId(registeredUser.getId());
207
            } catch (Exception e) {
208
                Set<Integer> authUserPartnerSet = csService.getAuthUserPartnerIdMapping().get(authUser.getEmailId());
209
                if (authUserPartnerSet != null && authUserPartnerSet.size() > 0) {
210
                    retailerId = authUserPartnerSet.stream().findFirst().get();
211
                    FofoStore fs = fofoStoreRepository.selectByRetailerId(retailerId);
34037 amit.gupta 212
                    retailerId = partnerTypeChangeService.getBestPartner(fs.getWarehouseId());
32458 amit.gupta 213
                } else {
34794 vikas.jang 214
                    com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectByEmailId(Utils.SYSTEM_PARTNER);
32458 amit.gupta 215
                    retailerId = user.getId();
216
                }
217
            }
218
            responseMap.put(ProfitMandiConstants.TOKEN,
219
                    JWTUtil.create(email, registeredUser.getId(), retailerId, roleTypes));
220
            LOGGER.info("Param value for email, registeredUser.getId(), retailerId, roleTypes are {}, {}, {} and {}",
221
                    email, registeredUser.getId(), retailerId, Arrays.asList(roleTypes));
222
            responseMap.put(ProfitMandiConstants.REGISTERED, true);
223
            return responseMap;
224
        }
30295 amit.gupta 225
 
32458 amit.gupta 226
        User user = null;
227
        try {
34794 vikas.jang 228
            if (loginRequest.getPassword() != null) {
229
                user = userService.authenticate(email, loginRequest.getPassword());
230
            } else {
231
                user = userRepository.selectByEmailId(email);
232
            }
32458 amit.gupta 233
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
30295 amit.gupta 234
 
32458 amit.gupta 235
        }
236
        if (user == null) {
237
            try {
238
                user = userRepository.selectByEmailId(email);
239
            } catch (ProfitMandiBusinessException profitMandiBusinessException) {
240
                responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(email));
241
                responseMap.put(ProfitMandiConstants.REGISTERED, false);
242
            }
243
        } else {
244
            List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
245
            int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
246
            String[] roleTypes = new String[roleIds.size()];
247
            int index = 0;
248
            for (int roleId : roleIds) {
249
                roleTypes[index++] = String.valueOf(roleId);
250
            }
251
            responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(user.getId(), retailerId, roleTypes));
252
            responseMap.put(ProfitMandiConstants.REGISTERED, true);
253
        }
30295 amit.gupta 254
 
32458 amit.gupta 255
        return responseMap;
256
    }
30295 amit.gupta 257
 
32458 amit.gupta 258
    @RequestMapping(value = "/store/token/{storeCode}", method = RequestMethod.GET)
259
    public ResponseEntity<?> googleLogin(HttpServletRequest request, @PathVariable String storeCode)
260
            throws ProfitMandiBusinessException {
261
        LOGGER.info("StoreCode {}", storeCode);
262
        return responseSender.ok(googleLoginProcessor.processStore(storeCode));
263
    }
21469 amit.gupta 264
 
34794 vikas.jang 265
    @RequestMapping(value = ProfitMandiConstants.URL_USER_FORGOT_PASSWORD, method = RequestMethod.POST)
266
    public ResponseEntity<?> forgotPassword(@RequestBody GoogleLoginRequest loginRequest) throws Exception {
267
        userService.resetPassword(loginRequest.getEmail());
268
        return responseSender.ok(true);
269
    }
270
 
271
    @RequestMapping(value = ProfitMandiConstants.URL_USER_CHANGE_PASSWORD, method = RequestMethod.POST)
272
    public ResponseEntity<?> changePassword(@RequestBody EmailPassword emailPassword) throws Exception {
273
        User user = userService.authenticate(emailPassword.getEmail(), emailPassword.getPassword());
274
        if (user != null){
275
            boolean response = userService.changePassword(user, emailPassword.getNewPassword());
276
            return responseSender.ok(response);
277
        }
278
        return responseSender.ok(false);
279
    }
280
 
32458 amit.gupta 281
    @RequestMapping(value = ProfitMandiConstants.URL_USER_TOKEN_IS_EXPIRED, method = RequestMethod.GET)
282
    public ResponseEntity<?> tokenIsExpired(HttpServletRequest request, @RequestParam(name = "token") String token)
283
            throws ProfitMandiBusinessException {
284
        LOGGER.info("requested url : " + request.getRequestURL().toString());
285
        return responseSender.ok(JWTUtil.isExpired(token));
286
    }
21469 amit.gupta 287
 
32458 amit.gupta 288
    @RequestMapping(value = ProfitMandiConstants.URL_USER_DETAIL_BY_TOKEN, method = RequestMethod.GET)
289
    @ApiImplicitParams({
290
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
291
    public ResponseEntity<?> tokenInfo(HttpServletRequest request) throws Throwable {
292
        Map<String, Object> responseMap = new HashMap<>();
293
        UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
294
        LOGGER.info("userinfo1 {}", userInfo);
295
        User user = null;
296
        if (userInfo.getUserId() > -1) {
297
            user = userRepository.selectById(userInfo.getUserId());
298
            String city = user.getCity();
30552 tejbeer 299
 
32458 amit.gupta 300
            if (!(userInfo.getEmail() == null || user.getEmailId().indexOf("@smartdukaan.com") == -1)) {
301
                String userName = null;
302
                if (user.getSecondryEmailId() != null && user.getSecondryEmailId().equals(userInfo.getEmail())) {
30547 tejbeer 303
 
32458 amit.gupta 304
                    userName = user.getFirstName() + " " + user.getLastName();
305
                } else {
32721 ranu 306
                        AuthUser authUser = authRepository.selectByGmailId(userInfo.getEmail());
32458 amit.gupta 307
                    LOGGER.info("authUser {}", authUser);
308
                    if (authUser == null || !authUser.isActive()) {
309
                        responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
310
                        responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
311
                        return responseSender.ok(responseMap);
312
                    }
313
                    userName = authUser.getName();
314
                }
315
                responseMap.put(ProfitMandiConstants.USER_ID, userInfo.getUserId());
316
                responseMap.put(ProfitMandiConstants.USER_NAME, userName);
317
                responseMap.put(ProfitMandiConstants.USER_STATUS, "fofoAssociate");
318
                responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
319
                responseMap.put("storeUrl", "");
320
                return responseSender.ok(responseMap);
321
            }
322
        } else {
323
            try {
30547 tejbeer 324
 
32458 amit.gupta 325
                LOGGER.info("userinfo4 {}", userInfo);
326
                user = userRepository.selectByEmailId(userInfo.getEmail());
327
            } catch (ProfitMandiBusinessException e1) {
328
            }
329
            if (user == null) {
330
                try {
331
                    LOGGER.info("userinfo8 {}", userInfo);
332
                    user = userRepository.selectBySecondryEmailId(userInfo.getEmail());
333
                } catch (ProfitMandiBusinessException e1) {
334
                    LOGGER.info("Uneregistered user", userInfo.getEmail());
335
                }
336
            }
337
        }
338
        if (user != null) {
339
            responseMap.put(ProfitMandiConstants.EMAIL_ID, user.getEmailId());
340
            responseMap.put(ProfitMandiConstants.USER_ID, user.getId());
341
            responseMap.put(ProfitMandiConstants.USER_NAME, user.getFirstName() + " " + user.getLastName());
32721 ranu 342
 
343
            if(roleManager.isUser(userInfo.getRoleIds()) && !roleManager.isRetailer(userInfo.getRoleIds())) {
344
 
345
            } else {
346
 
347
            }
348
 
349
 
32458 amit.gupta 350
            List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
32721 ranu 351
            LOGGER.info("userRoles {} ", user.getEmailId());
22032 ashik.ali 352
 
32721 ranu 353
            int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
32458 amit.gupta 354
            // generate new token if roles have been updated
355
            if (userInfo.getRoleIds() == null || roleIds.size() != userInfo.getRoleIds().size()) {
356
                String[] roleIdStrings = new String[roleIds.size()];
357
                int index = 0;
358
                for (int roleId : roleIds) {
359
                    roleIdStrings[index++] = String.valueOf(roleId);
360
                }
361
                String newToken = JWTUtil.create(user.getId(), retailerId, roleIdStrings);
362
                responseMap.put("newAuthToken", newToken);
363
            }
364
            // if user is retailer
365
            Set<Integer> roleIdsSet = new HashSet<Integer>(roleIds);
366
            if (roleManager.isRetailer(roleIdsSet)) {
367
                UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
368
                Retailer retailer = retailerRepository.selectById(uc.getUserId());
369
                com.spice.profitmandi.dao.entity.user.User saholicUser = userUserRepository.selectById(uc.getUserId());
370
                if (saholicUser.getAddressId() != null) {
371
                    Address address = addressRepository.selectById(saholicUser.getAddressId());
372
                    responseMap.put(ProfitMandiConstants.ADDRESS, address);
373
                }
34794 vikas.jang 374
 
32458 amit.gupta 375
                if (retailer.isActive() || user.isActivated()) {
376
                    if (roleManager.isPartner(roleIdsSet)) {
377
                        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(saholicUser.getId());
378
                        if (fofoStore.isActive()) {
379
                            responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.FOFO.getValue());
380
                            responseMap.put("storeUrl", retailerService.getAllFofoRetailerIdUrlMap().get(uc.getUserId()));
381
                            responseMap.put("timelineStatus", this.getTimeLineStatus(uc.getUserId()));
382
                        } else {
383
                            responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
384
                        }
385
                    } else {
386
                        responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
387
                    }
388
                } else if (retailer.isMigrated()) {
389
                    responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.RETAILER.getValue());
390
                } else {
391
                    responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_VERIFIED_RETAILER.getValue());
392
                }
393
            } else if (roleManager.isUser(roleIdsSet)) {
394
                responseMap.put("userInfo", getRegisteredUserInfo(user));
395
                responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.REGISTERED.getValue());
396
            }
397
        } else {
398
            responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
399
            responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
400
        }
22032 ashik.ali 401
 
32458 amit.gupta 402
        return responseSender.ok(responseMap);
403
    }
25366 tejbeer 404
 
32458 amit.gupta 405
    @Autowired
406
    FofoStoreRepository fofoStoreRepository;
407
    @Autowired
408
    PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
409
    @Autowired
410
    StoreTimelineTatService storeTimelineTatService;
29878 tejbeer 411
 
32458 amit.gupta 412
    private boolean getTimeLineStatus(int fofoId) throws ProfitMandiBusinessException {
413
        FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);
414
        PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
415
        boolean status = true;
416
        if (partnerOnBoardingPanel != null) {
29011 amit.gupta 417
 
32458 amit.gupta 418
            status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
419
        }
29011 amit.gupta 420
 
32458 amit.gupta 421
        LOGGER.info("status" + status);
422
        return status;
423
    }
29011 amit.gupta 424
 
32458 amit.gupta 425
    private RegisteredUserInfo getRegisteredUserInfo(User user) throws Throwable {
426
        RegisteredUserInfo ri = new RegisteredUserInfo();
427
        ri.setCity(user.getCity());
428
        ri.setFirstName(user.getFirstName());
429
        ri.setLastName(user.getLastName());
430
        ri.setPhone(user.getMobileNumber());
431
        ri.setPinCode(user.getPinCode());
432
        ri.setState(user.getState());
433
        return ri;
434
    }
21469 amit.gupta 435
 
32458 amit.gupta 436
    @RequestMapping(value = ProfitMandiConstants.URL_USER, method = RequestMethod.POST)
437
    @ApiImplicitParams({
438
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
439
    public ResponseEntity<?> createUser(HttpServletRequest request, @RequestBody UserRequest userRequest)
440
            throws ProfitMandiBusinessException {
441
        LOGGER.info("requested url : " + request.getRequestURL().toString());
442
        User user = new User();
443
        user.setFirstName(userRequest.getFirstName());
444
        user.setLastName(userRequest.getLastName());
445
        user.setCity(userRequest.getCity());
446
        user.setPinCode(Integer.valueOf(userRequest.getPinCode()));
447
        user.setState(userRequest.getState());
448
        user.setMobileNumber(userRequest.getMobieNumber());
449
        user.setEmailId(userRequest.getEmailId());
450
        user.setUsername("");
451
        user.setPassword("");
452
        user.setMobile_verified(false);
453
        user.setReferral_url("");
454
        user.setGroup_id(1);
455
        user.setStatus(1);
456
        user.setActivated(false);
457
        user.setCreateTimestamp(LocalDateTime.now());
458
        user.setUpdateTimestamp(LocalDateTime.now());
459
        userRepository.persist(user);
460
        Role role = roleRepository.selectByName(RoleType.USER.toString());
461
        UserRole userRole = new UserRole();
462
        userRole.setRoleId(role.getId());
463
        userRole.setUserId(user.getId());
464
        userRoleRepository.persist(userRole);
465
        return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1000"));
25366 tejbeer 466
 
32458 amit.gupta 467
    }
21469 amit.gupta 468
 
32458 amit.gupta 469
    @RequestMapping(value = ProfitMandiConstants.URL_USER_ID, method = RequestMethod.GET)
470
    public ResponseEntity<?> getById(HttpServletRequest request, @RequestParam(name = "id") int id)
471
            throws ProfitMandiBusinessException {
472
        LOGGER.info("requested url : " + request.getRequestURL().toString());
473
        return responseSender.ok(userRepository.selectById(id));
474
    }
21469 amit.gupta 475
 
32458 amit.gupta 476
    @RequestMapping(value = ProfitMandiConstants.URL_USER_MOBILE_NUMBER, method = RequestMethod.GET)
477
    public ResponseEntity<?> getByMobileNumber(HttpServletRequest request,
478
                                               @RequestParam(name = "mobileNumber") String mobileNumber) throws ProfitMandiBusinessException {
479
        LOGGER.info("requested url : " + request.getRequestURL().toString());
480
        return responseSender.ok(userRepository.selectByMobileNumber(mobileNumber));
481
    }
21469 amit.gupta 482
 
32458 amit.gupta 483
    @ApiImplicitParams({
484
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
485
    @RequestMapping(value = ProfitMandiConstants.URL_USER_ACTIVATE, method = RequestMethod.POST)
486
    public ResponseEntity<?> activateUser(HttpServletRequest request,
487
                                          @RequestParam(name = "activationCode") String activationCode) throws Throwable {
488
        int userId = (int) request.getAttribute("userId");
489
        UserCart uc = userAccountRepository.getUserCart(userId);
490
        return responseSender.ok(userService.updateActivation(userId, uc.getUserId(), activationCode));
491
    }
21855 amit.gupta 492
 
32458 amit.gupta 493
    /*
494
     * @ApiImplicitParams({
495
     *
496
     * @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true,
497
     * dataType = "string", paramType = "header") })
498
     *
499
     * @RequestMapping(value = ProfitMandiConstants.URL_USER_NOTIFICATIONS, method =
500
     * RequestMethod.GET) public ResponseEntity<?>
501
     * getNofitications(HttpServletRequest request,
502
     *
503
     * @RequestParam(name = "androidId") String androidId, @RequestParam(name =
504
     * "pageNumber") int pageNumber,
505
     *
506
     * @RequestParam(name = "pageSize") int pageSize) throws
507
     * ProfitMandiBusinessException { int userId = (int)
508
     * request.getAttribute("userId"); String restResponse = null; Map<String,
509
     * String> params = new HashMap<>();
510
     *
511
     * String uri = "/getAllNotifications"; params.put("user_id", userId + "");
512
     * params.put("android_id", androidId); params.put("limit", pageSize + "");
513
     * params.put("offset", "" + ((pageNumber - 1) * pageSize)); try { restResponse
514
     * = restClient.get(SchemeType.HTTP, nodeHost, nodePort, uri, params); } catch
515
     * (HttpHostConnectException e) { throw new ProfitMandiBusinessException("", "",
516
     * "Could not Connect to host"); }
517
     *
518
     * JsonArray result_json = Json.parse(restResponse).asArray();
519
     *
520
     * List<Notification> notifications = new ArrayList<>();
521
     *
522
     * for (JsonValue j : result_json) {
523
     * notifications.add(toNotifiaction(j.asObject())); }
524
     *
525
     * return responseSender.ok(notifications); }
526
     *
527
     * private Notification toNotifiaction(JsonObject jsonObject) { Notification n =
528
     * (Notification) (new Gson().fromJson(jsonObject.toString(),
529
     * Notification.class)); if (n.getStatus().equals("opened") ||
530
     * n.getStatus().equals("referrer") || n.getStatus().equals("seen")) {
531
     * n.setSeen(true); } return n; }
532
     */
21855 amit.gupta 533
 
32458 amit.gupta 534
    @RequestMapping(value = ProfitMandiConstants.URL_USER_IS_EXIST_MOBILE_NUMBER, method = RequestMethod.GET)
535
    public ResponseEntity<?> isMobileNumberExist(HttpServletRequest request,
536
                                                 @RequestParam(name = "mobileNumber") String mobileNumber) {
537
        LOGGER.info("requested url : " + request.getRequestURL().toString());
538
        return responseSender.ok(userRepository.isExistByMobileNumber(mobileNumber));
539
    }
21469 amit.gupta 540
 
32458 amit.gupta 541
    @RequestMapping(value = ProfitMandiConstants.URL_USER_EMAIL_ID, method = RequestMethod.GET)
542
    public ResponseEntity<?> getByEmailId(HttpServletRequest request, @RequestParam(name = "emailId") String emailId)
543
            throws ProfitMandiBusinessException {
544
        LOGGER.info("requested url : " + request.getRequestURL().toString());
545
        User user = null;
546
        try {
547
            user = userRepository.selectByEmailId(emailId);
548
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
549
            user = userRepository.selectBySecondryEmailId(emailId);
550
        }
551
        return responseSender.ok(user);
552
    }
21469 amit.gupta 553
 
32458 amit.gupta 554
    @RequestMapping(value = ProfitMandiConstants.URL_USER_ROLE_ALL, method = RequestMethod.GET)
555
    public ResponseEntity<?> getAllRoles(HttpServletRequest request, @RequestParam(name = "id") int id) {
556
        LOGGER.info("requested url : " + request.getRequestURL().toString());
557
        return responseSender.ok(userRoleRepository.selectRolesByUserId(id));
558
    }
25366 tejbeer 559
 
32458 amit.gupta 560
    @ApiImplicitParams({
561
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
562
    @RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID_AND_FOFO_STORE_CODE, method = RequestMethod.GET)
563
    public ResponseEntity<?> getSecondryEmailAndStoreCode(HttpServletRequest request)
564
            throws ProfitMandiBusinessException {
565
        LOGGER.info("requested url : " + request.getRequestURL().toString());
566
        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
567
        return responseSender.ok(userService.getEmailsAndFofoStoreCodeByUserId(userId));
568
    }
25366 tejbeer 569
 
32458 amit.gupta 570
    @ApiImplicitParams({
571
            @ApiImplicitParam(name = "Auth-Token", value = "-Token", required = true, dataType = "string", paramType = "header")})
572
    @RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID, method = RequestMethod.PUT)
573
    public ResponseEntity<?> updateSecondryEmailId(HttpServletRequest request,
574
                                                   @RequestParam(name = ProfitMandiConstants.SECONDRY_EMAIL_ID) String secondryEmailId) throws Throwable {
575
        int userId = (int) request.getAttribute("userId");
576
        User user = userRepository.selectById(userId);
577
        user.setSecondryEmailId(secondryEmailId);
578
        userRepository.persist(user);
579
        return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1001"));
580
    }
21414 kshitij.so 581
 
32458 amit.gupta 582
    @RequestMapping(value = ProfitMandiConstants.URL_ADMIN_TOKEN, method = RequestMethod.POST)
34794 vikas.jang 583
    public ResponseEntity<?> getAdminToken(HttpServletRequest request, @RequestParam(name = "adminToken") String adminToken, @RequestParam(name = "emailId") String emailId) throws Exception {
32458 amit.gupta 584
        LOGGER.info("requested url : " + request.getRequestURL().toString());
585
        if (!adminToken.equals(validAdminToken)) {
586
            return responseSender.forbidden(null);
587
        }
34794 vikas.jang 588
        GoogleLoginRequest loginRequest = new GoogleLoginRequest();
589
        loginRequest.setToken(adminToken);
590
        loginRequest.setEmail(emailId);
591
        loginRequest.setType("Internal");
21469 amit.gupta 592
 
34794 vikas.jang 593
        return responseSender.ok(this.getAuthTokenMap(emailId, loginRequest));
25366 tejbeer 594
 
32458 amit.gupta 595
    }
25366 tejbeer 596
 
32458 amit.gupta 597
    @RequestMapping(value = "/mobileappsettings")
34794 vikas.jang 598
    public ResponseEntity<?> mobileAppSettings(HttpServletRequest request, @RequestParam(name = "t") int timestamp, @RequestParam(name = "imeinumber") String imeinumber) throws ProfitMandiBusinessException, ClientProtocolException, IOException {
32458 amit.gupta 599
        final String uri = "http://192.168.158.89/mobileappsettings?t=" + timestamp + "&imeinumber=" + imeinumber;
600
        final String BASIC_AUTH = "Basic " + Base64.getEncoder().encodeToString("dtr:dtr18Feb2015".getBytes());
601
        Map<String, String> headers = new HashMap<>();
602
        Map<String, String> params = new HashMap<>();
603
        headers.put("Authorization", BASIC_AUTH);
604
        if (timestamp == 0) {
605
            return responseSender.ok(OrderController.APP_SETTINGS);
606
        } else {
607
            return responseSender.ok(OrderController.APP_SETTINGS_BLANK);
608
        }
609
    }
26792 tejbeer 610
 
32458 amit.gupta 611
    @RequestMapping(value = "/mobileappsettings1", method = RequestMethod.POST)
612
    public ResponseEntity<?> mobileAppSettings1(HttpServletRequest request, @RequestParam(name = "t") int timestamp,
613
                                                @RequestParam(name = "imeinumber") String imeinumber)
614
            throws ProfitMandiBusinessException, ClientProtocolException, IOException {
615
        LocalDateTime settingsLastUpdated = LocalDateTime.ofEpochSecond(timestamp, 0, ZoneOffset.ofHoursMinutes(5, 30));
616
        List<MobileAppSetting> mobileAppSettings = mobileAppSettingsRepository.getSettingAftera(settingsLastUpdated);
26792 tejbeer 617
 
32458 amit.gupta 618
        List<MobileAppSettingsWrapper> mobileSettingsWrappersList = mobileAppSettings.stream()
619
                .map(x -> new MobileAppSettingsWrapper(x)).collect(Collectors.toList());
620
        SettingsWrapper wrapper = new SettingsWrapper(mobileSettingsWrappersList);
26792 tejbeer 621
 
32458 amit.gupta 622
        LOGGER.info("Wrapper {}", wrapper);
623
        return responseSender.ok(objectMapper.writeValueAsString(wrapper));
624
    }
22032 ashik.ali 625
 
32458 amit.gupta 626
    @RequestMapping(value = "/getPartners", method = RequestMethod.GET)
627
    @ApiImplicitParams({
628
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
629
    public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
630
                                         @RequestParam(value = "offset") int offset, @RequestParam(value = "limit") int limit)
631
            throws ProfitMandiBusinessException {
632
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
25366 tejbeer 633
 
32458 amit.gupta 634
        Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
25366 tejbeer 635
 
32458 amit.gupta 636
        Set<String> emails = storeGuyMap.get(authUser.getEmailId().toLowerCase());
637
        LOGGER.info("emails" + emails);
638
        List<User> users = userRepository.selectAllByEmails(new ArrayList<>(emails), offset, limit);
639
        List<Partner> partners = new ArrayList<>();
640
        for (User user : users) {
25458 tejbeer 641
 
32458 amit.gupta 642
            UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
643
            com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
644
            CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
25366 tejbeer 645
 
32458 amit.gupta 646
            Partner partner = new Partner();
647
            partner.setBusinessName(customRetailer.getBusinessName());
648
            partner.setPartnerId(customRetailer.getPartnerId());
649
            partner.setCartId(customRetailer.getCartId());
650
            partner.setEmail(customRetailer.getEmail());
651
            partner.setGstNumber(customRetailer.getGstNumber());
652
            partner.setDisplayName(customRetailer.getDisplayName());
653
            partner.setCity(customRetailer.getAddress().getCity());
654
            partner.setUserId(user.getId());
655
            partners.add(partner);
656
        }
657
        LOGGER.info("partners" + partners);
658
        return responseSender.ok(partners);
659
    }
25366 tejbeer 660
 
32458 amit.gupta 661
    @RequestMapping(value = "/user/refferal", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
662
    @ApiImplicitParams({
663
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
664
    public ResponseEntity<?> RefferalUser(HttpServletRequest request,
665
                                          @RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
666
        Refferal refferal = new Refferal();
667
        refferal.setFirstName(createRefferalRequest.getFirstName());
668
        refferal.setLastName(createRefferalRequest.getLastName());
669
        refferal.setMobile(createRefferalRequest.getMobile());
670
        refferal.setState(createRefferalRequest.getState());
671
        refferal.setCity(createRefferalRequest.getCity());
672
        refferal.setCreatedTimestamp(LocalDateTime.now());
673
        refferal.setUpdatedTimestamp(LocalDateTime.now());
674
        refferal.setStatus(RefferalStatus.pending);
675
        if (createRefferalRequest.isFofoAssociate()) {
676
            AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
677
            if (authUser == null) {
678
                Promoter promoter = promoterRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
679
                refferal.setRefereeName(promoter.getName());
680
                refferal.setRefereeEmail(promoter.getEmail());
681
                refferal.setRefereeMobile(promoter.getMobile());
682
            } else {
683
                refferal.setRefereeName(authUser.getFirstName());
684
                refferal.setRefereeEmail(authUser.getGmailId());
685
                refferal.setRefereeMobile(authUser.getMobileNumber());
686
            }
687
        } else {
688
            User user = userRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
689
            refferal.setRefereeName(user.getFirstName());
690
            refferal.setRefereeEmail(user.getEmailId());
691
            refferal.setRefereeMobile(user.getMobileNumber());
692
        }
25458 tejbeer 693
 
32458 amit.gupta 694
        refferalRepository.persist(refferal);
29892 tejbeer 695
 
32458 amit.gupta 696
        List<PartnerOnBoardingPanel> pobs = partnerOnBoardingPanelRepository
697
                .selectAllByPhoneNumber((Long.parseLong(refferal.getMobile())));
29892 tejbeer 698
 
32458 amit.gupta 699
        if (!pobs.isEmpty()) {
29892 tejbeer 700
 
32458 amit.gupta 701
            List<PartnerOnBoardingStatus> ponbStatus = pobs.stream().map(x -> x.getStatus())
702
                    .collect(Collectors.toList());
29892 tejbeer 703
 
32458 amit.gupta 704
            if (ponbStatus.contains(PartnerOnBoardingStatus.open)) {
705
                refferal.setStatus(RefferalStatus.rejected);
706
                refferal.setRejectedReason("This is already a Smartdukaan Partner.");
707
            } else if (ponbStatus.contains(PartnerOnBoardingStatus.pending)) {
708
                refferal.setStatus(RefferalStatus.rejected);
709
                refferal.setRejectedReason("This is already a Smartdukaan Partner.");
710
            } else {
711
                this.sendEmailToValidate(refferal);
712
            }
29892 tejbeer 713
 
32458 amit.gupta 714
        } else {
29892 tejbeer 715
 
32458 amit.gupta 716
            this.sendEmailToValidate(refferal);
29892 tejbeer 717
 
32458 amit.gupta 718
        }
719
        return responseSender.ok(true);
720
    }
29892 tejbeer 721
 
32458 amit.gupta 722
    private void sendEmailToValidate(Refferal refferal) throws MessagingException, UnsupportedEncodingException {
29892 tejbeer 723
 
32458 amit.gupta 724
        String subject = "Referral Validate Request for " + refferal.getRefereeEmail();
725
        String messageText = this.getMessageForReferral(refferal);
726
        MimeMessage message = mailSender.createMimeMessage();
727
        MimeMessageHelper helper = new MimeMessageHelper(message, true);
728
        String[] email = {"kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com"};
729
        helper.setSubject(subject);
730
        helper.setText(messageText, true);
731
        helper.setTo(email);
732
        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
733
        helper.setFrom(senderAddress);
734
        mailSender.send(message);
26792 tejbeer 735
 
32458 amit.gupta 736
    }
25488 tejbeer 737
 
32458 amit.gupta 738
    private String getMessageForReferral(Refferal referral) {
26792 tejbeer 739
 
32458 amit.gupta 740
        StringBuilder sb = new StringBuilder();
741
        sb.append("<html><body><p>Alert</p><p> Referral Requests:-</p>"
742
                + "<br/><table style='border:1px solid black ;padding: 5px';>");
743
        sb.append("<tbody>\n" + "	    				<tr>\n"
744
                + "	    					<th style='border:1px solid black;padding: 5px'>RefereeName</th>\n"
745
                + "	    					<th style='border:1px solid black;padding: 5px'>Referee Email</th>\n"
746
                + "	    					<th style='border:1px solid black;padding: 5px'>Referral Name</th>\n"
747
                + "	    					<th style='border:1px solid black;padding: 5px'>Refferal Mobile</th>\n"
748
                + "	    					<th style='border:1px solid black;padding: 5px'>city</th>\n"
749
                + "	    					<th style='border:1px solid black;padding: 5px'>state</th>\n"
750
                + "	    				</tr>");
26792 tejbeer 751
 
32458 amit.gupta 752
        sb.append("<tr>");
753
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeName() + "</td>");
26792 tejbeer 754
 
32458 amit.gupta 755
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeEmail() + "</td>");
756
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getFirstName() + "</td>");
757
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getMobile() + "</td>");
758
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getCity() + "</td>");
759
        sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getState() + "</td>");
26792 tejbeer 760
 
32458 amit.gupta 761
        sb.append("</tr>");
26792 tejbeer 762
 
32458 amit.gupta 763
        sb.append("</tbody></table></body></html>");
26792 tejbeer 764
 
32458 amit.gupta 765
        return sb.toString();
766
    }
26792 tejbeer 767
 
32458 amit.gupta 768
    @RequestMapping(value = "/user/refferalAmount", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
769
    @ApiImplicitParams({
770
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
771
    public ResponseEntity<?> RefferalAmount(HttpServletRequest request, @RequestParam String refereeEmail)
772
            throws Exception {
773
        LocalDateTime ldt = LocalDate.now().atStartOfDay().withDayOfMonth(16);
774
        DateRangeModel drm = new DateRangeModel();
775
        List<RefferalEarningModel> refferAmountModel = new ArrayList<RefferalEarningModel>();
776
        RefferalEarningModel rfm = new RefferalEarningModel();
777
        long currentMonthEstimaterefferal = 0;
778
        long currentMonthConfirmedrefferal = 0;
779
        if (LocalDateTime.now().isBefore(ldt)) {
780
            List<Refferal> allPendingRefferalBeforeCurrentMonth = refferalRepository
781
                    .selectByEmailIdAndStatusAndbeforeCurrentMonth(refereeEmail, RefferalStatus.pending);
782
            drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
783
            drm.setEndDate(LocalDateTime.now().withDayOfMonth(1));
25488 tejbeer 784
 
32458 amit.gupta 785
            List<Refferal> previousMonthapprovedRefferalAfterSixteen = refferalRepository
786
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
787
            List<Refferal> previousMonthtransferredRefferalAfterSixteen = refferalRepository
788
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
25488 tejbeer 789
 
32458 amit.gupta 790
            drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
791
            drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
25488 tejbeer 792
 
32458 amit.gupta 793
            List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
794
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
795
            List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
796
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
797
            long pendingRefferalBeforeCurrentMonth = allPendingRefferalBeforeCurrentMonth.size();
798
            long previousapprovedRefferalAfterSixteen = previousMonthapprovedRefferalAfterSixteen.size();
799
            long previoustransferredRefferalAfterSixteen = previousMonthtransferredRefferalAfterSixteen.size();
800
            long previousapprovedRefferalbeforeSixteen = previousMonthapprovedRefferalbeforeSixteen.size();
801
            long previoustransferredRefferalbeforeSixteen = previousMonthtransferredRefferalbeforeSixteen.size();
802
            long previousMonthEstimateRefferal = pendingRefferalBeforeCurrentMonth
803
                    + previousapprovedRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen;
804
            long previousMonthConfirmedRefferal = previousapprovedRefferalAfterSixteen
805
                    + previoustransferredRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen
806
                    + previoustransferredRefferalbeforeSixteen;
807
            rfm = refferAmountEarning(pendingRefferalBeforeCurrentMonth, previousMonthConfirmedRefferal,
808
                    YearMonth.now().minusMonths(1));
809
            refferAmountModel.add(rfm);
810
            LOGGER.info("previousMonthPendingApprovedRefferal" + previousMonthEstimateRefferal);
811
            LOGGER.info("previousMonthApprovedTransfferedRefferal" + previousMonthConfirmedRefferal);
25488 tejbeer 812
 
32458 amit.gupta 813
            List<Refferal> pendingofCurrentMonth = refferalRepository
814
                    .selectByEmailIdAndStatusAndBetweenDates(refereeEmail, RefferalStatus.pending, YearMonth.now());
815
            List<Refferal> approvedofCurrentMonth = refferalRepository.selectByEmailIdAndStatusAndDatesBetweenTimestamp(
816
                    refereeEmail, RefferalStatus.approved, YearMonth.now());
817
            List<Refferal> transferredofCurrentMonth = refferalRepository
818
                    .selectByEmailIdAndStatusAndDatesBetweenTimestamp(refereeEmail, RefferalStatus.transferred,
819
                            YearMonth.now());
820
            LOGGER.info("pendingofCurrentMonth" + pendingofCurrentMonth);
821
            long pendingofCurrentMonthCount = pendingofCurrentMonth.size();
822
            currentMonthEstimaterefferal = pendingofCurrentMonth.size() + approvedofCurrentMonth.size();
823
            currentMonthConfirmedrefferal = approvedofCurrentMonth.size() + transferredofCurrentMonth.size();
25509 tejbeer 824
 
32458 amit.gupta 825
            rfm = refferAmountEarning(pendingofCurrentMonthCount, currentMonthConfirmedrefferal, YearMonth.now());
25488 tejbeer 826
 
32458 amit.gupta 827
            refferAmountModel.add(rfm);
25488 tejbeer 828
 
32458 amit.gupta 829
        } else if (LocalDateTime.now().isAfter(ldt)) {
830
            drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
831
            drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
25488 tejbeer 832
 
32458 amit.gupta 833
            List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
834
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
835
            List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
836
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
25488 tejbeer 837
 
32458 amit.gupta 838
            drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
839
            drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
25488 tejbeer 840
 
32458 amit.gupta 841
            List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
842
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
25488 tejbeer 843
 
32458 amit.gupta 844
            LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
25488 tejbeer 845
 
32458 amit.gupta 846
            List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
847
                    .filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
848
            List<Refferal> previousAndcurrentMonthtransferredRefferal = refferalRepository
849
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
850
            List<Refferal> preCurrMonthtransferred = previousAndcurrentMonthtransferredRefferal.stream()
851
                    .filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
25488 tejbeer 852
 
33792 ranu 853
            long approvedRefferalCount = previousMonthapprovedRefferalbeforeSixteen.size()
32458 amit.gupta 854
                    + previousMonthtransferredRefferalbeforeSixteen.size() + preCurrMonthapproved.size()
855
                    + preCurrMonthtransferred.size();
856
            rfm = new RefferalEarningModel();
33792 ranu 857
            rfm.setActualEarning(approvedRefferalCount * PER_REFERRAL_EARNING);
27595 tejbeer 858
 
32458 amit.gupta 859
            rfm.setYearMonth(YearMonth.now().minusMonths(1));
860
            rfm.setPendingRefferal(0);
33792 ranu 861
            rfm.setApprovedRefferal(approvedRefferalCount);
32458 amit.gupta 862
            refferAmountModel.add(rfm);
863
            List<Refferal> allpendingRefferal = refferalRepository.selectByEmailIdAndStatus(refereeEmail,
864
                    RefferalStatus.pending);
865
            LOGGER.info("allpendingRefferal" + allpendingRefferal);
25488 tejbeer 866
 
32458 amit.gupta 867
            drm.setStartDate(LocalDateTime.now().withDayOfMonth(16));
868
            drm.setEndDate(LocalDateTime.now().plusMonths(1).withDayOfMonth(1));
25488 tejbeer 869
 
32458 amit.gupta 870
            List<Refferal> currentMonthapprovedRefferalAfterSixteen = refferalRepository
871
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
872
            List<Refferal> currentMonthtransferredRefferalAfterSixteen = refferalRepository
873
                    .selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
874
            LOGGER.info("currentMonthapprovedRefferalAfterSixteen" + currentMonthapprovedRefferalAfterSixteen);
875
            drm.setStartDate(LocalDateTime.now().withDayOfMonth(1));
876
            drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
25488 tejbeer 877
 
32458 amit.gupta 878
            List<Refferal> currentMonthapprovedRefferalbeforeSixteen = refferalRepository
879
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
880
            List<Refferal> currentMonthtransferredRefferalbeforeSixteen = refferalRepository
881
                    .selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
882
            LOGGER.info("currentMonthapprovedRefferalbeforeSixteen" + currentMonthapprovedRefferalbeforeSixteen);
883
            long pendingrefferalcount = allpendingRefferal.size();
884
            currentMonthConfirmedrefferal = currentMonthapprovedRefferalAfterSixteen.size()
885
                    + currentMonthtransferredRefferalAfterSixteen.size()
886
                    + currentMonthapprovedRefferalbeforeSixteen.size()
887
                    + currentMonthtransferredRefferalbeforeSixteen.size();
25509 tejbeer 888
 
32458 amit.gupta 889
            rfm = refferAmountEarning(pendingrefferalcount, currentMonthConfirmedrefferal, YearMonth.now());
890
            refferAmountModel.add(rfm);
891
            LOGGER.info("currentMonthpendingApprovedrefferal" + currentMonthEstimaterefferal);
25488 tejbeer 892
 
32458 amit.gupta 893
            LOGGER.info("currentMonthapprovedTransferredrefferal" + currentMonthConfirmedrefferal);
25488 tejbeer 894
 
32458 amit.gupta 895
        }
896
        RefferalEarning re = new RefferalEarning();
897
        re.setTimestamp(LocalDateTime.now());
898
        re.setRefferalEarningModel(refferAmountModel);
899
        return responseSender.ok(re);
900
    }
25488 tejbeer 901
 
32458 amit.gupta 902
    private RefferalEarningModel refferAmountEarning(long pendingRefferalValue, long confirmedRefferalValue,
903
                                                     YearMonth yearMonth) {
904
        RefferalEarningModel rfm = new RefferalEarningModel();
905
        rfm.setYearMonth(yearMonth);
906
        rfm.setPendingRefferal(pendingRefferalValue);
907
        rfm.setApprovedRefferal(confirmedRefferalValue);
908
        long estimateRefferalValue = pendingRefferalValue + confirmedRefferalValue;
25488 tejbeer 909
 
33194 amit.gupta 910
        rfm.setMaximumEarning(estimateRefferalValue * PER_REFERRAL_EARNING);
27595 tejbeer 911
 
33194 amit.gupta 912
        rfm.setMinimumEarning(confirmedRefferalValue * PER_REFERRAL_EARNING);
27595 tejbeer 913
 
32458 amit.gupta 914
        return rfm;
915
    }
25979 tejbeer 916
 
32458 amit.gupta 917
    @RequestMapping(value = "/user/getReferals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
918
    @ApiImplicitParams({
919
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
920
    public ResponseEntity<?> getReferals(HttpServletRequest request, @RequestParam RefferalStatus status)
921
            throws Exception {
922
        int userId = (int) request.getAttribute("userId");
29890 tejbeer 923
 
32458 amit.gupta 924
        User user = userRepository.selectById(userId);
925
        UserCart uc = userAccountRepository.getUserCart(userId);
29890 tejbeer 926
 
32458 amit.gupta 927
        List<Refferal> refferals = refferalRepository.selectByEmailIdAndStatus(user.getEmailId(), status);
928
        return responseSender.ok(refferals);
929
    }
29890 tejbeer 930
 
32458 amit.gupta 931
    @RequestMapping(value = "/user/partnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
932
    @ApiImplicitParams({
933
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
934
    public ResponseEntity<?> PartnerTarget(HttpServletRequest request) throws Exception {
935
        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
936
        int retailerId = userAccountRepository.selectRetailerIdByUserId(userId);
937
        PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(retailerId, LocalDate.now());
25979 tejbeer 938
 
32458 amit.gupta 939
        return responseSender.ok(partnerType);
940
    }
26636 amit.gupta 941
 
32458 amit.gupta 942
    @RequestMapping(value = "/user/authUser", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
943
    @ApiImplicitParams({
944
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
945
    public ResponseEntity<?> authUserDetail(HttpServletRequest request, @RequestParam int userId) throws Exception {
946
        User user = userRepository.selectById(userId);
947
        AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
948
        return responseSender.ok(authUser);
949
    }
27425 tejbeer 950
 
21248 ashik.ali 951
}
26636 amit.gupta 952
 
953
class MobileAppSettingsWrapper {
32458 amit.gupta 954
    @JsonProperty(value = "Mobileappsetting")
955
    private MobileAppSetting mobileAppSettings;
26636 amit.gupta 956
 
32458 amit.gupta 957
    public MobileAppSettingsWrapper(MobileAppSetting mobileAppSettings) {
958
        super();
959
        this.mobileAppSettings = mobileAppSettings;
960
    }
26642 amit.gupta 961
 
32458 amit.gupta 962
    public MobileAppSetting getMobileAppSettings() {
963
        return mobileAppSettings;
964
    }
26642 amit.gupta 965
 
32458 amit.gupta 966
    public void setMobileAppSettings(MobileAppSetting mobileAppSettings) {
967
        this.mobileAppSettings = mobileAppSettings;
968
    }
26643 amit.gupta 969
 
32458 amit.gupta 970
    @Override
971
    public String toString() {
972
        return "MobileAppSettingsWrapper [mobileAppSettings=" + mobileAppSettings + "]";
973
    }
26644 amit.gupta 974
 
26636 amit.gupta 975
}
976
 
977
class SettingsWrapper {
32458 amit.gupta 978
    private List<MobileAppSettingsWrapper> settings;
26644 amit.gupta 979
 
32458 amit.gupta 980
    public SettingsWrapper(List<MobileAppSettingsWrapper> settings) {
981
        super();
982
        this.settings = settings;
983
    }
26636 amit.gupta 984
 
32458 amit.gupta 985
    @Override
986
    public String toString() {
987
        return "SettingsWrapper [settings=" + settings + "]";
988
    }
26642 amit.gupta 989
 
32458 amit.gupta 990
    public List<MobileAppSettingsWrapper> getSettings() {
991
        return settings;
992
    }
26642 amit.gupta 993
 
32458 amit.gupta 994
    public void setSettings(List<MobileAppSettingsWrapper> settings) {
995
        this.settings = settings;
996
    }
26642 amit.gupta 997
 
27425 tejbeer 998
}