Subversion Repositories SmartDukaan

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

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

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

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

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

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

	private String host;

    private String host;

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

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

	private String solrUrl;

    private String solrUrl;

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

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

	private int port;

    private int port;

	@Autowired

    @Autowired

	RestClient restClient;

    RestClient restClient;

	@Autowired

    @Autowired

	SolrService solrService;

    SolrService solrService;

	@Autowired

    @Autowired

	InventoryService inventoryService;

    InventoryService inventoryService;

	// This is now unused as we are not supporting multiple companies.

    // This is now unused as we are not supporting multiple companies.

	@Value("${gadgetCops.invoice.cc}")

    @Value("${gadgetCops.invoice.cc}")

	private String[] ccGadgetCopInvoiceTo;

    private String[] ccGadgetCopInvoiceTo;

	@Autowired

    @Autowired

	private PricingService pricingService;

    private PricingService pricingService;

	@Autowired

    @Autowired

	private CategoryRepository categoryRepository;

    private CategoryRepository categoryRepository;

	@Autowired

    @Autowired

	private SchemeService schemeService;

    private SchemeService schemeService;

	@Autowired

    @Autowired

	private SaholicInventoryService saholicInventoryService;

    private SaholicInventoryService saholicInventoryService;

	@Autowired

    @Autowired

	private Mongo mongoClient;

    private Mongo mongoClient;

	@Autowired

    @Autowired

	private ItemBucketService itemBucketService;

    private ItemBucketService itemBucketService;

	@Autowired

    @Autowired

	private UserAccountRepository userAccountRepository;

    private UserAccountRepository userAccountRepository;

	@Autowired

    @Autowired

	private FofoStoreRepository fofoStoreRepository;

    private FofoStoreRepository fofoStoreRepository;

	@Autowired

    @Autowired

	private ResponseSender<?> responseSender;

    private ResponseSender<?> responseSender;

	@Autowired

    @Autowired

	private TagListingRepository tagListingRepository;

    private TagListingRepository tagListingRepository;

	@Autowired

    @Autowired

	private ItemRepository itemRepository;

    private ItemRepository itemRepository;

	@Autowired

    @Autowired

	private PriceCircularService priceCircularService;

    private PriceCircularService priceCircularService;

	@Autowired

    @Autowired

	private RoleManager roleManagerService;

    private RoleManager roleManagerService;

	@Autowired

    @Autowired

	private SuggestedPoDetailRepository monthlyPoDetailRepository;

    private SuggestedPoDetailRepository monthlyPoDetailRepository;

	@Autowired

    @Autowired

	private SuggestedPoRepository suggestedPoRepository;

    private SuggestedPoRepository suggestedPoRepository;

	@Autowired

    @Autowired

	private WebOfferRepository webOfferRepository;

    private WebOfferRepository webOfferRepository;

	@Autowired

    @Autowired

	private ComboModelRepository comboModelRepository;

    private ComboModelRepository comboModelRepository;

	@Autowired

    @Autowired

	private ComboMappedModelRepository comboMappedModelRepository;

    private ComboMappedModelRepository comboMappedModelRepository;

	@Autowired

    @Autowired

	private BrandsService brandsService;

    private BrandsService brandsService;

	@Autowired

    @Autowired

	private WebListingRepository webListingRepository;

    private WebListingRepository webListingRepository;

	@Autowired

    @Autowired

	private WebProductListingRepository webProductListingRepository;

    private WebProductListingRepository webProductListingRepository;

	@Autowired

    @Autowired

	private CatalogFavouriteRepository catalogFavouriteRepository;

    private CatalogFavouriteRepository catalogFavouriteRepository;

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

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

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

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

	public ResponseEntity<?> getBuckets(HttpServletRequest request) throws ProfitMandiBusinessException {

    public ResponseEntity<?> getBuckets(HttpServletRequest request) throws ProfitMandiBusinessException {

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

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

		return responseSender.ok(itemBucketService.getBuckets(Optional.of(true)));

        return responseSender.ok(itemBucketService.getBuckets(Optional.of(true)));

	}

    }

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

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

	public ResponseEntity<?> getBucketDetails(HttpServletRequest request, @RequestParam int id)

    public ResponseEntity<?> getBucketDetails(HttpServletRequest request, @RequestParam int id) throws ProfitMandiBusinessException {

			throws ProfitMandiBusinessException {

        List<ItemQuantityPojo> iqPojo = itemBucketService.getBucketDetails(id);

		List<ItemQuantityPojo> iqPojo = itemBucketService.getBucketDetails(id);

        Map<Integer, Integer> itemIdsQtyMap = iqPojo.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getQuantity()));

		Map<Integer, Integer> itemIdsQtyMap = iqPojo.stream()

        Set<Integer> catalogIds = itemRepository.selectByIds(itemIdsQtyMap.keySet()).stream().map(x -> x.getCatalogItemId()).collect(Collectors.toSet());

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

        RestClient rc = new RestClient();

		Set<Integer> catalogIds = itemRepository.selectByIds(itemIdsQtyMap.keySet()).stream()

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

				.map(x -> x.getCatalogItemId()).collect(Collectors.toSet());

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

		RestClient rc = new RestClient();

        mandatoryQ.add(

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

                String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));

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

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

		mandatoryQ.add(

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

				String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));

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

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

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

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

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

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

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

        String response = null;

        try {

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

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

		String response = null;

        } catch (HttpHostConnectException e) {

		try {

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

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

        }

		} catch (HttpHostConnectException e) {

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

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

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

		}

        List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);

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

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

        Bucket bucket = itemBucketService.getBuckets(Optional.of(true)).stream().filter(x -> x.getId() == id).collect(Collectors.toList()).get(0);

		List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);

        bucket.setFofoCatalogResponses(dealResponse);

        return responseSender.ok(bucket);

		Bucket bucket = itemBucketService.getBuckets(Optional.of(true)).stream().filter(x -> x.getId() == id)

    }

				.collect(Collectors.toList()).get(0);

		bucket.setFofoCatalogResponses(dealResponse);

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

		return responseSender.ok(bucket);

    public ResponseEntity<?> getSuggestedPo(HttpServletRequest request, @RequestParam int id) throws ProfitMandiBusinessException {

	}

        List<SuggestedPoDetail> mpd = monthlyPoDetailRepository.selectByPoId(id);

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

        Map<Integer, Integer> itemIdsQtyMap = mpd.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getQuantity()));

	public ResponseEntity<?> getSuggestedPo(HttpServletRequest request, @RequestParam int id)

			throws ProfitMandiBusinessException {

        Set<Integer> catalogIds = itemRepository.selectByIds(itemIdsQtyMap.keySet()).stream().map(x -> x.getCatalogItemId()).collect(Collectors.toSet());

        RestClient rc = new RestClient();

		List<SuggestedPoDetail> mpd = monthlyPoDetailRepository.selectByPoId(id);

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

		Map<Integer, Integer> itemIdsQtyMap = mpd.stream()

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

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

        mandatoryQ.add(

                String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));

		Set<Integer> catalogIds = itemRepository.selectByIds(itemIdsQtyMap.keySet()).stream()

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

				.map(x -> x.getCatalogItemId()).collect(Collectors.toSet());

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

		RestClient rc = new RestClient();

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

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

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

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

		mandatoryQ.add(

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

				String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));

        String response = null;

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

        try {

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

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

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

        } catch (HttpHostConnectException e) {

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

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

        }

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

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

		String response = null;

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

		try {

        List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);

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

		} catch (HttpHostConnectException e) {

        return responseSender.ok(dealResponse);

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

    }

		}

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

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

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

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

		List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);

    @ApiOperation(value = "")

    public ResponseEntity<?> changeSuggestedPoStatus(HttpServletRequest request, @RequestParam int id) throws ProfitMandiBusinessException {

		return responseSender.ok(dealResponse);

        SuggestedPo suggestedPo = suggestedPoRepository.selectById(id);

	}

        suggestedPo.setStatus("closed");

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

        return responseSender.ok(true);

	@ApiImplicitParams({

    }

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

	@ApiOperation(value = "")

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

	public ResponseEntity<?> changeSuggestedPoStatus(HttpServletRequest request, @RequestParam int id)

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

			throws ProfitMandiBusinessException {

		SuggestedPo suggestedPo = suggestedPoRepository.selectById(id);

        int userId = (int) request.getAttribute("userId");

		suggestedPo.setStatus("closed");

        UserCart uc = userAccountRepository.getUserCart(userId);

        int fofoId = uc.getUserId();

		return responseSender.ok(true);

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

	}

        Set<Integer> catalogIds = catalogFavouriteRepository.selectBypartnerId(fofoId).stream().map(x -> x.getCatalogId()).collect(Collectors.toSet());

        if (!catalogIds.isEmpty()) {

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

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

            RestClient rc = new RestClient();

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

		int userId = (int) request.getAttribute("userId");

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

		UserCart uc = userAccountRepository.getUserCart(userId);

            mandatoryQ.add(String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));

		int fofoId = uc.getUserId();

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

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

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

		Set<Integer> catalogIds = catalogFavouriteRepository.selectBypartnerId(fofoId).stream()

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

				.map(x -> x.getCatalogId()).collect(Collectors.toSet());

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

		if (!catalogIds.isEmpty()) {

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

			RestClient rc = new RestClient();

            String response = null;

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

            try {

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

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

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

            } catch (HttpHostConnectException e) {

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

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

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

            }

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

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

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

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

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

            dealResponse = getCatalogResponse(docs, false, fofoId);

        }

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

        return responseSender.ok(dealResponse);

			String response = null;

    }

			try {

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

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

			} catch (HttpHostConnectException e) {

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

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

    @ApiOperation(value = "")

			}

    public ResponseEntity<?> mangeFavourites(HttpServletRequest request, @RequestParam int catalogId) throws ProfitMandiBusinessException {

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

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

        int userId = (int) request.getAttribute("userId");

			dealResponse = getCatalogResponse(docs, false, fofoId);

        UserCart uc = userAccountRepository.getUserCart(userId);

		}

        int fofoId = uc.getUserId();

		return responseSender.ok(dealResponse);

	}

        CatalogFavourite catalogFavourite = catalogFavouriteRepository.selectBypartnerAndCatalogId(fofoId, catalogId);

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

        if (catalogFavourite == null) {

	@ApiImplicitParams({

            catalogFavourite = new CatalogFavourite();

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

            catalogFavourite.setCatalogId(catalogId);

	@ApiOperation(value = "")

            catalogFavourite.setFofoId(fofoId);

	public ResponseEntity<?> mangeFavourites(HttpServletRequest request, @RequestParam int catalogId)

            catalogFavourite.setCreatedTimestamp(LocalDateTime.now());

			throws ProfitMandiBusinessException {

            catalogFavouriteRepository.persist(catalogFavourite);

		int userId = (int) request.getAttribute("userId");

        }

		UserCart uc = userAccountRepository.getUserCart(userId);

		int fofoId = uc.getUserId();

        else {

            catalogFavouriteRepository.deleteByPartnerAndCatalogId(fofoId, catalogId);

		CatalogFavourite catalogFavourite = catalogFavouriteRepository.selectBypartnerAndCatalogId(fofoId, catalogId);

        }

        return responseSender.ok(true);

		if (catalogFavourite == null) {

    }

			catalogFavourite = new CatalogFavourite();

			catalogFavourite.setCatalogId(catalogId);

    private String getCommaSeparateTags(int userId) {

			catalogFavourite.setFofoId(fofoId);

        UserCart uc = userAccountRepository.getUserCart(userId);

			catalogFavourite.setCreatedTimestamp(LocalDateTime.now());

        List<Integer> tagIds = pricingService.getTagsIdsByRetailerId(uc.getUserId());

			catalogFavouriteRepository.persist(catalogFavourite);

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

        for (Integer tagId : tagIds) {

		}

            strTagIds.add(String.valueOf(tagId));

        }

		else {

        return String.join(",", strTagIds);

			catalogFavouriteRepository.deleteByPartnerAndCatalogId(fofoId, catalogId);

    }

		}

		return responseSender.ok(true);

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

	}

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

    public ResponseEntity<?> getFofo(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(value = "hotDeal", required = false) boolean hotDeal, @RequestParam(value = "endPoint", required = false) String endPoint) throws Throwable {

	private String getCommaSeparateTags(int userId) {

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

		UserCart uc = userAccountRepository.getUserCart(userId);

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

		List<Integer> tagIds = pricingService.getTagsIdsByRetailerId(uc.getUserId());

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

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

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

		for (Integer tagId : tagIds) {

			strTagIds.add(String.valueOf(tagId));

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

		}

		return String.join(",", strTagIds);

        if (endPoint != null && !endPoint.trim().isEmpty()) {

	}

            WebListing webListing = webListingRepository.selectByUrl(endPoint);

            dealResponse = this.getDealResponses(userInfo, webListing, offset, limit);

	@ApiImplicitParams({

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

        } else {

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

	public ResponseEntity<?> getFofo(HttpServletRequest request,

            dealResponse = this.getCatalogResponse(

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

                    solrService.getSolrDocs(queryTerm, categoryId, offset, limit, sort, brand, subCategoryId, hotDeal), hotDeal, userInfo.getRetailerId());

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

        }

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

        logger.info("log me");

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

        return responseSender.ok(dealResponse);

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

    }

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

			@RequestParam(value = "hotDeal", required = false) boolean hotDeal,

    @RequestMapping(value = "/online-deals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

			@RequestParam(value = "endPoint", required = false) String endPoint) throws Throwable {

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

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

    @ApiOperation(value = "Get online deals")

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

    public ResponseEntity<?> getOnlineDeals(HttpServletRequest request, @RequestParam(value = "categoryId") String categoryId, @RequestParam(value = "offset") String offset, @RequestParam(value = "limit") String limit, @RequestParam(value = "sort", required = false) String sort, @RequestParam(value = "direction", required = false) String direction, @RequestParam(value = "filterData", required = false) String filterData) throws Throwable {

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

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

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

        String response = null;

        int userId = (int) request.getAttribute("userId");

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

        String uri = "/deals/" + userId;

		if (endPoint != null && !endPoint.trim().isEmpty()) {

        RestClient rc = new RestClient();

			WebListing webListing = webListingRepository.selectByUrl(endPoint);

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

			dealResponse = this.getDealResponses(userInfo, webListing, offset, limit);

        params.put("offset", offset);

        params.put("limit", limit);

		} else {

        params.put("categoryId", categoryId);

        params.put("direction", direction);

			dealResponse = this.getCatalogResponse(

        params.put("sort", sort);

					solrService.getSolrDocs(queryTerm, categoryId, offset, limit, sort, brand, subCategoryId, hotDeal),

        params.put("source", "online");

					hotDeal, userInfo.getRetailerId());

        params.put("filterData", filterData);

		}

        /*

		logger.info("log me");

         * if (userInfo.getRoleNames().contains(RoleType.FOFO.toString())) {

		return responseSender.ok(dealResponse);

         * params.put("tag_ids", getCommaSeparateTags(userId)); }

	}

         */

        List<Object> responseObject = new ArrayList<>();

	@RequestMapping(value = "/online-deals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

        try {

	@ApiImplicitParams({

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

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

        } catch (HttpHostConnectException e) {

	@ApiOperation(value = "Get online deals")

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

	public ResponseEntity<?> getOnlineDeals(HttpServletRequest request,

        }

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

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

        JsonArray result_json = Json.parse(response).asArray();

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

        for (JsonValue j : result_json) {

			@RequestParam(value = "filterData", required = false) String filterData) throws Throwable {

            // logger.info("res " + j.asArray());

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

            List<Object> innerObject = new ArrayList<>();

		String response = null;

            for (JsonValue jsonObject : j.asArray()) {

		int userId = (int) request.getAttribute("userId");

                innerObject.add(toDealObject(jsonObject.asObject()));

            }

		String uri = "/deals/" + userId;

            if (innerObject.size() > 0) {

		RestClient rc = new RestClient();

                responseObject.add(innerObject);

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

            }

		params.put("offset", offset);

        }

		params.put("limit", limit);

        return responseSender.ok(responseObject);

		params.put("categoryId", categoryId);

    }

		params.put("direction", direction);

		params.put("sort", sort);

    private Object toDealObject(JsonObject jsonObject) {

		params.put("source", "online");

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

		params.put("filterData", filterData);

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

		/*

        }

		 * if (userInfo.getRoleNames().contains(RoleType.FOFO.toString())) {

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

		 * params.put("tag_ids", getCommaSeparateTags(userId)); }

    }

		 */

		List<Object> responseObject = new ArrayList<>();

    @RequestMapping(value = ProfitMandiConstants.URL_BRANDS, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

		try {

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

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

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

		} catch (HttpHostConnectException e) {

    public ResponseEntity<?> getBrands(HttpServletRequest request, @RequestParam(value = "category_id") String category_id) throws ProfitMandiBusinessException {

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

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

		}

        String response = null;

        // TODO: move to properties

		JsonArray result_json = Json.parse(response).asArray();

        String uri = ProfitMandiConstants.URL_BRANDS;

		for (JsonValue j : result_json) {

        RestClient rc = new RestClient();

			// logger.info("res " + j.asArray());

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

			List<Object> innerObject = new ArrayList<>();

        params.put("category_id", category_id);

			for (JsonValue jsonObject : j.asArray()) {

        List<DealBrands> dealBrandsResponse = null;

				innerObject.add(toDealObject(jsonObject.asObject()));

        try {

			}

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

			if (innerObject.size() > 0) {

        } catch (HttpHostConnectException e) {

				responseObject.add(innerObject);

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

			}

        }

		}

		return responseSender.ok(responseObject);

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

	}

        }.getType());

	private Object toDealObject(JsonObject jsonObject) {

        return responseSender.ok(dealBrandsResponse);

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

    }

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

		}

    @RequestMapping(value = ProfitMandiConstants.URL_UNIT_DEAL, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

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

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

	}

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

    public ResponseEntity<?> getUnitDeal(HttpServletRequest request, @PathVariable(value = "id") long id) throws ProfitMandiBusinessException {

	@RequestMapping(value = ProfitMandiConstants.URL_BRANDS, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

        String response = null;

	@ApiImplicitParams({

        // TODO: move to properties

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

        String uri = "getDealById/" + id;

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

        System.out.println("Unit deal " + uri);

	public ResponseEntity<?> getBrands(HttpServletRequest request,

        RestClient rc = new RestClient();

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

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

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

        DealsResponse dealsResponse = null;

		String response = null;

        try {

		// TODO: move to properties

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

		String uri = ProfitMandiConstants.URL_BRANDS;

        } catch (HttpHostConnectException e) {

		RestClient rc = new RestClient();

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

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

        }

		params.put("category_id", category_id);

		List<DealBrands> dealBrandsResponse = null;

        JsonObject result_json = Json.parse(response).asObject();

		try {

        if (!result_json.isEmpty()) {

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

            dealsResponse = new Gson().fromJson(response, DealsResponse.class);

		} catch (HttpHostConnectException e) {

            Iterator<AvailabilityInfo> iter = dealsResponse.getAvailabilityInfo().iterator();

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

            while (iter.hasNext()) {

		}

                AvailabilityInfo ai = iter.next();

                if (ai.getAvailability() <= 0)

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

                    iter.remove();

		}.getType());

            }

        }

		return responseSender.ok(dealBrandsResponse);

        return responseSender.ok(dealsResponse);

	}

    }

	@RequestMapping(value = ProfitMandiConstants.URL_UNIT_DEAL, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

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

	@ApiImplicitParams({

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

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

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

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

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

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

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

			throws ProfitMandiBusinessException {

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

		String response = null;

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

		// TODO: move to properties

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

		String uri = "getDealById/" + id;

            String categoryId = "(3 OR 6)";

		System.out.println("Unit deal " + uri);

            UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());

		RestClient rc = new RestClient();

            RestClient rc = new RestClient();

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

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

		DealsResponse dealsResponse = null;

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

		try {

            String catalogString = "catalog" + id;

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

		} catch (HttpHostConnectException e) {

            mandatoryQ.add(String.format("+(categoryId_i:%s) +(id:%s) +{!parent which=\"id:%s\"} tagId_i:(%s)", categoryId, catalogString, catalogString, StringUtils.join(tagIds, " ")));

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

		}

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

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

		JsonObject result_json = Json.parse(response).asObject();

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

		if (!result_json.isEmpty()) {

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

			dealsResponse = new Gson().fromJson(response, DealsResponse.class);

            String response = null;

			Iterator<AvailabilityInfo> iter = dealsResponse.getAvailabilityInfo().iterator();

            try {

			while (iter.hasNext()) {

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

				AvailabilityInfo ai = iter.next();

            } catch (HttpHostConnectException e) {

				if (ai.getAvailability() <= 0)

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

					iter.remove();

            }

			}

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

		}

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

		return responseSender.ok(dealsResponse);

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

	}

        } else {

            return responseSender.badRequest(

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

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

	@ApiImplicitParams({

        }

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

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

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

    }

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

			throws Exception {

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

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

    public ResponseEntity<?> getBrandsToDisplay(HttpServletRequest request, @RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {

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

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

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

        logger.info("userInfo [{}]", userInfo);

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

        List<DBObject> brandsDisplay = mongoClient.getMongoBrands(userInfo.getRetailerId(), userInfo.getEmail(), categoryId);

			String categoryId = "(3 OR 6)";

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

			UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());

    }

			RestClient rc = new RestClient();

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

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

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

    public ResponseEntity<?> getBrands(HttpServletRequest request, @RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {

			String catalogString = "catalog" + id;

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

        logger.info("userInfo [{}]", userInfo);

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

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

        List<BrandCatalog> brandsDisplay = brandsService.getBrands(userInfo.getRetailerId(), userInfo.getEmail(), categoryId);

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

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

    }

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

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

    @RequestMapping(value = "/fofo/accessory/all-categories", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

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

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

			String response = null;

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

			try {

        logger.info("userInfo [{}]", userInfo);

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

        List<DBObject> subCategoriesDisplay = this.getSubCategoriesToDisplay();

			} catch (HttpHostConnectException e) {

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

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

    }

			}

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

    private List<DBObject> getSubCategoriesToDisplay() throws Exception {

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

        List<DBObject> subCategories = new ArrayList<>();

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

        RestClient rc = new RestClient();

		} else {

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

			return responseSender.badRequest(

        params.put("q", "categoryId_i:6");

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

        params.put("group", "true");

		}

        params.put("group.field", "subCategoryId_i");

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

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

	}

        params.put("rows", "50");

        params.put("fl", "subCategoryId_i");

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

        String response = null;

	public ResponseEntity<?> getBrandsToDisplay(HttpServletRequest request,

        try {

			@RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {

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

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

        } catch (HttpHostConnectException e) {

		logger.info("userInfo [{}]", userInfo);

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

		List<DBObject> brandsDisplay = mongoClient.getMongoBrands(userInfo.getRetailerId(), userInfo.getEmail(),

        }

				categoryId);

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

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

        JSONArray groups = solrResponseJSONObj.getJSONObject("subCategoryId_i").getJSONArray("groups");

	}

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

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

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

            JSONObject groupObject = groups.getJSONObject(i);

	public ResponseEntity<?> getBrands(HttpServletRequest request,

            int subCategoryId = groupObject.getInt("groupValue");

			@RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {

            int quantity = groupObject.getJSONObject("doclist").getInt("numFound");

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

            categoryIds.add(subCategoryId);

		logger.info("userInfo [{}]", userInfo);

        }

		List<BrandCatalog> brandsDisplay = brandsService.getBrands(userInfo.getRetailerId(), userInfo.getEmail(),

        List<Category> categories = categoryRepository.selectByIds(categoryIds);

				categoryId);

        AtomicInteger i = new AtomicInteger(0);

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

        categories.forEach(x -> {

	}

            DBObject dbObject = new BasicDBObject();

            dbObject.put("name", x.getLabel());

	@RequestMapping(value = "/fofo/accessory/all-categories", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

            dbObject.put("subCategoryId", x.getId());

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

            dbObject.put("rank", i.incrementAndGet());

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

            dbObject.put("categoryId", 6);

		logger.info("userInfo [{}]", userInfo);

            dbObject.put("url", "https://images.smartdukaan.com/uploads/campaigns/" + x.getId() + ".png");

		List<DBObject> subCategoriesDisplay = this.getSubCategoriesToDisplay();

            subCategories.add(dbObject);

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

        });

	}

        return subCategories;

	private List<DBObject> getSubCategoriesToDisplay() throws Exception {

		List<DBObject> subCategories = new ArrayList<>();

    }

		RestClient rc = new RestClient();

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

    @RequestMapping(value = "/banners/{bannerType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

		params.put("q", "categoryId_i:6");

    public ResponseEntity<?> getBanners(@PathVariable String bannerType) {

		params.put("group", "true");

        return new ResponseEntity<>(mongoClient.getBannersByType(bannerType), HttpStatus.OK);

		params.put("group.field", "subCategoryId_i");

    }

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

		params.put("rows", "50");

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

		params.put("fl", "subCategoryId_i");

    public ResponseEntity<?> getSubcategoriesToDisplay() {

		String response = null;

        return new ResponseEntity<>(mongoClient.getSubcategoriesToDisplay(), HttpStatus.OK);

		try {

    }

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

		} catch (HttpHostConnectException e) {

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

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

    @RequestMapping(value = "/deals/skus/{skus}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

		}

    public ResponseEntity<?> getDealsBySkus(@PathVariable String skus) throws ProfitMandiBusinessException {

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

        StringBuffer sb = new StringBuffer("/getDealsForNotification/");

		JSONArray groups = solrResponseJSONObj.getJSONObject("subCategoryId_i").getJSONArray("groups");

        String uri = sb.append(skus).toString();

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

        RestClient rc = new RestClient();

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

        String response;

			JSONObject groupObject = groups.getJSONObject(i);

        try {

			int subCategoryId = groupObject.getInt("groupValue");

            response = rc.get(SchemeType.HTTP, host, port, uri, new HashMap<>());

			int quantity = groupObject.getJSONObject("doclist").getInt("numFound");

        } catch (HttpHostConnectException e) {

			categoryIds.add(subCategoryId);

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

		}

        }

        JsonArray result_json = Json.parse(response).asArray();

		List<Category> categories = categoryRepository.selectByIds(categoryIds);

        List<Object> responseObject = new ArrayList<>();

		AtomicInteger i = new AtomicInteger(0);

        for (JsonValue j : result_json) {

		categories.forEach(x -> {

            // logger.info("res " + j.asArray());

			DBObject dbObject = new BasicDBObject();

            List<Object> innerObject = new ArrayList<>();

			dbObject.put("name", x.getLabel());

            for (JsonValue jsonObject : j.asArray()) {

			dbObject.put("subCategoryId", x.getId());

                innerObject.add(toDealObject(jsonObject.asObject()));

			dbObject.put("rank", i.incrementAndGet());

            }

			dbObject.put("categoryId", 6);

            if (innerObject.size() > 0) {

			dbObject.put("url", "https://images.smartdukaan.com/uploads/campaigns/" + x.getId() + ".png");

                responseObject.add(innerObject);

			subCategories.add(dbObject);

            }

		});

        }

        return responseSender.ok(responseObject);

		return subCategories;

    }

	}

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

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

	@RequestMapping(value = "/banners/{bannerType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

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

	public ResponseEntity<?> getBanners(@PathVariable String bannerType) {

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

		return new ResponseEntity<>(mongoClient.getBannersByType(bannerType), HttpStatus.OK);

        for (WebListing webListing : webListings) {

	}

            webListing.setFofoCatalogResponses(getDealResponses(userInfo, webListing, "0", "20"));

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

        }

	public ResponseEntity<?> getSubcategoriesToDisplay() {

        return responseSender.ok(webListings);

		return new ResponseEntity<>(mongoClient.getSubcategoriesToDisplay(), HttpStatus.OK);

    }

	}

    private List<FofoCatalogResponse> getDealResponses(UserInfo userInfo, WebListing webListing, String offset, String limit) throws Exception {

	@ApiImplicitParams({

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

        RestClient rc = new RestClient();

	@RequestMapping(value = "/deals/skus/{skus}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

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

	public ResponseEntity<?> getDealsBySkus(@PathVariable String skus) throws ProfitMandiBusinessException {

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

		StringBuffer sb = new StringBuffer("/getDealsForNotification/");

		String uri = sb.append(skus).toString();

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

		RestClient rc = new RestClient();

		String response;

        params.put("sort", "w" + fs.getWarehouseId() + "_i desc");

		try {

			response = rc.get(SchemeType.HTTP, host, port, uri, new HashMap<>());

        List<Integer> webProducts = null;

		} catch (HttpHostConnectException e) {

        if (webListing.getType().equals(WebListingType.solr)) {

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

            logger.info("solrtype {}", webListing.getSolrQuery());

		}

            mandatoryQ.add(String.format("+{!parent which=\"" + webListing.getSolrQuery() + "\"} AND active_b:true AND show_default_b:true"));

		JsonArray result_json = Json.parse(response).asArray();

        } else {

		List<Object> responseObject = new ArrayList<>();

            logger.info("solrtype2 {}", webListing.getSolrQuery());

		for (JsonValue j : result_json) {

			// logger.info("res " + j.asArray());

            webProducts = webProductListingRepository.selectAllByWebListingId(webListing.getId(), Integer.parseInt(offset), Integer.parseInt(limit)).stream().filter(x -> x.getRank() > 0).map(x -> x.getEntityId()).collect(Collectors.toList());

			List<Object> innerObject = new ArrayList<>();

			for (JsonValue jsonObject : j.asArray()) {

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

				innerObject.add(toDealObject(jsonObject.asObject()));

                return new ArrayList<>();

			}

            }

			if (innerObject.size() > 0) {

				responseObject.add(innerObject);

            mandatoryQ.add(String.format(

			}

                    "+{!parent which=\"catalogId_i:" + StringUtils.join(webProducts, " ") + "\"} AND active_b:true AND show_default_b:true"));

		}

		return responseSender.ok(responseObject);

        }

	}

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

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

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

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

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

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

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

				WebListingSource.partner);

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

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

        String response = null;

		for (WebListing webListing : webListings) {

        try {

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

			webListing.setFofoCatalogResponses(getDealResponses(userInfo, webListing, "0", "20"));

        } catch (HttpHostConnectException e) {

		}

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

		return responseSender.ok(webListings);

        }

	}

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

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

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

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

			String limit) throws Exception {

        if (webProducts != null && webListing.getUrl().equals("new-launches")) {

		RestClient rc = new RestClient();

            List<Integer> webProductsFinal = webProducts;

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

            dealResponse = dealResponse.stream().sorted(Comparator.comparing(x -> webProductsFinal.indexOf(x.getCatalogId()))).collect(Collectors.toList());

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

        }

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

        return dealResponse;

		params.put("sort", "w" + fs.getWarehouseId() + "_i desc");

    }

		List<Integer> webProducts = null;

    @Autowired

		if (webListing.getType().equals(WebListingType.solr)) {

    private SaholicCISTableRepository saholicCISTableRepository;

			logger.info("solrtype {}", webListing.getSolrQuery());

			mandatoryQ.add(String.format("+{!parent which=\"" + webListing.getSolrQuery() + "\"} AND active_b:true AND show_default_b:true"));

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

		} else {

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

			logger.info("solrtype2 {}", webListing.getSolrQuery());

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

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

			webProducts = webProductListingRepository

        if (docs.length() > 0) {

					.selectAllByWebListingId(webListing.getId(), Integer.parseInt(offset), Integer.parseInt(limit))

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

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

                JSONObject doc = docs.getJSONObject(i);

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

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

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

				return new ArrayList<>();

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

			}

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

                        itemIds.add(itemId);

			mandatoryQ.add(String.format(

                    }

					"+{!parent which=\"catalogId_i:" + StringUtils.join(webProducts, " ") + "\"} AND active_b:true AND show_default_b:true"));

                }

            }

		}

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

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

                return dealResponse;

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

            }

        }

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

        // get warehouse Id

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

        int warehouseId = fofoStoreRepository.selectByRetailerId(fofoId).getWarehouseId();

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

        Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = saholicInventoryService.getSaholicPOItems().get(warehouseId);

		String response = null;

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

		try {

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

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

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

		} catch (HttpHostConnectException e) {

            JSONObject doc = docs.getJSONObject(i);

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

            catalogIds.add(doc.getInt("catalogId_i"));

		}

        }

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

        List<CreateOfferRequest> allSchemOffers = null;

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

        Map<Integer, PriceCircularItemModelNew> priceCircularItemModelMap = new HashMap<>();

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

        if (catalogIds.size() > 0) {

            PriceCircularModel priceCircularModel = priceCircularService.getPriceCircularByOffer(fofoId, catalogIds, LocalDate.now());

		if (webProducts != null && webListing.getUrl().equals("new-launches")) {

            allSchemOffers = priceCircularModel.getOffers();

			List<Integer> webProductsFinal = webProducts;

			dealResponse = dealResponse.stream()

            List<PriceCircularItemModelNew> priceCircularItemModelNews = priceCircularModel.getPriceCircularItemModelNews();

					.sorted(Comparator.comparing(x -> webProductsFinal.indexOf(x.getCatalogId())))

            if (priceCircularItemModelNews != null) {

					.collect(Collectors.toList());

                priceCircularItemModelMap = priceCircularItemModelNews.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x));

            }

		}

        }

		return dealResponse;

        List<CatalogFavourite> catalogFavourites = catalogFavouriteRepository.selectBypartnerId(fofoId);

	}

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

        if (!catalogFavourites.isEmpty()) {

	@Autowired

            catalogFavouriteIds = catalogFavourites.stream().map(x -> x.getCatalogId()).collect(Collectors.toList());

	private SaholicCISTableRepository saholicCISTableRepository;

        }

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

        if (!catalogFavourites.isEmpty()) {

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

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

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

        }

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

		if (docs.length() > 0) {

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

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

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

				JSONObject doc = docs.getJSONObject(i);

            JSONObject doc = docs.getJSONObject(i);

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

            FofoCatalogResponse fofoCatalogResponse = new FofoCatalogResponse();

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

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

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

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

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

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

						itemIds.add(itemId);

					}

            if (catalogFavouriteIds.contains(fofoCatalogResponse.getCatalogId())) {

				}

                fofoCatalogResponse.setFavourite(true);

			}

            }

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

				return dealResponse;

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

			}

		}

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

		// get warehouse Id

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

		int warehouseId = fofoStoreRepository.selectByRetailerId(fofoId).getWarehouseId();

                fofoCatalogResponse.setWebOffers(webOffers);

		Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = saholicInventoryService.getSaholicPOItems()

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

				.get(warehouseId);

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

            }

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

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

            List<ComboModel> comboModels = comboModelRepository.selectByWarehouseId(warehouseId).stream().filter(x -> x.getCatalogId() == fofoCatalogResponse.getCatalogId()).collect(Collectors.toList());

			JSONObject doc = docs.getJSONObject(i);

			catalogIds.add(doc.getInt("catalogId_i"));

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

		}

		List<CreateOfferRequest> allSchemOffers = null;

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

		Map<Integer, PriceCircularItemModelNew> priceCircularItemModelMap = new HashMap<>();

                fofoCatalogResponse.setComboModels(comboModels);

		if (catalogIds.size() > 0) {

            }

			PriceCircularModel priceCircularModel = priceCircularService.getPriceCircularByOffer(fofoId, catalogIds, LocalDate.now());

			allSchemOffers = priceCircularModel.getOffers();

            try {

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

			List<PriceCircularItemModelNew> priceCircularItemModelNews = priceCircularModel.getPriceCircularItemModelNews();

            } catch (Exception e) {

			if (priceCircularItemModelNews != null) {

                fofoCatalogResponse.setFeature(null);

				priceCircularItemModelMap = priceCircularItemModelNews.stream()

                logger.info("Could not find Feature_s for {}", fofoCatalogResponse.getCatalogId());

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

            }

			}

		}

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

            logger.info("labelss {}", doc.has("label_ss"));

		List<CatalogFavourite> catalogFavourites = catalogFavouriteRepository.selectBypartnerId(fofoId);

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

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

		if (!catalogFavourites.isEmpty()) {

                logger.info("label {}", doc.getJSONArray("label_ss"));

			catalogFavouriteIds = catalogFavourites.stream().map(x -> x.getCatalogId()).collect(Collectors.toList());

		}

                JSONArray arr = doc.getJSONArray("label_ss");

                Set<String> labels = new HashSet<String>();

		if (!catalogFavourites.isEmpty()) {

                for (int j = 0; j < arr.length(); j++) {

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

                    labels.add(arr.getString(j));

		}

                }

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

                fofoCatalogResponse.setLabels(new ArrayList<>(labels));

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

			JSONObject doc = docs.getJSONObject(i);

            }

			FofoCatalogResponse fofoCatalogResponse = new FofoCatalogResponse();

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

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

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

                String modelColorClass = "grey";

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

                FofoAvailabilityInfo fdiAnyColour = null;

                // Iterating itemIds

			if (catalogFavouriteIds.contains(fofoCatalogResponse.getCatalogId())) {

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

				fofoCatalogResponse.setFavourite(true);

                    PriceCircularItemModelNew priceCircularItemModel = priceCircularItemModelMap.get(fofoCatalogResponse.getCatalogId());

			}

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

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

			List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers()

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

					.get(fofoCatalogResponse.getCatalogId());

                    if (!fofoAvailabilityInfoMap.containsKey(itemId)) {

                        FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();

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

                        List<SaholicCISTable> currentAvailability = saholicCISTableRepository.selectByItemWarehouse(itemId, warehouseId);

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

                        List<SaholicPOItem> poItemAvailability = null;

				fofoCatalogResponse.setWebOffers(webOffers);

                        if (poItemAvailabilityMap != null) {

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

                            poItemAvailability = poItemAvailabilityMap.get(itemId);

                        }

			}

                        if (priceCircularItemModel != null) {

			List<ComboModel> comboModels = comboModelRepository.selectByWarehouseId(warehouseId).stream()

                            fdi.setNlc((float) priceCircularItemModel.getNetNlc());

					.filter(x -> x.getCatalogId() == fofoCatalogResponse.getCatalogId()).collect(Collectors.toList());

                        }

			for (ComboModel comboModel : comboModels) {

                        for (SaholicCISTable saholicCISTable : currentAvailability) {

                            saholicCISTable.setWarehouseName(

				List<ComboMappedModel> mappedModels = comboMappedModelRepository.selectByComboId(comboModel.getId());

                                    ProfitMandiConstants.WAREHOUSE_MAP.get(saholicCISTable.getWarehouseFrom()));

                        }

				comboModel.setComboMappedModels(mappedModels);

                        Map<Integer, SaholicCISTable> map = currentAvailability.stream().collect(Collectors.toMap(SaholicCISTable::getWarehouseFrom, x -> x));

			}

                        if (poItemAvailability != null) {

                            for (SaholicPOItem saholicPOItem : poItemAvailability) {

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

                                if (map.containsKey(saholicPOItem.getWarehouseFrom())) {

				fofoCatalogResponse.setComboModels(comboModels);

                                    map.get(saholicPOItem.getWarehouseFrom()).setPopendingQty(saholicPOItem.getUnfulfilledQty());

			}

                                } else {

                                    SaholicCISTable saholicCISTable = new SaholicCISTable();

			try {

                                    saholicCISTable.setAvailability(0);

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

                                    saholicCISTable.setReserved(0);

			} catch (Exception e) {

                                    saholicCISTable.setItemId(itemId);

				fofoCatalogResponse.setFeature(null);

                                    saholicCISTable.setWarehouseId(warehouseId);

				logger.info("Could not find Feature_s for {}", fofoCatalogResponse.getCatalogId());

                                    saholicCISTable.setPopendingQty(saholicPOItem.getUnfulfilledQty());

			}

                                    saholicCISTable.setWarehouseFrom(saholicPOItem.getWarehouseFrom());

                                    saholicCISTable.setWarehouseName(

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

                                            ProfitMandiConstants.WAREHOUSE_MAP.get(saholicPOItem.getWarehouseFrom()));

			logger.info("labelss {}", doc.has("label_ss"));

                                    map.put(saholicPOItem.getWarehouseFrom(), saholicCISTable);

                                }

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

                            }

				logger.info("label {}", doc.getJSONArray("label_ss"));

                        }

                        fdi.setSaholicCISTableList(new ArrayList<>(map.values()));

				JSONArray arr = doc.getJSONArray("label_ss");

                        String poColor = "grey";

				Set<String> labels = new HashSet<String>();

                        boolean active = false;

				for (int j = 0; j < arr.length(); j++) {

                        if (currentAvailability != null && currentAvailability.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) > 0) {

					labels.add(arr.getString(j));

                            poColor = "green";

				}

                            modelColorClass = "green";

                        } else

				fofoCatalogResponse.setLabels(new ArrayList<>(labels));

                            if (poItemAvailability != null && poItemAvailability.stream().collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty)) > 0) {

                                if (currentAvailability != null && poItemAvailability.stream().collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty)) + currentAvailability.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) <= 0) {

			}

                                    poColor = "grey";

                                } else {

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

                                    poColor = "yellow";

				String modelColorClass = "grey";

                                    if (modelColorClass != "green") {

				FofoAvailabilityInfo fdiAnyColour = null;

                                        modelColorClass = poColor;

				// Iterating itemIds

                                    }

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

                                }

					PriceCircularItemModelNew priceCircularItemModel = priceCircularItemModelMap

                            }

							.get(fofoCatalogResponse.getCatalogId());

                        fdi.setColorClass(poColor);

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

                        fdi.setSellingPrice(sellingPrice);

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

                        fdi.setActive(active);

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

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

					if (!fofoAvailabilityInfoMap.containsKey(itemId)) {

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

						FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();

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

						List<SaholicCISTable> currentAvailability = saholicCISTableRepository

                        if (fdi.getColor().equalsIgnoreCase("any colour")) {

								.selectByItemWarehouse(itemId, warehouseId);

                            fdiAnyColour = fdi;

						List<SaholicPOItem> poItemAvailability = null;

                        }

						if (poItemAvailabilityMap != null) {

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

							poItemAvailability = poItemAvailabilityMap.get(itemId);

                        fdi.setItem_id(itemId);

						}

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

						fdi.setNlc((float)priceCircularItemModel.getNetNlc());

                        cashBack = cashBack == null ? 0 : cashBack;

                        fdi.setCashback(cashBack);

						for (SaholicCISTable saholicCISTable : currentAvailability) {

                        fdi.setMinBuyQuantity(1);

							saholicCISTable.setWarehouseName(

                        if (hotDeal) {

									ProfitMandiConstants.WAREHOUSE_MAP.get(saholicCISTable.getWarehouseFrom()));

                            if (currentAvailability != null) {

						}

                                fdi.setAvailability(currentAvailability.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)));

                            } else {

						Map<Integer, SaholicCISTable> map = currentAvailability.stream()

                                fdi.setAvailability(0);

								.collect(Collectors.toMap(SaholicCISTable::getWarehouseFrom, x -> x));

                            }

						if (poItemAvailability != null) {

                        } else {

							for (SaholicPOItem saholicPOItem : poItemAvailability) {

                            // Lets consider that its out of stock

								if (map.containsKey(saholicPOItem.getWarehouseFrom())) {

                            fdi.setAvailability(100);

									map.get(saholicPOItem.getWarehouseFrom())

                            Item item = null;

											.setPopendingQty(saholicPOItem.getUnfulfilledQty());

                            try {

								} else {

                                item = itemRepository.selectById(itemId);

									SaholicCISTable saholicCISTable = new SaholicCISTable();

                            } catch (Exception e) {

									saholicCISTable.setAvailability(0);

                                e.printStackTrace();

									saholicCISTable.setReserved(0);

                                continue;

									saholicCISTable.setItemId(itemId);

                            }

									saholicCISTable.setWarehouseId(warehouseId);

                            // In case its tampered glass moq should be

									saholicCISTable.setPopendingQty(saholicPOItem.getUnfulfilledQty());

                            if (item.getCategoryId() == 10020) {

									saholicCISTable.setWarehouseFrom(saholicPOItem.getWarehouseFrom());

                                fdi.setMinBuyQuantity(5);

									saholicCISTable.setWarehouseName(

                            }

											ProfitMandiConstants.WAREHOUSE_MAP.get(saholicPOItem.getWarehouseFrom()));

                        }

									map.put(saholicPOItem.getWarehouseFrom(), saholicCISTable);

                        fdi.setQuantityStep(1);

								}

                        fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));

							}

                        fofoAvailabilityInfoMap.put(itemId, fdi);

						}

                    }

						fdi.setSaholicCISTableList(new ArrayList<>(map.values()));

                }

						String poColor = "grey";

                if (fdiAnyColour != null) {

						boolean active = false;

                    fdiAnyColour.setColorClass(modelColorClass);

						if (currentAvailability != null && currentAvailability.stream()

                }

								.collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) > 0) {

            }

							poColor = "green";

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

							modelColorClass = "green";

                List<FofoAvailabilityInfo> availabilityList = fofoAvailabilityInfoMap.values().stream().sorted(Comparator.comparing(FofoAvailabilityInfo::getAvailability).reversed()).collect(Collectors.toList());

						} else if (poItemAvailability != null && poItemAvailability.stream()

                fofoCatalogResponse.setItems(availabilityList);

								.collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty)) > 0) {

                if (priceCircularItemModelMap.containsKey(fofoCatalogResponse.getCatalogId())) {

							if (currentAvailability != null && poItemAvailability.stream()

                    PriceCircularItemModelNew priceCircularItemModel = priceCircularItemModelMap.get(fofoCatalogResponse.getCatalogId());

									.collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty))

                    if (priceCircularItemModel.getSlabPayouts() != null) {

									+ currentAvailability.stream()

                        List<CreateOfferRequest> schemeOffers = new ArrayList<>();

											.collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) <= 0) {

                        List<Map<Integer, AmountModel>> slabPayouts = priceCircularItemModel.getSlabPayouts();

								poColor = "grey";

                        Iterator<Map<Integer, AmountModel>> iterator = slabPayouts.iterator();

							} else {

                        int iteratorCount = 0;

								poColor = "yellow";

                        while (iterator.hasNext()) {

								if (modelColorClass != "green") {

                            Map<Integer, AmountModel> slabPayoutMap = iterator.next();

									modelColorClass = poColor;

                            if (slabPayoutMap != null) {

								}

                                schemeOffers.add(allSchemOffers.get(iteratorCount));

							}

                            } else {

						}

                                iterator.remove();

						fdi.setColorClass(poColor);

                            }

						fdi.setSellingPrice(sellingPrice);

                            iteratorCount++;

						fdi.setActive(active);

                        }

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

                        fofoCatalogResponse.setSchemeOffers(schemeOffers);

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

                    }

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

                    fofoCatalogResponse.setPriceCircularItemModel(priceCircularItemModel);

						if (fdi.getColor().equalsIgnoreCase("any colour")) {

                }

							fdiAnyColour = fdi;

                dealResponse.add(fofoCatalogResponse);

						}

            }

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

        }

						fdi.setItem_id(itemId);

        return dealResponse;

						Float cashBack = schemeService.getCatalogSchemeCashBack()

								.get(fofoCatalogResponse.getCatalogId());

    }

						cashBack = cashBack == null ? 0 : cashBack;

						fdi.setCashback(cashBack);

    private List<FofoCatalogResponse> getCatalogSingleSkuResponse(JSONArray docs, Map<Integer, Integer> itemFilter, boolean hotDeal) throws ProfitMandiBusinessException {

						fdi.setMinBuyQuantity(1);

        Map<Integer, TagListing> itemTagListingMap = null;

						if (hotDeal) {

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

							if (currentAvailability != null) {

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

								fdi.setAvailability(currentAvailability.stream()

										.collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)));

        itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemFilter.keySet(), new HashSet<>(tagIds)).stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x));

							} else {

								fdi.setAvailability(0);

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

							}

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

						} else {

            JSONObject doc = docs.getJSONObject(i);

							// Lets consider that its out of stock

							fdi.setAvailability(100);

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

							Item item = null;

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

							try {

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

								item = itemRepository.selectById(itemId);

                TagListing tl = itemTagListingMap.get(itemId);

							} catch (Exception e) {

                if (tl == null) {

								e.printStackTrace();

                    continue;

								continue;

                }

							}

                if (hotDeal) {

							// In case its tampered glass moq should be

                    if (!tl.isHotDeals()) {

							if (item.getCategoryId() == 10020) {

                        continue;

								fdi.setMinBuyQuantity(5);

                    }

							}

                }

						}

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

						fdi.setQuantityStep(1);

                if (fofoAvailabilityInfoMap.containsKey(itemId)) {

						fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));

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

						fofoAvailabilityInfoMap.put(itemId, fdi);

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

					}

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

				}

                    }

				if (fdiAnyColour != null) {

                } else {

					fdiAnyColour.setColorClass(modelColorClass);

                    FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();

				}

                    fdi.setSellingPrice((float) childItem.getDouble("sellingPrice_f"));

			}

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

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

                    fdi.setMop((float) tl.getMrp());

				List<FofoAvailabilityInfo> availabilityList = fofoAvailabilityInfoMap.values().stream()

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

						.sorted(Comparator.comparing(FofoAvailabilityInfo::getAvailability).reversed())

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

						.collect(Collectors.toList());

                    fdi.setItem_id(itemId);

				fofoCatalogResponse.setItems(availabilityList);

                    Item item = itemRepository.selectById(itemId);

				if (priceCircularItemModelMap.containsKey(fofoCatalogResponse.getCatalogId())) {

                    // In case its tampered glass moq should be 5

					PriceCircularItemModelNew priceCircularItemModel = priceCircularItemModelMap

                    if (item.getCategoryId() == 10020) {

							.get(fofoCatalogResponse.getCatalogId());

                        fdi.setMinBuyQuantity(10);

					if (priceCircularItemModel.getSlabPayouts() != null) {

                    } else {

						List<CreateOfferRequest> schemeOffers = new ArrayList<>();

                        fdi.setMinBuyQuantity(1);

						List<Map<Integer, AmountModel>> slabPayouts = priceCircularItemModel.getSlabPayouts();

                    }

						Iterator<Map<Integer, AmountModel>> iterator = slabPayouts.iterator();

                    fdi.setAvailability(itemFilter.get(itemId));

						int iteratorCount = 0;

                    fdi.setQuantityStep(1);

						while (iterator.hasNext()) {

                    fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));

							Map<Integer, AmountModel> slabPayoutMap = iterator.next();

                    fofoAvailabilityInfoMap.put(itemId, fdi);

							if (slabPayoutMap != null) {

                }

								schemeOffers.add(allSchemOffers.get(iteratorCount));

            }

							} else {

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

								iterator.remove();

                for (FofoAvailabilityInfo fofoAvailabilityInfo : fofoAvailabilityInfoMap.values()) {

							}

                    FofoCatalogResponse ffdr = new FofoCatalogResponse();

							iteratorCount++;

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

						}

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

						fofoCatalogResponse.setSchemeOffers(schemeOffers);

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

					}

                    try {

					fofoCatalogResponse.setPriceCircularItemModel(priceCircularItemModel);

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

				}

                    } catch (Exception e) {

				dealResponse.add(fofoCatalogResponse);

                        ffdr.setFeature(null);