Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
21615 kshitij.so 1
package com.spice.profitmandi.web.controller;
2
 
25649 tejbeer 3
import com.google.gson.Gson;
28825 tejbeer 4
import com.mongodb.DBObject;
25651 tejbeer 5
import com.spice.profitmandi.common.enumuration.ContentType;
25683 tejbeer 6
import com.spice.profitmandi.common.enumuration.MessageType;
22481 ashik.ali 7
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
31337 amit.gupta 8
import com.spice.profitmandi.common.model.*;
25651 tejbeer 9
import com.spice.profitmandi.common.web.util.ResponseSender;
36890 aman 10
import com.spice.profitmandi.dao.entity.ContactUs;
35247 vikas 11
import com.spice.profitmandi.dao.entity.StoreSalesTarget;
26011 amit.gupta 12
import com.spice.profitmandi.dao.entity.auth.AuthUser;
27355 tejbeer 13
import com.spice.profitmandi.dao.entity.catalog.Item;
32308 amit.gupta 14
import com.spice.profitmandi.dao.entity.catalog.Scheme;
27636 tejbeer 15
import com.spice.profitmandi.dao.entity.catalog.TagListing;
33501 ranu 16
import com.spice.profitmandi.dao.entity.cs.PartnerRegion;
28471 tejbeer 17
import com.spice.profitmandi.dao.entity.cs.Position;
36268 ranu 18
import com.spice.profitmandi.dao.entity.cs.Ticket;
27660 tejbeer 19
import com.spice.profitmandi.dao.entity.cs.TicketAssigned;
25651 tejbeer 20
import com.spice.profitmandi.dao.entity.dtr.Document;
25649 tejbeer 21
import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
31337 amit.gupta 22
import com.spice.profitmandi.dao.entity.fofo.*;
29720 manish 23
import com.spice.profitmandi.dao.entity.transaction.LineItem;
27586 tejbeer 24
import com.spice.profitmandi.dao.entity.transaction.Order;
29707 tejbeer 25
import com.spice.profitmandi.dao.enumuration.catalog.UpgradeOfferStatus;
36481 ranu 26
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
31259 tejbeer 27
import com.spice.profitmandi.dao.enumuration.fofo.Milestone;
28409 tejbeer 28
import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
36849 ranu 29
import com.spice.profitmandi.dao.model.SamsungUpgradeOfferModel;
36816 aman 30
import com.spice.profitmandi.dao.model.*;
34973 aman 31
import com.spice.profitmandi.dao.model.warehouse.LMSGraphRequest;
36890 aman 32
import com.spice.profitmandi.dao.repository.ContactUsRepository;
25976 amit.gupta 33
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
34617 amit.gupta 34
import com.spice.profitmandi.dao.repository.catalog.*;
31662 amit.gupta 35
import com.spice.profitmandi.dao.repository.cs.*;
31337 amit.gupta 36
import com.spice.profitmandi.dao.repository.dtr.*;
37
import com.spice.profitmandi.dao.repository.fofo.*;
27529 tejbeer 38
import com.spice.profitmandi.dao.repository.inventory.ReporticoCacheTableRepository;
39
import com.spice.profitmandi.dao.repository.inventory.SaholicInventoryCISRepository;
29720 manish 40
import com.spice.profitmandi.dao.repository.transaction.LineItemRepository;
27893 tejbeer 41
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
28443 tejbeer 42
import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
35104 vikas 43
import com.spice.profitmandi.dao.service.SaleRewardService;
28468 tejbeer 44
import com.spice.profitmandi.service.AdminUser;
45
import com.spice.profitmandi.service.FofoUser;
24336 amit.gupta 46
import com.spice.profitmandi.service.PartnerInvestmentService;
26460 amit.gupta 47
import com.spice.profitmandi.service.PartnerStatsService;
32336 jai.hind 48
import com.spice.profitmandi.service.SshServer.SSHService;
23844 amit.gupta 49
import com.spice.profitmandi.service.authentication.RoleManager;
34176 tejus.loha 50
import com.spice.profitmandi.service.catalog.BrandsService;
32934 amit.gupta 51
import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;
25677 amit.gupta 52
import com.spice.profitmandi.service.inventory.InventoryService;
27876 amit.gupta 53
import com.spice.profitmandi.service.offers.OfferService;
32308 amit.gupta 54
import com.spice.profitmandi.service.scheme.SchemeService;
27586 tejbeer 55
import com.spice.profitmandi.service.transaction.TransactionService;
26005 amit.gupta 56
import com.spice.profitmandi.service.user.RetailerService;
22481 ashik.ali 57
import com.spice.profitmandi.web.model.LoginDetails;
58
import com.spice.profitmandi.web.util.CookiesProcessor;
27529 tejbeer 59
import com.spice.profitmandi.web.util.MVCResponseSender;
31337 amit.gupta 60
import org.apache.logging.log4j.LogManager;
61
import org.apache.logging.log4j.Logger;
62
import org.json.JSONObject;
63
import org.springframework.beans.factory.annotation.Autowired;
64
import org.springframework.beans.factory.annotation.Value;
65
import org.springframework.core.io.InputStreamResource;
66
import org.springframework.http.HttpHeaders;
67
import org.springframework.http.HttpStatus;
68
import org.springframework.http.ResponseEntity;
69
import org.springframework.stereotype.Controller;
35437 amit 70
import org.springframework.transaction.annotation.Transactional;
31337 amit.gupta 71
import org.springframework.ui.Model;
32336 jai.hind 72
import org.springframework.web.bind.annotation.*;
32407 amit.gupta 73
 
31337 amit.gupta 74
import javax.servlet.http.HttpServletRequest;
75
import java.io.File;
76
import java.io.FileInputStream;
77
import java.io.FileNotFoundException;
78
import java.time.LocalDate;
79
import java.time.LocalDateTime;
80
import java.time.LocalTime;
81
import java.time.YearMonth;
82
import java.time.format.DateTimeFormatter;
83
import java.util.*;
84
import java.util.Map.Entry;
85
import java.util.stream.Collectors;
32407 amit.gupta 86
 
31337 amit.gupta 87
import static in.shop2020.model.v1.order.OrderStatus.*;
32407 amit.gupta 88
 
21615 kshitij.so 89
@Controller
35458 amit 90
@Transactional(rollbackFor = Throwable.class)
21615 kshitij.so 91
public class DashboardController {
23923 amit.gupta 92
 
36870 ranu 93
    List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "amit.gupta@smartdukaan.com", "ranu.rajput@smartdukaan.com", "vikas.jangra@smartdukaan.com", "tanay.gupta@smartdukaan.com", "rudy.kanwar@smartdukaan.com");
27727 tejbeer 94
 
31751 tejbeer 95
    @Value("${web.api.host}")
96
    private String webApiHost;
23923 amit.gupta 97
 
31751 tejbeer 98
    @Value("${web.api.scheme}")
99
    private String webApiScheme;
24288 amit.gupta 100
 
31751 tejbeer 101
    @Autowired
102
    private CsService1 csService1;
31662 amit.gupta 103
 
31751 tejbeer 104
    @Value("${web.api.root}")
105
    private String webApiRoot;
24078 amit.gupta 106
 
31751 tejbeer 107
    @Value("${web.api.port}")
108
    private int webApiPort;
28430 tejbeer 109
 
31751 tejbeer 110
    @Autowired
111
    private PriceDropRepository priceDropRepository;
28443 tejbeer 112
 
31751 tejbeer 113
    @Autowired
114
    private CookiesProcessor cookiesProcessor;
26468 amit.gupta 115
 
31751 tejbeer 116
    @Autowired
117
    private PendingOrderRepository pendingOrderRepository;
28409 tejbeer 118
 
31751 tejbeer 119
    @Autowired
120
    private PartnerStatsService partnerStatsService;
23923 amit.gupta 121
 
31751 tejbeer 122
    @Autowired
123
    private CsService csService;
26090 amit.gupta 124
 
31751 tejbeer 125
    @Autowired
126
    private ResponseSender<?> responseSender;
26012 amit.gupta 127
 
31751 tejbeer 128
    @Autowired
129
    RetailerService retailerService;
25214 amit.gupta 130
 
31751 tejbeer 131
    @Autowired
132
    private AdminUser adminUser;
28468 tejbeer 133
 
31751 tejbeer 134
    @Autowired
135
    private RoleManager roleManager;
23923 amit.gupta 136
 
31751 tejbeer 137
    @Autowired
138
    private FofoStoreRepository fofoStoreRepository;
23884 amit.gupta 139
 
31751 tejbeer 140
    @Autowired
141
    private PartnerInvestmentService partnerInvestmentService;
24288 amit.gupta 142
 
31751 tejbeer 143
    @Autowired
144
    DocumentRepository documentRepository;
26236 amit.gupta 145
 
31751 tejbeer 146
    @Autowired
147
    InventoryItemRepository inventoryItemRepository;
25683 tejbeer 148
 
31751 tejbeer 149
    @Autowired
150
    InventoryService inventoryService;
23923 amit.gupta 151
 
31751 tejbeer 152
    @Autowired
153
    private PendingOrderItemRepository pendingOrderItemRepository;
28409 tejbeer 154
 
31751 tejbeer 155
    @Autowired
156
    private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
24203 amit.gupta 157
 
31751 tejbeer 158
    @Autowired
159
    private FofoOrderItemRepository fofoOrderItemRepository;
26012 amit.gupta 160
 
31751 tejbeer 161
    @Autowired
162
    private PartnerTypeChangeService partnerTypeChangeService;
25136 amit.gupta 163
 
31751 tejbeer 164
    @Autowired
165
    private HygieneDataRepository hygieneDataRepository;
25649 tejbeer 166
 
31751 tejbeer 167
    @Autowired
168
    private UserAccountRepository userAccountRepository;
25649 tejbeer 169
 
31751 tejbeer 170
    @Autowired
171
    private NotificationCampaignRepository notificationCampaignRepository;
25649 tejbeer 172
 
31751 tejbeer 173
    @Autowired
174
    private AuthRepository authRepository;
24880 govind 175
 
31751 tejbeer 176
    @Autowired
177
    private FofoOrderRepository fofoOrderRepository;
26071 tejbeer 178
 
31751 tejbeer 179
    @Autowired
180
    private Gson gson;
25649 tejbeer 181
 
31751 tejbeer 182
    @Autowired
183
    TicketRepository ticketRepository;
26418 tejbeer 184
 
31751 tejbeer 185
    @Autowired
186
    private OfferService offerService;
27876 amit.gupta 187
 
31751 tejbeer 188
    @Autowired
189
    private ItemRepository itemRepository;
26588 tejbeer 190
 
31751 tejbeer 191
    @Autowired
192
    private SaholicInventoryCISRepository saholicInventoryCISRepository;
27529 tejbeer 193
 
31751 tejbeer 194
    @Autowired
195
    private MVCResponseSender mvcResponseSender;
27529 tejbeer 196
 
31751 tejbeer 197
    @Autowired
36890 aman 198
    private ContactUsRepository contactUsRepository;
199
 
200
    @Autowired
31751 tejbeer 201
    private ReporticoCacheTableRepository reporticoCacheTableRepository;
27529 tejbeer 202
 
31751 tejbeer 203
    @Autowired
204
    private TransactionService transactionService;
27586 tejbeer 205
 
31751 tejbeer 206
    @Autowired
207
    private TagListingRepository tagListingRepository;
27632 tejbeer 208
 
31751 tejbeer 209
    @Autowired
210
    private TicketAssignedRepository ticketAssignedRepository;
27660 tejbeer 211
 
31751 tejbeer 212
    @Autowired
213
    private OrderRepository orderRepository;
28468 tejbeer 214
 
31751 tejbeer 215
    @Autowired
216
    private FofoUser fofoUser;
29875 tejbeer 217
 
31751 tejbeer 218
    @Autowired
219
    private ActivatedImeiRepository activatedImeiRepository;
28825 tejbeer 220
 
31751 tejbeer 221
    @Autowired
222
    private Mongo mongoClient;
28825 tejbeer 223
 
31751 tejbeer 224
    @Autowired
225
    private SchemeInOutRepository schemeInOutRepository;
29875 tejbeer 226
 
31751 tejbeer 227
    @Autowired
228
    private LineItemRepository lineItemRepository;
29875 tejbeer 229
 
31751 tejbeer 230
    @Autowired
231
    private FofoLineItemRepository fofoLineItemRepository;
29578 tejbeer 232
 
31751 tejbeer 233
    @Autowired
234
    private PositionRepository positionRepository;
29707 tejbeer 235
 
31751 tejbeer 236
    @Autowired
237
    private MonthlyTargetRepository monthlyTargetRepository;
31285 tejbeer 238
 
31751 tejbeer 239
    @Autowired
240
    private SamsungUpgradeOfferRepository samsungUpgradeOfferRepository;
241
    private static final Logger LOGGER = LogManager.getLogger(DashboardController.class);
32836 amit.gupta 242
 
32407 amit.gupta 243
    @Autowired
244
    private SSHService sshService;
35119 aman 245
 
34176 tejus.loha 246
    @Autowired
247
    BrandsService brandsService;
32407 amit.gupta 248
 
35104 vikas 249
    @Autowired
250
    SaleRewardService saleRewardService;
251
 
35119 aman 252
    @Autowired
253
    SchemeService schemeService;
254
    @Autowired
255
    PrintResourceRegionRepository printResourceRegionRepository;
256
    @Autowired
257
    PartnerRegionRepository partnerRegionRepository;
258
    @Autowired
259
    PrintResourceRepository printResourceRepository;
260
    @Autowired
261
    CatalogRepository catalogRepository;
262
    @Autowired
263
    OfferRepository offerRepository;
264
    @Autowired
265
    OfferPayoutRepository offerPayoutRepository;
266
    @Value("${google.api.key}")
267
    private String googleApiKey;
268
 
31751 tejbeer 269
    @RequestMapping(value = "/12dashboard34", method = RequestMethod.GET)
270
    public String dashboard1(HttpServletRequest request, Model model, @RequestParam int fofoId) throws Exception {
271
        boolean isAdmin = false;
272
        model.addAttribute("isAdmin", isAdmin);
25740 amit.gupta 273
 
31751 tejbeer 274
        model.addAttribute("webApiHost", webApiHost);
275
        model.addAttribute("webApiPort", webApiPort);
276
        model.addAttribute("webApiScheme", webApiScheme);
277
        model.addAttribute("webApiRoot", webApiRoot);
278
        if (isAdmin) {
279
            return "dashboard1";
280
        }
26236 amit.gupta 281
 
31751 tejbeer 282
        FofoStore fofoStore = null;
283
        try {
284
            CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
285
            fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
286
            if (!fofoStore.isActive()) {
287
                return "redirect:/login";
288
            }
25740 amit.gupta 289
 
31751 tejbeer 290
            PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());
291
            model.addAttribute("partnerType", partnerType);
292
            model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));
293
            model.addAttribute("fofoStore", customRetailer);
294
            model.addAttribute("partnerType", partnerType);
295
            model.addAttribute("hasGift", fofoUser.hasGift(fofoId));
296
            model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);
25740 amit.gupta 297
 
31884 tejbeer 298
            model.addAttribute("brandStockPrices", fofoUser.getBrandStockPrices(fofoId, false));
31751 tejbeer 299
            model.addAttribute("salesMap", fofoUser.getSales(fofoId));
300
            model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(fofoId));
301
            // this.setInvestments
302
            //
303
            Map<Integer, String> monthValueMap = new HashMap<>();
304
            for (int i = 0; i <= 5; i++) {
305
                LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);
306
                monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));
307
            }
308
            LOGGER.info("monthValueMap" + monthValueMap);
34176 tejus.loha 309
            Set<String> brands = brandsService.getBrandsToDisplay(3).stream().map(x -> x.getName()).collect(Collectors.toSet());
310
            brands.addAll(itemRepository.selectAllBrands(ProfitMandiConstants.LED_CATEGORY_ID));
311
            brands.addAll(itemRepository.selectAllBrands(ProfitMandiConstants.SMART_WATCH_CATEGORY_ID));
312
            brands.add("Live Demo");
313
            model.addAttribute("brands", brands);
31751 tejbeer 314
            model.addAttribute("monthValueMap", monthValueMap);
315
            model.addAttribute("investments", fofoUser.getInvestments(fofoId));
316
            model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(fofoId, ProfitMandiConstants.MIN_INVESTMENT_PERCENTAGE, ProfitMandiConstants.CUTOFF_INVESTMENT));
317
        } catch (ProfitMandiBusinessException e) {
318
            LOGGER.error("FofoStore Code not found of fofoId {}", fofoId);
25740 amit.gupta 319
 
31751 tejbeer 320
        }
25740 amit.gupta 321
 
31751 tejbeer 322
        return "12dashboard34";
323
    }
25740 amit.gupta 324
 
31751 tejbeer 325
    @RequestMapping(value = "/getMonthSale", method = RequestMethod.GET)
326
    public String getMonthsale(HttpServletRequest request, Model model) throws Exception {
327
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
328
        int fofoId = loginDetails.getFofoId();
329
        Map<Integer, MonthSaleModel> monthSaleMap = new HashMap<>();
330
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
331
        int dayOfMonth = curDate.getDayOfMonth();
34781 amit.gupta 332
        YearMonth yearMonth = YearMonth.now();
35284 aman 333
        for (int i = 0; i <= 6; i++) {
31751 tejbeer 334
            LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(i);
335
            int lengthOfMonth = YearMonth.from(startOfMonth).lengthOfMonth();
336
            LOGGER.info("Start of previous Month {}, start of next month Month {}", startOfMonth, startOfMonth.plusMonths(1));
337
            double monthSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth, startOfMonth.plusMonths(1), loginDetails.getFofoId(), false).get(fofoId);
35284 aman 338
            LOGGER.info("Month sales - {}", monthSales);
31751 tejbeer 339
            double mtdSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth, startOfMonth.plusDays(Math.min(dayOfMonth, lengthOfMonth)), loginDetails.getFofoId(), false).get(fofoId);
27474 tejbeer 340
 
34781 amit.gupta 341
            PartnerType partnerType = partnerTypeChangeService.getTypeOnMonth(fofoId, yearMonth.minusMonths(i));
27474 tejbeer 342
 
31751 tejbeer 343
            MonthSaleModel ms = new MonthSaleModel();
344
            ms.setMtdSales(fofoUser.format((long) mtdSales));
345
            ms.setMonthlySales(fofoUser.format(((long) monthSales)));
346
            ms.setPartnerType(partnerType);
347
            ms.setMonth(startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));
348
            monthSaleMap.put(i, ms);
349
        }
27474 tejbeer 350
 
31751 tejbeer 351
        model.addAttribute("monthSales", monthSaleMap);
352
        return "monthSales";
353
    }
27474 tejbeer 354
 
35064 aman 355
    @RequestMapping(value = "/getBrandwisePartnerSale", method = RequestMethod.GET)
356
    @ResponseBody
35284 aman 357
    public List<Map<String, Object>> getBrandwisePartnerSale(
358
            HttpServletRequest request,
359
            @RequestParam(name = "month", required = true, defaultValue = "0") int month,
360
            Model model) throws Exception {
361
 
35064 aman 362
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
363
        int fofoId = loginDetails.getFofoId();
35284 aman 364
 
365
        List<BrandWisePartnerSaleModel> mobileList =
366
                fofoStoreRepository.selectBrandWiseMonthlyPartnerSale(Collections.singletonList(fofoId), month);
367
 
368
        List<BrandWisePartnerSaleModel> accList =
369
                fofoStoreRepository.selectBrandWiseMonthlyPartnerAccessoriesSale(Collections.singletonList(fofoId), month);
370
 
35064 aman 371
        List<Map<String, Object>> response = new ArrayList<>();
35284 aman 372
 
373
        for (BrandWisePartnerSaleModel m : mobileList) {
35064 aman 374
            Map<String, Object> row = new HashMap<>();
375
            row.put("brand", m.getBrand());
36242 aman 376
            row.put("lmtd", fofoUser.format(m.getLmtd()));
377
            row.put("lmtdQty", m.getLmtdQty());
35064 aman 378
            row.put("mtd", fofoUser.format(m.getMtd()));
379
            row.put("mtdQty", m.getMtdQty());
380
            response.add(row);
381
        }
382
 
35284 aman 383
        long accLmtd = 0;
36242 aman 384
        long accLmtdQty = 0;
35284 aman 385
        long accMtd = 0;
386
        long accMtdQty = 0;
387
        for (BrandWisePartnerSaleModel a : accList) {
388
            accLmtd += a.getLmtd();
36242 aman 389
            accLmtdQty += a.getLmtdQty();
35284 aman 390
            accMtd += a.getMtd();
391
            accMtdQty += a.getMtdQty();
392
        }
393
        if (!accList.isEmpty()) {
394
            Map<String, Object> accRow = new HashMap<>();
395
            accRow.put("brand", "Accessories");
396
            accRow.put("lmtd", fofoUser.format(accLmtd));
36242 aman 397
            accRow.put("lmtdQty", accLmtdQty);
35284 aman 398
            accRow.put("mtd", fofoUser.format(accMtd));
399
            accRow.put("mtdQty", accMtdQty);
400
            response.add(accRow);
401
        }
35064 aman 402
 
403
        return response;
404
    }
405
 
35284 aman 406
 
35064 aman 407
    @RequestMapping(value = "/getBrandItemwisePartnerSale", method = RequestMethod.GET)
408
    @ResponseBody
