Subversion Repositories SmartDukaan

Rev

Rev 37101 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
22981 ashik.ali 1
package com.spice.profitmandi.web.controller;
2
 
23494 ashik.ali 3
import com.spice.profitmandi.common.enumuration.ContentType;
23955 govind 4
import com.spice.profitmandi.common.enumuration.CounterSize;
28825 tejbeer 5
import com.spice.profitmandi.common.enumuration.FofoType;
22981 ashik.ali 6
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
30017 amit.gupta 7
import com.spice.profitmandi.common.model.*;
28024 tejbeer 8
import com.spice.profitmandi.common.util.Utils;
23330 ashik.ali 9
import com.spice.profitmandi.common.web.util.ResponseSender;
27231 tejbeer 10
import com.spice.profitmandi.dao.entity.auth.AuthUser;
30017 amit.gupta 11
import com.spice.profitmandi.dao.entity.dtr.*;
12
import com.spice.profitmandi.dao.entity.fofo.*;
34527 tejus.loha 13
import com.spice.profitmandi.dao.entity.onBoarding.LoiForm;
24159 tejbeer 14
import com.spice.profitmandi.dao.entity.user.Location;
15
import com.spice.profitmandi.dao.entity.user.Promoter;
24123 tejbeer 16
import com.spice.profitmandi.dao.entity.user.User;
27231 tejbeer 17
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
35648 ranu 18
import com.spice.profitmandi.dao.repository.catalog.BrandsRepository;
27231 tejbeer 19
import com.spice.profitmandi.dao.repository.cs.CsService;
28272 tejbeer 20
import com.spice.profitmandi.dao.repository.cs.RetailerBrandsLimitService;
30017 amit.gupta 21
import com.spice.profitmandi.dao.repository.dtr.*;
27797 tejbeer 22
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeRepository;
23
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
28381 tejbeer 24
import com.spice.profitmandi.dao.repository.fofo.PincodePartnerRepository;
35289 amit 25
import com.spice.profitmandi.dao.repository.trialOnboarding.TrialFormRepository;
24123 tejbeer 26
import com.spice.profitmandi.dao.repository.user.LocationRepository;
34527 tejus.loha 27
import com.spice.profitmandi.dao.repository.user.LoiFormRepository;
24159 tejbeer 28
import com.spice.profitmandi.dao.repository.user.PromoterRepository;
24123 tejbeer 29
import com.spice.profitmandi.dao.repository.user.UserRepository;
33990 tejus.loha 30
import com.spice.profitmandi.dao.repository.warehouse.WarehouseSupplierInvoiceRepository;
24349 amit.gupta 31
import com.spice.profitmandi.service.PartnerInvestmentService;
33814 ranu 32
import com.spice.profitmandi.service.authentication.RoleManager;
32731 ranu 33
import com.spice.profitmandi.service.catalog.BrandsService;
24159 tejbeer 34
import com.spice.profitmandi.service.inventory.InventoryService;
22981 ashik.ali 35
import com.spice.profitmandi.service.user.RetailerService;
28908 tejbeer 36
import com.spice.profitmandi.service.user.StoreTimelineTatService;
25276 amit.gupta 37
import com.spice.profitmandi.web.model.LoginDetails;
38
import com.spice.profitmandi.web.util.CookiesProcessor;
24123 tejbeer 39
import com.spice.profitmandi.web.util.MVCResponseSender;
30017 amit.gupta 40
import org.apache.logging.log4j.LogManager;
41
import org.apache.logging.log4j.Logger;
42
import org.json.JSONObject;
43
import org.springframework.beans.factory.annotation.Autowired;
44
import org.springframework.beans.factory.annotation.Qualifier;
45
import org.springframework.core.io.InputStreamResource;
46
import org.springframework.http.HttpHeaders;
47
import org.springframework.http.HttpStatus;
48
import org.springframework.http.ResponseEntity;
49
import org.springframework.stereotype.Controller;
35648 ranu 50
import org.springframework.transaction.annotation.Transactional;
30017 amit.gupta 51
import org.springframework.ui.Model;
52
import org.springframework.web.bind.annotation.*;
22981 ashik.ali 53
 
30017 amit.gupta 54
import javax.servlet.http.HttpServletRequest;
55
import java.io.File;
56
import java.io.FileInputStream;
57
import java.io.FileNotFoundException;
58
import java.time.LocalDate;
59
import java.time.LocalDateTime;
60
import java.util.*;
61
import java.util.stream.Collectors;
62
 
22981 ashik.ali 63
@Controller
35458 amit 64
@Transactional(rollbackFor = Throwable.class)
22981 ashik.ali 65
public class RetailerController {
66
 
33990 tejus.loha 67
    private static final Logger LOGGER = LogManager.getLogger(RetailerController.class);
37630 amit 68
    private static final List<String> CHANGE_PARTNER_CATEGORY_PERMISSIONS = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com");
33990 tejus.loha 69
    @Autowired
70
    PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
71
    @Autowired
72
    BrandsService brandsService;
73
    @Autowired
74
    private RetailerService retailerService;
75
    @Autowired
76
    private RetailerRepository retailerRepository;
77
    @Autowired
78
    private PincodePartnerRepository pincodePartnerRepository;
79
    @Autowired
80
    private BrandLimitRepository brandLimitRepository;
81
    @Autowired
82
    private RetailerBrandsLimitService retailerBrandsLimitService;
83
    @Autowired
84
    private RetailerBrandsLimitRepository retailerBrandsLimitRepository;
85
    @Autowired
86
    private ShopRepository shopRepository;
87
    @Autowired
88
    private RetailerBlockBrandsRepository retailerBlockBrandsRepository;
89
    @Autowired
90
    private FofoStoreRepository fofoStoreRepository;
91
    @Autowired
92
    private DocumentRepository documentRepository;
93
    @Autowired
94
    private CookiesProcessor cookiesProcessor;
95
    @Autowired
96
    @Qualifier("userUserRepository")
97
    private UserRepository userRepository;
98
    @Autowired
99
    private AuthRepository authRepository;
100
    @Autowired
101
    private CsService csService;
102
    @Autowired
103
    private LocationRepository locationRepository;
104
    @Autowired
105
    private ResponseSender<?> responseSender;
106
    @Autowired
107
    private MVCResponseSender mvcResponseSender;
108
    @Autowired
109
    private InventoryService inventoryService;
110
    @Autowired
111
    private PromoterRepository promoterRepository;
112
    @Autowired
113
    private PartnerInvestmentService partnerInvestmentService;
114
    @Autowired
115
    private Mongo mongoClient;
116
    @Autowired
117
    private PartnerTypeChangeService partnerTypeChangeService;
118
    @Autowired
119
    private PartnerTypeChangeRepository partnerTypeChangeRepository;
120
    @Autowired
121
    private StoreTimelineTatService storeTimelineTatService;
122
    @Autowired
123
    private RoleManager roleManager;
124
    @Autowired
125
    private RetailerContactRepository retailerContactRepository;
126
    @Autowired
35648 ranu 127
    private BrandsRepository brandsRepository;
128
    @Autowired
33990 tejus.loha 129
    private WarehouseSupplierInvoiceRepository warehouseSupplierInvoiceRepository;
24124 govind 130
 
35289 amit 131
    @Autowired
132
    TrialFormRepository trialFormRepository;
133
 
33990 tejus.loha 134
    @RequestMapping(value = "/retailerDetails", method = RequestMethod.GET)
135
    public String retailerInfoByEmailIdOrMobileNumber(HttpServletRequest request,
136
                                                      @RequestParam(name = ProfitMandiConstants.EMAIL_ID_OR_MOBILE_NUMBER) String emailIdOrMobileNumber,
137
                                                      Model model) throws ProfitMandiBusinessException {
138
        LOGGER.info("Request Received at url {} with emailIdOrMobileNumber {}", request.getRequestURI(),
139
                emailIdOrMobileNumber);
24124 govind 140
 
33990 tejus.loha 141
        Map<String, Object> map = retailerService.getByEmailIdOrMobileNumber(emailIdOrMobileNumber);
35372 aman 142
        LOGGER.info("map - {}", map.get("trialForm"));
143
        LOGGER.info("map - {}", map);
33990 tejus.loha 144
        model.addAllAttributes(map);
28832 tejbeer 145
 
33990 tejus.loha 146
        model.addAttribute("counterSizes", CounterSize.values());
147
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
28832 tejbeer 148
 
35375 aman 149
        LOGGER.info("warehouseMap {}", warehouseMap);
33990 tejus.loha 150
        model.addAttribute("warehouses", warehouseMap);
151
        model.addAttribute("fofoTypes", FofoType.values());
152
        if (map.containsKey("retailer")) {
153
            Retailer retailer = (Retailer) map.get("retailer");
154
            User user = userRepository.selectById(retailer.getId());
155
            if (user.getLocation() != null) {
156
                Location location = locationRepository.selectById(user.getLocation());
157
                model.addAttribute("locationdetail", location);
158
                LOGGER.info("location" + location);
159
            }
160
        }
161
        return "retailer-details";
162
    }
28272 tejbeer 163
 
34527 tejus.loha 164
    @Autowired
165
    LoiFormRepository loiFormRepository;
166
 
33990 tejus.loha 167
    @RequestMapping(value = "/retailerDetails", method = RequestMethod.PUT)
168
    public String updateRetailerDetails(HttpServletRequest request,
169
                                        @RequestBody UpdateRetailerRequest updateRetailerRequest, Model model) throws ProfitMandiBusinessException {
170
        LOGGER.info("Request Received at url {} with body {}", request.getRequestURI(), updateRetailerRequest);
34639 tejus.loha 171
        String storeCode = updateRetailerRequest.getFofostorecode();
34640 tejus.loha 172
        boolean isStoreCodeNotCreated = (storeCode == null || storeCode.isEmpty());
173
        LOGGER.info("isStoreCodeNotCreated - "+isStoreCodeNotCreated);
174
        if (!updateRetailerRequest.getFofoType().equals(FofoType.INTERNAL) && isStoreCodeNotCreated) {
34631 tejus.loha 175
            checkLoiCompletion(updateRetailerRequest);
34527 tejus.loha 176
        }
33990 tejus.loha 177
        Map<String, Object> map = retailerService.updateRetailerDetails(updateRetailerRequest);
178
        //retailerService.up
28272 tejbeer 179
 
33990 tejus.loha 180
        model.addAllAttributes(map);
181
        model.addAttribute("counterSizes", CounterSize.values());
182
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
183
        LOGGER.info("warehouseMap", warehouseMap);
184
        model.addAttribute("warehouses", warehouseMap);
185
        model.addAttribute("fofoTypes", FofoType.values());
186
        return "retailer-details";
187
    }
28272 tejbeer 188
 
34631 tejus.loha 189
    private void checkLoiCompletion(UpdateRetailerRequest updateRetailerRequest) throws ProfitMandiBusinessException {
35305 amit 190
        TrialForm trialForm;
191
        try {
192
            trialForm = trialFormRepository.selectByEmailOrMobile(updateRetailerRequest.getUserMobileNumber());
193
            if (updateRetailerRequest.getFofoType().equals(FofoType.INTERNAL) || trialForm != null) {
194
                return; // Early return for internal type
195
            }
196
        } catch (Exception e) {
197
            trialForm = null;
198
        }
35289 amit 199
        if (updateRetailerRequest.getFofoType().equals(FofoType.INTERNAL) || trialForm != null) {
34631 tejus.loha 200
            return; // Early return for internal type
201
        }
202
        String userMobile = updateRetailerRequest.getUserMobileNumber();
203
        String gstNumber = updateRetailerRequest.getGstNumber();
204
        LoiForm loiForm = findLoiForm(userMobile, gstNumber);
205
        if (loiForm == null) {
34640 tejus.loha 206
            throw new ProfitMandiBusinessException("Loi Not Available", "Message - ", "Please fill the LOI_FORM and try again");
34631 tejus.loha 207
        }
208
        if (loiForm.getOnBoardingId() <= 0) {
209
            throw new ProfitMandiBusinessException("Loi not completed", "Message - ", "Please Complete LOI_FORM and try again");
210
        }
211
    }
34640 tejus.loha 212
 
34631 tejus.loha 213
    private LoiForm findLoiForm(String mobile, String gstNumber) throws ProfitMandiBusinessException {
214
        LoiForm form = loiFormRepository.selectByEmailOrMobile(mobile);
215
        if (form == null && gstNumber != null) {
216
            form = loiFormRepository.selectByEqualsKeyValue("gstNo", gstNumber);
217
        }
218
        return form;
219
    }
220
 
33990 tejus.loha 221
    @RequestMapping(value = "/retailer/update-email", method = RequestMethod.POST)
222
    public String updateRetailerEmail(@RequestParam("newEmail") String newEmail, @RequestParam("fofoID") int fofoID) throws ProfitMandiBusinessException {
223
        retailerService.updateRetailerEmail(fofoID, newEmail);
224
        return "retailer-details";
225
    }
24124 govind 226
 
33990 tejus.loha 227
    @RequestMapping(value = "/retailerInfo", method = RequestMethod.GET)
36369 vikas 228
    public String retailerInfo(HttpServletRequest request, Model model) throws Exception {
229
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
230
        model.addAttribute("loginDetails", loginDetails);
33990 tejus.loha 231
        return "retailer-info";
232
    }
28024 tejbeer 233
 
33990 tejus.loha 234
    @RequestMapping(value = "/district/all/stateName", method = RequestMethod.GET)
235
    public ResponseEntity<?> getAllDistrict(@RequestParam(name = "stateName") String stateName) {
236
        return responseSender.ok(retailerService.getAllDistrictMaster(stateName));
237
    }
24124 govind 238
 
33990 tejus.loha 239
    @RequestMapping(value = "/retailerDocument/documentId", method = RequestMethod.GET)
240
    public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,
241
                                                  @RequestParam(name = ProfitMandiConstants.DOCUMENT_ID) int documentId,
242
                                                  @RequestParam(name = ProfitMandiConstants.RETAILER_ID) int retailerId) throws ProfitMandiBusinessException {
243
        Document document = documentRepository.selectById(documentId);
244
        Retailer retailer = retailerRepository.selectById(retailerId);
24124 govind 245
 
33990 tejus.loha 246
        if (retailer.getDocumentId() == null) {
247
            throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, retailer.getId(), "RTLR_1012");
248
        }
