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

 package in.shop2020.catalog.dashboard.server;
 import in.shop2020.catalog.dashboard.client.CatalogService;
 import in.shop2020.catalog.dashboard.shared.Item;
 import in.shop2020.catalog.dashboard.shared.ItemsComparator;
+import in.shop2020.catalog.dashboard.shared.SourcePricings;
 import in.shop2020.catalog.dashboard.shared.VendorItemMapping;
 import in.shop2020.catalog.dashboard.shared.VendorPricings;
 import in.shop2020.config.ConfigException;
 import in.shop2020.model.v1.catalog.InventoryService;
 import in.shop2020.model.v1.catalog.status;
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItems(false);
             for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
-                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null, null));
+            }
         } catch (Exception e) {
             logger.error("Error while getting all items from the catalog service", e);
+        }
         Collections.sort(itemList, new ItemsComparator());
             CatalogClient catalogServiceClient = new CatalogClient();
             InventoryService.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));
+                itemList.add(getItemFromThriftItem(thriftItem, 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();
             InventoryService.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));
+                itemList.add(getItemFromThriftItem(thriftItem, 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();
             InventoryService.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));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null, null));
+            }
         } catch(Exception e){
             logger.error("Error while getting the best sellers from the catalog service", e);
+        }
         return itemList;
             InventoryService.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.catalog.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null, null));
+            }
         } catch(Exception e){
             logger.error("Error while getting the latest arrivals from the catalog service", e);
+        }
         return itemList;
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(itemId);
             List<in.shop2020.model.v1.catalog.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
             List<in.shop2020.model.v1.catalog.VendorItemMapping> vim = catalogClient.getVendorItemMappings(thriftItem.getId());
+            List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
-            return getItemFromThriftItem(thriftItem, vip, vim);
+            return getItemFromThriftItem(thriftItem, vip, vim, sip);
         }catch(Exception e){
             logger.error("Error while getting the item from the catalog service", e);
+        }
         return null;
+    }
                     tVendorPricing.setDealerPrice(v.getDealerPrice());
                     catalogClient.addVendorItemPricing(tVendorPricing);
                     logger.info("Updated VendorItemPricing: " + tVendorPricing.toString());
+                }
+            }
+            Map<Long, SourcePricings> sourcePricings = item.getSourcePricesMap();
+            if(sourcePricings != null && !sourcePricings.isEmpty()) {
+                in.shop2020.model.v1.catalog.SourceItemPricing tSourcePricings;
+                for(SourcePricings s : sourcePricings.values()) {
+                	tSourcePricings = new in.shop2020.model.v1.catalog.SourceItemPricing();
+                	tSourcePricings.setSourceId(s.getSourceId());
+                    tSourcePricings.setItemId(item.getId());
+                    tSourcePricings.setMrp(s.getMrp());
+                    tSourcePricings.setSellingPrice(s.getSellingPrice());
+                    catalogClient.addSourceItemPricing(tSourcePricings);
+                    logger.info("Updated SourceItemPricing: " + tSourcePricings.toString());
+                }
+            }
         }catch(Exception e){
             logger.error("Error while updating item: ", e);
             return false;
+        }
         return true;
+        }
         return vendorMap;
+    }
     @Override
+    public Map<Long, String> getAllSources() {
+        Map<Long, String> sourceMap = new HashMap<Long, String>();
+        try {
+            CatalogClient catalogServiceClient = new CatalogClient();
+            InventoryService.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());
+            }
+        } catch (Exception e) {
+            logger.error("Error while getting all the vendors: ", e);
+        }
+        return sourceMap;
+    }
+    @Override
     public Map<Long, String> getAllWarehouses() {
         Map<Long, String> warehouseMap = new HashMap<Long, String>();
         try {
             CatalogClient catalogServiceClient = new CatalogClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByVendorCategory(category);
             for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
                 List<in.shop2020.model.v1.catalog.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
                 List<in.shop2020.model.v1.catalog.VendorItemMapping> vim = catalogClient.getVendorItemMappings(thriftItem.getId());
+                List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, vip, vim));
+                itemList.add(getItemFromThriftItem(thriftItem, vip, vim, sip));
+            }
         } catch (Exception e) {
             logger.error("Error while getting items by vendor category: " + category, e);
+        }
         Collections.sort(itemList, new ItemsComparator());
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsByStatus(st);
             for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
-                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null, null));
+            }
         } catch (Exception e) {
             logger.error("Error while getting items by status: " + st, e);
+        }
         Collections.sort(itemList, new ItemsComparator());
      * @param tVendorMappings
      * @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.catalog.VendorItemPricing> tVendorPricings,
-            List<in.shop2020.model.v1.catalog.VendorItemMapping> tVendorMappings){
+            List<in.shop2020.model.v1.catalog.VendorItemMapping> tVendorMappings,
+            List<in.shop2020.model.v1.catalog.SourceItemPricing> tSourceMappings){
         Map<String, VendorItemMapping> vItemMap = new HashMap<String, VendorItemMapping>();
         VendorItemMapping vItemMapping;
         if(tVendorMappings != null) {
             for(in.shop2020.model.v1.catalog.VendorItemMapping vim : tVendorMappings) {
                 vPricings.setTransferPrice(vip.getTransferPrice());
                 vendorPricingMap.put(vPricings.getVendorId(), vPricings);
+            }
+        }
+        Map<Long, SourcePricings> sourcePricingMap = new HashMap<Long, SourcePricings>();
+        SourcePricings sPricings;
+        if(tSourceMappings != null) {
+            for(in.shop2020.model.v1.catalog.SourceItemPricing sip : tSourceMappings) {
+                sPricings = new SourcePricings();
+                sPricings.setSourceId(sip.getSourceId());
+                sPricings.setMrp(sip.getMrp());
+                sPricings.setSellingPrice(sip.getSellingPrice());
+                sourcePricingMap.put(sPricings.getSourceId(), sPricings);
+            }
+        }
         Item item = new Item(thriftItem.getId(),
                 thriftItem.getHotspotCategory(),
                 thriftItem.getProductGroup(),
                 thriftItem.getBrand(),
                 thriftItem.getModelNumber(),
                 thriftItem.isRisky(),
                 thriftItem.isSetExpectedDelay() ? thriftItem.getExpectedDelay() : null,
                 thriftItem.isSetPreferredWarehouse() ? thriftItem.getPreferredWarehouse() : null,
                 (thriftItem.getItemInventory() != null ? thriftItem.getItemInventory().getAvailability() : null),
                 vendorPricingMap,
-                vItemMap);
+                vItemMap,
+                sourcePricingMap);
         return item;
+    }
     /**
+     *

Subversion Repositories SmartDukaan

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