409
    public List<BrandItemWisePartnerSaleModel> getBrandItemwisePartnerSale(HttpServletRequest request, @RequestParam(name = "month", required = true, defaultValue = "0") int month, @RequestParam(name = "brand") String brand, @RequestParam(name = "fofoId") Integer fofoId, Model model) throws Exception {
410
        List<BrandItemWisePartnerSaleModel> brandItemWisePartnerSaleModels = fofoStoreRepository.selectPartnerBrandItemMonthlySale(Collections.singletonList(fofoId), month, brand);
411
        LOGGER.info("brandItemWisePartnerSaleModels {}", brandItemWisePartnerSaleModels);
412
        return brandItemWisePartnerSaleModels;
413
    }
414
 
35119 aman 415
    @RequestMapping(value = "/getBrandItemwisePartnerSecondarySale", method = RequestMethod.GET)
416
    @ResponseBody
417
    public List<BrandItemWisePartnerSaleModel> getBrandItemwisePartnerSecondarySale(HttpServletRequest request, @RequestParam(name = "month", required = true, defaultValue = "0") int month, @RequestParam(name = "brand") String brand, @RequestParam(name = "fofoId") Integer fofoId, Model model) throws Exception {
418
        List<BrandItemWisePartnerSaleModel> brandItemWisePartnerSaleModels = fofoStoreRepository.selectPartnerBrandItemMonthlySecondarySale(Collections.singletonList(fofoId), month, brand);
419
        LOGGER.info("brandItemWisePartnerSaleModels {}", brandItemWisePartnerSaleModels);
420
        return brandItemWisePartnerSaleModels;
421
    }
35064 aman 422
 
35583 ranu 423
    @RequestMapping(value = "/dasboard/getDateWiseBulletins", method = RequestMethod.GET)
424
    public String getDateWiseBulletins(HttpServletRequest request,
425
                                       @RequestParam("date") String date,
426
                                       Model model) throws Exception {
32308 amit.gupta 427
 
37095 ranu 428
        // Callers on the partner-facing domain don't always carry the fofo admin
429
        // cookies (FOFO_ID / EMAIL_ID / ROLE_IDS) — cookiesProcessor would then
430
        // throw ProfitMandiBusinessException and the global handler would turn it
431
        // into a 400. Bulletins are per-position, so a session-less request has
432
        // nothing to show — return an empty bulletin list instead of failing.
433
        LoginDetails loginDetails;
434
        try {
435
            loginDetails = cookiesProcessor.getCookiesObject(request);
436
        } catch (ProfitMandiBusinessException e) {
437
            model.addAttribute("bulletins", new LinkedHashMap<>());
438
            return "bulletin-list";
439
        }
35583 ranu 440
        String email = loginDetails.getEmailId();
441
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
37095 ranu 442
        List<Position> positions = authUser == null
443
                ? new ArrayList<>()
444
                : positionRepository.selectAllByAuthUserId(authUser.getId());
35583 ranu 445
        LocalDate selectedDate = LocalDate.parse(date);
446
 
36849 ranu 447
        // Short-circuit when the caller has no Position rows. getTodayBulletin's
448
        // `positions` parameter is @NotEmpty validated — handing it an empty list
449
        // throws "List should not be empty" and 500s the dashboard. A user with
450
        // no positions simply has no bulletins to see, so render an empty page.
35583 ranu 451
        Map<ProfitMandiConstants.BULLETIN_TYPE_ENUM, List<BulletinOfferModal>> dbBulletins =
36849 ranu 452
                (positions == null || positions.isEmpty())
453
                        ? new HashMap<>()
454
                        : adminUser.getTodayBulletin(positions, selectedDate.atStartOfDay());
35583 ranu 455
 
35585 ranu 456
        // Final ordered map (STRICT enum order)
35583 ranu 457
        Map<ProfitMandiConstants.BULLETIN_TYPE_ENUM, List<BulletinOfferModal>> bulletins =
458
                new LinkedHashMap<>();
459
 
460
        for (ProfitMandiConstants.BULLETIN_TYPE_ENUM type :
461
                ProfitMandiConstants.BULLETIN_TYPE_ENUM.values()) {
35585 ranu 462
 
463
            List<BulletinOfferModal> list = dbBulletins.get(type);
464
 
465
            if (list != null && !list.isEmpty()) {
466
                bulletins.put(type, list);   // only add if has data
467
            }
35583 ranu 468
        }
469
 
470
        model.addAttribute("bulletins", bulletins);
471
        return "bulletin-list";
472
    }
473
 
474
 
31751 tejbeer 475
    @RequestMapping(value = "/dashboard", method = RequestMethod.GET)
476
    public String dashboard(HttpServletRequest request, Model model) throws Exception {
477
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
478
        String email = loginDetails.getEmailId();
479
        int fofoId = loginDetails.getFofoId();
480
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
481
        model.addAttribute("isAdmin", isAdmin);
23923 amit.gupta 482
 
31751 tejbeer 483
        model.addAttribute("webApiHost", webApiHost);
484
        model.addAttribute("webApiPort", webApiPort);
485
        model.addAttribute("webApiScheme", webApiScheme);
486
        model.addAttribute("webApiRoot", webApiRoot);
33063 ranu 487
        model.addAttribute("googleApiKey", googleApiKey);
33501 ranu 488
 
31751 tejbeer 489
        if (isAdmin) {
490
            return adminUser.adminPanel(loginDetails.getFofoId(), email, model);
491
        } else {
33705 amit.gupta 492
            FofoStore fofoStore;
493
            List<PartnerRegion> partnerRegion = partnerRegionRepository.selectByfofoId(fofoId);
494
            LocalDateTime currentDate = LocalDateTime.now();
495
            List<PrintResource> printResources = printResourceRepository.selectPrintResourcesByFofoRegion(partnerRegion.get(0).getRegionId(), currentDate);
496
            LOGGER.info("printresourcesList {}", printResources);
497
            model.addAttribute("printResources", printResources);
31751 tejbeer 498
            try {
499
                fofoStore = fofoStoreRepository.selectByRetailerId(loginDetails.getFofoId());
500
                if (!fofoStore.isActive()) {
501
                    return "redirect:/login";
502
                }
30346 tejbeer 503
 
31751 tejbeer 504
                LocalDateTime startDate = LocalDate.now().withDayOfYear(1).atStartOfDay();
505
                LocalDateTime endtDate = LocalDateTime.now();
506
                OnlineDeliveredOrderSum onlineDeliveredOrderSum = pendingOrderItemRepository.selectSumSellingPriceOnlineOrder(fofoId, startDate, endtDate);
507
                LOGGER.info("onlineDeliveredOrderSum" + onlineDeliveredOrderSum.getSellingPrice());
30455 amit.gupta 508
 
31751 tejbeer 509
                long countOrder = pendingOrderRepository.pendingOrderCount(fofoId, OrderStatus.PROCESSING);
510
                LOGGER.info("countOrder" + countOrder);
30455 amit.gupta 511
 
31751 tejbeer 512
                ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();
30455 amit.gupta 513
 
31751 tejbeer 514
                orderStatus.add(SUBMITTED_FOR_PROCESSING);
515
                orderStatus.add(BILLED);
516
                orderStatus.add(SHIPPED_FROM_WH);
517
                orderStatus.add(DELIVERY_SUCCESS);
30455 amit.gupta 518
 
31751 tejbeer 519
                List<Order> openOrders = orderRepository.selectGrnTimestampNull(fofoId, orderStatus);
520
                List<LineItem> submittedLineItemIds = openOrders.stream().filter(x -> x.getStatus().equals(SUBMITTED_FOR_PROCESSING)).map(x -> x.getLineItem()).collect(Collectors.toList());
521
                List<LineItem> billedOrderIds = openOrders.stream().filter(x -> x.getStatus().equals(BILLED)).map(x -> x.getLineItem()).collect(Collectors.toList());
522
                List<LineItem> shippedOrderIds = openOrders.stream().filter(x -> x.getStatus().equals(SHIPPED_FROM_WH)).map(x -> x.getLineItem()).collect(Collectors.toList());
523
                List<LineItem> grnPendingLineItemIds = openOrders.stream().filter(x -> x.getStatus().equals(DELIVERY_SUCCESS)).map(x -> x.getLineItem()).collect(Collectors.toList());
30455 amit.gupta 524
 
31751 tejbeer 525
                long imeiActivationPendingCount = 0;
526
                long imeiActivationPendingValue = 0;
33310 amit.gupta 527
                //Only delivered orders should be visible
34176 tejus.loha 528
                List<Integer> grnPendingOrderIds = openOrders.stream().filter(x -> x.getStatus().equals(DELIVERY_SUCCESS)).map(x -> x.getId()).collect(Collectors.toList());
31751 tejbeer 529
                if (grnPendingOrderIds.size() > 0) {
530
                    List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectActivatedImeisByOrders(grnPendingOrderIds);
531
                    imeiActivationPendingCount = imeiActivationTimestampModels.size();
532
                    imeiActivationPendingValue = imeiActivationTimestampModels.stream().collect(Collectors.summingDouble(x -> x.getSellingPrice())).longValue();
533
                }
30455 amit.gupta 534
 
31751 tejbeer 535
                long grnPendingCount = grnPendingLineItemIds.stream().collect(Collectors.summingLong(LineItem::getQuantity));
536
                long grnPendingValue = grnPendingLineItemIds.stream().collect(Collectors.summingLong(x -> x.getTotalPrice().longValue()));
537
                model.addAttribute("grnPendingCount", grnPendingCount);
538
                model.addAttribute("grnPendingValue", grnPendingValue);
30455 amit.gupta 539
 
31751 tejbeer 540
                long submittedCount = submittedLineItemIds.stream().collect(Collectors.summingLong(LineItem::getQuantity));
541
                long submittedValue = submittedLineItemIds.stream().collect(Collectors.summingLong(x -> x.getTotalPrice().longValue()));
542
                model.addAttribute("submittedCount", submittedCount);
543
                model.addAttribute("submittedValue", submittedValue);
30455 amit.gupta 544
 
31751 tejbeer 545
                long billedCount = billedOrderIds.stream().collect(Collectors.summingLong(LineItem::getQuantity));
546
                long billedValue = billedOrderIds.stream().collect(Collectors.summingLong(x -> x.getTotalPrice().longValue()));
547
                model.addAttribute("billedValue", billedValue);
548
                model.addAttribute("billedCount", billedCount);
549
                LOGGER.info("billedCount {}", billedCount);
30455 amit.gupta 550
 
31751 tejbeer 551
                long shippedCount = shippedOrderIds.stream().collect(Collectors.summingLong(LineItem::getQuantity));
552
                model.addAttribute("shippedCount", shippedCount);
553
                LOGGER.info("shippedCount {}", shippedCount);
554
                long shippedValue = shippedOrderIds.stream().collect(Collectors.summingLong(x -> x.getTotalPrice().longValue()));
555
                model.addAttribute("shippedValue", shippedValue);
30455 amit.gupta 556
 
31751 tejbeer 557
                LocalDateTime curDate = LocalDate.now().atStartOfDay();
30455 amit.gupta 558
 
31751 tejbeer 559
                LocalDateTime currentMonthStart = curDate.withDayOfMonth(1);
560
                LocalDateTime lastMonthStart = currentMonthStart.minusMonths(1);
561
                LocalDateTime currentMonthEnd = currentMonthStart.withDayOfMonth(1);
30455 amit.gupta 562
 
31751 tejbeer 563
                LOGGER.info("lastMonthStart" + lastMonthStart);
564
                LOGGER.info("currentMonthEnd" + currentMonthEnd);
30455 amit.gupta 565
 
32308 amit.gupta 566
                Scheme staticScheme = schemeService.getStaticScheme(fofoId);
567
                double schemeAchievement = 0;
568
                String schemeCategory = null;
569
                if (staticScheme != null) {
32313 tejbeer 570
                    Map<Integer, Double> schemeAchievementMap = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(staticScheme.getStartDateTime(), staticScheme.getEndDateTime());
571
                    if (schemeAchievementMap.get(fofoId) != null) {
572
                        schemeAchievement = schemeAchievementMap.get(fofoId);
35099 amit 573
                        if (staticScheme.getTarget() >= 1500000 && staticScheme.getTarget() < 2500000) {
574
                            schemeCategory = "Silver Club";
33705 amit.gupta 575
                        } else if (staticScheme.getTarget() < 3000000) {
576
                            schemeCategory = "Gold Club";
577
                        } else if (staticScheme.getTarget() < 6000000) {
578
                            schemeCategory = "Rising Star Club";
579
                        } else if (staticScheme.getTarget() < 8000000) {
580
                            schemeCategory = "Super Star Club";
35099 amit 581
                        } else if (staticScheme.getTarget() < 10000000) {
33705 amit.gupta 582
                            schemeCategory = "Diamond Club";
35099 amit 583
                        } else if (staticScheme.getTarget() < 20000000) {
33705 amit.gupta 584
                            schemeCategory = "Platinum Club";
32313 tejbeer 585
                        } else {
33705 amit.gupta 586
                            schemeCategory = "Premium Club";
32313 tejbeer 587
                        }
32308 amit.gupta 588
                    }
589
                }
590
 
591
 
31751 tejbeer 592
                model.addAttribute("countOrder", countOrder);
593
                model.addAttribute("onlineDeliveredOrderSum", onlineDeliveredOrderSum.getSellingPrice());
30455 amit.gupta 594
 
31751 tejbeer 595
                PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());
596
                model.addAttribute("partnerType", partnerType);
597
                model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));
598
                model.addAttribute("fofoStore", fofoStore);
599
                model.addAttribute("partnerType", partnerType);
600
                model.addAttribute("hasGift", fofoUser.hasGift(loginDetails.getFofoId()));
601
                model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);
602
                model.addAttribute("retailers", new JSONObject().append("code", fofoStore.getCode()).append("partnerId", fofoStore.getId()).toString());
603
                model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(loginDetails.getFofoId()));
604
                model.addAttribute("imeiActivationPendingCount", imeiActivationPendingCount);
605
                model.addAttribute("imeiActivationPendingValue", imeiActivationPendingValue);
30053 manish 606
 
31751 tejbeer 607
                Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(), curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));
27701 tejbeer 608
 
31751 tejbeer 609
                Double accesoriesStock = currentInventorySnapshotRepository.selectSumStockGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(), Optional.of(false)).get(loginDetails.getFofoId());
25180 amit.gupta 610
 
31751 tejbeer 611
                model.addAttribute("accesoriesStock", String.format("%.0f", accesoriesStock));
32308 amit.gupta 612
                model.addAttribute("staticScheme", staticScheme);
613
                model.addAttribute("schemeCategory", schemeCategory);
614
                model.addAttribute("schemeAchievement", schemeAchievement);
31884 tejbeer 615
                model.addAttribute("brandStockPrices", fofoUser.getBrandStockPrices(loginDetails.getFofoId(), false));
31751 tejbeer 616
                model.addAttribute("salesMap", fofoUser.getSales(loginDetails.getFofoId()));
34388 tejus.loha 617
                ChartModel cm = fofoUser.getBrandChart(loginDetails.getFofoId(),null,null,false);
26055 tejbeer 618
 
31751 tejbeer 619
                LOGGER.info("chartMap" + gson.toJson(cm));
620
                model.addAttribute("chartMap", gson.toJson(cm));
27701 tejbeer 621
 
34617 amit.gupta 622
                List<CreateOfferRequest> createOffers = offerService.getPublishedOffers(loginDetails.getFofoId(), YearMonth.from(LocalDateTime.now()));
623
 
35395 amit 624
                // Batch fetch all catalog IDs to avoid N+1 queries
625
                Set<Integer> allCatalogIds = createOffers.stream()
626
                        .flatMap(offer -> offer.getTargetSlabs().stream())
627
                        .flatMap(slab -> slab.getItemCriteriaPayouts().stream())
34617 amit.gupta 628
                        .map(ItemCriteriaPayout::getItemCriteria)
35395 amit 629
                        .flatMap(criteria -> criteria.getCatalogIds().stream())
630
                        .collect(Collectors.toSet());
34617 amit.gupta 631
 
35395 amit 632
                final Map<Integer, String> catalogBrandMap = new HashMap<>();
633
                if (!allCatalogIds.isEmpty()) {
634
                    try {
635
                        catalogBrandMap.putAll(catalogRepository.selectAllByIds(new ArrayList<>(allCatalogIds)).stream()
636
                                .collect(Collectors.toMap(c -> c.getId(), c -> c.getBrand())));
637
                    } catch (ProfitMandiBusinessException e) {
638
                        LOGGER.error("Error fetching catalogs by IDs", e);
639
                    }
640
                }
641
 
642
                List<CreateOfferRequest> publishedOffers = createOffers.stream()
643
                        .filter(createOffer -> createOffer.getTargetSlabs().stream()
644
                                .flatMap(slab -> slab.getItemCriteriaPayouts().stream())
645
                                .map(ItemCriteriaPayout::getItemCriteria)
646
                                .flatMap(criteria -> criteria.getCatalogIds().stream())
647
                                .noneMatch(catalogId -> "Live Demo".equals(catalogBrandMap.get(catalogId))))
648
                        .collect(Collectors.toList());
649
 
31751 tejbeer 650
                model.addAttribute("publishedOffers", publishedOffers);
651
                model.addAttribute("investments", fofoUser.getInvestments(loginDetails.getFofoId()));
652
                model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(loginDetails.getFofoId(), ProfitMandiConstants.MIN_INVESTMENT_PERCENTAGE, ProfitMandiConstants.CUTOFF_INVESTMENT));
26460 amit.gupta 653
 
32626 amit.gupta 654
                double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(currentMonthStart, currentMonthEnd)) / 2;
655
                double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(lastMonthStart, currentMonthStart)) / 2;
656
                double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.withEndDate(currentMonthEnd)) / 2;
31751 tejbeer 657
                model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);
658
                model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);
659
                model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);
30455 amit.gupta 660
 
31751 tejbeer 661
                long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart, currentMonthEnd);
30455 amit.gupta 662
 
31751 tejbeer 663
                long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false, currentMonthStart, currentMonthEnd);
664
                if (hygieneCount == 0 && invalidHygieneCount == 0) {
665
                    invalidHygieneCount = 1;
666
                }
667
                Map<Integer, String> monthValueMap = new HashMap<>();
33401 ranu 668
                for (int i = 0; i <= 12; i++) {
31751 tejbeer 669
                    LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);
670
                    monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));
671
                }
30455 amit.gupta 672
 
31751 tejbeer 673
                MonthlyTarget monthlyTarget = monthlyTargetRepository.selectByDateAndFofoId(YearMonth.now(), fofoId);
674
                model.addAttribute("monthlyTarget", monthlyTarget);
34176 tejus.loha 675
                Set<String> brands = brandsService.getBrandsToDisplay(3).stream().map(x -> x.getName()).collect(Collectors.toSet());
34181 tejus.loha 676
 
34176 tejus.loha 677
                model.addAttribute("brands", brands);
31751 tejbeer 678
                model.addAttribute("monthValueMap", monthValueMap);
679
                model.addAttribute("month", 0);
33409 ranu 680
                model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));
31751 tejbeer 681
                model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());
682
                model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());
35104 vikas 683
                Map<String, Object> rewardsMap = saleRewardService.findByFofoAndRegionId(fofoId, partnerRegion.get(0).getRegionId());
35247 vikas 684
                StoreSalesTarget targetData = saleRewardService.findTargetsByFofoId(fofoId);
35104 vikas 685
                model.addAttribute("rewardsMap", rewardsMap);
35247 vikas 686
                model.addAttribute("targetData", targetData);
35104 vikas 687
                model.addAttribute("regionId", partnerRegion.get(0).getRegionId());
30455 amit.gupta 688
 
35104 vikas 689
 
690
 
32308 amit.gupta 691
            } catch (
32407 amit.gupta 692
                    ProfitMandiBusinessException e) {
31751 tejbeer 693
                LOGGER.error("FofoStore Code not found of fofoId {}", loginDetails.getFofoId());
25180 amit.gupta 694
 
31751 tejbeer 695
            }
696
            return "dashboard1";
697
        }
25649 tejbeer 698
 
31751 tejbeer 699
    }
29875 tejbeer 700
 
31751 tejbeer 701
    @RequestMapping(value = "/getGrnPendingOrderStatus", method = RequestMethod.GET)
702
    public String getGrnPendingOrderStatus(HttpServletRequest request, Model model) throws Exception {
29875 tejbeer 703
 
31751 tejbeer 704
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
705
        int fofoId = loginDetails.getFofoId();
706
        List<Order> grnPendingOrders = orderRepository.selectGrnTimestampNull(fofoId, Arrays.asList(in.shop2020.model.v1.order.OrderStatus.DELIVERY_SUCCESS));
29746 manish 707
 
31751 tejbeer 708
        model.addAttribute("grnPendingOrders", grnPendingOrders);
709
        return "purchase-grn-order-status";
710
    }
29875 tejbeer 711
 
31751 tejbeer 712
    @RequestMapping(value = "/getPendingOrderStatus", method = RequestMethod.GET)
713
    public String getPendingOrderStatus(HttpServletRequest request, Model model) throws Exception {
29875 tejbeer 714
 
31751 tejbeer 715
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
716
        int fofoId = loginDetails.getFofoId();
717
        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();
29875 tejbeer 718
 
31751 tejbeer 719
        orderStatus.add(in.shop2020.model.v1.order.OrderStatus.SUBMITTED_FOR_PROCESSING);
29875 tejbeer 720
 
31751 tejbeer 721
        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);
