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



import in.shop2020.content.ContentServiceException;
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.inventory.InventoryService;
import in.shop2020.model.v1.inventory.ItemStockPurchaseParams;
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;

            Client catalogClient = catalogServiceClient.getClient();
 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllIgnoredInventoryUpdateItemsList(offset, limit);
 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null));
            }
        } catch (Exception e) {
            logger.error("Error while getting all items from the catalog service", e);
        }
        return itemList;

            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, null));
            }
        } catch (Exception e) {
            logger.error("Error while getting all items from the catalog service", e);
        }
        return itemList;

            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, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the best deals from the catalog service", e);
        }
        //Collections.sort(itemList, new ItemsComparator());

            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, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the risky items from the catalog service", e);
        }
        Collections.sort(itemList, new ItemsComparator());

            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, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the best sellers from the catalog service", e);
        }
        return itemList;        

            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, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the latest arrivals from the catalog service", e);
        }
        return itemList;

            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, null));
            }
        } catch(Exception e){
            logger.error("Error while getting the search results from the catalog service", e);
        }
        return itemList;

            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());
            ItemStockPurchaseParams stockPurchaseParams = inventoryClient.getItemStockPurchaseParams(thriftItem.getId());
            List<in.shop2020.model.v1.catalog.VoucherItemMapping> tvouchers = catalogClient.getAllItemVouchers(thriftItem.getId());
            Item it = getItemFromThriftItem(thriftItem, vip, vim, sip, sit, itemInventory, tvouchers, stockPurchaseParams);
            it.setSameItemsWithDifferentColors(sameItemsWithDifferentColors);
            return it;
        }catch(Exception e){
            logger.error("Error while getting the item from the catalog service", e);
        }

                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
                    logger.info("Updates VendorItemMapping: " + tVendorMapping.toString());
                }
            }
 
            if(item.getMinStockLevel()!=0 || item.getNumOfDaysStock()!=0) {
            	inventoryClient.updateItemStockPurchaseParams(item.getId(), item.getNumOfDaysStock(),
            			item.getMinStockLevel());
            }
            
            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();

                    tVendorMapping.setItemKey(v.getItemKey());
                    tVendorMapping.setItemId(itemId);
                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
                }
            }
            
        	inventoryClient.updateItemStockPurchaseParams(itemId, item.getNumOfDaysStock(),
        			item.getMinStockLevel());
        } catch (Exception e) {
            logger.error("Error while adding an item: ", e);
        }
        return itemId;
    }

            
            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, null));
            }
        } catch (Exception e) {
            logger.error("Error while getting items by category: " + category, e);
        }
        Collections.sort(itemList, new ItemsComparator());

                
    			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, null));
    		} catch (Exception e) {
    			logger.error("Could not fetch item for : " + itemId, e);
    			return "Could not push to production. No item got pushed.";
    		}
    	}

            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, null));
            }
        } catch (Exception e) {
            logger.error("Error while getting items by status: " + st, e);
        }
        return itemList;

     * @param tVendorPricings
     * @param tVendorMappings
     * @param tSourceMappings
     * @param tSimilarItems
     * @param tVoucherMappings
     * @param stockPurchaseParams 
     * @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, 
            ItemStockPurchaseParams tStockPurchaseParams){
 
        Map<String, VendorItemMapping> vItemMap = new HashMap<String, VendorItemMapping>();
        VendorItemMapping vItemMapping;
        if(tVendorMappings != null) {
            for(in.shop2020.model.v1.inventory.VendorItemMapping vim : tVendorMappings) {

            for(in.shop2020.model.v1.catalog.VoucherItemMapping tvoucher : tVoucherMappings) {
            	voucher = new VoucherItemMapping(tvoucher.getAmount(), VoucherType.findByValue((int) tvoucher.getVoucherType()).name());
            	voucherMap.put(VoucherType.findByValue((int) tvoucher.getVoucherType()).name(), voucher);
            }
        }
       
        in.shop2020.catalog.dashboard.shared.ItemStockPurchaseParams stockPurchaseParams = 
        	new in.shop2020.catalog.dashboard.shared.ItemStockPurchaseParams();
        if(tStockPurchaseParams != null) {
        	stockPurchaseParams.setItem_id(tStockPurchaseParams.getItem_id());
        	stockPurchaseParams.setMinStockLevel(tStockPurchaseParams.getMinStockLevel());
        	stockPurchaseParams.setNumOfDaysStock(tStockPurchaseParams.getNumOfDaysStock());
        }
        
        Item item = new Item(thriftItem.getId(),
                thriftItem.getProductGroup(),
                thriftItem.getBrand(),
                thriftItem.getModelNumber(),
                thriftItem.getModelName(),

                itemInventoryMap,
                vendorPricingMap,
                vItemMap,
                sourcePricingMap,
                SimilarItemslist,
                voucherMap, stockPurchaseParams.getNumOfDaysStock(), 
                stockPurchaseParams.getMinStockLevel());
        return item;
    }
    
    /**
     * 

		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, null);
        }catch(Exception e){
            logger.error("Error while adding the SimilarItems for: " + itemId, e);
        }
        return null;
	}

Subversion Repositories SmartDukaan

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

Rev 6777		Rev 6813
Line 15...		Line 15...
15	`import in.shop2020.content.ContentServiceException;`	15	`import in.shop2020.content.ContentServiceException;`
16	`import in.shop2020.model.v1.catalog.CatalogService.Client;`	16	`import in.shop2020.model.v1.catalog.CatalogService.Client;`
17	`import in.shop2020.model.v1.catalog.ItemType;`	17	`import in.shop2020.model.v1.catalog.ItemType;`
18	`import in.shop2020.model.v1.catalog.status;`	18	`import in.shop2020.model.v1.catalog.status;`
19	`import in.shop2020.model.v1.inventory.InventoryService;`	19	`import in.shop2020.model.v1.inventory.InventoryService;`
-		20	`import in.shop2020.model.v1.inventory.ItemStockPurchaseParams;`
20	`import in.shop2020.model.v1.user.VoucherType;`	21	`import in.shop2020.model.v1.user.VoucherType;`
21	`import in.shop2020.thrift.clients.CatalogClient;`	22	`import in.shop2020.thrift.clients.CatalogClient;`
22	`import in.shop2020.thrift.clients.ContentClient;`	23	`import in.shop2020.thrift.clients.ContentClient;`
23	`import in.shop2020.thrift.clients.InventoryClient;`	24	`import in.shop2020.thrift.clients.InventoryClient;`
24	`import in.shop2020.thrift.clients.config.ConfigClient;`	25	`import in.shop2020.thrift.clients.config.ConfigClient;`
Line 98...		Line 99...
98	`Client catalogClient = catalogServiceClient.getClient();`	99	`Client catalogClient = catalogServiceClient.getClient();`
99		100
100	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllIgnoredInventoryUpdateItemsList(offset, limit);`	101	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllIgnoredInventoryUpdateItemsList(offset, limit);`
101		102
102	`for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {`	103	`for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {`
103	`itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));`	104	`itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null));`
104	`}`	105	`}`
105	`} catch (Exception e) {`	106	`} catch (Exception e) {`
106	`logger.error("Error while getting all items from the catalog service", e);`	107	`logger.error("Error while getting all items from the catalog service", e);`
107	`}`	108	`}`
108	`return itemList;`	109	`return itemList;`
Line 132...		Line 133...
132	`Client catalogClient = catalogServiceClient.getClient();`	133	`Client catalogClient = catalogServiceClient.getClient();`
133		134
134	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);`	135	`List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);`
135		136
136	`for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {`	137	`for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {`
137	`itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null));`	138	`itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null));`
138	`}`	139	`}`
139	`} catch (Exception e) {`	140	`} catch (Exception e) {`
140	`logger.error("Error while getting all items from the catalog service", e);`	141	`logger.error("Error while getting all items from the catalog service", e);`
141	`}`	142	`}`
142	`return itemList;`	143	`return itemList;`
Line 172...		Line 173...
172	`CatalogClient catalogServiceClient = new CatalogClient();`	173	`CatalogClient catalogServiceClient = new CatalogClient();`
173	`Client catalogClient = catalogServiceClient.getClient();`	174	`Client catalogClient = catalogServiceClient.getClient();`
174		175