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.VendorDetails;
 import in.shop2020.model.v1.catalog.InventoryService;
+import in.shop2020.model.v1.catalog.VendorItemMapping;
 import in.shop2020.model.v1.catalog.VendorItemPricing;
+import in.shop2020.model.v1.catalog.status;
 import in.shop2020.thrift.clients.CatalogServiceClient;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.Collections;
-import java.util.Comparator;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItems(true);
             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.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, vip));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
         } catch (Exception e) {
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestDeals();
             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.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, vip));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
         } catch(Exception e){
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestSellers();
             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.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, vip));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
         } catch(Exception e){
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             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());
+                //List<in.shop2020.model.v1.catalog.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, vip));
+                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
         } catch(Exception e){
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             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());
-            return getItemFromThriftItem(thriftItem, vip);
+            return getItemFromThriftItem(thriftItem, vip, null);
         }catch(Exception e){
             // Oops! We didn't receive the details. We should let the user know
             // that the catalog service is currently unavailable.
             e.printStackTrace();
+        }
             // periodically.
             e.printStackTrace();
+        }
+    }
-    private Item getItemFromThriftItem(in.shop2020.model.v1.catalog.Item thriftItem, List<in.shop2020.model.v1.catalog.VendorItemPricing> thriftItemPricings){
+    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){
-        Map<Long, double[]> vendorPricings = new HashMap<Long, double[]>();
+        Map<Long, VendorDetails> vendorDetailsMap = new HashMap<Long, VendorDetails>();
-        double[] prices;
+        VendorDetails vDetails;
+        if(tVendorMappings != null) {
+            for(VendorItemMapping vim : tVendorMappings) {
+                vDetails = vendorDetailsMap.get(vim.getVendorId());
+                if(vDetails == null) {
+                    vDetails = new VendorDetails();
+                    vDetails.setVendorId(vim.getVendorId());
+                }
+                vDetails.setVendorId(vim.getVendorId());
+                vDetails.setItemKey(vim.getItemKey());
+                vendorDetailsMap.put(vDetails.getVendorId(), vDetails);
+            }
+        }
-        if(thriftItemPricings != null) {
+        if(tVendorPricings != null) {
-            for(VendorItemPricing v : thriftItemPricings) {
+            for(VendorItemPricing vip : tVendorPricings) {
+                vDetails = vendorDetailsMap.get(vip.getVendorId());
+                if(vDetails == null) {
-                prices = new double[3];
+                    vDetails = new VendorDetails();
+                    vDetails.setVendorId(vip.getVendorId());
+                }
-                prices[0] = v.getMop();
+                vDetails.setMop(vip.getMop());
-                prices[1] = v.getDealerPrice();
+                vDetails.setDealerPrice(vip.getDealerPrice());
-                prices[2] = v.getTransferPrice();
+                vDetails.setTransferPrice(vip.getTransferPrice());
-                vendorPricings.put(v.getVendorId(), prices);
+                vendorDetailsMap.put(vDetails.getVendorId(), vDetails);
+            }
+        }
         Item item = new Item(thriftItem.getId(),
                 thriftItem.getProductGroup(),
                 thriftItem.getBrand(),
                 thriftItem.getModelNumber(),
                 thriftItem.getModelName(),
                 thriftItem.getBestDealText(),
                 thriftItem.getBestDealValue(),
                 thriftItem.getBestSellingRank(),
                 thriftItem.isDefaultForEntity(),
                 (thriftItem.getItemInventory() != null ? thriftItem.getItemInventory().getAvailability() : null),
-                vendorPricings
+                vendorDetailsMap
                 );
         return item;
+    }
     @Override
 //          tItem.setCategory(item.getCategory());
 //          tItem.setFeatureId(item.getFeatureId());
 //          tItem.setFeatureDescription(item.getFeatureDescription());
+            long rItemId;
+            if((rItemId = catalogClient.updateItem(tItem)) != item.getId()) {
+                GWT.log("Error updating item, returned Item Id: " + rItemId);
+                return false;
+            }
+            GWT.log("Item updated successfully, Item Id: " + item.getId());
+            Map<Long, VendorDetails> vendorDetails = item.getVendorDetails();
+            if(vendorDetails != null && !vendorDetails.isEmpty()) {
+                in.shop2020.model.v1.catalog.VendorItemPricing tVendorPricing;
+                in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;
+                for(VendorDetails v : vendorDetails.values()) {
+                    tVendorPricing = new VendorItemPricing();
+                    tVendorPricing.setVendorId(v.getVendorId());
+                    tVendorPricing.setItemId(item.getId());
+                    tVendorPricing.setMop(v.getMop());
+                    tVendorPricing.setTransferPrice(v.getTransferPrice());
+                    tVendorPricing.setDealerPrice(v.getDealerPrice());
+                    catalogClient.addVendorItemPricing(tVendorPricing);
+                    GWT.log("VendorItemPricing updated. " + tVendorPricing.getVendorId() + ", " + tVendorPricing.getItemId() + ", " +
+                            tVendorPricing.getMop() + ", " + tVendorPricing.getTransferPrice() + ", " + tVendorPricing.getDealerPrice());
+                    /*tVendorMapping = new VendorItemMapping();
+                    tVendorMapping.setVendorId(v.getVendorId());
+                    tVendorMapping.setItemKey(v.getItemKey());
+                    tVendorMapping.setItemId(item.getId());
+                    tVendorMapping.setVendorCategory(item.getVendorCategory());
+                    catalogClient.addVendorItemMapping(tVendorMapping);
+                    GWT.log("VendorItemMapping updated. " + tVendorMapping.getVendorId() + ", " + tVendorMapping.getItemId() + ", " +
+                            tVendorMapping.getItemKey() + ", " + tVendorMapping.getVendorCategory());*/
+                }
+            }
+        }catch(Exception e){
+            e.printStackTrace();
+        }
+        return true;
             /*List<VendorItemPricing> tVendorPrices = tItem.getVendorPrices();
             if(tVendorPrices == null) {
                 tVendorPrices = new ArrayList<VendorItemPricing>();
+            }
             for(Entry<Long, double[]> vendorItemPricing : item.getVendorPricings().entrySet()) {
                 vip.setMop(vendorItemPricing.getValue()[Item.INDEX_MOP]);
                 vip.setDealerPrice(vendorItemPricing.getValue()[Item.INDEX_DP]);
                 vip.setTransferPrice(vendorItemPricing.getValue()[Item.INDEX_TP]);
                 //catalogClient.updateVendorItemPricing(vip);
             }*/
-            VendorItemPricing vip = new VendorItemPricing();
-            for(Entry<Long, double[]> vendorItemPricing : item.getVendorPricings().entrySet()) {
-                vip.setItemId(item.getId());
-                vip.setVendorId(vendorItemPricing.getKey());
-                vip.setMop(vendorItemPricing.getValue()[Item.INDEX_MOP]);
-                vip.setDealerPrice(vendorItemPricing.getValue()[Item.INDEX_DP]);
-                vip.setTransferPrice(vendorItemPricing.getValue()[Item.INDEX_TP]);
-                catalogClient.updateVendorItemPricing(vip);
-            }
-            if(catalogClient.updateItem(tItem) == item.getId());
-                return true;
-        }catch(Exception e){
-            e.printStackTrace();
-        }
-        return false;
+    }
     @Override
     public Map<Long, String> getAllVendors() {
         } catch (Exception e) {
             e.printStackTrace();
+        }
         return warehouseMap;
