Subversion Repositories SmartDukaan

Rev

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