Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.eclipsesource.json.JsonObject;

import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.enumuration.SchemeType;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.*;

import com.spice.profitmandi.common.solr.SolrService;

import com.spice.profitmandi.common.util.FormattingUtils;

import com.spice.profitmandi.common.util.PdfUtils;

import com.spice.profitmandi.common.util.Utils;

import com.spice.profitmandi.common.web.client.RestClient;

import com.spice.profitmandi.common.web.util.ResponseSender;

import com.spice.profitmandi.dao.entity.catalog.Item;

import com.spice.profitmandi.dao.entity.catalog.TagListing;

import com.spice.profitmandi.dao.entity.dtr.ScratchOffer;

import com.spice.profitmandi.dao.entity.dtr.User;

import com.spice.profitmandi.dao.entity.dtr.WebListing;

import com.spice.profitmandi.dao.entity.dtr.WebOffer;

import com.spice.profitmandi.dao.entity.fofo.*;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

import com.spice.profitmandi.dao.enumuration.dtr.OtpType;

import com.spice.profitmandi.dao.enumuration.dtr.WebListingSource;

import com.spice.profitmandi.dao.enumuration.inventory.ScratchedGift;

import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;

import com.spice.profitmandi.dao.model.*;

import com.spice.profitmandi.dao.repository.catalog.ItemRepository;

import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;

import com.spice.profitmandi.dao.repository.cs.CsService;

import com.spice.profitmandi.dao.repository.dtr.*;

import com.spice.profitmandi.dao.repository.fofo.*;

import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;

import com.spice.profitmandi.dao.repository.user.UserRepository;

import com.spice.profitmandi.service.CustomerService;

import com.spice.profitmandi.service.EmailService;

import com.spice.profitmandi.service.NotificationService;

import com.spice.profitmandi.service.authentication.RoleManager;

import com.spice.profitmandi.service.inventory.*;

import com.spice.profitmandi.service.order.OrderService;

import com.spice.profitmandi.service.scheme.SchemeService;

import com.spice.profitmandi.service.user.RetailerService;

import com.spice.profitmandi.web.processor.OtpProcessor;

import com.spice.profitmandi.web.res.DealBrands;

import com.spice.profitmandi.web.res.DealObjectResponse;

import com.spice.profitmandi.web.res.DealsResponse;

import com.spice.profitmandi.web.res.ValidateCartResponse;

import com.spice.profitmandi.web.services.PartnerIndexService;

import io.swagger.annotations.ApiImplicitParam;

import io.swagger.annotations.ApiImplicitParams;

import io.swagger.annotations.ApiOperation;

import org.apache.commons.lang3.StringUtils;

import org.apache.http.conn.HttpHostConnectException;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.json.JSONArray;

import org.json.JSONObject;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.core.io.InputStreamResource;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.MediaType;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.format.DateTimeFormatter;

import java.util.*;

import java.util.stream.Collectors;

@Controller

@Transactional(rollbackFor = Throwable.class)

public class StoreController {

	private static final Logger logger = LogManager.getLogger(StoreController.class);

	private static final LocalTime CUTOFF_TIME = LocalTime.of(15, 0);

	private static final List<Integer> TAG_IDS = Arrays.asList(4);

	@Autowired

	CustomerAddressRepository customerAddressRepository;

	@Autowired

	WebOfferRepository webOfferRepository;

	@Value("${new.solr.url}")

	private String solrUrl;

	@Autowired

	private PartnerIndexService partnerIndexService;

	@Autowired

	InventoryService inventoryService;

	@Autowired

	UserAccountRepository userAccountRepository;

	@Value("${python.api.host}")

	private String host;

	@Autowired

	CustomerService customerService;

	@Value("${python.api.port}")

	private int port;

	@Autowired

	private SaholicInventoryService saholicInventoryService;

	@Autowired

	private PincodePartnerRepository pincodePartnerRepository;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Autowired

	private RetailerService retailerService;

	@Autowired

	private PendingOrderRepository pendingOrderRepository;

	@Autowired

	private PendingOrderItemRepository pendingOrderItemRepository;

	@Autowired

	private PendingOrderService pendingOrderService;

	@Autowired

	private CustomerRepository customerRepository;

	@Autowired

	private SolrService commonSolrService;

	@Autowired

	private OtpProcessor otpProcessor;

	@Autowired

	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;

	@Autowired

	private ResponseSender<?> responseSender;

	@Autowired

	private TagListingRepository tagListingRepository;

	@Autowired

	private ItemRepository itemRepository;

	@Autowired

	private SchemeService schemeService;

	@Autowired

	private UserRepository userRepository;

	@Autowired

	private ItemAvailabilityCacheRepository itemAvailabilityCacheRepository;

	@Autowired

	private WebListingRepository webListingRepository;

	@Autowired

	private WebProductListingRepository webProductListingRepository;

	@Autowired

	private RoleManager roleManagerService;

	@Autowired

	EmailService emailService;

	@Autowired