722
        List<Integer> submittedOrderIds = order.stream().filter(x -> x.getStatus() == in.shop2020.model.v1.order.OrderStatus.SUBMITTED_FOR_PROCESSING).map(x -> x.getId()).collect(Collectors.toList());
723
        model.addAttribute("submittedOrderIds", submittedOrderIds);
724
        if (!submittedOrderIds.isEmpty()) {
29875 tejbeer 725
 
31751 tejbeer 726
            List<LineItem> submittedLineItem = lineItemRepository.selectLineItem(submittedOrderIds);
727
            Map<Integer, LineItem> submittedLineItemMap = submittedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));
33075 amit.gupta 728
            //LOGGER.info("submittedLineItemMap {}", submittedLineItemMap);
31751 tejbeer 729
            model.addAttribute("submittedLineItemMap", submittedLineItemMap);
730
        }
29875 tejbeer 731
 
31751 tejbeer 732
        return "purchase-pending-order-status";
733
    }
29875 tejbeer 734
 
31751 tejbeer 735
    @RequestMapping(value = "/getBilledOrderStatus", method = RequestMethod.GET)
736
    public String getBilledOrderStatus(HttpServletRequest request, Model model) throws Exception {
29875 tejbeer 737
 
31751 tejbeer 738
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
739
        int fofoId = loginDetails.getFofoId();
740
        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();
741
        orderStatus.add(in.shop2020.model.v1.order.OrderStatus.BILLED);
29875 tejbeer 742
 
31751 tejbeer 743
        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);
744
        List<Integer> billedOrderIds = order.stream().filter(x -> x.getStatus() == in.shop2020.model.v1.order.OrderStatus.BILLED).map(x -> x.getId()).collect(Collectors.toList());
745
        LOGGER.info("billedOrderIds {}", billedOrderIds);
746
        model.addAttribute("billedOrderIds", billedOrderIds);
29875 tejbeer 747
 
31751 tejbeer 748
        if (!billedOrderIds.isEmpty()) {
749
            List<LineItem> billedLineItem = lineItemRepository.selectLineItem(billedOrderIds);
750
            Map<Integer, LineItem> billedLineItemMap = billedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));
751
            LOGGER.info("billedLineItemMap {}", billedLineItemMap);
752
            model.addAttribute("billedLineItemMap", billedLineItemMap);
753
        }
29875 tejbeer 754
 
31751 tejbeer 755
        return "purchase-billed-order-status";
756
    }
29875 tejbeer 757
 
31751 tejbeer 758
    @RequestMapping(value = "/getShippedOrderStatus", method = RequestMethod.GET)
759
    public String getShippedOrderStatus(HttpServletRequest request, Model model) throws Exception {
29875 tejbeer 760
 
31751 tejbeer 761
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
762
        int fofoId = loginDetails.getFofoId();
763
        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();
29875 tejbeer 764
 
31751 tejbeer 765
        orderStatus.add(SHIPPED_FROM_WH);
29875 tejbeer 766
 
31751 tejbeer 767
        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);
768
        List<Integer> shippedOrderIds = order.stream().filter(x -> x.getPartnerGrnTimestamp() == null).map(x -> x.getId()).collect(Collectors.toList());
769
        model.addAttribute("shippedOrderIds", shippedOrderIds);
770
        LOGGER.info("shippedOrderIds {}", shippedOrderIds);
29875 tejbeer 771
 
31751 tejbeer 772
        if (!shippedOrderIds.isEmpty()) {
773
            List<LineItem> shippedLineItem = lineItemRepository.selectLineItem(shippedOrderIds);
774
            Map<Integer, LineItem> shippedLineItemMap = shippedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));
775
            LOGGER.info("shippedLineItemMap {}", shippedLineItemMap);
29875 tejbeer 776
 
31751 tejbeer 777
            model.addAttribute("shippedLineItemMap", shippedLineItemMap);
778
        }
779
        return "purchase-shipped-order-status";
780
    }
23923 amit.gupta 781
 
31337 amit.gupta 782
 
31353 amit.gupta 783
 
31751 tejbeer 784
    @RequestMapping(value = "/partnerTotalIncomeByMonth/{yearMonth}", method = RequestMethod.GET)
32836 amit.gupta 785
    public String getPartnerTotalIncomeByMonth(HttpServletRequest request, @PathVariable int yearMonth, Model model) throws
786
            Exception {
30224 tejbeer 787
 
31751 tejbeer 788
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34813 aman 789
        Map<String, Object> data = retailerService
790
                .computeIncomeMap(loginDetails.getFofoId(), yearMonth);
791
//        long pendingIncome = 0;
792
//        long partnerPurchaseIn = 0;
793
//        long partnerCreditedSale = 0;
794
//        long partnerFrontIncome = 0;
795
//
796
//        LocalDateTime startOfMonth = LocalDate.now().minusMonths(yearMonth).withDayOfMonth(1).atStartOfDay();
797
//        LocalDateTime endOfMonth = startOfMonth.plusMonths(1).toLocalDate().atStartOfDay();
798
//
799
//        AllPurchaseInventoryModel partnerlPendingSaleAmount = schemeInOutRepository.selectAllPendingSaleInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);
800
//        AllPurchaseInventoryModel partnerCreditedSaleAmount = schemeInOutRepository.selectAllCreditedSaleInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);
801
//        AllPurchaseInventoryModel partnerPurchaseInAmount = schemeInOutRepository.selectAllPurchaseInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);
802
//
803
//        AllPurchaseInventoryModel partnerFrontIncomes = schemeInOutRepository.selectFrontIncomeByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);
804
//
805
//        List<OfferPayoutImeiIncomeModel> offerPayoutImeiIncomeModels = offerPayoutRepository.getTotalPayoutsByPartnerPeriod(YearMonth.of(startOfMonth.getYear(), startOfMonth.getMonth()), loginDetails.getFofoId(), null, null);
806
//
807
//        long additionalIncome = offerPayoutImeiIncomeModels.stream().collect(Collectors.summingDouble(x -> x.getSalePayout() + x.getPurchasePayout())).longValue();
808
//        // AllPurchaseInventoryModel partnerAdditionalIncome =
809
//        // offerRepository.selectPurchaseIncome(loginDetails.getFofoId(), startOfMonth,
810
//        // endOfMonth);
811
//
812
//        LOGGER.info("partnerfrontIncomes" + partnerFrontIncomes);
813
//
814
//        LOGGER.info("partnerCreditedSaleAmount" + partnerCreditedSaleAmount);
815
//        LOGGER.info("partnerPurchaseInAmount" + partnerPurchaseInAmount);
816
//        LOGGER.info("partnerlPendingSaleAmount" + partnerlPendingSaleAmount);
817
//
818
//        if (partnerlPendingSaleAmount != null) {
819
//
820
//            pendingIncome = partnerlPendingSaleAmount.getAmount();
821
//
822
//            LOGGER.info("pendingIncome" + pendingIncome);
823
//
824
//        }
825
//
826
//        if (partnerCreditedSaleAmount != null) {
827
//
828
//            partnerCreditedSale = partnerCreditedSaleAmount.getAmount();
829
//
830
//            LOGGER.info("partnerCreditedSale" + partnerCreditedSale);
831
//
832
//        }
833
//        if (partnerFrontIncomes != null) {
834
//
835
//            partnerFrontIncome = partnerFrontIncomes.getAmount();
836
//            LOGGER.info("partnerPurchaseIn" + partnerPurchaseIn);
837
//
838
//        }
839
//        if (partnerPurchaseInAmount != null) {
840
//
841
//            partnerPurchaseIn = partnerPurchaseInAmount.getAmount();
842
//            LOGGER.info("partnerPurchaseIn" + partnerPurchaseIn);
843
//
844
//        }
845
//
846
//        LOGGER.info("partnerPurchaseInTT" + partnerPurchaseIn);
847
//        LOGGER.info("partnerCreditedSaleTT" + partnerCreditedSale);
848
//        LOGGER.info("pendingIncomeTT" + pendingIncome);
849
//
850
//        long totalIncome = partnerCreditedSale + partnerPurchaseIn + pendingIncome + partnerFrontIncome + additionalIncome;
851
//
852
//        long creditedIncome = partnerCreditedSale + partnerPurchaseIn + partnerFrontIncome + additionalIncome;
853
//
854
//        long pendingTotalIncome = pendingIncome;
855
//        LOGGER.info("totalIncome" + totalIncome);
856
//        LOGGER.info("creditedIncome" + creditedIncome);
857
//        LOGGER.info("pendingTotalIncome" + pendingTotalIncome);
858
//
859
        model.addAttribute("totalIncome", data.get("totalIncome"));
860
        model.addAttribute("creditedIncome", data.get("creditedIncome"));
861
        model.addAttribute("pendingTotalIncome", data.get("pendingIncome"));
862
//
863
//        Map<Integer, String> monthValueMap = new HashMap<>();
864
//        for (int i = 0; i <= 5; i++) {
865
//            LocalDateTime monthStart = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);
866
//            monthValueMap.put(i, monthStart.format(DateTimeFormatter.ofPattern("MMM''uu")));
867
//        }
868
//
869
        model.addAttribute("month", data.get("monthIndex"));
870
        model.addAttribute("monthValueMap", data.get("monthValueMap"));
871
        LOGGER.info("income data", data);
872
        model.addAttribute("data", data);
31751 tejbeer 873
        return "partner-total-income";
874
    }
30224 tejbeer 875
 
31751 tejbeer 876
    @RequestMapping(value = "/getMonthsInvestment", method = RequestMethod.GET)
32836 amit.gupta 877
    public String getMonthsInvestment(HttpServletRequest request,
878
                                      @RequestParam(name = "month", required = true, defaultValue = "0") int month, Model model) throws Exception {
31751 tejbeer 879
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
880
        int fofoId = loginDetails.getFofoId();
881
        Map<String, Object> investment = fofoUser.getInvestmentsMonths(fofoId, month);
28430 tejbeer 882
 
31751 tejbeer 883
        LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);
884
        LocalDateTime lastMonthStart = currentMonthStart.minusMonths(1);
885
        LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);
32626 amit.gupta 886
        double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(currentMonthStart, currentMonthEnd)) / 2;
887
        double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(lastMonthStart, currentMonthStart)) / 2;
888
        double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.withEndDate(currentMonthEnd)) / 2;
31751 tejbeer 889
        model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);
890
        model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);
891
        model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);
28272 tejbeer 892
 
31751 tejbeer 893
        long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart.minusMonths(month), currentMonthEnd.minusMonths(month));
28272 tejbeer 894
 
31751 tejbeer 895
        long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false, currentMonthStart.minusMonths(month), currentMonthEnd.minusMonths(month));
896
        if (hygieneCount == 0 && invalidHygieneCount == 0) {
897
            invalidHygieneCount = 1;
898
        }
899
        Map<Integer, String> monthValueMap = new HashMap<>();
900
        for (int i = 0; i <= 5; i++) {
901
            LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);
902
            monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));
903
        }
904
        model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));
905
        model.addAttribute("monthValueMap", monthValueMap);
906
        model.addAttribute("investments", investment);
907
        model.addAttribute("monthDays", LocalDate.now().minusMonths(month).lengthOfMonth());
908
        model.addAttribute("dayOfMonth", LocalDate.now().minusMonths(month).lengthOfMonth());
909
        model.addAttribute("month", month);
910
        return "performance";
911
    }
28272 tejbeer 912
 
31751 tejbeer 913
    @RequestMapping(value = "/investmentDetails", method = RequestMethod.GET)
914
    public String getInvestmentDetails(HttpServletRequest request, Model model) throws Exception {
915
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
916
        int fofoId = loginDetails.getFofoId();
917
        ChartInvestmentModel cm = fofoUser.getInvestmentChart(fofoId);
918
        model.addAttribute("chartPieMap", gson.toJson(cm));
27884 tejbeer 919
 
31751 tejbeer 920
        LOGGER.info("InvestmentChart" + gson.toJson(cm));
921
        LOGGER.info("InvestmentChart" + cm);
922
        return "investmentdetails";
923
    }
27884 tejbeer 924
 
31751 tejbeer 925
    @RequestMapping(value = "/getlmsLineChart", method = RequestMethod.GET)
