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.model.v1.catalog.InventoryService;

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

import in.shop2020.thrift.clients.CatalogServiceClient;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

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

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

            }

        } catch (Exception e) {

            e.printStackTrace();

        }

        return itemList;

    }

    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.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, vip));

            }

        } catch(Exception e){

            e.printStackTrace();

        }

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

            }

        } catch(Exception e){

            e.printStackTrace();

        }

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

            }

        } catch(Exception e){

            e.printStackTrace();

        }

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

            return getItemFromThriftItem(thriftItem, vip);

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

    }

    public void reduceReservationCount(long itemId, long warehouseId, double quantity){

        GWT.log("Got a call to reduce the reservation count for item " + itemId + " and warehouse " + warehouseId);

        try{

            CatalogServiceClient catalogServiceClient = new CatalogServiceClient();

            InventoryService.Client catalogClient = catalogServiceClient.getClient();

            catalogClient.reduceReservationCount(itemId, warehouseId, quantity);

        }catch(Exception e){

            // TODO: Oops! We couldn't reduce the item reservation count. This will

            // result in underestimation of inventory stock. Should be corrected

            // periodically.

            e.printStackTrace();

        }

    }

    private Item getItemFromThriftItem(in.shop2020.model.v1.catalog.Item thriftItem, List<in.shop2020.model.v1.catalog.VendorItemPricing> thriftItemPricings){

        Map<Long, double[]> vendorPricings = new HashMap<Long, double[]>();

        double[] prices;

        if(thriftItemPricings != null) {

            for(VendorItemPricing v : thriftItemPricings) {

                prices = new double[3];

                prices[0] = v.getMop();

                prices[1] = v.getDealerPrice();

                prices[2] = v.getTransferPrice();

                vendorPricings.put(v.getVendorId(), prices);

            }

        }

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

                thriftItem.getProductGroup(),

                thriftItem.getBrand(),

                thriftItem.getModelNumber(),

                thriftItem.getModelName(),

                thriftItem.getColor(),

                thriftItem.getCategory(),

                thriftItem.getComments(),

                thriftItem.getCatalogItemId(),

                thriftItem.getFeatureId(),

                thriftItem.getFeatureDescription(),

                thriftItem.getMrp(),

                thriftItem.getMop(),

                thriftItem.getSellingPrice(),

                thriftItem.getDealerPrice(),

                thriftItem.getWeight(),

                thriftItem.getAddedOn(),

                thriftItem.getStartDate(),

                thriftItem.getRetireDate(),

                thriftItem.getUpdatedOn(),

                thriftItem.getItemStatus().name(),

                thriftItem.getOtherInfo(),

                thriftItem.getBestDealText(),

                thriftItem.getBestDealValue(),

                (thriftItem.getItemInventory() != null ? thriftItem.getItemInventory().getAvailability() : null),

                vendorPricings

                );

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

//            tItem.setAddedOn(item.getAddedOn());

//            tItem.setBestDealText(item.getBestDealsText());

//            tItem.setBrand(item.getBrand());

//            tItem.setCatalogItemId(item.getCatalogItemId());

//            tItem.setCategory(item.getCategory());

//            tItem.setColor(item.getColor());

//            tItem.setComments(item.getComments());

//            tItem.setDealerPrice(item.getDealerPrice()); 

//            tItem.setFeatureId(item.getFeatureId());

//            tItem.setFeatureDescription(item.getFeatureDescription());

//            tItem.setModelName(item.getModelName());

//            tItem.setModelNumber(item.getModelNumber());

            tItem.setMrp(item.getMrp());

//            tItem.setMop(item.getMop());

            tItem.setSellingPrice(item.getSellingPrice());

//            tItem.setTransferPrice(item.getTransferPrice());

            tItem.setWeight(item.getWeight());

            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;

            //TODO: update left out fields of item also. Also update vendor prices and availability.

        }catch(Exception e){

            e.printStackTrace();

        }

        return false;

    }

}