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.model.v1.catalog.InventoryService;
 import in.shop2020.model.v1.catalog.status;
 import in.shop2020.thrift.clients.CatalogServiceClient;
 import in.shop2020.utils.CategoryManager;
+import in.shop2020.utils.ConfigClientKeys;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
 import com.google.gwt.core.client.GWT;
 import com.google.gwt.user.server.rpc.RemoteServiceServlet;
 @SuppressWarnings("serial")
 public class CatalogServiceImpl extends RemoteServiceServlet implements CatalogService {
     public List<Item> getAllItems(){
         List<Item> itemList = new ArrayList<Item>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             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) {
-                //List<in.shop2020.model.v1.catalog.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
                 itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
         } catch (Exception e) {
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
-    public List<Item> getAllPhasedOutItems(){
+    public List<Item> getAllActiveItems(){
         List<Item> itemList = new ArrayList<Item>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
-            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsByStatus(status.PHASED_OUT);
+            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());
+                List<in.shop2020.model.v1.catalog.VendorItemMapping> vim = catalogClient.getVendorItemMappings(thriftItem.getId());
-                itemList.add(getItemFromThriftItem(thriftItem, null, null));
+                itemList.add(getItemFromThriftItem(thriftItem, vip, vim));
+            }
         } catch (Exception e) {
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
+    @Override
+    public List<Item> getAllPhasedOutItems(){
+        return getItemsByStatus(status.PHASED_OUT);
+    }
+    @Override
     public List<Item> getAllPausedItems(){
-        List<Item> itemList = new ArrayList<Item>();
+        return getItemsByStatus(status.PAUSED);
-        try {
-            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
-            InventoryService.Client catalogClient = catalogServiceClient.getClient();
-            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsByStatus(status.PAUSED);
-            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));
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-        Collections.sort(itemList, new ItemsComparator());
-        return itemList;
+    }
+    @Override
+    public List<Item> getAllInProcessItems() {
+        return getItemsByStatus(status.IN_PROCESS);
+    }
+    @Override
+    public List<Item> getAllContentCompleteItems() {
+        return getItemsByStatus(status.CONTENT_COMPLETE);
+    }
-    public List<Item> getAllActiveItems(){
+    public List<Item> getBestDeals(){
         List<Item> itemList = new ArrayList<Item>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
-            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItems(true);
+            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());
                 itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
-        } catch (Exception e) {
+        } catch(Exception e){
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
+    @Override
-    public List<Item> getBestDeals(){
+    public List<Item> getRiskyItems() {
         List<Item> itemList = new ArrayList<Item>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
-            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestDeals();
+            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByRiskyFlag();
             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));
+            }
         } catch(Exception e){
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
     public List<Item> getBestSellers(){
         List<Item> itemList = new ArrayList<Item>();
         try {
             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());
                 itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
     public List<Item> getLatestArrivals(){
         List<Item> itemList = new ArrayList<Item>();
         try {
             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());
                 itemList.add(getItemFromThriftItem(thriftItem, null, null));
+            }
             e.printStackTrace();
+        }
         Collections.sort(itemList, new ItemsComparator());
         return itemList;
+    }
     public Item getItem(long itemId){
         try{
             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, vim);
         }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();
+        }
         return null;
+    }
     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, VendorItemMapping> vItemMap = new HashMap<Long, VendorItemMapping>();