34528 ranu 926
    public String getlmsLineChart(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {
927
        if (fofoId == 0) {
928
            LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
929
            fofoId = loginDetails.getFofoId();
930
        }
28430 tejbeer 931
 
34528 ranu 932
        ChartModel cm = fofoUser.getLmsLineChart(fofoId);
933
 
31751 tejbeer 934
        LOGGER.info("linechartMap" + gson.toJson(cm));
935
        model.addAttribute("linechartMap", gson.toJson(cm));
936
        return "lmsLineChart";
937
    }
28430 tejbeer 938
 
31751 tejbeer 939
    @RequestMapping(value = "/getMonthlyPurchaseLineChart", method = RequestMethod.GET)
34528 ranu 940
    public String getMonthlyPurchaseLineChart(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {
941
        if (fofoId == 0) {
942
            LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
943
            fofoId = loginDetails.getFofoId();
944
        }
31751 tejbeer 945
        ChartModel cm = fofoUser.getPurchaseOrderChart(fofoId);
28439 tejbeer 946
 
31751 tejbeer 947
        LOGGER.info("chartMap" + gson.toJson(cm));
948
        model.addAttribute("chartMap", gson.toJson(cm));
28439 tejbeer 949
 
31751 tejbeer 950
        return "purchase_chart";
951
    }
28439 tejbeer 952
 
31751 tejbeer 953
    @RequestMapping(value = "/getBarChart", method = RequestMethod.GET)
34388 tejus.loha 954
    public String getBarChart(HttpServletRequest request, @RequestParam(required = false) LocalDate from, @RequestParam(required = false) LocalDate to,@RequestParam(required = false) Boolean isQuantity ,Model model) throws Exception {
31751 tejbeer 955
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
956
        int fofoId = loginDetails.getFofoId();
34388 tejus.loha 957
        LocalDateTime curDate = from == null ? LocalDate.now().atStartOfDay().withDayOfMonth(1) : from.atStartOfDay();
958
        LocalDateTime lastDate = to == null ? LocalDate.now().atStartOfDay().with(LocalTime.MAX) : to.atStartOfDay();
959
        isQuantity = isQuantity==null?false:isQuantity;
960
        ChartModel cm = fofoUser.getBrandChart(fofoId, from, to,isQuantity);
961
        LOGGER.info("from" + curDate);
962
        LOGGER.info("to" + lastDate);
31751 tejbeer 963
        LOGGER.info("chartMap" + gson.toJson(cm));
964
        model.addAttribute("chartMap", gson.toJson(cm));
34388 tejus.loha 965
        model.addAttribute("from", curDate.toLocalDate());
966
        model.addAttribute("to", lastDate.toLocalDate());
967
        model.addAttribute("fofoId", fofoId);
968
        model.addAttribute("isQuantity",isQuantity);
31751 tejbeer 969
        return "bar_chart";
970
    }
28430 tejbeer 971
 
34388 tejus.loha 972
    @GetMapping(value = "/brandWiseFofoSaleData")
973
    public String getBarChartModelWise(HttpServletRequest request,
974
                                       @RequestParam LocalDate from,
975
                                       @RequestParam LocalDate to,
976
                                       @RequestParam String brand,
977
                                       @RequestParam boolean isQuantity,
978
                                       @RequestParam int fofoId, Model model) throws Exception {
979
        ChartModel cm = fofoUser.getModelBrandChart(fofoId, brand, from, to,isQuantity);
980
 
981
        LOGGER.info("chartMap" + gson.toJson(cm));
982
 
983
        model.addAttribute("chartMap", gson.toJson(cm));
984
        return "bar_chart_model_wise";
985
    }
986
 
31751 tejbeer 987
    @RequestMapping(value = "/getPriceDropDetails", method = RequestMethod.GET)
32836 amit.gupta 988
    public String getPriceDropDetails(HttpServletRequest request,
989
                                      @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
990
                                      @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,
991
                                      @RequestParam(name = "yearMonth", required = false, defaultValue = "0") String yearMonth, Model model) throws
992
            Exception {
28455 tejbeer 993
 
31751 tejbeer 994
        LOGGER.info("params" + fofoId + brand + yearMonth);
28455 tejbeer 995
 
31751 tejbeer 996
        List<PriceDropWithDetailsByYearMonthModel> priceDropdetailsList = priceDropRepository.selectBrandPendingPriceDropWithDetailsByYearMonth(fofoId, brand, yearMonth);
28455 tejbeer 997
 
31751 tejbeer 998
        LOGGER.info("priceDropdetailsList" + priceDropdetailsList);
28455 tejbeer 999
 
31751 tejbeer 1000
        model.addAttribute("priceDropdetailsList", priceDropdetailsList);
28455 tejbeer 1001
 
31751 tejbeer 1002
        return "price-drop-details";
1003
    }
28825 tejbeer 1004
 
31751 tejbeer 1005
    @RequestMapping(value = "/getPriceDropDetailSixMonths", method = RequestMethod.GET)
32836 amit.gupta 1006
    public String getPriceDropDetailSixMonths(HttpServletRequest request,
1007
                                              @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1008
                                              @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model) throws Exception {
28455 tejbeer 1009
 
31751 tejbeer 1010
        LOGGER.info("params" + fofoId + brand);
1011
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
1012
        LocalDateTime startfMonthSixMonth = curDate.withDayOfMonth(1).minusMonths(12);
1013
        LocalDateTime endMonthTotal = curDate.withDayOfMonth(1).minusMonths(6);
28641 amit.gupta 1014
 
31751 tejbeer 1015
        List<PriceDropWithDetailsByYearMonthModel> priceDropdetailsList = priceDropRepository.selectBrandPendingPriceDropWithDetailsAndSixMonth(fofoId, brand, startfMonthSixMonth, endMonthTotal);
28641 amit.gupta 1016
 
31751 tejbeer 1017
        LOGGER.info("priceDropdetailsList" + priceDropdetailsList);
28641 amit.gupta 1018
 
31751 tejbeer 1019
        model.addAttribute("priceDropdetailsList", priceDropdetailsList);
28641 amit.gupta 1020
 
31751 tejbeer 1021
        return "price-drop-details";
1022
    }
28641 amit.gupta 1023
 
31751 tejbeer 1024
    @RequestMapping(value = "/getMonthlyPriceDrop", method = RequestMethod.GET)
34528 ranu 1025
    public String getMonthlyPriceDropTabular(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {
31751 tejbeer 1026
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34528 ranu 1027
        if (fofoId == 0) {
1028
            fofoId = loginDetails.getFofoId();
1029
        }
1030
 
31751 tejbeer 1031
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
28455 tejbeer 1032
 
31751 tejbeer 1033
        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
1034
        LocalDateTime startfMonthTotal = curDate.withDayOfMonth(1).minusMonths(12);
1035
        LocalDateTime endMonthTotal = curDate.withDayOfMonth(1).minusMonths(5);
28455 tejbeer 1036
 
31751 tejbeer 1037
        LOGGER.info("startfMonthTotal" + startfMonthTotal);
29875 tejbeer 1038
 
31751 tejbeer 1039
        LOGGER.info("endMonthTotal" + endMonthTotal);
1040
        List<YearMonth> yms = new ArrayList<YearMonth>();
28455 tejbeer 1041
 
31751 tejbeer 1042
        for (int i = 0; i <= 5; i++) {
1043
            yms.add(YearMonth.from(curDate.withDayOfMonth(1).minusMonths(i)));
1044
        }
1045
        Collections.reverse(yms);
1046
        model.addAttribute("yms", yms);
1047
        LOGGER.info("ym" + yms);
28455 tejbeer 1048
 
31751 tejbeer 1049
        List<PriceDropYearMonthModel> priceDropYearMonthModels = priceDropRepository.selectBrandPendingPriceDropByYearMonth(fofoId, startOfMonth);
28455 tejbeer 1050
 
31751 tejbeer 1051
        List<PriceDropBrandModel> priceDropBrandSixMonthTotals = priceDropRepository.selectSixMonthBrandPriceDropByYearMonth(fofoId, startfMonthTotal, endMonthTotal);
28641 amit.gupta 1052
 
31751 tejbeer 1053
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-yyyy");
28455 tejbeer 1054
 
31751 tejbeer 1055
        Map<String, Map<YearMonth, Double>> brandMonthValue = new HashMap<>();
28641 amit.gupta 1056
 
31751 tejbeer 1057
        LOGGER.info("priceDropBrandSixMonthTotals" + priceDropBrandSixMonthTotals);
28825 tejbeer 1058
 
31751 tejbeer 1059
        Map<String, Double> priceDropBrandSixMonthMap = priceDropBrandSixMonthTotals.stream().collect(Collectors.toMap(x -> x.getBrand(), x -> (double) x.getAmount()));
28825 tejbeer 1060
 
31751 tejbeer 1061
        model.addAttribute("priceDropBrandSixMonthMap", priceDropBrandSixMonthMap);
1062
        LOGGER.info("priceDropYearMonthModels" + priceDropYearMonthModels);
28641 amit.gupta 1063
 
31751 tejbeer 1064
        for (PriceDropYearMonthModel pdm : priceDropYearMonthModels) {
1065
            Map<YearMonth, Double> brandValue = new HashMap<>();
28455 tejbeer 1066
 
31751 tejbeer 1067
            if (brandMonthValue.containsKey(pdm.getBrand())) {
1068
                brandValue = brandMonthValue.get(pdm.getBrand());
1069
                brandValue.put(YearMonth.parse(pdm.getYearMonth(), dateTimeFormatter), (double) pdm.getAmount());
1070
            } else {
28455 tejbeer 1071
 
31751 tejbeer 1072
                brandValue.put(YearMonth.parse(pdm.getYearMonth(), dateTimeFormatter), (double) pdm.getAmount());
28455 tejbeer 1073
 
31751 tejbeer 1074
            }
1075
            brandMonthValue.put(pdm.getBrand(), brandValue);
1076
        }
1077
        List<String> brands = new ArrayList<>();
1078
        brands.add("Accessories");
1079
        brands.add("Oppo");
1080
        brands.add("Vivo");
1081
        brands.add("Samsung");
1082
        brands.add("Realme");
1083
        brands.add("MI");
1084
        brands.add("Tecno");
1085
        brands.add("Itel");
1086
        brands.add("Nokia");
29578 tejbeer 1087
 
31751 tejbeer 1088
        Map<String, List<Double>> sortedBrandValue = new LinkedHashMap<>();
28455 tejbeer 1089
 
31751 tejbeer 1090
        model.addAttribute("brands", brands);
28825 tejbeer 1091
 
31751 tejbeer 1092
        for (String brand : brands) {
1093
            Map<YearMonth, Double> yearMonthValue = brandMonthValue.get(brand);
1094
            for (int i = 5; i >= 0; i--) {
28455 tejbeer 1095
 
31751 tejbeer 1096
                LocalDateTime startMonth = curDate.withDayOfMonth(1).minusMonths(i);
28455 tejbeer 1097
 
31751 tejbeer 1098
                if (yearMonthValue != null) {
1099
                    if (yearMonthValue.get(YearMonth.from(startMonth)) == null) {
1100
                        yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1101
                    }
28455 tejbeer 1102
 
31751 tejbeer 1103
                } else {
1104
                    yearMonthValue = new HashMap<>();
1105
                    yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1106
                }
1107
            }
28455 tejbeer 1108
 
31751 tejbeer 1109
            Map<YearMonth, Double> sortedMonthBrandValue = new TreeMap<>(yearMonthValue);
28455 tejbeer 1110
 
31751 tejbeer 1111
            brandMonthValue.put(brand, sortedMonthBrandValue);
28455 tejbeer 1112
 
31751 tejbeer 1113
            sortedBrandValue.put(brand, sortedMonthBrandValue.values().stream().collect(Collectors.toList()));
28455 tejbeer 1114
 
31751 tejbeer 1115
        }
28455 tejbeer 1116
 
31751 tejbeer 1117
        LOGGER.info("sortedBrandValue" + sortedBrandValue);
1118
        model.addAttribute("fofoId", fofoId);
28455 tejbeer 1119
 
31751 tejbeer 1120
        model.addAttribute("sortedBrandValue", sortedBrandValue);
28455 tejbeer 1121
 
31751 tejbeer 1122
        return "price-drop-tabular";
1123
    }
28455 tejbeer 1124
 
31751 tejbeer 1125
    @RequestMapping(value = "/getMonthlyActivation", method = RequestMethod.GET)
34528 ranu 1126
    public String getMonthlyActivation(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {
31751 tejbeer 1127
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34528 ranu 1128
        if (fofoId == 0) {
1129
            fofoId = loginDetails.getFofoId();
1130
        }
28455 tejbeer 1131
 
31751 tejbeer 1132
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
1133
        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
29578 tejbeer 1134
 
31751 tejbeer 1135
        List<YearMonth> yms = new ArrayList<YearMonth>();
29578 tejbeer 1136
 
31751 tejbeer 1137
        for (int i = 0; i <= 5; i++) {
1138
            yms.add(YearMonth.from(curDate.withDayOfMonth(1).minusMonths(i)));
1139
        }
1140
        Collections.reverse(yms);
1141
        model.addAttribute("yms", yms);
1142
        LOGGER.info("ym" + yms);
29578 tejbeer 1143
 
31751 tejbeer 1144
        List<ActivationYearMonthModel> pendingActivationModels = schemeInOutRepository.selectPendingActivationGroupByBrandYearMonth(fofoId, startOfMonth);
29578 tejbeer 1145
 
31751 tejbeer 1146
        List<ActivationBrandModel> pendingActivationBeforeSixMonth = schemeInOutRepository.selectByYearMonthActivationGroupByBrand(fofoId, startOfMonth);
29578 tejbeer 1147
 
31751 tejbeer 1148
        Map<String, Double> pendingActivationBeforeSixMonthMap = pendingActivationBeforeSixMonth.stream().collect(Collectors.toMap(x -> x.getBrand(), x -> (double) x.getAmount()));
29578 tejbeer 1149
 
31751 tejbeer 1150
        model.addAttribute("pendingActivationBeforeSixMonthMap", pendingActivationBeforeSixMonthMap);
29578 tejbeer 1151
 
31751 tejbeer 1152
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-yyyy");
29578 tejbeer 1153
 
31751 tejbeer 1154
        Map<String, Map<YearMonth, Double>> activationBrandMonthMap = new HashMap<>();
29578 tejbeer 1155
 
31751 tejbeer 1156
        for (ActivationYearMonthModel pam : pendingActivationModels) {
1157
            Map<YearMonth, Double> brandValue = new HashMap<>();
29578 tejbeer 1158
 
31751 tejbeer 1159
            if (activationBrandMonthMap.containsKey(pam.getBrand())) {
1160
                brandValue = activationBrandMonthMap.get(pam.getBrand());
1161
                brandValue.put(YearMonth.parse(pam.getYearMonth(), dateTimeFormatter), (double) pam.getAmount());
1162
            } else {
29578 tejbeer 1163
 
31751 tejbeer 1164
                brandValue.put(YearMonth.parse(pam.getYearMonth(), dateTimeFormatter), (double) pam.getAmount());
29578 tejbeer 1165
 
31751 tejbeer 1166
            }
1167
            activationBrandMonthMap.put(pam.getBrand(), brandValue);
1168
        }
28455 tejbeer 1169
 
31751 tejbeer 1170
        List<String> brands = new ArrayList<>();
1171
        brands.add("Oppo");
1172
        brands.add("Vivo");
1173
        brands.add("Samsung");
1174
        brands.add("Realme");
1175
        brands.add("MI");
1176
        brands.add("Tecno");
1177
        brands.add("Itel");
1178
        brands.add("Nokia");
1179
        brands.add("Lava");
1180
        Map<String, List<Double>> sortedBrandValue = new LinkedHashMap<>();
29578 tejbeer 1181
 
31751 tejbeer 1182
        model.addAttribute("brands", brands);
29578 tejbeer 1183
 
31751 tejbeer 1184
        for (String brand : brands) {
1185
            Map<YearMonth, Double> yearMonthValue = activationBrandMonthMap.get(brand);
1186
            for (int i = 5; i >= 0; i--) {
1187
                LocalDateTime startMonth = curDate.withDayOfMonth(1).minusMonths(i);
1188
                if (yearMonthValue != null) {
1189
                    if (yearMonthValue.get(YearMonth.from(startMonth)) == null) {
1190
                        yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1191
                    }
29578 tejbeer 1192
 
31751 tejbeer 1193
                } else {
1194
                    yearMonthValue = new HashMap<>();
1195
                    yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1196
                }
1197
            }
1198
            Map<YearMonth, Double> sortedMonthBrandValue = new TreeMap<>(yearMonthValue);
1199
            activationBrandMonthMap.put(brand, sortedMonthBrandValue);
1200
            sortedBrandValue.put(brand, sortedMonthBrandValue.values().stream().collect(Collectors.toList()));
1201
        }
28455 tejbeer 1202
 
31751 tejbeer 1203
        LOGGER.info("sortedBrandValue" + sortedBrandValue);
1204
        model.addAttribute("sortedBrandValue", sortedBrandValue);
1205
        model.addAttribute("fofoId", fofoId);
1206
        return "activation-tabular";
1207
    }
28455 tejbeer 1208
 
31751 tejbeer 1209
    @RequestMapping(value = "/getMonthlyActivationItemDetail", method = RequestMethod.GET)
32836 amit.gupta 1210
    public String getMonthlyActivationItemDetail(HttpServletRequest request,
1211
                                                 @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1212
                                                 @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,
1213
                                                 @RequestParam(name = "yearMonth", required = false, defaultValue = "0") String yearMonth, Model model) throws
1214
            Exception {
28455 tejbeer 1215
 
31751 tejbeer 1216
        LOGGER.info("params" + fofoId + brand + yearMonth);
29578 tejbeer 1217
 
31751 tejbeer 1218
        List<ActivationItemDetailModel> activationItemDetails = schemeInOutRepository.selectBrandPendingActivationItemDetails(fofoId, brand, yearMonth);
29578 tejbeer 1219
 
35395 amit 1220
        if (!activationItemDetails.isEmpty()) {
1221
            // Batch fetch to avoid N+1 queries
1222
            List<Integer> inventoryItemIds = activationItemDetails.stream()
1223
                    .map(ActivationItemDetailModel::getInventoryItemId)
1224
                    .collect(Collectors.toList());
29578 tejbeer 1225
 
35395 amit 1226
            Map<Integer, List<FofoLineItem>> lineItemsByInventoryId;
1227
            try {
1228
                lineItemsByInventoryId = fofoLineItemRepository
1229
                        .selectByInventoryItemIds(inventoryItemIds).stream()
1230
                        .collect(Collectors.groupingBy(FofoLineItem::getInventoryItemId));
1231
            } catch (ProfitMandiBusinessException e) {
1232
                LOGGER.error("Error fetching FofoLineItems by inventory IDs", e);
1233
                lineItemsByInventoryId = new HashMap<>();
1234
            }
29578 tejbeer 1235
 
35395 amit 1236
            // Get max FofoOrderItemId for each inventory item
1237
            Set<Integer> fofoOrderItemIds = lineItemsByInventoryId.values().stream()
1238
                    .map(list -> list.stream().mapToInt(FofoLineItem::getFofoOrderItemId).max().orElse(-1))
1239
                    .filter(id -> id > 0)
1240
                    .collect(Collectors.toSet());
29578 tejbeer 1241
 
35395 amit 1242
            Map<Integer, FofoOrderItem> fofoOrderItemMap;
1243
            try {
1244
                fofoOrderItemMap = fofoOrderItemRepository
1245
                        .selectByIds(new ArrayList<>(fofoOrderItemIds)).stream()
1246
                        .collect(Collectors.toMap(FofoOrderItem::getId, foi -> foi));
1247
            } catch (ProfitMandiBusinessException e) {
1248
                LOGGER.error("Error fetching FofoOrderItems by IDs", e);
1249
                fofoOrderItemMap = new HashMap<>();
1250
            }
29578 tejbeer 1251
 
35395 amit 1252
            Set<Integer> orderIds = fofoOrderItemMap.values().stream()
1253
                    .map(FofoOrderItem::getOrderId)
1254
                    .collect(Collectors.toSet());
29578 tejbeer 1255
 
35395 amit 1256
            Map<Integer, FofoOrder> fofoOrderMap = new HashMap<>();
1257
            try {
1258
                fofoOrderMap = fofoOrderRepository
1259
                        .selectAllByOrderIds(new ArrayList<>(orderIds)).stream()
1260
                        .collect(Collectors.toMap(FofoOrder::getId, fo -> fo));
1261
            } catch (ProfitMandiBusinessException e) {
1262
                LOGGER.error("Error fetching FofoOrders by order IDs", e);
1263
            }
29578 tejbeer 1264
 
35395 amit 1265
            for (ActivationItemDetailModel activationItemDetail : activationItemDetails) {
1266
                List<FofoLineItem> flis = lineItemsByInventoryId.get(activationItemDetail.getInventoryItemId());
1267
                if (flis != null && !flis.isEmpty()) {
1268
                    int maxFofoOrderItemId = flis.stream().mapToInt(FofoLineItem::getFofoOrderItemId).max().orElse(-1);
1269
                    FofoOrderItem foi = fofoOrderItemMap.get(maxFofoOrderItemId);
1270
                    if (foi != null) {
1271
                        FofoOrder fo = fofoOrderMap.get(foi.getOrderId());
1272
                        if (fo != null) {
1273
                            activationItemDetail.setInvoiceNumber(fo.getInvoiceNumber());
1274
                        }
1275
                    }
1276
                }
1277
            }
31751 tejbeer 1278
        }
1279
        LOGGER.info("activationItemDetails" + activationItemDetails);
29578 tejbeer 1280
 
31751 tejbeer 1281
        model.addAttribute("activationItemDetails", activationItemDetails);
29578 tejbeer 1282
 
31751 tejbeer 1283
        return "activation-pending-item-details";
1284
    }
28455 tejbeer 1285
 
31751 tejbeer 1286
    @RequestMapping(value = "/getMonthlyActivationBeforeSixMonthsItemDetail", method = RequestMethod.GET)
32836 amit.gupta 1287
    public String getMonthlyActivationItemDetail(HttpServletRequest request,
1288
                                                 @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1289
                                                 @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model) throws Exception {
31751 tejbeer 1290
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
29578 tejbeer 1291
 
31751 tejbeer 1292
        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
29578 tejbeer 1293
 
31751 tejbeer 1294
        List<ActivationItemDetailModel> activationItemDetails = schemeInOutRepository.selectBrandPendingActivationItemDetailByYearMonth(fofoId, brand, startOfMonth);
29578 tejbeer 1295
 
35395 amit 1296
        if (!activationItemDetails.isEmpty()) {
1297
            // Batch fetch to avoid N+1 queries
1298
            List<Integer> inventoryItemIds = activationItemDetails.stream()
1299
                    .map(ActivationItemDetailModel::getInventoryItemId)
1300
                    .collect(Collectors.toList());
29578 tejbeer 1301
 
35395 amit 1302
            Map<Integer, List<FofoLineItem>> lineItemsByInventoryId;
1303
            try {
1304
                lineItemsByInventoryId = fofoLineItemRepository
1305
                        .selectByInventoryItemIds(inventoryItemIds).stream()
1306
                        .collect(Collectors.groupingBy(FofoLineItem::getInventoryItemId));
1307
            } catch (ProfitMandiBusinessException e) {
1308
                LOGGER.error("Error fetching FofoLineItems by inventory IDs", e);
1309
                lineItemsByInventoryId = new HashMap<>();
1310
            }
29578 tejbeer 1311
 
35395 amit 1312
            Set<Integer> fofoOrderItemIds = lineItemsByInventoryId.values().stream()
1313
                    .map(list -> list.stream().mapToInt(FofoLineItem::getFofoOrderItemId).max().orElse(-1))
1314
                    .filter(id -> id > 0)
1315
                    .collect(Collectors.toSet());
29578 tejbeer 1316
 
35395 amit 1317
            Map<Integer, FofoOrderItem> fofoOrderItemMap;
1318
            try {
1319
                fofoOrderItemMap = fofoOrderItemRepository
1320
                        .selectByIds(new ArrayList<>(fofoOrderItemIds)).stream()
1321
                        .collect(Collectors.toMap(FofoOrderItem::getId, foi -> foi));
1322
            } catch (ProfitMandiBusinessException e) {
1323
                LOGGER.error("Error fetching FofoOrderItems by IDs", e);
1324
                fofoOrderItemMap = new HashMap<>();
1325
            }
29578 tejbeer 1326
 
35395 amit 1327
            Set<Integer> orderIds = fofoOrderItemMap.values().stream()
1328
                    .map(FofoOrderItem::getOrderId)
1329
                    .collect(Collectors.toSet());
29578 tejbeer 1330
 
35395 amit 1331
            Map<Integer, FofoOrder> fofoOrderMap = new HashMap<>();
1332
            try {
1333
                fofoOrderMap = fofoOrderRepository
1334
                        .selectAllByOrderIds(new ArrayList<>(orderIds)).stream()
1335
                        .collect(Collectors.toMap(FofoOrder::getId, fo -> fo));
1336
            } catch (ProfitMandiBusinessException e) {
1337
                LOGGER.error("Error fetching FofoOrders by order IDs", e);
1338
            }
29578 tejbeer 1339
 
35395 amit 1340
            for (ActivationItemDetailModel activationItemDetail : activationItemDetails) {
1341
                List<FofoLineItem> flis = lineItemsByInventoryId.get(activationItemDetail.getInventoryItemId());
1342
                if (flis != null && !flis.isEmpty()) {
1343
                    int maxFofoOrderItemId = flis.stream().mapToInt(FofoLineItem::getFofoOrderItemId).max().orElse(-1);
1344
                    FofoOrderItem foi = fofoOrderItemMap.get(maxFofoOrderItemId);
1345
                    if (foi != null) {
1346
                        FofoOrder fo = fofoOrderMap.get(foi.getOrderId());
1347
                        if (fo != null) {
1348
                            activationItemDetail.setInvoiceNumber(fo.getInvoiceNumber());
1349
                        }
1350
                    }
1351
                }
1352
            }
31751 tejbeer 1353
        }
1354
        LOGGER.info("activationItemDetails" + activationItemDetails);
29578 tejbeer 1355
 
31751 tejbeer 1356
        model.addAttribute("activationItemDetails", activationItemDetails);
29578 tejbeer 1357
 
31751 tejbeer 1358
        return "activation-pending-item-details";
1359
    }
29578 tejbeer 1360
 
31751 tejbeer 1361
    @RequestMapping(value = "/getMonthlySamsungUpgradeOffer", method = RequestMethod.GET)
1362
    public String getMonthlySamsungUpgradeOffer(HttpServletRequest request, Model model) throws Exception {
1363
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1364
        int fofoId = loginDetails.getFofoId();
29707 tejbeer 1365
 
31751 tejbeer 1366
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
1367
        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
29707 tejbeer 1368
 
31751 tejbeer 1369
        List<YearMonth> yms = new ArrayList<YearMonth>();
29707 tejbeer 1370
 
31751 tejbeer 1371
        for (int i = 0; i <= 5; i++) {
1372
            yms.add(YearMonth.from(curDate.withDayOfMonth(1).minusMonths(i)));
1373
        }
1374
        Collections.reverse(yms);
1375
        model.addAttribute("yms", yms);
1376
        LOGGER.info("ym" + yms);
29707 tejbeer 1377
 
31751 tejbeer 1378
        List<SamsungUpgradeOfferModel> suos = samsungUpgradeOfferRepository.selectUpgradeOfferGroupByYearMonth(fofoId, UpgradeOfferStatus.approved, startOfMonth);
29707 tejbeer 1379
 
31751 tejbeer 1380
        LOGGER.info("suos" + suos);
29707 tejbeer 1381
 
31751 tejbeer 1382
        List<BrandAmountModel> beforeSixMonthOffers = samsungUpgradeOfferRepository.selectUpgradeOfferByYearMonthGroupByBrand(fofoId, UpgradeOfferStatus.approved, startOfMonth);
29707 tejbeer 1383
 
31751 tejbeer 1384
        Map<String, Double> pendingUpgradeOfferBeforeSixMonthMap = beforeSixMonthOffers.stream().collect(Collectors.toMap(x -> x.getBrand(), x -> (double) x.getAmount()));
29707 tejbeer 1385
 
31751 tejbeer 1386
        model.addAttribute("pendingUpgradeOfferBeforeSixMonthMap", pendingUpgradeOfferBeforeSixMonthMap);
29707 tejbeer 1387
 
31751 tejbeer 1388
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-yyyy");
29707 tejbeer 1389
 
31751 tejbeer 1390
        Map<String, Map<YearMonth, Double>> upgradeOfferBrandMonthMap = new HashMap<>();
29707 tejbeer 1391
 
31751 tejbeer 1392
        for (SamsungUpgradeOfferModel suo : suos) {
1393
            Map<YearMonth, Double> brandValue = new HashMap<>();
29707 tejbeer 1394
 
31751 tejbeer 1395
            if (upgradeOfferBrandMonthMap.containsKey(suo.getBrand())) {
1396
                brandValue = upgradeOfferBrandMonthMap.get(suo.getBrand());
1397
                brandValue.put(YearMonth.parse(suo.getYearMonth(), dateTimeFormatter), (double) suo.getAmount());
1398
            } else {
29707 tejbeer 1399
 
31751 tejbeer 1400
                brandValue.put(YearMonth.parse(suo.getYearMonth(), dateTimeFormatter), (double) suo.getAmount());
29707 tejbeer 1401
 
31751 tejbeer 1402
            }
1403
            upgradeOfferBrandMonthMap.put(suo.getBrand(), brandValue);
1404
        }
29707 tejbeer 1405
 
31751 tejbeer 1406
        Map<String, List<Double>> sortedBrandValue = new LinkedHashMap<>();
1407
        String brand = "Samsung";
29707 tejbeer 1408
 
31751 tejbeer 1409
        Map<YearMonth, Double> yearMonthValue = upgradeOfferBrandMonthMap.get(brand);
1410
        for (int i = 5; i >= 0; i--) {
1411
            LocalDateTime startMonth = curDate.withDayOfMonth(1).minusMonths(i);
1412
            if (yearMonthValue != null) {
1413
                if (yearMonthValue.get(YearMonth.from(startMonth)) == null) {
1414
                    yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1415
                }
29707 tejbeer 1416
 
31751 tejbeer 1417
            } else {
1418
                yearMonthValue = new HashMap<>();
1419
                yearMonthValue.put(YearMonth.from(startMonth), 0.0);
1420
            }
1421
        }
1422
        Map<YearMonth, Double> sortedMonthBrandValue = new TreeMap<>(yearMonthValue);
1423
        upgradeOfferBrandMonthMap.put(brand, sortedMonthBrandValue);
1424
        sortedBrandValue.put(brand, sortedMonthBrandValue.values().stream().collect(Collectors.toList()));
1425
        LOGGER.info("sortedBrandValue" + sortedBrandValue);
29707 tejbeer 1426
 
31751 tejbeer 1427
        model.addAttribute("brand", brand);
1428
        model.addAttribute("sortedBrandValue", sortedBrandValue);
1429
        model.addAttribute("fofoId", fofoId);
1430
        return "upgrade-offer-tabular";
29707 tejbeer 1431
 
31751 tejbeer 1432
    }
29707 tejbeer 1433
 
31751 tejbeer 1434
    @RequestMapping(value = "/getMonthlyUpgradeOfferItemDetail", method = RequestMethod.GET)
32836 amit.gupta 1435
    public String getMonthlyUpgradeOfferItemDetail(HttpServletRequest request,
1436
                                                   @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1437
                                                   @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,
1438
                                                   @RequestParam(name = "yearMonth", required = false, defaultValue = "0") String yearMonth, Model model) throws
1439
            Exception {
29707 tejbeer 1440
 
31751 tejbeer 1441
        LOGGER.info("params" + fofoId + brand + yearMonth);
1442
        List<UpgradeOfferItemDetailModel> offerItems = samsungUpgradeOfferRepository.selectUpgradeOfferItemDetails(fofoId, UpgradeOfferStatus.approved, brand, yearMonth);
29707 tejbeer 1443
 
31751 tejbeer 1444
        model.addAttribute("offerItems", offerItems);
29707 tejbeer 1445
 
31751 tejbeer 1446
        return "upgrade-offer-item-detail";
1447
    }
29707 tejbeer 1448
 
31751 tejbeer 1449
    @RequestMapping(value = "/getUpgradeOfferBeforeSixMonthItemDetail", method = RequestMethod.GET)
32836 amit.gupta 1450
    public String getUpgradeOfferBeforeSixMonthItemDetail(HttpServletRequest request,
1451
                                                          @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,
1452
                                                          @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model) throws Exception {
31751 tejbeer 1453
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
29707 tejbeer 1454
 
31751 tejbeer 1455
        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
29707 tejbeer 1456
 
31751 tejbeer 1457
        List<UpgradeOfferItemDetailModel> offerItems = samsungUpgradeOfferRepository.selectUpgradeOfferItemDetailByYearMonth(fofoId, UpgradeOfferStatus.approved, brand, startOfMonth);
29707 tejbeer 1458
 
31751 tejbeer 1459
        model.addAttribute("offerItems", offerItems);
29707 tejbeer 1460
 
31751 tejbeer 1461
        return "upgrade-offer-item-detail";
1462
    }
29707 tejbeer 1463
 
31751 tejbeer 1464
    @RequestMapping(value = "/getAuthUserPartners", method = RequestMethod.GET)
32836 amit.gupta 1465
    public String AuthUserPartnersDetail(HttpServletRequest request, Model model, @RequestParam int authId) throws
1466
            Exception {
26418 tejbeer 1467
 
31751 tejbeer 1468
        Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();
1469
        Map<Integer, CustomRetailer> fofoIdAndPartnerMap = retailerService.getFofoRetailers(false);
26418 tejbeer 1470
 
31751 tejbeer 1471
        Map<Integer, PartnerDetailModel> fofoIdAndallValues = partnerStatsService.getAllPartnerStats();
1472
        if (authId != 0) {
1473
            List<Integer> fofoIds = pp.get(authId);
1474
            fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> fofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
1475
        } else {
1476
        }
26418 tejbeer 1477
 
36268 ranu 1478
        // Build escalation map: fofoId -> escalation label (from open tickets)
1479
        Set<Integer> escalationSubCatIds = new HashSet<>(Arrays.asList(
1480
                ProfitMandiConstants.RBM_L2_ESCALATION,
1481
                ProfitMandiConstants.RBM_L3_ESCALATION,
1482
                ProfitMandiConstants.SALES_ESCALATION));
1483
        Map<Integer, String> escalationMap = new HashMap<>();
1484
        List<Integer> partnerFofoIds = new ArrayList<>(fofoIdAndallValues.keySet());
1485
        if (!partnerFofoIds.isEmpty()) {
1486
            List<Ticket> openTickets = ticketRepository.selectAllOpenTickets(partnerFofoIds);
1487
            for (Ticket t : openTickets) {
1488
                if (t.getCloseTimestamp() == null && escalationSubCatIds.contains(t.getSubCategoryId())) {
1489
                    String label;
1490
                    if (t.getSubCategoryId() == ProfitMandiConstants.RBM_L2_ESCALATION) {
1491
                        label = "RBM L2 Escalation";
1492
                    } else if (t.getSubCategoryId() == ProfitMandiConstants.RBM_L3_ESCALATION) {
1493
                        label = "RBM L3 Escalation";
1494
                    } else {
1495
                        label = "Sales Escalation";
1496
                    }
1497
                    // If partner already has an escalation, keep higher priority (Sales > L3 > L2)
1498
                    String existing = escalationMap.get(t.getFofoId());
1499
                    if (existing == null || label.contains("Sales") || (label.contains("L3") && !existing.contains("Sales"))) {
1500
                        escalationMap.put(t.getFofoId(), label);
1501
                    }
1502
                }
1503
            }
1504
        }
1505
        model.addAttribute("escalationMap", escalationMap);
1506
 
31751 tejbeer 1507
        model.addAttribute("fofoIdAndallValues", fofoIdAndallValues);
1508
        model.addAttribute("fofoIdAndPartnerMap", fofoIdAndPartnerMap);
26418 tejbeer 1509
 
31751 tejbeer 1510
        return "auth_user_partner_detail";
1511
    }
26418 tejbeer 1512
 
31751 tejbeer 1513
    @RequestMapping(value = "/getWarehousePartners", method = RequestMethod.GET)
32836 amit.gupta 1514
    public String warehousePartnersDetail(HttpServletRequest request, Model model, @RequestParam int warehouseId) throws
1515
            Exception {
31751 tejbeer 1516
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1517
        String email = loginDetails.getEmailId();
28472 tejbeer 1518
 
35480 amit 1519
        Set<Integer> authfofoIds = csService1.getAuthFofoIds(email, true);
1520
        if (authfofoIds == null) {
1521
            authfofoIds = new HashSet<>();
1522
        }
31751 tejbeer 1523
        Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository.selectActivePartnersByRetailerIds(new ArrayList<>(authfofoIds)).stream().collect(Collectors.groupingBy(
1524
                FofoStore::getWarehouseId, Collectors.mapping(FofoStore::getId, Collectors.toList())));
27701 tejbeer 1525
 
35099 amit 1526
        if (!warehouseIdFofoIdMap.containsKey(7573)) {
1527
            warehouseIdFofoIdMap.put(7573, new ArrayList<>());
1528
        }
1529
 
31751 tejbeer 1530
        Map<Integer, CustomRetailer> fofoIdAndPartnerMap = retailerService.getFofoRetailers(false);
1531
        Map<Integer, PartnerDetailModel> fofoIdAndallValues = adminUser.getPartnersStatDataFromFile();
35480 amit 1532
        if (fofoIdAndallValues == null) {
1533
            fofoIdAndallValues = new HashMap<>();
1534
        }
31751 tejbeer 1535
        if (warehouseId != 0) {
1536
            List<Integer> fofoIds = warehouseIdFofoIdMap.get(warehouseId);
35480 amit 1537
            if (fofoIds != null) {
1538
                fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> fofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
1539
            }
35854 amit 1540
        } else {
1541
            Set<Integer> finalAuthfofoIds = authfofoIds;
1542
            fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> finalAuthfofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
31751 tejbeer 1543
        }
1544
        ChartInvestmentModel cm = adminUser.getAllStatePartnerType(fofoIdAndallValues);
1545
        model.addAttribute("chartPieMap", gson.toJson(cm));
27545 tejbeer 1546
 
31751 tejbeer 1547
        LOGGER.info("adminUserChart" + gson.toJson(cm));
29164 manish 1548
 
31751 tejbeer 1549
        Map<Integer, MonthlyTarget> monthlyTargetMap = monthlyTargetRepository.selectByDate(YearMonth.now()).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
31211 tejbeer 1550
 
36268 ranu 1551
        // Build escalation map from open tickets
1552
        Set<Integer> escalationSubCatIds2 = new HashSet<>(Arrays.asList(
1553
                ProfitMandiConstants.RBM_L2_ESCALATION,
1554
                ProfitMandiConstants.RBM_L3_ESCALATION,
1555
                ProfitMandiConstants.SALES_ESCALATION));
1556
        Map<Integer, String> escalationMap = new HashMap<>();
1557
        List<Integer> partnerFofoIds2 = new ArrayList<>(fofoIdAndallValues.keySet());
1558
        if (!partnerFofoIds2.isEmpty()) {
1559
            List<Ticket> openTickets = ticketRepository.selectAllOpenTickets(partnerFofoIds2);
1560
            for (Ticket t : openTickets) {
1561
                if (t.getCloseTimestamp() == null && escalationSubCatIds2.contains(t.getSubCategoryId())) {
1562
                    String label;
1563
                    if (t.getSubCategoryId() == ProfitMandiConstants.RBM_L2_ESCALATION) {
1564
                        label = "RBM L2 Escalation";
1565
                    } else if (t.getSubCategoryId() == ProfitMandiConstants.RBM_L3_ESCALATION) {
1566
                        label = "RBM L3 Escalation";
1567
                    } else {
1568
                        label = "Sales Escalation";
1569
                    }
1570
                    String existing = escalationMap.get(t.getFofoId());
1571
                    if (existing == null || label.contains("L3") || (label.contains("Sales") && !existing.contains("L3"))) {
1572
                        escalationMap.put(t.getFofoId(), label);
1573
                    }
1574
                }
1575
            }
1576
        }
1577
        model.addAttribute("escalationMap", escalationMap);
1578
 
31751 tejbeer 1579
        model.addAttribute("fofoIdAndallValues", fofoIdAndallValues);
1580
        model.addAttribute("fofoIdAndPartnerMap", fofoIdAndPartnerMap);
1581
        model.addAttribute("monthlyTargetMap", monthlyTargetMap);
27545 tejbeer 1582
 
31751 tejbeer 1583
        List<PartnerType> partnerTypes = Arrays.asList(PartnerType.values()).stream().filter(x -> !x.equals(PartnerType.ALL)).collect(Collectors.toList());
31211 tejbeer 1584
 
31751 tejbeer 1585
        model.addAttribute("partnerTypes", partnerTypes);
31154 tejbeer 1586
 
31751 tejbeer 1587
        return "auth_user_partner_detail";
1588
    }
27545 tejbeer 1589
 
31662 amit.gupta 1590
 
31751 tejbeer 1591
    @RequestMapping(value = "/getWarehouseWiseBrandStock", method = RequestMethod.GET)
32836 amit.gupta 1592
    public String getWarehouseWiseBrandStock(HttpServletRequest request, Model
1593
            model, @RequestParam List<Integer> warehouseId) throws Exception {
31751 tejbeer 1594
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1595
        String email = loginDetails.getEmailId();
36481 ranu 1596
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
1597
        List<Position> positions = positionRepository.selectAllByAuthUserId(authUser.getId());
35099 amit 1598
 
36481 ranu 1599
        boolean isRbmL3OrAbove = positions.stream().anyMatch(pos ->
1600
                pos.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM
1601
                        && pos.getEscalationType() != null
1602
                        && pos.getEscalationType() != EscalationType.L1
1603
                        && pos.getEscalationType() != EscalationType.L2);
1604
 
1605
        Set<Integer> fofoIds;
1606
        if (isRbmL3OrAbove) {
1607
            fofoIds = fofoStoreRepository.selectActiveStores().stream()
1608
                    .map(x -> x.getId()).collect(Collectors.toSet());
1609
        } else {
1610
            fofoIds = csService1.getAuthFofoIds(email, true);
1611
        }
1612
 
1613
        Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository
1614
                .selectActivePartnersByRetailerIds(new ArrayList<>(fofoIds)).stream()
1615
                .collect(Collectors.groupingBy(FofoStore::getWarehouseId,
1616
                        Collectors.mapping(FofoStore::getId, Collectors.toList())));
1617
 
35099 amit 1618
        if (!warehouseIdFofoIdMap.containsKey(7573)) {
1619
            warehouseIdFofoIdMap.put(7573, new ArrayList<>());
1620
        }
36725 ranu 1621
        if (!warehouseIdFofoIdMap.containsKey(10516)) {
1622
            warehouseIdFofoIdMap.put(10516, new ArrayList<>());
1623
        }
36480 ranu 1624
        if (!warehouseIdFofoIdMap.containsKey(7678)) {
1625
            warehouseIdFofoIdMap.put(7678, new ArrayList<>());
1626
        }
31751 tejbeer 1627
        List<WarehouseWiseBrandStockModel> warehouseWiseBrandStock = new ArrayList<>();
1628
        if (!warehouseId.contains(0)) {
1629
            warehouseWiseBrandStock = saholicInventoryCISRepository.selectGroupByWarehouseAndBrand(warehouseId);
1630
        } else {
1631
            LOGGER.info("warehouseIdFofoIdMap" + warehouseIdFofoIdMap.keySet());
1632
            warehouseWiseBrandStock = saholicInventoryCISRepository.selectGroupByWarehouseAndBrand(new ArrayList<>(warehouseIdFofoIdMap.keySet()));
27701 tejbeer 1633
 
31751 tejbeer 1634
        }
1635
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
1636
        model.addAttribute("warehouseWiseBrandStock", warehouseWiseBrandStock);
1637
        model.addAttribute("warehouseId", warehouseId);
1638
        model.addAttribute("warehouseMap", warehouseMap);
27660 tejbeer 1639
 
31751 tejbeer 1640
        return "warehouse_brand_stock";
1641
    }
27509 tejbeer 1642
 
31751 tejbeer 1643
    @RequestMapping(value = "/getWarehouseWiseData", method = RequestMethod.GET)
1644
    public String getWarehouseWiseData(HttpServletRequest request, Model model) throws Exception {
1645
        inventoryService.getItemAvailabilityAndIndent();
1646
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1647
        return "response";
1648
    }
27529 tejbeer 1649
 
31751 tejbeer 1650
    @RequestMapping(value = "/getWarehouseWiseBrandAndCategory", method = RequestMethod.GET)
32836 amit.gupta 1651
    public String getWarehouseWiseBrandAndCategory(HttpServletRequest request, Model
1652
            model, @RequestParam List<Integer> warehouseId, @RequestParam List<String> brands, @RequestParam String
1653
                                                           category) throws Exception {
27509 tejbeer 1654
 
31751 tejbeer 1655
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
1656
        List<String> listbrands = saholicInventoryCISRepository.selectAllBrand();
1657
        List<String> listCategory = saholicInventoryCISRepository.selectAllSubCategory();
27539 tejbeer 1658
 
31751 tejbeer 1659
        model.addAttribute("warehouseMap", warehouseMap);
1660
        model.addAttribute("brands", listbrands);
1661
        model.addAttribute("listCategory", listCategory);
27538 tejbeer 1662
 
31751 tejbeer 1663
        model.addAttribute("selectedBrand", brands);
1664
        model.addAttribute("selectedWarehouse", warehouseId);
1665
        model.addAttribute("selectedCategory", category);
27539 tejbeer 1666
 
31751 tejbeer 1667
        return "warehouse_brand_item_stock";
1668
    }
27509 tejbeer 1669
 
31751 tejbeer 1670
    @RequestMapping(value = "/getWarehouseWiseItemStock", method = RequestMethod.GET)
32836 amit.gupta 1671
    public String getWarehouseWiseItemStock(HttpServletRequest request, Model
34176 tejus.loha 1672
            model, @RequestParam(name = "warehouseId") List<Integer> warehouseIds, @RequestParam List<String> brands, @RequestParam String
32836 amit.gupta 1673
                                                    category) throws Exception {
31751 tejbeer 1674
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
32836 amit.gupta 1675
        if (warehouseIds.contains(0)) {
1676
            warehouseIds.addAll(warehouseMap.keySet());
31751 tejbeer 1677
        }
32836 amit.gupta 1678
        List<WarehouseWiseitemStockModel> warehouseWiseItemStock = saholicInventoryCISRepository.selectWarehouseItemStock(warehouseIds, brands, category);
27539 tejbeer 1679
 
31751 tejbeer 1680
        model.addAttribute("warehouseWiseItemStock", warehouseWiseItemStock);
1681
        model.addAttribute("warehouseMap", warehouseMap);
1682
        return "warehouse_item_details";
1683
    }
27538 tejbeer 1684
 
31751 tejbeer 1685
    @RequestMapping(value = "/getWarehouseWiseBrandPartnerSale", method = RequestMethod.GET)
32836 amit.gupta 1686
    public String getWarehouseWiseBrandPartnerSale(HttpServletRequest request, Model model, @RequestParam String
1687
            brand) throws Exception {
27701 tejbeer 1688
 
31751 tejbeer 1689
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1690
        String email = loginDetails.getEmailId();
27701 tejbeer 1691
 
31751 tejbeer 1692
        Set<Integer> authfofoIds = csService1.getAuthFofoIds(email, true);
28472 tejbeer 1693
 
31751 tejbeer 1694
        Map<Integer, WarehouseWiseBrandSaleModel> warehouseWiseBrandPartnerSales = fofoStoreRepository.selectGroupByWarehouseBrandWisePartnerSale(brand, new ArrayList<>(authfofoIds)).stream().collect(Collectors.toMap(x -> x.getWarehouseId(), x -> x));
27670 tejbeer 1695
 
31751 tejbeer 1696
        List<WarehouseWiseBrandUnbilledActivatedModel> unbilledStock = fofoStoreRepository.selectUnbilledActivateStockGroupByWarehouse(brand, new ArrayList<>(authfofoIds));
27670 tejbeer 1697
 
31751 tejbeer 1698
        for (WarehouseWiseBrandUnbilledActivatedModel un : unbilledStock) {
1699
            WarehouseWiseBrandSaleModel bpt = warehouseWiseBrandPartnerSales.get(un.getWarehouseId());
1700
            if (bpt != null) {
1701
                bpt.setAmtd(un.getUnbilledMtd());
1702
                bpt.setUamtdQty(un.getUnbilledQty());
1703
            } else {
1704
                bpt = new WarehouseWiseBrandSaleModel();
1705
                bpt.setWarehouseId(un.getWarehouseId());
1706
                bpt.setAmtd(un.getUnbilledMtd());
1707
                bpt.setUamtdQty(un.getUnbilledQty());
1708
                bpt.setLms(0);
1709
                bpt.setLmtd(0);
1710
                bpt.setMtd(0);
1711
                bpt.setMtdQty(0);
1712
                bpt.setLmtd(0);
1713
                bpt.setLmtdQty(0);
1714
                warehouseWiseBrandPartnerSales.put(un.getWarehouseId(), bpt);
1715
            }
1716
        }
1717
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
27591 tejbeer 1718
 
31751 tejbeer 1719
        Set<String> brands = inventoryService.getAllTagListingBrands();
1720
        model.addAttribute("warehouseWiseBrandPartnerSales", warehouseWiseBrandPartnerSales);
1721
        model.addAttribute("warehouseMap", warehouseMap);
1722
        model.addAttribute("brands", brands);
1723
        model.addAttribute("selectedbrand", brand);
1724
        return "warehousewise_brand_partners_sale";
1725
    }
27556 tejbeer 1726
 
31751 tejbeer 1727
    @RequestMapping(value = "/getWarehouseWiseAccesoriesBrandPartnerSale", method = RequestMethod.GET)
32836 amit.gupta 1728
    public String getWarehouseWiseAccesoriesBrandPartnerSale(HttpServletRequest request, Model
1729
            model, @RequestParam String brand) throws Exception {
31751 tejbeer 1730
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1731
        String email = loginDetails.getEmailId();
1732
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
1733
        Set<Integer> authfofoIds = storeGuyMap.get(email);
28472 tejbeer 1734
 
31751 tejbeer 1735
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
1736
        if (authfofoIds == null) {
35395 amit 1737
            List<Position> positions1 = positionRepository.selectAllByAuthUserId(authUser.getId());
31751 tejbeer 1738
            if (positions1.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_MASTER).count() > 0) {
1739
                authfofoIds = csService.getPositionCustomRetailerMap(positions1).values().stream().flatMap(x -> x.stream()).map(x -> x.getPartnerId()).collect(Collectors.toSet());
1740
            }
1741
        }
1742
        List<WarehouseWiseBrandSaleModel> warehouseWiseBrandPartnerSales = fofoStoreRepository.selectGroupByWarehouseAccesoriesBrandWisePartnerSale(brand, new ArrayList<>(authfofoIds));
1743
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
27594 tejbeer 1744
 
31751 tejbeer 1745
        Set<String> brands = inventoryService.getAllTagListingBrands();
1746
        model.addAttribute("warehouseWiseBrandPartnerSales", warehouseWiseBrandPartnerSales);
1747
        model.addAttribute("warehouseMap", warehouseMap);
1748
        model.addAttribute("brands", brands);
1749
        model.addAttribute("selectedbrand", brand);
1750
        return "warehousewise_accessoriesbrand_sale";
1751
    }
27594 tejbeer 1752
 
31751 tejbeer 1753
    @RequestMapping(value = "/getWarehouseBrandWiseItemSale", method = RequestMethod.GET)
32836 amit.gupta 1754
    public String getWarehouseBrandWiseItemSale(HttpServletRequest request, Model
1755
            model, @RequestParam List<Integer> warehouseId, @RequestParam String brand) throws Exception {
31751 tejbeer 1756
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
1757
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1758
        String email = loginDetails.getEmailId();
1759
        Set<Integer> authfofoIds = csService1.getAuthFofoIds(email, true);
1760
        Map<Integer, WarehouseBrandWiseItemSaleModel> branditemSalesMap = fofoStoreRepository.selectWarehouseBrandItemSale(warehouseId, brand, new ArrayList<>(authfofoIds)).stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x));
27670 tejbeer 1761
 
31751 tejbeer 1762
        List<WarehouseBrandItemUnbilledActivatedModel> unbilledItems = fofoStoreRepository.selectWarehouseBrandItemUnbilledActivateStock(warehouseId, brand, new ArrayList<>(authfofoIds));
27670 tejbeer 1763
 
31751 tejbeer 1764
        for (WarehouseBrandItemUnbilledActivatedModel un : unbilledItems) {
1765
            WarehouseBrandWiseItemSaleModel bpt = branditemSalesMap.get(un.getItemId());
1766
            if (bpt != null) {
1767
                bpt.setAmtd(un.getAmtd());
1768
                bpt.setUamtdQty(un.getUnmtdQty());
1769
            } else {
1770
                bpt = new WarehouseBrandWiseItemSaleModel();
1771
                bpt.setWarehouseId(un.getWarehouseId());
1772
                bpt.setItemId(un.getItemId());
1773
                bpt.setAmtd(un.getAmtd());
1774
                bpt.setUamtdQty(un.getUnmtdQty());
1775
                bpt.setBrand(un.getBrand());
1776
                bpt.setModelName(un.getModelName());
1777
                bpt.setModelNumber(un.getModelNumber());
1778
                bpt.setColor(un.getColor());
1779
                bpt.setLms(0);
1780
                bpt.setLmtd(0);
1781
                bpt.setMtd(0);
1782
                bpt.setMtdQty(0);
1783
                bpt.setLmtd(0);
1784
                bpt.setLmtdQty(0);
1785
                branditemSalesMap.put(un.getItemId(), bpt);
1786
            }
1787
        }
1788
        model.addAttribute("branditemSales", branditemSalesMap);
1789
        model.addAttribute("warehouseMap", warehouseMap);
1790
        return "warehouse_partner_itemwise_sale";
1791
    }
27556 tejbeer 1792
 
31751 tejbeer 1793
    @RequestMapping(value = "/getWarehouseAccesoriesBrandWiseItemSale", method = RequestMethod.GET)
32836 amit.gupta 1794
    public String getWarehouseAccesoriesBrandWiseItemSale(HttpServletRequest request, Model
1795
            model, @RequestParam List<Integer> warehouseId, @RequestParam String brand) throws Exception {
31751 tejbeer 1796
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
1797
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1798
        String email = loginDetails.getEmailId();
1799
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
1800
        Set<Integer> authfofoIds = storeGuyMap.get(email);
1801
        List<WarehouseBrandWiseItemSaleModel> branditemSales = fofoStoreRepository.selectWarehouseAccesoriesBrandItemSale(warehouseId, brand, new ArrayList<>(authfofoIds));
1802
        model.addAttribute("branditemSales", branditemSales);
1803
        model.addAttribute("warehouseMap", warehouseMap);
1804
        return "warehouse_accessories_itemwsie_sale";
1805
    }
27594 tejbeer 1806
 
36890 aman 1807
    // Users allowed to add / edit / delete contact-us entries.
1808
    private static final Set<String> CONTACT_US_EDITORS = new HashSet<>(Arrays.asList(
1809
            "kangan.monga@smartdukaan.com",
1810
            "gaurav.mathur1@smartdukaan.com"));
1811
 
1812
    private boolean isContactUsEditor(LoginDetails loginDetails) {
1813
        return loginDetails != null && loginDetails.getEmailId() != null
1814
                && CONTACT_US_EDITORS.contains(loginDetails.getEmailId().trim().toLowerCase());
1815
    }
1816
 
31751 tejbeer 1817
    @RequestMapping(value = "/contactUs", method = RequestMethod.GET)
1818
    public String contactUs(HttpServletRequest request, Model model) throws Throwable {
36890 aman 1819
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
31751 tejbeer 1820
        model.addAttribute("appContextPath", request.getContextPath());
36890 aman 1821
        // Defensive: never let a DB hiccup turn the contact page into a 500.
1822
        // The table is provisioned by ContactUsTableBootstrap, but if a query
1823
        // still fails we render the page with empty lists rather than crashing.
1824
        try {
1825
            model.addAttribute("mainContacts", contactUsRepository.findActiveBySection(ContactUs.SECTION_MAIN));
1826
            model.addAttribute("escalationContacts", contactUsRepository.findActiveBySection(ContactUs.SECTION_ESCALATION));
1827
        } catch (Exception e) {
1828
            LOGGER.error("Failed loading contact_us data; rendering empty contact list", e);
1829
            model.addAttribute("mainContacts", java.util.Collections.emptyList());
1830
            model.addAttribute("escalationContacts", java.util.Collections.emptyList());
1831
        }
1832
        model.addAttribute("contactUsEditor", isContactUsEditor(loginDetails));
31751 tejbeer 1833
        return "contact-us";
1834
    }
23923 amit.gupta 1835
 
36890 aman 1836
    @RequestMapping(value = "/contactUs/save", method = RequestMethod.POST)
1837
    @ResponseBody
1838
    public Map<String, Object> saveContactUs(HttpServletRequest request,
1839
                                             @RequestParam(name = "id", defaultValue = "0") int id,
1840
                                             @RequestParam(name = "section") String section,
1841
                                             @RequestParam(name = "area", defaultValue = "") String area,
1842
                                             @RequestParam(name = "baseArea", defaultValue = "") String baseArea,
1843
                                             @RequestParam(name = "name", defaultValue = "") String name,
1844
                                             @RequestParam(name = "designation", defaultValue = "") String designation,
1845
                                             @RequestParam(name = "mobile", defaultValue = "") String mobile,
37019 aman 1846
                                             @RequestParam(name = "email", defaultValue = "") String email,
1847
                                             @RequestParam(name = "position", defaultValue = "") String position,
1848
                                             @RequestParam(name = "afterId", defaultValue = "0") int afterId) throws Exception {
36890 aman 1849
        Map<String, Object> response = new HashMap<>();
1850
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1851
        if (!isContactUsEditor(loginDetails)) {
1852
            response.put("success", false);
1853
            response.put("message", "You are not authorised to edit contacts.");
1854
            return response;
1855
        }
1856
 
1857
        if (!ContactUs.SECTION_MAIN.equals(section) && !ContactUs.SECTION_ESCALATION.equals(section)) {
1858
            response.put("success", false);
1859
            response.put("message", "Invalid section.");
1860
            return response;
1861
        }
1862
        if (name == null || name.trim().isEmpty()) {
1863
            response.put("success", false);
1864
            response.put("message", "Name is required.");
1865
            return response;
1866
        }
1867
 
1868
        ContactUs contact;
1869
        if (id > 0) {
1870
            contact = contactUsRepository.selectById(id);
1871
            if (contact == null || !contact.isActive()) {
1872
                response.put("success", false);
1873
                response.put("message", "Contact not found.");
1874
                return response;
1875
            }
1876
        } else {
1877
            contact = new ContactUs();
1878
            contact.setSection(section);
1879
            contact.setSortOrder(contactUsRepository.maxSortOrder(section) + 10);
1880
        }
1881
        contact.setArea(area == null ? "" : area.trim());
1882
        contact.setBaseArea(baseArea == null ? "" : baseArea.trim());
1883
        contact.setName(name.trim());
1884
        contact.setDesignation(designation == null ? "" : designation.trim());
1885
        contact.setMobile(mobile == null || mobile.trim().isEmpty() ? "-" : mobile.trim());
1886
        contact.setEmail(email == null ? "" : email.trim());
1887
        contactUsRepository.persist(contact);
1888
 
37019 aman 1889
        // Position control: place the new/edited contact within its section. A NEW contact defaults
1890
        // to the bottom; an EDIT keeps its place unless the editor explicitly chose a new position.
1891
        String pos = (position == null || position.trim().isEmpty())
1892
                ? (id > 0 ? "KEEP" : "BOTTOM")
1893
                : position.trim().toUpperCase();
1894
        if (!"KEEP".equals(pos)) {
1895
            repositionInSection(section, contact.getId(), pos, afterId);
1896
        }
1897
 
36890 aman 1898
        response.put("success", true);
1899
        return response;
1900
    }
1901
 
1902
    @RequestMapping(value = "/contactUs/delete", method = RequestMethod.POST)
1903
    @ResponseBody
1904
    public Map<String, Object> deleteContactUs(HttpServletRequest request,
1905
                                               @RequestParam(name = "id") int id) throws Exception {
1906
        Map<String, Object> response = new HashMap<>();
1907
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1908
        if (!isContactUsEditor(loginDetails)) {
1909
            response.put("success", false);
1910
            response.put("message", "You are not authorised to edit contacts.");
1911
            return response;
1912
        }
1913
        ContactUs contact = contactUsRepository.selectById(id);
1914
        if (contact == null) {
1915
            response.put("success", false);
1916
            response.put("message", "Contact not found.");
1917
            return response;
1918
        }
1919
        contact.setActive(false);
1920
        contactUsRepository.persist(contact);
1921
        response.put("success", true);
1922
        return response;
1923
    }
1924
 
37019 aman 1925
    @RequestMapping(value = "/contactUs/reorder", method = RequestMethod.POST)
1926
    @ResponseBody
1927
    public Map<String, Object> reorderContactUs(HttpServletRequest request,
1928
                                                @RequestParam(name = "id") int id,
1929
                                                @RequestParam(name = "direction") String direction) throws Exception {
1930
        Map<String, Object> response = new HashMap<>();
1931
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1932
        if (!isContactUsEditor(loginDetails)) {
1933
            response.put("success", false);
1934
            response.put("message", "You are not authorised to edit contacts.");
1935
            return response;
1936
        }
1937
        ContactUs contact = contactUsRepository.selectById(id);
1938
        if (contact == null || !contact.isActive()) {
1939
            response.put("success", false);
1940
            response.put("message", "Contact not found.");
1941
            return response;
1942
        }
1943
        boolean up = "UP".equalsIgnoreCase(direction);
1944
        List<ContactUs> list = contactUsRepository.findActiveBySection(contact.getSection());
1945
        int idx = indexOfContact(list, id);
1946
        int target = up ? idx - 1 : idx + 1;
1947
        if (idx < 0 || target < 0 || target >= list.size()) {
1948
            // Already at the top/bottom edge - nothing to move.
1949
            response.put("success", true);
1950
            return response;
1951
        }
1952
        ContactUs tmp = list.get(idx);
1953
        list.set(idx, list.get(target));
1954
        list.set(target, tmp);
1955
        renumberSequential(list);
1956
        response.put("success", true);
1957
        return response;
1958
    }
1959
 
1960
    /**
1961
     * Places {@code contactId} within its section per {@code position} (TOP | BOTTOM | AFTER) and
1962
     * renumbers the whole section's sort_order to a clean 10, 20, 30 … sequence, so ordering is
1963
     * always gap-free and deterministic. {@code afterId} is only consulted for AFTER.
1964
     */
1965
    private void repositionInSection(String section, int contactId, String position, int afterId) {
1966
        List<ContactUs> list = contactUsRepository.findActiveBySection(section);
1967
        int movingIdx = indexOfContact(list, contactId);
1968
        if (movingIdx < 0) {
1969
            return; // not found (should not happen immediately after persist)
1970
        }
1971
        ContactUs moving = list.remove(movingIdx);
1972
        int index;
1973
        if ("TOP".equals(position)) {
1974
            index = 0;
1975
        } else if ("AFTER".equals(position)) {
1976
            int anchorIdx = indexOfContact(list, afterId);
1977
            index = (anchorIdx >= 0) ? anchorIdx + 1 : list.size();
1978
        } else { // BOTTOM
1979
            index = list.size();
1980
        }
1981
        list.add(index, moving);
1982
        renumberSequential(list);
1983
    }
1984
 
1985
    /** Assigns sort_order 10, 20, 30 … in list order, persisting only rows whose order changed. */
1986
    private void renumberSequential(List<ContactUs> orderedContacts) {
1987
        for (int i = 0; i < orderedContacts.size(); i++) {
1988
            ContactUs c = orderedContacts.get(i);
1989
            int newOrder = (i + 1) * 10;
1990
            if (c.getSortOrder() != newOrder) {
1991
                c.setSortOrder(newOrder);
1992
                contactUsRepository.persist(c);
1993
            }
1994
        }
1995
    }
1996
 
1997
    private int indexOfContact(List<ContactUs> list, int id) {
1998
        for (int i = 0; i < list.size(); i++) {
1999
            if (list.get(i).getId() == id) {
2000
                return i;
2001
            }
2002
        }
2003
        return -1;
2004
    }
2005
 
31751 tejbeer 2006
    @RequestMapping(value = "/notifications", method = RequestMethod.GET)
32836 amit.gupta 2007
    public String getNotificationsWithType(HttpServletRequest request, @RequestParam(required = false) MessageType
2008
            messageType, @RequestParam(name = "offset", defaultValue = "0") int offset,
2009
                                           @RequestParam(name = "limit", defaultValue = "20") int limit, Model model) throws Exception {
31751 tejbeer 2010
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2011
        int userId = 0;
2012
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
2013
        if (isAdmin) {
2014
            userId = loginDetails.getFofoId();
2015
        } else {
2016
            userId = userAccountRepository.selectUserIdByRetailerId(loginDetails.getFofoId());
2017
        }
2018
        List<Notification> notifications = null;
25683 tejbeer 2019
 
31751 tejbeer 2020
        List<NotificationCampaign> notificationCampaigns = notificationCampaignRepository.getNotifications(messageType, userId, offset, limit);
35943 amit 2021
        LOGGER.debug("messageType {}", messageType);
34176 tejus.loha 2022
        if (messageType != null) {
2023
            notifications = fofoUser.getNotifications(notificationCampaigns, messageType);
26086 tejbeer 2024
 
34176 tejus.loha 2025
            model.addAttribute("notifications", notifications);
25683 tejbeer 2026
 
35943 amit 2027
            LOGGER.debug("notifications count {}", notifications.size());
34176 tejus.loha 2028
        }
31751 tejbeer 2029
        return "notification-template";
2030
    }
25683 tejbeer 2031
 
31751 tejbeer 2032
    @RequestMapping(value = "/notifyDocument/documentId", method = RequestMethod.GET)
32836 amit.gupta 2033
    public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,
2034
                                                  @RequestParam(name = ProfitMandiConstants.DOCUMENT_ID) int documentId, @RequestParam int cid) throws
