Subversion Repositories SmartDukaan

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.ItemInventory;

import in.shop2020.catalog.dashboard.shared.ItemStatus;

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.content.ContentService;

import in.shop2020.content.ContentServiceException;

import in.shop2020.model.v1.catalog.InventoryService;

import in.shop2020.model.v1.catalog.SourceItemPricing;

import in.shop2020.model.v1.catalog.status;

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.ContentClient;

import in.shop2020.thrift.clients.config.ConfigClient;

import in.shop2020.utils.CategoryManager;

import in.shop2020.utils.ConfigClientKeys;

import java.io.BufferedReader;

import java.io.FileReader;

import java.io.IOException;

import java.text.DateFormat;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Collections;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import org.apache.log4j.Logger;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

import com.google.gwt.user.server.rpc.RemoteServiceServlet;

@SuppressWarnings("serial")

public class CatalogServiceImpl extends RemoteServiceServlet implements CatalogService {

    private static Logger logger = Logger.getLogger(CatalogServiceImpl.class);

    private static Logger pushToProdLogger = Logger.getLogger("pushToProdLogger");

    private static Date pushToProdDate;

    private static String logFile;

    private static int maxCount;

    static {

        try {

            logFile = ConfigClient.getClient().get(ConfigClientKeys.push_prices_to_prod_log_file.toString());

            maxCount = Integer.parseInt(ConfigClient.getClient().get(ConfigClientKeys.push_prices_to_prod_max_count.toString()));    

        } catch(ConfigException ce) {

            logger.error("Unable to connect to the config server. Setting sensible defaults.", ce);

            logFile = "/var/log/services/pushToProductionCount/pushToProd.log";

            maxCount = 5;

        }

    }

    @Override

    public int getItemCountByStatus(boolean useStatus, ItemStatus itemStatus){

        int count = 0;

        try{

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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);

        }

