WebSVN – SmartDukaan – Diff – /trunk/CatalogDashboard/src/main/java/in/shop2020/catalog/dashboard/server/CatalogServiceImpl.java



import in.shop2020.catalog.dashboard.shared.VendorPricings;
import in.shop2020.catalog.dashboard.shared.VoucherItemMapping;
import in.shop2020.config.ConfigException;
import in.shop2020.content.ContentService;
import in.shop2020.content.ContentServiceException;
import in.shop2020.model.v1.inventory.InventoryService;
import in.shop2020.model.v1.catalog.CatalogService.Client;
import in.shop2020.model.v1.catalog.ItemType;
import in.shop2020.model.v1.catalog.status;
import in.shop2020.model.v1.user.VoucherType;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.ContentClient;
import in.shop2020.thrift.clients.InventoryClient;
import in.shop2020.thrift.clients.config.ConfigClient;
import in.shop2020.utils.CategoryManager;
import in.shop2020.utils.ConfigClientKeys;
 
import java.io.BufferedReader;

    @Override
    public int getItemCountByStatus(boolean useStatus, ItemStatus itemStatus){
        int count = 0;
        try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            
            status stat = status.findByValue(itemStatus.getValue());
            count = catalogClient.getItemCountByStatus(useStatus, stat);
        }catch(Exception e){
            logger.error("Error while getting the count of items from the catalog service", e);

    public List<Item> getAllItems(int start, int limit) {
        List<Item> itemList = new ArrayList<Item>();
 
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);
 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));

 
    public List<Item> getBestDeals(){
        List<Item> itemList = new ArrayList<Item>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestDeals();
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));
            }

    @Override
    public List<Item> getRiskyItems() {
        List<Item> itemList = new ArrayList<Item>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByRiskyFlag();
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));
            }

    public List<Item> getBestSellers(){
        List<Item> itemList = new ArrayList<Item>();
 
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestSellers();
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));
            }

    public List<Item> getLatestArrivals(){
        List<Item> itemList = new ArrayList<Item>();
 
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getLatestArrivals();
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                //List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the latest arrivals from the catalog service", e);
        }

    public List<Item> searchItems(int start, int limit, List<String> searchTerms) {
        List<Item> itemList = new ArrayList<Item>();
 
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.searchItemsInRange(searchTerms, start, limit);
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));
            }

    @Override
    public int getSearchResultCount(List<String> searchTerms){
        int count = 0;
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            count = catalogClient.getSearchResultCount(searchTerms);
        } catch(Exception e){
            logger.error("Error while getting the search results from the catalog service", e);
        }

    }
    
    public Item getItem(long itemId){
        try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(itemId);
            Long catalogItemId = thriftItem.getCatalogItemId();
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByCatalogId(catalogItemId);
            List <Long> sameItemsWithDifferentColors = new ArrayList<Long>();
            if(thriftItems.size()>1){

		        	if(!id.equals(itemId)){
		        		sameItemsWithDifferentColors.add(id); 
		        	}
	            }
            }
            List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
            List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
            List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
            List<in.shop2020.model.v1.catalog.Item> sit = catalogClient.getAllSimilarItems(thriftItem.getId());
            in.shop2020.model.v1.inventory.ItemInventory itemInventory = inventoryClient.getItemInventoryByItemId(thriftItem.getId());
            List<in.shop2020.model.v1.catalog.VoucherItemMapping> tvouchers = catalogClient.getAllItemVouchers(thriftItem.getId());
            Item it = getItemFromThriftItem(thriftItem, vip, vim, sip, sit, itemInventory, tvouchers);
            it.setSameItemsWithDifferentColors(sameItemsWithDifferentColors);
            return it;
        }catch(Exception e){

    @Override
    public boolean updateItem(Item item) {
        logger.info("Updating item with Id: " + item.getId());
        try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            
            in.shop2020.model.v1.catalog.Item tItem = catalogClient.getItem(item.getId());
            setThriftItemParams(tItem, item);
 
            long rItemId;
            if((rItemId = catalogClient.updateItem(tItem)) != item.getId()) {

            }
            logger.info("Successfully updated item with id: " + item.getId());
 
            Map<String, VendorItemMapping> vendorMappings = item.getVendorKeysMap();
            if(vendorMappings != null && !vendorMappings.isEmpty()) {
                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
 
                for(Entry<String, VendorItemMapping> e : vendorMappings.entrySet()) {
                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
                    VendorItemMapping v = e.getValue();
                    tVendorMapping.setVendorId(v.getVendorId());
                    tVendorMapping.setItemKey(v.getItemKey());
                    tVendorMapping.setItemId(item.getId());
                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
                    logger.info("Updates VendorItemMapping: " + tVendorMapping.toString());
                }
            }
 
            Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
            if(vendorPricings != null && !vendorPricings.isEmpty()) {
                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
                for(VendorPricings v : vendorPricings.values()) {
                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
                    tVendorPricing.setVendorId(v.getVendorId());
                    tVendorPricing.setItemId(item.getId());
                    tVendorPricing.setMop(v.getMop());
                    tVendorPricing.setTransferPrice(v.getTransferPrice());
                    tVendorPricing.setDealerPrice(v.getDealerPrice());
                    inventoryClient.addVendorItemPricing(tVendorPricing);
                    logger.info("Updated VendorItemPricing: " + tVendorPricing.toString());
                }
            }
            
            Map<Long, SourcePricings> sourcePricings = item.getSourcePricesMap();

 
    @Override
    public Map<Long, String> getAllVendors() {
        Map<Long, String> vendorMap = new HashMap<Long, String>();
        try {
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            
            List<in.shop2020.model.v1.inventory.Vendor> vendors = inventoryClient.getAllVendors();
 
            for(in.shop2020.model.v1.inventory.Vendor v : vendors) {
                vendorMap.put(v.getId(), v.getName());
            }
        } catch (Exception e) {
            logger.error("Error while getting all the vendors: ", e);
        }

    @Override
    public Map<Long, String> getAllSources() {
        Map<Long, String> sourceMap = new HashMap<Long, String>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Source> sources = catalogClient.getAllSources();
 
            for(in.shop2020.model.v1.catalog.Source s : sources) {
            	sourceMap.put(s.getId(), s.getName());

    @Override
    public Map<Long, String> getShippingWarehouses() {
        Map<Long, String> warehouseMap = new HashMap<Long, String>();
        Set<Long> shippingLocations = new HashSet<Long>();
        try {
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            
            List<in.shop2020.model.v1.inventory.Warehouse> warehouses = inventoryClient.getAllWarehouses(true);
 
            for(in.shop2020.model.v1.inventory.Warehouse warehouse : warehouses) {
                shippingLocations.add(warehouse.getShippingWarehouseId());
            }
            
            for(in.shop2020.model.v1.inventory.Warehouse warehouse : warehouses) {
                if (shippingLocations.contains(warehouse.getId())) {
                    warehouseMap.put(warehouse.getId(), warehouse.getDisplayName());
                }                
            }
        } catch (Exception e) {

 
    @Override
    public Map<Long, String> getAllWarehouses() {
        Map<Long, String> warehouseMap = new HashMap<Long, String>();
        try {
        	InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 
            List<in.shop2020.model.v1.inventory.Warehouse> warehouses = inventoryClient.getAllWarehouses(true);
 
            for(in.shop2020.model.v1.inventory.Warehouse w : warehouses) {
                warehouseMap.put(w.getId(), w.getDisplayName());
            }
        } catch (Exception e) {
            logger.error("Error while getting all the warehouses:", e );
        }

    @Override
    public long addItem(Item item) {
        long itemId = 0;
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 
            in.shop2020.model.v1.catalog.Item tItem = new in.shop2020.model.v1.catalog.Item();
            setThriftItemParams(tItem, item);
            itemId = catalogClient.addItem(tItem);
 
            Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
            if(vendorPricings != null && !vendorPricings.isEmpty()) {
                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
                for(VendorPricings v : vendorPricings.values()) {
                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
                    tVendorPricing.setVendorId(v.getVendorId());
                    tVendorPricing.setItemId(itemId);
                    tVendorPricing.setMop(v.getMop());
                    tVendorPricing.setTransferPrice(v.getTransferPrice());
                    tVendorPricing.setDealerPrice(v.getDealerPrice());
                    inventoryClient.addVendorItemPricing(tVendorPricing);
                }
            }
 
            Map<String, VendorItemMapping> vendorKeysMap = item.getVendorKeysMap();
            if(vendorKeysMap != null && !vendorKeysMap.isEmpty()) {
                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
                for(Entry<String, VendorItemMapping> e : vendorKeysMap.entrySet()) {
                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
                    VendorItemMapping v = e.getValue();
                    tVendorMapping.setVendorId(v.getVendorId());
                    tVendorMapping.setItemKey(v.getItemKey());
                    tVendorMapping.setItemId(itemId);
                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
                }
            }
        } catch (Exception e) {
            logger.error("Error while adding an item: ", e);
        }

    @Override
    public long checkSimilarItem(String brand, String modelNumber, String modelName, String color) {
 
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            return catalogClient.checkSimilarItem(brand, modelNumber, modelName, color);
        } catch (Exception e) {
            logger.error("Error while checking for a similar item: ", e);
        }
        return 0;

 
    @Override
    public void pauseItem(long itemId) {
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PAUSED);
        } catch (Exception e) {
            logger.error("Error while pausing the item: " + itemId, e);
        }

 
    @Override
    public void markInProcess(long itemId) {
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.IN_PROCESS);
        } catch (Exception e) {
            logger.error("Error while marking in-process the item: " + itemId, e);
        }

 
    @Override
    public void phaseoutItem(long itemId) {
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PHASED_OUT);
        } catch (Exception e) {
            logger.error("Error while phasing out the item: " + itemId, e);
        }

 
    @Override
    public void activateItem(long itemId) {
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.ACTIVE);
        } catch (Exception e) {
            logger.error("Error while activating the item: " + itemId, e);
        }

    public boolean changeItemRiskyFlag(long itemId, boolean risky) {
        try {
            logger.info("Updating risky flag for item id: " + itemId + " to " + risky);
            // Initialize client for staging server
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            // Initialize client for production server
            CatalogClient catalogServiceClient_Prod = new CatalogClient(ConfigClientKeys.catalog_service_server_host_prod.toString(),
                    ConfigClientKeys.catalog_service_server_port.toString());
            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
            catalogClient.changeItemRiskyFlag(itemId, risky);
 
            try{
                catalogClient_Prod.changeItemRiskyFlag(itemId, risky);
            }catch(Exception e){

     */
    public List<Item> getItemsForMasterSheet(String category, String brand) {
        List<Item> itemList = new ArrayList<Item>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsForMasterSheet(category, brand);
            
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
                List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
                List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
                itemList.add(getItemFromThriftItem(thriftItem, vip, vim, sip, null, null, null));
            }
        } catch (Exception e) {
            logger.error("Error while getting items by category: " + category, e);

    	List<Item> items = new ArrayList<Item>();
    	items.add(item);
    	for(Long itemId : itemIds) {
    		try {
    			CatalogClient catalogServiceClient = new CatalogClient();
    			Client catalogClient = catalogServiceClient.getClient();
    			InventoryClient inventoryServiceClient = new InventoryClient();
                in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
                
    			in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(itemId);
				List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
				List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
				List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
				items.add(getItemFromThriftItem(thriftItem, vip, vim, sip, null, null, null));
    		} catch (Exception e) {
    			logger.error("Could not fetch item for : " + itemId, e);
    			return "Could not push to production. No item got pushed.";

	        try{
	            CatalogClient catalogServiceClient_Prod = new CatalogClient( 
	                    ConfigClientKeys.catalog_service_server_host_prod.toString(),
	                    ConfigClientKeys.catalog_service_server_port.toString());
	            
	            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
	
	            in.shop2020.model.v1.catalog.Item tItem = catalogClient_Prod.getItem(it.getId());
	            
	            InventoryClient inventoryServiceClient = new InventoryClient();
	            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
	            
	            if(it.getMrp() != null) {
	                tItem.setMrp(it.getMrp());
	            }
	            
	            if(it.getSellingPrice() != null) {

	
	            StringBuilder sb = new StringBuilder();
	            
	            Map<Long, VendorPricings> vendorPricings = it.getVendorPricesMap();
	            if(vendorPricings != null && !vendorPricings.isEmpty()) {
	                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
	                for(VendorPricings v : vendorPricings.values()) {
	                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
	                    tVendorPricing.setVendorId(v.getVendorId());
	                    tVendorPricing.setItemId(it.getId());
	                    tVendorPricing.setMop(v.getMop());
	                    tVendorPricing.setTransferPrice(v.getTransferPrice());
	                    tVendorPricing.setDealerPrice(v.getDealerPrice());
	                    inventoryClient.addVendorItemPricing(tVendorPricing);
	                    logger.info("VendorItemPricing updated. " + tVendorPricing.toString());
	                    sb.append("[VId:" + v.getVendorId() + ",MOP=" + v.getMop() + ",TP=" + v.getTransferPrice() + ",DP=" + v.getDealerPrice() + "], ");
	                }
	            }
	            
	            Map<String, VendorItemMapping> vendorMappings = it.getVendorKeysMap();
	            if(vendorMappings != null && !vendorMappings.isEmpty()) {
	                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
	                for(VendorItemMapping vendorItemMapping : vendorMappings.values()) {
	                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
	                    tVendorMapping.setVendorId(vendorItemMapping.getVendorId());
	                    tVendorMapping.setItemId(it.getId());
	                    tVendorMapping.setItemKey(vendorItemMapping.getItemKey());
	                    inventoryClient.addVendorItemMapping(vendorItemMapping.getItemKey(), tVendorMapping);
	                    logger.info("VendorItemMapping updated. " + tVendorMapping.toString());
	                    sb.append("[VId:" + vendorItemMapping.getVendorId() + ",ItemKey=" + vendorItemMapping.getItemKey() + "], ");
	                }
	            }
	

     */
    private List<Item> getItemsByStatus(status st, int start, int limit) {
        List<Item> itemList = new ArrayList<Item>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsByStatusInRange(st, start, limit);
 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));

     * @param tSimilarItems
     * @param tVoucherMappings
     * @return item object with attributes copied from thrift item object.
     */
    private Item getItemFromThriftItem(in.shop2020.model.v1.catalog.Item thriftItem, 
            List<in.shop2020.model.v1.inventory.VendorItemPricing> tVendorPricings, 
            List<in.shop2020.model.v1.inventory.VendorItemMapping> tVendorMappings,
            List<in.shop2020.model.v1.catalog.SourceItemPricing> tSourceMappings,
            List<in.shop2020.model.v1.catalog.Item> tSimilarItems, in.shop2020.model.v1.inventory.ItemInventory tItemInventory, List<in.shop2020.model.v1.catalog.VoucherItemMapping> tVoucherMappings){
 
        Map<String, VendorItemMapping> vItemMap = new HashMap<String, VendorItemMapping>();
        VendorItemMapping vItemMapping;
        if(tVendorMappings != null) {
            for(in.shop2020.model.v1.inventory.VendorItemMapping vim : tVendorMappings) {
                vItemMapping = new VendorItemMapping();
                vItemMapping.setVendorId(vim.getVendorId());
                vItemMapping.setItemKey(vim.getItemKey());
                vItemMap.put(vItemMapping.getVendorId() + Item.KEY_SEPARATOR + vim.getItemKey(), vItemMapping);
            }
        }
 
        Map<Long, VendorPricings> vendorPricingMap = new HashMap<Long, VendorPricings>();
        VendorPricings vPricings;
        if(tVendorPricings != null) {
            for(in.shop2020.model.v1.inventory.VendorItemPricing vip : tVendorPricings) {
                vPricings = new VendorPricings();
                vPricings.setVendorId(vip.getVendorId());
                vPricings.setMop(vip.getMop());
                vPricings.setDealerPrice(vip.getDealerPrice());
                vPricings.setTransferPrice(vip.getTransferPrice());

 
	@Override
	public boolean deleteSimilarItem(long itemId, long catalogItemId) {
		try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            return catalogClient.deleteSimilarItem(itemId, catalogItemId);
 
        }catch(Exception e){
            logger.error("Error while deleting the SimilarItems for: " + itemId, e);

 
	@Override
	public Item addSimilarItem(long itemId, long catalogItemId) {
		try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.addSimilarItem(itemId, catalogItemId);;
 
            return getItemFromThriftItem(thriftItem, null, null, null, null, null, null);
        }catch(Exception e){
            logger.error("Error while adding the SimilarItems for: " + itemId, e);

	public Map<Long, ItemInventory> getProdItemInventory(long itemId) {
		try {
            // Initialize client for production server
            CatalogClient catalogServiceClient_Prod = new CatalogClient(ConfigClientKeys.catalog_service_server_host_prod.toString(),
                    ConfigClientKeys.catalog_service_server_port.toString());
            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
            InventoryClient inventoryServiceClient = new InventoryClient();
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
            in.shop2020.model.v1.inventory.ItemInventory thriftItemInventory = inventoryClient.getItemInventoryByItemId(itemId);
            
            Map<Long, ItemInventory> itemInventoryMap = new HashMap<Long, ItemInventory>();
            ItemInventory warehousedata;
            if(thriftItemInventory != null) {
            	Map<Long, Long> availabilityMap = thriftItemInventory.getAvailability();

 
	@Override
	public boolean addAuthorizationLog(long itemId, String username, String message) {
		try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            return catalogClient.addAuthorizationLog(itemId, username, message);
 
        }catch(Exception e){
            logger.error("Error while adding the event for: " + itemId, e);

	public List<String> getAllCategories() {
		List<String> categoryList = new ArrayList<String>();
		List<Long> parentCategoryIDs = Arrays.asList(new Long[] {(long) 0,(long) 10001,(long) 10009,(long) 10049});
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Category> categories = catalogClient.getAllCategories();
 
            for(in.shop2020.model.v1.catalog.Category category : categories) {
            	if(!parentCategoryIDs.contains(category.getParent_category_id())){

	@Override
	public List<String> getAllBrands() {
		List<String> brandsList = new ArrayList<String>();
        try {
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            brandsList = catalogClient.getAllBrands();
        } catch (Exception e) {
            logger.error("Error while getting all the categories: ", e);
        }

 
	@Override
	public boolean deleteVoucher(Long catalogItemId, Long voucherType) {
		try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            return catalogClient.deleteVoucherForItem(catalogItemId, voucherType);
 
        }catch(Exception e){
            logger.error("Error while deleting the Voucher for: " + catalogItemId, e);

 
	@Override
	public boolean addVoucher(Long catalogItemId, Long voucherType, long voucherAmount) {
		try{
            CatalogClient catalogServiceClient = new CatalogClient();
            Client catalogClient = catalogServiceClient.getClient();
 
            return catalogClient.addupdateVoucherForItem(catalogItemId, voucherType, voucherAmount);
 
        }catch(Exception e){
            logger.error("Error while adding the Voucher for: " + catalogItemId, e);

 
	@Override
	public boolean checkEntityId(long entityId) {
		try {
            CatalogClient catalogServiceClient = new CatalogClient(ConfigClientKeys.catalog_service_server_host_master.toString(), ConfigClientKeys.catalog_service_server_port.toString());
            Client catalogClient = catalogServiceClient.getClient();
            return catalogClient.isValidCatalogItemId(entityId);
        } catch (Exception e) {
            logger.error("Error while checking for a Catalog Item Id: ", e);
        }
		return false;

Subversion Repositories SmartDukaan

(root)/trunk/CatalogDashboard/src/main/java/in/shop2020/catalog/dashboard/server/CatalogServiceImpl.java – Rev 5706 → 5946

Rev 5706		Rev 5946
Line 10...		Line 10...
10	`import in.shop2020.catalog.dashboard.shared.VendorPricings;`	10	`import in.shop2020.catalog.dashboard.shared.VendorPricings;`
11	`import in.shop2020.catalog.dashboard.shared.VoucherItemMapping;`	11	`import in.shop2020.catalog.dashboard.shared.VoucherItemMapping;`
12	`import in.shop2020.config.ConfigException;`	12	`import in.shop2020.config.ConfigException;`
13	`import in.shop2020.content.ContentService;`	13	`import in.shop2020.content.ContentService;`
14	`import in.shop2020.content.ContentServiceException;`	14	`import in.shop2020.content.ContentServiceException;`
15	`import in.shop2020.model.v1.catalog.InventoryService;`	15	`import in.shop2020.model.v1.inventory.InventoryService;`
-		16	`import in.shop2020.model.v1.catalog.CatalogService.Client;`
16	`import in.shop2020.model.v1.catalog.ItemType;`	17	`import in.shop2020.model.v1.catalog.ItemType;`
17	`import in.shop2020.model.v1.catalog.status;`	18	`import in.shop2020.model.v1.catalog.status;`
18	`import in.shop2020.model.v1.user.VoucherType;`	19	`import in.shop2020.model.v1.user.VoucherType;`
19	`import in.shop2020.thrift.clients.CatalogClient;`	20	`import in.shop2020.thrift.clients.CatalogClient;`
20	`import in.shop2020.thrift.clients.ContentClient;`	21	`import in.shop2020.thrift.clients.ContentClient;`
-		22	`import in.shop2020.thrift.clients.InventoryClient;`
21	`import in.shop2020.thrift.clients.config.ConfigClient;`	23	`import in.shop2020.thrift.clients.config.ConfigClient;`
22	`import in.shop2020.utils.CategoryManager;`	24	`import in.shop2020.utils.CategoryManager;`
23	`import in.shop2020.utils.ConfigClientKeys;`	25	`import in.shop2020.utils.ConfigClientKeys;`
24		26
25	`import java.io.BufferedReader;`	27	`import java.io.BufferedReader;`
Line 73...		Line 75...
73	`@Override`	75	`@Override`
74	`public int getItemCountByStatus(boolean useStatus, ItemStatus itemStatus){`	76	`public int getItemCountByStatus(boolean useStatus, ItemStatus itemStatus){`
75	`int count = 0;`	77	`int count = 0;`
76	`try{`	78	`try{`
77	`CatalogClient catalogServiceClient = new CatalogClient();`	79	`CatalogClient catalogServiceClient = new CatalogClient();`
78	`InventoryService.Client catalogClient = catalogServiceClient.getClient();`	80	`Client catalogClient = catalogServiceClient.getClient();`
79		81
80	`status stat = status.findByValue(itemStatus.getValue());`	82	`status stat = status.findByValue(itemStatus.getValue());`
81	`count = catalogClient.getItemCountByStatus(useStatus, stat);`	83	`count = catalogClient.getItemCountByStatus(useStatus, stat);`
82	`}catch(Exception e){`	84	`}catch(Exception e){`
83	`logger.error("Error while getting the count of items from the catalog service", e);`	85	`logger.error("Error while getting the count of items from the catalog service", e);`
Line 89...		Line 91...
89	`public List<Item> getAllItems(int start, int limit) {`	91	`public List<Item> getAllItems(int start, int limit) {`
90	`List<Item> itemList = new ArrayList<Item>();`	92	`List<Item> itemList = new ArrayList<Item>();`
91		93
92	`try {`	94	`try {`
93	`CatalogClient catalogServiceClient = new CatalogClient();`	95	`CatalogClient catalogServiceClient = new CatalogClient();`
94	`InventoryService.Client catalogClient = catalogServiceClient.getClient();`	96	`Client catalogClient = catalogServiceClient.getClient();`
95		97
96	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);`	98	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);`