2035
            ProfitMandiBusinessException {
31751 tejbeer 2036
        Document document = documentRepository.selectById(documentId);
2037
        NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
2038
        if (nc.getDocumentId() == null) {
2039
            throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
2040
        }
2041
        if (nc.getDocumentId() != documentId) {
2042
            throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, documentId, "RTLR_1014");
2043
        }
2044
        return responseSender.ok(document);
2045
    }
25649 tejbeer 2046
 
32934 amit.gupta 2047
    @Autowired
2048
    PsiSmartService psiSmartService;
34176 tejus.loha 2049
 
32934 amit.gupta 2050
    @RequestMapping(value = "/psi/auth-endpoint", method = RequestMethod.GET)
32935 amit.gupta 2051
    public ResponseEntity<?> getPartnerPSIUrl(HttpServletRequest request) throws Exception {
32934 amit.gupta 2052
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2053
        CustomRetailer customRetailer = retailerService.getAllFofoRetailers().get(loginDetails.getFofoId());
2054
        return responseSender.ok(psiSmartService.getRegistrationEndPoint(customRetailer.getMobileNumber()));
2055
    }
2056
 
31751 tejbeer 2057
    @RequestMapping(value = "/notifyDocument/download", method = RequestMethod.GET)
32836 amit.gupta 2058
    public ResponseEntity<?> downloadRetailerDocument(HttpServletRequest request, @RequestParam int cid, Model model) throws
