Subversion Repositories SmartDukaan

Rev

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