+    }
+    @Override
+    public void phaseoutItem(long itemId) {
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            InventoryService.Client catalogClient = catalogServiceClient.getClient();
+            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PHASED_OUT);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    @Override
+    public void activateItem(long itemId) {
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            InventoryService.Client catalogClient = catalogServiceClient.getClient();
+            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.ACTIVE);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    @Override
+    public long addItem(Item item) {
+        long itemId = 0;
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            InventoryService.Client catalogClient = catalogServiceClient.getClient();
+            in.shop2020.model.v1.catalog.Item tItem = new in.shop2020.model.v1.catalog.Item();
+            tItem.setProductGroup(item.getProductGroup());
+            tItem.setBrand(item.getBrand());
+            tItem.setModelNumber(item.getModelNumber());
+            tItem.setModelName(item.getModelName());
+            tItem.setColor(item.getColor());
+            tItem.setComments(item.getComments());
+            tItem.setMrp(item.getMrp());
+            tItem.setSellingPrice(item.getSellingPrice());
+            tItem.setWeight(item.getWeight());
+            tItem.setAddedOn(Calendar.getInstance().getTimeInMillis());
+            tItem.setUpdatedOn(Calendar.getInstance().getTimeInMillis());
+            tItem.setRetireDate(item.getRetireDate());
+            tItem.setStartDate(item.getStartDate());
+            tItem.setBestDealText(item.getBestDealsText());
+            tItem.setBestDealValue(item.getBestDealsValue());
+            tItem.setBestSellingRank(item.getBestSellingRank());
+            tItem.setDefaultForEntity(item.isDefaultForEntity());
+            tItem.setHotspotCategory(item.getVendorCategory());
+            itemId = catalogClient.addItem(tItem);
+            Map<Long, VendorDetails> vendorDetails = item.getVendorDetails();
+            if(vendorDetails != null && !vendorDetails.isEmpty()) {
+                in.shop2020.model.v1.catalog.VendorItemPricing tVendorPricing;
+                in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;
+                for(VendorDetails v : vendorDetails.values()) {
+                    tVendorMapping = new VendorItemMapping();
+                    tVendorMapping.setVendorId(v.getVendorId());
+                    tVendorMapping.setItemKey(v.getItemKey());
+                    tVendorMapping.setItemId(itemId);
+                    tVendorMapping.setVendorCategory(item.getVendorCategory());
+                    catalogClient.addVendorItemMapping(tVendorMapping);
+                    /*tVendorPricing = new VendorItemPricing();
+                    tVendorPricing.setVendorId(v.getVendorId());
+                    tVendorPricing.setItemId(itemId);
+                    tVendorPricing.setMop(v.getMop());
+                    tVendorPricing.setTransferPrice(v.getTransferPrice());
+                    tVendorPricing.setDealerPrice(v.getDealerPrice());
+                    catalogClient.addVendorItemPricing(tVendorPricing);*/
+                }
+            }
+            /*Map<Long, double[]> vendors = item.getVendorPricings();
+            List<VendorItemPricing> vPricesList;
+            if(vendors != null && !vendors.isEmpty()) {
+                vPricesList = new ArrayList<VendorItemPricing>();
+                VendorItemPricing vendorPrices = null;
+                for(Entry<Long, double[]> v : vendors.entrySet()) {
+                    vendorPrices = new VendorItemPricing(v.getKey(), item.getId(),
+                            v.getValue()[Item.INDEX_TP], v.getValue()[Item.INDEX_MOP], v.getValue()[Item.INDEX_DP]);
+                    vPricesList.add(vendorPrices);
+                }
+                boolean itemExists = catalogClient.itemExists(item.getProductGroup(), item.getHbrand(), item.getHmodelNumber(),
+                        item.getHcolor(), vendorPrices.getVendorId(), item.getVendorCategory());
+                if(itemExists) {
+                    return itemId;
+                }
+            } else {
+                return 0;
+            }
+            catalogClient.addVendorItemPricing(vendorItemPricing)
+            */
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return itemId;
+    }
+}

Subversion Repositories SmartDukaan

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