+        Map<String, VendorItemMapping> vItemMap = new HashMap<String, VendorItemMapping>();
         VendorItemMapping vItemMapping;
         if(tVendorMappings != null) {
             for(in.shop2020.model.v1.catalog.VendorItemMapping vim : tVendorMappings) {
                 vItemMapping = new VendorItemMapping();
                 vItemMapping.setVendorId(vim.getVendorId());
                 vItemMapping.setItemKey(vim.getItemKey());
-                vItemMap.put(vItemMapping.getVendorId(), vItemMapping);
+                vItemMap.put(vItemMapping.getVendorId() + Item.KEY_SEPARATOR + vim.getItemKey(), vItemMapping);
+            }
+        }
         // TODO: For testing. Remove this code before moving to production.
         /*
         Map<Long, VendorItemMapping> vItemMap = new HashMap<Long, VendorItemMapping>();
         vItemMap.put(1L, new VendorItemMapping(1, "Item Key Test 1"));
         vItemMap.put(1L, new VendorItemMapping(1, "Item Key Test 2"));
-        */
+         */
         Map<Long, VendorPricings> vendorPricingMap = new HashMap<Long, VendorPricings>();
         VendorPricings vPricings;
         if(tVendorPricings != null) {
             for(in.shop2020.model.v1.catalog.VendorItemPricing vip : tVendorPricings) {
                 vPricings = new VendorPricings();
                 vPricings.setDealerPrice(vip.getDealerPrice());
                 vPricings.setTransferPrice(vip.getTransferPrice());
                 vendorPricingMap.put(vPricings.getVendorId(), vPricings);
+            }
+        }
         Item item = new Item(thriftItem.getId(),
                 thriftItem.getProductGroup(),
                 thriftItem.getBrand(),
                 thriftItem.getModelNumber(),
                 thriftItem.getModelName(),
                 thriftItem.getStartDate(),
                 thriftItem.getRetireDate(),
                 thriftItem.getUpdatedOn(),
                 thriftItem.getItemStatus().name(),
                 thriftItem.getItemStatus().getValue(),
+                thriftItem.getStatus_description(),
                 thriftItem.getOtherInfo(),
                 thriftItem.getBestDealText(),
                 thriftItem.isSetBestDealValue() ? thriftItem.getBestDealValue() : -1,
                 thriftItem.isSetBestSellingRank() ? thriftItem.getBestSellingRank() : -1,
                 thriftItem.isDefaultForEntity(),
                 thriftItem.isRisky(),
                 (thriftItem.getItemInventory() != null ? thriftItem.getItemInventory().getAvailability() : null),
                 vendorPricingMap,
-                vItemMap
+                vItemMap);
-                );
         return item;
+    }
     @Override
     public boolean updateItem(Item item) {
         GWT.log("Got a call to update item, Item Id: " + item.getId());
         try{
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             in.shop2020.model.v1.catalog.Item tItem = catalogClient.getItem(item.getId());
             setThriftItemParams(tItem, item);
-//          tItem.setAddedOn(item.getAddedOn());
+            //          tItem.setAddedOn(item.getAddedOn());
-//          tItem.setCatalogItemId(item.getCatalogItemId());
+            //          tItem.setCatalogItemId(item.getCatalogItemId());
-//          tItem.setCategory(item.getCategory());
+            //          tItem.setCategory(item.getCategory());
-//          tItem.setFeatureId(item.getFeatureId());
+            //          tItem.setFeatureId(item.getFeatureId());
-//          tItem.setFeatureDescription(item.getFeatureDescription());
+            //          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, VendorItemMapping> vendorMappings = item.getVendorMappingsMap();
+            Map<String, VendorItemMapping> vendorMappings = item.getVendorKeysMap();
             if(vendorMappings != null && !vendorMappings.isEmpty()) {
                 in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;
-                for(VendorItemMapping v : vendorMappings.values()) {
+                for(Entry<String, VendorItemMapping> e : vendorMappings.entrySet()) {
                     tVendorMapping = new in.shop2020.model.v1.catalog.VendorItemMapping();
+                    VendorItemMapping v = e.getValue();
                     tVendorMapping.setVendorId(v.getVendorId());
                     tVendorMapping.setItemKey(v.getItemKey());
                     tVendorMapping.setItemId(item.getId());
                     tVendorMapping.setVendorCategory(item.getVendorCategory());
-                    catalogClient.addVendorItemMapping(tVendorMapping);
+                    catalogClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
                     GWT.log("VendorItemMapping updated. " + tVendorMapping.getVendorId() + ", " + tVendorMapping.getItemId() + ", " +
                             tVendorMapping.getItemKey() + ", " + tVendorMapping.getVendorCategory());
+                }
+            }
             Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
             if(vendorPricings != null && !vendorPricings.isEmpty()) {
                 in.shop2020.model.v1.catalog.VendorItemPricing tVendorPricing;
                 for(VendorPricings v : vendorPricings.values()) {
                     tVendorPricing = new in.shop2020.model.v1.catalog.VendorItemPricing();
                     catalogClient.addVendorItemPricing(tVendorPricing);
                     GWT.log("VendorItemPricing updated. " + tVendorPricing.getVendorId() + ", " + tVendorPricing.getItemId() + ", " +
                             tVendorPricing.getMop() + ", " + tVendorPricing.getTransferPrice() + ", " + tVendorPricing.getDealerPrice());
+                }
+            }
         }catch(Exception e){
             e.printStackTrace();
+        }
         return true;
+    }
     @Override
     public Map<Long, String> getAllVendors() {
         Map<Long, String> vendorMap = new HashMap<Long, String>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Vendor> vendors = catalogClient.getAllVendors();
             for(in.shop2020.model.v1.catalog.Vendor v : vendors) {
                 vendorMap.put(v.getId(), v.getName());
+            }
         } catch (Exception e) {
             e.printStackTrace();
     public Map<Long, String> getAllWarehouses() {
         Map<Long, String> warehouseMap = new HashMap<Long, String>();
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             List<in.shop2020.model.v1.catalog.Warehouse> warehouses = catalogClient.getAllWarehouses(true);
             for(in.shop2020.model.v1.catalog.Warehouse w : warehouses) {
                 warehouseMap.put(w.getId(), w.getDisplayName());
+            }
         } catch (Exception e) {
             e.printStackTrace();
         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();
             setThriftItemParams(tItem, item);
             itemId = catalogClient.addItem(tItem);
             Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
                     tVendorPricing.setTransferPrice(v.getTransferPrice());
                     tVendorPricing.setDealerPrice(v.getDealerPrice());
                     catalogClient.addVendorItemPricing(tVendorPricing);
+                }
+            }
-            Map<Long, VendorItemMapping> vendorKeysMap = item.getVendorMappingsMap();
+            Map<String, VendorItemMapping> vendorKeysMap = item.getVendorKeysMap();
             if(vendorKeysMap != null && !vendorKeysMap.isEmpty()) {
                 in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;
-                for(VendorItemMapping v : vendorKeysMap.values()) {
+                for(Entry<String, VendorItemMapping> e : vendorKeysMap.entrySet()) {
                     tVendorMapping = new in.shop2020.model.v1.catalog.VendorItemMapping();
+                    VendorItemMapping v = e.getValue();
                     tVendorMapping.setVendorId(v.getVendorId());
                     tVendorMapping.setItemKey(v.getItemKey());
                     tVendorMapping.setItemId(itemId);
                     tVendorMapping.setVendorCategory(item.getVendorCategory());
-                    catalogClient.addVendorItemMapping(tVendorMapping);
+                    catalogClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
+                }
+            }
         } catch (Exception e) {
             e.printStackTrace();
+        }
         return itemId;
+    }
     @Override
     public long checkSimilarItem(String productGroup, String brand, String modelNumber, String color) {
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             return catalogClient.checkSimilarItem(productGroup, brand, modelNumber, color);
         } catch (Exception e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
+        }
         return 0;
