Subversion Repositories SmartDukaan

    // ===== Offer Partner & Target Management (Admin Only) =====

    @RequestMapping(value = "/offer/partners", method = RequestMethod.GET)

    public String getOfferPartners(HttpServletRequest request, @RequestParam int offerId, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {

            throw new ProfitMandiBusinessException("Unauthorized", "Unauthorized", "");

        }

        CreateOfferRequest offer = offerService.getOffer(0, offerId);

        List<com.spice.profitmandi.dao.entity.catalog.OfferPartner> offerPartners = offerPartnerRepository.selectByOfferId(offerId);

        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

        List<Integer> allFofoIds = fofoStoreRepository.selectActiveStores().stream()

                .map(x -> x.getId()).collect(Collectors.toList());

        Map<Integer, CustomRetailer> allRetailersMap = allFofoIds.stream()

                .map(id -> customRetailerMap.get(id))

                .filter(x -> x != null)

                .collect(Collectors.toMap(CustomRetailer::getPartnerId, x -> x));

        model.addAttribute("offer", offer);

        model.addAttribute("offerId", offerId);

        model.addAttribute("offerPartners", offerPartners);

        model.addAttribute("customRetailerMap", customRetailerMap);

        model.addAttribute("allRetailersMap", allRetailersMap);

        return "offer_partners";

    }

    @RequestMapping(value = "/offer/removePartners", method = RequestMethod.POST)

    public ResponseEntity<?> removePartnersFromOffer(HttpServletRequest request,

            @RequestParam int offerId, @RequestParam List<Integer> fofoIds,

            @RequestParam(required = false, defaultValue = "false") boolean createNewOffer,

            @RequestParam(required = false) List<Integer> targets) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {

            throw new ProfitMandiBusinessException("Unauthorized", "Unauthorized", "");

        }

        Offer offer = offerRepository.selectById(offerId);

        YearMonth ym = YearMonth.from(offer.getStartDate());

        offerService.removePartnersFromOffer(offerId, fofoIds);

        Integer newOfferId = null;

        String message;

        if (createNewOffer && targets != null && !targets.isEmpty()) {

            newOfferId = offerService.cloneOfferForPartners(offerId, fofoIds, targets);

            message = "Partner(s) removed from Offer #" + offerId + ". New Offer #" + newOfferId + " created (Unpublished).";

        } else {

            message = "Partner(s) removed from Offer #" + offerId + ".";

        }

        oneDayCacheManager.getCache("allOffers").evict(ym);

        redisCacheManager.getCache("catalog.published_yearmonth").evict(ym);

        redisShortCacheManager.getCache("publishedOffersWithAchievement").clear();

        Map<String, Object> response = new HashMap<>();

        response.put("message", message);

        response.put("newOfferId", newOfferId);

        response.put("yearMonth", ym.toString());

        return responseSender.ok(response);

    }

    @RequestMapping(value = "/offer/addPartners", method = RequestMethod.POST)

    public ResponseEntity<?> addPartnersToOffer(HttpServletRequest request,

            @RequestParam int offerId, @RequestParam List<Integer> fofoIds) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {

            throw new ProfitMandiBusinessException("Unauthorized", "Unauthorized", "");

        }

        offerService.addPartnersToOffer(offerId, fofoIds);

        Offer offer = offerRepository.selectById(offerId);

        YearMonth ym = YearMonth.from(offer.getStartDate());

        oneDayCacheManager.getCache("allOffers").evict(ym);

        redisCacheManager.getCache("catalog.published_yearmonth").evict(ym);

        redisShortCacheManager.getCache("publishedOffersWithAchievement").clear();

        Map<String, Object> response = new HashMap<>();

        response.put("message", "Partner(s) added to Offer #" + offerId + ".");

        response.put("yearMonth", ym.toString());

        return responseSender.ok(response);

    }

    @RequestMapping(value = "/offer/updateTargets", method = RequestMethod.POST)

    public ResponseEntity<?> updateOfferTargets(HttpServletRequest request,

            @RequestParam int offerId, @RequestParam List<Integer> targets) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (!roleManager.isAdmin(loginDetails.getRoleIds())) {

            throw new ProfitMandiBusinessException("Unauthorized", "Unauthorized", "");

        }

        offerService.updateOfferTargets(offerId, targets);

        Offer offer = offerRepository.selectById(offerId);

        YearMonth ym = YearMonth.from(offer.getStartDate());

        oneDayCacheManager.getCache("allOffers").evict(ym);

        redisCacheManager.getCache("catalog.published_yearmonth").evict(ym);

        redisShortCacheManager.getCache("publishedOffersWithAchievement").clear();

        return responseSender.ok("Targets updated for Offer #" + offerId);

    }