249
        if (retailer.getDocumentId() != documentId) {
250
            throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, documentId, "RTLR_1014");
251
        }
252
        return responseSender.ok(document);
253
    }
25276 amit.gupta 254
 
33990 tejus.loha 255
    @RequestMapping(value = "/retailerDocument/download", method = RequestMethod.GET)
256
    public ResponseEntity<?> downloadRetailerDocument(HttpServletRequest request,
257
                                                      @RequestParam(name = ProfitMandiConstants.RETAILER_ID) int retailerId, Model model)
258
            throws ProfitMandiBusinessException {
24124 govind 259
 
33990 tejus.loha 260
        Retailer retailer = retailerRepository.selectById(retailerId);
27231 tejbeer 261
 
33990 tejus.loha 262
        if (retailer.getDocumentId() == null) {
263
            throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, retailer.getId(), "RTLR_1012");
264
        }
27231 tejbeer 265
 
33990 tejus.loha 266
        Document document = documentRepository.selectById(retailer.getDocumentId());
24124 govind 267
 
33990 tejus.loha 268
        FileInputStream file = null;
269
        try {
270
            file = new FileInputStream(document.getPath() + File.separator + document.getName());
271
        } catch (FileNotFoundException e) {
272
            LOGGER.error("Retailer Document file not found : ", e);
273
            throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
274
        }
275
        // ByteArrayOutputStream byteArrayOutputStream = new
276
        // ByteArrayOutputStream();
277
        // ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
24124 govind 278
 
33990 tejus.loha 279
        final HttpHeaders headers = new HttpHeaders();
280
        String contentType = "";
281
        if (document.getContentType() == ContentType.JPEG) {
282
            contentType = "image/jpeg";
283
        } else if (document.getContentType() == ContentType.PNG) {
284
            contentType = "image/png";
285
        } else if (document.getContentType() == ContentType.PDF) {
286
            contentType = "application/pdf";
287
        }
288
        headers.set("Content-Type", contentType);
289
        headers.set("Content-disposition", "inline; filename=" + document.getName());
290
        headers.setContentLength(document.getSize());
291
        final InputStreamResource inputStreamResource = new InputStreamResource(file);
292
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
24124 govind 293
 
33990 tejus.loha 294
        // return
295
        // responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
296
    }
24159 tejbeer 297
 
33990 tejus.loha 298
    @RequestMapping(value = "/retailerShopDocument/shopId", method = RequestMethod.GET)
299
    public ResponseEntity<?> retailerShopDocumentById(HttpServletRequest request,
300
                                                      @RequestParam(name = ProfitMandiConstants.SHOP_ID) int shopId,
301
                                                      @RequestParam(name = ProfitMandiConstants.RETAILER_ID) int retailerId) throws ProfitMandiBusinessException {
302
        Shop shop = shopRepository.selectById(shopId);
24159 tejbeer 303
 
33990 tejus.loha 304
        if (shop.getRetailerId() != retailerId) {
305
            throw new ProfitMandiBusinessException(ProfitMandiConstants.SHOP_ID, shop.getId(), "SHP_1004");
306
        }
24349 amit.gupta 307
 
33990 tejus.loha 308
        if (shop.getDocumentId() == null) {
309
            throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, shop.getId(), "SHP_1005");
310
        }
24159 tejbeer 311
 
33990 tejus.loha 312
        Document document = documentRepository.selectById(shop.getDocumentId());
313
        return responseSender.ok(document);
314
    }
27797 tejbeer 315
 
33990 tejus.loha 316
    @RequestMapping(value = "/retailerShopDocument/download", method = RequestMethod.GET)
317
    public ResponseEntity<?> downloadRetailerShopDocument(HttpServletRequest request,
318
                                                          @RequestParam(name = ProfitMandiConstants.SHOP_ID) int shopId,
319
                                                          @RequestParam(name = ProfitMandiConstants.RETAILER_ID) int retailerId, Model model)
320
            throws ProfitMandiBusinessException {
27797 tejbeer 321
 
33990 tejus.loha 322
        Shop shop = shopRepository.selectById(shopId);
28908 tejbeer 323
 
33990 tejus.loha 324
        if (shop.getRetailerId() != retailerId) {
325
            throw new ProfitMandiBusinessException(ProfitMandiConstants.SHOP_ID, shop.getId(), "SHP_1004");
326
        }
28908 tejbeer 327
 
33990 tejus.loha 328
        if (shop.getDocumentId() == null) {
329
            throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, shop.getId(), "SHP_1005");
330
        }
33814 ranu 331
 
33990 tejus.loha 332
        Document document = documentRepository.selectById(shop.getDocumentId());
33814 ranu 333
 
33990 tejus.loha 334
        FileInputStream file = null;
335
        try {
336
            file = new FileInputStream(document.getPath() + File.separator + document.getName());
337
        } catch (FileNotFoundException e) {
338
            LOGGER.error("Retailer Document file not found : ", e);
339
            throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
340
        }
341
        // ByteArrayOutputStream byteArrayOutputStream = new
342
        // ByteArrayOutputStream();
343
        // ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
28071 tejbeer 344
 
33990 tejus.loha 345
        final HttpHeaders headers = new HttpHeaders();
346
        String contentType = "";
