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

 package com.spice.profitmandi.service.order;
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.AbstractMap.SimpleEntry;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Random;
+import java.util.Set;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.core.io.InputStreamResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
 import com.spice.profitmandi.common.enumuration.ItemType;
 import com.spice.profitmandi.common.enumuration.SearchType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.model.BadReturnRequest;
+import com.spice.profitmandi.common.model.CartFofo;
+import com.spice.profitmandi.common.model.CreateOrderRequest;
+import com.spice.profitmandi.common.model.CreditNotePdfModel;
+import com.spice.profitmandi.common.model.CustomAddress;
+import com.spice.profitmandi.common.model.CustomCustomer;
+import com.spice.profitmandi.common.model.CustomFofoOrderItem;
+import com.spice.profitmandi.common.model.CustomInsurancePolicy;
+import com.spice.profitmandi.common.model.CustomOrderItem;
+import com.spice.profitmandi.common.model.CustomPaymentOption;
+import com.spice.profitmandi.common.model.CustomRetailer;
+import com.spice.profitmandi.common.model.FoiBadReturnRequest;
-import com.spice.profitmandi.common.model.*;
+import com.spice.profitmandi.common.model.GstRate;
+import com.spice.profitmandi.common.model.InsuranceModel;
+import com.spice.profitmandi.common.model.InvoicePdfModel;
+import com.spice.profitmandi.common.model.ItemIdQuantityAvailability;
+import com.spice.profitmandi.common.model.PriceModel;
+import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.model.Quantity;
+import com.spice.profitmandi.common.model.SerialNumberDetail;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
+import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
+import com.spice.profitmandi.dao.entity.dtr.Retailer;
+import com.spice.profitmandi.dao.entity.dtr.ScratchOffer;
-import com.spice.profitmandi.dao.entity.dtr.*;
+import com.spice.profitmandi.dao.entity.dtr.User;
+import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
-import com.spice.profitmandi.dao.entity.fofo.*;
+import com.spice.profitmandi.dao.entity.fofo.Customer;
+import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
+import com.spice.profitmandi.dao.entity.fofo.CustomerCreditNote;
+import com.spice.profitmandi.dao.entity.fofo.CustomerReturnItem;
+import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
+import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.fofo.HygieneData;
+import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
+import com.spice.profitmandi.dao.entity.fofo.InvoiceNumberGenerationSequence;
+import com.spice.profitmandi.dao.entity.fofo.LiveDemoSerialNumber;
+import com.spice.profitmandi.dao.entity.fofo.PendingOrder;
+import com.spice.profitmandi.dao.entity.fofo.PendingOrderItem;
+import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.inventory.State;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.entity.user.Counter;
 import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
 import com.spice.profitmandi.dao.enumuration.inventory.ScratchedGift;
 import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
+import com.spice.profitmandi.dao.repository.dtr.InsuranceProviderRepository;
-import com.spice.profitmandi.dao.repository.dtr.*;
+import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.PaymentOptionTransactionRepository;
+import com.spice.profitmandi.dao.repository.dtr.PolicyNumberGenerationSequenceRepository;
+import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
+import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
+import com.spice.profitmandi.dao.repository.dtr.ScratchOfferRepository;
+import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
-import com.spice.profitmandi.dao.repository.fofo.*;
+import com.spice.profitmandi.dao.repository.dtr.UserRepository;
+import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
+import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;
+import com.spice.profitmandi.dao.repository.fofo.CustomerCreditNoteRepository;
+import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;
+import com.spice.profitmandi.dao.repository.fofo.CustomerReturnItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
+import com.spice.profitmandi.dao.repository.fofo.HygieneDataRepository;
+import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
+import com.spice.profitmandi.dao.repository.fofo.LiveDemoBillingRespository;
+import com.spice.profitmandi.dao.repository.fofo.PaymentOptionRepository;
+import com.spice.profitmandi.dao.repository.fofo.PendingOrderItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.PendingOrderRepository;
+import com.spice.profitmandi.dao.repository.fofo.PurchaseReturnItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.CounterRepository;
 import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
 import com.spice.profitmandi.service.offers.ItemCriteria;
 import com.spice.profitmandi.service.pricing.PricingService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.hibernate.Session;