2059
            ProfitMandiBusinessException {
25651 tejbeer 2060
 
31751 tejbeer 2061
        NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
25651 tejbeer 2062
 
31751 tejbeer 2063
        if (nc.getDocumentId() == null) {
2064
            throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
2065
        }
25651 tejbeer 2066
 
31751 tejbeer 2067
        Document document = documentRepository.selectById(nc.getDocumentId());
25651 tejbeer 2068
 
31751 tejbeer 2069
        FileInputStream file = null;
2070
        try {
2071
            file = new FileInputStream(document.getPath() + File.separator + document.getName());
2072
        } catch (FileNotFoundException e) {
2073
            LOGGER.error("Retailer Document file not found : ", e);
2074
            throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
2075
        }
32308 amit.gupta 2076
// ByteArrayOutputStream byteArrayOutputStream = new
2077
// ByteArrayOutputStream();
2078
// ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
25651 tejbeer 2079
 
31751 tejbeer 2080
        final HttpHeaders headers = new HttpHeaders();
2081
        String contentType = "";
2082
        if (document.getContentType() == ContentType.JPEG) {
2083
            contentType = "image/jpeg";
2084
        } else if (document.getContentType() == ContentType.PNG) {
2085
            contentType = "image/png";
2086
        } else if (document.getContentType() == ContentType.PDF) {
2087
            contentType = "application/pdf";
2088
        }
2089
        headers.set("Content-Type", contentType);
2090
        headers.set("Content-disposition", "inline; filename=" + document.getName());
2091
        headers.setContentLength(document.getSize());
2092
        final InputStreamResource inputStreamResource = new InputStreamResource(file);
2093
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
2094
    }
26460 amit.gupta 2095
 
31751 tejbeer 2096
    @RequestMapping(value = "/getItemWiseTertiary", method = RequestMethod.GET)
32836 amit.gupta 2097
    public String getItemWiseTertiary(HttpServletRequest request,
2098
                                      @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws ProfitMandiBusinessException {
31751 tejbeer 2099
        List<ItemWiseTertiaryModel> itemWiseTertiary = fofoOrderRepository.SelectItemWiseTertiary(fofoId);
27579 tejbeer 2100
 
31751 tejbeer 2101
        LOGGER.info("itemWiseTertiary" + itemWiseTertiary);
2102
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2103
        model.addAttribute("customRetailer", customRetailer);
2104
        model.addAttribute("itemWiseTertiary", itemWiseTertiary);
2105
        return "item-wise-tertiary";
2106
    }
27579 tejbeer 2107
 
31751 tejbeer 2108
    @RequestMapping(value = "/getItemWiseIndent", method = RequestMethod.GET)
32836 amit.gupta 2109
    public String getItemWiseIndent(HttpServletRequest request,
2110
                                    @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws ProfitMandiBusinessException {
27586 tejbeer 2111
 
31751 tejbeer 2112
        List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoId);
2113
        model.addAttribute("unbilledOrders", unbilledOrders);
27586 tejbeer 2114
 
31751 tejbeer 2115
        return "item-wise-indent";
2116
    }
27586 tejbeer 2117
 
31751 tejbeer 2118
    @RequestMapping(value = "/getPartnerInvestment", method = RequestMethod.GET)
32836 amit.gupta 2119
    public String getPartnerInvestment(HttpServletRequest request,
2120
                                       @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2121
        Map<Integer, PartnerDetailModel> partnerStats = adminUser.getPartnersStatDataFromFile();
2122
        PartnerDetailModel partnerDetailModel = partnerStats.get(fofoId);
2123
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2124
        model.addAttribute("partnerDetailModel", partnerDetailModel);
2125
        model.addAttribute("customRetailer", customRetailer);
2126
        return "partner-investment";
2127
    }
27727 tejbeer 2128
 
31751 tejbeer 2129
    @RequestMapping(value = "/getPartnerPendingIndentItem", method = RequestMethod.GET)
32836 amit.gupta 2130
    public String getPartnerPendingIndentItem(HttpServletRequest request, @RequestParam int warehouseId,
2131
                                              @RequestParam int itemId, Model model) throws ProfitMandiBusinessException {
31751 tejbeer 2132
        List<PartnerPendingIndentItemModel> partnerPendingIndent = fofoStoreRepository.selectPartnerPendingIndentItem(itemId, warehouseId);
27636 tejbeer 2133
 
31751 tejbeer 2134
        model.addAttribute("partnerPendingIndent", partnerPendingIndent);
2135
        return "partner-pending-indent-item";
2136
    }
27704 amit.gupta 2137
 
31751 tejbeer 2138
    @RequestMapping(value = "/getPatnerActivateStock", method = RequestMethod.GET)
32836 amit.gupta 2139
    public String getPartnerActivateStockItem(HttpServletRequest request,
2140
                                              @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2141
        List<ActivateItemModel> activateStocks = new ArrayList<>();
2142
        List<InventoryItem> inventoryItems = inventoryItemRepository.selectByActivatedNotSold(fofoId);
2143
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
27636 tejbeer 2144
 
31751 tejbeer 2145
        for (InventoryItem inventoryItem : inventoryItems) {
2146
            TagListing tagListing = tagListingRepository.selectByItemId(inventoryItem.getItemId());
2147
            Item item = itemRepository.selectById(inventoryItem.getItemId());
2148
            ActivateItemModel aim = new ActivateItemModel();
2149
            aim.setFofoId(inventoryItem.getFofoId());
2150
            aim.setQuantity(inventoryItem.getGoodQuantity());
2151
            aim.setAmount(tagListing.getSellingPrice());
2152
            aim.setItemDescription(item.getItemDescription());
2153
            aim.setItemId(inventoryItem.getItemId());
2154
            activateStocks.add(aim);
2155
        }
27636 tejbeer 2156
 
31751 tejbeer 2157
        model.addAttribute("activateStocks", activateStocks);
2158
        model.addAttribute("customRetailer", customRetailer);
2159
        return "partner-activate-stock";
2160
    }
27636 tejbeer 2161
 
31751 tejbeer 2162
    @RequestMapping(value = "/getPatnerBrandWiseMTDSale", method = RequestMethod.GET)
32836 amit.gupta 2163
    public String getPatnerBrandWiseMTDSale(HttpServletRequest request,
2164
                                            @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2165
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
2166
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2167
        Map<String, Double> brandMtdAmount = fofoOrderItemRepository.selectSumAmountGroupByBrand(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId);
2168
        Map<String, Long> brandMtdQty = fofoOrderItemRepository.selectSumQuantityGroupByBrand(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId);
2169
        Double accesoriesmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false)).get(fofoId);