347
        if (document.getContentType() == ContentType.JPEG) {
348
            contentType = "image/jpeg";
349
        } else if (document.getContentType() == ContentType.PNG) {
350
            contentType = "image/png";
351
        } else if (document.getContentType() == ContentType.PDF) {
352
            contentType = "application/pdf";
353
        }
354
        headers.set("Content-Type", contentType);
355
        headers.set("Content-disposition", "inline; filename=" + document.getName());
356
        headers.setContentLength(document.getSize());
357
        final InputStreamResource inputStreamResource = new InputStreamResource(file);
358
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
28071 tejbeer 359
 
33990 tejus.loha 360
        // return
361
        // responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
362
    }
28071 tejbeer 363
 
33990 tejus.loha 364
    @GetMapping(value = "/getstore")
33247 ranu 365
    public String getstore(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30017 amit.gupta 366
 
33990 tejus.loha 367
        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
368
                .collect(Collectors.toList());
30426 tejbeer 369
 
33990 tejus.loha 370
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
30426 tejbeer 371
 
33990 tejus.loha 372
        Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = fofoIds.stream().map(x -> customRetailerMap.get(x))
373
                .filter(x -> x != null).collect(Collectors.toList()).stream()
374
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
30426 tejbeer 375
 
33990 tejus.loha 376
        //LOGGER.info("fofoIds" + fofoIds);
377
        model.addAttribute("fofoIdsAndCustomRetailer", fofoIdsAndCustomRetailer);
378
        //LOGGER.info("fofoIdsAndCustomRetailer" + fofoIdsAndCustomRetailer);
379
        model.addAttribute("fofoIds", fofoIds);
24124 govind 380
 
33990 tejus.loha 381
        return "store";
29267 manish 382
 
33990 tejus.loha 383
    }
30017 amit.gupta 384
 
33990 tejus.loha 385
    @RequestMapping(value = "/getPartnerinfo")
386
    public String getPartnerinfo(HttpServletRequest request, @RequestBody SelectStorePartnerInfo selectStorePartnerInfo,
387
                                 Model model) throws ProfitMandiBusinessException {
388
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
389
        //LOGGER.info("selectStorePartnerInfo" + selectStorePartnerInfo.getUserIds());
390
        List<FofoStore> fofoStores = fofoStoreRepository.selectByRetailerIds(selectStorePartnerInfo.getUserIds());
391
        //LOGGER.info("fofoStoresInfo" + fofoStores);
392
        Map<Integer, Boolean> investments = new HashMap<>();
32207 amit.gupta 393
 
33990 tejus.loha 394
        for (FofoStore fofoStore : fofoStores) {
395
            boolean isOk = false;
396
            if (fofoStore.getGraceDate() != null && fofoStore.getGraceDate().isAfter(LocalDate.now())) {
397
                isOk = true;
398
            } else {
399
                try {
400
                    isOk = partnerInvestmentService.isInvestmentOk(fofoStore.getId(), ProfitMandiConstants.MIN_INVESTMENT_PERCENTAGE,
401
                            ProfitMandiConstants.CUTOFF_INVESTMENT);
402
                    if (fofoStore.getGraceCount() > 0) {
403
                        fofoStore.setGraceDate(null);
404
                        fofoStore.setGraceCount(0);
405
                    }
406
                } catch (ProfitMandiBusinessException e) {
407
                }
408
            }
409
            investments.put(fofoStore.getId(), isOk);
410
        }
29267 manish 411
 
33990 tejus.loha 412
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(false);
413
        model.addAttribute("fofoStores", fofoStores);
414
        model.addAttribute("investments", investments);
415
        model.addAttribute("customRetailers", customRetailers);
416
        boolean canChangeCategory = CHANGE_PARTNER_CATEGORY_PERMISSIONS.contains(loginDetails.getEmailId());
417
        model.addAttribute("canChangeCategory", canChangeCategory);
29267 manish 418
 
33990 tejus.loha 419
        return "store-investment";
29267 manish 420
 
33990 tejus.loha 421
    }
29267 manish 422
 
33990 tejus.loha 423
    @GetMapping(value = "/getAllStores")
424
    public String getAllStores(HttpServletRequest request, Model model) throws Exception {
30017 amit.gupta 425
 
33990 tejus.loha 426
        List<FofoStore> fofoStores = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive())
427
                .collect(Collectors.toList());
428
        Map<Integer, Boolean> investments = new HashMap<>();
24124 govind 429
 
33990 tejus.loha 430
        for (FofoStore fofoStore : fofoStores) {
431
            boolean isOk = false;
432
            if (fofoStore.getGraceDate() != null && fofoStore.getGraceDate().isAfter(LocalDate.now())) {
433
                isOk = true;
434
            } else {
435
                try {
436
                    isOk = partnerInvestmentService.isInvestmentOk(fofoStore.getId(), ProfitMandiConstants.MIN_INVESTMENT_PERCENTAGE,
437
                            ProfitMandiConstants.CUTOFF_INVESTMENT);
438
                    if (fofoStore.getGraceCount() > 0) {
439
                        fofoStore.setGraceDate(null);
440
                        fofoStore.setGraceCount(0);
441
                    }
442
                } catch (ProfitMandiBusinessException e) {
443
                }
444
            }
445
            investments.put(fofoStore.getId(), isOk);
446
        }
24124 govind 447
 
33990 tejus.loha 448
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(false);
449
        model.addAttribute("fofoStores", fofoStores);
450
        model.addAttribute("investments", investments);
451
        model.addAttribute("customRetailers", customRetailers);
24124 govind 452
 
33990 tejus.loha 453
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
454
        boolean canChangeCategory = CHANGE_PARTNER_CATEGORY_PERMISSIONS.contains(loginDetails.getEmailId());
455
        model.addAttribute("canChangeCategory", canChangeCategory);
24124 govind 456
 
33990 tejus.loha 457
        return "store-investment";
32207 amit.gupta 458
 
33990 tejus.loha 459
    }
24124 govind 460
 
33990 tejus.loha 461
    @GetMapping(value = "/getPartnerCategory")
33247 ranu 462
    public String getPartnerCategory(HttpServletRequest request, @RequestParam int fofoId, Model model) throws ProfitMandiBusinessException {
27797 tejbeer 463
 
33990 tejus.loha 464
        PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId, LocalDate.now());
465
        List<PartnerType> partnerTypes = partnerType.nextPartnerTypes();
466
        LOGGER.info("partnerType" + partnerTypes);
467
        model.addAttribute("partnerTypes", partnerTypes);
468
        model.addAttribute("fofoId", fofoId);
469
        return "partner-category";
470
    }
27797 tejbeer 471
 
33990 tejus.loha 472
    @PostMapping(value = "/updatePartnerCategory")
473
    public String updatePartnerCategory(HttpServletRequest request, @RequestParam(name = "fofoId") int fofoId,
35674 amit 474
                                        @RequestParam(name = "partnerType") PartnerType partnerType,
475
                                        @RequestParam(name = "durationMonths", defaultValue = "1") int durationMonths,
476
                                        Model model) throws Exception {
27797 tejbeer 477
 
35509 amit 478
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
479
 
35674 amit 480
        if (durationMonths < 1 || durationMonths > 3) {
481
            durationMonths = 1;
482
        }
483
 
484
        LocalDate startOfMonth = LocalDate.now().withDayOfMonth(1);
485
        for (int i = 0; i < durationMonths; i++) {
486
            PartnerTypeChange ptc = new PartnerTypeChange();
487
            ptc.setFofoId(fofoId);
488
            ptc.setPartnerType(partnerType);
489
            ptc.setCreateTimestamp(startOfMonth.plusMonths(i).atStartOfDay());
490
            ptc.setSource(PartnerTypeSource.MANUAL);
491
            ptc.setUpgradedBy(loginDetails.getEmailId());
492
            partnerTypeChangeRepository.persist(ptc);
493
        }
33990 tejus.loha 494
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
27797 tejbeer 495
 
33990 tejus.loha 496
        return "response";
497
    }
27797 tejbeer 498
 
33990 tejus.loha 499
    @GetMapping(value = "/partners")
500
    public String getStoreName(HttpServletRequest request, Model model, @RequestParam String query) throws Exception {
501
        model.addAttribute("response1",
502
                mvcResponseSender.createResponseString(retailerService.getFofoRetailers(false).values().stream()
503
                        .filter(x -> x.getDisplayName().toLowerCase().matches(".*?" + query.toLowerCase() + ".*?"))
504
                        .collect(Collectors.toList())));
505
        return "response";
506
    }
24349 amit.gupta 507
 
33990 tejus.loha 508
    @PostMapping(value = "/deactivateStore")
509
    public String deActivateStore(HttpServletRequest request,
510
                                  @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
511
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
512
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
513
        if (!Arrays
514
                .asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "amit.gupta@smartdukaan.com",
37630 amit 515
                        "vikas.jangra@smartdukaan.com")
33990 tejus.loha 516
                .contains(loginDetails.getEmailId())) {
517
            throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access",
518
                    "You are not authorise to deactivate retailer");
519
        }
35962 amit 520
        if (fofoStore.isClosed()) {
521
            throw new ProfitMandiBusinessException("Store Closed", "Store Already Closed",
522
                    "This store is permanently closed and cannot be modified");
523
        }
33990 tejus.loha 524
        fofoStore.setActive(false);
525
        LOGGER.info("inserted into InActiveFofoStore successfully");
526
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
527
        return "response";
528
    }
28825 tejbeer 529
 
35962 amit 530
    @PostMapping(value = "/closeStore")
531
    public String closeStore(HttpServletRequest request,
532
                             @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId,
533
                             @RequestParam(name = "storeCode") String storeCode, Model model) throws Exception {
534
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
535
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
536
        if (!Arrays
537
                .asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "amit.gupta@smartdukaan.com",
37630 amit 538
                        "vikas.jangra@smartdukaan.com")
35962 amit 539
                .contains(loginDetails.getEmailId())) {
540
            throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access",
541
                    "You are not authorise to close store");
