Rev 21612 | Rev 21689 | Go to most recent revision | View as "text/plain" | Blame | Compare with Previous | Last modification | View Log | RSS feed
package com.spice.profitmandi.web.controller;import java.util.ArrayList;import java.util.HashMap;import java.util.HashSet;import java.util.List;import java.util.Map;import java.util.Set;import javax.servlet.http.HttpServletRequest;import javax.transaction.Transactional;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.RequestBody;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;import com.spice.profitmandi.common.model.CustomAddress;import com.spice.profitmandi.common.model.ProfitMandiConstants;import com.spice.profitmandi.common.util.StringUtils;import com.spice.profitmandi.dao.entity.Address;import com.spice.profitmandi.dao.entity.CurrentInventorySnapshot;import com.spice.profitmandi.dao.entity.Customer;import com.spice.profitmandi.dao.entity.FofoLineItem;import com.spice.profitmandi.dao.entity.FofoLineItemSerialNumber;import com.spice.profitmandi.dao.entity.FofoOrder;import com.spice.profitmandi.dao.entity.InventoryItem;import com.spice.profitmandi.dao.entity.InvoiceNumberGenerationSequence;import com.spice.profitmandi.dao.entity.Item;import com.spice.profitmandi.dao.entity.LineItem;import com.spice.profitmandi.dao.entity.Order;import com.spice.profitmandi.dao.entity.PaymentOption;import com.spice.profitmandi.dao.entity.ScanRecord;import com.spice.profitmandi.dao.enumuration.ScanType;import com.spice.profitmandi.dao.repository.AddressRepository;import com.spice.profitmandi.dao.repository.CurrentInventorySnapshotRepository;import com.spice.profitmandi.dao.repository.CustomerRepository;import com.spice.profitmandi.dao.repository.FofoLineItemRepository;import com.spice.profitmandi.dao.repository.FofoLineItemSerialNumberRepository;import com.spice.profitmandi.dao.repository.FofoOrderRepository;import com.spice.profitmandi.dao.repository.InventoryItemRepository;import com.spice.profitmandi.dao.repository.InvoiceNumberGenerationSequenceRepository;import com.spice.profitmandi.dao.repository.OrderRepository;import com.spice.profitmandi.dao.repository.PaymentOptionRepository;import com.spice.profitmandi.dao.repository.ScanRecordRepository;import com.spice.profitmandi.web.model.FofoDetails;import com.spice.profitmandi.web.request.CreateOrderRequest;import com.spice.profitmandi.web.request.CustomCustomer;import com.spice.profitmandi.web.request.CustomFofoLineItem;import com.spice.profitmandi.web.request.CustomPaymentOption;import com.spice.profitmandi.web.response.ItemIdQuantityAvailability;import com.spice.profitmandi.web.response.Quantity;import com.spice.profitmandi.web.util.CookiesFetcher;import com.spice.profitmandi.web.util.MVCResponseSender;@Controller@Transactionalpublic class OrderController {private static final Logger LOGGER = LoggerFactory.getLogger(OrderController.class);@AutowiredOrderRepository orderRepository;@AutowiredInventoryItemRepository inventoryItemRepository;@AutowiredCurrentInventorySnapshotRepository currentInventorySnapshotRepository;@AutowiredInvoiceNumberGenerationSequenceRepository invoiceNumberGenerationSequenceRepository;@AutowiredCustomerRepository customerRepository;@AutowiredAddressRepository addressRepository;@AutowiredFofoLineItemSerialNumberRepository fofoLineItemSerialNumberRepository;@AutowiredFofoLineItemRepository fofoLineItemRepository;@AutowiredPaymentOptionRepository paymentOptionRepository;@AutowiredScanRecordRepository scanRecordRepository;@AutowiredFofoOrderRepository fofoOrderRepository;@AutowiredMVCResponseSender mvcResponseSender;@AutowiredCookiesFetcher cookiesFetcher;@RequestMapping(value = "/order", method = RequestMethod.POST)public String createOrder(HttpServletRequest request, @RequestBody CreateOrderRequest createOrderRequest) throws Throwable{//FofoDetails fofoDetails = cookiesFetcher.getCookiesObject(request);LOGGER.info("/order request {}", createOrderRequest);FofoDetails fofoDetails = new FofoDetails();fofoDetails.setFofoId(963490);Set<CustomFofoLineItem> fofoLineItems = createOrderRequest.getFofoLineItems();Set<Integer> itemIds = new HashSet<>();Set<Integer> nonSerializedItemIds = new HashSet<>();Map<Integer, Integer> itemIdQuantity = new HashMap<>();for(CustomFofoLineItem fofoLineItem : fofoLineItems){itemIds.add(fofoLineItem.getItemId());if(fofoLineItem.getSerialNumbers().size() > 0 && fofoLineItem.getQuantity() != fofoLineItem.getSerialNumbers().size()){itemIdQuantity.put(fofoLineItem.getItemId(), fofoLineItem.getQuantity());}if(fofoLineItem.getSerialNumbers().isEmpty()){nonSerializedItemIds.add(fofoLineItem.getItemId());}}if(!itemIdQuantity.isEmpty()){// if item quantity does not match with given serialnumbers sizeLOGGER.error("itemId's quantity should be equal to given serialnumber size {} ", itemIdQuantity);return "error";}float totalAmount = 0;Map<Integer, Float> lineItemPrice = new HashMap<>();List<CurrentInventorySnapshot> currentInventorySnapshots = currentInventorySnapshotRepository.selectByFofoItemIds(fofoDetails.getFofoId(), itemIds);List<ItemIdQuantityAvailability> itemIdQuantityAvailabilities = new ArrayList<>();for(CurrentInventorySnapshot currentInventorySnapshot : currentInventorySnapshots){for(CustomFofoLineItem fofoLineItem : fofoLineItems){if(currentInventorySnapshot.getId().getItemId() == fofoLineItem.getItemId()){if(fofoLineItem.getQuantity() > currentInventorySnapshot.getAvailability()){ItemIdQuantityAvailability itemIdQuantityAvailability = new ItemIdQuantityAvailability();itemIdQuantityAvailability.setItemId(fofoLineItem.getItemId());Quantity quantity = new Quantity();quantity.setAvailable(currentInventorySnapshot.getAvailability());quantity.setRequested(fofoLineItem.getQuantity());itemIdQuantityAvailability.setQuantity(quantity);itemIdQuantityAvailabilities.add(itemIdQuantityAvailability);}}if(!(fofoLineItem.getSellingPrice() > 0)){lineItemPrice.put(fofoLineItem.getItemId(), fofoLineItem.getSellingPrice());}else{totalAmount = totalAmount + fofoLineItem.getSellingPrice();}}}try{this.validatePaymentOptionsAndTotalAmount(createOrderRequest.getPaymentOptions(), totalAmount);}catch(ProfitMandiBusinessException profitMandiBusinessException){LOGGER.error("Error occured while validating payment options : ", profitMandiBusinessException);return "error";}if(!itemIdQuantityAvailabilities.isEmpty()){// itemIdQuantity request is not validLOGGER.error("Requested quantities should not be greater than currently available quantities {}", itemIdQuantityAvailabilities);return "error";}if(!lineItemPrice.isEmpty()){// given fofo line item price must be greater than zeroLOGGER.error("requested itemId's selling price must greater thant 0");return "error";}Set<Integer> invalidItemIdSerialNumbers = new HashSet<>();Map<Integer, Set<String>> itemIdSerialNumbers = new HashMap<>();List<InventoryItem> inventoryItems = inventoryItemRepository.selectByFofoIdItemIds(fofoDetails.getFofoId(), itemIds);if(inventoryItems.isEmpty()){// invalid item idsLOGGER.error("Requested itemId's are not available in inventoryItem");return "error";}for(InventoryItem inventoryItem : inventoryItems){for(CustomFofoLineItem fofoLineItem : fofoLineItems){if(inventoryItem.getItemId() == fofoLineItem.getItemId()){if(fofoLineItem.getSerialNumbers().isEmpty()){if(!(inventoryItem.getSerialNumber() == null && inventoryItem.getSerialNumber().equals(""))){invalidItemIdSerialNumbers.add(inventoryItem.getItemId());}}if(!fofoLineItem.getSerialNumbers().isEmpty()){if(!fofoLineItem.getSerialNumbers().contains(inventoryItem.getSerialNumber())){if(!itemIdSerialNumbers.containsKey(fofoLineItem.getItemId())){Set<String> serialNumbers = new HashSet<>();serialNumbers.add(inventoryItem.getSerialNumber());itemIdSerialNumbers.put(fofoLineItem.getItemId(), serialNumbers);}else{itemIdSerialNumbers.get(fofoLineItem.getItemId()).add(inventoryItem.getSerialNumber());}}}}}}if(!invalidItemIdSerialNumbers.isEmpty()){LOGGER.error("Invalid itemId's serialNumbers {}", invalidItemIdSerialNumbers);// itemId's are serialized you are saying these are not serializedreturn "error";}if(!itemIdSerialNumbers.isEmpty()){LOGGER.error("Invalid itemId's serialNumbers {}", itemIdSerialNumbers);// itemId's are non serialized you are saying these are serializedreturn "error";}InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = null;try{invoiceNumberGenerationSequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoDetails.getFofoId());invoiceNumberGenerationSequence.setSequence(invoiceNumberGenerationSequence.getSequence() + 1);invoiceNumberGenerationSequenceRepository.persist(invoiceNumberGenerationSequence);}catch(ProfitMandiBusinessException profitMandiBusinessException){invoiceNumberGenerationSequence = new InvoiceNumberGenerationSequence();invoiceNumberGenerationSequence.setFofoId(fofoDetails.getFofoId());invoiceNumberGenerationSequence.setPrefix("INVOICE");invoiceNumberGenerationSequenceRepository.persist(invoiceNumberGenerationSequence);}CustomCustomer customCustomer = createOrderRequest.getCustomer();if(!StringUtils.isValidEmailAddress(customCustomer.getEmailId())){LOGGER.error("invalid customer emailId {} ", customCustomer.getEmailId());return "error";}if(!StringUtils.isValidMobile(customCustomer.getMobileNumber())){LOGGER.error("invalid customer mobileNumber {} ", customCustomer.getMobileNumber());return "error";}Address address = this.createAddress(customCustomer.getAddress());addressRepository.persist(address);Customer customer = null;try{customer = customerRepository.selectByEmailIdAndMobileNumber(customCustomer.getEmailId(), customCustomer.getMobileNumber());}catch(ProfitMandiBusinessException profitMandiBusinessException){LOGGER.error("Error : ", profitMandiBusinessException);customer = new Customer();customer.setEmailId(customCustomer.getEmailId());customer.setMobileNumber(customCustomer.getMobileNumber());customer.setAddressId(address.getId());customerRepository.persist(customer);}/*InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = */FofoOrder fofoOrder = new FofoOrder();fofoOrder.setCustomerId(customer.getId());fofoOrder.setFofoId(fofoDetails.getFofoId());fofoOrder.setInvoiceNumber(invoiceNumberGenerationSequence.getPrefix() + invoiceNumberGenerationSequence.getSequence());fofoOrder.setTotalAmount(totalAmount);fofoOrderRepository.persist(fofoOrder);for(CustomPaymentOption customPaymentOption : createOrderRequest.getPaymentOptions()){PaymentOption paymentOption = new PaymentOption();paymentOption.setOrderId(fofoOrder.getId());paymentOption.setAmount(customPaymentOption.getAmount());paymentOption.setType(customPaymentOption.getType());paymentOptionRepository.persist(paymentOption);}List<Order> orders = orderRepository.selectByRetailerIdItemIds(fofoDetails.getFofoId(), itemIds);Set<Item> items = new HashSet<>(itemIds.size());for(Order order : orders){LineItem lineItem = order.getLineItem();items.add(lineItem.getItem());}if(items.size() != itemIds.size()){LOGGER.error("Requested ItemIds not found in catalog");// invalid itemIdsreturn "error";}Map<Integer, Map<String, String>> itemIdDetails = this.toMap(items);for(CustomFofoLineItem customFofoLineItem : createOrderRequest.getFofoLineItems()){FofoLineItem fofoLineItem = new FofoLineItem();fofoLineItem.setItemId(customFofoLineItem.getItemId());fofoLineItem.setQuantity(customFofoLineItem.getQuantity());fofoLineItem.setSellingPrice(customFofoLineItem.getSellingPrice() * customFofoLineItem.getQuantity());fofoLineItem.setOrderId(fofoOrder.getId());fofoLineItem.setDp(customFofoLineItem.getSellingPrice());Map<String, String> itemIdDetail = itemIdDetails.get(customFofoLineItem.getItemId());fofoLineItem.setBrand(itemIdDetail.get(ProfitMandiConstants.BRAND));fofoLineItem.setModelName(itemIdDetail.get(ProfitMandiConstants.MODEL_NAME));fofoLineItem.setModelNumber(itemIdDetail.get(ProfitMandiConstants.MODEL_NUMBER));fofoLineItem.setColor(itemIdDetail.get(ProfitMandiConstants.COLOR));fofoLineItemRepository.persist(fofoLineItem);LOGGER.info("\n\n");if(!customFofoLineItem.getSerialNumbers().isEmpty()){for(String serialNumber : customFofoLineItem.getSerialNumbers()){FofoLineItemSerialNumber fofoLineItemSerialNumber = new FofoLineItemSerialNumber();fofoLineItemSerialNumber.setFofoLineItemId(fofoLineItem.getId());fofoLineItemSerialNumber.setSerialNumber(serialNumber);fofoLineItemSerialNumberRepository.persist(fofoLineItemSerialNumber);}}for(InventoryItem inventoryItem : inventoryItems){if(inventoryItem.getItemId() == fofoLineItem.getItemId()){if(inventoryItem.getSerialNumber() == null || inventoryItem.getSerialNumber().isEmpty()){if(fofoLineItem.getQuantity() > 0)if(fofoLineItem.getQuantity() <= inventoryItem.getGoodQuantity()){inventoryItem.setGoodQuantity(inventoryItem.getGoodQuantity() - fofoLineItem.getQuantity());inventoryItem.setLastScanType(ScanType.SALE);inventoryItemRepository.persist(inventoryItem);ScanRecord scanRecord = new ScanRecord();scanRecord.setInventoryItemId(inventoryItem.getId());scanRecord.setFofoId(fofoDetails.getFofoId());scanRecord.setQuantity(fofoLineItem.getQuantity());scanRecord.setType(ScanType.SALE);scanRecordRepository.persist(scanRecord);}else{int availableGoodQuantity = inventoryItem.getGoodQuantity();inventoryItem.setGoodQuantity(0);fofoLineItem.setQuantity(fofoLineItem.getQuantity() - availableGoodQuantity);inventoryItem.setLastScanType(ScanType.SALE);inventoryItemRepository.persist(inventoryItem);ScanRecord scanRecord = new ScanRecord();scanRecord.setInventoryItemId(inventoryItem.getId());scanRecord.setFofoId(fofoDetails.getFofoId());scanRecord.setQuantity(availableGoodQuantity);scanRecord.setType(ScanType.SALE);scanRecordRepository.persist(scanRecord);}}else{inventoryItem.setGoodQuantity(0);inventoryItem.setLastScanType(ScanType.SALE);inventoryItemRepository.persist(inventoryItem);ScanRecord scanRecord = new ScanRecord();scanRecord.setInventoryItemId(inventoryItem.getId());scanRecord.setFofoId(fofoDetails.getFofoId());scanRecord.setQuantity(1);scanRecord.setType(ScanType.SALE);scanRecordRepository.persist(scanRecord);}}}}return null;}private Map<Integer, Map<String, String>> toMap(Set<Item> items){Map<Integer, Map<String, String>> map = new HashMap<>();for(Item item : items){Map<String, String> detailMap = new HashMap<>();detailMap.put(ProfitMandiConstants.BRAND, item.getBrand());detailMap.put(ProfitMandiConstants.MODEL_NAME, item.getModelName());detailMap.put(ProfitMandiConstants.MODEL_NUMBER, item.getModelNumber());detailMap.put(ProfitMandiConstants.COLOR, item.getColor());map.put(item.getId(), detailMap);}return map;}private Address createAddress(CustomAddress customAddress){Address address = new Address();address.setName(customAddress.getName());address.setLine1(customAddress.getLine1());address.setLine2(customAddress.getLine2());address.setLandmark(customAddress.getLandmark());address.setCity(customAddress.getCity());address.setPinCode(customAddress.getPinCode());address.setState(customAddress.getState());address.setCountry(customAddress.getCountry());address.setPhoneNumber(customAddress.getPhoneNumber());address.setEnabled(true);return address;}private void validateCreateOrderRequest(CreateOrderRequest createOrderRequest){Set<CustomPaymentOption> customPaymentOptions = createOrderRequest.getPaymentOptions();}private void validatePaymentOptionsAndTotalAmount(Set<CustomPaymentOption> customPaymentOptions, float totalAmount) throws ProfitMandiBusinessException{float calculatedAmount = 0;Set<String> paymentOptionTypes = new HashSet<>();for(CustomPaymentOption customPaymentOption : customPaymentOptions){if(paymentOptionTypes.contains(customPaymentOption.getType().name())){throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_TYPE, customPaymentOption.getType().name(), "");}else{paymentOptionTypes.add(customPaymentOption.getType().name());calculatedAmount = calculatedAmount + customPaymentOption.getAmount();}}if(calculatedAmount != totalAmount){throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_CALCULATED_AMOUNT, calculatedAmount, "");}}}