2170
        Long accesoriesmtdqty = fofoOrderRepository.selectSumSaleQuantityGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false)).get(fofoId);
27638 tejbeer 2171
 
31751 tejbeer 2172
        LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);
2173
        model.addAttribute("brandMtdAmount", brandMtdAmount);
2174
        model.addAttribute("brandMtdQty", brandMtdQty);
2175
        model.addAttribute("accesoriesmtdsale", accesoriesmtdsale);
2176
        model.addAttribute("accesoriesmtdqty", accesoriesmtdqty);
27638 tejbeer 2177
 
31751 tejbeer 2178
        model.addAttribute("customRetailer", customRetailer);
2179
        return "partner-brand-mtd-sale";
2180
    }
27636 tejbeer 2181
 
31751 tejbeer 2182
    @RequestMapping(value = "/getPatnerBrandWiseLMTDSale", method = RequestMethod.GET)
32836 amit.gupta 2183
    public String getPatnerBrandWiseLMTDSale(HttpServletRequest request,
2184
                                             @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2185
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
2186
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2187
        Map<String, Double> brandLMtdAmount = fofoOrderItemRepository.selectSumAmountGroupByBrand(
2188
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), fofoId);
2189
        Map<String, Long> brandLmtdQty = fofoOrderItemRepository.selectSumQuantityGroupByBrand(
2190
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), fofoId);
27637 tejbeer 2191
 
31751 tejbeer 2192
        Double accesorieslmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), Optional.of(false)).get(fofoId);
2193
        Long accesorieslmtdqty = fofoOrderRepository.selectSumSaleQuantityGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), Optional.of(false)).get(fofoId);
27638 tejbeer 2194
 
31751 tejbeer 2195
        model.addAttribute("brandLMtdAmount", brandLMtdAmount);
2196
        model.addAttribute("brandLmtdQty", brandLmtdQty);
2197
        model.addAttribute("accesorieslmtdqty", accesorieslmtdqty);
2198
        model.addAttribute("accesorieslmtdsale", accesorieslmtdsale);
2199
        model.addAttribute("customRetailer", customRetailer);
2200
        return "partner-brand-lmtd-sale";
2201
    }
27637 tejbeer 2202
 
31751 tejbeer 2203
    @RequestMapping(value = "/getPatnerBrandWiseLMSSale", method = RequestMethod.GET)
32836 amit.gupta 2204
    public String getPatnerBrandWiseLMSSale(HttpServletRequest request,
2205
                                            @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2206
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
2207
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2208
        int lengthOfMonth = YearMonth.from(curDate.minusMonths(1)).lengthOfMonth();
27660 tejbeer 2209
 
31751 tejbeer 2210
        Map<String, Double> brandLMSAmount = fofoOrderItemRepository.selectSumAmountGroupByBrand(
2211
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), fofoId);
2212
        Map<String, Long> brandLmsQty = fofoOrderItemRepository.selectSumQuantityGroupByBrand(
2213
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), fofoId);
27660 tejbeer 2214
 
31751 tejbeer 2215
        Double accesorieslmssale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), Optional.of(false)).get(fofoId);
2216
        Long accesorieslmsqty = fofoOrderRepository.selectSumSaleQuantityGroupByFofoIdsForMobileOrAccessories(fofoId, curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), Optional.of(false)).get(fofoId);
27660 tejbeer 2217
 
31751 tejbeer 2218
        model.addAttribute("brandLMSAmount", brandLMSAmount);
2219
        model.addAttribute("brandLmsQty", brandLmsQty);
2220
        model.addAttribute("accesorieslmssale", accesorieslmssale);
2221
        model.addAttribute("accesorieslmsqty", accesorieslmsqty);
2222
        model.addAttribute("customRetailer", customRetailer);
2223
        return "partner-brand-lms-sale";
2224
    }
27660 tejbeer 2225
 
31751 tejbeer 2226
    @RequestMapping(value = "/getPatnerInStock", method = RequestMethod.GET)
32836 amit.gupta 2227
    public String getPatnerInStock(HttpServletRequest request,
2228
                                   @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
27640 tejbeer 2229
 
31751 tejbeer 2230
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
27640 tejbeer 2231
 
31751 tejbeer 2232
        List<InStockBrandModel> mobileStocks = currentInventorySnapshotRepository.selectSumInStockMobileGroupByBrand(fofoId);
2233
        List<InStockBrandModel> accesStock = currentInventorySnapshotRepository.selectSumInStockAccessoriesGroupByBrand(fofoId);
27640 tejbeer 2234
 
31751 tejbeer 2235
        List<InStockBrandItemModel> stockItemlist = currentInventorySnapshotRepository.selectInStockItemsByBrand(fofoId);
27660 tejbeer 2236
 
31751 tejbeer 2237
        Map<String, List<InStockBrandItemModel>> stockItemMap = stockItemlist.stream().collect(Collectors.groupingBy(InStockBrandItemModel::getBrand));
27660 tejbeer 2238
 
31751 tejbeer 2239
        model.addAttribute("stockItemMap", stockItemMap);
2240
        model.addAttribute("mobileStock", mobileStocks);
2241
        model.addAttribute("accesStock", accesStock);
2242
        model.addAttribute("customRetailer", customRetailer);
2243
        return "partner-instock-item";
2244
    }
27640 tejbeer 2245
 
31751 tejbeer 2246
    @RequestMapping(value = "/getOpenTicketByFofoId", method = RequestMethod.GET)
32836 amit.gupta 2247
    public String getOpenTicketByFofoId(HttpServletRequest request,
2248
                                        @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
31751 tejbeer 2249
        Map<Integer, AuthUser> ticketIdAuthUser = new HashMap<>();
2250
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2251
        List<Integer> ticketIds = ticketRepository.selectAllOpenTicketByRetailer(fofoId).stream().map(x -> x.getId()).collect(Collectors.toList());
2252
        List<TicketAssigned> ticketAssigns = ticketAssignedRepository.selectByTicketIds(ticketIds);
27660 tejbeer 2253
 
35395 amit 2254
        if (!ticketAssigns.isEmpty()) {
2255
            // Batch fetch AuthUsers to avoid N+1 queries
2256
            Set<Integer> assigneeIds = ticketAssigns.stream()
2257
                    .map(TicketAssigned::getAssineeId)
2258
                    .collect(Collectors.toSet());
2259
 
2260
            Map<Integer, AuthUser> authUserMap = authRepository.selectByIds(new ArrayList<>(assigneeIds)).stream()
2261
                    .collect(Collectors.toMap(AuthUser::getId, au -> au));
2262
 
2263
            for (TicketAssigned ticketAssign : ticketAssigns) {
2264
                AuthUser authUser = authUserMap.get(ticketAssign.getAssineeId());
2265
                if (authUser != null) {
2266
                    ticketIdAuthUser.put(ticketAssign.getTicketId(), authUser);
2267
                }
2268
            }
31751 tejbeer 2269
        }
2270
        model.addAttribute("ticketIdAuthUser", ticketIdAuthUser);
2271
        model.addAttribute("ticketAssigns", ticketAssigns);
2272
        model.addAttribute("customRetailer", customRetailer);
2273
        return "open-ticket";
2274
    }
27660 tejbeer 2275
 
31751 tejbeer 2276
    @RequestMapping(value = "/getPartnerSecondarySale", method = RequestMethod.GET)
32836 amit.gupta 2277
    public String getPartnerSecondarySale(HttpServletRequest request,
2278
                                          @RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, @RequestParam String timeValue, Model model) throws
2279
            Exception {
31751 tejbeer 2280
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
2281
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
2282
        int lengthOfMonth = YearMonth.from(curDate.minusMonths(1)).lengthOfMonth();
2283
        LocalDateTime startDate = null;
2284
        LocalDateTime endDate = null;
2285
        List<InStockBrandModel> secondarySale = null;
2286
        Map<String, List<InStockBrandItemModel>> secondaryItemSale = null;
27893 tejbeer 2287
 
31751 tejbeer 2288
        if (timeValue.equals("mtd")) {
2289
            startDate = curDate.withDayOfMonth(1);
2290
            endDate = curDate.with(LocalTime.MAX);
2291
            secondarySale = orderRepository.selectAllBilledOrderBrandByFofoId(startDate, endDate, fofoId);
2292
            secondaryItemSale = orderRepository.selectAllBilledOrderBrandItemByFofoId(startDate, endDate, fofoId).stream().collect(Collectors.groupingBy(InStockBrandItemModel::getBrand));
2293
            LOGGER.info("secondarySalemtd" + secondarySale);
2294
        } else if (timeValue.equals("lmtd")) {
2295
            startDate = curDate.withDayOfMonth(1).minusMonths(1);
2296
            endDate = curDate.with(LocalTime.MAX).minusMonths(1);
2297
            secondaryItemSale = orderRepository.selectAllBilledOrderBrandItemByFofoId(startDate, endDate, fofoId).stream().collect(Collectors.groupingBy(InStockBrandItemModel::getBrand));
27893 tejbeer 2298
 
31751 tejbeer 2299
            secondarySale = orderRepository.selectAllBilledOrderBrandByFofoId(startDate, endDate, fofoId);
2300
            LOGGER.info("secondarySalelmtd" + secondarySale);
27893 tejbeer 2301
 
31751 tejbeer 2302
        } else {
2303
            startDate = curDate.withDayOfMonth(1).minusMonths(1);
2304
            endDate = curDate.withDayOfMonth(1);
2305
            secondaryItemSale = orderRepository.selectAllBilledOrderBrandItemByFofoId(startDate, endDate, fofoId).stream().collect(Collectors.groupingBy(InStockBrandItemModel::getBrand));
27893 tejbeer 2306
 
31751 tejbeer 2307
            secondarySale = orderRepository.selectAllBilledOrderBrandByFofoId(startDate, endDate, fofoId);
2308
            LOGGER.info("secondarySalelms" + secondarySale);
27893 tejbeer 2309
 
31751 tejbeer 2310
        }
27893 tejbeer 2311
 
31751 tejbeer 2312
        LOGGER.info("secondarySale" + secondarySale);
2313
        model.addAttribute("secondarySale", secondarySale);
2314
        model.addAttribute("secondaryItemSale", secondaryItemSale);
2315
        model.addAttribute("customRetailer", customRetailer);
27893 tejbeer 2316
 
31751 tejbeer 2317
        return "partner-secondary-order";
2318
    }
27893 tejbeer 2319
 
31751 tejbeer 2320
    @RequestMapping(value = "/getMobileBrandWise", method = RequestMethod.GET)
2321
    public String getMobileBrandWise(HttpServletRequest request, Model model) throws Exception {
2322
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2323
        String email = loginDetails.getEmailId();
28451 tejbeer 2324
 
31751 tejbeer 2325
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
2326
        Set<Integer> fofoIds = csService1.getAuthFofoIds(email, true);
28451 tejbeer 2327
 
31751 tejbeer 2328
        Map<String, BrandWisePartnerSaleModel> partnersBrandSaleMap = null;
2329
        partnersBrandSaleMap = fofoStoreRepository.selectGroupByBrandWarehousePartnerSale(new ArrayList<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getBrand(), x -> x));
28451 tejbeer 2330
 
31751 tejbeer 2331
        List<BrandWiseUnbilledActivateStockModel> unbilledActivatedStock = fofoStoreRepository.selectUnbilledActivateStockGroupByBrand(new ArrayList<>(fofoIds));
2332
        for (BrandWiseUnbilledActivateStockModel un : unbilledActivatedStock) {
2333
            BrandWisePartnerSaleModel bpt = partnersBrandSaleMap.get(un.getBrand());
2334
            if (bpt != null) {
2335
                bpt.setAmtd(un.getUnbilledMtd());
2336
                bpt.setUamtdQty(un.getUnbilledMTDQty());
2337
            } else {
2338
                bpt = new BrandWisePartnerSaleModel();
2339
                bpt.setBrand(un.getBrand());
2340
                bpt.setAmtd(un.getUnbilledMtd());
2341
                bpt.setUamtdQty(un.getUnbilledMTDQty());
2342
                bpt.setLms(0);
2343
                bpt.setLmtd(0);
2344
                bpt.setMtd(0);
2345
                bpt.setMtdQty(0);
2346
                bpt.setLmtd(0);
2347
                bpt.setLmtdQty(0);
2348
                partnersBrandSaleMap.put(un.getBrand(), bpt);
2349
            }
2350
        }
28451 tejbeer 2351
 
31751 tejbeer 2352
        model.addAttribute("brandSalesMap", partnersBrandSaleMap);
28451 tejbeer 2353
 
31751 tejbeer 2354
        return "mobile-brand-wise-report";
2355
    }
28451 tejbeer 2356
 
31751 tejbeer 2357
    @RequestMapping(value = "/getAccessoriesBrandWise", method = RequestMethod.GET)
2358
    public String getAccessoriesBrandWise(HttpServletRequest request, Model model) throws Exception {
2359
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2360
        String email = loginDetails.getEmailId();
28451 tejbeer 2361
 
31751 tejbeer 2362
        Set<Integer> fofoIds = csService1.getAuthFofoIds(email, true);
28451 tejbeer 2363
 
31751 tejbeer 2364
        List<BrandWisePartnerSaleModel> accessoriesBrandSales = null;
28451 tejbeer 2365
 
31751 tejbeer 2366
        accessoriesBrandSales = fofoStoreRepository.selectGroupByBrandAccesoriesWarehousePartnerSale(new ArrayList<>(fofoIds));
28451 tejbeer 2367
 
31751 tejbeer 2368
        model.addAttribute("accessoriesBrandSales", accessoriesBrandSales);
2369
        return "accessories-brand-wise-report";
2370
    }
28451 tejbeer 2371
 
34973 aman 2372
    @PostMapping("/getMobileLMSGraph")
2373
    public String getMobileLMSGraph(@RequestBody LMSGraphRequest lmsGraphRequest, Model model) throws Exception {
2374
        LocalDate startDate = lmsGraphRequest.getDate().toLocalDate();
2375
        LocalDate endLocalDate = lmsGraphRequest.getEndDate().toLocalDate();
28451 tejbeer 2376
 
34973 aman 2377
        Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository.selectActivePartnersByRetailerIds(lmsGraphRequest.getFofoIds())
2378
                .stream()
2379
                .collect(Collectors.groupingBy(FofoStore::getWarehouseId,
2380
                        Collectors.mapping(FofoStore::getId, Collectors.toList())));
2381
 
31751 tejbeer 2382
        ChartModel cm;
34973 aman 2383
        if (lmsGraphRequest.getWarehouseId() != 0) {
2384
            cm = adminUser.getBrandWiseLms(
2385
                    Arrays.asList(lmsGraphRequest.getWarehouseId()),
2386
                    lmsGraphRequest.getFofoIds(),
2387
                    startDate,
2388
                    endLocalDate,
2389
                    lmsGraphRequest.getFilterType()
2390
            );
31751 tejbeer 2391
        } else {
34973 aman 2392
            cm = adminUser.getBrandWiseLms(
2393
                    new ArrayList<>(warehouseIdFofoIdMap.keySet()),
2394
                    lmsGraphRequest.getFofoIds(),
2395
                    startDate,
2396
                    endLocalDate,
2397
                    lmsGraphRequest.getFilterType()
2398
            );
31751 tejbeer 2399
        }
28451 tejbeer 2400
 
34973 aman 2401
        LOGGER.info("chartMap: " + gson.toJson(cm));
31751 tejbeer 2402
        model.addAttribute("chartMap", gson.toJson(cm));
34973 aman 2403
 
31751 tejbeer 2404
        return "brand-wise-mobile-lms-chart";
2405
    }
28451 tejbeer 2406
 
34973 aman 2407
 
31751 tejbeer 2408
    @RequestMapping(value = "/getMobileLMSFilter", method = RequestMethod.GET)
32836 amit.gupta 2409
    public String getMobileLMSFilter(HttpServletRequest request,
2410
                                     @RequestParam(required = false, defaultValue = "0") int warehouseId,
2411
                                     @RequestParam(required = false) LocalDateTime date, @RequestParam(required = false) LocalDateTime endDate, Model
2412
                                             model) throws Exception {
28461 tejbeer 2413
 
31751 tejbeer 2414
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2415
        String email = loginDetails.getEmailId();
28461 tejbeer 2416
 
31751 tejbeer 2417
        if (date == null) {
2418
            LocalDateTime curDate = LocalDate.now().atStartOfDay();
28461 tejbeer 2419
 
31751 tejbeer 2420
            LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);
2421
            date = startOfMonth.toLocalDate().atStartOfDay();
2422
        }
28461 tejbeer 2423
 
31751 tejbeer 2424
        if (endDate == null) {
2425
            LocalDateTime curDate = LocalDate.now().atTime(LocalTime.MAX);
30279 tejbeer 2426
 
31751 tejbeer 2427
            endDate = curDate;
30279 tejbeer 2428
 
31751 tejbeer 2429
        }
30279 tejbeer 2430
 
31751 tejbeer 2431
        Map<String, Object> map = adminUser.getFilter(warehouseId, email, date, endDate);
2432
        model.addAttribute("warehouseId", warehouseId);
2433
        model.addAllAttributes(map);
28461 tejbeer 2434
 
31751 tejbeer 2435
        return "chart-filter-lms";
2436
    }
28461 tejbeer 2437
 
35514 amit 2438
    @PostMapping("/getMobileLMPGraph")
2439
    public String getMobileLMPGraph(@RequestBody LMSGraphRequest lmpGraphRequest, Model model) throws Exception {
2440
        LocalDate startDate = lmpGraphRequest.getDate().toLocalDate();
2441
        LocalDate endLocalDate = lmpGraphRequest.getEndDate().toLocalDate();
28461 tejbeer 2442
 
35514 amit 2443
        Map<Integer, List<Integer>> warehouseIdFofoIdMap = fofoStoreRepository.selectActivePartnersByRetailerIds(lmpGraphRequest.getFofoIds())
2444
                .stream()
2445
                .collect(Collectors.groupingBy(FofoStore::getWarehouseId,
2446
                        Collectors.mapping(FofoStore::getId, Collectors.toList())));
2447
 
31751 tejbeer 2448
        ChartModel cm;
35514 amit 2449
        if (lmpGraphRequest.getWarehouseId() != 0) {
2450
            cm = adminUser.getBrandWiseLmp(
2451
                    Arrays.asList(lmpGraphRequest.getWarehouseId()),
2452
                    lmpGraphRequest.getFofoIds(),
2453
                    startDate,
2454
                    endLocalDate,
2455
                    lmpGraphRequest.getFilterType()
2456
            );
31751 tejbeer 2457
        } else {
35514 amit 2458
            cm = adminUser.getBrandWiseLmp(
2459
                    new ArrayList<>(warehouseIdFofoIdMap.keySet()),
2460
                    lmpGraphRequest.getFofoIds(),
2461
                    startDate,
2462
                    endLocalDate,
2463
                    lmpGraphRequest.getFilterType()
2464
            );
31751 tejbeer 2465
        }
28461 tejbeer 2466
 
35514 amit 2467
        LOGGER.info("chartMap: " + gson.toJson(cm));
31751 tejbeer 2468
        model.addAttribute("chartMap", gson.toJson(cm));
2469
        return "brand-wise-mobile-lmp-chart";
2470
    }
28461 tejbeer 2471
 
31751 tejbeer 2472
    @RequestMapping(value = "/getSaleCountByMilestone", method = RequestMethod.GET)
32836 amit.gupta 2473
    public String getSaleCountByMilestone(HttpServletRequest request,
2474
                                          @RequestParam(required = false, defaultValue = "0") int warehouseId, Model model) throws Exception {
31259 tejbeer 2475
 
31751 tejbeer 2476
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2477
        String email = loginDetails.getEmailId();
2478
        Set<Integer> authFofoIds = csService1.getAuthFofoIds(email, true);
31259 tejbeer 2479
 
31751 tejbeer 2480
        Set<Integer> fofoIdlist = fofoStoreRepository.selectActiveStores().stream().filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toSet());
32792 shampa 2481
        Set<Integer> fofoIds = null;
34176 tejus.loha 2482
        if (authFofoIds != null) {
32792 shampa 2483
            fofoIds = authFofoIds.stream().filter(x -> fofoIdlist.contains(x)).collect(Collectors.toSet());
2484
        }