542
        }
543
        if (fofoStore.isClosed()) {
544
            throw new ProfitMandiBusinessException("Store Closed", "Store Already Closed",
545
                    "This store is already permanently closed");
546
        }
547
        if (storeCode == null || !storeCode.equals(fofoStore.getCode())) {
548
            throw new ProfitMandiBusinessException("Invalid Store Code", "Store Code Mismatch",
549
                    "Please type the correct store code to confirm closure");
550
        }
551
        fofoStore.setActive(false);
552
        fofoStore.setClosed(true);
553
        fofoStore.setClosedTimestamp(LocalDateTime.now());
554
        LOGGER.info("Store {} closed permanently by {}", fofoStore.getCode(), loginDetails.getEmailId());
555
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
556
        return "response";
557
    }
558
 
33990 tejus.loha 559
    @PostMapping(value = "/activateStoreForever")
560
    public String activateStoreForever(HttpServletRequest request,
561
                                       @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
562
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
563
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
37630 amit 564
        if (!Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "amit.gupta@smartdukaan.com").contains(loginDetails.getEmailId())) {
33990 tejus.loha 565
            throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access",
566
                    "You are not authorise to activate retailer");
567
        }
35962 amit 568
        if (fofoStore.isClosed()) {
569
            throw new ProfitMandiBusinessException("Store Closed", "Store Permanently Closed",
570
                    "This store is permanently closed and cannot be reactivated");
571
        }
33990 tejus.loha 572
        fofoStore.setActive(true);
573
        LOGGER.info("inserted into ActiveFofoStore successfully");
574
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
575
        return "response";
576
    }
28825 tejbeer 577
 
33990 tejus.loha 578
    @PostMapping(value = "/activateStoreTemporary")
579
    public String activateStoreTemporary(HttpServletRequest request,
580
                                         @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId,
581
                                         @RequestParam(name = "days", required = true) int days, Model model) throws Exception {
28825 tejbeer 582
 
33990 tejus.loha 583
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
584
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
37630 amit 585
        if (!Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "amit.gupta@smartdukaan.com").contains(loginDetails.getEmailId())) {
33990 tejus.loha 586
            throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access",
587
                    "You are not authorise to deactivate retailer");
588
        }
28825 tejbeer 589
 
35962 amit 590
        if (fofoStore.isClosed()) {
591
            throw new ProfitMandiBusinessException("Store Closed", "Store Permanently Closed",
592
                    "This store is permanently closed and cannot be reactivated");
593
        }
594
 
33990 tejus.loha 595
        LocalDateTime currentDate = LocalDate.now().atStartOfDay();
28825 tejbeer 596
 
33990 tejus.loha 597
        LocalDateTime EndDate = currentDate.plusDays(days);
598
        fofoStore.setActiveTimeStamp(EndDate);
28825 tejbeer 599
 
33990 tejus.loha 600
        LOGGER.info("EndDate" + EndDate);
601
        LOGGER.info("getActiveTimeStamp" + fofoStore.getActiveTimeStamp());
28825 tejbeer 602
 
33990 tejus.loha 603
        if (currentDate.isBefore(fofoStore.getActiveTimeStamp())) {
604
            fofoStore.setActive(true);
605
            LOGGER.info("inserted into InActiveFofoStore successfully");
606
        }
28825 tejbeer 607
 
33990 tejus.loha 608
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
609
        return "response";
610
    }
25276 amit.gupta 611
 
33990 tejus.loha 612
    @GetMapping(value = "/getAllInactiveStores")
33247 ranu 613
    public String getInactiveStores(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
33990 tejus.loha 614
        List<FofoStore> inActiveFofoStores = fofoStoreRepository.selectInActiveStore();
30426 tejbeer 615
 
33990 tejus.loha 616
        LOGGER.info("inActiveFofoStores {}", inActiveFofoStores);
617
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
30426 tejbeer 618
 
33990 tejus.loha 619
        List<Integer> fofoIds = inActiveFofoStores.stream().map(x -> x.getId()).collect(Collectors.toList());
30431 tejbeer 620
 
33990 tejus.loha 621
        Map<Integer, CustomRetailer> customRetailers = fofoIds.stream().map(x -> customRetailerMap.get(x))
622
                .filter(x -> x != null).collect(Collectors.toList()).stream()
623
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
624
        LOGGER.info("customRetailers {}", customRetailers);
30426 tejbeer 625
 
33990 tejus.loha 626
        model.addAttribute("inActiveFofoStores", inActiveFofoStores);
627
        model.addAttribute("customRetailers", customRetailers);
628
        return "inactive-stores";
629
    }
25276 amit.gupta 630
 
33990 tejus.loha 631
    // Extend billing for 2 days
632
    @PostMapping(value = "/extendBilling")
633
    public String extendBilling(HttpServletRequest request,
634
                                @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
635
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
636
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
637
        if (Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "amit.gupta@smartdukaan.com",
37630 amit 638
                "mohit.gulati@smartdukaan.com").contains(loginDetails.getEmailId())) {
33990 tejus.loha 639
            fofoStore.setGraceDate(LocalDate.now().plusDays(2));
640
            fofoStore.setGraceCount(fofoStore.getGraceCount() + 1);
641
            model.addAttribute("response1", mvcResponseSender.createResponseString(fofoStore.getGraceCount()));
642
        } else {
643
            throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access",
644
                    "You are not authorise to extend billing");
645
        }
646
        return "response";
25276 amit.gupta 647
 
33990 tejus.loha 648
    }
24124 govind 649
 
33990 tejus.loha 650
    @RequestMapping(value = "/getPromoterInfo", method = RequestMethod.GET)
32887 shampa 651
 
33990 tejus.loha 652
    public String getShowPromoterInfo(HttpServletRequest request,
653
                                      @RequestParam(name = "offset", defaultValue = "0") int offset,
654
                                      @RequestParam(name = "limit", defaultValue = "10") int limit,
655
                                      @RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
656
            throws Exception {
657
        //LOGGER.info("requested url : " + request.getRequestURL().toString());
658
        List<Promoter> promoterInfo = null;
659
        long size = 0;
24159 tejbeer 660
 
33990 tejus.loha 661
        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
662
                .collect(Collectors.toList());
32887 shampa 663
 
33990 tejus.loha 664
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
32887 shampa 665
 
33990 tejus.loha 666
        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
667
                .filter(x -> x != null).collect(Collectors.toList()).stream()
668
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
669
        String customRetailers = JSONObject.valueToString(customRetailersMap.values());
670
        Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
671
        brands.add("Airtel");
672
        brands.add("Vodafone");
673
        brands.add("Idea");
674
        LOGGER.info("brands" + brands);
675
        model.addAttribute("customRetailers", customRetailers);
676
        model.addAttribute("brands", brands);
32887 shampa 677
 
33990 tejus.loha 678
        if (fofoId != 0) {
679
            promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit, true);
32887 shampa 680
 
33990 tejus.loha 681
            //size = promoterRepository.selectPromoterCount(fofoId);
682
            size = promoterInfo.size();
683
        } else {
684
            //rkb
685
            promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit, true);
32887 shampa 686
 
33990 tejus.loha 687
            //size = promoterRepository.selectAllCount();
688
            size = promoterInfo.size();
689
        }
690
        if (!promoterInfo.isEmpty()) {
691
            Set<Integer> partnerIds = new HashSet<>();
32887 shampa 692
 
33990 tejus.loha 693
            for (Promoter promoterdetail : promoterInfo) {
694
                partnerIds.add(promoterdetail.getRetailerId());
695
            }
696
            Map<Integer, CustomRetailer> partnersMap = null;
697
            if (!partnerIds.equals(null)) {
698
                LOGGER.info("partnerIds" + partnerIds);
32887 shampa 699
 
33990 tejus.loha 700
                partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
701
                        .collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
32887 shampa 702
 
33990 tejus.loha 703
            }
32887 shampa 704
 
33990 tejus.loha 705
            LOGGER.info("partnerIds" + partnersMap);
706
            model.addAttribute("promoterInfo", promoterInfo);
707
            model.addAttribute("partnersMap", partnersMap);
708
            model.addAttribute("start", offset + 1);
709
            model.addAttribute("size", size);
710
            model.addAttribute("url", "/getPaginatedPromoterInfo");
32887 shampa 711
 
33990 tejus.loha 712
            if (promoterInfo.size() < limit) {
713
                model.addAttribute("end", offset + promoterInfo.size());
714
            } else {
715
                model.addAttribute("end", offset + limit);
716
            }
717
        } else {
718
            model.addAttribute("promoterInfo", promoterInfo);
719
            model.addAttribute("size", size);
720
        }
721
        return "promoter-info";
32887 shampa 722
 
33990 tejus.loha 723
    }
32887 shampa 724
 
33990 tejus.loha 725
    @RequestMapping(value = "/getPromoterInactive", method = RequestMethod.GET)
32887 shampa 726
 