	CsService csService;

	@Autowired

	private NotificationService notificationService;

	@Autowired

	private com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;

	@Autowired

	private FofoOrderRepository fofoOrderRepository;

	@Autowired

	private FofoOrderItemRepository fofoOrderItemRepository;

	@Autowired

	private OrderService orderService;

	@Autowired

	private ScratchOfferRepository scratchOfferRepository;

	private static final List<String> offlineOrders = Arrays.asList("EMIOD", "POD");

	List<String> filterableParams = Arrays.asList("brand");

	@RequestMapping(value = "/store/entity/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get unit deal object")

	public ResponseEntity<?> getUnitFocoDeal(HttpServletRequest request, @PathVariable(value = "id") long id)

			throws ProfitMandiBusinessException {

		List<FofoCatalogResponse> dealResponses = new ArrayList<>();

		List<Integer> tagIds = Arrays.asList(4);

		FofoCatalogResponse fofoCatalogResponse = null;

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		if (roleManagerService.isPartner(userInfo.getRoleIds())) {

			String categoryId = "(3 OR 6)";

			RestClient rc = new RestClient();

			Map<String, String> params = new HashMap<>();

			List<String> mandatoryQ = new ArrayList<>();

			String catalogString = "catalog" + id;

			mandatoryQ.add(String.format("+(categoryId_i:%s) +(id:%s) +{!parent which=\"id:%s\"} tagId_i:(%s)",

					categoryId, catalogString, catalogString, StringUtils.join(tagIds, " ")));

			params.put("q", StringUtils.join(mandatoryQ, " "));

			params.put("fl", "*, [child parentFilter=id:catalog*]");

			params.put("sort", "rank_i asc, create_s desc");

			params.put("wt", "json");

			String response = null;

			try {

				response = rc.get(SchemeType.HTTP, solrUrl, 8984, "solr/demo/select", params);

			} catch (HttpHostConnectException e) {

				throw new ProfitMandiBusinessException("", "", "Could not connect to host");

			}

			JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");

			JSONArray docs = solrResponseJSONObj.getJSONArray("docs");

			dealResponses = getCatalogResponse(docs, false, userInfo.getRetailerId());

			fofoCatalogResponse = dealResponses.get(0);

			fofoCatalogResponse

					.setWebOffers(webOfferRepository.selectAllActiveOffers().get(fofoCatalogResponse.getCatalogId()));

		} else {

			return responseSender.badRequest(

					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));

		}