        return count;

    }

    @Override

    public List<Item> getAllItems(int start, int limit) {

        List<Item> itemList = new ArrayList<Item>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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));

            }

        } catch (Exception e) {

            logger.error("Error while getting all items from the catalog service", e);

        }

        return itemList;

    }

    public List<Item> getAllActiveItems(int start, int limit){

        return getItemsByStatus(status.ACTIVE, start, limit);

    }

    @Override

    public List<Item> getAllPhasedOutItems(int start, int limit){

        return getItemsByStatus(status.PHASED_OUT, start, limit);

    }

    @Override

    public List<Item> getAllPausedItems(int start, int limit){

        return getItemsByStatus(status.PAUSED, start, limit);

    }

    @Override

    public List<Item> getAllInProcessItems(int start, int limit) {

        return getItemsByStatus(status.IN_PROCESS, start, limit);

    }

    @Override

    public List<Item> getAllContentCompleteItems(int start, int limit) {

        return getItemsByStatus(status.CONTENT_COMPLETE, start, limit);

    }

    public List<Item> getBestDeals(){

        List<Item> itemList = new ArrayList<Item>();

        try {

            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, null, null));

            }

        } catch(Exception e){

            logger.error("Error while getting the best deals from the catalog service", e);

        }

        //Collections.sort(itemList, new ItemsComparator());

        return itemList;

    }

    @Override

    public List<Item> getRiskyItems() {

        List<Item> itemList = new ArrayList<Item>();

        try {

            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, null, null));

            }

        } catch(Exception e){

            logger.error("Error while getting the risky items from the catalog service", e);

        }

        Collections.sort(itemList, new ItemsComparator());

        return itemList;

    }

    public List<Item> getBestSellers(){

        List<Item> itemList = new ArrayList<Item>();

        try {

            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, null, null));

            }

        } catch(Exception e){

            logger.error("Error while getting the best sellers from the catalog service", e);

        }

        return itemList;        

    }

    @Override

    public List<Item> getLatestArrivals(){

        List<Item> itemList = new ArrayList<Item>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            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, null, null));

            }

        } catch(Exception e){

            logger.error("Error while getting the latest arrivals from the catalog service", e);

        }

        return itemList;

    }

    @Override

    public List<Item> searchItems(int start, int limit, List<String> searchTerms) {

        List<Item> itemList = new ArrayList<Item>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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));

            }

        } catch(Exception e){

            logger.error("Error while getting the search results from the catalog service", e);

        }

        return itemList;

    }

    @Override

    public int getSearchResultCount(List<String> searchTerms){

        int count = 0;

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            count = catalogClient.getSearchResultCount(searchTerms);

        } catch(Exception e){

            logger.error("Error while getting the search results from the catalog service", e);

        }

        return count;

    }

    public Item getItem(long itemId){

        try{

            CatalogClient catalogServiceClient = new CatalogClient();

            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());

            List<in.shop2020.model.v1.catalog.Item> sit = catalogClient.getAllSimilarItems(thriftItem.getId());

            return getItemFromThriftItem(thriftItem, vip, vim, sip, sit);

        }catch(Exception e){

            logger.error("Error while getting the item from the catalog service", e);

        }

        return null;

    }

    @Override

    public boolean updateItem(Item item) {

        logger.info("Updating item with Id: " + item.getId());

        try{

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.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.error("Error updating item, returned Item Id: " + rItemId);

                return false;

            }

            logger.info("Successfully updated item with id: " + item.getId());

            Map<String, VendorItemMapping> vendorMappings = item.getVendorKeysMap();

            if(vendorMappings != null && !vendorMappings.isEmpty()) {

                in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;

                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());

                    catalogClient.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.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.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;

    }

    @Override

    public Map<Long, String> getAllVendors() {

        Map<Long, String> vendorMap = new HashMap<Long, String>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            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) {

            logger.error("Error while getting all the vendors: ", e);

        }

        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.Warehouse> warehouses = catalogClient.getAllWarehouses(true);

            for(in.shop2020.model.v1.catalog.Warehouse w : warehouses) {

                warehouseMap.put(w.getId(), w.getDisplayName());

            }

        } catch (Exception e) {

            logger.error("Error while getting all the warehouses:", e );

        }

        return warehouseMap;

    }

    @Override

    public long addItem(Item item) {

        long itemId = 0;

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            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();

            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(itemId);

                    tVendorPricing.setMop(v.getMop());

                    tVendorPricing.setTransferPrice(v.getTransferPrice());

                    tVendorPricing.setDealerPrice(v.getDealerPrice());

                    catalogClient.addVendorItemPricing(tVendorPricing);

                }

            }

            Map<String, VendorItemMapping> vendorKeysMap = item.getVendorKeysMap();

            if(vendorKeysMap != null && !vendorKeysMap.isEmpty()) {

                in.shop2020.model.v1.catalog.VendorItemMapping tVendorMapping;

                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);

                    catalogClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);

                }

            }

        } catch (Exception e) {

            logger.error("Error while adding an item: ", e);

        }

        return itemId;

    }

    @Override

    public long checkSimilarItem(String brand, String modelNumber, String modelName, String color) {

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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;

    }

    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() != null) {

            tItem.setMrp(item.getMrp());

        }

        if(item.getSellingPrice() != null) {

            tItem.setSellingPrice(item.getSellingPrice());

        }

        if(item.getWeight() != null) {

            tItem.setWeight(item.getWeight());

        }

        if(item.getExpectedDelay() != null) {

            tItem.setExpectedDelay(item.getExpectedDelay());

        }

        if(item.getPreferredWarehouse() != null) {

            tItem.setPreferredWarehouse(item.getPreferredWarehouse());

        }

        if(item.getDefaultWarehouse() != null) {

            tItem.setDefaultWarehouse(item.getDefaultWarehouse());

        }

        tItem.setIsWarehousePreferenceSticky(item.isWarehouseStickiness());

        if(item.getPreferredVendor() != null) {

            tItem.setPreferredVendor(item.getPreferredVendor());

        }

        tItem.setBestDealText(item.getBestDealsText());

        if(item.getBestDealsValue() != null) {

            tItem.setBestDealValue(item.getBestDealsValue());

        }

        if(item.getBestSellingRank() != null) {

            tItem.setBestSellingRank(item.getBestSellingRank());

        }

        tItem.setDefaultForEntity(item.isDefaultForEntity());

        tItem.setRisky(item.isRisky());

        if(item.getStartDate() != null) {

            tItem.setStartDate(item.getStartDate());

        }

        if(item.getRetireDate() != null) {

            tItem.setRetireDate(item.getRetireDate());

        }

        tItem.setUpdatedOn(Calendar.getInstance().getTimeInMillis());

    }

    @Override

    public void pauseItem(long itemId) {

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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();

            InventoryService.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();

            InventoryService.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();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.ACTIVE);

        } catch (Exception e) {

            logger.error("Error while activating the item: " + itemId, e);

        }

    }

    @Override

    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();

            InventoryService.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());

            InventoryService.Client catalogClient_Prod = catalogServiceClient_Prod.getClient();

            catalogClient.changeItemRiskyFlag(itemId, risky);

            try{

                catalogClient_Prod.changeItemRiskyFlag(itemId, risky);

            }catch(Exception e){

                logger.error("Error while updating item's risky flag on production", e);

                // 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) {

            logger.error("Error while updating item's risky flag on staging", e);

            return false;

        }

        return true;

    }

    /**

     * Retuns list of Items filtered by category (column is product_group in catalog.item table)

     * This list is used to generate master sheet (excel sheet)

     * @param category

     * @return

     */

    public List<Item> getItemsByCategory(String category) {

        List<Item> itemList = new ArrayList<Item>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByCategory(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, sip, null));

            }

        } catch (Exception e) {

            logger.error("Error while getting items by category: " + category, e);

        }

        Collections.sort(itemList, new ItemsComparator());

        return itemList;

    }

    @Override

    public String updateItemOnProduction(Item item) {

        logger.info("Update item on production call, Item Id: " + item.getId());

        if(!canPushToProduction()) {

            // If we can't push to production, then return that message to user

            // else move forward with update.

            return "Maximum push to production count reached for today";

        }

        try{

            CatalogClient catalogServiceClient_Prod = new CatalogClient( 

                    ConfigClientKeys.catalog_service_server_host_prod.toString(),

                    ConfigClientKeys.catalog_service_server_port.toString());

            InventoryService.Client catalogClient_Prod = catalogServiceClient_Prod.getClient();

            in.shop2020.model.v1.catalog.Item tItem = catalogClient_Prod.getItem(item.getId());

            if(item.getMrp() != null) {

                tItem.setMrp(item.getMrp());

            }

            if(item.getSellingPrice() != null) {

                tItem.setSellingPrice(item.getSellingPrice());

            }

            long rItemId;

            if((rItemId = catalogClient_Prod.updateItem(tItem)) != item.getId()) {

                logger.error("Error updating item on production, returned Item Id: " + rItemId);

                return "Error updating item prices on production";

            }

            logger.info("Successfully updated item: " + item.getId());

            StringBuilder sb = new StringBuilder();

            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);

                    logger.info("VendorItemPricing updated. " + tVendorPricing.toString());

                    sb.append("[VId:" + v.getVendorId() + ",MOP=" + v.getMop() + ",TP=" + v.getTransferPrice() + ",DP=" + v.getDealerPrice() + "], ");

                }

            }

            Map<Long, SourcePricings> sourcePricings = item.getSourcePricesMap();

            if(sourcePricings != null && !sourcePricings.isEmpty()){

                in.shop2020.model.v1.catalog.SourceItemPricing tSourcePricing;

                for(SourcePricings s : sourcePricings.values()){

                    tSourcePricing = new in.shop2020.model.v1.catalog.SourceItemPricing();

                    tSourcePricing.setSourceId(s.getSourceId());

                    tSourcePricing.setItemId(item.getId());

                    tSourcePricing.setMrp(s.getMrp());

                    tSourcePricing.setSellingPrice(s.getSellingPrice());

                    catalogClient_Prod.addSourceItemPricing(tSourcePricing);

                    logger.info("SourceItemPricing updated. " + tSourcePricing.toString());

                    sb.append("[SId:" + s.getSourceId() + ",MRP=" + s.getMrp() + ",SP=" + s.getSellingPrice() + "], ");

                }

            }

            pushToProdLogger.info("Id=" + item.getId() + ",MRP=" + item.getMrp() + ",SP=" + " " + item.getSellingPrice() + sb.toString());

        } catch (Exception e) {

            logger.error("Error while updating prices on production", e);

            return "Error while updating all prices on production. Some of the prices may have been  updated";

        }

        try {

            ContentClient contentServiceClient = new ContentClient();

            ContentService.Client contentClient = contentServiceClient.getClient();

            contentClient.pushContentToProduction(item.getCatalogItemId());

        } catch (TTransportException e) {

            logger.error("Error while establishing connection to the content server", e);

            return "Error generating content. Prices updated successfully.";

        } catch (TException e) {

            logger.error("Error while pushing content to production", e);

            return "Error generating content. Prices updated successfully.";

        } catch (ContentServiceException e) {

            logger.error("Error while pushing content to production", e);

            return "Error generating content. Prices updated successfully.";

        }

        return "Prices updated and content generated successfully";

    }

    /**

     * Returns list of items with a particular status.

     * @param st

     * @return

     */

    private List<Item> getItemsByStatus(status st, int start, int limit) {

        List<Item> itemList = new ArrayList<Item>();

        try {

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.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));

            }

        } catch (Exception e) {

            logger.error("Error while getting items by status: " + st, e);

        }

        return itemList;

    }

    /**

     * Creates a new Item object and populates its attributes from thrift item passed as parameter.

     * Also creates a Map each for VendorItemPricing, VendorItemMapping, SourceItemPricing and SimilarItems and adds these maps to the

     * new Item object.

     * @param thriftItem

     * @param tVendorPricings

     * @param tVendorMappings

     * @param tSourceMappings

     * @param tSimilarItems

     * @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.SourceItemPricing> tSourceMappings,

            List<in.shop2020.model.v1.catalog.Item> tSimilarItems){

        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() + Item.KEY_SEPARATOR + vim.getItemKey(), vItemMapping);

            }

        }

        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.setVendorId(vip.getVendorId());

                vPricings.setMop(vip.getMop());

                vPricings.setDealerPrice(vip.getDealerPrice());

                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);

            }

        }

        Map<Long, Item> SimilarItemslist = new HashMap<Long, Item>();

        Item sItems;

        if(tSimilarItems != null) {

            for(in.shop2020.model.v1.catalog.Item sit : tSimilarItems) {

            	sItems = new Item();

            	sItems.setCatalogItemId(sit.getCatalogItemId());

            	sItems.setProductGroup(sit.getProductGroup());

            	sItems.setBrand(sit.getBrand());

            	sItems.setModelNumber(sit.getModelNumber());

            	sItems.setModelName(sit.getModelName());

            	sItems.setContentCategory(CategoryManager.getCategoryManager().getCategoryLabel(sit.getCategory()));

            	SimilarItemslist.put(sit.getCatalogItemId(), sItems);

            }

        }

        Map<Long, ItemInventory> itemInventoryMap = new HashMap<Long, ItemInventory>();

        ItemInventory warehousedata;

        if(thriftItem.getItemInventory() != null) {

        	Map<Long, Long> availabilityMap = thriftItem.getItemInventory().getAvailability();

        	Map<Long, Long> reservedMap = thriftItem.getItemInventory().getReserved();

            for(Entry<Long, Long> availability : availabilityMap.entrySet()) {

            	warehousedata = new ItemInventory();

            	warehousedata.setWarehouseId(availability.getKey());

            	warehousedata.setAvailability(availability.getValue());

            	warehousedata.setReserved(reservedMap.get(availability.getKey()));

            	itemInventoryMap.put(warehousedata.getWarehouseId(), warehousedata);

            }

        }

        else {

        	itemInventoryMap = null;

        }

        Item item = new Item(thriftItem.getId(),

                thriftItem.getProductGroup(),

                thriftItem.getBrand(),

                thriftItem.getModelNumber(),

                thriftItem.getModelName(),

                thriftItem.getColor(),

                CategoryManager.getCategoryManager().getCategoryLabel(thriftItem.getCategory()),

                thriftItem.getCategory(),

                thriftItem.getComments(),

                thriftItem.getCatalogItemId(),

                thriftItem.getFeatureId(),

                thriftItem.getFeatureDescription(),

                thriftItem.isSetMrp() ? thriftItem.getMrp() : null,

                thriftItem.isSetSellingPrice() ? thriftItem.getSellingPrice() : null,

                thriftItem.isSetWeight() ? thriftItem.getWeight() : null,

                thriftItem.getAddedOn(),

                thriftItem.getStartDate(),

                thriftItem.getRetireDate(),

                thriftItem.getUpdatedOn(),

                thriftItem.getItemStatus().name(),

                thriftItem.getItemStatus().getValue(),

                thriftItem.getStatus_description(),

                thriftItem.getOtherInfo(),

                thriftItem.getBestDealText(),

                thriftItem.isSetBestDealValue() ? thriftItem.getBestDealValue() : null,

                thriftItem.isSetBestSellingRank() ? thriftItem.getBestSellingRank() : null,

                thriftItem.isDefaultForEntity(),

                thriftItem.isRisky(),

                thriftItem.isSetExpectedDelay() ? thriftItem.getExpectedDelay() : null,

                thriftItem.isSetPreferredWarehouse() ? thriftItem.getPreferredWarehouse() : null,

                thriftItem.isSetDefaultWarehouse() ? thriftItem.getDefaultWarehouse() : null,

                thriftItem.isIsWarehousePreferenceSticky(),

                thriftItem.isSetPreferredVendor() ? thriftItem.getPreferredVendor() : null,

                itemInventoryMap,

                vendorPricingMap,

                vItemMap,

                sourcePricingMap,

                SimilarItemslist);

        return item;

    }

    /**

     * 

     * @return True if push to production count is less than maximum allowed.

     */

    private boolean canPushToProduction() {

        int count = getPushToProdCount(logFile);

        return count < maxCount;

    }

    /**

     * If this is the first attempt to push to production for current date, returns 0

     * else reads number of lines from daily rolling log file to get the count.

     * @return push to production count for current date

     */

    private int getPushToProdCount(String logfile) {

        // logfile is "/var/log/services/pushToProductionCount/pushToProd.log"

        // this should also be set in log4j.properties

        int lineCount = 0;

        DateFormat dateFormat = new SimpleDateFormat("dd/MM/yyyy");

        Date currentDate = Calendar.getInstance().getTime();

        if(pushToProdDate == null ||  !dateFormat.format(pushToProdDate).equals(dateFormat.format(currentDate))) {

            pushToProdDate = currentDate;

            return lineCount;

        }

        try {

            BufferedReader br = new BufferedReader(new FileReader(logfile));

            while (br.readLine() != null) {

                lineCount++;

            }

        } catch (IOException e) {

            logger.error("Error while reading the log file", e);

        }

        return lineCount;

    }

	@Override

	public boolean deleteSimilarItem(long itemId, long catalogItemId) {

		try{

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            return catalogClient.deleteSimilarItem(itemId, catalogItemId);

        }catch(Exception e){

            logger.error("Error while deleting the SimilarItems for: " + itemId, e);

        }

        return false;

	}

	@Override

	public Item addSimilarItem(long itemId, long catalogItemId) {

		try{

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.addSimilarItem(itemId, catalogItemId);;

            return getItemFromThriftItem(thriftItem, null, null, null, null);

        }catch(Exception e){

            logger.error("Error while adding the SimilarItems for: " + itemId, e);

        }

        return null;

	}

	@Override

	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());

            InventoryService.Client catalogClient_Prod = catalogServiceClient_Prod.getClient();

            in.shop2020.model.v1.catalog.ItemInventory thriftItemInventory = catalogClient_Prod.getItemInventoryByItemId(itemId);

            Map<Long, ItemInventory> itemInventoryMap = new HashMap<Long, ItemInventory>();

            ItemInventory warehousedata;

            if(thriftItemInventory != null) {

            	Map<Long, Long> availabilityMap = thriftItemInventory.getAvailability();

            	Map<Long, Long> reservedMap = thriftItemInventory.getReserved();

                for(Entry<Long, Long> availability : availabilityMap.entrySet()) {

                	warehousedata = new ItemInventory();

                	warehousedata.setWarehouseId(availability.getKey());

                	warehousedata.setAvailability(availability.getValue());

                	warehousedata.setReserved(reservedMap.get(availability.getKey()));

                	itemInventoryMap.put(warehousedata.getWarehouseId(), warehousedata);

                }

            }

            else {

            	itemInventoryMap = null;

            }

            return itemInventoryMap;

        } catch (Exception e) {

            logger.error("Error while updating item's risky flag on staging", e);

        }

		return null;

	}

	@Override

	public boolean addAuthorizationLog(long itemId, String username, String message) {

		try{

            CatalogClient catalogServiceClient = new CatalogClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            return catalogClient.addAuthorizationLog(itemId, username, message);

        }catch(Exception e){

            logger.error("Error while adding the event for: " + itemId, e);

        }

		return false;

	}

	@Override

	public Map<String, String> getConfigdataforPriceCompare() {

		Map<String, String> ConfigMap = new HashMap<String, String>();

		try {

			ConfigMap.put("courier_cost_factor", ConfigClient.getClient().get(ConfigClientKeys.courier_cost_factor.toString()));

            ConfigMap.put("courier_weight_factor", ConfigClient.getClient().get(ConfigClientKeys.courier_weight_factor.toString()));

            ConfigMap.put("breakeven_divisor", ConfigClient.getClient().get(ConfigClientKeys.breakeven_divisor.toString()));

            ConfigMap.put("breakeven_additon_factor", ConfigClient.getClient().get(ConfigClientKeys.breakeven_additon_factor.toString()));

            ConfigMap.put("transfer_price_percentage", ConfigClient.getClient().get(ConfigClientKeys.transfer_price_percentage.toString()));

            ConfigMap.put("transfer_price_factor", ConfigClient.getClient().get(ConfigClientKeys.transfer_price_factor.toString()));