-import org.hibernate.SessionFactory;
-import org.json.JSONObject;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.core.io.InputStreamResource;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Component;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Predicate;
-import javax.persistence.criteria.Root;
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.util.AbstractMap.SimpleEntry;
-import java.util.*;
-import java.util.function.Function;
-import java.util.stream.Collectors;
 @Component
 public class OrderServiceImpl implements OrderService {
     private static final Logger LOGGER = LogManager.getLogger(OrderServiceImpl.class);
             PendingOrderItem poi = pendingOrderItemRepository.selectById(createOrderRequest.getPoItemId());
             poi.setStatus(OrderStatus.BILLED);
             poi.setBilledTimestamp(LocalDateTime.now());
+        }
-        LocalDate startDate = LocalDate.of(2023, 01, 13);
+        LocalDate startDate = LocalDate.of(2023, 07, 22);
-        LocalDate endDate = LocalDate.of(2023, 01, 27);
+        LocalDate endDate = LocalDate.of(2023, 07, 23);
         if (smartPhone) {
+            LOGGER.error("hellloooo23 {}", "kjhkjhkjhkjhkjhkjh23");
             if (LocalDateTime.now().isAfter(startDate.atStartOfDay()) && LocalDateTime.now().isBefore(endDate.atStartOfDay())) {
                 try {
                     this.sendAppDownloadBillingOffer(customer.getMobileNumber());
                 } catch (Exception e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
+                }
+                LOGGER.info("hellloooo {}", "kjhkjhkjhkjhkjhkjh");
-                this.createScratchOffer(fofoOrder.getInvoiceNumber(), fofoOrder.getCustomerId());
+                this.createScratchOffer(fofoId, fofoOrder.getInvoiceNumber(), fofoOrder.getCustomerId());
+            }
+        }
         return fofoOrder.getId();
+    }
         String response = restClient.post(SMS_GATEWAY, map, new HashMap<>());
         LOGGER.info(response);