31267 tejbeer 2485
 
32792 shampa 2486
 
31751 tejbeer 2487
        Map<Integer, Double> last3MonthSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
2488
                LocalDateTime.now().withDayOfMonth(1).minusMonths(2), LocalDateTime.now(), 0, false);
31318 tejbeer 2489
 
31751 tejbeer 2490
        if (fofoIds != null && fofoIds.size() > 0) {
2491
            if (warehouseId != 0) {
2492
                fofoIds = fofoStoreRepository.selectPartnerByfofoIdAndWarehouse(new ArrayList<>(fofoIds), warehouseId).stream().map(x -> x).collect(Collectors.toSet());
2493
            }
2494
            Map<Integer, PartnerDetailModel> partnerStats = adminUser.getPartnersStatDataFromFile();
2495
            if (partnerStats != null) {
2496
                List<PartnerDetailModel> partnerDetails = fofoIds.stream().filter(x -> partnerStats.containsKey(x)).map(x -> partnerStats.get(x)).collect(Collectors.toList());
2497
                Map<Milestone, List<Integer>> avg3Monthlms = new HashMap<>();
2498
                if (!last3MonthSale.isEmpty()) {
2499
                    int days = 60 + LocalDateTime.now().getDayOfMonth();
2500
                    for (Entry<Integer, Double> last3MonthEntry : last3MonthSale.entrySet()) {
2501
                        if (fofoIds.contains(last3MonthEntry.getKey())) {
2502
                            Double monthSale = last3MonthEntry.getValue();
2503
                            if (monthSale == null) {
2504
                                monthSale = (double) 0;
31319 tejbeer 2505
 
31751 tejbeer 2506
                            }
2507
                            double avg3MonthSale = (monthSale / days) * 30;
2508
                            Milestone milestone = Milestone.get((int) avg3MonthSale);
31318 tejbeer 2509
 
31751 tejbeer 2510
                            List<Integer> values = null;
31318 tejbeer 2511
 
31751 tejbeer 2512
                            if (avg3Monthlms.containsKey(milestone)) {
31319 tejbeer 2513
 
31751 tejbeer 2514
                                values = avg3Monthlms.get(milestone);
2515
                                values.add(last3MonthEntry.getKey());
2516
                                avg3Monthlms.put(milestone, values);
31267 tejbeer 2517
 
31751 tejbeer 2518
                            } else {
2519
                                values = new ArrayList<>();
31267 tejbeer 2520
 
31751 tejbeer 2521
                                values.add(last3MonthEntry.getKey());
2522
                                avg3Monthlms.put(milestone, values);
31267 tejbeer 2523
 
31751 tejbeer 2524
                            }
2525
                        }
31267 tejbeer 2526
 
31751 tejbeer 2527
                    }
31263 tejbeer 2528
 
31751 tejbeer 2529
                }
31285 tejbeer 2530
 
31751 tejbeer 2531
                if (partnerDetails != null) {
31318 tejbeer 2532
 
31751 tejbeer 2533
                    Map<Milestone, List<Integer>> mtdMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getMtd()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
2534
                    Map<Milestone, List<Integer>> lmtdMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getLmtd()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
31260 tejbeer 2535
 
31751 tejbeer 2536
                    Map<Milestone, List<Integer>> lmsMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getLms()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
31259 tejbeer 2537
 
31751 tejbeer 2538
                    model.addAttribute("mtdMap", mtdMap);
2539
                    model.addAttribute("lmtdMap", lmtdMap);
2540
                    model.addAttribute("avg3Monthlms", avg3Monthlms);
2541
                    model.addAttribute("lmsMap", lmsMap);
2542
                }
31267 tejbeer 2543
 
31751 tejbeer 2544
            }
2545
        }
31273 tejbeer 2546
 
31751 tejbeer 2547
        model.addAttribute("warehouseMap", ProfitMandiConstants.WAREHOUSE_MAP);
2548
        model.addAttribute("warehouseId", warehouseId);
2549
        model.addAttribute("milestones", Milestone.values());
31273 tejbeer 2550
 
31751 tejbeer 2551
        return "sale-milestone";
31273 tejbeer 2552
 
31751 tejbeer 2553
    }
31273 tejbeer 2554
 
31751 tejbeer 2555
    @RequestMapping(value = "/getPurchaseCountByMileStone", method = RequestMethod.GET)
32836 amit.gupta 2556
    public String getPurchaseCountByMileStone(HttpServletRequest request,
2557
                                              @RequestParam(required = false, defaultValue = "0") int warehouseId, Model model) throws Exception {
31273 tejbeer 2558
 
31751 tejbeer 2559
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2560
        String email = loginDetails.getEmailId();
31320 tejbeer 2561
 
31751 tejbeer 2562
        Set<Integer> authFofoIds = csService1.getAuthFofoIds(email, true);
31320 tejbeer 2563
 
31751 tejbeer 2564
        Set<Integer> fofoIdlist = fofoStoreRepository.selectActiveStores().stream().filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toSet());
32792 shampa 2565
        Set<Integer> fofoIds = null;
34176 tejus.loha 2566
        if (authFofoIds != null) {
32792 shampa 2567
            fofoIds = authFofoIds.stream().filter(x -> fofoIdlist.contains(x)).collect(Collectors.toSet());
2568
        }
31273 tejbeer 2569
 
31751 tejbeer 2570
        Map<Integer, Double> last3MonthS = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
2571
                LocalDateTime.now().withDayOfMonth(1).minusMonths(2), LocalDateTime.now());
31320 tejbeer 2572
 
31751 tejbeer 2573
        if (fofoIds != null && fofoIds.size() > 0) {
2574
            if (warehouseId != 0) {
2575
                fofoIds = fofoStoreRepository.selectPartnerByfofoIdAndWarehouse(new ArrayList<>(fofoIds), warehouseId).stream().map(x -> x).collect(Collectors.toSet());
2576
            }
2577
            Map<Integer, PartnerDetailModel> partnerStats = adminUser.getPartnersStatDataFromFile();
2578
            if (partnerStats != null) {
2579
                List<PartnerDetailModel> partnerDetails = fofoIds.stream().filter(x -> partnerStats.containsKey(x)).map(x -> partnerStats.get(x)).collect(Collectors.toList());
2580
                Map<Milestone, List<Integer>> avg3MonthS = new HashMap<>();
2581
                if (!last3MonthS.isEmpty()) {
2582
                    int days = 60 + LocalDateTime.now().getDayOfMonth();
2583
                    for (Entry<Integer, Double> last3MonthSEntry : last3MonthS.entrySet()) {
2584
                        if (fofoIds.contains(last3MonthSEntry.getKey())) {
2585
                            Double monthSec = last3MonthSEntry.getValue();
2586
                            if (monthSec == null) {
2587
                                monthSec = (double) 0;
31320 tejbeer 2588
 
31751 tejbeer 2589
                            }
2590
                            double avg3MonthSale = (monthSec / days) * 30;
2591
                            Milestone milestone = Milestone.get((int) avg3MonthSale);
31320 tejbeer 2592
 
31751 tejbeer 2593
                            List<Integer> values = null;
2594
                            if (avg3MonthS.containsKey(milestone)) {
2595
                                values = avg3MonthS.get(milestone);
2596
                                values.add(last3MonthSEntry.getKey());
31273 tejbeer 2597
 
31751 tejbeer 2598
                                avg3MonthS.put(milestone, values);
2599
                            } else {
31273 tejbeer 2600
 
31751 tejbeer 2601
                                values = new ArrayList<>();
31273 tejbeer 2602
 
31751 tejbeer 2603
                                values.add(last3MonthSEntry.getKey());
31273 tejbeer 2604
 
31751 tejbeer 2605
                                avg3MonthS.put(milestone, values);
31273 tejbeer 2606
 
31751 tejbeer 2607
                            }
2608
                        }
31273 tejbeer 2609
 
31751 tejbeer 2610
                    }
31267 tejbeer 2611
 
31751 tejbeer 2612
                }
31259 tejbeer 2613
 
31751 tejbeer 2614
                if (partnerDetails != null) {
2615
                    Map<Milestone, List<Integer>> smtdMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getSecondarymtd()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
2616
                    Map<Milestone, List<Integer>> slmtdMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getSecondarylmtd()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
2617
                    Map<Milestone, List<Integer>> lmsMap = partnerDetails.stream().collect(Collectors.groupingBy(x -> Milestone.get(x.getSecondarylms()), Collectors.mapping(x -> x.getFofoId(), Collectors.toList())));
31259 tejbeer 2618
 
31751 tejbeer 2619
                    model.addAttribute("smtdMap", smtdMap);
2620
                    model.addAttribute("slmtdMap", slmtdMap);
2621
                    model.addAttribute("avg3MonthS", avg3MonthS);
2622
                    model.addAttribute("lmsMap", lmsMap);
31259 tejbeer 2623
 
31751 tejbeer 2624
                }
28825 tejbeer 2625
 
31751 tejbeer 2626
            }
2627
        }
28825 tejbeer 2628
 
31751 tejbeer 2629
        model.addAttribute("warehouseMap", ProfitMandiConstants.WAREHOUSE_MAP);
2630
        model.addAttribute("warehouseId", warehouseId);
2631
        model.addAttribute("milestones", Milestone.values());
28825 tejbeer 2632
 
31751 tejbeer 2633
        return "purchase-milestone";
28825 tejbeer 2634
 
31751 tejbeer 2635
    }
31152 tejbeer 2636
 
31751 tejbeer 2637
    @RequestMapping(value = "/getActivatedModelWarehouseWise", method = RequestMethod.GET)
32836 amit.gupta 2638
    public String getActivatedModelWarehouseWise(HttpServletRequest request, Model model, @RequestParam String
2639
            brand) throws Exception {
31751 tejbeer 2640
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2641
        List<Integer> fofoIds = getFofoIds(loginDetails);
2642
        List<WarehouseWiseActivatedModel> warehouseWiseActivatedModels = activatedImeiRepository.selectActivatedModelGroupByWarehouse(brand, fofoIds);
2643
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
28825 tejbeer 2644
 
31751 tejbeer 2645
        List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
28825 tejbeer 2646
 
31751 tejbeer 2647
        List<String> brands = mobileBrands.stream().map(x -> (String) x.get("name")).collect(Collectors.toList());
2648
        LOGGER.info("brands" + brands.add("Redmi"));
28825 tejbeer 2649
 
31751 tejbeer 2650
        model.addAttribute("warehouseWiseActivatedModels", warehouseWiseActivatedModels);
2651
        model.addAttribute("warehouseMap", warehouseMap);
2652
        model.addAttribute("brands", brands);
2653
        model.addAttribute("selectedbrand", brand);
2654
        return "warehousewise_activated_model";
2655
    }
28825 tejbeer 2656
 
31751 tejbeer 2657
    @RequestMapping(value = "/getActivatedModelByBrand", method = RequestMethod.GET)
2658
    public String getActivatedModelByBrand(HttpServletRequest request, Model model) throws Exception {
2659
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2660
        Set<Integer> fofoIds = csService1.getAuthFofoIds(loginDetails.getEmailId(), true);
28825 tejbeer 2661
 
31751 tejbeer 2662
        List<BrandWiseActivatedModel> activatedModels = activatedImeiRepository.selectActivatedModelGroupByBrand(new ArrayList<>(fofoIds));
2663
        model.addAttribute("activatedModels", activatedModels);
2664
        return "activation-brandwise-report";
2665
    }
28825 tejbeer 2666
 
31751 tejbeer 2667
    @RequestMapping(value = "/getWarehouseBrandWiseItemActivatedModel", method = RequestMethod.GET)
32836 amit.gupta 2668
    public String getWarehouseBrandWiseItemActivatedModel(HttpServletRequest request, Model
2669
            model, @RequestParam List<Integer> warehouseId, @RequestParam String brand) throws Exception {
31751 tejbeer 2670
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2671
        List<Integer> fofoIds = getFofoIds(loginDetails);
28825 tejbeer 2672
 
31751 tejbeer 2673
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
2674
        List<WarehouseBrandWiseItemActivatedModel> activatedItems = activatedImeiRepository.selectWarehouseBrandActivatedItem(warehouseId, brand, fofoIds);
2675
        model.addAttribute("warehouseMap", warehouseMap);
2676
        model.addAttribute("activatedItems", activatedItems);
2677
        return "warehouse-activated-itemwise-model";
28825 tejbeer 2678
 
31751 tejbeer 2679
    }
28825 tejbeer 2680
 
31751 tejbeer 2681
    @RequestMapping(value = "/getActivatedImeiUpdationDate", method = RequestMethod.GET)
2682
    public String getActivatedImeiUpdationDate(HttpServletRequest request, Model model) throws Exception {
28825 tejbeer 2683
 
31751 tejbeer 2684
        Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
35466 amit 2685
        List<String> brands = ProfitMandiConstants.BRANDS;
28825 tejbeer 2686
 
31751 tejbeer 2687
        List<ActivationImeiUpdationModel> activationImeiUpdations = activatedImeiRepository.selectActivatedUpdationDate();
35466 amit 2688
 
2689
        // Create a map for quick lookup of existing results
2690
        Map<String, ActivationImeiUpdationModel> resultMap = activationImeiUpdations.stream()
2691
                .collect(Collectors.toMap(
2692
                        m -> m.getWarehouseId() + "_" + m.getBrand(),
2693
                        m -> m
2694
                ));
2695
 
2696
        // Merge with master data - add missing combinations with null timestamp
2697
        List<ActivationImeiUpdationModel> completeList = new ArrayList<>();
2698
        for (Integer warehouseId : warehouseMap.keySet()) {
2699
            for (String brand : brands) {
2700
                String key = warehouseId + "_" + brand;
2701
                ActivationImeiUpdationModel existing = resultMap.get(key);
2702
                if (existing != null) {
2703
                    completeList.add(existing);
2704
                } else {
2705
                    completeList.add(new ActivationImeiUpdationModel(warehouseId, brand, null));
2706
                }
2707
            }
2708
        }
2709
 
31751 tejbeer 2710
        model.addAttribute("warehouseMap", warehouseMap);
35466 amit 2711
        model.addAttribute("activationImeiUpdations", completeList);
31751 tejbeer 2712
        return "activation-updation-timestamp";
28825 tejbeer 2713
 
31751 tejbeer 2714
    }
31285 tejbeer 2715
 
31751 tejbeer 2716
    private List<Integer> getFofoIds(LoginDetails loginDetails) throws ProfitMandiBusinessException {
2717
        String email = loginDetails.getEmailId();
31287 tejbeer 2718
 
31751 tejbeer 2719
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
2720
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
31287 tejbeer 2721
 
31751 tejbeer 2722
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
2723
        if (emails.contains(authUser.getEmailId())) {
2724
            fofoIds = storeGuyMap.get("tarun.verma@smartdukaan.com");
2725
            LOGGER.info("fofoIds" + fofoIds);
2726
        }
31287 tejbeer 2727
 
31751 tejbeer 2728
        if (fofoIds == null) {
35395 amit 2729
            List<Position> positions1 = positionRepository.selectAllByAuthUserId(authUser.getId());
31751 tejbeer 2730
            if (positions1.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_MASTER).count() > 0) {
2731
                fofoIds = csService.getPositionCustomRetailerMap(positions1).values().stream().flatMap(x -> x.stream()).map(x -> x.getPartnerId()).collect(Collectors.toSet());
2732
            }
2733
        }
2734
        return new ArrayList<>(fofoIds);
2735
    }
31287 tejbeer 2736
 
31751 tejbeer 2737
    @RequestMapping(value = "/getMonthWiseSale", method = RequestMethod.GET)
32836 amit.gupta 2738
    public String getPartnerSaleByMonth(HttpServletRequest request, @RequestParam List<Integer> fofoIds, Model
2739
            model) throws Exception {
31287 tejbeer 2740
 
31751 tejbeer 2741
        YearMonth now = YearMonth.now();
2742
        YearMonth ym = YearMonth.now().minusMonths(12);
2743
        List<YearMonth> list = new ArrayList<>();
2744
        while (!now.isBefore(ym)) {
2745
            list.add(now);
2746
            now = now.minusMonths(1);
2747
        }
31287 tejbeer 2748
 
31751 tejbeer 2749
        model.addAttribute("yearMonth", list);
31287 tejbeer 2750
 
31751 tejbeer 2751
        List<PartnerMonthlySaleModel> partnerMonthlySaleModels = fofoOrderItemRepository.selectPartnerMonthlySale(fofoIds, LocalDateTime.now().minusMonths(12).withDayOfMonth(1));
2752
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-yyyy");
2753
        Map<Integer, Map<YearMonth, Double>> partnerMonthSaleMap = new HashMap<>();
2754
        if (!partnerMonthlySaleModels.isEmpty()) {
31287 tejbeer 2755
 
31751 tejbeer 2756
            partnerMonthSaleMap = partnerMonthlySaleModels.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.toMap(
2757
                    x -> YearMonth.parse(x.getYearMonth(), dateTimeFormatter), x -> (double) x.getAmount())));
2758
        }
31297 tejbeer 2759
 
31751 tejbeer 2760
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers().entrySet().stream().filter(x -> fofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
31297 tejbeer 2761
 
31751 tejbeer 2762
        model.addAttribute("customRetailerMap", customRetailerMap);
31297 tejbeer 2763
 
31751 tejbeer 2764
        model.addAttribute("customRetailerMap", customRetailerMap);
31297 tejbeer 2765
 
31751 tejbeer 2766
        model.addAttribute("partnerMonthSaleMap", partnerMonthSaleMap);
2767
        return "monthly-partner-sale";
31297 tejbeer 2768
 
31751 tejbeer 2769
    }
31297 tejbeer 2770
 
35541 amit 2771
    @RequestMapping(value = "/getMonthWisePurchase", method = RequestMethod.POST)
35543 amit 2772
    public String getMonthWisePurchase(HttpServletRequest request, @RequestBody List<Integer> fofoIds, Model
32836 amit.gupta 2773
            model) throws Exception {
31751 tejbeer 2774
 
2775
        YearMonth now = YearMonth.now();
2776
        YearMonth ym = YearMonth.now().minusMonths(12);
2777
        List<YearMonth> list = new ArrayList<>();
2778
        while (!now.isBefore(ym)) {
2779
            list.add(now);
2780
            now = now.minusMonths(1);
2781
        }
2782
 
2783
        model.addAttribute("yearMonth", list);
2784
 
2785
        List<PartnerMonthlySaleModel> partnerMonthlySaleModels = orderRepository.selectSecondaryGroupByYearMonth(
32445 amit.gupta 2786
                fofoIds, LocalDate.now().withDayOfMonth(1).atStartOfDay().minusMonths(12), LocalDateTime.now());
31751 tejbeer 2787
        Map<Integer, Map<YearMonth, Double>> partnerMonthPurchaseMap = partnerMonthlySaleModels.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.groupingBy(
2788
                y -> YearMonth.parse(y.getYearMonth(), DateTimeFormatter.ofPattern("MM-yyyy")), Collectors.summingDouble(x -> x.getAmount()))));
2789
 
2790
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers().entrySet().stream().filter(x -> fofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
2791
        model.addAttribute("customRetailerMap", customRetailerMap);
2792
        model.addAttribute("partnerMonthPurchaseMap", partnerMonthPurchaseMap);
2793
        return "monthly-partner-purchase";
2794
 
2795
    }
32407 amit.gupta 2796
 
32336 jai.hind 2797
    @GetMapping("/restartServer")
32407 amit.gupta 2798
    public String RestartServer(HttpServletRequest request, Model model) throws Exception {
2799
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2800
        if (Arrays.asList("amit.gupta@smartdukaan.com", "shivam.gupta@smartdukaan.com", "vinay.p@smartdukaan.com").contains(loginDetails.getEmailId())) {
2801
            String ipAddress = "45.79.106.95";
2802
            int port = 22;
2803
            String username = "root";
2804
            String password = "spic@2015shop2020";
32408 amit.gupta 2805
            String restartServices = "./restart-services.sh";
2806
            sshService.executeCommand(ipAddress, port, username, password, restartServices);
32407 amit.gupta 2807
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
2808
        } else {
2809
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
2810
        }
32337 jai.hind 2811
        return "response";
2812
    }
32336 jai.hind 2813
 
32337 jai.hind 2814
    @GetMapping("/rebootServer")
32407 amit.gupta 2815
    public String rebootServer(HttpServletRequest request, Model model) throws Exception {
2816
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
2817
        if (Arrays.asList("amit.gupta@smartdukaan.com", "shivam.gupta@smartdukaan.com", "vinay.p@smartdukaan.com").contains(loginDetails.getEmailId())) {
2818
            String ipAddress = "45.79.106.95";
2819
            int port = 22;
2820
            String username = "root";
2821
            String password = "spic@2015shop2020";
2822
            String rebootCommand = "reboot";
32337 jai.hind 2823
 
32408 amit.gupta 2824
            sshService.executeCommand(ipAddress, port, username, password, rebootCommand);
32407 amit.gupta 2825
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
2826
        } else {
2827
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
2828
        }
32336 jai.hind 2829
        return "response";
2830
    }
32407 amit.gupta 2831
 
32336 jai.hind 2832
    @GetMapping("/getRestartServer")
32407 amit.gupta 2833
    public String getRestartServer(HttpServletRequest request, Model model) {
2834
        return "restart-server-page";
32336 jai.hind 2835
    }
21615 kshitij.so 2836
}