Subversion Repositories SmartDukaan

Rev

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