33990 tejus.loha 727
    public String getShowPromoterInactiveInfo(HttpServletRequest request,
728
                                              @RequestParam(name = "offset", defaultValue = "0") int offset,
729
                                              @RequestParam(name = "limit", defaultValue = "10") int limit,
730
                                              @RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
731
            throws Exception {
732
        //LOGGER.info("requested url : " + request.getRequestURL().toString());
733
        List<Promoter> promoterInfo = null;
734
        long size = 0;
32887 shampa 735
 
33990 tejus.loha 736
        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
737
                .collect(Collectors.toList());
32887 shampa 738
 
33990 tejus.loha 739
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
27489 tejbeer 740
 
33990 tejus.loha 741
        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
742
                .filter(x -> x != null).collect(Collectors.toList()).stream()
743
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
744
        String customRetailers = JSONObject.valueToString(customRetailersMap.values());
745
        Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
746
        brands.add("Airtel");
747
        brands.add("Vodafone");
748
        brands.add("Idea");
749
        LOGGER.info("brands" + brands);
750
        model.addAttribute("customRetailers", customRetailers);
751
        model.addAttribute("brands", brands);
30426 tejbeer 752
 
33990 tejus.loha 753
        if (fofoId != 0) {
754
            promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit, false);
30426 tejbeer 755
 
33990 tejus.loha 756
            //size = promoterRepository.selectPromoterCount(fofoId);
757
            size = promoterInfo.size();
24159 tejbeer 758
 
33990 tejus.loha 759
        } else {
760
            //rkb
761
            promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit, false);
24159 tejbeer 762
 
33990 tejus.loha 763
            //size = promoterRepository.selectAllCount();
764
            size = promoterInfo.size();
27489 tejbeer 765
 
33990 tejus.loha 766
        }
767
        if (!promoterInfo.isEmpty()) {
768
            Set<Integer> partnerIds = new HashSet<>();
27489 tejbeer 769
 
33990 tejus.loha 770
            for (Promoter promoterdetail : promoterInfo) {
771
                partnerIds.add(promoterdetail.getRetailerId());
772
            }
773
            Map<Integer, CustomRetailer> partnersMap = null;
774
            if (!partnerIds.equals(null)) {
775
                LOGGER.info("partnerIds" + partnerIds);
27489 tejbeer 776
 
33990 tejus.loha 777
                partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
778
                        .collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
24159 tejbeer 779
 
33990 tejus.loha 780
            }
30426 tejbeer 781
 
33990 tejus.loha 782
            LOGGER.info("partnerIds" + partnersMap);
783
            model.addAttribute("promoterInfo", promoterInfo);
784
            model.addAttribute("partnersMap", partnersMap);
785
            model.addAttribute("start", offset + 1);
786
            model.addAttribute("size", size);
787
            model.addAttribute("url", "/getPaginatedPromoterInactiveInfo");
30426 tejbeer 788
 
33990 tejus.loha 789
            if (promoterInfo.size() < limit) {
790
                model.addAttribute("end", offset + promoterInfo.size());
791
            } else {
792
                model.addAttribute("end", offset + limit);
793
            }
794
        } else {
795
            model.addAttribute("promoterInfo", promoterInfo);
796
            model.addAttribute("size", size);
797
        }
798
        return "promoter-inactive";
24349 amit.gupta 799
 
33990 tejus.loha 800
    }
24159 tejbeer 801
 
33990 tejus.loha 802
    @RequestMapping(value = "/getPaginatedPromoterInfo", method = RequestMethod.GET)
803
    public String getPaginatedPromoterInfo(HttpServletRequest request,
804
                                           @RequestParam(name = "offset", defaultValue = "0") int offset,
805
                                           @RequestParam(name = "limit", defaultValue = "10") int limit,
806
                                           @RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
807
            throws ProfitMandiBusinessException {
808
        LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
809
        List<Promoter> promoterInfo = null;
810
        if (fofoId != 0) {
811
            promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit, true);
812
        } else {
813
            promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit, true);
814
        }
815
        LOGGER.info("promoterInfo" + promoterInfo);
816
        if (!promoterInfo.isEmpty()) {
817
            Set<Integer> partnerIds = new HashSet<>();
24159 tejbeer 818
 
33990 tejus.loha 819
            for (Promoter promoterdetail : promoterInfo) {
820
                partnerIds.add(promoterdetail.getRetailerId());
821
            }
822
            Map<Integer, CustomRetailer> partnersMap = null;
823
            if (!partnerIds.equals(null)) {
824
                LOGGER.info("partnerIds" + partnerIds);
24349 amit.gupta 825
 
33990 tejus.loha 826
                Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
32887 shampa 827
 
33990 tejus.loha 828
                partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
829
                        .collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
24159 tejbeer 830
 
33990 tejus.loha 831
            }
30426 tejbeer 832
 
33990 tejus.loha 833
            LOGGER.info("partnerIds" + partnersMap);
834
            model.addAttribute("promoterInfo", promoterInfo);
835
            model.addAttribute("partnersMap", partnersMap);
836
            model.addAttribute("url", "/getPaginatedPromoterInfo");
837
        } else {
838
            model.addAttribute("promoterInfo", promoterInfo);
30426 tejbeer 839
 
33990 tejus.loha 840
        }
30426 tejbeer 841
 
33990 tejus.loha 842
        return "promoter-info-paginated";
843
    }
24349 amit.gupta 844
 
33990 tejus.loha 845
    @RequestMapping(value = "/getPaginatedPromoterInactiveInfo", method = RequestMethod.GET)
846
    public String getPaginatedPromoterInactiveInfo(HttpServletRequest request,
847
                                                   @RequestParam(name = "offset", defaultValue = "0") int offset,
848
                                                   @RequestParam(name = "limit", defaultValue = "10") int limit,
849
                                                   @RequestParam(name = "fofoId", required = false, defaultValue = "0") int fofoId, Model model)
850
            throws ProfitMandiBusinessException {
851
        LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
852
        List<Promoter> promoterInfo = null;
853
        if (fofoId != 0) {
854
            promoterInfo = promoterRepository.selectAllPromoterByFofoIdStatus(fofoId, offset, limit, false);
855
        } else {
856
            promoterInfo = promoterRepository.selectAllPromoterStatus(offset, limit, false);
857
        }
858
        LOGGER.info("promoterInfo" + promoterInfo);
859
        if (!promoterInfo.isEmpty()) {
860
            Set<Integer> partnerIds = new HashSet<>();
24159 tejbeer 861
 
33990 tejus.loha 862
            for (Promoter promoterdetail : promoterInfo) {
863
                partnerIds.add(promoterdetail.getRetailerId());
864
            }
865
            Map<Integer, CustomRetailer> partnersMap = null;
866
            if (!partnerIds.equals(null)) {
867
                LOGGER.info("partnerIds" + partnerIds);
24159 tejbeer 868
 
33990 tejus.loha 869
                Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
24159 tejbeer 870
 
33990 tejus.loha 871
                partnersMap = partnerIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null)
872
                        .collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
32887 shampa 873
 
33990 tejus.loha 874
            }
32887 shampa 875
 
33990 tejus.loha 876
            LOGGER.info("partnerIds" + partnersMap);
877
            model.addAttribute("promoterInfo", promoterInfo);
878
            model.addAttribute("partnersMap", partnersMap);
879
            model.addAttribute("url", "/getPaginatedPromoterInactiveInfo");
880
        } else {
881
            model.addAttribute("promoterInfo", promoterInfo);
32887 shampa 882
 
33990 tejus.loha 883
        }
32887 shampa 884
 
33990 tejus.loha 885
        return "promoter-inactive-info-paginated";
886
    }
32887 shampa 887
 
33990 tejus.loha 888
    @RequestMapping(value = "/createPromoter", method = RequestMethod.POST)
889
    public String createPromoter(HttpServletRequest request, @RequestBody PromoterDetailModel promoterdetailModel,
890
                                 Model model) throws Exception {
891
        LOGGER.info("requested url : " + request.getRequestURL().toString());
892
        LOGGER.info("requested url : " + promoterdetailModel);
893
        Promoter promoter = promoterRepository.selectById(promoterdetailModel.getId());
894
        if (promoter == null) {
895
            promoter = new Promoter();
896
            promoter.setBrand(promoterdetailModel.getBrand());
897
            promoter.setRetailerId(promoterdetailModel.getRetailerId());
898
            promoter.setCreatedTimestamp(LocalDateTime.now());
899
            promoter.setEmail(promoterdetailModel.getEmail());
900
            promoter.setName(promoterdetailModel.getName());
901
            promoter.setMobile(promoterdetailModel.getMobile());
902
            promoter.setSdPortalAccess(promoterdetailModel.isSdPortalAccess());
903
            promoter.setStatus(promoterdetailModel.isStatus());
904
            promoterRepository.persist(promoter);
32887 shampa 905
 
33990 tejus.loha 906
            List<Promoter> promoters = promoterRepository.selectAllByRetailer(promoterdetailModel.getRetailerId());
907
            if (!promoters.isEmpty()) {
908
                FofoStore fs = fofoStoreRepository.selectByRetailerId(promoterdetailModel.getRetailerId());
909
                PartnerOnBoardingPanel pobp = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
910
                if (pobp != null) {
911
                    storeTimelineTatService.promoterComplete(pobp.getId());
912
                }
913
            }
32887 shampa 914
 
33990 tejus.loha 915
        } else {
916
            promoter.setEmail(promoterdetailModel.getEmail());
917
            promoter.setName(promoterdetailModel.getName());
918
            promoter.setMobile(promoterdetailModel.getMobile());
919
            promoter.setSdPortalAccess(promoterdetailModel.isSdPortalAccess());
920
            promoter.setStatus(promoterdetailModel.isStatus());
921
        }
922
        LOGGER.info("sdport" + promoterdetailModel.isStatus());
26131 tejbeer 923
 
33990 tejus.loha 924
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28908 tejbeer 925
 
33990 tejus.loha 926
        return "response";
24159 tejbeer 927
 
33990 tejus.loha 928
    }
24159 tejbeer 929
 
33990 tejus.loha 930
    @RequestMapping(value = "/setPromoterInActive", method = RequestMethod.POST)
931
    public String PromoterInActive(HttpServletRequest request, @RequestParam(name = "id", required = true, defaultValue = "0") int id, Model model) throws Exception {
24159 tejbeer 932
 
33990 tejus.loha 933
        Promoter promoter = promoterRepository.selectById(id);
24159 tejbeer 934
 
33990 tejus.loha 935
        promoter.setStatus(false);
32887 shampa 936
 
33990 tejus.loha 937
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
32887 shampa 938
 
33990 tejus.loha 939
        return "response";
940
    }
