WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java

 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.ItemCriteria;
 import com.spice.profitmandi.dao.entity.catalog.Offer;
+import com.spice.profitmandi.dao.entity.catalog.OfferPartner;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.catalog.TargetSlabEntity;
 import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.enumuration.catalog.OfferSchemeType;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.repository.GenericRepository;
 import com.spice.profitmandi.dao.repository.catalog.*;
+import com.spice.profitmandi.dao.repository.catalog.OfferPartnerRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
 import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.OfferPayoutRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
     @Autowired
     private OfferTargetSlabRepository offerTargetSlabRepository;
     @Autowired
+    private OfferPartnerRepository offerPartnerRepository;
+    @Autowired
     private ItemCriteriaRepository itemCriteriaRepository;
     @Autowired
     private ItemRepository itemRepository;
         List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = offerTargetSlabRepository
                 .getByOfferId(fromOffer.getId());
         createOfferRequest.setPartnerCriteriaString(
                 this.getPartnerCriteriaString(createOfferRequest.getPartnerCriteria()));
         createOfferRequest.setTargetSlabs(targetSlabs);
+        if (!targetSlabs.isEmpty() && !targetSlabs.get(0).getItemCriteriaPayouts().isEmpty()) {
-        for (com.spice.profitmandi.dao.model.ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs()
+            for (com.spice.profitmandi.dao.model.ItemCriteriaPayout itemCriteriaPayout : targetSlabs.get(0).getItemCriteriaPayouts()) {
-                .get(0).getItemCriteriaPayouts()) {
+                if (!itemCriteriaPayout.getPayoutSlabs().isEmpty()) {
-            itemCriteriaPayout.setNextSlab(itemCriteriaPayout.getPayoutSlabs().get(0));
+                    itemCriteriaPayout.setNextSlab(itemCriteriaPayout.getPayoutSlabs().get(0));
+                }
+            }
+        }
         return createOfferRequest;
+    }
     @Override
                     for (ItemCriteriaPayout itemCriteriaPayout : itemCriteriaPayouts) {
                         ItemCriteria itemCriteria = itemCriteriaRepository.selectById(itemCriteriaPayout.getItemCriteria().getId());
                         if (itemCriteriaPayout.getItemCriteria().getId() > 0) {
                             itemCriteriaPayout.getItemCriteria().setId(0);
                         } else {
                             String itemCriteriaJson = gson.toJson(itemCriteriaPayout.getItemCriteria());
                             itemCriteria = itemCriteriaRepository.selectByCriteria(itemCriteriaJson);
                             // ItemCriteria Only once
                             if (itemCriteria == null) {
                                 itemCriteria = new ItemCriteria();
             offer.setActive(true);
+        }
         LOGGER.info("Published {} unpublished offers for {}", unpublished.size(), yearMonth);
         return unpublished;
+    }
+    @Override
+    public void removePartnersFromOffer(int offerId, List<Integer> fofoIds) throws ProfitMandiBusinessException {
+        Offer offer = offerRepository.selectById(offerId);
+        if (offer == null) {
+            throw new ProfitMandiBusinessException("Offer not found", "Offer not found", "");
+        }
+        PartnerCriteria partnerCriteria = gson.fromJson(offer.getPartnerCriteria(), PartnerCriteria.class);
+        if (partnerCriteria.getFofoIds() != null) {
+            partnerCriteria.getFofoIds().removeAll(fofoIds);
+        }
+        offer.setPartnerCriteria(gson.toJson(partnerCriteria));
+        genericRepository.persist(offer);
+        offerPartnerRepository.deleteByOfferIdAndFofoIds(offerId, fofoIds);
+        LOGGER.info("Removed partners {} from offer {}", fofoIds, offerId);
+    }
+    @Override
+    public void addPartnersToOffer(int offerId, List<Integer> fofoIds) throws ProfitMandiBusinessException {
+        Offer offer = offerRepository.selectById(offerId);
+        if (offer == null) {
+            throw new ProfitMandiBusinessException("Offer not found", "Offer not found", "");
+        }
+        PartnerCriteria partnerCriteria = gson.fromJson(offer.getPartnerCriteria(), PartnerCriteria.class);
+        List<Integer> existingFofoIds = partnerCriteria.getFofoIds();
+        if (existingFofoIds == null) {
+            existingFofoIds = new ArrayList<>();
+        }
+        for (int fofoId : fofoIds) {
+            if (!existingFofoIds.contains(fofoId)) {
+                existingFofoIds.add(fofoId);
+                OfferPartner offerPartner = new OfferPartner();
+                offerPartner.setOfferId(offerId);
+                offerPartner.setFofoId(fofoId);
+                offerPartnerRepository.persist(offerPartner);
+            }
+        }
+        partnerCriteria.setFofoIds(existingFofoIds);
+        offer.setPartnerCriteria(gson.toJson(partnerCriteria));
+        genericRepository.persist(offer);
+        LOGGER.info("Added partners {} to offer {}", fofoIds, offerId);
+    }
+    @Override
+    public int cloneOfferForPartners(int sourceOfferId, List<Integer> fofoIds, List<Integer> targets) throws ProfitMandiBusinessException {
+        Offer sourceOffer = offerRepository.selectById(sourceOfferId);
+        if (sourceOffer == null) {
+            throw new ProfitMandiBusinessException("Source offer not found", "Source offer not found", "");
+        }
+        CreateOfferRequest clonedRequest = this.getCreateOfferRequest(sourceOffer);
+        clonedRequest.setId(0);
+        clonedRequest.setActive(false);
+        PartnerCriteria newPartnerCriteria = new PartnerCriteria();
+        newPartnerCriteria.setFofoIds(new ArrayList<>(fofoIds));
+        newPartnerCriteria.setExcludeFofoIds(new ArrayList<>());
+        newPartnerCriteria.setRegionIds(clonedRequest.getPartnerCriteria().getRegionIds() != null
+                ? new ArrayList<>(clonedRequest.getPartnerCriteria().getRegionIds()) : new ArrayList<>());
+        newPartnerCriteria.setPartnerTypes(clonedRequest.getPartnerCriteria().getPartnerTypes() != null
+                ? new ArrayList<>(clonedRequest.getPartnerCriteria().getPartnerTypes()) : new ArrayList<>());
+        clonedRequest.setPartnerCriteria(newPartnerCriteria);
+        if (targets != null && !targets.isEmpty() && !clonedRequest.getTargetSlabs().isEmpty()) {
+            List<PayoutSlab> payoutSlabs = clonedRequest.getTargetSlabs().get(0).getItemCriteriaPayouts()
+                    .stream().flatMap(x -> x.getPayoutSlabs().stream()).collect(Collectors.toList());
+            int counter = 0;
+            for (PayoutSlab payoutSlab : payoutSlabs) {
+                if (counter < targets.size()) {
+                    payoutSlab.setOnwardsAmount(targets.get(counter));
+                    counter++;
+                }
+            }
+        }
+        this.addOfferService(clonedRequest);
+        LOGGER.info("Cloned offer {} to new offer {} for partners {}", sourceOfferId, clonedRequest.getId(), fofoIds);
+        return clonedRequest.getId();
+    }
+    @Override
+    public void updateOfferTargets(int offerId, List<Integer> newTargets) throws ProfitMandiBusinessException {
+        Offer offer = offerRepository.selectById(offerId);
+        if (offer == null) {
+            throw new ProfitMandiBusinessException("Offer not found", "Offer not found", "");
+        }
+        List<TargetSlabEntity> targetSlabs = offerTargetSlabRepository.selectEntitiesByOfferId(offerId);
+        targetSlabs.sort(Comparator.comparing(TargetSlabEntity::getPayoutTarget));
+        if (newTargets.size() != targetSlabs.size()) {
+            throw new ProfitMandiBusinessException(
+                    "Target count mismatch. Expected " + targetSlabs.size() + " but got " + newTargets.size(),
+                    "Target count mismatch", "");
+        }
+        for (int i = 0; i < targetSlabs.size(); i++) {
+            targetSlabs.get(i).setPayoutTarget(newTargets.get(i));
+            genericRepository.persist(targetSlabs.get(i));
+        }
+        LOGGER.info("Updated targets for offer {} to {}", offerId, newTargets);
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java – Rev 35861 → 35885