Subversion Repositories SmartDukaan

Rev

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

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