32887 shampa 941
 
33990 tejus.loha 942
    @RequestMapping(value = "/removePromoterfromPartnerStore", method = RequestMethod.POST)
943
    public String removePromoterfromPartnerStore(HttpServletRequest request,
944
                                                 @RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
32887 shampa 945
 
33990 tejus.loha 946
        Promoter promoter = promoterRepository.selectById(id);
947
        promoter.setStatus(false);
948
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
32887 shampa 949
 
33990 tejus.loha 950
        return "response";
951
    }
24159 tejbeer 952
 
33990 tejus.loha 953
    @RequestMapping(value = "/activePromoterfromPartnerStore", method = RequestMethod.POST)
954
    public String activePromoterfromPartnerStore(HttpServletRequest request,
955
                                                 @RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
24159 tejbeer 956
 
33990 tejus.loha 957
        Promoter promoter = promoterRepository.selectById(id);
958
        promoter.setStatus(true);
959
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
32887 shampa 960
 
33990 tejus.loha 961
        return "response";
962
    }
24159 tejbeer 963
 
33990 tejus.loha 964
    @RequestMapping(value = "/addLocation", method = RequestMethod.POST)
965
    public String addLocation(HttpServletRequest request, @RequestBody AddLocationModel addLocationModel, Model model)
966
            throws Exception {
24159 tejbeer 967
 
33990 tejus.loha 968
        Location location = new Location();
969
        location.setName(addLocationModel.getName());
970
        location.setLine1(addLocationModel.getLine1());
971
        location.setLine2(addLocationModel.getLine2());
972
        location.setCity(addLocationModel.getCity());
973
        location.setState(addLocationModel.getState());
974
        location.setPin(addLocationModel.getPin());
24159 tejbeer 975
 
33990 tejus.loha 976
        LOGGER.info("PostLocation" + location);
977
        locationRepository.persist(location);
24159 tejbeer 978
 
33990 tejus.loha 979
        User user = userRepository.selectById(addLocationModel.getUserId());
980
        user.setLocation(location.getId());
981
        userRepository.persist(user);
24159 tejbeer 982
 
33990 tejus.loha 983
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
984
        return "response";
24159 tejbeer 985
 
33990 tejus.loha 986
    }
24159 tejbeer 987
 
33990 tejus.loha 988
    @RequestMapping(value = "/updateLocation", method = RequestMethod.POST)
989
    public String updateLocation(HttpServletRequest request, @RequestBody AddLocationModel addLocationModel,
990
                                 Model model) throws Exception {
24159 tejbeer 991
 
33990 tejus.loha 992
        Location userlocation = locationRepository.selectById(addLocationModel.getUserId());
24159 tejbeer 993
 
33990 tejus.loha 994
        userlocation.setName(addLocationModel.getName());
995
        userlocation.setCity(addLocationModel.getCity());
996
        userlocation.setLine1(addLocationModel.getLine1());
997
        userlocation.setLine2(addLocationModel.getLine2());
998
        userlocation.setPin(addLocationModel.getPin());
999
        userlocation.setState(addLocationModel.getState());
24159 tejbeer 1000
 
33990 tejus.loha 1001
        locationRepository.persist(userlocation);
24159 tejbeer 1002
 
33990 tejus.loha 1003
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1004
        return "response";
24159 tejbeer 1005
 
33990 tejus.loha 1006
    }
24159 tejbeer 1007
 
33990 tejus.loha 1008
    @RequestMapping(value = "/getPartnerReadonlyInfo")
1009
    public String getPartnerReadonlyInfo(HttpServletRequest request, Model model) throws Exception {
24159 tejbeer 1010
 
33990 tejus.loha 1011
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1012
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
27231 tejbeer 1013
 
33990 tejus.loha 1014
        Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();
27231 tejbeer 1015
 
35452 amit 1016
        List<Integer> fofoIds = pp.get(authUser.getId());
27231 tejbeer 1017
 
35452 amit 1018
        Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(fofoIds);
27231 tejbeer 1019
 
33990 tejus.loha 1020
        model.addAttribute("customRetailersMap", customRetailersMap);
27231 tejbeer 1021
 
33990 tejus.loha 1022
        return "partner-readonly-info";
27243 tejbeer 1023
 
33990 tejus.loha 1024
    }
27231 tejbeer 1025
 
33990 tejus.loha 1026
    @RequestMapping(value = "/getBlockBrandMapping")
1027
    public String getBlockBrandMapping(HttpServletRequest request, Model model) throws Exception {
27231 tejbeer 1028
 
33990 tejus.loha 1029
        int fofoId = Utils.SYSTEM_PARTNER_ID;
35236 amit 1030
        Set<String> brands = brandsService.getBrands(fofoId, null, 3).stream().map(x -> x.getName()).collect(Collectors.toSet());
28071 tejbeer 1031
 
33990 tejus.loha 1032
        LOGGER.info("brands" + brands);
1033
        model.addAttribute("brands", brands);
28071 tejbeer 1034
 
33990 tejus.loha 1035
        return "block-brand-mapping";
28071 tejbeer 1036
 
33990 tejus.loha 1037
    }
28071 tejbeer 1038
 
33990 tejus.loha 1039
    @RequestMapping(value = "/getBlockBrand")
1040
    public String getBlockBrand(HttpServletRequest request,
1041
                                @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model)
1042
            throws Exception {
28071 tejbeer 1043
 
33990 tejus.loha 1044
        List<RetailerBlockBrands> retailerBlockBrands = retailerBlockBrandsRepository.selectAllByBrands(brand);
28071 tejbeer 1045
 
33990 tejus.loha 1046
        List<Integer> blockBrandPartners = retailerBlockBrands.stream().map(x -> x.getFofoId())
1047
                .collect(Collectors.toList());
1048
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
28071 tejbeer 1049
 
33990 tejus.loha 1050
        LOGGER.info("retailerBlockBrands" + retailerBlockBrands);
1051
        model.addAttribute("blockBrandPartners", blockBrandPartners);
1052
        model.addAttribute("retailerBlockBrands", retailerBlockBrands);
1053
        model.addAttribute("customRetailers", customRetailers);
28272 tejbeer 1054
 
33990 tejus.loha 1055
        return "retailer-block-brand";
28071 tejbeer 1056
 
33990 tejus.loha 1057
    }
28071 tejbeer 1058
 
33990 tejus.loha 1059
    @RequestMapping(value = "/getRetailerBlockBrandMappping", method = RequestMethod.POST)
1060
    public String getBlockBrandMappping(HttpServletRequest request,
1061
                                        @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,
1062
                                        @RequestParam(name = "fofoIds", required = true, defaultValue = "0") List<Integer> fofoIds, Model model)
1063
            throws Exception {
37101 amit 1064
        if (brand == null || brand.trim().isEmpty()
1065
                || "null".equalsIgnoreCase(brand.trim()) || "0".equals(brand.trim())) {
1066
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
1067
            return "response";
1068
        }
33990 tejus.loha 1069
        List<RetailerBlockBrands> retailerBlockBrands = retailerBlockBrandsRepository.selectAllByBrands(brand);
1070
        if (!retailerBlockBrands.isEmpty()) {
1071
            retailerBlockBrandsRepository.deleteAllbyBrands(brand);
1072
        }
28071 tejbeer 1073
 
33990 tejus.loha 1074
        for (int id : fofoIds) {
1075
            RetailerBlockBrands retailerBlockBrand = new RetailerBlockBrands();
1076
            retailerBlockBrand.setFofoId(id);
1077
            retailerBlockBrand.setBlockBrands(brand);
1078
            retailerBlockBrandsRepository.persist(retailerBlockBrand);
28071 tejbeer 1079
 
33990 tejus.loha 1080
        }
1081
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28071 tejbeer 1082
 
33990 tejus.loha 1083
        return "response";
1084
    }
28071 tejbeer 1085
 
33990 tejus.loha 1086
    @RequestMapping(value = "/getBrandslimit", method = RequestMethod.GET)
1087
    public String getBrandslimit(HttpServletRequest request, Model model) throws Exception {
28071 tejbeer 1088
 
33990 tejus.loha 1089
        int fofoId = Utils.SYSTEM_PARTNER_ID;
32731 ranu 1090
 
33990 tejus.loha 1091
        List<String> brands = brandsService.getBrandsToDisplay(3).stream().map(x -> x.getName()).collect(Collectors.toList());
1092
        model.addAttribute("brands", brands);
28272 tejbeer 1093
 
33990 tejus.loha 1094
        return "brands-limit";
28272 tejbeer 1095
 
33990 tejus.loha 1096
    }
28272 tejbeer 1097
 
33990 tejus.loha 1098
    @RequestMapping(value = "/setUpdateLimit", method = RequestMethod.POST)
1099
    public String getUpdateLimit(HttpServletRequest request,
1100
                                 @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,
1101
                                 @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1102
                                 @RequestParam(name = "limit", required = true, defaultValue = "0") float limit,
1103
                                 @RequestParam(name = "minStockLimit", required = true, defaultValue = "0") float minStockLimit,
1104
                                 @RequestParam(name = "preLimit", required = true, defaultValue = "0") float preLimit,
1105
                                 @RequestParam(name = "preStockLimit", required = true, defaultValue = "0") float preStockLimit, Model model)
