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

 import com.spice.profitmandi.common.model.PdfModel;
 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.model.WiseAppInsuaranceModel;
 import com.spice.profitmandi.common.util.FormattingUtils;
-import com.spice.profitmandi.common.util.InsuranceUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 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.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
 import com.spice.profitmandi.dao.enumuration.fofo.ReturnType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.fofo.SettlementType;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 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.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.integrations.zest.MobileInsurancePlan;
-import com.spice.profitmandi.service.integrations.zest.ZestService;
+import com.spice.profitmandi.service.integrations.zest.InsuranceService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.inventory.PurchaseReturnService;
 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 in.shop2020.model.v1.order.WalletReferenceType;
 @Component
 public class OrderServiceImpl implements OrderService {
 	private static final Logger LOGGER = LogManager.getLogger(OrderServiceImpl.class);
 	@Autowired
 	private LiveDemoBillingRespository liveDemoBillingRespository;
 	@Autowired
+	private InsuranceService insuranceService;
+	@Autowired
 	private WalletService walletService;
 	@Autowired
 	@Qualifier("fofoCurrentInventorySnapshotRepository")
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	@Autowired
 	private PurchaseReturnService purchaseReturnService;
 	@Autowired
-	private ZestService zestService;
+	private InsuranceService zestService;
 	@Autowired
 	private RetailerService retailerService;
 	@Autowired
 	private HygieneDataRepository hygieneDataRepository;
 	@Override
 	public int createOrder(CreateOrderRequest createOrderRequest, int fofoId, boolean accessoriesDeals)
 			throws ProfitMandiBusinessException {
+		LOGGER.info("fofoId -- {} Order Request -- {}", fofoId, createOrderRequest);
 		CustomCustomer customCustomer = createOrderRequest.getCustomer();
 		if (!StringUtils.isValidEmailAddress(customCustomer.getEmailId())) {
 			LOGGER.error("invalid customer emailId {} ", customCustomer.getEmailId());
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, customCustomer.getEmailId(),
 		Map<Integer, Item> itemMap = this.toItemMap(items);
 		Set<Integer> nonSerializedItemIds = new HashSet<>();
 		Set<String> serialNumbers = new HashSet<>();
-		Map<String, InsuranceModel> insuranceSerialNumberMap = new HashMap<>();
+		List<InsuranceModel> insuredModels = new ArrayList<>();
 		for (CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()) {
 			Item item = itemMap.get(customFofoOrderItem.getItemId());
 			noGST = item.getHsnCode().equals("NOGST");
 			if (item.getType().equals(ItemType.SERIALIZED)) {
 				for (SerialNumberDetail serialNumberDetail : customFofoOrderItem.getSerialNumberDetails()) {
 					serialNumbers.add(serialNumberDetail.getSerialNumber());
 					if (serialNumberDetail.getAmount() > 0) {
 						InsuranceModel im = new InsuranceModel();
 						im.setBrand(item.getBrand());
-						im.setModelName(item.getModelName());
+						im.setColor(item.getColor());
+						im.setModelName(item.getModelName() + item.getModelNumber());
 						im.setInsuranceAmount(serialNumberDetail.getAmount());
 						im.setDeviceSellingPrice(customFofoOrderItem.getSellingPrice());
-						im.setInsuranceId(serialNumberDetail.getInsurance() + "");
+						im.setInsuranceId(serialNumberDetail.getInsurance());
-						insuranceSerialNumberMap.put(serialNumberDetail.getSerialNumber(), im);
+						im.setSerialNumber(serialNumberDetail.getSerialNumber());
+						insuredModels.add(im);
+					}
+				}
 			} else {
 				nonSerializedItemIds.add(customFofoOrderItem.getItemId());
+			}
 				// TODO:handle null
 				if (serializedInventoryItemMap.get(item.getId()) == null
 						|| itemIdCustomFofoOrderItemMap.get(item.getId()).getSerialNumberDetails()
 								.size() != serializedInventoryItemMap.get(item.getId()).size()) {
-					LOGGER.error("itemId {} => mismatch size of requested serial numbers", item.getId());
 					List<String> invalidSerialNumbers = itemIdCustomFofoOrderItemMap.get(item.getId())
 							.getSerialNumberDetails().stream().map(x -> x.getSerialNumber())
 							.collect(Collectors.toList());
 					throw new ProfitMandiBusinessException("invalidSerialNumbers", invalidSerialNumbers, "FFORDR_1004");
+				}
 				this.createAndGetHygieneData(fofoOrder.getId(), fofoOrder.getFofoId());
+			}
+		}
 		// insurance calculation is insurance flag is enabled
 		//
-		if (!insuranceSerialNumberMap.isEmpty()) {
+		if (insuredModels.size() > 0) {
 			LOGGER.info("Processing insurane for serialNumbers");
 			LocalDate customerDateOfBirth = LocalDate.from(createOrderRequest.getCustomer().getDateOfBirth());
-			for (Map.Entry<String, InsuranceModel> entry : insuranceSerialNumberMap.entrySet()) {
+			fofoOrder.setDateOfBirth(customerDateOfBirth);
-				InsuranceModel insuranceModel = entry.getValue();
+			for (InsuranceModel insuranceModel : insuredModels) {
-				MobileInsurancePlan mobileInsurancePlan = zestService.getAllPlansMap()
-						.get(insuranceModel.getInsuranceId());
-				InsurancePolicy insurancePolicy = this.createInsurancePolicy(fofoOrder.getInvoiceNumber(), fofoId,
-						insuranceModel.getInsuranceAmount() - mobileInsurancePlan.getPartnerCommission(),
-						insuranceModel.getInsuranceAmount(), insuranceModel.getDeviceSellingPrice(), entry.getKey(),
-						insuranceModel.getModelName(), insuranceModel.getBrand(), customer, customerDateOfBirth,
-						customerAddress,
-						mobileInsurancePlan.getProductName() + " for " + mobileInsurancePlan.getDuration() + " Months");
-				String walletDescription = null;
-				if (mobileInsurancePlan.getProviderId().equals("0")) {
-					insurancePolicy.setProviderId(1);
-					int policyNumberGenerationSequence = this.createPolicyNumberGenerationSequence().getSequence();
-					insurancePolicy.setPolicyNumber(StringUtils.generatePolicyNumber(
-							ProfitMandiConstants.POLICY_NUMBER_PREFIX, policyNumberGenerationSequence));
-					GadgetCopsInsuranceModel gadgetCopsInsuranceModel = this.createGadgetCopsInsuranceModel(
-							entry.getValue().getBrand(), entry.getValue().getModelName(), entry.getKey(),
-							customerDateOfBirth, customer, customerAddress, insurancePolicy);
-					try {
-						InsuranceUtils.submitToGadgetCops(gadgetCopsInsuranceModel);
-						insurancePolicy.setPosted(true);
-						walletDescription = "Sale of " + insurancePolicy.getPolicyNumber() + " for "
-								+ fofoOrder.getInvoiceNumber();
-					} catch (ProfitMandiBusinessException profitMandiBusinessException) {
-						LOGGER.info("Unable to submit insurance policy details to {}", insuranceModel.getProviderName(),
-								profitMandiBusinessException);
-						throw new ProfitMandiBusinessException("Insurance", mobileInsurancePlan.getProductName(),
-								"Could not generate insurance for Gadget Cop");
-					}
-				} else {
-					try {
+				try {
-						WiseAppInsuaranceModel wiseAppInsuaranceModel = this
-								.createWiseAppInsuranceModel(mobileInsurancePlan, insurancePolicy, customCustomer);
-						String wiseAppInsuranceCode = zestService.createInsurance(wiseAppInsuaranceModel);
+					insuranceService.createInsurance(fofoOrder, insuranceModel);
-						insurancePolicy.setPolicyNumber(wiseAppInsuranceCode);
-						// TODO: remove hardcoding
-						insurancePolicy.setProviderId(2);
-						walletDescription = "Sale of " + insurancePolicy.getProductName() + " against "
-								+ fofoOrder.getInvoiceNumber();
-					} catch (ProfitMandiBusinessException pbe) {
+				} catch (Exception e) {
-						pbe.printStackTrace();
+					e.printStackTrace();
-						throw new ProfitMandiBusinessException("Insurance", mobileInsurancePlan.getProductName(),
+					throw new ProfitMandiBusinessException("Insurance creation", insuranceModel,
-								pbe.getMessage());
+							"Failed to create insurance");
-					}
+				}
-				walletService.consumeAmountFromWallet(fofoId, insurancePolicy.getId(),
-						WalletReferenceType.DAMAGE_PROTECTION, walletDescription, insurancePolicy.getPurchaseAmount());
-				insurancePolicyRepository.persist(insurancePolicy);
+			}
+		}
 		schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
 		return fofoOrder.getId();
+	}
 		hygieneDataRepository.persist(hygieneData);
 		return hygieneData;
+	}
-	private WiseAppInsuaranceModel createWiseAppInsuranceModel(MobileInsurancePlan mobileInsurancePlan,
-			InsurancePolicy insurancePolicy, CustomCustomer customer) throws ProfitMandiBusinessException {
-		WiseAppInsuaranceModel wiseAppInsuranceModel = new WiseAppInsuaranceModel();
-		CustomAddress address = customer.getAddress();
-		String sAddress = (address.getLine1() + " " + address.getLine2()).replaceAll("  ", " ");
-		wiseAppInsuranceModel.setAddress(sAddress);
-		wiseAppInsuranceModel.setBrand(insurancePolicy.getBrand());
-		wiseAppInsuranceModel.setBalanceType("4");
-		wiseAppInsuranceModel.setProduct(mobileInsurancePlan.getProductId());
-		wiseAppInsuranceModel
-				.setName((insurancePolicy.getCustomerFirstName() + " " + insurancePolicy.getCustomerLastName()));
-		wiseAppInsuranceModel.setCity(address.getCity());
-		wiseAppInsuranceModel.setDob(StringUtils.toHyphenatedString(customer.getDateOfBirth()));
-		wiseAppInsuranceModel.setDuration(mobileInsurancePlan.getDuration());
-		wiseAppInsuranceModel.setPincode(address.getPinCode());
-		wiseAppInsuranceModel.setEmail(customer.getEmailId());
-		wiseAppInsuranceModel.setDeviceType(mobileInsurancePlan.getDeviceTypeId());
-		wiseAppInsuranceModel.setImeiNo(insurancePolicy.getSerialNumber());
-		wiseAppInsuranceModel.setPlanValue(String.valueOf(insurancePolicy.getSaleAmount()));
-		wiseAppInsuranceModel.setRetailerId(zestService.getWiseAppPartnerCode(insurancePolicy.getRetailerId()));
-		wiseAppInsuranceModel.setDuration(mobileInsurancePlan.getDuration());
-		wiseAppInsuranceModel.setGender(customer.getGender());
-		wiseAppInsuranceModel.setInvoiceNo(insurancePolicy.getInvoiceNumber());
-		wiseAppInsuranceModel.setNumber(insurancePolicy.getCustomerMobileNumber());
-		wiseAppInsuranceModel
-				.setPurchaseDate(StringUtils.toHyphenatedString(insurancePolicy.getCreateTimestamp().toLocalDate()));
-		wiseAppInsuranceModel.setModel(insurancePolicy.getModelName());
-		wiseAppInsuranceModel.setHandSetValue(String.valueOf(insurancePolicy.getSellingPrice()));
-		wiseAppInsuranceModel.setInsurerCompany(mobileInsurancePlan.getProviderId());
-		return wiseAppInsuranceModel;
-	}
 	@Override
 	public String getInvoiceNumber(int fofoId, String fofoStoreCode) {
 		InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = null;
 		try {
 			invoiceNumberGenerationSequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoId);
+			}
+		}
 		return serialNumbers;
+	}
-	private PolicyNumberGenerationSequence createPolicyNumberGenerationSequence() {
-		PolicyNumberGenerationSequence policyNumberGenerationSequence = null;
-		try {
-			policyNumberGenerationSequence = policyNumberGenerationSequenceRepository.select();
-			policyNumberGenerationSequence.setSequence(policyNumberGenerationSequence.getSequence() + 1);
-			policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);
-		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
-			policyNumberGenerationSequence = new PolicyNumberGenerationSequence();
-			policyNumberGenerationSequence.setSequence(1);
-			policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);
-		}
-		return policyNumberGenerationSequence;
-	}
-	private GadgetCopsInsuranceModel createGadgetCopsInsuranceModel(String brand, String modelName, String serialNumber,
-			LocalDate customerDateOfBirth, Customer customer, CustomerAddress customerAddress,
-			InsurancePolicy insurancePolicy) {
-		GadgetCopsInsuranceModel gadgetCopsInsuranceModel = new GadgetCopsInsuranceModel();
-		gadgetCopsInsuranceModel.setBrand(brand);
-		gadgetCopsInsuranceModel.setModelName(modelName);
-		gadgetCopsInsuranceModel.setSerialNumber(serialNumber);
-		gadgetCopsInsuranceModel.setCustomerFirstName(customer.getFirstName());
-		gadgetCopsInsuranceModel.setCustomerLastName(customer.getLastName());
-		gadgetCopsInsuranceModel.setCustomerDateOfBirth(customerDateOfBirth);
-		gadgetCopsInsuranceModel.setCustomerMobileNumber(customer.getMobileNumber());
-		gadgetCopsInsuranceModel.setCustomerEmailId(customer.getEmailId());
-		gadgetCopsInsuranceModel.setCustomerAddress1(customerAddress.getLine1());
-		gadgetCopsInsuranceModel.setCustomerAddress2(customerAddress.getLine2());
-		gadgetCopsInsuranceModel.setCustomerCity(customerAddress.getCity());
-		gadgetCopsInsuranceModel.setCustomerPinCode(customerAddress.getPinCode());
-		gadgetCopsInsuranceModel.setCustomerState(customerAddress.getState());
-		gadgetCopsInsuranceModel.setPrice(insurancePolicy.getSellingPrice());
-		gadgetCopsInsuranceModel.setInvoiceNumber(insurancePolicy.getInvoiceNumber());
-		gadgetCopsInsuranceModel.setPolicyNumber(insurancePolicy.getPolicyNumber());
-		return gadgetCopsInsuranceModel;
-	}
-	private InsurancePolicy createInsurancePolicy(String invoiceNumber, int retailerId, float purchaseAmount,
-			float saleAmount, float sellingPrice, String serialNumber, String modelName, String brand,
-			Customer customer, LocalDate customerDateOfBirth, CustomerAddress customerAddress, String productName) {
-		InsurancePolicy insurancePolicy = new InsurancePolicy();
-		insurancePolicy.setInvoiceNumber(invoiceNumber);
-		insurancePolicy.setRetailerId(retailerId);
-		insurancePolicy.setPurchaseAmount(purchaseAmount);
-		insurancePolicy.setSaleAmount(saleAmount);
-		insurancePolicy.setSellingPrice(sellingPrice);
-		insurancePolicy.setSerialNumber(serialNumber);
-		insurancePolicy.setModelName(modelName);
-		insurancePolicy.setBrand(brand);
-		insurancePolicy.setCustomerFirstName(customer.getFirstName());
-		insurancePolicy.setCustomerLastName(customer.getLastName());
-		insurancePolicy.setCustomerMobileNumber(customer.getMobileNumber());
-		insurancePolicy.setCustomerEmailId(customer.getEmailId());
-		insurancePolicy.setCustomerDateOfBirth(customerDateOfBirth);
-		insurancePolicy.setCustomerAddress1(customerAddress.getLine1());
-		insurancePolicy.setCustomerAddress2(customerAddress.getLine2());
-		insurancePolicy.setCustomerCity(customerAddress.getCity());
-		insurancePolicy.setCustomerPinCode(customerAddress.getPinCode());
-		insurancePolicy.setCustomerState(customerAddress.getState());
-		insurancePolicy.setProductName(productName);
-		return insurancePolicy;
-	}
 	private void validateDpPrice(Map<Integer, PriceModel> itemIdMopPriceMap,
 			Map<Integer, CustomFofoOrderItem> itemIdCustomFofoLineItemMap) throws ProfitMandiBusinessException {
 		for (Map.Entry<Integer, CustomFofoOrderItem> entry : itemIdCustomFofoLineItemMap.entrySet()) {
 			int itemId = entry.getKey();
 			CustomFofoOrderItem customFofoOrderItem = entry.getValue();
+	}
 	@Override
 	public boolean notifyColorChange(int orderId, int itemId) throws ProfitMandiBusinessException {
 		Order order = orderRepository.selectById(orderId);
-		inventoryService.reservationCount(itemId, order);
+		inventoryService.reservationCountByColor(itemId, order);
 		order.getLineItem().setItemId(itemId);
 		Item item = itemRepository.selectById(itemId);
 		order.getLineItem().setColor(item.getColor());
 		return true;
 			return fofoOrder;
 		} else {
 			throw new Exception(String.format("Could not find inventoryItemId - %s", inventoryItemId));
+		}
+	}
 }

Subversion Repositories SmartDukaan

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