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

 package com.spice.profitmandi.web.controller;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-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.http.conn.HttpHostConnectException;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.json.JSONArray;
-import org.json.JSONObject;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Controller;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
 import com.eclipsesource.json.Json;
 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.itextpdf.text.pdf.security.CertificateInfo.X500Name;
 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.solr.SolrService;
 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.ComboMappedModel;
-import com.spice.profitmandi.dao.entity.catalog.ComboModel;
-import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.catalog.*;
-import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.dtr.WebOffer;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.SuggestedPo;
 import com.spice.profitmandi.dao.entity.fofo.SuggestedPoDetail;
 import com.spice.profitmandi.dao.entity.inventory.SaholicCISTable;
 import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.UserCart;
-import com.spice.profitmandi.dao.repository.catalog.CategoryRepository;
-import com.spice.profitmandi.dao.repository.catalog.ComboMappedModelRepository;
-import com.spice.profitmandi.dao.repository.catalog.ComboModelRepository;
-import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.catalog.*;
-import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.WebOfferRepository;
 import com.spice.profitmandi.dao.repository.fofo.SuggestedPoDetailRepository;
 import com.spice.profitmandi.dao.repository.fofo.SuggestedPoRepository;
 import com.spice.profitmandi.dao.repository.inventory.SaholicCISTableRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
-import com.spice.profitmandi.service.inventory.AvailabilityInfo;
-import com.spice.profitmandi.service.inventory.Bucket;
+import com.spice.profitmandi.service.inventory.*;
-import com.spice.profitmandi.service.inventory.FofoAvailabilityInfo;
-import com.spice.profitmandi.service.inventory.FofoCatalogResponse;
-import com.spice.profitmandi.service.inventory.InventoryService;
-import com.spice.profitmandi.service.inventory.ItemBucketService;
-import com.spice.profitmandi.service.inventory.ItemQuantityPojo;
-import com.spice.profitmandi.service.inventory.SaholicInventoryService;
 import com.spice.profitmandi.service.pricecircular.PriceCircularItemModel;
 import com.spice.profitmandi.service.pricecircular.PriceCircularModel;
 import com.spice.profitmandi.service.pricecircular.PriceCircularService;
 import com.spice.profitmandi.service.pricing.PricingService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.web.res.DealBrands;
 import com.spice.profitmandi.web.res.DealObjectResponse;
 import com.spice.profitmandi.web.res.DealsResponse;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.conn.HttpHostConnectException;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.json.JSONArray;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import javax.servlet.http.HttpServletRequest;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class DealsController {
 		return responseSender.ok(dealResponse);
+	}
 	@RequestMapping(value = "/suggestedPo/status", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
 	@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 = "")
 	public ResponseEntity<?> changeSuggestedPoStatus(HttpServletRequest request, @RequestParam int id)
 			throws ProfitMandiBusinessException {
 		SuggestedPo suggestedPo = suggestedPoRepository.selectById(id);
 		suggestedPo.setStatus("closed");
+		}
 		return String.join(",", strTagIds);
+	}
 	@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")})
 	@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 = "categoryId", required = false, defaultValue = "3") String categoryId,
