Subversion Repositories SmartDukaan

	public ResponseEntity<?> getDeals(HttpServletRequest request, @RequestParam(value="categoryId") String categoryId,

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

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

	@RequestMapping(value = ProfitMandiConstants.URL_DEALS, 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 online deals")

	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 ){

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

		String response = null;

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

		//TODO: move to properties

		String uri = "/deals/"+userId;

		RestClient rc = new RestClient(SchemeType.HTTP, host , port);

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

		params.put("offset", offset);

		params.put("limit", limit);

		params.put("categoryId", categoryId);

		params.put("direction", direction);

		params.put("sort", sort);

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

		params.put("filterData", filterData);

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

		try {

			response = rc.get(uri, params);

		} catch (Exception | ProfitMandiBusinessException e) {

			logger.error("Unable to get deals",e);

			final ProfitMandiResponse<?> profitMandiResponse=new ProfitMandiResponse<>(LocalDateTime.now(), request.getRequestURL().toString() , HttpStatus.INTERNAL_SERVER_ERROR.toString(), HttpStatus.INTERNAL_SERVER_ERROR, ResponseStatus.FAILURE, responseObject);

			return new ResponseEntity<>(profitMandiResponse,HttpStatus.INTERNAL_SERVER_ERROR);

		}

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

		for (JsonValue j : result_json ){

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

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

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

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

			}

			if (innerObject.size() > 0){

				responseObject.add(innerObject);

			}

		}

		final ProfitMandiResponse<?> profitMandiResponse=new ProfitMandiResponse<>(LocalDateTime.now(), request.getRequestURL().toString() , HttpStatus.OK.toString(), HttpStatus.OK, ResponseStatus.SUCCESS, responseObject);

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

	}

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

	@ApiImplicitParams({

		@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", 

				required = true, dataType = "string", paramType = "header")

	})

	public ResponseEntity<?> getDirectDeals(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 ){

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

	}*/