WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/DealsController.java

 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import org.apache.commons.lang3.StringUtils;
 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.cache.annotation.Cacheable;
 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 com.eclipsesource.json.JsonArray;
 import com.eclipsesource.json.JsonObject;
 import com.eclipsesource.json.JsonValue;
 import com.google.gson.Gson;
 import com.google.gson.reflect.TypeToken;
+import com.mongodb.BasicDBObject;
 import com.mongodb.DBObject;
 import com.spice.profitmandi.common.enumuration.SchemeType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.UserInfo;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
+import com.spice.profitmandi.dao.entity.catalog.Category;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.inventory.ItemAvailabilityCache;
 import com.spice.profitmandi.dao.model.UserCart;
+import com.spice.profitmandi.dao.repository.catalog.CategoryRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;
 	@Autowired
 	private PricingService pricingService;
 	@Autowired
+	private CategoryRepository categoryRepository;
+	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private UserAccountRepository userAccountRepository;
 	@Autowired
 	private ResponseSender<?> responseSender;
 	@Autowired
+	private CategoryRepository repository;
+	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private ItemRepository itemRepository;
+			}
 			JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
 			JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
 			dealResponse = getCatalogResponse(docs, hotDeal);
 			if (Mongo.EMAIL_BLOCKED_BRANDS.containsKey(userInfo.getEmail())) {
+				dealResponse.stream()
-				dealResponse.stream().filter(x -> Mongo.EMAIL_BLOCKED_BRANDS.get(userInfo.getEmail()).contains(x.getBrand()));
+						.filter(x -> Mongo.EMAIL_BLOCKED_BRANDS.get(userInfo.getEmail()).contains(x.getBrand()));
+			}
 		} else {
 			return responseSender.badRequest(
 					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));
+		}
+		}
 		return responseSender.ok(dealResponse.get(0));
+	}
 	@RequestMapping(value = "/fofo/brands", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	@Cacheable(value = "display", cacheManager = "thirtyMinsTimeOutCacheManager")
 	public ResponseEntity<?> getBrandsToDisplay(HttpServletRequest request,
-			@RequestParam(required = false, defaultValue = "0") int categoryId) {
+			@RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+		List<DBObject> brandsDisplay = null;
+		if (categoryId == 3) {
-		List<DBObject> brandsDisplay = mongoClient.getMongoBrands(userInfo.getRetailerId(), userInfo.getEmail(), categoryId);
+			brandsDisplay = mongoClient.getMongoBrands(userInfo.getRetailerId(), userInfo.getEmail(), categoryId);
+		} else {
+			brandsDisplay = this.getAccessories();
+		}
 		return new ResponseEntity<>(brandsDisplay, HttpStatus.OK);
+	}
+	private List<DBObject> getAccessories() throws Exception {
+		List<DBObject> subCategories = new ArrayList<>();
+		RestClient rc = new RestClient();
+		Map<String, String> params = new HashMap<>();
+		params.put("q", "categoryId_i:6");
+		params.put("group", "true");
+		params.put("group.field", "subCategoryId_i");
+		params.put("wt", "json");
+		String response = null;
+		try {
+			response = rc.get(SchemeType.HTTP, "dtr", 8984, "solr/demo/select", params);
+		} catch (HttpHostConnectException e) {
+			throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+		}
+		JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("grouped");
+		JSONArray groups = solrResponseJSONObj.getJSONObject("subCategoryId_i").getJSONArray("groups");
+		List<Integer> categoryIds = new ArrayList<>();
+		for(int i=0;i< groups.length();i++) {
+			JSONObject groupObject = groups.getJSONObject(i);
+			int subCategoryId =  groupObject.getInt("groupValue");
+			int quantity = groupObject.getJSONObject("doclist").getInt("numFound");
+		}
+		List<Category> categories = categoryRepository.selectByIds(categoryIds);
+		AtomicInteger i= new AtomicInteger(0);
+		categories.forEach(x->{
+			DBObject object = new BasicDBObject();
+			object.put("name", x.getLabel());
+			object.put("rank", i.incrementAndGet());
+			object.put("categoryId", 6);
+			object.put("url", "http://api.profittill.com/uploads/campaigns/" + x.getId() + ".png");
+		});
+	}
 	@RequestMapping(value = "/banners/{bannerType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getBanners(@PathVariable String bannerType) {
 		return new ResponseEntity<>(mongoClient.getBannersByType(bannerType), HttpStatus.OK);
+	}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/DealsController.java – Rev 24995 → 25010