-			@RequestParam(value = "offset") String offset, @RequestParam(value = "limit") String limit,
+									 @RequestParam(value = "offset") String offset, @RequestParam(value = "limit") String limit,
-			@RequestParam(value = "sort", required = false) String sort,
+									 @RequestParam(value = "sort", required = false) String sort,
-			@RequestParam(value = "brand", required = false) String brand,
+									 @RequestParam(value = "brand", required = false) String brand,
-			@RequestParam(value = "subCategoryId", required = false) int subCategoryId,
+									 @RequestParam(value = "subCategoryId", required = false) int subCategoryId,
-			@RequestParam(value = "q", required = false) String queryTerm,
+									 @RequestParam(value = "q", required = false) String queryTerm,
-			@RequestParam(value = "hotDeal", required = false) boolean hotDeal) throws Throwable {
+									 @RequestParam(value = "hotDeal", required = false) boolean hotDeal) throws Throwable {
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		FofoStore fs = fofoStoreRepository.selectByRetailerId(userInfo.getRetailerId());
 		sort = "w" + fs.getWarehouseId() + "_i desc";
 		dealResponse = this.getCatalogResponse(
 		return responseSender.ok(dealResponse);
+	}
 	@RequestMapping(value = "/online-deals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@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 online deals")
 	public ResponseEntity<?> getOnlineDeals(HttpServletRequest request,
-			@RequestParam(value = "categoryId") String categoryId, @RequestParam(value = "offset") String offset,
+											@RequestParam(value = "categoryId") String categoryId, @RequestParam(value = "offset") String offset,
-			@RequestParam(value = "limit") String limit, @RequestParam(value = "sort", required = false) String sort,
+											@RequestParam(value = "limit") String limit, @RequestParam(value = "sort", required = false) String sort,
-			@RequestParam(value = "direction", required = false) String direction,
+											@RequestParam(value = "direction", required = false) String direction,
-			@RequestParam(value = "filterData", required = false) String filterData) throws Throwable {
+											@RequestParam(value = "filterData", required = false) String filterData) throws Throwable {
 		logger.info("Request " + request.getParameterMap());
 		String response = null;
 		int userId = (int) request.getAttribute("userId");
 		String uri = "/deals/" + userId;
 		return new Gson().fromJson(jsonObject.toString(), DealsResponse.class);
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_BRANDS, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@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 brand list and count for category")
 	public ResponseEntity<?> getBrands(HttpServletRequest request,
-			@RequestParam(value = "category_id") String category_id) throws ProfitMandiBusinessException {
+									   @RequestParam(value = "category_id") String category_id) throws ProfitMandiBusinessException {
 		logger.info("Request " + request.getParameterMap());
 		String response = null;
 		// TODO: move to properties
 		String uri = ProfitMandiConstants.URL_BRANDS;
 		RestClient rc = new RestClient();
 		return responseSender.ok(dealBrandsResponse);
+	}
 	@RequestMapping(value = ProfitMandiConstants.URL_UNIT_DEAL, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@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")
 	public ResponseEntity<?> getUnitDeal(HttpServletRequest request, @PathVariable(value = "id") long id)
 			throws ProfitMandiBusinessException {
 		String response = null;
 		// TODO: move to properties
 		return responseSender.ok(dealsResponse);
+	}
 	@RequestMapping(value = "/partnerdeals/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@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")
 	public ResponseEntity<?> getUnitFocoDeal(HttpServletRequest request, @PathVariable(value = "id") long id)
 			throws Exception {
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		List<Integer> tagIds = Arrays.asList(4);
 		return responseSender.ok(dealResponse.get(0));
+	}
 	@RequestMapping(value = "/fofo/brands", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getBrandsToDisplay(HttpServletRequest request,
-			@RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {
+												@RequestParam(required = false, defaultValue = "0") int categoryId) throws Exception {
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		logger.info("userInfo [{}]", userInfo);
 		List<DBObject> brandsDisplay = mongoClient.getMongoBrands(userInfo.getRetailerId(), userInfo.getEmail(),
 				categoryId);
 		return new ResponseEntity<>(brandsDisplay, HttpStatus.OK);
 	public ResponseEntity<?> getSubcategoriesToDisplay() {
 		return new ResponseEntity<>(mongoClient.getSubcategoriesToDisplay(), HttpStatus.OK);
+	}
 	@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")})
 	@RequestMapping(value = "/deals/skus/{skus}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getDealsBySkus(@PathVariable String skus) throws ProfitMandiBusinessException {
 		StringBuffer sb = new StringBuffer("/getDealsForNotification/");
 		String uri = sb.append(skus).toString();
 		RestClient rc = new RestClient();
+			}
 			fofoCatalogResponse.setBrand(doc.getJSONArray("brand_ss").getString(0));
 			if (doc.has("_childDocuments_")) {
 				String modelColorClass = "grey";
 				FofoAvailabilityInfo fdiAnyColour = null;
-				int allColorNetAvailability = 0;
 				for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {
 					PriceCircularItemModel priceCircularItemModel = priceCircularItemModelMap
 							.get(fofoCatalogResponse.getCatalogId());
 					JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);
 					int itemId = childItem.getInt("itemId_i");
 						List<SaholicPOItem> poItemAvailability = null;
 						if (poItemAvailabilityMap != null) {
 							poItemAvailability = poItemAvailabilityMap.get(itemId);
+						}
 						fdi.setNlc(priceCircularItemModel == null ? 0 : priceCircularItemModel.getNetPrice());
-						if (currentAvailability != null) {
+						Map<Integer, SaholicCISTable> map = null;
-							allColorNetAvailability += currentAvailability.stream()
+						for (SaholicCISTable saholicCISTable : currentAvailability) {
+							saholicCISTable.setWarehouseName(
-									.collect(Collectors.summingInt(SaholicCISTable::getNetAvailability));
+									ProfitMandiConstants.WAREHOUSE_MAP.get(saholicCISTable.getWarehouseFrom()));
+						}
+						map = currentAvailability.stream()
+								.collect(Collectors.toMap(SaholicCISTable::getWarehouseFrom, x -> x));
 						if (poItemAvailability != null) {
-							allColorNetAvailability += poItemAvailability.stream()
-									.collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty));
-						}
-						Map<Integer, SaholicCISTable> map = null;
-						if (currentAvailability != null) {
-							for (SaholicCISTable saholicCISTable : currentAvailability) {
-								saholicCISTable.setWarehouseName(
-										ProfitMandiConstants.WAREHOUSE_MAP.get(saholicCISTable.getWarehouseFrom()));
-							}
-							map = currentAvailability.stream()
-									.collect(Collectors.toMap(SaholicCISTable::getWarehouseFrom, x -> x));
-							if (poItemAvailability != null) {
-								for (SaholicPOItem saholicPOItem : poItemAvailability) {
+							for (SaholicPOItem saholicPOItem : poItemAvailability) {
-									if (map.containsKey(saholicPOItem.getWarehouseFrom())) {
+								if (map.containsKey(saholicPOItem.getWarehouseFrom())) {
-										map.get(saholicPOItem.getWarehouseFrom())
+									map.get(saholicPOItem.getWarehouseFrom())
-												.setPopendingQty(saholicPOItem.getUnfulfilledQty());
+											.setPopendingQty(saholicPOItem.getUnfulfilledQty());
-										map.get(saholicPOItem.getWarehouseFrom())
-												.setWarehouseName(ProfitMandiConstants.WAREHOUSE_MAP
-														.get(saholicPOItem.getWarehouseFrom()));
-									} else {
+								} else {
-										SaholicCISTable saholicCISTable = new SaholicCISTable();
-										saholicCISTable.setAvailability(0);
-										saholicCISTable.setReserved(0);
-										saholicCISTable.setItemId(itemId);
-										saholicCISTable.setPopendingQty(saholicPOItem.getUnfulfilledQty());
-										saholicCISTable.setWarehouseFrom(saholicPOItem.getWarehouseFrom());
-										saholicCISTable.setWarehouseName(ProfitMandiConstants.WAREHOUSE_MAP
-												.get(saholicPOItem.getWarehouseFrom()));
-										map.put(saholicPOItem.getWarehouseFrom(), saholicCISTable);
-									}
-								}
-							}
-						} else {
-							map = new HashMap<>();
-							if (poItemAvailability != null) {
-								for (SaholicPOItem saholicPOItem : poItemAvailability) {
 									SaholicCISTable saholicCISTable = new SaholicCISTable();
 									saholicCISTable.setAvailability(0);
 									saholicCISTable.setReserved(0);
 									saholicCISTable.setItemId(itemId);
 									saholicCISTable.setPopendingQty(saholicPOItem.getUnfulfilledQty());
 									saholicCISTable.setWarehouseFrom(saholicPOItem.getWarehouseFrom());
-									saholicCISTable.setWarehouseName(
+									saholicCISTable.setWarehouseName(ProfitMandiConstants.WAREHOUSE_MAP
-											ProfitMandiConstants.WAREHOUSE_MAP.get(saholicPOItem.getWarehouseFrom()));
+											.get(saholicPOItem.getWarehouseFrom()));
 									map.put(saholicPOItem.getWarehouseFrom(), saholicCISTable);
+								}
+							}
+						}
 						fdi.setSaholicCISTableList(new ArrayList<>(map.values()));
 						String poColor = "grey";
 						boolean active = false;
 						if (currentAvailability != null && currentAvailability.stream()
 						fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));
 						fofoAvailabilityInfoMap.put(itemId, fdi);
+					}
+				}
 				if (fdiAnyColour != null) {
-					/*
-					 * if (allColorNetAvailability <= 0) { for (Map.Entry<Integer,
-					 * FofoAvailabilityInfo> entry : fofoAvailabilityInfoMap.entrySet()) {
-					 * entry.getValue().setColorClass("grey"); } } else {
-					 *
-					 * }
-					 */
 					fdiAnyColour.setColorClass(modelColorClass);
+				}
+			}
 			if (fofoAvailabilityInfoMap.values().size() > 0) {
 				List<FofoAvailabilityInfo> availabilityList = fofoAvailabilityInfoMap.values().stream()
 		return dealResponse;
+	}
 	private List<FofoCatalogResponse> getCatalogSingleSkuResponse(JSONArray docs, Map<Integer, Integer> itemFilter,
-			boolean hotDeal) throws ProfitMandiBusinessException {
+																  boolean hotDeal) throws ProfitMandiBusinessException {
 		Map<Integer, TagListing> itemTagListingMap = null;
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		List<Integer> tagIds = Arrays.asList(4);
 		itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemFilter.keySet(), new HashSet<>(tagIds))

Subversion Repositories SmartDukaan

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