1106
            throws Exception {
28272 tejbeer 1107
 
33990 tejus.loha 1108
        CustomRetailer cr = retailerService.getFofoRetailer(fofoId);
28272 tejbeer 1109
 
33990 tejus.loha 1110
        Map.Entry<Integer, CustomRetailer> customRetailers = new AbstractMap.SimpleEntry(cr.getPartnerId(), cr);
28272 tejbeer 1111
 
33990 tejus.loha 1112
        // Map<Integer, CustomRetailer> customRetailers =
1113
        // retailerService.getFofoRetailers(true);
28277 tejbeer 1114
 
33990 tejus.loha 1115
        RetailerBrandsLimit retailerBrands = retailerBrandsLimitRepository.selectLimitByBrandAndFofoId(fofoId, brand);
28277 tejbeer 1116
 
33990 tejus.loha 1117
        if (retailerBrands == null) {
1118
            retailerBrands = new RetailerBrandsLimit();
1119
            retailerBrands.setMinStockLimit(minStockLimit);
1120
            retailerBrands.setBrandLimit(limit);
1121
            retailerBrands.setIsUpdate(1);
1122
            retailerBrands.setCreatedTimestamp(LocalDateTime.now());
1123
            retailerBrands.setPartnerId(fofoId);
1124
            retailerBrands.setBrandName(brand);
1125
            retailerBrands.setUpdatedTimestamp(LocalDateTime.now());
1126
            retailerBrandsLimitRepository.persist(retailerBrands);
1127
        } else {
1128
            retailerBrands.setMinStockLimit(minStockLimit);
1129
            retailerBrands.setBrandLimit(limit);
1130
            retailerBrands.setIsUpdate(1);
1131
            retailerBrands.setUpdatedTimestamp(LocalDateTime.now());
1132
            retailerBrandsLimitRepository.persist(retailerBrands);
30028 manish 1133
 
33990 tejus.loha 1134
        }
1135
        retailerBrands = retailerBrandsLimitRepository.selectLimitByBrandAndFofoId(fofoId, brand);
28277 tejbeer 1136
 
33990 tejus.loha 1137
        Map<Integer, RetailerBrandsLimit> retailerBrandsLimitMap = new HashMap<>();
28272 tejbeer 1138
 
33990 tejus.loha 1139
        retailerBrandsLimitMap.put(retailerBrands.getPartnerId(), retailerBrands);
28272 tejbeer 1140
 
33990 tejus.loha 1141
        BrandLimit brandLimit = brandLimitRepository.setLimitByBrands(brand);
28272 tejbeer 1142
 
33990 tejus.loha 1143
        model.addAttribute("retailerBrandsLimitMap", retailerBrandsLimitMap);
1144
        model.addAttribute("brandLimit", brandLimit);
1145
        model.addAttribute("customRetailers", customRetailers);
28272 tejbeer 1146
 
33990 tejus.loha 1147
        model.addAttribute("brand", brand);
1148
        return "brands-limit-row-mapping";
28272 tejbeer 1149
 
33990 tejus.loha 1150
    }
28277 tejbeer 1151
 
33990 tejus.loha 1152
    @RequestMapping(value = "/getRetailerBrandslimitMapping", method = RequestMethod.GET)
1153
    public String getRetailerBrandslimit(HttpServletRequest request,
1154
                                         @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model)
1155
            throws Exception {
28272 tejbeer 1156
 
33990 tejus.loha 1157
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
1158
        List<RetailerBrandsLimit> retailerBrandsLimit = retailerBrandsLimitRepository.setAllLimitByBrand(brand);
1159
        Map<Integer, RetailerBrandsLimit> retailerBrandsLimitMap = retailerBrandsLimit.stream()
1160
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
28272 tejbeer 1161
 
33990 tejus.loha 1162
        model.addAttribute("customRetailers", customRetailers);
1163
        model.addAttribute("brand", brand);
1164
        model.addAttribute("retailerBrandsLimitMap", retailerBrandsLimitMap);
28272 tejbeer 1165
 
33990 tejus.loha 1166
        BrandLimit brandLimit = brandLimitRepository.setLimitByBrands(brand);
28272 tejbeer 1167
 
33990 tejus.loha 1168
        model.addAttribute("brandLimit", brandLimit);
28272 tejbeer 1169
 
33990 tejus.loha 1170
        return "brands-limit-mapping";
28272 tejbeer 1171
 
33990 tejus.loha 1172
    }
28272 tejbeer 1173
 
33990 tejus.loha 1174
    @RequestMapping(value = "/setBrandWiseLimit", method = RequestMethod.POST)
1175
    public String brandwiseLimit(HttpServletRequest request,
1176
                                 @RequestParam(name = "brands", required = true, defaultValue = "") String brands,
1177
                                 @RequestParam(name = "limit", required = true, defaultValue = "") float limit, Model model)
1178
            throws Exception {
28272 tejbeer 1179
 
33990 tejus.loha 1180
        LOGGER.info("limit" + limit);
30426 tejbeer 1181
 
33990 tejus.loha 1182
        BrandLimit brandLimit = brandLimitRepository.setLimitByBrands(brands);
28272 tejbeer 1183
 
33990 tejus.loha 1184
        List<RetailerBrandsLimit> retailerBrandsLimit = retailerBrandsLimitRepository.setAllLimitByBrand(brands);
28272 tejbeer 1185
 
33990 tejus.loha 1186
        Map<Integer, RetailerBrandsLimit> retailerBrandsLimitMap = retailerBrandsLimit.stream()
1187
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
28272 tejbeer 1188
 
33990 tejus.loha 1189
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
28272 tejbeer 1190
 
33990 tejus.loha 1191
        if (brandLimit == null) {
28272 tejbeer 1192
 
33990 tejus.loha 1193
            brandLimit = new BrandLimit();
1194
            brandLimit.setBrandLimit(limit);
1195
            brandLimit.setBrandName(brands);
1196
            brandLimit.setCreatedTimestamp(LocalDateTime.now());
1197
            brandLimit.setUpdatedTimestamp(LocalDateTime.now());
1198
            brandLimitRepository.persist(brandLimit);
28272 tejbeer 1199
 
33990 tejus.loha 1200
        } else {
1201
            brandLimit.setBrandLimit(limit);
28272 tejbeer 1202
 
33990 tejus.loha 1203
            brandLimit.setUpdatedTimestamp(LocalDateTime.now());
1204
            brandLimitRepository.persist(brandLimit);
28272 tejbeer 1205
 
33990 tejus.loha 1206
        }
1207
        brandLimit = brandLimitRepository.setLimitByBrands(brands);
30028 manish 1208
 
33990 tejus.loha 1209
        LOGGER.info("brandLimit" + brandLimit);
1210
        model.addAttribute("brand", brands);
1211
        model.addAttribute("brandLimit", brandLimit);
1212
        model.addAttribute("customRetailers", customRetailers);
1213
        model.addAttribute("retailerBrandsLimitMap", retailerBrandsLimitMap);
1214
        return "brands-limit-mapping";
28272 tejbeer 1215
 
33990 tejus.loha 1216
    }
28272 tejbeer 1217
 
33990 tejus.loha 1218
    @RequestMapping(value = "/setBrandWiseStockLimit", method = RequestMethod.POST)
1219
    public String setBrandWiseStockLimit(HttpServletRequest request,
1220
                                         @RequestParam(name = "brands", required = true, defaultValue = "") String brands,
1221
                                         @RequestParam(name = "stockLimit", required = true, defaultValue = "") float stockLimit, Model model)
1222
            throws Exception {
28272 tejbeer 1223
 
33990 tejus.loha 1224
        LOGGER.info("limit" + stockLimit);
28272 tejbeer 1225
 
33990 tejus.loha 1226
        BrandLimit brandLimit = brandLimitRepository.setLimitByBrands(brands);
28825 tejbeer 1227
 
33990 tejus.loha 1228
        List<RetailerBrandsLimit> retailerBrandsLimit = retailerBrandsLimitRepository.setAllLimitByBrand(brands);
30028 manish 1229
 
33990 tejus.loha 1230
        Map<Integer, RetailerBrandsLimit> retailerBrandsLimitMap = retailerBrandsLimit.stream()
1231
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
30028 manish 1232
 
33990 tejus.loha 1233
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
30028 manish 1234
 
33990 tejus.loha 1235
        if (brandLimit == null) {
30028 manish 1236
 
33990 tejus.loha 1237
            brandLimit = new BrandLimit();
1238
            brandLimit.setBrandLimit(0);
1239
            brandLimit.setBrandName(brands);
1240
            brandLimit.setStockLimit(stockLimit);
1241
            brandLimit.setCreatedTimestamp(LocalDateTime.now());
1242
            brandLimit.setUpdatedTimestamp(LocalDateTime.now());
1243
            brandLimitRepository.persist(brandLimit);
30028 manish 1244
 
33990 tejus.loha 1245
        } else {
1246
            brandLimit.setStockLimit(stockLimit);
30028 manish 1247
 
33990 tejus.loha 1248
            brandLimit.setUpdatedTimestamp(LocalDateTime.now());
1249
            brandLimitRepository.persist(brandLimit);
30028 manish 1250
 
33990 tejus.loha 1251
        }
1252
        brandLimit = brandLimitRepository.setLimitByBrands(brands);
30028 manish 1253
 
33990 tejus.loha 1254
        model.addAttribute("brand", brands);
1255
        model.addAttribute("brandLimit", brandLimit);
1256
        model.addAttribute("customRetailers", customRetailers);
1257
        model.addAttribute("retailerBrandsLimitMap", retailerBrandsLimitMap);
1258
        return "brands-limit-mapping";
30028 manish 1259
 
33990 tejus.loha 1260
    }
30028 manish 1261
 
33990 tejus.loha 1262
    @RequestMapping(value = "/setPartnerPincode", method = RequestMethod.POST)
1263
    public String setPartnerPincode(HttpServletRequest request,
1264
                                    @RequestParam(name = "pincode", required = true, defaultValue = "") String pincode,
1265
                                    @RequestParam(name = "fofoId", required = true, defaultValue = "") int fofoId, Model model)