+    }
     private void setThriftItemParams(in.shop2020.model.v1.catalog.Item tItem, Item item) {
         tItem.setId(tItem.getId());
         tItem.setProductGroup(item.getProductGroup());
         tItem.setBrand(item.getBrand());
         tItem.setModelName(item.getModelName());
         tItem.setModelNumber(item.getModelNumber());
         tItem.setColor(item.getColor());
+        tItem.setStatus_description(item.getItemStatusDesc());
         tItem.setComments(item.getComments());
         if(item.getMrp() != -1) {
             tItem.setMrp(item.getMrp());
         } else {
             tItem.setMrpIsSet(false);
+        }
         if(item.getWeight() != -1) {
             tItem.setWeight(item.getWeight());
         } else {
             tItem.setWeightIsSet(false);
+        }
         tItem.setMop(item.getMop());
         tItem.setDealerPrice(item.getDealerPrice());
         tItem.setTransferPrice(item.getTransferPrice());
         tItem.setBestDealText(item.getBestDealsText());
         } else {
             tItem.setBestSellingRankIsSet(false);
+        }
         tItem.setDefaultForEntity(item.isDefaultForEntity());
         tItem.setRisky(item.isRisky());
         tItem.setStartDate(item.getStartDate());
         tItem.setUpdatedOn(Calendar.getInstance().getTimeInMillis());
         tItem.setRetireDate(item.getRetireDate());
         tItem.setHotspotCategory(item.getVendorCategory());