+    }
-    private void createScratchOffer(String invoiceNumber, int customerId) {
+    private void createScratchOffer(int fofoId, String invoiceNumber, int customerId) {
+        Map<Integer, ScratchedGift> giftSeries = new HashMap<>();
+        giftSeries.put(1, ScratchedGift.MINI_CHOPPER);
+        giftSeries.put(2, ScratchedGift.FRUIT_JUICER);
+        giftSeries.put(3, ScratchedGift.STEAM_IRON);
+        LocalDate startDate = LocalDate.of(2023, 07, 22);
+        LocalDate endDate = LocalDate.of(2023, 07, 23);
+        List<FofoOrder> fofoOrders = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(fofoId, startDate.atStartOfDay(), endDate.atStartOfDay());
+        ScratchedGift gift = ScratchedGift.BLNT;
+        Random random = new Random();
+        int rand = 0;
+        LOGGER.info("Processing insurane for serialNumbers");
+        while (true) {
+            rand = random.nextInt(4);
+            if (rand != 0) break;
-        /*
+        }
+        LOGGER.info("rand {}", rand);
+        if (fofoOrders.isEmpty()) {
+            gift = giftSeries.get(rand);
+            LOGGER.info("gift11 {}", gift);
+        } else {
+            List<String> invoiceNumbers = fofoOrders.stream().filter(x -> x.getCancelledTimestamp() == null).map(x -> x.getInvoiceNumber()).collect(Collectors.toList());
-         * ScratchOffer so = new ScratchOffer(); so.setInvoiceNumber(invoiceNumber);
+            List<ScratchOffer> scratchOffers = scratchOfferRepository.selectByInvoiceNumbers(invoiceNumbers);
+            if (scratchOffers.isEmpty()) {
+                gift = giftSeries.get(rand);
+                LOGGER.info("gift3 {}", gift);
+            } else {
+                List<ScratchOffer> bigGifts = scratchOffers.stream().filter(x -> !x.getOfferName().equals(ScratchedGift.BLNT) && !x.getOfferName().equals(ScratchedGift.EW)).collect(Collectors.toList());
+                LOGGER.info("bigGifts {}", bigGifts);
+                if (bigGifts.size() <= 10) {
+                    List<Integer> scratchCustomerIds = scratchOffers.stream().map(x -> x.getCustomerId()).collect(Collectors.toList());
-         * so.setOfferName(ScratchedGift.EW); so.setScratched(false);
+                    if (scratchCustomerIds.contains(customerId)) {
-         * so.setCreatedTimestamp(LocalDateTime.now());
+                        gift = ScratchedGift.BLNT;
+                        LOGGER.info("gift2 {}", gift);
+                    } else {
+                        int miniChopper = (int) bigGifts.stream().filter(x -> x.getOfferName().equals(ScratchedGift.MINI_CHOPPER)).count();
+                        int fruitJuicer = (int) bigGifts.stream().filter(x -> x.getOfferName().equals(ScratchedGift.FRUIT_JUICER)).count();
+                        int streanIron = (int) bigGifts.stream().filter(x -> x.getOfferName().equals(ScratchedGift.STEAM_IRON)).count();
+                        LOGGER.info("miniChopper {}", miniChopper);
-         * so.setExpiredTimestamp(so.getCreatedTimestamp().plusDays(1));
+                        LOGGER.info("fruitJuicer {}", fruitJuicer);
+                        LOGGER.info("streanIron {}", streanIron);
+                        if (rand == 1) {
+                            if (miniChopper < 4) {
+                                LOGGER.info("miniChopper {}", miniChopper);
+                                gift = giftSeries.get(rand);
+                            }
+                        }
+                        if (rand == 2) {
+                            if (fruitJuicer < 3) {
-         * so.setUnlockedAt(LocalDateTime.now()); so.setCustomerId(customerId);
+                                LOGGER.info("fruitJuicer {}", fruitJuicer);
+                                gift = giftSeries.get(rand);
+                            }
+                        }
+                        if (rand == 3) {
-         * scratchOfferRepository.persist(so);
+                            if (streanIron < 3) {
+                                LOGGER.info("streanIron {}", streanIron);
+                                gift = giftSeries.get(rand);
+                            }
+                        }
+                        LOGGER.info("gift4 {}", gift);
+                    }
+                }
+            }
-         */
+        }
-        LocalDateTime endDate = LocalDateTime.of(LocalDate.now().getYear(), LocalDate.now().getMonth(), 27, 21, 00);
+        //  LocalDateTime endDate = LocalDateTime.of(LocalDate.now().getYear(), LocalDate.now().getMonth(), 27, 21, 00);
         ScratchOffer so2 = new ScratchOffer();
         so2.setInvoiceNumber(invoiceNumber);
         so2.setScratched(false);
         so2.setCreatedTimestamp(LocalDateTime.now());
-        so2.setExpiredTimestamp(endDate.plusDays(1).toLocalDate().atTime(LocalTime.MAX));
+        so2.setExpiredTimestamp(LocalDateTime.now().plusDays(1));
-        so2.setOfferName(ScratchedGift.BLNT);
+        so2.setOfferName(gift);
         so2.setCustomerId(customerId);
+        so2.setUnlockedAt(LocalDateTime.now());
         LocalDate date = LocalDate.now();
-        LocalDateTime seven = LocalDateTime.of(date.getYear(), date.getMonth(), date.getDayOfMonth(), 19, 0);
+        /* LocalDateTime seven = LocalDateTime.of(date.getYear(), date.getMonth(), date.getDayOfMonth(), 19, 0);
         LocalDateTime nine = LocalDateTime.of(date.getYear(), date.getMonth(), date.getDayOfMonth(), 21, 0);
         if (LocalDateTime.now().isAfter(seven)) {
-            so2.setUnlockedAt(nine.plusDays(1));
+        so2.setUnlockedAt(nine.plusDays(1));
         } else {
-            so2.setUnlockedAt(nine);
+        so2.setUnlockedAt(nine);
-        }
+        }*/
         scratchOfferRepository.persist(so2);
+        ScratchOffer so = new ScratchOffer();
+        so.setInvoiceNumber(invoiceNumber);
+        so.setOfferName(ScratchedGift.EW);
+        so.setScratched(false);
+        so.setCreatedTimestamp(LocalDateTime.now());
+        so.setExpiredTimestamp(so.getCreatedTimestamp().plusDays(1));
+        so.setUnlockedAt(LocalDateTime.now());
+        so.setCustomerId(customerId);
+        scratchOfferRepository.persist(so);
+    }
     private HygieneData createAndGetHygieneData(int id, int fofoId) {
         HygieneData hygieneData = new HygieneData();
         hygieneData.setOrderId(id);

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/order/OrderServiceImpl.java – Rev 32145 → 32218