1266
            throws Exception {
30028 manish 1267
 
33990 tejus.loha 1268
        if (!pincode.equals("")) {
1269
            PincodePartner pinPartner = new PincodePartner();
1270
            pinPartner.setFofoId(fofoId);
1271
            pinPartner.setPincode(pincode);
1272
            pincodePartnerRepository.perist(pinPartner);
1273
        }
30028 manish 1274
 
33990 tejus.loha 1275
        List<PincodePartner> partnerPincodeList = pincodePartnerRepository.selectByPartnerId(fofoId);
30028 manish 1276
 
33990 tejus.loha 1277
        LOGGER.info("partnerPincodeList" + partnerPincodeList);
30028 manish 1278
 
33990 tejus.loha 1279
        model.addAttribute("partnerPincodeList", partnerPincodeList);
1280
        return "pincode-partner-index";
28272 tejbeer 1281
 
33990 tejus.loha 1282
    }
28381 tejbeer 1283
 
33990 tejus.loha 1284
    @RequestMapping(value = "/removePartnerPincode", method = RequestMethod.POST)
1285
    public String removePartnerPincode(HttpServletRequest request, @RequestParam int id,
1286
                                       @RequestParam(name = "fofoId", required = true, defaultValue = "") int fofoId, Model model)
1287
            throws Exception {
28825 tejbeer 1288
 
33990 tejus.loha 1289
        pincodePartnerRepository.delete(id);
28825 tejbeer 1290
 
33990 tejus.loha 1291
        List<PincodePartner> partnerPincodeList = pincodePartnerRepository.selectByPartnerId(fofoId);
28381 tejbeer 1292
 
33990 tejus.loha 1293
        LOGGER.info("partnerPincodeList" + partnerPincodeList);
28825 tejbeer 1294
 
33990 tejus.loha 1295
        model.addAttribute("partnerPincodeList", partnerPincodeList);
28381 tejbeer 1296
 
33990 tejus.loha 1297
        return "pincode-partner-index";
28381 tejbeer 1298
 
33990 tejus.loha 1299
    }
28825 tejbeer 1300
 
33990 tejus.loha 1301
    @RequestMapping(value = "/removeSearchPincode", method = RequestMethod.POST)
1302
    public String removeSearchPincode(HttpServletRequest request, @RequestParam int id,
1303
                                      @RequestParam(name = "pin", required = true, defaultValue = "") String pin,
1304
                                      @RequestParam(name = "fofoId", required = true, defaultValue = "") int fofoId, Model model)
1305
            throws Exception {
28825 tejbeer 1306
 
33990 tejus.loha 1307
        pincodePartnerRepository.delete(id);
28825 tejbeer 1308
 
33990 tejus.loha 1309
        List<PincodePartner> partnerPincodeList = pincodePartnerRepository.selectPartnersByPincode(pin);
28381 tejbeer 1310
 
33990 tejus.loha 1311
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
28825 tejbeer 1312
 
33990 tejus.loha 1313
        model.addAttribute("customRetailerMap", customRetailerMap);
28381 tejbeer 1314
 
33990 tejus.loha 1315
        model.addAttribute("partnerPincodeList", partnerPincodeList);
28381 tejbeer 1316
 
33990 tejus.loha 1317
        return "search-pincode-partner";
28381 tejbeer 1318
 
33990 tejus.loha 1319
    }
28825 tejbeer 1320
 
33990 tejus.loha 1321
    @RequestMapping(value = "/searchPincodePartner", method = RequestMethod.GET)
1322
    public String searchPincodePartner(HttpServletRequest request,
1323
                                       @RequestParam(name = "pincode", required = true, defaultValue = "") String pincode, Model model)
1324
            throws Exception {
28825 tejbeer 1325
 
33990 tejus.loha 1326
        List<PincodePartner> partnerPincodeList = pincodePartnerRepository.selectPartnersByPincode(pincode);
28825 tejbeer 1327
 
33990 tejus.loha 1328
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
28381 tejbeer 1329
 
33990 tejus.loha 1330
        model.addAttribute("customRetailerMap", customRetailerMap);
28825 tejbeer 1331
 
33990 tejus.loha 1332
        model.addAttribute("partnerPincodeList", partnerPincodeList);
28381 tejbeer 1333
 
33990 tejus.loha 1334
        return "search-pincode-partner";
28825 tejbeer 1335
 
33990 tejus.loha 1336
    }
28381 tejbeer 1337
 
33990 tejus.loha 1338
    @RequestMapping(value = "/showPartnerPincode", method = RequestMethod.GET)
1339
    public String showPartnerPincode(HttpServletRequest request,
1340
                                     @RequestParam(name = "partnerId", required = true, defaultValue = "") int partnerId, Model model)
1341
            throws Exception {
28825 tejbeer 1342
 
33990 tejus.loha 1343
        List<PincodePartner> partnerPincodeList = pincodePartnerRepository.selectByPartnerId(partnerId);
28825 tejbeer 1344
 
33990 tejus.loha 1345
        model.addAttribute("partnerPincodeList", partnerPincodeList);
28825 tejbeer 1346
 
33990 tejus.loha 1347
        return "pincode-partner-index";
28825 tejbeer 1348
 
33990 tejus.loha 1349
    }
28381 tejbeer 1350
 
33990 tejus.loha 1351
    @RequestMapping(value = "/getAllPartnerPincode", method = RequestMethod.GET)
1352
    public String getAllPartnerPincode(HttpServletRequest request, Model model) throws Exception {
1353
        return "add-partner-pincode";
1354
    }
28825 tejbeer 1355
 
33990 tejus.loha 1356
    @RequestMapping(value = "/alternateRetailerContacts", method = RequestMethod.GET)
1357
    public String alternateRetailerContacts(HttpServletRequest request, Model model) throws Exception {
1358
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1359
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
28825 tejbeer 1360
 
33990 tejus.loha 1361
        model.addAttribute("isAdmin", isAdmin);
35648 ranu 1362
        model.addAttribute("brands", brandsRepository.selectAll());
33990 tejus.loha 1363
        return "retailer-contacts";
1364
    }
28825 tejbeer 1365
 
33990 tejus.loha 1366
    @RequestMapping(value = "/retailer-contact-list", method = RequestMethod.GET)
1367
    public String getRetailerContactList(HttpServletRequest request, Model model, @RequestParam(defaultValue = "0") int fofoId)
1368
            throws Exception {
28825 tejbeer 1369
 
33990 tejus.loha 1370
        List<RetailerContact> retailerContacts = retailerContactRepository.selectAllByRetailerId(fofoId);
32629 amit.gupta 1371
 
33990 tejus.loha 1372
        model.addAttribute("retailerContacts", retailerContacts);
35648 ranu 1373
        model.addAttribute("brands", brandsRepository.selectAll());
32667 raveendra. 1374
 
33990 tejus.loha 1375
        return "retailer-contact-list";
33814 ranu 1376
 
33990 tejus.loha 1377
    }
33814 ranu 1378
 
33990 tejus.loha 1379
    @RequestMapping(value = "/add-retailer-contact-list", method = RequestMethod.GET)
1380
    public String updateRetailerContactList(HttpServletRequest request, Model model,
1381
                                            @RequestParam(defaultValue = "0") int fofoId,
1382
                                            @RequestParam String contactName,
35648 ranu 1383
                                            @RequestParam String contactNumber,
1384
                                            @RequestParam String brandName,
1385
                                            @RequestParam String contactType) throws Exception {
33990 tejus.loha 1386
        RetailerContact retailerContact = new RetailerContact();
1387
        retailerContact.setFofoId(fofoId);
1388
        retailerContact.setName(contactName);
1389
        retailerContact.setMobile(contactNumber);
35648 ranu 1390
        retailerContact.setBrandName(brandName);
1391
        retailerContact.setContactType(contactType);
33990 tejus.loha 1392
        retailerContact.setActive(true);
1393
        retailerContact.setCreatedAt(LocalDateTime.now());
37001 ranu 1394
        try {
1395
            retailerContactRepository.persist(retailerContact);
1396
        } catch (org.springframework.dao.DataIntegrityViolationException dup) {
1397
            // uk_retailer_contact_fofo_mobile — same number already exists for this partner.
1398
            throw new ProfitMandiBusinessException("RetailerContact", contactNumber,
1399
                    "This number is already registered for this partner");
1400
        }
33814 ranu 1401
 
33990 tejus.loha 1402
        List<RetailerContact> retailerContacts = retailerContactRepository.selectAllByRetailerId(fofoId);
33814 ranu 1403
 
33990 tejus.loha 1404
        model.addAttribute("retailerContacts", retailerContacts);
35648 ranu 1405
        model.addAttribute("brands", brandsRepository.selectAll());
33814 ranu 1406
 
33990 tejus.loha 1407
        return "retailer-contact-list";
33814 ranu 1408
 
33990 tejus.loha 1409
    }
33814 ranu 1410
 
33990 tejus.loha 1411
    @RequestMapping(value = "/update-contact-status", method = RequestMethod.GET)
1412
    public String updateRetailerContactStatus(HttpServletRequest request, Model model,
1413
                                              @RequestParam(defaultValue = "0") int fofoId,
1414
                                              @RequestParam(defaultValue = "0") int contactId,
1415
                                              @RequestParam boolean active) throws Exception {
33814 ranu 1416
 
33990 tejus.loha 1417
        RetailerContact retailerContact = retailerContactRepository.selectById(contactId);
1418
        retailerContact.setActive(active);
33814 ranu 1419
 
33990 tejus.loha 1420
        List<RetailerContact> retailerContacts = retailerContactRepository.selectAllByRetailerId(fofoId);
33814 ranu 1421
 
33990 tejus.loha 1422
        model.addAttribute("retailerContacts", retailerContacts);
33814 ranu 1423
 
33990 tejus.loha 1424
        return "retailer-contact-list";
33814 ranu 1425
 
33990 tejus.loha 1426
    }
33814 ranu 1427
 
1428
 
28272 tejbeer 1429
}