		return responseSender.ok(dealResponses.get(0));

	}

	private Object toDealObject(JsonObject jsonObject) {

		if (jsonObject.get("dealObject") != null && jsonObject.get("dealObject").asInt() == 1) {

			return new Gson().fromJson(jsonObject.toString(), DealObjectResponse.class);

		}

		return new Gson().fromJson(jsonObject.toString(), DealsResponse.class);

	}

	@RequestMapping(value = "/store/brands", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> getBrands(HttpServletRequest request,

			@RequestParam(value = "category_id") String category_id) throws ProfitMandiBusinessException {

		logger.info("Request " + request.getParameterMap());

		String response = null;

		// TODO: move to properties

		String uri = ProfitMandiConstants.URL_BRANDS;

		RestClient rc = new RestClient();

		Map<String, String> params = new HashMap<>();

		params.put("category_id", category_id);

		List<DealBrands> dealBrandsResponse = null;

		try {

			response = rc.get(SchemeType.HTTP, host, port, uri, params);

		} catch (HttpHostConnectException e) {

			throw new ProfitMandiBusinessException("", "", "Could not connect to host");

		}

		dealBrandsResponse = new Gson().fromJson(response, new TypeToken<List<DealBrands>>() {

		}.getType());

		return responseSender.ok(dealBrandsResponse);

	}

	@RequestMapping(value = "/store/listing/{listingUrl}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> bestSellers(HttpServletRequest request, @PathVariable String listingUrl) throws Exception {

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		WebListing webListing = webListingRepository.selectByUrl(listingUrl);

		webListing.setFofoCatalogResponses(getDealResponses(userInfo, webListing));

		return responseSender.ok(webListing);

	}

	@RequestMapping(value = "/store/otp/generateOTP", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> generateOtp(HttpServletRequest request, @RequestParam String mobile) throws Exception {

		return responseSender.ok(otpProcessor.generateOtp(mobile, OtpType.REGISTRATION));

	}

	@RequestMapping(value = "/store/checkmobile/{mobile}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> checkRegistrationUsingMobile(HttpServletRequest request, @PathVariable String mobile)

			throws Exception {

		try {

			Customer customer = customerRepository.selectByMobileNumber(mobile);

			customer.setPasswordExist(StringUtils.isNotEmpty(customer.getPassword()));

			return responseSender.ok(new CustomerModel(true, customer));

		} catch (Exception e) {

			return responseSender.ok(new CustomerModel(false, null));

		}

	}

	@RequestMapping(value = "/store/signin", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> signIn(HttpServletRequest request, @RequestBody UserModel userModel) throws Exception {

		if (customerService.authenticate(userModel.getMobile(), userModel.getPassword())) {

			return responseSender.ok(true);

		} else {

			return responseSender.ok(false);

		}

	}

	@RequestMapping(value = "/store/resetPassword", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> resetPassword(HttpServletRequest request, @RequestBody UserModel userModel)

			throws Exception {

		customerService.changePassword(userModel.getMobile(), userModel.getPassword());

		return responseSender.ok(true);

	}

	@RequestMapping(value = "/store/register", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> register(HttpServletRequest request, @RequestBody UserModel userModel) throws Exception {

		Customer customer = new Customer();

		customer.setPassword(userModel.getPassword());

		customer.setEmailId(userModel.getEmail());

		customer.setFirstName(userModel.getFirstName());

		customer.setLastName(userModel.getLastName());

		customer.setMobileNumber(userModel.getMobile());

		return responseSender.ok(customerService.addCustomer(customer));

	}

	@RequestMapping(value = "/store/confirmOrder", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> confirmOrder(HttpServletRequest request,

			@RequestBody CreatePendingOrderRequest createPendingOrderRequest) throws Exception {

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		Integer storeId = userInfo.getRetailerId();

		createPendingOrderRequest.setFofoId(storeId);

		List<CreatePendingOrderItem> pendingOrderItems = createPendingOrderRequest.getCreatePendingOrderItem();

		List<CartItem> cartItems = new ArrayList<>();

		pendingOrderItems.stream().forEach(x -> {

			CartItem ci = new CartItem();

			ci.setItemId(x.getItemId());

			ci.setQuantity(x.getQuantity());

			ci.setSellingPrice(x.getSellingPrice());

			cartItems.add(ci);

		});

		CartResponse cr = this.validateCart(storeId, cartItems);

		if (cr.getCartMessageChanged() > 0 || cr.getTotalAmount() != createPendingOrderRequest.getTotalAmount()) {

			return responseSender.badRequest("Invalid request");

		}

		Map<String, String> returnMap = this.pendingOrderService.createPendingOrder(createPendingOrderRequest, cr);

		PendingOrder pendingOrder = pendingOrderRepository.selectById(Integer.parseInt(returnMap.get("poId")));

		if (offlineOrders.contains(pendingOrder.getPayMethod())) {

			Map<String, Object> emailModel = pendingOrderService.sendCreateOrderMail(pendingOrder);

			CustomRetailer customRetailer = retailerService.getFofoRetailer(pendingOrder.getFofoId());

			Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());

			String[] customerEmail = null;

			if (Utils.validateEmail(customer.getEmailId())) {

				customerEmail = new String[] { customer.getEmailId() };

			}

			List<String> bccTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com",

					"niranjan.kala@smartdukaan.com", "sm@smartdukaan.com", "tejbeer.kaur@shop2020.in",

					"devkinandan.lal@smartdukaan.com", customRetailer.getEmail());

			List<String> authUserEmails = csService.getAuthUserByPartnerId(customRetailer.getPartnerId());

			if (authUserEmails != null) {

				authUserEmails = new ArrayList<>();

			}

			logger.info("authUserEmails {}", authUserEmails);

			authUserEmails.addAll(bccTo);

			StringBuffer itemBuffer = new StringBuffer();

			List<PendingOrderItem> orderItems = pendingOrderItemRepository.selectByOrderId(pendingOrder.getId());

			int totalItems = 0;

			String itemNoColor = null;

			float maxValue = 0;

			for (PendingOrderItem orderItem : orderItems) {

				if (maxValue < orderItem.getSellingPrice()) {

					maxValue = orderItem.getSellingPrice();

					itemNoColor = itemRepository.selectById(orderItem.getItemId()).getItemDescriptionNoColor();

				}

				totalItems += orderItem.getQuantity();

			}

			if (totalItems > 1) {

				itemBuffer.append(StringUtils.abbreviate(itemNoColor, 22));

				itemBuffer.append(" +").append(totalItems - 1).append(" items");

			} else {

				itemBuffer.append(StringUtils.abbreviate(itemNoColor, 30));

			}

			String message = String.format(OtpProcessor.TEMPLATE_ORDER_CREATED, pendingOrder.getId(),

					itemBuffer.toString(), pendingOrder.getTotalAmount());

			otpProcessor.sendSms(OtpProcessor.TEMPLATE_ORDER_CREATED_ID, message, customer.getMobileNumber());

			emailService.sendMailWithAttachments("Order Created with SmartDukaan", "order-confirm.vm", emailModel,

					customerEmail, null, bccTo.toArray(new String[0]));

			List<String> emailIds = csService.getAuthUserIdByPartnerId(customRetailer.getPartnerId()).stream()

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

			emailIds.addAll(

					csService

							.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_MARKETING,

									Arrays.asList(EscalationType.L1, EscalationType.L2, EscalationType.L3,

											EscalationType.L4))

							.stream().map(x -> x.getEmailId()).collect(Collectors.toList()));

			emailIds.add("tarun.verma@smartdukaan.com");

			emailIds.add("devkinandan.lal@smartdukaan.com");

			emailIds.add("tejbeer.kaur@shop2020.in");

			List<User> user = dtrUserRepository.selectAllByEmailIds(emailIds);

			List<Integer> userIds = user.stream().map(x -> x.getId()).collect(Collectors.toList());

			logger.info("userIds" + userIds);

			SendNotificationModel sendNotificationModel = new SendNotificationModel();

			sendNotificationModel.setCampaignName("Online Order Alert");

			sendNotificationModel.setTitle("Online Order Update");

			sendNotificationModel.setMessage(String.format(

					"You have new Online Order. Please check your Dashboard. In case of an activation scheme pls ensure the handset is activated, payout will be processed as per brand's activation report."));

			sendNotificationModel.setType("url");

			sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));

			sendNotificationModel.setMessageType(MessageType.notification);

			int userId = userAccountRepository.selectUserIdByRetailerId(pendingOrder.getFofoId());

			sendNotificationModel.setUserIds(Arrays.asList(userId));

			notificationService.sendNotification(sendNotificationModel);

			SendNotificationModel snm = new SendNotificationModel();

			snm.setCampaignName("Online Order Alert");

			snm.setTitle("Online Order Update");

			snm.setMessage(String.format("Your Partner " + customRetailer.getBusinessName()

					+ " have new Online Order. Please inform your partner. In case of an activation scheme pls ensure the handset is activated, payout will be processed as per brand's activation report."));

			snm.setType("url");

			snm.setUrl("https://app.smartdukaan.com/pages/home/notifications");

			snm.setExpiresat(LocalDateTime.now().plusDays(1));

			snm.setMessageType(MessageType.notification);

			snm.setUserIds(userIds);

			notificationService.sendNotification(snm);

		}

		return responseSender.ok(returnMap);

	}

	@RequestMapping(value = "/store/address", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> getAddress(HttpServletRequest request) throws Exception {

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		Integer storeId = userInfo.getRetailerId();

		CustomRetailer customRetailer = retailerService.getFofoRetailer(storeId);

		return responseSender.ok(customRetailer.getAddress());

	}

	@RequestMapping(value = "/store/address/{pincode}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> getStoresByPincode(HttpServletRequest request, @PathVariable String pincode)

			throws Exception {

		List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);

		int fofoId = ProfitMandiConstants.DEFAULT_STORE;

		if (pincodePartners.size() > 0) {

			List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId()).collect(Collectors.toList());

			List<FofoStore> fofoStores = fofoStoreRepository.selectActivePartnersByRetailerIds(fofoIds);

			if (fofoStores.size() > 0) {

				fofoId = fofoStores.get(0).getId();

			}

		}

		return responseSender.ok(fofoStoreRepository.selectByRetailerId(fofoId).getCode());

	}

	@RequestMapping(value = "/store/addresses", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> getStoresByPincod(HttpServletRequest request, @RequestParam String pincode,

			@RequestParam(name = "fofoCode", defaultValue = "", required = false) String fofoCode) throws Exception {

		List<CustomRetailer> customerRetailers = new ArrayList<>();

		logger.info("fofoCode" + fofoCode);

		if (fofoCode != null) {

			FofoStore fs = fofoStoreRepository.selectByStoreCode(fofoCode.toUpperCase());

			PincodePartner pp = pincodePartnerRepository.selectPartnerByPincode(pincode, fs.getId());

			if (pp != null) {

				return responseSender.ok(customerRetailers.add(retailerService.getFofoRetailer(pp.getFofoId())));

			} else {

				List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);

				if (pincodePartners.size() > 0) {

					List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId())

							.collect(Collectors.toList());

					List<Integer> activefofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()

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

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

					Map<Integer, CustomRetailer> customerRetailerMap = activefofoIds.stream()

							.map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList())

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

					customerRetailers.addAll(customerRetailerMap.values());

				}

				return responseSender.ok(customerRetailers);

			}

		} else {

			List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);

			if (pincodePartners.size() > 0) {

				List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId()).collect(Collectors.toList());

				List<Integer> activefofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()

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

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

				Map<Integer, CustomRetailer> customerRetailerMap = activefofoIds.stream()

						.map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream()

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

				customerRetailers.addAll(customerRetailerMap.values());

			}

			return responseSender.ok(customerRetailers);

		}

	}

	@RequestMapping(value = "/store/address/detail/{pincode}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> getStoresDetailsByPincode(HttpServletRequest request, @PathVariable String pincode)

			throws Exception {

		List<CustomRetailer> customerRetailers = new ArrayList<>();

		List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);

		if (!pincodePartners.isEmpty()) {

			List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId()).collect(Collectors.toList());

			List<Integer> activefofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()

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

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

			Map<Integer, CustomRetailer> customerRetailerMap = activefofoIds.stream().map(x -> customRetailerMap.get(x))

					.filter(x -> x != null).collect(Collectors.toList()).stream()

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

			customerRetailers.addAll(customerRetailerMap.values());

		}

		logger.info("customerRetailers" + customerRetailers);

		return responseSender.ok(customerRetailers);

	}

	@RequestMapping(value = "/store/order", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> getOrderDetail(HttpServletRequest request, @RequestParam(value = "id") int id,

			@RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {

		List<CustomerOrderDetail> customerOrderDetails = new ArrayList<>();

		List<Integer> catalogIds = new ArrayList<>();

		List<PendingOrder> pendingOrders = pendingOrderRepository.selectByCustomerId(id, offset, limit);

		if (!pendingOrders.isEmpty()) {

			for (PendingOrder po : pendingOrders) {

				List<PendingOrderItem> pois = pendingOrderItemRepository.selectByOrderId(po.getId());

				for (PendingOrderItem pendingOrderItem : pois) {

					Item item = itemRepository.selectById(pendingOrderItem.getItemId());

					pendingOrderItem.setItemName(item.getItemDescription());

					catalogIds.add(item.getCatalogItemId());

				}

				Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);

				for (PendingOrderItem poi : pois) {

					CustomerOrderDetail customerOrderDetail = new CustomerOrderDetail();

					Item item = itemRepository.selectById(poi.getItemId());

					JSONObject jsonObj = contentMap.get(item.getCatalogItemId());

					customerOrderDetail.setImageUrl(jsonObj.getString("imageUrl_s"));

					customerOrderDetail.setBrand(item.getBrand());

					customerOrderDetail.setColor(item.getColor());

					customerOrderDetail.setPendingOrderItemId(poi.getId());

					customerOrderDetail.setId(poi.getOrderId());

					customerOrderDetail.setItemId(poi.getItemId());

					customerOrderDetail.setModelName(item.getModelName());

					customerOrderDetail.setModelNumber(item.getModelNumber());

					customerOrderDetail.setQuantity(poi.getQuantity());

					customerOrderDetail.setBilledTimestamp(poi.getBilledTimestamp());

					customerOrderDetail.setStatus(poi.getStatus());

					customerOrderDetail.setTotalPrice(poi.getSellingPrice());

					customerOrderDetail.setPayMethod(po.getPayMethod());

					customerOrderDetail.setCreatedTimeStamp(po.getCreateTimestamp());

					customerOrderDetails.add(customerOrderDetail);

				}

			}

		}

		return responseSender.ok(customerOrderDetails);

	}

	@RequestMapping(value = "/store/invoiceOrder", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> getOrderInvoiceDetail(HttpServletRequest request, @RequestParam(value = "id") int id,

			@RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {

		List<CustomerOrderDetail> customerOrderDetails = new ArrayList<>();

		List<Integer> catalogIds = new ArrayList<>();

		List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByCustomerId(id, offset, limit);

		if (!fofoOrders.isEmpty()) {

			for (FofoOrder fo : fofoOrders) {

				List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fo.getId());

				for (FofoOrderItem fofoOrderItem : fofoOrderItems) {

					Item item = itemRepository.selectById(fofoOrderItem.getItemId());

					fofoOrderItem.setItemName(item.getItemDescription());

					catalogIds.add(item.getCatalogItemId());

				}

				Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);

				for (FofoOrderItem foi : fofoOrderItems) {

					CustomerOrderDetail customerOrderDetail = new CustomerOrderDetail();

					Item item = itemRepository.selectById(foi.getItemId());

					JSONObject jsonObj = contentMap.get(item.getCatalogItemId());

					customerOrderDetail.setImageUrl(jsonObj.getString("imageUrl_s"));

					customerOrderDetail.setBrand(item.getBrand());

					customerOrderDetail.setColor(item.getColor());

					customerOrderDetail.setFofoOrderItemId(foi.getId());

					customerOrderDetail.setFofoOrderId(foi.getOrderId());

					customerOrderDetail.setItemId(foi.getItemId());

					customerOrderDetail.setModelName(item.getModelName());

					customerOrderDetail.setModelNumber(item.getModelNumber());

					customerOrderDetail.setQuantity(foi.getQuantity());

					customerOrderDetail.setTotalPrice(foi.getSellingPrice());

					customerOrderDetail.setCreatedTimeStamp(foi.getCreateTimestamp());

					customerOrderDetail.setInvoiceNumber(fo.getInvoiceNumber());

					customerOrderDetail.setCancelledTimestamp(fo.getCancelledTimestamp());

					customerOrderDetails.add(customerOrderDetail);

				}

			}

		}

		return responseSender.ok(customerOrderDetails);

	}

	@RequestMapping(value = "/store/generateInvoice", method = RequestMethod.GET)

	public ResponseEntity<?> generateInvoice(HttpServletRequest request,

			@RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {

		InvoicePdfModel pdfModel = null;

		FofoOrder fo = fofoOrderRepository.selectByOrderId(orderId);

		pdfModel = orderService.getInvoicePdfModel(fo.getFofoId(), orderId);

		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

		PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);

		try {

			byteArrayOutputStream.close();

		} catch (IOException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

		final HttpHeaders headers = new HttpHeaders();

		headers.setContentType(MediaType.APPLICATION_PDF);

		// headers.setCacheControl("must-revalidate, post-check=0, pre-check=0");

		headers.setContentType(MediaType.parseMediaType("application/pdf"));

		headers.set("Content-disposition", "inline; filename=invoice-" + pdfModel.getInvoiceNumber() + ".pdf");

		headers.add("Cache-Control", "no-cache, no-store, must-revalidate");

		headers.add("Pragma", "no-cache");

		headers.add("Expires", "0");

		headers.setContentLength(byteArrayOutputStream.toByteArray().length);

		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());

		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

		return new ResponseEntity<>(inputStreamResource, headers, HttpStatus.OK);

		// return responseSender.ok(new

		// ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(),

		// headers,HttpStatus.OK));

		/*

		 * ResponseEntity<byte[]> response = new

		 * ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(), headers,

		 * HttpStatus.OK); return response;

		 */

	}

	@RequestMapping(value = "/store/listing", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> getStoresListing(HttpServletRequest request) throws Exception {

		List<WebListing> webListings = webListingRepository.selectAllWebListingByType(Optional.of(true),

				WebListingSource.store);

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		for (WebListing webListing : webListings) {

			webListing.setFofoCatalogResponses(getDealResponses(userInfo, webListing));

		}

		return responseSender.ok(webListings);

	}

	private List<FofoCatalogResponse> getDealResponses(UserInfo userInfo, WebListing webListing)

			throws ProfitMandiBusinessException {

		List<Integer> webProducts = webProductListingRepository.selectAllByWebListingId(webListing.getId()).stream()

				.filter(x -> x.getRank() > 0).map(x -> x.getEntityId()).collect(Collectors.toList());

		if (webProducts.size() == 0) {

			return new ArrayList<>();

		}

		RestClient rc = new RestClient();

		Map<String, String> params = new HashMap<>();

		List<String> mandatoryQ = new ArrayList<>();

		mandatoryQ.add(String.format(

				"+{!parent which=\"catalogId_i:" + StringUtils.join(webProducts, " ") + "\"} tagId_i:(%s)",

				StringUtils.join(TAG_IDS, " ")));

		params.put("q", StringUtils.join(mandatoryQ, " "));

		params.put("fl", "*, [child parentFilter=id:catalog*]");

		// params.put("sort", "create_s desc");

		params.put("start", String.valueOf(0));

		params.put("rows", String.valueOf(100));

		params.put("wt", "json");

		String response = null;

		try {

			response = rc.get(SchemeType.HTTP, "50.116.10.120", 8984, "solr/demo/select", params);

		} catch (HttpHostConnectException e) {

			throw new ProfitMandiBusinessException("", "", "Could not connect to host");

		}

		JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");

		JSONArray docs = solrResponseJSONObj.getJSONArray("docs");

		List<FofoCatalogResponse> dealResponse = getCatalogResponse(docs, false, userInfo.getRetailerId());

		return dealResponse;

	}

	@RequestMapping(value = "/store/cart", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	@ApiOperation(value = "Get brand list and count for category")

	public ResponseEntity<?> cart(HttpServletRequest request, @RequestBody AddCartRequest cartRequest)

			throws Exception {

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		Integer storeId = userInfo.getRetailerId();

		ValidateCartResponse vc = new ValidateCartResponse(this.validateCart(storeId, cartRequest.getCartItems()),

				"Success", "Items added to cart successfully");

		return responseSender.ok(vc);

	}

	// Validate Cart for B2C Customers

	private CartResponse validateCart(int storeId, List<CartItem> cartItems) throws Exception {

		cartItems = cartItems.stream().filter(x -> x.getQuantity() > 0).collect(Collectors.toList());

		List<Integer> itemIds = cartItems.stream().map(x -> x.getItemId()).collect(Collectors.toList());

		Map<Integer, AvailabilityModel> inventoryItemAvailabilityMap = inventoryService.getStoreAndOurStock(storeId,

				itemIds);

		CartResponse cartResponse = new CartResponse();

		List<CartItemResponseModel> cartItemResponseModels = new ArrayList<>();

		cartResponse.setCartItems(cartItemResponseModels);

		Set<Integer> itemsIdsSet = new HashSet<>(itemIds);

		logger.info("Store Id {}, Item Ids {}", storeId, itemsIdsSet);

		Map<Integer, Item> itemsMap = itemRepository.selectByIds(itemsIdsSet).stream()

				.collect(Collectors.toMap(x -> x.getId(), x -> x));

		Map<Integer, TagListing> tagListingMap = tagListingRepository

				.selectByItemIdsAndTagIds(new HashSet<>(itemIds), new HashSet<>(Arrays.asList(4))).stream()

				.collect(Collectors.toMap(x -> x.getItemId(), x -> x));

		List<Integer> catalogIds = itemsMap.values().stream().map(x -> x.getCatalogItemId())

				.collect(Collectors.toList());

		Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);

		// cartResponse.getCartItems()

		int cartMessageChanged = 0;

		int cartMessageOOS = 0;

		int totalAmount = 0;

		int totalQty = 0;

		for (CartItem cartItem : cartItems) {

			Item item = itemsMap.get(cartItem.getItemId());

			TagListing tagListing = tagListingMap.get(cartItem.getItemId());

			Float cashback = schemeService.getCatalogSchemeCashBack()

					.get(itemsMap.get(cartItem.getItemId()).getCatalogItemId());

			cashback = cashback == null ? 0 : cashback;

			float itemSellingPrice = tagListing.getMop() - cashback;

			CartItemResponseModel cartItemResponseModel = new CartItemResponseModel();

			cartItemResponseModel.setSellingPrice(cartItem.getSellingPrice());

			if (itemSellingPrice != cartItem.getSellingPrice()) {

				cartItemResponseModel.setSellingPrice(itemSellingPrice);

				cartMessageChanged++;

			}

			int estimate = -2;

			LocalDateTime promiseDeliveryTime = LocalDateTime.now();

			int qtyRequired = (int) cartItem.getQuantity();

			AvailabilityModel availabilityModel = inventoryItemAvailabilityMap.get(cartItem.getItemId());

			cartItemResponseModel.setMaxQuantity(availabilityModel.getMaxAvailability());

			if (availabilityModel.getStoreAvailability() >= qtyRequired) {

				estimate = 0;

			} else if (availabilityModel.getWarehouseAvailability() >= qtyRequired) {

				estimate = 2;

			} else if (availabilityModel.getStoreAvailability() > 0) {

				estimate = 0;

				qtyRequired = availabilityModel.getStoreAvailability();

				cartMessageChanged++;

			} else if (availabilityModel.getWarehouseAvailability() > 0) {

				qtyRequired = availabilityModel.getWarehouseAvailability();

				estimate = 2;

				cartMessageChanged++;

			} else {

				qtyRequired = 0;

				cartMessageChanged++;

			}

			cartItemResponseModel.setQuantity(qtyRequired);

			if (estimate >= 0 && LocalTime.now().isAfter(CUTOFF_TIME)) {

				estimate = estimate + 1;

				promiseDeliveryTime = promiseDeliveryTime.plusDays(3);

			}

			totalQty += qtyRequired;

			totalAmount += qtyRequired * itemSellingPrice;

			cartItemResponseModel.setEstimate(estimate);

			cartItemResponseModel.setTitle(item.getItemDescriptionNoColor());

			cartItemResponseModel.setItemId(cartItem.getItemId());

			cartItemResponseModel.setMinBuyQuantity(1);

			cartItemResponseModel.setQuantity(qtyRequired);

			cartItemResponseModel.setQuantityStep(1);

			cartItemResponseModel.setPromiseDelivery(promiseDeliveryTime);

			cartItemResponseModel.setMaxQuantity(availabilityModel.getMaxAvailability());

			cartItemResponseModel.setCatalogItemId(item.getCatalogItemId());

			cartItemResponseModel.setImageUrl(contentMap.get(item.getCatalogItemId()).getString("imageUrl_s"));

			cartItemResponseModel.setColor(item.getColor());

			cartItemResponseModels.add(cartItemResponseModel);

		}

		cartResponse.setCartItems(cartItemResponseModels);

		cartResponse.setCartMessageChanged(cartMessageChanged);

		cartResponse.setCartMessageOOS(cartMessageOOS);

		int maxEstimate = cartItemResponseModels.stream().mapToInt(x -> x.getEstimate()).max().getAsInt();

		cartResponse.setMaxEstimate(maxEstimate);

		cartResponse.setTotalAmount(totalAmount);

		cartResponse.setTotalQty(totalQty);

		return cartResponse;

	}

	@RequestMapping(value = "/store/partnerStock", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	public ResponseEntity<?> partnerStock(HttpServletRequest request,

			@RequestParam(value = "categoryId", required = false, defaultValue = "3") String categoryId,

			@RequestParam(value = "offset") String offset, @RequestParam(value = "limit") String limit,

			@RequestParam(value = "sort", required = false) String sort,

			@RequestParam(value = "brand", required = false) String brand,

			@RequestParam(value = "subCategoryId", required = false) int subCategoryId,

			@RequestParam(value = "q", required = false) String queryTerm,

			@RequestParam(required = false) String listing,

			@RequestParam(required = false, defaultValue = "true") boolean partnerStockOnly) throws Throwable {

		List<FofoCatalogResponse> dealResponse = new ArrayList<>();

		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");

		FofoStore fs = fofoStoreRepository.selectByRetailerId(userInfo.getRetailerId());

		sort = "w" + fs.getWarehouseId() + "_i desc";

		dealResponse = this.getCatalogResponse(

				commonSolrService.getSolrDocs(queryTerm, categoryId, offset, limit, sort, brand, subCategoryId, false),

				false, userInfo.getRetailerId());

		return responseSender.ok(dealResponse);

	}

	private List<FofoCatalogResponse> getCatalogResponse(JSONArray docs, boolean hotDeal, int fofoId)

			throws ProfitMandiBusinessException {

		Map<Integer, Integer> ourItemAvailabilityMap = null;

		Map<Integer, Integer> partnerStockAvailabilityMap = null;

		List<FofoCatalogResponse> dealResponse = new ArrayList<>();

		List<Integer> tagIds = Arrays.asList(4);

		if (docs.length() > 0) {

			HashSet<Integer> itemsSet = new HashSet<>();

			for (int i = 0; i < docs.length(); i++) {

				JSONObject doc = docs.getJSONObject(i);

				if (doc.has("_childDocuments_")) {

					for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {

						JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);

						int itemId = childItem.getInt("itemId_i");

						itemsSet.add(itemId);

					}

				}

			}

			if (itemsSet.size() == 0) {

				return dealResponse;

			}

			if (fofoId > 0) {

				partnerStockAvailabilityMap = currentInventorySnapshotRepository.selectItemsStock(fofoId).stream()

						.collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));

			}

			ourItemAvailabilityMap = saholicInventoryService.getTotalAvailabilityByItemIds(new ArrayList<>(itemsSet));

		}

		for (int i = 0; i < docs.length(); i++) {

			Map<Integer, FofoAvailabilityInfo> fofoAvailabilityInfoMap = new HashMap<>();

			JSONObject doc = docs.getJSONObject(i);

			FofoCatalogResponse ffdr = new FofoCatalogResponse();

			ffdr.setCatalogId(doc.getInt("catalogId_i"));

			ffdr.setImageUrl(doc.getString("imageUrl_s"));

			ffdr.setTitle(doc.getString("title_s"));

			List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers().get(ffdr.getCatalogId());

			if (webOffers != null && webOffers.size() > 0) {

				ffdr.setOffers(webOffers.stream().map(x -> x.getTitle()).collect(Collectors.toList()));

			}

			try {

				ffdr.setFeature(doc.getString("feature_s"));

			} catch (Exception e) {

				ffdr.setFeature(null);

			}

			ffdr.setBrand(doc.getJSONArray("brand_ss").getString(0));

			if (doc.has("_childDocuments_")) {

				for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {

					JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);

					int itemId = childItem.getInt("itemId_i");

					float sellingPrice = (float) childItem.getDouble("sellingPrice_f");

					if (fofoAvailabilityInfoMap.containsKey(itemId)) {

						if (fofoAvailabilityInfoMap.get(itemId).getSellingPrice() > sellingPrice) {

							fofoAvailabilityInfoMap.get(itemId).setSellingPrice(sellingPrice);

							fofoAvailabilityInfoMap.get(itemId).setMop((float) childItem.getDouble("mop_f"));

						}

					} else {

						FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();

						fdi.setSellingPrice(sellingPrice);

						fdi.setMrp(childItem.getDouble("mrp_f"));

						fdi.setMop((float) childItem.getDouble("mop_f"));

						fdi.setColor(childItem.has("color_s") ? childItem.getString("color_s") : "");

						fdi.setTagId(childItem.getInt("tagId_i"));

						fdi.setItem_id(itemId);

						Float cashBack = schemeService.getCatalogSchemeCashBack().get(ffdr.getCatalogId());

						cashBack = cashBack == null ? 0 : cashBack;

						// TODO:Dont commit

						// fdi.setCashback(Math.min(100, fdi.getMop()));

						fdi.setCashback(cashBack);

						fdi.setMinBuyQuantity(1);

						int partnerAvailability = partnerStockAvailabilityMap.get(itemId) == null ? 0

								: partnerStockAvailabilityMap.get(itemId);

						int ourStockAvailability = ourItemAvailabilityMap.get(itemId) == null ? 0

								: Math.max(0, ourItemAvailabilityMap.get(itemId));

						fdi.setActive(partnerAvailability > 0);

						// fdi.setActive(true);

						fdi.setAvailability(Math.min(5, ourStockAvailability + partnerAvailability));

						fdi.setQuantityStep(1);

						fdi.setMaxQuantity(fdi.getAvailability());

						fofoAvailabilityInfoMap.put(itemId, fdi);

					}

				}

			}

			if (fofoAvailabilityInfoMap.values().size() > 0) {

				ffdr.setItems(fofoAvailabilityInfoMap.values().stream()

						.sorted(Comparator.comparing(FofoAvailabilityInfo::isActive, Comparator.reverseOrder())

								.thenComparingInt(y -> -y.getAvailability()))

						.collect(Collectors.toList()));

				dealResponse.add(ffdr);

			}

		}

		return dealResponse.stream()