Subversion Repositories SmartDukaan

Rev

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