Subversion Repositories SmartDukaan

Rev

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