+    }
     @Override
     public void pauseItem(long itemId) {
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PAUSED);
         } catch (Exception e) {
             e.printStackTrace();
+        }
+    }
     @Override
     public void markInProcess(long itemId) {
         try {
             CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
             InventoryService.Client catalogClient = catalogServiceClient.getClient();
             catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.IN_PROCESS);
         } catch (Exception e) {
             e.printStackTrace();
+        }
+    }
     @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 void uploadItems(String filename, long vendorId, String category, boolean fullUpdate, boolean dryRun, String suppliedProductGroup) {
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            InventoryService.Client catalogClient = catalogServiceClient.getClient();
+            catalogClient.runItemLoader(filename, vendorId, category, fullUpdate, dryRun, suppliedProductGroup);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }*/
+    @Override
+    public boolean changeItemRiskyFlag(long itemId, boolean risky) {
+        try {
+            // Initialize client for staging server
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            InventoryService.Client catalogClient = catalogServiceClient.getClient();
+            // Initialize client for production server
+            CatalogServiceClient catalogServiceClient_Prod = new CatalogServiceClient(CatalogServiceClient.class.getSimpleName(),
+                    ConfigClientKeys.catalog_service_server_host_prod.toString(),
+                    ConfigClientKeys.catalog_service_server_port.toString());
+            InventoryService.Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
+            catalogClient.changeItemRiskyFlag(itemId, risky);
+            try{
+                catalogClient_Prod.changeItemRiskyFlag(itemId, risky);
+            }catch(Exception e){
+                e.printStackTrace();
+                // If not able to change risky flag on production, revert on staging and return false (to show error to user).
+                catalogClient.changeItemRiskyFlag(itemId, !risky);
+                return false;
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+        return true;
+    }
+    List<Item> getItemsByVendorCategory(String category) {
+        List<Item> itemList = new ArrayList<Item>();
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            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());
+                itemList.add(getItemFromThriftItem(thriftItem, vip, vim));
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        Collections.sort(itemList, new ItemsComparator());
+        return itemList;
+    }
+    List<Item> getItemsByStatus(status st) {
+        List<Item> itemList = new ArrayList<Item>();
+        try {
+            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();
+            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));
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        Collections.sort(itemList, new ItemsComparator());
+        return itemList;
+    }
+    @Override
+    public boolean updateItemOnProduction(Item item) {
+        GWT.log("Update item on production, Item Id: " + item.getId());
+        try{
+            CatalogServiceClient catalogServiceClient_Prod = new CatalogServiceClient(CatalogServiceClient.class.getSimpleName(),
+                    ConfigClientKeys.catalog_service_server_host_prod.toString(),
+                    ConfigClientKeys.catalog_service_server_port.toString());
+            //for testing, put catalog_service_server_port_test in shop2020.cfg
+            /*CatalogServiceClient catalogServiceClient_Prod = new CatalogServiceClient(CatalogServiceClient.class.getSimpleName(),
+                    ConfigClientKeys.catalog_service_server_host.toString(), "catalog_service_server_port_test");*/
+            InventoryService.Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
+            in.shop2020.model.v1.catalog.Item tItem = catalogClient_Prod.getItem(item.getId());
+            if(item.getMrp() != -1) {
+                tItem.setMrp(item.getMrp());
+            } else {
+                tItem.setMrpIsSet(false);
+            }
+            if(item.getSellingPrice() != -1) {
+                tItem.setSellingPrice(item.getSellingPrice());
+            } else {
+                tItem.setSellingPriceIsSet(false);
+            }
+            if(item.getMop() != -1) {
+                tItem.setMop(item.getMop());
+            } else {
+                tItem.setMopIsSet(false);
+            }
+            if(item.getDealerPrice() != -1) {
+                tItem.setDealerPrice(item.getDealerPrice());
+            } else {
+                tItem.setDealerPriceIsSet(false);
+            }
+            if(item.getTransferPrice() != -1) {
+                tItem.setTransferPrice(item.getTransferPrice());
+            } else {
+                tItem.setTransferPriceIsSet(false);
+            }
+            long rItemId;
+            if((rItemId = catalogClient_Prod.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, VendorPricings> vendorPricings = item.getVendorPricesMap();
+            if(vendorPricings != null && !vendorPricings.isEmpty()) {
+                in.shop2020.model.v1.catalog.VendorItemPricing tVendorPricing;
+                for(VendorPricings v : vendorPricings.values()) {
+                    tVendorPricing = new in.shop2020.model.v1.catalog.VendorItemPricing();
+                    tVendorPricing.setVendorId(v.getVendorId());
+                    tVendorPricing.setItemId(item.getId());
+                    tVendorPricing.setMop(v.getMop());
+                    tVendorPricing.setTransferPrice(v.getTransferPrice());
+                    tVendorPricing.setDealerPrice(v.getDealerPrice());
+                    catalogClient_Prod.addVendorItemPricing(tVendorPricing);
+                    GWT.log("VendorItemPricing updated. " + tVendorPricing.getVendorId() + ", " + tVendorPricing.getItemId() + ", " +
+                            tVendorPricing.getMop() + ", " + tVendorPricing.getTransferPrice() + ", " + tVendorPricing.getDealerPrice());
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+        return true;
+    }
+}

Subversion Repositories SmartDukaan

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